Home
last modified time | relevance | path

Searched refs:fast_work_queue (Results 1 – 25 of 27) sorted by relevance

12

/unit/src/
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_conn_close.c123 nxt_work_queue_add(&engine->fast_work_queue, in nxt_conn_close_handler()
131 c->write_timer.work_queue = &engine->fast_work_queue; in nxt_conn_close_handler()
154 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_conn_close_timer_handler()
H A Dnxt_conn.c80 c->socket.read_work_queue = &thr->engine->fast_work_queue; in nxt_conn_create()
81 c->socket.write_work_queue = &thr->engine->fast_work_queue; in nxt_conn_create()
H A Dnxt_log_moderation.c61 mod->timer.work_queue = &thr->engine->fast_work_queue; in nxt_log_moderate_allow()
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()
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_http_websocket.c92 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_http_websocket_client()
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_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_job.c175 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_job_return()
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_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_thread_pool.c239 nxt_work_queue_add(&thr->engine->fast_work_queue, tp->exit, in nxt_thread_pool_destroy()
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_devpoll_engine.c486 nxt_work_queue_add(&engine->fast_work_queue, ev->error_handler, in nxt_devpoll_change_error()
626 nxt_work_queue_add(&engine->fast_work_queue, ev->error_handler, in nxt_devpoll_poll()
H A Dnxt_var.c673 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_var_query_resolve()
687 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_var_query_handle()
H A Dnxt_event_engine.h447 nxt_work_queue_t fast_work_queue; member
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_conn_accept.c62 lev->timer.work_queue = &engine->fast_work_queue; in nxt_listen_event()
H A Dnxt_router_access_log.c259 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()
1378 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_h1p_request_header_send()
1575 wq = &task->thread->engine->fast_work_queue; in nxt_h1p_request_discard()
1725 c->write = nxt_sendbuf_completion(task, &engine->fast_work_queue, c->write); in nxt_h1p_conn_sent()
2388 c->write = nxt_sendbuf_completion(task, &engine->fast_work_queue, c->write); in nxt_h1p_peer_header_sent()
H A Dnxt_kqueue_engine.c500 wq = &engine->fast_work_queue; in nxt_kqueue_error()
737 wq = &engine->fast_work_queue; in nxt_kqueue_poll()
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()

12