Home
last modified time | relevance | path

Searched refs:nxt_work_queue_add (Results 1 – 25 of 33) sorted by path

12

/unit/src/
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, \
H A Dnxt_conn_accept.c212 nxt_work_queue_add(c->read_work_queue, lev->listen->handler, in nxt_conn_accept()
216 nxt_work_queue_add(c->write_work_queue, lev->listen->handler, in nxt_conn_accept()
223 nxt_work_queue_add(lev->socket.read_work_queue, in nxt_conn_accept()
255 nxt_work_queue_add(&engine->close_work_queue, in nxt_conn_accept_close_idle()
H A Dnxt_conn_close.c70 nxt_work_queue_add(wq, handler, c->socket.task, c, engine); in nxt_conn_close()
89 nxt_work_queue_add(&engine->close_work_queue, nxt_conn_close_handler, in nxt_conn_shutdown_handler()
123 nxt_work_queue_add(&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_connect.c29 nxt_work_queue_add(&task->thread->engine->connect_work_queue, in nxt_conn_sys_socket()
73 nxt_work_queue_add(c->write_work_queue, handler, task, c, data); in nxt_conn_io_connect()
140 nxt_work_queue_add(c->write_work_queue, c->write_state->ready_handler, in nxt_conn_connect_test()
183 nxt_work_queue_add(c->write_work_queue, handler, task, c, data); in nxt_conn_connect_error()
H A Dnxt_conn_proxy.c417 nxt_work_queue_add(source->read_work_queue, nxt_conn_proxy_read, in nxt_conn_proxy_read_process()
618 nxt_work_queue_add(source->read_work_queue, nxt_conn_proxy_read, in nxt_conn_proxy_write_process()
H A Dnxt_conn_read.c23 nxt_work_queue_add(&engine->fast_work_queue, state->ready_handler, in nxt_conn_wait()
88 nxt_work_queue_add(c->read_work_queue, in nxt_conn_io_read()
100 nxt_work_queue_add(&engine->fast_work_queue, in nxt_conn_io_read()
H A Dnxt_conn_write.c128 nxt_work_queue_add(c->write_work_queue, c->write_state->ready_handler, in nxt_conn_io_write()
141 nxt_work_queue_add(c->write_work_queue, c->write_state->error_handler, in nxt_conn_io_write()
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()
635 nxt_work_queue_add(ev->read_work_queue, ev->read_handler, in nxt_devpoll_poll()
650 nxt_work_queue_add(ev->write_work_queue, ev->write_handler, in nxt_devpoll_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_event_conn_job_sendfile.c222 nxt_work_queue_add(c->write_work_queue, c->write_state->ready_handler, in nxt_event_conn_job_sendfile_return()
231 nxt_work_queue_add(c->write_work_queue, c->write_state->error_handler, in nxt_event_conn_job_sendfile_return()
252 nxt_work_queue_add(c->write_work_queue, in nxt_event_conn_job_sendfile_completion()
H A Dnxt_event_engine.c409 nxt_work_queue_add(&engine->fast_work_queue, in nxt_event_engine_change()
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_fiber.c18 nxt_work_queue_add(&(thr)->engine->fast_work_queue, \
H A Dnxt_h1proto.c1378 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_h1p_request_header_send()
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_http_chunk_parse.c175 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_http_chunk_parse()
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_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_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_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_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_router_access_log.c259 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_router_access_log_ready()

12