Lines Matching refs:nxt_task_t

18 static uint8_t nxt_port_enqueue_buf(nxt_task_t *task, nxt_port_msg_t *pm,
20 static nxt_int_t nxt_port_msg_chk_insert(nxt_task_t *task, nxt_port_t *port,
23 static void nxt_port_write_handler(nxt_task_t *task, void *obj, void *data);
27 static nxt_buf_t *nxt_port_buf_completion(nxt_task_t *task,
31 static void nxt_port_read_handler(nxt_task_t *task, void *obj, void *data);
32 static void nxt_port_queue_read_handler(nxt_task_t *task, void *obj,
34 static void nxt_port_read_msg_process(nxt_task_t *task, nxt_port_t *port,
38 static void nxt_port_error_handler(nxt_task_t *task, void *obj, void *data);
42 nxt_port_socket_init(nxt_task_t *task, nxt_port_t *port, size_t max_size) in nxt_port_socket_init()
128 nxt_port_write_enable(nxt_task_t *task, nxt_port_t *port) in nxt_port_write_enable()
160 nxt_port_socket_write2(nxt_task_t *task, nxt_port_t *port, nxt_uint_t type, in nxt_port_socket_write2()
269 nxt_port_enqueue_buf(nxt_task_t *task, nxt_port_msg_t *pm, void *qbuf, in nxt_port_enqueue_buf()
303 nxt_port_msg_chk_insert(nxt_task_t *task, nxt_port_t *port, in nxt_port_msg_chk_insert()
353 nxt_port_fd_block_write(nxt_task_t *task, nxt_port_t *port, void *data) in nxt_port_fd_block_write()
360 nxt_port_fd_enable_write(nxt_task_t *task, nxt_port_t *port, void *data) in nxt_port_fd_enable_write()
367 nxt_port_write_handler(nxt_task_t *task, void *obj, void *data) in nxt_port_write_handler()
618 nxt_port_buf_completion(nxt_task_t *task, nxt_work_queue_t *wq, nxt_buf_t *b, in nxt_port_buf_completion()
703 nxt_port_read_enable(nxt_task_t *task, nxt_port_t *port) in nxt_port_read_enable()
731 nxt_port_read_handler(nxt_task_t *task, void *obj, void *data) in nxt_port_read_handler()
812 nxt_port_queue_read_handler(nxt_task_t *task, void *obj, void *data) in nxt_port_queue_read_handler()
1076 nxt_port_frag_start(nxt_task_t *task, nxt_port_t *port, in nxt_port_frag_start()
1132 nxt_port_frag_find(nxt_task_t *task, nxt_port_t *port, nxt_port_recv_msg_t *msg) in nxt_port_frag_find()
1171 nxt_port_read_msg_process(nxt_task_t *task, nxt_port_t *port, in nxt_port_read_msg_process()
1336 nxt_port_error_handler(nxt_task_t *task, void *obj, void *data) in nxt_port_error_handler()