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;
973 nxt_unit_process_msg(nxt_unit_ctx_t *ctx, nxt_unit_read_buf_t *rbuf, in nxt_unit_process_msg()
2782 static nxt_unit_read_buf_t *
2786 nxt_unit_read_buf_t *rbuf; in nxt_unit_read_buf_get()
2802 static nxt_unit_read_buf_t *
2806 nxt_unit_read_buf_t *rbuf; in nxt_unit_read_buf_get_impl()
2812 rbuf = nxt_container_of(link, nxt_unit_read_buf_t, link); in nxt_unit_read_buf_get_impl()
2817 rbuf = nxt_unit_malloc(&ctx_impl->ctx, sizeof(nxt_unit_read_buf_t)); in nxt_unit_read_buf_get_impl()
2829 nxt_unit_read_buf_t *rbuf) in nxt_unit_read_buf_release()
3648 nxt_unit_read_buf_t *rbuf; in nxt_unit_wait_shm_ack()
4007 nxt_unit_read_buf_t *rbuf; in nxt_unit_incoming_mmap()
4068 nxt_queue_each(rbuf, &awaiting_rbuf, nxt_unit_read_buf_t, link) { in nxt_unit_incoming_mmap()
4170 nxt_unit_read_buf_t *rbuf) in nxt_unit_check_rbuf_mmap()
4216 nxt_unit_read_buf_t *rbuf) in nxt_unit_mmap_read()
4578 nxt_unit_read_buf_t *rbuf; in nxt_unit_run_once_impl()
4609 nxt_unit_read_buf(nxt_unit_ctx_t *ctx, nxt_unit_read_buf_t *rbuf) in nxt_unit_read_buf()
4741 nxt_unit_read_buf_t *rbuf; in nxt_unit_process_pending_rbuf()
4762 nxt_queue_each(rbuf, &pending_rbuf, nxt_unit_read_buf_t, link) { in nxt_unit_process_pending_rbuf()
4853 nxt_unit_read_buf_t *rbuf; in nxt_unit_run_ctx()
4896 nxt_unit_is_read_queue(nxt_unit_read_buf_t *rbuf) in nxt_unit_is_read_queue()
4911 nxt_unit_is_read_socket(nxt_unit_read_buf_t *rbuf) in nxt_unit_is_read_socket()
4922 nxt_unit_is_shm_ack(nxt_unit_read_buf_t *rbuf) in nxt_unit_is_shm_ack()
4937 nxt_unit_is_quit(nxt_unit_read_buf_t *rbuf) in nxt_unit_is_quit()
4956 nxt_unit_read_buf_t *rbuf; in nxt_unit_run_shared()
5000 nxt_unit_read_buf_t *rbuf; in nxt_unit_dequeue_request()
5054 nxt_unit_read_buf_t *rbuf; in nxt_unit_process_port_msg_impl()
5183 nxt_unit_read_buf_t *rbuf; in nxt_unit_ctx_free()
5221 nxt_queue_each(rbuf, &ctx_impl->free_rbuf, nxt_unit_read_buf_t, link) in nxt_unit_ctx_free()
6033 nxt_unit_read_buf_t *rbuf) in nxt_unit_ctx_port_recv()
6143 nxt_unit_rbuf_cpy(nxt_unit_read_buf_t *dst, nxt_unit_read_buf_t *src) in nxt_unit_rbuf_cpy()
6154 nxt_unit_read_buf_t *rbuf) in nxt_unit_shared_port_recv()
6191 nxt_unit_read_buf_t *rbuf) in nxt_unit_port_recv()
6254 nxt_unit_port_queue_recv(nxt_unit_port_t *port, nxt_unit_read_buf_t *rbuf) in nxt_unit_port_queue_recv()
6268 nxt_unit_read_buf_t *rbuf) in nxt_unit_app_queue_recv()