Home
last modified time | relevance | path

Searched refs:write_work_queue (Results 1 – 24 of 24) sorted by relevance

/unit/src/
H A Dnxt_conn_connect.c22 c->socket.write_work_queue = c->write_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.c81 c->socket.write_work_queue = &thr->engine->fast_work_queue; in nxt_conn_create()
84 nxt_conn_timer_init(&c->write_timer, c, c->socket.write_work_queue); in nxt_conn_create()
125 c->write_work_queue = wq; in nxt_conn_work_queue_set()
H A Dnxt_conn.h132 nxt_work_queue_t *write_work_queue; member
290 c->socket.write_work_queue = &e->write_work_queue; \
292 nxt_work_queue_add(&e->write_work_queue, c->io->write, \
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_conn_proxy.c79 client->write_work_queue = &thr->engine->write_work_queue; in nxt_conn_proxy_create()
81 client->socket.write_work_queue = &thr->engine->write_work_queue; in nxt_conn_proxy_create()
83 peer->socket.write_work_queue = &thr->engine->write_work_queue; in nxt_conn_proxy_create()
88 peer->write_work_queue = client->write_work_queue; in nxt_conn_proxy_create()
90 peer->write_timer.work_queue = client->write_work_queue; in nxt_conn_proxy_create()
H A Dnxt_fd_event.h110 nxt_work_queue_t *write_work_queue; member
H A Dnxt_event_engine.c83 engine->write_work_queue.cache = &engine->work_queue_cache; in nxt_event_engine_create()
92 nxt_work_queue_name(&engine->write_work_queue, "write"); in nxt_event_engine_create()
208 pipe->event.write_work_queue = &engine->fast_work_queue; in nxt_event_engine_signal_pipe_create()
754 nxt_work_queue_thread_adopt(&engine->write_work_queue); in nxt_event_engine_thread_adopt()
H A Dnxt_conn_accept.c206 c->write_work_queue = lev->work_queue; in nxt_conn_accept()
216 nxt_work_queue_add(c->write_work_queue, lev->listen->handler, in nxt_conn_accept()
H A Dnxt_stream_source.c204 nxt_source_filter(task->thread, c->write_work_queue, task, in nxt_stream_source_read_ready()
438 nxt_source_filter(task->thread, c->write_work_queue, task, stream->next, b); in nxt_stream_source_closed()
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_cyassl.c470 nxt_event_conn_io_handle(thr, c->write_work_queue, in nxt_cyassl_conn_io_shutdown()
521 wq = c->write_work_queue; in nxt_cyassl_conn_test_error()
H A Dnxt_kqueue_engine.c798 wq = ev->write_work_queue; 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()
H A Dnxt_event_engine.h452 nxt_work_queue_t write_work_queue; member
H A Dnxt_epoll_engine.c971 nxt_work_queue_add(ev->write_work_queue, ev->write_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_select_engine.c363 nxt_work_queue_add(ev->write_work_queue, ev->write_handler, in nxt_select_poll()
H A Dnxt_h1proto.c231 c->write_work_queue = &engine->fast_work_queue; in nxt_http_conn_init()
2186 wq = socket->write_work_queue; in nxt_h1p_peer_connect()
2187 c->write_work_queue = wq; in nxt_h1p_peer_connect()
2188 c->socket.write_work_queue = wq; in nxt_h1p_peer_connect()
H A Dnxt_eventport_engine.c570 nxt_work_queue_add(ev->write_work_queue, ev->write_handler, in nxt_eventport_poll()
H A Dnxt_poll_engine.c625 nxt_work_queue_add(ev->write_work_queue, ev->write_handler, in nxt_poll()
H A Dnxt_pollset_engine.c634 nxt_work_queue_add(ev->write_work_queue, ev->write_handler, in nxt_pollset_poll()
H A Dnxt_devpoll_engine.c650 nxt_work_queue_add(ev->write_work_queue, ev->write_handler, in nxt_devpoll_poll()
H A Dnxt_gnutls.c626 nxt_event_conn_io_handle(thr, c->write_work_queue, handler, c, data); in nxt_gnutls_conn_io_shutdown()
H A Dnxt_openssl.c1325 wq = (c->read_state != NULL) ? c->read_work_queue : c->write_work_queue;
1539 nxt_work_queue_add(c->write_work_queue, handler, task, c, data);
H A Dnxt_controller.c713 c->write_work_queue = &engine->write_work_queue; in nxt_controller_conn_init()
H A Dnxt_port_socket.c136 port->socket.write_work_queue = &port->engine->fast_work_queue; in nxt_port_write_enable()