Home
last modified time | relevance | path

Searched refs:read_handler (Results 1 – 15 of 15) sorted by relevance

/unit/src/
H A Dnxt_fd_event.h109 nxt_work_handler_t read_handler; member
H A Dnxt_conn_read.c28 c->socket.read_handler = state->ready_handler; in nxt_conn_wait()
62 c->socket.read_handler = c->io->read; in nxt_conn_io_read()
H A Dnxt_poll_engine.c604 if ((events & POLLIN) || (error && ev->read_handler != NULL)) { in nxt_poll()
613 nxt_work_queue_add(ev->read_work_queue, ev->read_handler, in nxt_poll()
H A Dnxt_epoll_engine.c703 engine->u.epoll.signalfd.read_handler = nxt_epoll_signalfd_handler; in nxt_epoll_add_signal()
785 engine->u.epoll.eventfd.read_handler = nxt_epoll_eventfd_handler; 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_conn_accept.c53 lev->socket.read_handler = nxt_conn_listen_handler; in nxt_listen_event()
H A Dnxt_kqueue_engine.c407 ev->read_handler = nxt_kqueue_listen_handler; in nxt_kqueue_enable_accept()
766 handler = ev->read_handler; in nxt_kqueue_poll()
H A Dnxt_eventport_engine.c556 nxt_work_queue_add(ev->read_work_queue, ev->read_handler, in nxt_eventport_poll()
H A Dnxt_cyassl.c493 c->socket.read_handler = handler; in nxt_cyassl_conn_test_error()
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_event_engine.c207 pipe->event.read_handler = nxt_event_engine_signal_pipe; in nxt_event_engine_signal_pipe_create()
H A Dnxt_gnutls.c652 c->socket.read_handler = handler; in nxt_gnutls_conn_test_error()
H A Dnxt_openssl.c1297 c->socket.read_handler = nxt_openssl_conn_handshake;
1511 c->socket.read_handler = nxt_openssl_conn_io_shutdown;
H A Dnxt_port_socket.c711 port->socket.read_handler = port->queue != NULL in nxt_port_read_enable()