nxt_port_socket.c - OpenGrok cross reference for /unit/src/nxt_port

Lines Matching refs:queue
192     if (port->queue != NULL && type != _NXT_PORT_MSG_READ_QUEUE) {  in nxt_port_socket_write2()
203             res = nxt_port_queue_send(port->queue, &qmsg, qmsg_size, &notify);  in nxt_port_socket_write2()
230             res = nxt_port_queue_send(port->queue, qmsg.buf, 1, &notify);  in nxt_port_socket_write2()
711     port->socket.read_handler = port->queue != NULL  in nxt_port_read_enable()
820     nxt_port_queue_t     *queue;  in nxt_port_queue_read_handler()  local
829     queue = port->queue;  in nxt_port_queue_read_handler()
830     nxt_atomic_fetch_add(&queue->nitems, 1);  in nxt_port_queue_read_handler()
835             n = nxt_port_queue_recv(queue, qmsg);  in nxt_port_queue_read_handler()
838                 nxt_atomic_fetch_add(&queue->nitems, -1);  in nxt_port_queue_read_handler()
840                 n = nxt_port_queue_recv(queue, qmsg);  in nxt_port_queue_read_handler()
845                 nxt_atomic_fetch_add(&queue->nitems, 1);  in nxt_port_queue_read_handler()
885             nxt_atomic_fetch_add(&queue->nitems, -1);  in nxt_port_queue_read_handler()