| /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()
|