Home
last modified time | relevance | path

Searched refs:nxt_work_queue_add (Results 1 – 25 of 32) sorted by relevance

12

/unit/src/
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_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_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_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_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.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_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_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_work_queue.h89 NXT_EXPORT void nxt_work_queue_add(nxt_work_queue_t *wq,
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_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_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_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_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_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_http_chunk_parse.c175 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_http_chunk_parse()
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_thread_pool.c239 nxt_work_queue_add(&thr->engine->fast_work_queue, tp->exit, in nxt_thread_pool_destroy()
H A Dnxt_timer.c323 nxt_work_queue_add(timer->work_queue, nxt_timer_handler, in nxt_timer_expire()
H A Dnxt_sendbuf.c442 nxt_work_queue_add(wq, handler, task, start, start->parent); in nxt_sendbuf_coalesce_completion()
H A Dnxt_fiber.c18 nxt_work_queue_add(&(thr)->engine->fast_work_queue, \
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);

12