Lines Matching refs:ev

13 static void nxt_select_enable(nxt_event_engine_t *engine, nxt_fd_event_t *ev);
14 static void nxt_select_disable(nxt_event_engine_t *engine, nxt_fd_event_t *ev);
16 nxt_fd_event_t *ev);
18 nxt_fd_event_t *ev);
20 nxt_fd_event_t *ev);
23 nxt_fd_event_t *ev);
25 nxt_fd_event_t *ev);
27 nxt_fd_event_t *ev);
29 nxt_fd_event_t *ev);
31 nxt_fd_event_t *ev);
33 nxt_fd_event_t *ev);
98 nxt_select_enable(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_select_enable() argument
100 nxt_select_enable_read(engine, ev); in nxt_select_enable()
101 nxt_select_enable_write(engine, ev); in nxt_select_enable()
106 nxt_select_disable(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_select_disable() argument
108 if (ev->read != NXT_EVENT_INACTIVE) { in nxt_select_disable()
109 nxt_select_disable_read(engine, ev); in nxt_select_disable()
112 if (ev->write != NXT_EVENT_INACTIVE) { in nxt_select_disable()
113 nxt_select_disable_write(engine, ev); in nxt_select_disable()
119 nxt_select_close(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_select_close() argument
121 nxt_select_disable(engine, ev); in nxt_select_close()
128 nxt_select_enable_read(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_select_enable_read() argument
132 fd = ev->fd; in nxt_select_enable_read()
134 nxt_debug(ev->task, "select enable read: fd:%d", fd); in nxt_select_enable_read()
138 ev->task, ev, ev->data); in nxt_select_enable_read()
142 ev->read = NXT_EVENT_ACTIVE; in nxt_select_enable_read()
145 engine->u.select.events[fd] = ev; in nxt_select_enable_read()
155 nxt_select_enable_write(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_select_enable_write() argument
159 fd = ev->fd; in nxt_select_enable_write()
161 nxt_debug(ev->task, "select enable write: fd:%d", fd); in nxt_select_enable_write()
165 ev->task, ev, ev->data); in nxt_select_enable_write()
169 ev->write = NXT_EVENT_ACTIVE; in nxt_select_enable_write()
172 engine->u.select.events[fd] = ev; in nxt_select_enable_write()
184 nxt_fd_event_t *ev; in nxt_select_error_handler() local
186 ev = obj; in nxt_select_error_handler()
188 ev->read = NXT_EVENT_INACTIVE; in nxt_select_error_handler()
189 ev->write = NXT_EVENT_INACTIVE; in nxt_select_error_handler()
191 ev->error_handler(task, ev, data); in nxt_select_error_handler()
196 nxt_select_disable_read(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_select_disable_read() argument
200 fd = ev->fd; in nxt_select_disable_read()
202 nxt_debug(ev->task, "select disable read: fd:%d", fd); in nxt_select_disable_read()
210 ev->read = NXT_EVENT_INACTIVE; in nxt_select_disable_read()
212 if (ev->write == NXT_EVENT_INACTIVE) { in nxt_select_disable_read()
220 nxt_select_disable_write(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_select_disable_write() argument
224 fd = ev->fd; in nxt_select_disable_write()
226 nxt_debug(ev->task, "select disable write: fd:%d", fd); in nxt_select_disable_write()
234 ev->write = NXT_EVENT_INACTIVE; in nxt_select_disable_write()
236 if (ev->read == NXT_EVENT_INACTIVE) { in nxt_select_disable_write()
244 nxt_select_block_read(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_select_block_read() argument
246 if (ev->read != NXT_EVENT_INACTIVE) { in nxt_select_block_read()
247 nxt_select_disable_read(engine, ev); in nxt_select_block_read()
253 nxt_select_block_write(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_select_block_write() argument
255 if (ev->write != NXT_EVENT_INACTIVE) { in nxt_select_block_write()
256 nxt_select_disable_write(engine, ev); in nxt_select_block_write()
262 nxt_select_oneshot_read(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_select_oneshot_read() argument
264 nxt_select_enable_read(engine, ev); in nxt_select_oneshot_read()
266 ev->read = NXT_EVENT_ONESHOT; in nxt_select_oneshot_read()
271 nxt_select_oneshot_write(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_select_oneshot_write() argument
273 nxt_select_enable_write(engine, ev); in nxt_select_oneshot_write()
275 ev->write = NXT_EVENT_ONESHOT; in nxt_select_oneshot_write()
286 nxt_fd_event_t *ev; in nxt_select_poll() local
335 ev = engine->u.select.events[fd]; in nxt_select_poll()
337 nxt_debug(ev->task, "select() fd:%ui read rd:%d wr:%d", in nxt_select_poll()
338 fd, ev->read, ev->write); in nxt_select_poll()
340 ev->read_ready = 1; in nxt_select_poll()
342 if (ev->read == NXT_EVENT_ONESHOT) { in nxt_select_poll()
343 nxt_select_disable_read(engine, ev); in nxt_select_poll()
346 nxt_work_queue_add(ev->read_work_queue, ev->read_handler, in nxt_select_poll()
347 ev->task, ev, ev->data); in nxt_select_poll()
352 ev = engine->u.select.events[fd]; in nxt_select_poll()
354 nxt_debug(ev->task, "select() fd:%ui write rd:%d wr:%d", in nxt_select_poll()
355 fd, ev->read, ev->write); in nxt_select_poll()
357 ev->write_ready = 1; in nxt_select_poll()
359 if (ev->write == NXT_EVENT_ONESHOT) { in nxt_select_poll()
360 nxt_select_disable_write(engine, ev); in nxt_select_poll()
363 nxt_work_queue_add(ev->write_work_queue, ev->write_handler, in nxt_select_poll()
364 ev->task, ev, ev->data); in nxt_select_poll()