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()
2783 static nxt_unit_read_buf_t *
2787 nxt_unit_read_buf_t *rbuf; in nxt_unit_read_buf_get()
2803 static nxt_unit_read_buf_t *
2807 nxt_unit_read_buf_t *rbuf; in nxt_unit_read_buf_get_impl()
2813 rbuf = nxt_container_of(link, nxt_unit_read_buf_t, link); in nxt_unit_read_buf_get_impl()
2818 rbuf = nxt_unit_malloc(&ctx_impl->ctx, sizeof(nxt_unit_read_buf_t)); in nxt_unit_read_buf_get_impl()
2830 nxt_unit_read_buf_t *rbuf) in nxt_unit_read_buf_release()
3649 nxt_unit_read_buf_t *rbuf; in nxt_unit_wait_shm_ack()
4008 nxt_unit_read_buf_t *rbuf; in nxt_unit_incoming_mmap()
4069 nxt_queue_each(rbuf, &awaiting_rbuf, nxt_unit_read_buf_t, link) { in nxt_unit_incoming_mmap()
4171 nxt_unit_read_buf_t *rbuf) in nxt_unit_check_rbuf_mmap()
4217 nxt_unit_read_buf_t *rbuf) in nxt_unit_mmap_read()
4579 nxt_unit_read_buf_t *rbuf; in nxt_unit_run_once_impl()
4610 nxt_unit_read_buf(nxt_unit_ctx_t *ctx, nxt_unit_read_buf_t *rbuf) in nxt_unit_read_buf()
4742 nxt_unit_read_buf_t *rbuf; in nxt_unit_process_pending_rbuf()
4763 nxt_queue_each(rbuf, &pending_rbuf, nxt_unit_read_buf_t, link) { in nxt_unit_process_pending_rbuf()
4854 nxt_unit_read_buf_t *rbuf; in nxt_unit_run_ctx()
4897 nxt_unit_is_read_queue(nxt_unit_read_buf_t *rbuf) in nxt_unit_is_read_queue()
4912 nxt_unit_is_read_socket(nxt_unit_read_buf_t *rbuf) in nxt_unit_is_read_socket()
4923 nxt_unit_is_shm_ack(nxt_unit_read_buf_t *rbuf) in nxt_unit_is_shm_ack()
4938 nxt_unit_is_quit(nxt_unit_read_buf_t *rbuf) in nxt_unit_is_quit()
4957 nxt_unit_read_buf_t *rbuf; in nxt_unit_run_shared()
5001 nxt_unit_read_buf_t *rbuf; in nxt_unit_dequeue_request()
5055 nxt_unit_read_buf_t *rbuf; in nxt_unit_process_port_msg_impl()
5184 nxt_unit_read_buf_t *rbuf; in nxt_unit_ctx_free()
5222 nxt_queue_each(rbuf, &ctx_impl->free_rbuf, nxt_unit_read_buf_t, link) in nxt_unit_ctx_free()
6034 nxt_unit_read_buf_t *rbuf) in nxt_unit_ctx_port_recv()
6144 nxt_unit_rbuf_cpy(nxt_unit_read_buf_t *dst, nxt_unit_read_buf_t *src) in nxt_unit_rbuf_cpy()
6155 nxt_unit_read_buf_t *rbuf) in nxt_unit_shared_port_recv()
6192 nxt_unit_read_buf_t *rbuf) in nxt_unit_port_recv()
6255 nxt_unit_port_queue_recv(nxt_unit_port_t *port, nxt_unit_read_buf_t *rbuf) in nxt_unit_port_queue_recv()
6269 nxt_unit_read_buf_t *rbuf) in nxt_unit_app_queue_recv()