Home
last modified time | relevance | path

Searched refs:kq_available (Results 1 – 2 of 2) sorted by relevance

/unit/src/
H A Dnxt_kqueue_engine.c746 ev->kq_available = (int32_t) kev->data; in nxt_kqueue_poll()
761 if (nxt_slow_path(ev->kq_available == 0 && eof && err != 0)) { in nxt_kqueue_poll()
920 lev->socket.fd, lev->socket.kq_available); in nxt_kqueue_listen_handler()
943 lev->socket.kq_available--; in nxt_kqueue_conn_io_accept()
944 lev->socket.read_ready = (lev->socket.kq_available != 0); in nxt_kqueue_conn_io_accept()
981 if (c->socket.kq_available == 0 && c->socket.kq_eof) { in nxt_kqueue_conn_io_read()
1005 if (c->socket.kq_available == 0 && c->socket.kq_eof) { in nxt_kqueue_conn_io_recvbuf()
1013 c->socket.kq_available -= n; in nxt_kqueue_conn_io_recvbuf()
1015 if (c->socket.kq_available < 0) { in nxt_kqueue_conn_io_recvbuf()
1016 c->socket.kq_available = 0; in nxt_kqueue_conn_io_recvbuf()
[all …]
H A Dnxt_fd_event.h103 int32_t kq_available; member