Home
last modified time | relevance | path

Searched refs:NXT_EVENT_INACTIVE (Results 1 – 9 of 9) sorted by relevance

/unit/src/
H A Dnxt_eventport_engine.c165 if (ev->read != NXT_EVENT_INACTIVE || ev->write != NXT_EVENT_INACTIVE) { in nxt_eventport_disable()
167 ev->read = NXT_EVENT_INACTIVE; in nxt_eventport_disable()
168 ev->write = NXT_EVENT_INACTIVE; in nxt_eventport_disable()
184 ev->read = NXT_EVENT_INACTIVE; in nxt_eventport_close()
185 ev->write = NXT_EVENT_INACTIVE; in nxt_eventport_close()
251 ev->read = NXT_EVENT_INACTIVE; in nxt_eventport_disable_read()
265 ev->write = NXT_EVENT_INACTIVE; in nxt_eventport_disable_write()
267 if (ev->read == NXT_EVENT_INACTIVE) { in nxt_eventport_disable_write()
369 ev->read = NXT_EVENT_INACTIVE; in nxt_eventport_error_handler()
370 ev->write = NXT_EVENT_INACTIVE; in nxt_eventport_error_handler()
[all …]
H A Dnxt_poll_engine.c149 if (ev->read != NXT_EVENT_INACTIVE && ev->write != NXT_EVENT_INACTIVE) { in nxt_poll_disable()
150 ev->read = NXT_EVENT_INACTIVE; in nxt_poll_disable()
151 ev->write = NXT_EVENT_INACTIVE; in nxt_poll_disable()
194 if (ev->read == NXT_EVENT_INACTIVE) { in nxt_poll_enable_write()
212 ev->read = NXT_EVENT_INACTIVE; in nxt_poll_disable_read()
232 ev->write = NXT_EVENT_INACTIVE; in nxt_poll_disable_write()
234 if (ev->read == NXT_EVENT_INACTIVE) { in nxt_poll_disable_write()
270 op = (ev->read == NXT_EVENT_INACTIVE && ev->write == NXT_EVENT_INACTIVE) ? in nxt_poll_oneshot_read()
274 ev->write = NXT_EVENT_INACTIVE; in nxt_poll_oneshot_read()
285 op = (ev->read == NXT_EVENT_INACTIVE && ev->write == NXT_EVENT_INACTIVE) ? in nxt_poll_oneshot_write()
[all …]
H A Dnxt_select_engine.c108 if (ev->read != NXT_EVENT_INACTIVE) { in nxt_select_disable()
112 if (ev->write != NXT_EVENT_INACTIVE) { in nxt_select_disable()
188 ev->read = NXT_EVENT_INACTIVE; in nxt_select_error_handler()
189 ev->write = NXT_EVENT_INACTIVE; in nxt_select_error_handler()
210 ev->read = NXT_EVENT_INACTIVE; in nxt_select_disable_read()
212 if (ev->write == NXT_EVENT_INACTIVE) { in nxt_select_disable_read()
234 ev->write = NXT_EVENT_INACTIVE; in nxt_select_disable_write()
236 if (ev->read == NXT_EVENT_INACTIVE) { in nxt_select_disable_write()
246 if (ev->read != NXT_EVENT_INACTIVE) { in nxt_select_block_read()
255 if (ev->write != NXT_EVENT_INACTIVE) { in nxt_select_block_write()
H A Dnxt_pollset_engine.c177 if (ev->read != NXT_EVENT_INACTIVE || ev->write != NXT_EVENT_INACTIVE) { in nxt_pollset_disable()
179 ev->read = NXT_EVENT_INACTIVE; in nxt_pollset_disable()
180 ev->write = NXT_EVENT_INACTIVE; in nxt_pollset_disable()
252 ev->read = NXT_EVENT_INACTIVE; in nxt_pollset_enable_write()
272 ev->read = NXT_EVENT_INACTIVE; in nxt_pollset_disable_read()
275 ev->write = NXT_EVENT_INACTIVE; in nxt_pollset_disable_read()
293 ev->write = NXT_EVENT_INACTIVE; in nxt_pollset_disable_write()
296 ev->read = NXT_EVENT_INACTIVE; in nxt_pollset_disable_write()
312 if (ev->read != NXT_EVENT_INACTIVE) { in nxt_pollset_block_read()
468 ev->read = NXT_EVENT_INACTIVE; in nxt_pollset_change_error()
[all …]
H A Dnxt_devpoll_engine.c182 if (ev->read != NXT_EVENT_INACTIVE || ev->write != NXT_EVENT_INACTIVE) { in nxt_devpoll_disable()
184 ev->read = NXT_EVENT_INACTIVE; in nxt_devpoll_disable()
185 ev->write = NXT_EVENT_INACTIVE; in nxt_devpoll_disable()
278 ev->read = NXT_EVENT_INACTIVE; in nxt_devpoll_enable_write()
298 ev->read = NXT_EVENT_INACTIVE; in nxt_devpoll_disable_read()
301 ev->write = NXT_EVENT_INACTIVE; in nxt_devpoll_disable_read()
319 ev->write = NXT_EVENT_INACTIVE; in nxt_devpoll_disable_write()
322 ev->read = NXT_EVENT_INACTIVE; in nxt_devpoll_disable_write()
338 if (ev->read != NXT_EVENT_INACTIVE) { in nxt_devpoll_block_read()
483 ev->read = NXT_EVENT_INACTIVE; in nxt_devpoll_change_error()
[all …]
H A Dnxt_epoll_engine.c381 if (ev->read != NXT_EVENT_INACTIVE || ev->write != NXT_EVENT_INACTIVE) { in nxt_epoll_delete()
420 if (ev->read == NXT_EVENT_INACTIVE && ev->write == NXT_EVENT_INACTIVE) { in nxt_epoll_enable_read()
445 if (ev->read == NXT_EVENT_INACTIVE && ev->write == NXT_EVENT_INACTIVE) { in nxt_epoll_enable_write()
465 ev->read = NXT_EVENT_INACTIVE; in nxt_epoll_disable_read()
487 ev->write = NXT_EVENT_INACTIVE; in nxt_epoll_disable_write()
539 op = (ev->read == NXT_EVENT_INACTIVE && ev->write == NXT_EVENT_INACTIVE) ? in nxt_epoll_oneshot_read()
543 ev->write = NXT_EVENT_INACTIVE; in nxt_epoll_oneshot_read()
554 op = (ev->read == NXT_EVENT_INACTIVE && ev->write == NXT_EVENT_INACTIVE) ? in nxt_epoll_oneshot_write()
557 ev->read = NXT_EVENT_INACTIVE; in nxt_epoll_oneshot_write()
656 ev->read = NXT_EVENT_INACTIVE; in nxt_epoll_error_handler()
[all …]
H A Dnxt_kqueue_engine.c260 if (ev->read != NXT_EVENT_INACTIVE) { in nxt_kqueue_disable()
261 ev->read = NXT_EVENT_INACTIVE; in nxt_kqueue_disable()
266 ev->write = NXT_EVENT_INACTIVE; in nxt_kqueue_disable()
276 ev->read = NXT_EVENT_INACTIVE; in nxt_kqueue_delete()
281 ev->write = NXT_EVENT_INACTIVE; in nxt_kqueue_delete()
301 ev->read = NXT_EVENT_INACTIVE; in nxt_kqueue_close()
302 ev->write = NXT_EVENT_INACTIVE; in nxt_kqueue_close()
350 ev->read = NXT_EVENT_INACTIVE; in nxt_kqueue_disable_read()
359 ev->write = NXT_EVENT_INACTIVE; in nxt_kqueue_disable_write()
540 ev->read = NXT_EVENT_INACTIVE; in nxt_kqueue_fd_error_handler()
[all …]
H A Dnxt_fd_event.h13 NXT_EVENT_INACTIVE = 0, enumerator
H A Dnxt_port_socket.c724 port->socket.read = NXT_EVENT_INACTIVE; in nxt_port_read_close()