Home
last modified time | relevance | path

Searched refs:link (Results 1 – 25 of 43) sorted by relevance

12

/unit/src/
H A Dnxt_queue.h33 (link)->prev = (link); \
34 (link)->next = (link); \
89 (link)->next
93 (link)->prev
99 (link)->next->prev = (link); \
108 (link)->prev->next = (link); \
117 (link)->next->prev = (link); \
128 (link)->prev->next = (link); \
136 (link)->next->prev = (link)->prev; \
137 (link)->prev->next = (link)->next; \
[all …]
H A Dnxt_queue.c57 nxt_queue_link_t *link, *prev, *next; in nxt_queue_sort() local
59 link = nxt_queue_first(queue); in nxt_queue_sort()
61 if (link == nxt_queue_last(queue)) { in nxt_queue_sort()
65 for (link = nxt_queue_next(link); in nxt_queue_sort()
66 link != nxt_queue_tail(queue); in nxt_queue_sort()
67 link = next) in nxt_queue_sort()
69 prev = nxt_queue_prev(link); in nxt_queue_sort()
70 next = nxt_queue_next(link); in nxt_queue_sort()
72 nxt_queue_remove(link); in nxt_queue_sort()
75 if (cmp(data, prev, link) <= 0) { in nxt_queue_sort()
[all …]
H A Dnxt_thread.c95 nxt_free(link); in nxt_thread_create()
105 nxt_thread_link_t *link; in nxt_thread_trampoline() local
108 link = data; in nxt_thread_trampoline()
116 start = link->start; in nxt_thread_trampoline()
117 data = link->work.data; in nxt_thread_trampoline()
120 thr->link = link; in nxt_thread_trampoline()
123 nxt_free(link); in nxt_thread_trampoline()
185 nxt_thread_link_t *link; in nxt_thread_exit() local
190 link = thr->link; in nxt_thread_exit()
191 thr->link = NULL; in nxt_thread_exit()
[all …]
H A Dnxt_thread_pool.c62 nxt_thread_link_t *link; in nxt_thread_pool_init() local
86 link = nxt_zalloc(sizeof(nxt_thread_link_t)); in nxt_thread_pool_init()
88 if (nxt_fast_path(link != NULL)) { in nxt_thread_pool_init()
89 link->start = nxt_thread_pool_start; in nxt_thread_pool_init()
90 link->work.data = tp; in nxt_thread_pool_init()
171 nxt_thread_link_t *link; in nxt_thread_pool_wait() local
216 link = nxt_zalloc(sizeof(nxt_thread_link_t)); in nxt_thread_pool_wait()
218 if (nxt_fast_path(link != NULL)) { in nxt_thread_pool_wait()
219 link->start = nxt_thread_pool_loop; in nxt_thread_pool_wait()
220 link->work.data = tp; in nxt_thread_pool_wait()
[all …]
H A Dnxt_port_rpc.c19 nxt_queue_link_t link; member
218 lhq.value = &reg->link; in nxt_port_rpc_ex_set_peer()
227 nxt_queue_self(&reg->link); in nxt_port_rpc_ex_set_peer()
230 reg->stream, reg->peer, reg->link.next); in nxt_port_rpc_ex_set_peer()
236 nxt_queue_insert_after(peer_link, &reg->link); in nxt_port_rpc_ex_set_peer()
268 if (reg->link.next == &reg->link) { in nxt_port_rpc_remove_from_peers()
269 nxt_assert(reg->link.prev == &reg->link); in nxt_port_rpc_remove_from_peers()
281 lhq.value = reg->link.next; in nxt_port_rpc_remove_from_peers()
283 r = nxt_queue_link_data(reg->link.next, nxt_port_rpc_reg_t, link); in nxt_port_rpc_remove_from_peers()
286 nxt_queue_remove(&reg->link); in nxt_port_rpc_remove_from_peers()
[all …]
H A Dnxt_signal.c113 nxt_thread_link_t *link; in nxt_signal_thread_start() local
136 link = nxt_zalloc(sizeof(nxt_thread_link_t)); in nxt_signal_thread_start()
138 if (nxt_fast_path(link != NULL)) { in nxt_signal_thread_start()
139 link->start = nxt_signal_thread; in nxt_signal_thread_start()
140 link->work.data = engine; in nxt_signal_thread_start()
142 if (nxt_thread_create(&engine->signals->thread, link) == NXT_OK) { in nxt_signal_thread_start()
H A Dnxt_mp.c32 nxt_queue_link_t link; member
526 nxt_queue_link_t *link; in nxt_mp_alloc_small() local
540 page = nxt_queue_link_data(link, nxt_mp_page_t, link); in nxt_mp_alloc_small()
600 nxt_queue_link_t *link, *next; in nxt_mp_get_small() local
606 link = next) in nxt_mp_get_small()
608 next = nxt_queue_next(link); in nxt_mp_get_small()
609 page = nxt_queue_link_data(link, nxt_mp_page_t, link); in nxt_mp_get_small()
618 nxt_queue_remove(link); in nxt_mp_get_small()
649 nxt_queue_link_t *link; in nxt_mp_alloc_page() local
659 nxt_queue_remove(link); in nxt_mp_alloc_page()
[all …]
H A Dnxt_conn_accept.c75 nxt_queue_insert_tail(&engine->listen_connections, &lev->link); in nxt_listen_event()
198 nxt_queue_insert_head(&task->thread->engine->idle_connections, &c->link); in nxt_conn_accept()
272 nxt_queue_link_t *link, *next; in nxt_conn_accept_close_idle_handler() local
283 for (link = nxt_queue_last(idle); in nxt_conn_accept_close_idle_handler()
284 link != nxt_queue_head(idle); in nxt_conn_accept_close_idle_handler()
285 link = next) in nxt_conn_accept_close_idle_handler()
287 next = nxt_queue_next(link); in nxt_conn_accept_close_idle_handler()
289 c = nxt_queue_link_data(link, nxt_conn_t, link); in nxt_conn_accept_close_idle_handler()
H A Dnxt_cache.c437 nxt_queue_insert_head(&cache->expiry_queue, &node->link); in nxt_cache_update()
444 nxt_queue_remove(&node->link); in nxt_cache_update()
533 nxt_queue_remove(&node->link); in nxt_cache_release_locked()
534 nxt_queue_insert_head(&cache->expiry_queue, &node->link); in nxt_cache_release_locked()
559 nxt_queue_link_t *link; in nxt_cache_node_alloc() local
562 link = nxt_queue_first(&cache->free_nodes); in nxt_cache_node_alloc()
564 if (nxt_fast_path(link != nxt_queue_tail(&cache->free_nodes))) { in nxt_cache_node_alloc()
566 nxt_queue_remove(link); in nxt_cache_node_alloc()
568 node = nxt_queue_link_data(link, nxt_cache_node_t, link); in nxt_cache_node_alloc()
588 nxt_queue_insert_head(&cache->free_nodes, &node->link); in nxt_cache_node_free()
H A Dnxt_mem_zone.c53 nxt_queue_link_t link; member
193 nxt_queue_sentinel(&zone->sentinel_page.link); in nxt_mem_zone_init()
194 nxt_queue_insert_after(&zone->sentinel_page.link, &page->link); in nxt_mem_zone_init()
682 nxt_queue_insert_after(&prev_page->link, &page->link); in nxt_mem_zone_alloc_pages()
693 nxt_queue_insert_after(&page->link, &next_page->link); in nxt_mem_zone_alloc_pages()
913 next_page = nxt_queue_link_data(page->link.next, nxt_mem_zone_page_t, link); in nxt_mem_zone_free_pages()
919 nxt_queue_remove(&next_page->link); in nxt_mem_zone_free_pages()
927 prev_page = nxt_queue_link_data(page->link.prev, nxt_mem_zone_page_t, link); in nxt_mem_zone_free_pages()
933 nxt_queue_remove(&page->link); in nxt_mem_zone_free_pages()
H A Dnxt_process.h120 nxt_queue_link_t link; /* for nxt_process_t.children */ member
170 nxt_queue_remove(&port->link)
173 nxt_queue_link_data(nxt_queue_first(&process->ports), nxt_port_t, link)
179 nxt_queue_each(port, &process->ports, nxt_port_t, link)
H A Dnxt_thread_time.c85 nxt_thread_link_t *link; in nxt_time_thread_start() local
88 link = nxt_zalloc(sizeof(nxt_thread_link_t)); in nxt_time_thread_start()
90 if (nxt_fast_path(link != NULL)) { in nxt_time_thread_start()
91 link->start = nxt_time_thread; in nxt_time_thread_start()
92 link->work.data = (void *) (uintptr_t) interval; in nxt_time_thread_start()
94 (void) nxt_thread_create(&handle, link); in nxt_time_thread_start()
H A Dnxt_job.c42 nxt_queue_self(&job->link); in nxt_job_create()
55 nxt_queue_self(&job->link); in nxt_job_init()
66 nxt_queue_remove(&job->link); in nxt_job_destroy()
H A Dnxt_runtime.c473 nxt_queue_link_t *link, *next; in nxt_runtime_close_idle_connections() local
479 for (link = nxt_queue_first(idle); in nxt_runtime_close_idle_connections()
480 link != nxt_queue_tail(idle); in nxt_runtime_close_idle_connections()
481 link = next) in nxt_runtime_close_idle_connections()
483 next = nxt_queue_next(link); in nxt_runtime_close_idle_connections()
484 c = nxt_queue_link_data(link, nxt_conn_t, link); in nxt_runtime_close_idle_connections()
487 nxt_queue_remove(link); in nxt_runtime_close_idle_connections()
644 nxt_queue_link_t *link; in nxt_runtime_event_engine_free() local
648 nxt_queue_remove(link); in nxt_runtime_event_engine_free()
650 engine = nxt_queue_link_data(link, nxt_event_engine_t, link); in nxt_runtime_event_engine_free()
[all …]
H A Dnxt_router.h139 nxt_queue_link_t link; member
163 nxt_queue_link_t link; member
210 nxt_queue_link_t link; member
H A Dnxt_thread.h90 nxt_thread_link_t *link);
142 nxt_thread_link_t *link; member
H A Dnxt_port_socket.c173 msg.link.next = NULL; in nxt_port_socket_write2()
174 msg.link.prev = NULL; in nxt_port_socket_write2()
476 if (msg->link.next != NULL) { in nxt_port_write_handler()
479 nxt_queue_remove(&msg->link); in nxt_port_write_handler()
498 if (msg->link.next != NULL) { in nxt_port_write_handler()
501 nxt_queue_remove(&msg->link); in nxt_port_write_handler()
502 msg->link.next = NULL; in nxt_port_write_handler()
518 if (msg->link.next == NULL) { in nxt_port_write_handler()
527 if (msg->link.next == NULL) { in nxt_port_write_handler()
694 nxt_queue_insert_tail(&port->messages, &msg->link); in nxt_port_msg_insert_tail()
[all …]
H A Dnxt_process.c992 nxt_queue_insert_tail(&process->ports, &port->link); in nxt_process_port_add()
1027 nxt_queue_link_t *link, *next; in nxt_process_quit() local
1037 for (link = nxt_queue_first(listen); in nxt_process_quit()
1038 link != nxt_queue_tail(listen); in nxt_process_quit()
1039 link = next) in nxt_process_quit()
1041 next = nxt_queue_next(link); in nxt_process_quit()
1042 lev = nxt_queue_link_data(link, nxt_listen_event_t, link); in nxt_process_quit()
1043 nxt_queue_remove(link); in nxt_process_quit()
H A Dnxt_router.c3236 link->engine = engine; in nxt_router_thread_create()
3239 link->work.data = link; in nxt_router_thread_create()
3337 link = data; in nxt_router_thread_start()
3338 engine = link->engine; in nxt_router_thread_start()
4108 link = data; in nxt_router_thread_exit_handler()
4112 engine = link->engine; in nxt_router_thread_exit_handler()
4129 nxt_free(link); in nxt_router_thread_exit_handler()
4655 link = NULL; in nxt_router_app_port_error()
4667 link->next = NULL; in nxt_router_app_port_error()
4672 while (link != NULL) { in nxt_router_app_port_error()
[all …]
H A Dnxt_job.h44 nxt_queue_link_t link; member
H A Dnxt_cache.h58 nxt_queue_link_t link; member
H A Dnxt_controller.c26 nxt_queue_link_t link; member
548 nxt_queue_each(req, &queue, nxt_controller_request_t, link) { in nxt_controller_flush_requests()
746 nxt_queue_remove(&c->link); in nxt_controller_conn_read()
747 nxt_queue_self(&c->link); in nxt_controller_conn_read()
972 nxt_queue_remove(&c->link); in nxt_controller_conn_close()
1308 nxt_queue_insert_head(&nxt_controller_waiting_requests, &req->link); in nxt_controller_process_config()
1391 nxt_queue_insert_head(&nxt_controller_waiting_requests, &req->link); in nxt_controller_process_config()
1725 nxt_queue_remove(&req->link); in nxt_controller_conf_handler()
1783 nxt_queue_insert_tail(&nxt_controller_waiting_requests, &req->link); in nxt_controller_process_control()
1830 nxt_queue_insert_head(&nxt_controller_waiting_requests, &req->link); in nxt_controller_process_control()
[all …]
/unit/src/test/
H A Dnxt_unit_websocket_chat.c27 nxt_queue_link_t link; member
75 nxt_queue_insert_tail(&ws_chat_sessions, &data->link); in ws_chat_request_handler()
149 nxt_queue_each(data, &ws_chat_sessions, ws_chat_request_data_t, link) { in ws_chat_broadcast()
196 nxt_queue_remove(&data->link); in ws_chat_close_handler()
H A Dnxt_cq_test.c301 nxt_thread_link_t *link; in worker_create() local
303 link = nxt_zalloc(sizeof(nxt_thread_link_t)); in worker_create()
305 link->start = start; in worker_create()
306 link->work.data = wi; in worker_create()
308 return nxt_thread_create(&wi->handle, link); in worker_create()
/unit/src/python/
H A Dnxt_python_asgi.h14 nxt_queue_link_t *link);

12