Home
last modified time | relevance | path

Searched refs:nxt_work_queue_add (Results 1 – 25 of 33) sorted by last modified time

12

/unit/src/
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_router_access_log.c259 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_router_access_log_ready()
H A Dnxt_router.c2618 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_router_listen_socket_ready()
2750 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_router_tls_rpc_handler()
2902 nxt_work_queue_add(&engine->fast_work_queue, in nxt_router_app_prefork_ready()
3888 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_router_response_ready_handler()
H A Dnxt_port_socket.c216 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_port_socket_write2()
549 nxt_work_queue_add(wq, nxt_port_error_handler, task, &port->socket, in nxt_port_write_handler()
670 nxt_work_queue_add(wq, b->completion_handler, task, b, b->parent); in nxt_port_buf_completion()
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()
1289 nxt_work_queue_add(port->socket.read_work_queue, in nxt_port_read_msg_process()
1371 nxt_work_queue_add(wq, b->completion_handler, task, b, b->parent); in nxt_port_error_handler()
H A Dnxt_h1proto.c1378 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_h1p_request_header_send()
H A Dnxt_openssl.c1215 nxt_work_queue_add(c->read_work_queue, c->read_state->error_handler,
1327 nxt_work_queue_add(wq, handler, task, c, data);
1539 nxt_work_queue_add(c->write_work_queue, handler, task, c, data);
H A Dnxt_work_queue.h89 NXT_EXPORT void nxt_work_queue_add(nxt_work_queue_t *wq,
H A Dnxt_fiber.c18 nxt_work_queue_add(&(thr)->engine->fast_work_queue, \
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_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_h1proto_websocket.c688 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_h1p_conn_ws_pong()
H A Dnxt_event_engine.c409 nxt_work_queue_add(&engine->fast_work_queue, in nxt_event_engine_change()
H A Dnxt_work_queue.c160 nxt_work_queue_add(nxt_work_queue_t *wq, nxt_work_handler_t handler, in nxt_work_queue_add() function
306 nxt_work_queue_add(wq, work->handler, work->task, in nxt_locked_work_queue_move()
H A Dnxt_sendbuf.c442 nxt_work_queue_add(wq, handler, task, start, start->parent); in nxt_sendbuf_coalesce_completion()
H A Dnxt_timer.c323 nxt_work_queue_add(timer->work_queue, nxt_timer_handler, in nxt_timer_expire()
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()
346 nxt_work_queue_add(ev->read_work_queue, ev->read_handler, in nxt_select_poll()
363 nxt_work_queue_add(ev->write_work_queue, ev->write_handler, in nxt_select_poll()
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()
613 nxt_work_queue_add(ev->read_work_queue, ev->read_handler, in nxt_poll()
625 nxt_work_queue_add(ev->write_work_queue, ev->write_handler, 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()
619 nxt_work_queue_add(ev->read_work_queue, ev->read_handler, in nxt_pollset_poll()
634 nxt_work_queue_add(ev->write_work_queue, ev->write_handler, in nxt_pollset_poll()
H A Dnxt_http_websocket.c92 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_http_websocket_client()
H A Dnxt_job.c175 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_job_return()
H A Dnxt_kqueue_engine.c510 nxt_work_queue_add(wq, nxt_kqueue_fd_error_handler, in nxt_kqueue_error()
516 nxt_work_queue_add(wq, nxt_kqueue_file_error_handler, in nxt_kqueue_error()
840 nxt_work_queue_add(wq, handler, task, obj, data); in nxt_kqueue_poll()
888 nxt_work_queue_add(c->write_work_queue, handler, task, c, data); in nxt_kqueue_conn_io_connect()
907 nxt_work_queue_add(c->write_work_queue, c->write_state->ready_handler, in nxt_kqueue_conn_connected()
985 nxt_work_queue_add(c->read_work_queue, c->read_state->close_handler, in nxt_kqueue_conn_io_read()
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()
556 nxt_work_queue_add(ev->read_work_queue, ev->read_handler, in nxt_eventport_poll()
570 nxt_work_queue_add(ev->write_work_queue, ev->write_handler, 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()
951 nxt_work_queue_add(ev->read_work_queue, ev->read_handler, in nxt_epoll_poll()
971 nxt_work_queue_add(ev->write_work_queue, ev->write_handler, in nxt_epoll_poll()
999 nxt_work_queue_add(&engine->fast_work_queue, nxt_epoll_error_handler, in nxt_epoll_poll()
1125 nxt_work_queue_add(c->write_work_queue, handler, task, c, data); in nxt_epoll_edge_conn_io_connect()
1145 nxt_work_queue_add(c->write_work_queue, c->write_state->ready_handler, in nxt_epoll_edge_conn_connected()
H A Dnxt_conn.h271 nxt_work_queue_add(&engine->socket_work_queue, nxt_conn_sys_socket, \
281 nxt_work_queue_add(&e->read_work_queue, c->io->read, \
292 nxt_work_queue_add(&e->write_work_queue, c->io->write, \

12