Lines Matching refs:op

53     nxt_uint_t op, nxt_uint_t events);
170 nxt_uint_t op, events; in nxt_poll_enable_read() local
175 op = NXT_POLL_ADD; in nxt_poll_enable_read()
179 op = NXT_POLL_CHANGE; in nxt_poll_enable_read()
183 nxt_poll_change(engine, ev, op, events); in nxt_poll_enable_read()
190 nxt_uint_t op, events; in nxt_poll_enable_write() local
195 op = NXT_POLL_ADD; in nxt_poll_enable_write()
199 op = NXT_POLL_CHANGE; in nxt_poll_enable_write()
203 nxt_poll_change(engine, ev, op, events); in nxt_poll_enable_write()
210 nxt_uint_t op, events; in nxt_poll_disable_read() local
215 op = NXT_POLL_DELETE; in nxt_poll_disable_read()
219 op = NXT_POLL_CHANGE; in nxt_poll_disable_read()
223 nxt_poll_change(engine, ev, op, events); in nxt_poll_disable_read()
230 nxt_uint_t op, events; in nxt_poll_disable_write() local
235 op = NXT_POLL_DELETE; in nxt_poll_disable_write()
239 op = NXT_POLL_CHANGE; in nxt_poll_disable_write()
243 nxt_poll_change(engine, ev, op, events); in nxt_poll_disable_write()
268 nxt_uint_t op; in nxt_poll_oneshot_read() local
270 op = (ev->read == NXT_EVENT_INACTIVE && ev->write == NXT_EVENT_INACTIVE) ? in nxt_poll_oneshot_read()
276 nxt_poll_change(engine, ev, op, POLLIN); in nxt_poll_oneshot_read()
283 nxt_uint_t op; in nxt_poll_oneshot_write() local
285 op = (ev->read == NXT_EVENT_INACTIVE && ev->write == NXT_EVENT_INACTIVE) ? in nxt_poll_oneshot_write()
291 nxt_poll_change(engine, ev, op, POLLOUT); in nxt_poll_oneshot_write()
301 nxt_poll_change(nxt_event_engine_t *engine, nxt_fd_event_t *ev, nxt_uint_t op, in nxt_poll_change() argument
306 nxt_debug(ev->task, "poll change: fd:%d op:%d ev:%XD", ev->fd, op, events); in nxt_poll_change()
315 change->op = op; in nxt_poll_change()
338 switch (change->op) { in nxt_poll_commit_changes()