Home
last modified time | relevance | path

Searched refs:work_queue (Results 1 – 17 of 17) sorted by relevance

/unit/src/
H A Dnxt_thread_pool.c50 nxt_locked_work_queue_add(&tp->work_queue, work); in nxt_thread_pool_post()
74 nxt_thread_spin_lock(&tp->work_queue.lock); in nxt_thread_pool_init()
108 nxt_thread_spin_unlock(&tp->work_queue.lock); in nxt_thread_pool_init()
149 handler = nxt_locked_work_queue_pop(&tp->work_queue, &task, &obj, in nxt_thread_pool_loop()
H A Dnxt_thread_pool.h26 nxt_locked_work_queue_t work_queue; member
H A Dnxt_listen_socket.h16 nxt_work_queue_t *work_queue; member
H A Dnxt_conn_accept.c60 lev->work_queue = &engine->read_work_queue; in nxt_listen_event()
62 lev->timer.work_queue = &engine->fast_work_queue; in nxt_listen_event()
210 c->read_work_queue = lev->work_queue; in nxt_conn_accept()
211 c->write_work_queue = lev->work_queue; in nxt_conn_accept()
H A Dnxt_conn.c126 c->read_timer.work_queue = wq; in nxt_conn_work_queue_set()
127 c->write_timer.work_queue = wq; in nxt_conn_work_queue_set()
H A Dnxt_timer.h36 nxt_work_queue_t *work_queue; member
H A Dnxt_log_moderation.c61 mod->timer.work_queue = &thr->engine->fast_work_queue; in nxt_log_moderate_allow()
H A Dnxt_conn.h110 nxt_work_queue_t *work_queue; member
178 (ev)->work_queue = (wq); \
H A Dnxt_conn_close.c135 c->write_timer.work_queue = &engine->fast_work_queue; in nxt_conn_close_handler()
H A Dnxt_event_conn_job_sendfile.c144 if (first && task->thread->thread_pool->work_queue.head != NULL) { in nxt_event_conn_job_sendfile_handler()
H A Dnxt_timer.c323 nxt_work_queue_add(timer->work_queue, nxt_timer_handler, in nxt_timer_expire()
H A Dnxt_fiber.c391 fib->timer.work_queue = &task->thread->engine->fast_work_queue; in nxt_fiber_sleep()
H A Dnxt_conn_proxy.c89 peer->read_timer.work_queue = client->read_work_queue; in nxt_conn_proxy_create()
90 peer->write_timer.work_queue = client->write_work_queue; in nxt_conn_proxy_create()
H A Dnxt_h1proto_websocket.c106 timer->work_queue = &task->thread->engine->fast_work_queue; in nxt_h1p_websocket_first_frame_start()
H A Dnxt_h1proto.c2195 c->read_timer.work_queue = wq; in nxt_h1p_peer_connect()
2200 c->write_timer.work_queue = wq; in nxt_h1p_peer_connect()
H A Dnxt_router.c1881 app_joint->idle_timer.work_queue = &engine->fast_work_queue; in nxt_router_conf_create()
3788 lev->timer.work_queue = &engine->fast_work_queue; in nxt_router_listen_socket_delete()
5170 r->timer.work_queue = &engine->fast_work_queue; in nxt_router_process_http_request()
H A Dnxt_controller.c690 ls->work_queue = wq; in nxt_runtime_controller_socket()