/unit/src/ |
H A D | nxt_queue.h | 33 (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 D | nxt_queue.c | 57 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 D | nxt_thread.c | 95 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 D | nxt_thread_pool.c | 62 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 D | nxt_port_rpc.c | 19 nxt_queue_link_t link; member 218 lhq.value = ®->link; in nxt_port_rpc_ex_set_peer() 227 nxt_queue_self(®->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, ®->link); in nxt_port_rpc_ex_set_peer() 268 if (reg->link.next == ®->link) { in nxt_port_rpc_remove_from_peers() 269 nxt_assert(reg->link.prev == ®->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(®->link); in nxt_port_rpc_remove_from_peers() [all …]
|
H A D | nxt_mp.c | 32 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 D | nxt_signal.c | 113 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 D | nxt_conn_accept.c | 75 nxt_queue_insert_tail(&engine->listen_connections, &lev->link); in nxt_listen_event() 277 nxt_queue_link_t *link, *next; in nxt_conn_accept_close_idle_handler() local 288 for (link = nxt_queue_last(idle); in nxt_conn_accept_close_idle_handler() 289 link != nxt_queue_head(idle); in nxt_conn_accept_close_idle_handler() 290 link = next) in nxt_conn_accept_close_idle_handler() 292 next = nxt_queue_next(link); in nxt_conn_accept_close_idle_handler() 294 c = nxt_queue_link_data(link, nxt_conn_t, link); in nxt_conn_accept_close_idle_handler()
|
H A D | nxt_mem_zone.c | 53 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 D | nxt_process.h | 124 nxt_queue_link_t link; /* for nxt_process_t.children */ member 176 nxt_queue_remove(&port->link) 179 nxt_queue_link_data(nxt_queue_first(&process->ports), nxt_port_t, link) 185 nxt_queue_each(port, &process->ports, nxt_port_t, link)
|
H A D | nxt_thread_time.c | 85 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 D | nxt_job.c | 44 nxt_queue_self(&job->link); in nxt_job_create() 57 nxt_queue_self(&job->link); in nxt_job_init() 68 nxt_queue_remove(&job->link); in nxt_job_destroy()
|
H A D | nxt_runtime.c | 473 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() 661 nxt_queue_link_t *link; in nxt_runtime_event_engine_free() local 665 nxt_queue_remove(link); in nxt_runtime_event_engine_free() 667 engine = nxt_queue_link_data(link, nxt_event_engine_t, link); in nxt_runtime_event_engine_free() [all …]
|
H A D | nxt_thread.h | 90 nxt_thread_link_t *link); 142 nxt_thread_link_t *link; member
|
H A D | nxt_router.h | 147 nxt_queue_link_t link; member 171 nxt_queue_link_t link; member 223 nxt_queue_link_t link; member
|
H A D | nxt_port_socket.c | 173 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 D | nxt_router.c | 66 nxt_queue_link_t link; member 3482 link->engine = engine; in nxt_router_thread_create() 3485 link->work.data = link; in nxt_router_thread_create() 3583 link = data; in nxt_router_thread_start() 3584 engine = link->engine; in nxt_router_thread_start() 4013 link = data; in nxt_router_thread_exit_handler() 4017 engine = link->engine; in nxt_router_thread_exit_handler() 4034 nxt_free(link); in nxt_router_thread_exit_handler() 4560 link = NULL; in nxt_router_app_port_error() 4572 link->next = NULL; in nxt_router_app_port_error() [all …]
|
H A D | nxt_conn.h | 114 nxt_queue_link_t link; member 172 nxt_queue_link_t link; member 302 nxt_queue_insert_head(&e->idle_connections, &c->link); \ 313 nxt_queue_remove(&c->link); \
|
H A D | nxt_process.c | 316 nxt_queue_each(p, init->siblings, nxt_process_t, link) { in nxt_process_child_fixup() 1224 nxt_queue_insert_tail(&process->ports, &port->link); in nxt_process_port_add() 1261 nxt_queue_link_t *link, *next; in nxt_process_quit() local 1268 for (link = nxt_queue_first(listen); in nxt_process_quit() 1269 link != nxt_queue_tail(listen); in nxt_process_quit() 1270 link = next) in nxt_process_quit() 1272 next = nxt_queue_next(link); in nxt_process_quit() 1273 lev = nxt_queue_link_data(link, nxt_listen_event_t, link); in nxt_process_quit() 1274 nxt_queue_remove(link); in nxt_process_quit()
|
H A D | nxt_job.h | 44 nxt_queue_link_t link; member
|
H A D | nxt_controller.c | 28 nxt_queue_link_t link; member 581 nxt_queue_each(req, &queue, nxt_controller_request_t, link) { in nxt_controller_flush_requests() 787 nxt_queue_remove(&c->link); in nxt_controller_conn_read() 788 nxt_queue_self(&c->link); in nxt_controller_conn_read() 1013 nxt_queue_remove(&c->link); in nxt_controller_conn_close() 1421 nxt_queue_insert_head(&nxt_controller_waiting_requests, &req->link); in nxt_controller_process_config() 1607 nxt_queue_insert_head(&nxt_controller_waiting_requests, &req->link); in nxt_controller_process_status() 1643 nxt_queue_remove(&req->link); in nxt_controller_status_handler() 2248 nxt_queue_remove(&req->link); in nxt_controller_conf_handler() 2353 nxt_queue_insert_head(&nxt_controller_waiting_requests, &req->link); in nxt_controller_process_control() [all …]
|
/unit/src/test/ |
H A D | nxt_unit_websocket_chat.c | 27 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 D | nxt_cq_test.c | 301 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/auto/modules/ |
H A D | wasm-wasi-component | 88 …path src/wasm-wasi-component/Cargo.toml -- --emit link=target/release/libwasm_wasi_component.so -C…
|
/unit/src/python/ |
H A D | nxt_python_asgi.h | 14 nxt_queue_link_t *link);
|