Lines Matching refs:write

107     .write = nxt_conn_io_write,
358 ev->write = NXT_EVENT_ACTIVE; in nxt_epoll_enable()
368 if (ev->read > NXT_EVENT_DISABLED || ev->write > NXT_EVENT_DISABLED) { in nxt_epoll_disable()
371 ev->write = NXT_EVENT_INACTIVE; in nxt_epoll_disable()
381 if (ev->read != NXT_EVENT_INACTIVE || ev->write != NXT_EVENT_INACTIVE) { in nxt_epoll_delete()
384 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()
423 } else if (ev->write >= NXT_EVENT_BLOCKED) { in nxt_epoll_enable_read()
440 if (ev->write != NXT_EVENT_BLOCKED) { in nxt_epoll_enable_write()
445 if (ev->read == NXT_EVENT_INACTIVE && ev->write == NXT_EVENT_INACTIVE) { in nxt_epoll_enable_write()
455 ev->write = NXT_EVENT_ACTIVE; in nxt_epoll_enable_write()
467 if (ev->write <= NXT_EVENT_DISABLED) { in nxt_epoll_disable_read()
468 ev->write = NXT_EVENT_INACTIVE; in nxt_epoll_disable_read()
487 ev->write = NXT_EVENT_INACTIVE; in nxt_epoll_disable_write()
515 if (ev->write != NXT_EVENT_INACTIVE) { in nxt_epoll_block_write()
516 ev->write = NXT_EVENT_BLOCKED; in nxt_epoll_block_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()
558 ev->write = NXT_EVENT_ONESHOT; in nxt_epoll_oneshot_write()
657 ev->write = NXT_EVENT_INACTIVE; in nxt_epoll_error_handler()
859 ret = write(engine->u.epoll.eventfd.fd, &event, sizeof(uint64_t)); in nxt_epoll_signal()
920 ev->fd, events, ev, ev->read, ev->write); in nxt_epoll_poll()
931 && ev->write <= NXT_EVENT_BLOCKED) in nxt_epoll_poll()
965 if (ev->write != NXT_EVENT_BLOCKED) { in nxt_epoll_poll()
967 if (ev->write == NXT_EVENT_ONESHOT) { in nxt_epoll_poll()
968 ev->write = NXT_EVENT_DISABLED; in nxt_epoll_poll()
989 if (ev->read == NXT_EVENT_BLOCKED && ev->write == NXT_EVENT_BLOCKED) { in nxt_epoll_poll()
1139 c->socket.write = NXT_EVENT_BLOCKED; in nxt_epoll_edge_conn_connected()