Lines Matching refs:nxt_buf_t
17 static nxt_bool_t nxt_port_can_enqueue_buf(nxt_buf_t *b);
19 void *qbuf, nxt_buf_t *b);
27 static nxt_buf_t *nxt_port_buf_completion(nxt_task_t *task,
28 nxt_work_queue_t *wq, nxt_buf_t *b, size_t sent, nxt_bool_t mmap_mode);
36 static nxt_buf_t *nxt_port_buf_alloc(nxt_port_t *port);
37 static void nxt_port_buf_free(nxt_port_t *port, nxt_buf_t *b);
162 nxt_buf_t *b) in nxt_port_socket_write2()
253 nxt_port_can_enqueue_buf(nxt_buf_t *b) in nxt_port_can_enqueue_buf()
270 nxt_buf_t *b) in nxt_port_enqueue_buf()
617 static nxt_buf_t *
618 nxt_port_buf_completion(nxt_task_t *task, nxt_work_queue_t *wq, nxt_buf_t *b, in nxt_port_buf_completion()
622 nxt_buf_t *next; in nxt_port_buf_completion()
734 nxt_buf_t *b; in nxt_port_read_handler()
815 nxt_buf_t *b; in nxt_port_queue_read_handler()
1174 nxt_buf_t *b, *orig_b, *next; in nxt_port_read_msg_process()
1304 static nxt_buf_t *
1307 nxt_buf_t *b; in nxt_port_buf_alloc()
1328 nxt_port_buf_free(nxt_port_t *port, nxt_buf_t *b) in nxt_port_buf_free()
1339 nxt_buf_t *b, *next; in nxt_port_error_handler()