Searched refs:queue (Results 1 – 12 of 12) sorted by last modified time
/unit/ |
H A D | CHANGES | 1088 time and time in queue now are not accounted.
|
/unit/src/ |
H A D | nxt_router.c | 128 static nxt_app_t *nxt_router_app_find(nxt_queue_t *queue, nxt_str_t *name); 556 cancelled = nxt_app_queue_cancel(app_port->queue, in nxt_router_msg_cancel() 2452 nxt_router_app_find(nxt_queue_t *queue, nxt_str_t *name) in nxt_router_app_find() argument 2456 nxt_queue_each(app, queue, nxt_app_t, link) { in nxt_router_app_find() 2490 port->queue = mem; in nxt_router_app_queue_init() 2518 port->queue = mem; in nxt_router_port_queue_init() 2538 port->queue = mem; in nxt_router_port_queue_map() 5257 nxt_assert(port->queue != NULL); in nxt_router_app_prepare_request() 5306 res = nxt_app_queue_send(port->queue, &msg, sizeof(msg), in nxt_router_app_prepare_request()
|
H A D | nxt_main_process.c | 431 port->queue = mem; in nxt_main_new_port_handler()
|
H A D | nxt_controller.c | 573 nxt_queue_t queue; in nxt_controller_flush_requests() local 576 nxt_queue_init(&queue); in nxt_controller_flush_requests() 577 nxt_queue_add(&queue, &nxt_controller_waiting_requests); in nxt_controller_flush_requests() 581 nxt_queue_each(req, &queue, nxt_controller_request_t, link) { in nxt_controller_flush_requests()
|
H A D | nxt_unit.c | 157 nxt_unit_port_t *port, void *queue); 396 void *queue; member 1562 port_impl->queue = NULL; in nxt_unit_request_check_response_port() 5156 port_impl->queue = mem; in nxt_unit_ctx_alloc() 5420 if (port_impl->queue != NULL) { in nxt_unit_port_release() 5484 if (old_port_impl->queue == NULL) { in nxt_unit_add_port() 5485 old_port_impl->queue = queue; in nxt_unit_add_port() 5569 new_port->queue = queue; in nxt_unit_add_port() 5958 if (port_impl->queue != NULL) { in nxt_unit_port_send() 6273 nxt_app_queue_t *queue; in nxt_unit_app_queue_recv() local [all …]
|
H A D | nxt_port.h | 282 void *queue; member
|
H A D | nxt_port.c | 116 if (port->queue != NULL) { in nxt_port_close() 119 nxt_mem_munmap(port->queue, size); in nxt_port_close() 121 port->queue = NULL; in nxt_port_close() 335 port->queue = nxt_mem_mmap(NULL, sizeof(nxt_port_queue_t), in nxt_port_process_ready_handler()
|
H A D | nxt_port_socket.c | 192 if (port->queue != NULL && type != _NXT_PORT_MSG_READ_QUEUE) { in nxt_port_socket_write2() 230 res = nxt_port_queue_send(port->queue, qmsg.buf, 1, ¬ify); 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() [all …]
|
H A D | nxt_queue.h | 26 (queue)->head.prev = &(queue)->head; \ 27 (queue)->head.next = &(queue)->head; \ 48 (&(queue)->head == (queue)->head.prev) 73 (queue)->head.next 77 (queue)->head.prev 81 (&(queue)->head) 85 (&(queue)->head) 164 (queue)->head.prev->next = &(queue)->head; \ 174 (queue)->head.prev->next = &(queue)->head; \ 189 (queue)->head.prev->next = &(queue)->head; \ [all …]
|
H A D | nxt_queue.c | 17 nxt_queue_middle(nxt_queue_t *queue) in nxt_queue_middle() argument 21 middle = nxt_queue_first(queue); in nxt_queue_middle() 23 if (middle == nxt_queue_last(queue)) { in nxt_queue_middle() 34 if (next == nxt_queue_last(queue)) { in nxt_queue_middle() 40 if (next == nxt_queue_last(queue)) { in nxt_queue_middle() 53 nxt_queue_sort(nxt_queue_t *queue, in nxt_queue_sort() argument 59 link = nxt_queue_first(queue); in nxt_queue_sort() 61 if (link == nxt_queue_last(queue)) { in nxt_queue_sort() 66 link != nxt_queue_tail(queue); in nxt_queue_sort() 81 } while (prev != nxt_queue_head(queue)); in nxt_queue_sort()
|
H A D | nxt_port_queue.h | 28 nxt_nncq_t queue; member 39 nxt_nncq_init(&q->queue); in nxt_port_queue_init() 67 nxt_nncq_enqueue(&q->queue, i); in nxt_port_queue_send() 84 i = nxt_nncq_dequeue(&q->queue); in nxt_port_queue_recv() 85 if (i == nxt_nncq_empty(&q->queue)) { in nxt_port_queue_recv()
|
H A D | nxt_app_queue.h | 28 nxt_app_nncq_t queue; member 39 nxt_app_nncq_init(&q->queue); in nxt_app_queue_init() 69 nxt_app_nncq_enqueue(&q->queue, i); in nxt_app_queue_send() 107 i = nxt_app_nncq_dequeue(&q->queue); in nxt_app_queue_recv() 108 if (i == nxt_app_nncq_empty(&q->queue)) { in nxt_app_queue_recv()
|