Lines Matching refs:nxt_unit_read_buf_t

38 typedef struct nxt_unit_read_buf_s              nxt_unit_read_buf_t;  typedef
63 static int nxt_unit_process_msg(nxt_unit_ctx_t *ctx, nxt_unit_read_buf_t *rbuf,
93 static nxt_unit_read_buf_t *nxt_unit_read_buf_get(nxt_unit_ctx_t *ctx);
94 static nxt_unit_read_buf_t *nxt_unit_read_buf_get_impl(
97 nxt_unit_read_buf_t *rbuf);
125 nxt_port_mmap_header_t **hdr, nxt_unit_read_buf_t *rbuf);
127 nxt_unit_recv_msg_t *recv_msg, nxt_unit_read_buf_t *rbuf);
138 static int nxt_unit_read_buf(nxt_unit_ctx_t *ctx, nxt_unit_read_buf_t *rbuf);
142 nxt_inline int nxt_unit_is_read_queue(nxt_unit_read_buf_t *rbuf);
143 nxt_inline int nxt_unit_is_read_socket(nxt_unit_read_buf_t *rbuf);
144 nxt_inline int nxt_unit_is_shm_ack(nxt_unit_read_buf_t *rbuf);
145 nxt_inline int nxt_unit_is_quit(nxt_unit_read_buf_t *rbuf);
175 nxt_unit_read_buf_t *rbuf);
176 nxt_inline void nxt_unit_rbuf_cpy(nxt_unit_read_buf_t *dst,
177 nxt_unit_read_buf_t *src);
179 nxt_unit_read_buf_t *rbuf);
181 nxt_unit_read_buf_t *rbuf);
183 nxt_unit_read_buf_t *rbuf);
185 nxt_unit_read_buf_t *rbuf);
327 nxt_unit_read_buf_t ctx_read_buf;
399 nxt_unit_read_buf_t *socket_rbuf;
959 nxt_unit_process_msg(nxt_unit_ctx_t *ctx, nxt_unit_read_buf_t *rbuf, in nxt_unit_process_msg()
2768 static nxt_unit_read_buf_t *
2772 nxt_unit_read_buf_t *rbuf; in nxt_unit_read_buf_get()
2788 static nxt_unit_read_buf_t *
2792 nxt_unit_read_buf_t *rbuf; in nxt_unit_read_buf_get_impl()
2798 rbuf = nxt_container_of(link, nxt_unit_read_buf_t, link); in nxt_unit_read_buf_get_impl()
2803 rbuf = nxt_unit_malloc(&ctx_impl->ctx, sizeof(nxt_unit_read_buf_t)); in nxt_unit_read_buf_get_impl()
2815 nxt_unit_read_buf_t *rbuf) in nxt_unit_read_buf_release()
3634 nxt_unit_read_buf_t *rbuf; in nxt_unit_wait_shm_ack()
3993 nxt_unit_read_buf_t *rbuf; in nxt_unit_incoming_mmap()
4054 nxt_queue_each(rbuf, &awaiting_rbuf, nxt_unit_read_buf_t, link) { in nxt_unit_incoming_mmap()
4156 nxt_unit_read_buf_t *rbuf) in nxt_unit_check_rbuf_mmap()
4202 nxt_unit_read_buf_t *rbuf) in nxt_unit_mmap_read()
4564 nxt_unit_read_buf_t *rbuf; in nxt_unit_run_once_impl()
4595 nxt_unit_read_buf(nxt_unit_ctx_t *ctx, nxt_unit_read_buf_t *rbuf) in nxt_unit_read_buf()
4727 nxt_unit_read_buf_t *rbuf; in nxt_unit_process_pending_rbuf()
4748 nxt_queue_each(rbuf, &pending_rbuf, nxt_unit_read_buf_t, link) { in nxt_unit_process_pending_rbuf()
4839 nxt_unit_read_buf_t *rbuf; in nxt_unit_run_ctx()
4882 nxt_unit_is_read_queue(nxt_unit_read_buf_t *rbuf) in nxt_unit_is_read_queue()
4897 nxt_unit_is_read_socket(nxt_unit_read_buf_t *rbuf) in nxt_unit_is_read_socket()
4908 nxt_unit_is_shm_ack(nxt_unit_read_buf_t *rbuf) in nxt_unit_is_shm_ack()
4923 nxt_unit_is_quit(nxt_unit_read_buf_t *rbuf) in nxt_unit_is_quit()
4942 nxt_unit_read_buf_t *rbuf; in nxt_unit_run_shared()
4986 nxt_unit_read_buf_t *rbuf; in nxt_unit_dequeue_request()
5040 nxt_unit_read_buf_t *rbuf; in nxt_unit_process_port_msg_impl()
5169 nxt_unit_read_buf_t *rbuf; in nxt_unit_ctx_free()
5207 nxt_queue_each(rbuf, &ctx_impl->free_rbuf, nxt_unit_read_buf_t, link) in nxt_unit_ctx_free()
6019 nxt_unit_read_buf_t *rbuf) in nxt_unit_ctx_port_recv()
6129 nxt_unit_rbuf_cpy(nxt_unit_read_buf_t *dst, nxt_unit_read_buf_t *src) in nxt_unit_rbuf_cpy()
6140 nxt_unit_read_buf_t *rbuf) in nxt_unit_shared_port_recv()
6177 nxt_unit_read_buf_t *rbuf) in nxt_unit_port_recv()
6240 nxt_unit_port_queue_recv(nxt_unit_port_t *port, nxt_unit_read_buf_t *rbuf) in nxt_unit_port_queue_recv()
6254 nxt_unit_read_buf_t *rbuf) in nxt_unit_app_queue_recv()