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_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_router.c2240 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_router_js_module_rpc_handler()
2876 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_router_listen_socket_ready()
3008 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_router_tls_rpc_handler()
3160 nxt_work_queue_add(&engine->fast_work_queue, in nxt_router_app_prefork_ready()
4183 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_router_response_ready_handler()
H A Dnxt_h1proto.c1388 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_h1p_request_header_send()
H A Dnxt_tstr.c316 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 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_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()
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 Dnxt_job.c177 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_job_return()
H A Dnxt_router_access_log.c262 nxt_work_queue_add(&task->thread->engine->fast_work_queue, in nxt_router_access_log_ready()
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_conn.h272 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 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()
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 Dnxt_conn_accept.c217 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 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_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_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()

12