Searched refs:read_handler (Results 1 – 15 of 15) sorted by relevance
/unit/src/ |
H A D | nxt_fd_event.h | 109 nxt_work_handler_t read_handler; member
|
H A D | nxt_conn_read.c | 28 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 D | nxt_poll_engine.c | 604 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 D | nxt_epoll_engine.c | 703 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 D | nxt_select_engine.c | 346 nxt_work_queue_add(ev->read_work_queue, ev->read_handler, in nxt_select_poll()
|
H A D | nxt_conn_accept.c | 53 lev->socket.read_handler = nxt_conn_listen_handler; in nxt_listen_event()
|
H A D | nxt_kqueue_engine.c | 407 ev->read_handler = nxt_kqueue_listen_handler; in nxt_kqueue_enable_accept() 766 handler = ev->read_handler; in nxt_kqueue_poll()
|
H A D | nxt_eventport_engine.c | 556 nxt_work_queue_add(ev->read_work_queue, ev->read_handler, in nxt_eventport_poll()
|
H A D | nxt_cyassl.c | 493 c->socket.read_handler = handler; in nxt_cyassl_conn_test_error()
|
H A D | nxt_pollset_engine.c | 619 nxt_work_queue_add(ev->read_work_queue, ev->read_handler, in nxt_pollset_poll()
|
H A D | nxt_devpoll_engine.c | 635 nxt_work_queue_add(ev->read_work_queue, ev->read_handler, in nxt_devpoll_poll()
|
H A D | nxt_event_engine.c | 207 pipe->event.read_handler = nxt_event_engine_signal_pipe; in nxt_event_engine_signal_pipe_create()
|
H A D | nxt_gnutls.c | 652 c->socket.read_handler = handler; in nxt_gnutls_conn_test_error()
|
H A D | nxt_openssl.c | 1297 c->socket.read_handler = nxt_openssl_conn_handshake; 1511 c->socket.read_handler = nxt_openssl_conn_io_shutdown;
|
H A D | nxt_port_socket.c | 711 port->socket.read_handler = port->queue != NULL in nxt_port_read_enable()
|