/unit/src/ |
H A D | nxt_conn_close.c | 70 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() 127 nxt_work_queue_add(&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 D | nxt_conn_connect.c | 29 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 D | nxt_conn_read.c | 23 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 D | nxt_event_conn_job_sendfile.c | 222 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 D | nxt_select_engine.c | 137 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 D | nxt_conn_accept.c | 217 nxt_work_queue_add(c->read_work_queue, lev->listen->handler, in nxt_conn_accept() 221 nxt_work_queue_add(c->write_work_queue, lev->listen->handler, in nxt_conn_accept() 228 nxt_work_queue_add(lev->socket.read_work_queue, in nxt_conn_accept() 260 nxt_work_queue_add(&engine->close_work_queue, in nxt_conn_accept_close_idle()
|
H A D | nxt_conn.h | 272 nxt_work_queue_add(&engine->socket_work_queue, nxt_conn_sys_socket, \ 282 nxt_work_queue_add(&e->read_work_queue, c->io->read, \ 293 nxt_work_queue_add(&e->write_work_queue, c->io->write, \
|
H A D | nxt_eventport_engine.c | 344 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 D | nxt_work_queue.c | 160 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 D | nxt_work_queue.h | 89 NXT_EXPORT void nxt_work_queue_add(nxt_work_queue_t *wq,
|
H A D | nxt_poll_engine.c | 368 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 D | nxt_pollset_engine.c | 471 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 D | nxt_devpoll_engine.c | 486 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 D | nxt_tstr.c | 316 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 D | nxt_kqueue_engine.c | 510 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() 841 nxt_work_queue_add(wq, handler, task, obj, data); in nxt_kqueue_poll() 889 nxt_work_queue_add(c->write_work_queue, handler, task, c, data); in nxt_kqueue_conn_io_connect() 908 nxt_work_queue_add(c->write_work_queue, c->write_state->ready_handler, in nxt_kqueue_conn_connected() 986 nxt_work_queue_add(c->read_work_queue, c->read_state->close_handler, in nxt_kqueue_conn_io_read()
|
H A D | nxt_port_socket.c | 216 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 D | nxt_epoll_engine.c | 635 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 D | nxt_http_websocket.c | 92 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_http_websocket_client()
|
H A D | nxt_job.c | 177 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_job_return()
|
H A D | nxt_http_chunk_parse.c | 175 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_http_chunk_parse()
|
H A D | nxt_conn_write.c | 128 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 D | nxt_thread_pool.c | 239 nxt_work_queue_add(&thr->engine->fast_work_queue, tp->exit, in nxt_thread_pool_destroy()
|
H A D | nxt_timer.c | 323 nxt_work_queue_add(timer->work_queue, nxt_timer_handler, in nxt_timer_expire()
|
H A D | nxt_sendbuf.c | 442 nxt_work_queue_add(wq, handler, task, start, start->parent); in nxt_sendbuf_coalesce_completion()
|
H A D | nxt_fiber.c | 18 nxt_work_queue_add(&(thr)->engine->fast_work_queue, \
|