Home
last modified time | relevance | path

Searched refs:read_work_queue (Results 1 – 22 of 22) sorted by relevance

/unit/src/
H A Dnxt_conn_accept.c52 lev->socket.read_work_queue = &engine->accept_work_queue; in nxt_listen_event()
60 lev->work_queue = &engine->read_work_queue; in nxt_listen_event()
106 c->socket.read_work_queue = lev->socket.read_work_queue; in nxt_conn_accept_alloc()
205 c->read_work_queue = lev->work_queue; in nxt_conn_accept()
212 nxt_work_queue_add(c->read_work_queue, lev->listen->handler, in nxt_conn_accept()
223 nxt_work_queue_add(lev->socket.read_work_queue, in nxt_conn_accept()
H A Dnxt_conn.c80 c->socket.read_work_queue = &thr->engine->fast_work_queue; in nxt_conn_create()
83 nxt_conn_timer_init(&c->read_timer, c, c->socket.read_work_queue); in nxt_conn_create()
124 c->read_work_queue = wq; in nxt_conn_work_queue_set()
H A Dnxt_conn_proxy.c78 client->read_work_queue = &thr->engine->read_work_queue; in nxt_conn_proxy_create()
80 client->socket.read_work_queue = &thr->engine->read_work_queue; in nxt_conn_proxy_create()
82 peer->socket.read_work_queue = &thr->engine->read_work_queue; in nxt_conn_proxy_create()
87 peer->read_work_queue = client->read_work_queue; in nxt_conn_proxy_create()
89 peer->read_timer.work_queue = client->read_work_queue; in nxt_conn_proxy_create()
417 nxt_work_queue_add(source->read_work_queue, nxt_conn_proxy_read, in nxt_conn_proxy_read_process()
618 nxt_work_queue_add(source->read_work_queue, nxt_conn_proxy_read, in nxt_conn_proxy_write_process()
H A Dnxt_conn.h127 nxt_work_queue_t *read_work_queue; member
279 c->socket.read_work_queue = &e->read_work_queue; \
281 nxt_work_queue_add(&e->read_work_queue, c->io->read, \
H A Dnxt_fd_event.h108 nxt_work_queue_t *read_work_queue; member
H A Dnxt_event_engine.c80 engine->read_work_queue.cache = &engine->work_queue_cache; in nxt_event_engine_create()
89 nxt_work_queue_name(&engine->read_work_queue, "read"); in nxt_event_engine_create()
206 pipe->event.read_work_queue = &engine->fast_work_queue; in nxt_event_engine_signal_pipe_create()
227 if (pipe->event.read_work_queue != NULL) { in nxt_event_engine_signal_pipe_free()
751 nxt_work_queue_thread_adopt(&engine->read_work_queue); in nxt_event_engine_thread_adopt()
H A Dnxt_cyassl.c222 nxt_event_conn_io_handle(thr, c->read_work_queue, in nxt_cyassl_conn_init()
329 nxt_event_conn_io_handle(thr, c->read_work_queue, in nxt_cyassl_conn_handshake()
390 nxt_event_conn_io_handle(thr, c->read_work_queue, handler, c, data); in nxt_cyassl_conn_io_read()
517 wq = c->read_work_queue; in nxt_cyassl_conn_test_error()
H A Dnxt_gnutls.c331 nxt_event_conn_io_handle(thr, c->read_work_queue, in nxt_gnutls_conn_init()
456 nxt_event_conn_io_handle(thr, c->read_work_queue, in nxt_gnutls_conn_handshake()
521 nxt_event_conn_io_handle(thr, c->read_work_queue, handler, c, data); in nxt_gnutls_conn_io_read()
H A Dnxt_conn_read.c88 nxt_work_queue_add(c->read_work_queue, in nxt_conn_io_read()
H A Dnxt_event_engine.h449 nxt_work_queue_t read_work_queue; member
H A Dnxt_epoll_engine.c702 engine->u.epoll.signalfd.read_work_queue = &engine->fast_work_queue; in nxt_epoll_add_signal()
784 engine->u.epoll.eventfd.read_work_queue = &engine->fast_work_queue; in nxt_epoll_enable_post()
951 nxt_work_queue_add(ev->read_work_queue, ev->read_handler, in nxt_epoll_poll()
H A Dnxt_select_engine.c346 nxt_work_queue_add(ev->read_work_queue, ev->read_handler, in nxt_select_poll()
H A Dnxt_stream_source.c112 &task->thread->engine->read_work_queue, in nxt_stream_source_connected()
H A Dnxt_kqueue_engine.c767 wq = ev->read_work_queue; in nxt_kqueue_poll()
985 nxt_work_queue_add(c->read_work_queue, c->read_state->close_handler, in nxt_kqueue_conn_io_read()
H A Dnxt_h1proto.c230 c->read_work_queue = &engine->fast_work_queue; in nxt_http_conn_init()
2181 wq = socket->read_work_queue; in nxt_h1p_peer_connect()
2182 c->read_work_queue = wq; in nxt_h1p_peer_connect()
2183 c->socket.read_work_queue = wq; in nxt_h1p_peer_connect()
H A Dnxt_eventport_engine.c556 nxt_work_queue_add(ev->read_work_queue, ev->read_handler, in nxt_eventport_poll()
H A Dnxt_port_socket.c710 port->socket.read_work_queue = &port->engine->fast_work_queue; in nxt_port_read_enable()
1289 nxt_work_queue_add(port->socket.read_work_queue, in nxt_port_read_msg_process()
H A Dnxt_poll_engine.c613 nxt_work_queue_add(ev->read_work_queue, ev->read_handler, in nxt_poll()
H A Dnxt_pollset_engine.c619 nxt_work_queue_add(ev->read_work_queue, ev->read_handler, in nxt_pollset_poll()
H A Dnxt_devpoll_engine.c635 nxt_work_queue_add(ev->read_work_queue, ev->read_handler, in nxt_devpoll_poll()
H A Dnxt_openssl.c1215 nxt_work_queue_add(c->read_work_queue, c->read_state->error_handler,
1325 wq = (c->read_state != NULL) ? c->read_work_queue : c->write_work_queue;
H A Dnxt_controller.c712 c->read_work_queue = &engine->read_work_queue; in nxt_controller_conn_init()