/unit/src/ |
H A D | nxt_buf_filter.c | 142 nxt_thread_work_queue_add(task->thread, f->work_queue, in nxt_buf_filter() 168 nxt_thread_work_queue_add(task->thread, f->work_queue, f->run->filter_error, in nxt_buf_filter() 217 nxt_thread_work_queue_add(task->thread, f->work_queue, nxt_buf_filter, in nxt_buf_filter_enqueue() 232 nxt_thread_work_queue_add(task->thread, f->work_queue, in nxt_buf_filter_file_read_start() 320 nxt_thread_work_queue_add(task->thread, f->work_queue, f->run->filter_error, in nxt_buf_filter_file_read() 394 nxt_thread_work_queue_add(task->thread, f->work_queue, f->run->filter_error, in nxt_buf_filter_file_job_completion() 431 nxt_thread_work_queue_add(task->thread, f->work_queue, in nxt_buf_filter_buf_completion() 447 nxt_thread_work_queue_add(task->thread, f->work_queue, f->run->filter_error, in nxt_buf_filter_file_read_error()
|
H A D | nxt_thread_pool.c | 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()
|
H A D | nxt_thread_pool.h | 26 nxt_locked_work_queue_t work_queue; member
|
H A D | nxt_listen_socket.h | 16 nxt_work_queue_t *work_queue; member
|
H A D | nxt_conn_accept.c | 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() 205 c->read_work_queue = lev->work_queue; in nxt_conn_accept() 206 c->write_work_queue = lev->work_queue; in nxt_conn_accept()
|
H A D | nxt_upstream_source.h | 60 nxt_work_queue_t *work_queue; member
|
H A D | nxt_conn.c | 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()
|
H A D | nxt_stream_source.c | 61 nxt_conn_work_queue_set(c, us->work_queue); in nxt_stream_source_connect() 265 stream->upstream->work_queue, in nxt_stream_source_read_done() 273 stream->upstream->work_queue, in nxt_stream_source_read_done() 383 stream->upstream->work_queue, in nxt_stream_source_buf_completion()
|
H A D | nxt_buf_filter.h | 94 nxt_work_queue_t *work_queue; member
|
H A D | nxt_timer.h | 36 nxt_work_queue_t *work_queue; member
|
H A D | nxt_log_moderation.c | 61 mod->timer.work_queue = &thr->engine->fast_work_queue; in nxt_log_moderate_allow()
|
H A D | nxt_conn.h | 110 nxt_work_queue_t *work_queue; member 177 (ev)->work_queue = (wq); \
|
H A D | nxt_conn_close.c | 131 c->write_timer.work_queue = &engine->fast_work_queue; in nxt_conn_close_handler()
|
H A D | nxt_event_conn_job_sendfile.c | 144 if (first && task->thread->thread_pool->work_queue.head != NULL) { in nxt_event_conn_job_sendfile_handler()
|
H A D | nxt_http_source.c | 526 nxt_source_filter(task->thread, hs->upstream->work_queue, task, in nxt_http_source_chunk_filter() 568 nxt_source_filter(task->thread, hs->upstream->work_queue, task, in nxt_http_source_body_filter()
|
H A D | nxt_timer.c | 323 nxt_work_queue_add(timer->work_queue, nxt_timer_handler, in nxt_timer_expire()
|
H A D | nxt_fastcgi_source.c | 445 nxt_source_filter(task->thread, fs->upstream->work_queue, task, in nxt_fastcgi_source_record_filter() 701 nxt_source_filter(task->thread, fs->upstream->work_queue, task, in nxt_fastcgi_source_body_filter()
|
H A D | nxt_fiber.c | 391 fib->timer.work_queue = &task->thread->engine->fast_work_queue; in nxt_fiber_sleep()
|
H A D | nxt_conn_proxy.c | 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()
|
H A D | nxt_cache.c | 505 nxt_thread_work_queue_add(thr, &thr->work_queue.main, in nxt_cache_release()
|
H A D | nxt_h1proto_websocket.c | 106 timer->work_queue = &task->thread->engine->fast_work_queue; in nxt_h1p_websocket_first_frame_start()
|
H A D | nxt_h1proto.c | 2184 c->read_timer.work_queue = wq; in nxt_h1p_peer_connect() 2189 c->write_timer.work_queue = wq; in nxt_h1p_peer_connect()
|
H A D | nxt_router.c | 1747 app_joint->idle_timer.work_queue = &engine->fast_work_queue; in nxt_router_conf_create() 3578 lev->timer.work_queue = &engine->fast_work_queue; in nxt_router_listen_socket_delete() 5301 r->timer.work_queue = &engine->fast_work_queue; in nxt_router_process_http_request()
|
H A D | nxt_controller.c | 657 ls->work_queue = wq; in nxt_runtime_controller_socket()
|