Lines Matching refs:link

55     nxt_queue_link_t        link;  /* for nxt_socket_conf_t.tls */  member
66 nxt_queue_link_t link; member
970 nxt_queue_each(app, &nxt_router->apps, nxt_app_t, link) { in nxt_router_status_handler()
1000 nxt_queue_each(app, &nxt_router->apps, nxt_app_t, link) { in nxt_router_status_handler()
1195 skcf = nxt_queue_link_data(qlk, nxt_socket_conf_t, link); in nxt_router_conf_apply()
1208 tls = nxt_queue_link_data(qlk, nxt_router_tlssock_t, link); in nxt_router_conf_apply()
1222 js_module = nxt_queue_link_data(qlk, nxt_router_js_module_t, link); in nxt_router_conf_apply()
1237 nxt_queue_each(app, &tmcf->apps, nxt_app_t, link) { in nxt_router_conf_apply()
1362 skcf = nxt_queue_link_data(qlk, nxt_socket_conf_t, link); in nxt_router_conf_error()
1374 nxt_queue_each(app, &tmcf->apps, nxt_app_t, link) { in nxt_router_conf_error()
1730 nxt_queue_remove(&prev->link); in nxt_router_conf_create()
1731 nxt_queue_insert_tail(&tmcf->previous, &prev->link); in nxt_router_conf_create()
1866 nxt_queue_insert_tail(&tmcf->apps, &app->link); in nxt_router_conf_create()
2160 nxt_queue_each(app, &tmcf->apps, nxt_app_t, link) { in nxt_router_conf_create()
2162 nxt_queue_remove(&app->link); in nxt_router_conf_create()
2192 nxt_queue_insert_tail(&tmcf->tls, &tls->link); in nxt_router_conf_tls_insert()
2265 nxt_queue_insert_tail(&tmcf->js_modules, &js_module->link); in nxt_router_js_module_insert()
2456 nxt_queue_each(app, queue, nxt_app_t, link) { in nxt_router_app_find()
2767 skcf = nxt_queue_link_data(qlk, nxt_socket_conf_t, link); in nxt_router_listen_socket_find()
2775 nxt_queue_insert_tail(&updating_sockets, &nskcf->link); in nxt_router_listen_socket_find()
2781 nxt_queue_insert_tail(&pending_sockets, &nskcf->link); in nxt_router_listen_socket_find()
3376 skcf = nxt_queue_link_data(qlk, nxt_socket_conf_t, link); in nxt_router_engine_joints_create()
3435 job->work.data = nxt_queue_link_data(qlk, nxt_socket_conf_t, link); in nxt_router_engine_joints_delete()
3472 nxt_thread_link_t *link; in nxt_router_thread_create() local
3475 link = nxt_zalloc(sizeof(nxt_thread_link_t)); in nxt_router_thread_create()
3477 if (nxt_slow_path(link == NULL)) { in nxt_router_thread_create()
3481 link->start = nxt_router_thread_start; in nxt_router_thread_create()
3482 link->engine = engine; in nxt_router_thread_create()
3483 link->work.handler = nxt_router_thread_exit_handler; in nxt_router_thread_create()
3484 link->work.task = task; in nxt_router_thread_create()
3485 link->work.data = link; in nxt_router_thread_create()
3487 nxt_queue_insert_tail(&rt->engines, &engine->link); in nxt_router_thread_create()
3489 ret = nxt_thread_create(&handle, link); in nxt_router_thread_create()
3492 nxt_queue_remove(&engine->link); in nxt_router_thread_create()
3505 nxt_queue_each(app, &router->apps, nxt_app_t, link) { in nxt_router_apps_sort()
3580 nxt_thread_link_t *link; in nxt_router_thread_start() local
3583 link = data; in nxt_router_thread_start()
3584 engine = link->engine; in nxt_router_thread_start()
3635 work->task = link->work.task; in nxt_router_thread_start()
3639 nxt_event_engine_post(link->work.task->thread->engine, work); in nxt_router_thread_start()
3678 nxt_queue_insert_tail(&task->thread->engine->joints, &joint->link); in nxt_router_listen_socket_create()
3718 lev = nxt_queue_link_data(qlk, nxt_listen_event_t, link); in nxt_router_listen_event()
3742 nxt_queue_insert_tail(&engine->joints, &joint->link); in nxt_router_listen_socket_update()
3825 nxt_queue_remove(&lev->link); in nxt_router_listen_socket_close()
3950 nxt_queue_remove(&joint->link); in nxt_router_conf_release()
3971 nxt_queue_remove(&skcf->link); in nxt_router_conf_release()
4008 nxt_thread_link_t *link; in nxt_router_thread_exit_handler() local
4013 link = data; in nxt_router_thread_exit_handler()
4017 engine = link->engine; in nxt_router_thread_exit_handler()
4019 nxt_queue_remove(&engine->link); in nxt_router_thread_exit_handler()
4034 nxt_free(link); in nxt_router_thread_exit_handler()
4537 nxt_queue_link_t *link; in nxt_router_app_port_error() local
4560 link = NULL; in nxt_router_app_port_error()
4569 link = nxt_queue_first(&app->ack_waiting_req); in nxt_router_app_port_error()
4571 nxt_queue_remove(link); in nxt_router_app_port_error()
4572 link->next = NULL; in nxt_router_app_port_error()
4577 while (link != NULL) { in nxt_router_app_port_error()
4578 r = nxt_container_of(link, nxt_http_request_t, app_link); in nxt_router_app_port_error()
4582 link = NULL; in nxt_router_app_port_error()
4589 link = nxt_queue_first(&app->ack_waiting_req); in nxt_router_app_port_error()
4591 nxt_queue_remove(link); in nxt_router_app_port_error()
4592 link->next = NULL; in nxt_router_app_port_error()
4662 nxt_queue_remove(&app->link); in nxt_router_app_unlink()