Lines Matching refs:nxt_unit_ctx_t

47 nxt_inline void nxt_unit_ctx_use(nxt_unit_ctx_t *ctx);
48 nxt_inline void nxt_unit_ctx_release(nxt_unit_ctx_t *ctx);
61 static int nxt_unit_ready(nxt_unit_ctx_t *ctx, int ready_fd, uint32_t stream,
63 static int nxt_unit_process_msg(nxt_unit_ctx_t *ctx, nxt_unit_read_buf_t *rbuf,
65 static int nxt_unit_process_new_port(nxt_unit_ctx_t *ctx,
67 static int nxt_unit_ctx_ready(nxt_unit_ctx_t *ctx);
68 static int nxt_unit_process_req_headers(nxt_unit_ctx_t *ctx,
70 static int nxt_unit_process_req_body(nxt_unit_ctx_t *ctx,
75 static int nxt_unit_process_websocket(nxt_unit_ctx_t *ctx,
77 static int nxt_unit_process_shm_ack(nxt_unit_ctx_t *ctx);
79 nxt_unit_ctx_t *ctx);
83 nxt_unit_ctx_t *ctx);
85 static void nxt_unit_websocket_frame_free(nxt_unit_ctx_t *ctx,
87 static nxt_unit_mmap_buf_t *nxt_unit_mmap_buf_get(nxt_unit_ctx_t *ctx);
93 static nxt_unit_read_buf_t *nxt_unit_read_buf_get(nxt_unit_ctx_t *ctx);
96 static void nxt_unit_read_buf_release(nxt_unit_ctx_t *ctx,
102 static nxt_port_mmap_header_t *nxt_unit_mmap_get(nxt_unit_ctx_t *ctx,
104 static int nxt_unit_send_oosm(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port);
105 static int nxt_unit_wait_shm_ack(nxt_unit_ctx_t *ctx);
107 static nxt_port_mmap_header_t *nxt_unit_new_mmap(nxt_unit_ctx_t *ctx,
109 static int nxt_unit_shm_open(nxt_unit_ctx_t *ctx, size_t size);
110 static int nxt_unit_send_mmap(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port,
112 static int nxt_unit_get_outgoing_buf(nxt_unit_ctx_t *ctx,
115 static int nxt_unit_incoming_mmap(nxt_unit_ctx_t *ctx, pid_t pid, int fd);
117 static void nxt_unit_awake_ctx(nxt_unit_ctx_t *ctx,
123 static int nxt_unit_check_rbuf_mmap(nxt_unit_ctx_t *ctx,
126 static int nxt_unit_mmap_read(nxt_unit_ctx_t *ctx,
128 static int nxt_unit_get_mmap(nxt_unit_ctx_t *ctx, pid_t pid, uint32_t id);
129 static void nxt_unit_mmap_release(nxt_unit_ctx_t *ctx,
131 static int nxt_unit_send_shm_ack(nxt_unit_ctx_t *ctx, pid_t pid);
133 static nxt_unit_process_t *nxt_unit_process_get(nxt_unit_ctx_t *ctx, pid_t pid);
137 static int nxt_unit_run_once_impl(nxt_unit_ctx_t *ctx);
138 static int nxt_unit_read_buf(nxt_unit_ctx_t *ctx, nxt_unit_read_buf_t *rbuf);
139 static int nxt_unit_chk_ready(nxt_unit_ctx_t *ctx);
140 static int nxt_unit_process_pending_rbuf(nxt_unit_ctx_t *ctx);
141 static void nxt_unit_process_ready_req(nxt_unit_ctx_t *ctx);
146 static int nxt_unit_process_port_msg_impl(nxt_unit_ctx_t *ctx,
149 static nxt_unit_port_t *nxt_unit_create_port(nxt_unit_ctx_t *ctx);
151 static int nxt_unit_send_port(nxt_unit_ctx_t *ctx, nxt_unit_port_t *dst,
156 static nxt_unit_port_t *nxt_unit_add_port(nxt_unit_ctx_t *ctx,
158 static void nxt_unit_process_awaiting_req(nxt_unit_ctx_t *ctx,
160 static void nxt_unit_remove_port(nxt_unit_impl_t *lib, nxt_unit_ctx_t *ctx,
167 static void nxt_unit_quit(nxt_unit_ctx_t *ctx, uint8_t quit_param);
168 static int nxt_unit_get_port(nxt_unit_ctx_t *ctx, nxt_unit_port_id_t *port_id);
169 static ssize_t nxt_unit_port_send(nxt_unit_ctx_t *ctx,
172 static ssize_t nxt_unit_sendmsg(nxt_unit_ctx_t *ctx, int fd,
174 static int nxt_unit_ctx_port_recv(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port,
178 static int nxt_unit_shared_port_recv(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port,
180 static int nxt_unit_port_recv(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port,
184 static int nxt_unit_app_queue_recv(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port,
194 static int nxt_unit_request_hash_add(nxt_unit_ctx_t *ctx,
197 nxt_unit_ctx_t *ctx, uint32_t stream, int remove);
288 nxt_unit_ctx_t ctx;
426 nxt_unit_ctx_t *
432 nxt_unit_ctx_t *ctx; in nxt_unit_init()
726 nxt_unit_ctx_use(nxt_unit_ctx_t *ctx) in nxt_unit_ctx_use()
737 nxt_unit_ctx_release(nxt_unit_ctx_t *ctx) in nxt_unit_ctx_release()
942 nxt_unit_ready(nxt_unit_ctx_t *ctx, int ready_fd, uint32_t stream, int queue_fd) in nxt_unit_ready()
973 nxt_unit_process_msg(nxt_unit_ctx_t *ctx, nxt_unit_read_buf_t *rbuf, in nxt_unit_process_msg()
1182 nxt_unit_process_new_port(nxt_unit_ctx_t *ctx, nxt_unit_recv_msg_t *recv_msg) in nxt_unit_process_new_port()
1244 nxt_unit_ctx_ready(nxt_unit_ctx_t *ctx) in nxt_unit_ctx_ready()
1284 nxt_unit_process_req_headers(nxt_unit_ctx_t *ctx, nxt_unit_recv_msg_t *recv_msg, in nxt_unit_process_req_headers()
1414 nxt_unit_process_req_body(nxt_unit_ctx_t *ctx, nxt_unit_recv_msg_t *recv_msg) in nxt_unit_process_req_body()
1471 nxt_unit_ctx_t *ctx; in nxt_unit_request_check_response_port()
1621 nxt_unit_process_websocket(nxt_unit_ctx_t *ctx, nxt_unit_recv_msg_t *recv_msg) in nxt_unit_process_websocket()
1727 nxt_unit_process_shm_ack(nxt_unit_ctx_t *ctx) in nxt_unit_process_shm_ack()
1744 nxt_unit_request_info_get(nxt_unit_ctx_t *ctx) in nxt_unit_request_info_get()
1791 nxt_unit_ctx_t *ctx; in nxt_unit_request_info_release()
1858 nxt_unit_websocket_frame_get(nxt_unit_ctx_t *ctx) in nxt_unit_websocket_frame_get()
1913 nxt_unit_websocket_frame_free(nxt_unit_ctx_t *ctx, in nxt_unit_websocket_frame_free()
2447 nxt_unit_mmap_buf_get(nxt_unit_ctx_t *ctx) in nxt_unit_mmap_buf_get()
2784 nxt_unit_read_buf_get(nxt_unit_ctx_t *ctx) in nxt_unit_read_buf_get()
2829 nxt_unit_read_buf_release(nxt_unit_ctx_t *ctx, in nxt_unit_read_buf_release()
3492 nxt_unit_mmap_get(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port, in nxt_unit_mmap_get()
3618 nxt_unit_send_oosm(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port) in nxt_unit_send_oosm()
3645 nxt_unit_wait_shm_ack(nxt_unit_ctx_t *ctx) in nxt_unit_wait_shm_ack()
3745 nxt_unit_new_mmap(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port, int n) in nxt_unit_new_mmap()
3827 nxt_unit_shm_open(nxt_unit_ctx_t *ctx, size_t size) in nxt_unit_shm_open()
3900 nxt_unit_send_mmap(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port, int fd) in nxt_unit_send_mmap()
3931 nxt_unit_get_outgoing_buf(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port, in nxt_unit_get_outgoing_buf()
3999 nxt_unit_incoming_mmap(nxt_unit_ctx_t *ctx, pid_t pid, int fd) in nxt_unit_incoming_mmap()
4090 nxt_unit_awake_ctx(nxt_unit_ctx_t *ctx, nxt_unit_ctx_impl_t *ctx_impl) in nxt_unit_awake_ctx()
4169 nxt_unit_check_rbuf_mmap(nxt_unit_ctx_t *ctx, nxt_unit_mmaps_t *mmaps, in nxt_unit_check_rbuf_mmap()
4216 nxt_unit_mmap_read(nxt_unit_ctx_t *ctx, nxt_unit_recv_msg_t *recv_msg, in nxt_unit_mmap_read()
4310 nxt_unit_get_mmap(nxt_unit_ctx_t *ctx, pid_t pid, uint32_t id) in nxt_unit_get_mmap()
4344 nxt_unit_mmap_release(nxt_unit_ctx_t *ctx, nxt_port_mmap_header_t *hdr, in nxt_unit_mmap_release()
4386 nxt_unit_send_shm_ack(nxt_unit_ctx_t *ctx, pid_t pid) in nxt_unit_send_shm_ack()
4448 nxt_unit_process_get(nxt_unit_ctx_t *ctx, pid_t pid) in nxt_unit_process_get()
4534 nxt_unit_run(nxt_unit_ctx_t *ctx) in nxt_unit_run()
4561 nxt_unit_run_once(nxt_unit_ctx_t *ctx) in nxt_unit_run_once()
4576 nxt_unit_run_once_impl(nxt_unit_ctx_t *ctx) 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()
4722 nxt_unit_chk_ready(nxt_unit_ctx_t *ctx) in nxt_unit_chk_ready()
4737 nxt_unit_process_pending_rbuf(nxt_unit_ctx_t *ctx) in nxt_unit_process_pending_rbuf()
4783 nxt_unit_process_ready_req(nxt_unit_ctx_t *ctx) in nxt_unit_process_ready_req()
4851 nxt_unit_run_ctx(nxt_unit_ctx_t *ctx) in nxt_unit_run_ctx()
4953 nxt_unit_run_shared(nxt_unit_ctx_t *ctx) in nxt_unit_run_shared()
4997 nxt_unit_dequeue_request(nxt_unit_ctx_t *ctx) in nxt_unit_dequeue_request()
5036 nxt_unit_process_port_msg(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port) in nxt_unit_process_port_msg()
5051 nxt_unit_process_port_msg_impl(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port) in nxt_unit_process_port_msg_impl()
5097 nxt_unit_done(nxt_unit_ctx_t *ctx) in nxt_unit_done()
5103 nxt_unit_ctx_t *
5104 nxt_unit_ctx_alloc(nxt_unit_ctx_t *ctx, void *data) in nxt_unit_ctx_alloc()
5273 nxt_unit_create_port(nxt_unit_ctx_t *ctx) in nxt_unit_create_port()
5344 nxt_unit_send_port(nxt_unit_ctx_t *ctx, nxt_unit_port_t *dst, in nxt_unit_send_port()
5432 nxt_unit_add_port(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port, void *queue) in nxt_unit_add_port()
5618 nxt_unit_process_awaiting_req(nxt_unit_ctx_t *ctx, nxt_queue_t *awaiting_req) in nxt_unit_process_awaiting_req()
5647 nxt_unit_remove_port(nxt_unit_impl_t *lib, nxt_unit_ctx_t *ctx, in nxt_unit_remove_port()
5755 nxt_unit_quit(nxt_unit_ctx_t *ctx, uint8_t quit_param) in nxt_unit_quit()
5867 nxt_unit_get_port(nxt_unit_ctx_t *ctx, nxt_unit_port_id_t *port_id) in nxt_unit_get_port()
5903 nxt_unit_port_send(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port, in nxt_unit_port_send()
5995 nxt_unit_sendmsg(nxt_unit_ctx_t *ctx, int fd, in nxt_unit_sendmsg()
6033 nxt_unit_ctx_port_recv(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port, in nxt_unit_ctx_port_recv()
6154 nxt_unit_shared_port_recv(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port, in nxt_unit_shared_port_recv()
6191 nxt_unit_port_recv(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port, in nxt_unit_port_recv()
6268 nxt_unit_app_queue_recv(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port, in nxt_unit_app_queue_recv()
6491 nxt_unit_request_hash_add(nxt_unit_ctx_t *ctx, in nxt_unit_request_hash_add()
6536 nxt_unit_request_hash_find(nxt_unit_ctx_t *ctx, uint32_t stream, int remove) in nxt_unit_request_hash_find()
6580 nxt_unit_log(nxt_unit_ctx_t *ctx, int level, const char *fmt, ...) in nxt_unit_log()
6746 nxt_unit_malloc(nxt_unit_ctx_t *ctx, size_t size) in nxt_unit_malloc()
6767 nxt_unit_free(nxt_unit_ctx_t *ctx, void *p) in nxt_unit_free()