Lines Matching defs:ctx

288     nxt_unit_ctx_t                ctx;  member
432 nxt_unit_ctx_t *ctx; in nxt_unit_init() local
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() local
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() local
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()
2446 nxt_unit_mmap_buf_get(nxt_unit_ctx_t *ctx) in nxt_unit_mmap_buf_get()
2783 nxt_unit_read_buf_get(nxt_unit_ctx_t *ctx) in nxt_unit_read_buf_get()
2828 nxt_unit_read_buf_release(nxt_unit_ctx_t *ctx, in nxt_unit_read_buf_release()
3491 nxt_unit_mmap_get(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port, in nxt_unit_mmap_get()
3617 nxt_unit_send_oosm(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port) in nxt_unit_send_oosm()
3644 nxt_unit_wait_shm_ack(nxt_unit_ctx_t *ctx) in nxt_unit_wait_shm_ack()
3744 nxt_unit_new_mmap(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port, int n) in nxt_unit_new_mmap()
3826 nxt_unit_shm_open(nxt_unit_ctx_t *ctx, size_t size) in nxt_unit_shm_open()
3899 nxt_unit_send_mmap(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port, int fd) in nxt_unit_send_mmap()
3930 nxt_unit_get_outgoing_buf(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port, in nxt_unit_get_outgoing_buf()
3998 nxt_unit_incoming_mmap(nxt_unit_ctx_t *ctx, pid_t pid, int fd) in nxt_unit_incoming_mmap()
4089 nxt_unit_awake_ctx(nxt_unit_ctx_t *ctx, nxt_unit_ctx_impl_t *ctx_impl) in nxt_unit_awake_ctx()
4168 nxt_unit_check_rbuf_mmap(nxt_unit_ctx_t *ctx, nxt_unit_mmaps_t *mmaps, in nxt_unit_check_rbuf_mmap()
4215 nxt_unit_mmap_read(nxt_unit_ctx_t *ctx, nxt_unit_recv_msg_t *recv_msg, in nxt_unit_mmap_read()
4309 nxt_unit_get_mmap(nxt_unit_ctx_t *ctx, pid_t pid, uint32_t id) in nxt_unit_get_mmap()
4343 nxt_unit_mmap_release(nxt_unit_ctx_t *ctx, nxt_port_mmap_header_t *hdr, in nxt_unit_mmap_release()
4385 nxt_unit_send_shm_ack(nxt_unit_ctx_t *ctx, pid_t pid) in nxt_unit_send_shm_ack()
4447 nxt_unit_process_get(nxt_unit_ctx_t *ctx, pid_t pid) in nxt_unit_process_get()
4533 nxt_unit_run(nxt_unit_ctx_t *ctx) in nxt_unit_run()
4560 nxt_unit_run_once(nxt_unit_ctx_t *ctx) in nxt_unit_run_once()
4575 nxt_unit_run_once_impl(nxt_unit_ctx_t *ctx) 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()
4721 nxt_unit_chk_ready(nxt_unit_ctx_t *ctx) in nxt_unit_chk_ready()
4736 nxt_unit_process_pending_rbuf(nxt_unit_ctx_t *ctx) in nxt_unit_process_pending_rbuf()
4782 nxt_unit_process_ready_req(nxt_unit_ctx_t *ctx) in nxt_unit_process_ready_req()
4850 nxt_unit_run_ctx(nxt_unit_ctx_t *ctx) in nxt_unit_run_ctx()
4952 nxt_unit_run_shared(nxt_unit_ctx_t *ctx) in nxt_unit_run_shared()
4996 nxt_unit_dequeue_request(nxt_unit_ctx_t *ctx) in nxt_unit_dequeue_request()
5035 nxt_unit_process_port_msg(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port) in nxt_unit_process_port_msg()
5050 nxt_unit_process_port_msg_impl(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port) in nxt_unit_process_port_msg_impl()
5096 nxt_unit_done(nxt_unit_ctx_t *ctx) in nxt_unit_done()
5103 nxt_unit_ctx_alloc(nxt_unit_ctx_t *ctx, void *data) in nxt_unit_ctx_alloc()
5272 nxt_unit_create_port(nxt_unit_ctx_t *ctx) in nxt_unit_create_port()
5343 nxt_unit_send_port(nxt_unit_ctx_t *ctx, nxt_unit_port_t *dst, in nxt_unit_send_port()
5431 nxt_unit_add_port(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port, void *queue) in nxt_unit_add_port()
5617 nxt_unit_process_awaiting_req(nxt_unit_ctx_t *ctx, nxt_queue_t *awaiting_req) in nxt_unit_process_awaiting_req()
5646 nxt_unit_remove_port(nxt_unit_impl_t *lib, nxt_unit_ctx_t *ctx, in nxt_unit_remove_port()
5754 nxt_unit_quit(nxt_unit_ctx_t *ctx, uint8_t quit_param) in nxt_unit_quit()
5866 nxt_unit_get_port(nxt_unit_ctx_t *ctx, nxt_unit_port_id_t *port_id) in nxt_unit_get_port()
5902 nxt_unit_port_send(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port, in nxt_unit_port_send()
5994 nxt_unit_sendmsg(nxt_unit_ctx_t *ctx, int fd, in nxt_unit_sendmsg()
6032 nxt_unit_ctx_port_recv(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port, in nxt_unit_ctx_port_recv()
6153 nxt_unit_shared_port_recv(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port, in nxt_unit_shared_port_recv()
6190 nxt_unit_port_recv(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port, in nxt_unit_port_recv()
6267 nxt_unit_app_queue_recv(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port, in nxt_unit_app_queue_recv()
6490 nxt_unit_request_hash_add(nxt_unit_ctx_t *ctx, in nxt_unit_request_hash_add()
6535 nxt_unit_request_hash_find(nxt_unit_ctx_t *ctx, uint32_t stream, int remove) in nxt_unit_request_hash_find()
6579 nxt_unit_log(nxt_unit_ctx_t *ctx, int level, const char *fmt, ...) in nxt_unit_log()
6745 nxt_unit_malloc(nxt_unit_ctx_t *ctx, size_t size) in nxt_unit_malloc()
6766 nxt_unit_free(nxt_unit_ctx_t *ctx, void *p) in nxt_unit_free()