Searched refs:work_queue (Results 1 – 17 of 17) sorted by relevance
50 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()
26 nxt_locked_work_queue_t work_queue; member
16 nxt_work_queue_t *work_queue; member
60 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()
126 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()
36 nxt_work_queue_t *work_queue; member
61 mod->timer.work_queue = &thr->engine->fast_work_queue; in nxt_log_moderate_allow()
110 nxt_work_queue_t *work_queue; member178 (ev)->work_queue = (wq); \
135 c->write_timer.work_queue = &engine->fast_work_queue; in nxt_conn_close_handler()
144 if (first && task->thread->thread_pool->work_queue.head != NULL) { in nxt_event_conn_job_sendfile_handler()
323 nxt_work_queue_add(timer->work_queue, nxt_timer_handler, in nxt_timer_expire()
391 fib->timer.work_queue = &task->thread->engine->fast_work_queue; in nxt_fiber_sleep()
89 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()
106 timer->work_queue = &task->thread->engine->fast_work_queue; in nxt_h1p_websocket_first_frame_start()
2195 c->read_timer.work_queue = wq; in nxt_h1p_peer_connect()2200 c->write_timer.work_queue = wq; in nxt_h1p_peer_connect()
1881 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()
690 ls->work_queue = wq; in nxt_runtime_controller_socket()