Home
last modified time | relevance | path

Searched refs:NXT_EVENT_BLOCKED (Results 1 – 6 of 6) sorted by relevance

/unit/src/
H A Dnxt_pollset_engine.c216 if (ev->read != NXT_EVENT_BLOCKED) { in nxt_pollset_enable_read()
244 if (ev->write != NXT_EVENT_BLOCKED) { in nxt_pollset_enable_write()
251 } else if (ev->read == NXT_EVENT_BLOCKED) { in nxt_pollset_enable_write()
274 if (ev->write <= NXT_EVENT_BLOCKED) { in nxt_pollset_disable_read()
295 if (ev->read <= NXT_EVENT_BLOCKED) { in nxt_pollset_disable_write()
313 ev->read = NXT_EVENT_BLOCKED; in nxt_pollset_block_read()
322 ev->write = NXT_EVENT_BLOCKED; in nxt_pollset_block_write()
618 if (ev->read != NXT_EVENT_BLOCKED) { in nxt_pollset_poll()
623 if (ev->read == NXT_EVENT_BLOCKED in nxt_pollset_poll()
633 if (ev->write != NXT_EVENT_BLOCKED) { in nxt_pollset_poll()
[all …]
H A Dnxt_devpoll_engine.c242 if (ev->read != NXT_EVENT_BLOCKED) { in nxt_devpoll_enable_read()
270 if (ev->write != NXT_EVENT_BLOCKED) { in nxt_devpoll_enable_write()
277 } else if (ev->read == NXT_EVENT_BLOCKED) { in nxt_devpoll_enable_write()
300 if (ev->write <= NXT_EVENT_BLOCKED) { in nxt_devpoll_disable_read()
321 if (ev->read <= NXT_EVENT_BLOCKED) { in nxt_devpoll_disable_write()
339 ev->read = NXT_EVENT_BLOCKED; in nxt_devpoll_block_read()
348 ev->write = NXT_EVENT_BLOCKED; in nxt_devpoll_block_write()
634 if (ev->read != NXT_EVENT_BLOCKED) { in nxt_devpoll_poll()
639 if (ev->read == NXT_EVENT_BLOCKED in nxt_devpoll_poll()
649 if (ev->write != NXT_EVENT_BLOCKED) { in nxt_devpoll_poll()
[all …]
H A Dnxt_epoll_engine.c415 if (ev->read != NXT_EVENT_BLOCKED) { in nxt_epoll_enable_read()
440 if (ev->write != NXT_EVENT_BLOCKED) { in nxt_epoll_enable_write()
507 ev->read = NXT_EVENT_BLOCKED; in nxt_epoll_block_read()
516 ev->write = NXT_EVENT_BLOCKED; in nxt_epoll_block_write()
930 && ev->read <= NXT_EVENT_BLOCKED in nxt_epoll_poll()
931 && ev->write <= NXT_EVENT_BLOCKED) in nxt_epoll_poll()
945 if (ev->read != NXT_EVENT_BLOCKED) { in nxt_epoll_poll()
989 if (ev->read == NXT_EVENT_BLOCKED && ev->write == NXT_EVENT_BLOCKED) { in nxt_epoll_poll()
1084 c->socket.read = NXT_EVENT_BLOCKED; in nxt_epoll_edge_conn_io_connect()
1110 c->socket.read = NXT_EVENT_BLOCKED; in nxt_epoll_edge_conn_io_connect()
[all …]
H A Dnxt_eventport_engine.c196 if (ev->read != NXT_EVENT_BLOCKED) { in nxt_eventport_enable_read()
211 if (ev->write != NXT_EVENT_BLOCKED) { in nxt_eventport_enable_write()
380 ev->read = NXT_EVENT_BLOCKED; in nxt_eventport_block_read()
389 ev->write = NXT_EVENT_BLOCKED; in nxt_eventport_block_write()
555 if (ev->read != NXT_EVENT_BLOCKED) { in nxt_eventport_poll()
569 if (ev->write != NXT_EVENT_BLOCKED) { in nxt_eventport_poll()
H A Dnxt_fd_event.h25 NXT_EVENT_BLOCKED, enumerator
H A Dnxt_kqueue_engine.c369 ev->read = NXT_EVENT_BLOCKED; in nxt_kqueue_block_read()
378 ev->write = NXT_EVENT_BLOCKED; in nxt_kqueue_block_write()
752 if (ev->read <= NXT_EVENT_BLOCKED) { in nxt_kqueue_poll()
783 if (ev->write <= NXT_EVENT_BLOCKED) { in nxt_kqueue_poll()
901 c->socket.write = NXT_EVENT_BLOCKED; in nxt_kqueue_conn_connected()