Home
last modified time | relevance | path

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

/unit/src/
H A Dnxt_buf_filter.c142 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 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()
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 Dnxt_upstream_source.h60 nxt_work_queue_t *work_queue; member
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_stream_source.c61 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 Dnxt_buf_filter.h94 nxt_work_queue_t *work_queue; member
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
177 (ev)->work_queue = (wq); \
H A Dnxt_conn_close.c131 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_http_source.c526 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 Dnxt_timer.c323 nxt_work_queue_add(timer->work_queue, nxt_timer_handler, in nxt_timer_expire()
H A Dnxt_fastcgi_source.c445 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 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_cache.c505 nxt_thread_work_queue_add(thr, &thr->work_queue.main, in nxt_cache_release()
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.c2184 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 Dnxt_router.c1747 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 Dnxt_controller.c657 ls->work_queue = wq; in nxt_runtime_controller_socket()