Home
last modified time | relevance | path

Searched refs:read_ready (Results 1 – 17 of 17) sorted by relevance

/unit/src/
H A Dnxt_conn_read.c17 c->socket.fd, c->socket.read_ready); in nxt_conn_wait()
22 if (c->socket.read_ready) { in nxt_conn_wait()
49 c->socket.fd, c->socket.read_ready, c->socket.closed, in nxt_conn_io_read()
66 if (c->socket.read_ready) { in nxt_conn_io_read()
107 if (c->socket.read_ready) { in nxt_conn_io_read()
161 c->socket.read_ready = 0; in nxt_conn_io_recvbuf()
169 c->socket.read_ready = 0; in nxt_conn_io_recvbuf()
179 c->socket.read_ready = 0; in nxt_conn_io_recvbuf()
213 c->socket.read_ready = 0; in nxt_conn_io_recv()
223 c->socket.read_ready = 0; in nxt_conn_io_recv()
[all …]
H A Dnxt_fd_event.h67 uint8_t read_ready; member
84 uint8_t read_ready:1; member
H A Dnxt_conn_accept.c148 lev->socket.read_ready = (lev->ready != 0); in nxt_conn_io_accept()
222 if (next != NULL && lev->socket.read_ready) { in nxt_conn_accept()
292 c->socket.fd, c->socket.read_ready); in nxt_conn_accept_close_idle_handler()
294 if (!c->socket.read_ready) { in nxt_conn_accept_close_idle_handler()
319 lev->socket.read_ready = 0; in nxt_conn_accept_error()
H A Dnxt_socketpair.c161 ev->read_ready = 0; in nxt_socketpair_recv()
172 ev->read_ready = 0; in nxt_socketpair_recv()
H A Dnxt_epoll_engine.c943 ev->read_ready = 1; in nxt_epoll_poll()
986 ev->read_ready = 1; in nxt_epoll_poll()
1020 lev->socket.read_ready = (lev->ready != 0); in nxt_epoll_conn_io_accept4()
1100 c->socket.read_ready = 1; in nxt_epoll_edge_conn_io_connect()
1168 c->socket.read_ready = 1; in nxt_epoll_edge_conn_io_recvbuf()
H A Dnxt_kqueue_engine.c745 ev->read_ready = 1; in nxt_kqueue_poll()
941 lev->socket.read_ready = (lev->ready != 0); in nxt_kqueue_conn_io_accept()
944 lev->socket.read_ready = (lev->socket.kq_available != 0); in nxt_kqueue_conn_io_accept()
1022 c->socket.read_ready = (c->socket.kq_available != 0 in nxt_kqueue_conn_io_recvbuf()
H A Dnxt_port_socket.c723 port->socket.read_ready = 0; in nxt_port_read_close()
788 if (port->socket.read_ready) { in nxt_port_read_handler()
837 if (n < 0 && !port->socket.read_ready) { in nxt_port_queue_read_handler()
884 if (n < 0 && !port->socket.read_ready) { in nxt_port_queue_read_handler()
H A Dnxt_select_engine.c340 ev->read_ready = 1; in nxt_select_poll()
H A Dnxt_eventport_engine.c553 ev->read_ready = 1; in nxt_eventport_poll()
H A Dnxt_cyassl.c492 c->socket.read_ready = 0; in nxt_cyassl_conn_test_error()
H A Dnxt_poll_engine.c606 ev->read_ready = 1; in nxt_poll()
H A Dnxt_pollset_engine.c616 ev->read_ready = 1; in nxt_pollset_poll()
H A Dnxt_devpoll_engine.c632 ev->read_ready = 1; in nxt_devpoll_poll()
H A Dnxt_gnutls.c651 c->socket.read_ready = 0; in nxt_gnutls_conn_test_error()
H A Dnxt_openssl.c1559 c->socket.read_ready = 0;
H A Dnxt_runtime.c486 if (!c->socket.read_ready) { in nxt_runtime_close_idle_connections()
H A Dnxt_controller.c708 c->socket.read_ready = 1; in nxt_controller_conn_init()