Lines Matching refs:buf

170         uint8_t          buf[NXT_PORT_MAX_ENQUEUE_BUF_SIZE];  in nxt_port_socket_write2()  member
176 msg.buf = b; in nxt_port_socket_write2()
200 qmsg_size += nxt_port_enqueue_buf(task, &qmsg.pm, qmsg.buf, b); in nxt_port_socket_write2()
225 msg.buf = NULL; in nxt_port_socket_write2()
228 qmsg.buf[0] = _NXT_PORT_MSG_READ_SOCKET; in nxt_port_socket_write2()
230 res = nxt_port_queue_send(port->queue, qmsg.buf, 1, &notify); in nxt_port_socket_write2()
407 sb.buf = msg->buf; in nxt_port_write_handler()
418 m = nxt_port_mmap_get_method(task, port, msg->buf); in nxt_port_write_handler()
457 msg->buf = nxt_port_buf_completion(task, wq, msg->buf, plain_size, in nxt_port_write_handler()
460 if (msg->buf != NULL) { in nxt_port_write_handler()
775 msg.buf = b; in nxt_port_read_handler()
784 if (msg.buf == b) { in nxt_port_read_handler()
865 b = smsg->buf; in nxt_port_queue_read_handler()
979 smsg->buf = b; in nxt_port_queue_read_handler()
994 msg.buf = b; in nxt_port_queue_read_handler()
1003 if (msg.buf == b) { in nxt_port_queue_read_handler()
1189 b = orig_b = msg->buf; in nxt_port_read_msg_process()
1208 nxt_buf_chain_add(&fmsg->buf, msg->buf); in nxt_port_read_msg_process()
1211 msg->buf = NULL; in nxt_port_read_msg_process()
1216 b = fmsg->buf; in nxt_port_read_msg_process()
1220 msg->buf = fmsg->buf; in nxt_port_read_msg_process()
1228 if (!msg->port_msg.mmap && msg->buf == b) { in nxt_port_read_msg_process()
1242 b = msg->buf; in nxt_port_read_msg_process()
1255 msg->buf = NULL; in nxt_port_read_msg_process()
1268 b = msg->buf; in nxt_port_read_msg_process()
1284 if (msg->buf == b) { in nxt_port_read_msg_process()
1299 msg->buf = orig_b; in nxt_port_read_msg_process()
1363 for (b = msg->buf; b != NULL; b = next) { in nxt_port_error_handler()