Home
last modified time | relevance | path

Searched refs:fast_work_queue (Results 1 – 25 of 27) sorted by last modified time

12

/unit/src/
H A Dnxt_router.c1881 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 Dnxt_runtime.c138 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 Dnxt_http_static.c830 wq = &task->thread->engine->fast_work_queue; in nxt_http_static_body_handler()
H A Dnxt_router_access_log.c287 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_router_access_log_ready()
H A Dnxt_h1proto.c230 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 Dnxt_tstr.c316 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 Dnxt_kqueue_engine.c500 wq = &engine->fast_work_queue; in nxt_kqueue_error()
738 wq = &engine->fast_work_queue; in nxt_kqueue_poll()
H A Dnxt_job.c177 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_job_return()
H A Dnxt_conn_close.c127 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 Dnxt_event_engine.h447 nxt_work_queue_t fast_work_queue; member
H A Dnxt_conn_accept.c62 lev->timer.work_queue = &engine->fast_work_queue; in nxt_listen_event()
H A Dnxt_port_socket.c136 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 Dnxt_fiber.c18 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 Dnxt_http_chunk_parse.c175 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_http_chunk_parse()
H A Dnxt_h1proto_websocket.c106 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 Dnxt_event_engine.c74 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 Dnxt_thread_pool.c239 nxt_work_queue_add(&thr->engine->fast_work_queue, tp->exit, in nxt_thread_pool_destroy()
H A Dnxt_select_engine.c137 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 Dnxt_poll_engine.c368 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 Dnxt_pollset_engine.c471 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 Dnxt_log_moderation.c61 mod->timer.work_queue = &thr->engine->fast_work_queue; in nxt_log_moderate_allow()
H A Dnxt_http_websocket.c92 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_http_websocket_client()
H A Dnxt_eventport_engine.c344 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 Dnxt_epoll_engine.c635 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 Dnxt_conn_read.c23 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()

12