Home
last modified time | relevance | path

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

/unit/src/
H A Dnxt_queue.h26 (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 Dnxt_queue.c17 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 Dnxt_port_queue.h28 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 Dnxt_app_queue.h28 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()
H A Dnxt_port_socket.c192 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, &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()
[all …]
H A Dnxt_file_cache.c318 node = nxt_queue_node_data(qn, nxt_cache_node_t, queue); in nxt_cache_node_alloc()
338 nxt_queue_insert_head(&cache->free_nodes, &node->queue); in nxt_cache_node_free()
475 nxt_queue_remove(&node->queue); in nxt_cache_node_release_locked()
476 nxt_queue_insert_head(&cache->expiry_queue, &node->queue); in nxt_cache_node_release_locked()
H A Dnxt_port.c116 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 Dnxt_unit.c157 nxt_unit_port_t *port, void *queue);
396 void *queue; member
1562 port_impl->queue = NULL; in nxt_unit_request_check_response_port()
5155 port_impl->queue = mem; in nxt_unit_ctx_alloc()
5419 if (port_impl->queue != NULL) { in nxt_unit_port_release()
5483 if (old_port_impl->queue == NULL) { in nxt_unit_add_port()
5484 old_port_impl->queue = queue; in nxt_unit_add_port()
5568 new_port->queue = queue; in nxt_unit_add_port()
5957 if (port_impl->queue != NULL) { in nxt_unit_port_send()
6272 nxt_app_queue_t *queue; in nxt_unit_app_queue_recv() local
[all …]
H A Dnxt_port.h273 void *queue; member
H A Dnxt_controller.c548 nxt_queue_t queue; in nxt_controller_flush_requests() local
551 nxt_queue_init(&queue); in nxt_controller_flush_requests()
552 nxt_queue_add(&queue, &nxt_controller_waiting_requests); in nxt_controller_flush_requests()
556 nxt_queue_each(req, &queue, nxt_controller_request_t, link) { in nxt_controller_flush_requests()
H A Dnxt_router.c114 static nxt_app_t *nxt_router_app_find(nxt_queue_t *queue, nxt_str_t *name);
534 cancelled = nxt_app_queue_cancel(app_port->queue, in nxt_router_msg_cancel()
2289 nxt_router_app_find(nxt_queue_t *queue, nxt_str_t *name) in nxt_router_app_find() argument
2293 nxt_queue_each(app, queue, nxt_app_t, link) { in nxt_router_app_find()
2327 port->queue = mem; in nxt_router_app_queue_init()
2355 port->queue = mem; in nxt_router_port_queue_init()
2375 port->queue = mem; in nxt_router_port_queue_map()
5057 nxt_assert(port->queue != NULL); in nxt_router_app_prepare_request()
5106 res = nxt_app_queue_send(port->queue, &msg, sizeof(msg), in nxt_router_app_prepare_request()
H A Dnxt_main_process.c344 port->queue = mem; in nxt_main_new_port_handler()
/unit/
H A DCHANGES899 time and time in queue now are not accounted.