Lines Matching refs:write
121 .write = nxt_conn_io_write,
265 if (ev->write != NXT_EVENT_INACTIVE) { in nxt_kqueue_disable()
266 ev->write = NXT_EVENT_INACTIVE; in nxt_kqueue_disable()
280 if (ev->write != NXT_EVENT_INACTIVE) { in nxt_kqueue_delete()
281 ev->write = NXT_EVENT_INACTIVE; in nxt_kqueue_delete()
302 ev->write = NXT_EVENT_INACTIVE; in nxt_kqueue_close()
338 if (ev->write == NXT_EVENT_INACTIVE) { in nxt_kqueue_enable_write()
343 ev->write = NXT_EVENT_ACTIVE; in nxt_kqueue_enable_write()
359 ev->write = NXT_EVENT_INACTIVE; in nxt_kqueue_disable_write()
377 if (ev->write != NXT_EVENT_INACTIVE) { in nxt_kqueue_block_write()
378 ev->write = NXT_EVENT_BLOCKED; in nxt_kqueue_block_write()
386 ev->write = NXT_EVENT_ACTIVE; in nxt_kqueue_oneshot_read()
396 ev->write = NXT_EVENT_ACTIVE; in nxt_kqueue_oneshot_write()
541 ev->write = NXT_EVENT_INACTIVE; in nxt_kqueue_fd_error_handler()
783 if (ev->write <= NXT_EVENT_BLOCKED) { in nxt_kqueue_poll()
789 ev->write = NXT_EVENT_INACTIVE; in nxt_kqueue_poll()
901 c->socket.write = NXT_EVENT_BLOCKED; in nxt_kqueue_conn_connected()