Home
last modified time | relevance | path

Searched refs:qmsg (Results 1 – 1 of 1) sorted by relevance

/unit/src/
H A Dnxt_port_socket.c171 } qmsg; in nxt_port_socket_write2() local
195 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() local
835 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 …]