/unit/src/ |
H A D | nxt_router.c | 1881 app_joint->idle_timer.work_queue = &engine->fast_work_queue; in nxt_router_conf_create() 2241 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_router_js_module_rpc_handler() 2872 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_router_listen_socket_ready() 3004 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_router_tls_rpc_handler() 3156 nxt_work_queue_add(&engine->fast_work_queue, in nxt_router_app_prefork_ready() 3788 lev->timer.work_queue = &engine->fast_work_queue; in nxt_router_listen_socket_delete() 4179 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_router_response_ready_handler() 5170 r->timer.work_queue = &engine->fast_work_queue; in nxt_router_process_http_request()
|
H A D | nxt_runtime.c | 138 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_runtime_create() 462 nxt_work_queue_add(&engine->fast_work_queue, nxt_runtime_exit, in nxt_runtime_quit()
|
H A D | nxt_http_static.c | 830 wq = &task->thread->engine->fast_work_queue; in nxt_http_static_body_handler()
|
H A D | nxt_router_access_log.c | 287 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_router_access_log_ready()
|
H A D | nxt_h1proto.c | 230 c->read_work_queue = &engine->fast_work_queue; in nxt_http_conn_init() 231 c->write_work_queue = &engine->fast_work_queue; in nxt_http_conn_init() 1388 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_h1p_request_header_send() 1585 wq = &task->thread->engine->fast_work_queue; in nxt_h1p_request_discard() 1735 c->write = nxt_sendbuf_completion(task, &engine->fast_work_queue, c->write); in nxt_h1p_conn_sent() 2399 c->write = nxt_sendbuf_completion(task, &engine->fast_work_queue, c->write); in nxt_h1p_peer_header_sent()
|
H A D | nxt_tstr.c | 316 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_tstr_query_resolve() 330 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_tstr_query_handle()
|
H A D | nxt_kqueue_engine.c | 500 wq = &engine->fast_work_queue; in nxt_kqueue_error() 738 wq = &engine->fast_work_queue; in nxt_kqueue_poll()
|
H A D | nxt_job.c | 177 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_job_return()
|
H A D | nxt_conn_close.c | 127 nxt_work_queue_add(&engine->fast_work_queue, in nxt_conn_close_handler() 135 c->write_timer.work_queue = &engine->fast_work_queue; in nxt_conn_close_handler() 165 nxt_work_queue_add(&engine->fast_work_queue, c->write_state->ready_handler, in nxt_conn_close_timer_handler()
|
H A D | nxt_event_engine.h | 447 nxt_work_queue_t fast_work_queue; member
|
H A D | nxt_conn_accept.c | 62 lev->timer.work_queue = &engine->fast_work_queue; in nxt_listen_event()
|
H A D | nxt_port_socket.c | 136 port->socket.write_work_queue = &port->engine->fast_work_queue; in nxt_port_write_enable() 216 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_port_socket_write2() 387 wq = &task->thread->engine->fast_work_queue; in nxt_port_write_handler() 710 port->socket.read_work_queue = &port->engine->fast_work_queue; in nxt_port_read_enable() 804 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_port_read_handler() 1020 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_port_queue_read_handler() 1355 wq = &task->thread->engine->fast_work_queue; in nxt_port_error_handler()
|
H A D | nxt_fiber.c | 18 nxt_work_queue_add(&(thr)->engine->fast_work_queue, \ 391 fib->timer.work_queue = &task->thread->engine->fast_work_queue; in nxt_fiber_sleep()
|
H A D | nxt_http_chunk_parse.c | 175 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_http_chunk_parse()
|
H A D | nxt_h1proto_websocket.c | 106 timer->work_queue = &task->thread->engine->fast_work_queue; in nxt_h1p_websocket_first_frame_start() 688 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_h1p_conn_ws_pong()
|
H A D | nxt_event_engine.c | 74 engine->current_work_queue = &engine->fast_work_queue; in nxt_event_engine_create() 78 engine->fast_work_queue.cache = &engine->work_queue_cache; in nxt_event_engine_create() 87 nxt_work_queue_name(&engine->fast_work_queue, "fast"); in nxt_event_engine_create() 206 pipe->event.read_work_queue = &engine->fast_work_queue; in nxt_event_engine_signal_pipe_create() 208 pipe->event.write_work_queue = &engine->fast_work_queue; in nxt_event_engine_signal_pipe_create() 339 &engine->fast_work_queue); in nxt_event_engine_post_handler() 409 nxt_work_queue_add(&engine->fast_work_queue, in nxt_event_engine_change() 475 wq = &engine->fast_work_queue; in nxt_event_engine_queue_pop() 484 wq = &engine->fast_work_queue; in nxt_event_engine_queue_pop() 494 engine->current_work_queue = &engine->fast_work_queue; in nxt_event_engine_queue_pop() [all …]
|
H A D | nxt_thread_pool.c | 239 nxt_work_queue_add(&thr->engine->fast_work_queue, tp->exit, in nxt_thread_pool_destroy()
|
H A D | nxt_select_engine.c | 137 nxt_work_queue_add(&engine->fast_work_queue, nxt_select_error_handler, in nxt_select_enable_read() 164 nxt_work_queue_add(&engine->fast_work_queue, nxt_select_error_handler, in nxt_select_enable_write()
|
H A D | nxt_poll_engine.c | 368 nxt_work_queue_add(&engine->fast_work_queue, ev->error_handler, in nxt_poll_commit_changes() 570 nxt_work_queue_add(&engine->fast_work_queue, in nxt_poll()
|
H A D | nxt_pollset_engine.c | 471 nxt_work_queue_add(&engine->fast_work_queue, ev->error_handler, in nxt_pollset_change_error() 610 nxt_work_queue_add(&engine->fast_work_queue, ev->error_handler, in nxt_pollset_poll()
|
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_http_websocket.c | 92 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_http_websocket_client()
|
H A D | nxt_eventport_engine.c | 344 nxt_work_queue_add(&engine->fast_work_queue, in nxt_eventport_commit_changes() 546 nxt_work_queue_add(&engine->fast_work_queue, in nxt_eventport_poll() 599 nxt_work_queue_add(&engine->fast_work_queue, handler, in nxt_eventport_poll()
|
H A D | nxt_epoll_engine.c | 635 nxt_work_queue_add(&engine->fast_work_queue, in nxt_epoll_commit_changes() 702 engine->u.epoll.signalfd.read_work_queue = &engine->fast_work_queue; in nxt_epoll_add_signal() 784 engine->u.epoll.eventfd.read_work_queue = &engine->fast_work_queue; in nxt_epoll_enable_post() 999 nxt_work_queue_add(&engine->fast_work_queue, nxt_epoll_error_handler, in nxt_epoll_poll()
|
H A D | nxt_conn_read.c | 23 nxt_work_queue_add(&engine->fast_work_queue, state->ready_handler, in nxt_conn_wait() 100 nxt_work_queue_add(&engine->fast_work_queue, in nxt_conn_io_read()
|