Searched refs:qmsg (Results 1 – 1 of 1) sorted by relevance
171 } qmsg; in nxt_port_socket_write2() local195 qmsg.pm = msg.port_msg; in nxt_port_socket_write2()197 qmsg_size = sizeof(qmsg.pm); in nxt_port_socket_write2()200 qmsg_size += nxt_port_enqueue_buf(task, &qmsg.pm, qmsg.buf, b); in nxt_port_socket_write2()210 if (qmsg.pm.mmap) { in nxt_port_socket_write2()228 qmsg.buf[0] = _NXT_PORT_MSG_READ_SOCKET; in nxt_port_socket_write2()822 uint8_t qmsg[NXT_PORT_QUEUE_MSG_SIZE]; in nxt_port_queue_read_handler() local835 n = nxt_port_queue_recv(queue, qmsg); in nxt_port_queue_read_handler()840 n = nxt_port_queue_recv(queue, qmsg); in nxt_port_queue_read_handler()848 if (n == 1 && qmsg[0] == _NXT_PORT_MSG_READ_SOCKET) { in nxt_port_queue_read_handler()[all …]