/unit/src/ |
H A D | nxt_conn_connect.c | 22 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 D | nxt_conn.c | 81 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 D | nxt_conn.h | 132 nxt_work_queue_t *write_work_queue; member 291 c->socket.write_work_queue = &e->write_work_queue; \ 293 nxt_work_queue_add(&e->write_work_queue, c->io->write, \
|
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_conn_proxy.c | 79 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 D | nxt_fd_event.h | 110 nxt_work_queue_t *write_work_queue; member
|
H A D | nxt_event_engine.c | 83 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 D | nxt_conn_accept.c | 211 c->write_work_queue = lev->work_queue; in nxt_conn_accept() 221 nxt_work_queue_add(c->write_work_queue, lev->listen->handler, in nxt_conn_accept()
|
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_cyassl.c | 470 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 D | nxt_kqueue_engine.c | 799 wq = ev->write_work_queue; 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()
|
H A D | nxt_epoll_engine.c | 971 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 D | nxt_event_engine.h | 452 nxt_work_queue_t write_work_queue; member
|
H A D | nxt_select_engine.c | 363 nxt_work_queue_add(ev->write_work_queue, ev->write_handler, in nxt_select_poll()
|
H A D | nxt_eventport_engine.c | 570 nxt_work_queue_add(ev->write_work_queue, ev->write_handler, in nxt_eventport_poll()
|
H A D | nxt_poll_engine.c | 625 nxt_work_queue_add(ev->write_work_queue, ev->write_handler, in nxt_poll()
|
H A D | nxt_pollset_engine.c | 634 nxt_work_queue_add(ev->write_work_queue, ev->write_handler, in nxt_pollset_poll()
|
H A D | nxt_devpoll_engine.c | 650 nxt_work_queue_add(ev->write_work_queue, ev->write_handler, in nxt_devpoll_poll()
|
H A D | nxt_gnutls.c | 626 nxt_event_conn_io_handle(thr, c->write_work_queue, handler, c, data); in nxt_gnutls_conn_io_shutdown()
|
H A D | nxt_h1proto.c | 231 c->write_work_queue = &engine->fast_work_queue; in nxt_http_conn_init() 2197 wq = socket->write_work_queue; in nxt_h1p_peer_connect() 2198 c->write_work_queue = wq; in nxt_h1p_peer_connect() 2199 c->socket.write_work_queue = wq; in nxt_h1p_peer_connect()
|
H A D | nxt_openssl.c | 1325 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 D | nxt_controller.c | 754 c->write_work_queue = &engine->write_work_queue; in nxt_controller_conn_init()
|
H A D | nxt_port_socket.c | 136 port->socket.write_work_queue = &port->engine->fast_work_queue; in nxt_port_write_enable()
|