Lines Matching refs:events

86     handle->submitted_events_1 = handle->events;  in uv__fast_poll_submit_poll_req()
88 handle->mask_events_2 = handle->events; in uv__fast_poll_submit_poll_req()
92 handle->submitted_events_2 = handle->events; in uv__fast_poll_submit_poll_req()
93 handle->mask_events_1 = handle->events; in uv__fast_poll_submit_poll_req()
113 if (handle->events & UV_READABLE) { in uv__fast_poll_submit_poll_req()
117 if (handle->events & UV_DISCONNECT) { in uv__fast_poll_submit_poll_req()
121 if (handle->events & UV_WRITABLE) { in uv__fast_poll_submit_poll_req()
160 if (error != WSAEINTR && handle->events != 0) { in uv__fast_poll_process_poll_req()
161 handle->events = 0; /* Stop the watcher */ in uv__fast_poll_process_poll_req()
166 unsigned char events = 0; in uv__fast_poll_process_poll_req() local
170 events |= UV_READABLE; in uv__fast_poll_process_poll_req()
172 events |= UV_DISCONNECT; in uv__fast_poll_process_poll_req()
177 events |= UV_WRITABLE; in uv__fast_poll_process_poll_req()
180 events &= handle->events & ~mask_events; in uv__fast_poll_process_poll_req()
184 handle->events = 0; in uv__fast_poll_process_poll_req()
189 if (events != 0) { in uv__fast_poll_process_poll_req()
190 handle->poll_cb(handle, 0, events); in uv__fast_poll_process_poll_req()
194 if ((handle->events & ~(handle->submitted_events_1 | in uv__fast_poll_process_poll_req()
280 if (handle->events & UV_READABLE) { in uv__slow_poll_thread_proc()
287 if (handle->events & UV_WRITABLE) { in uv__slow_poll_thread_proc()
344 handle->submitted_events_1 = handle->events; in uv__slow_poll_submit_poll_req()
346 handle->mask_events_2 = handle->events; in uv__slow_poll_submit_poll_req()
349 handle->submitted_events_2 = handle->events; in uv__slow_poll_submit_poll_req()
350 handle->mask_events_1 = handle->events; in uv__slow_poll_submit_poll_req()
386 if (handle->events != 0) { in uv__slow_poll_process_poll_req()
388 handle->events = 0; /* Stop the watcher */ in uv__slow_poll_process_poll_req()
393 int events = req->u.io.overlapped.InternalHigh & handle->events & ~mask_events; in uv__slow_poll_process_poll_req() local
394 if (events != 0) { in uv__slow_poll_process_poll_req()
395 handle->poll_cb(handle, 0, events); in uv__slow_poll_process_poll_req()
399 if ((handle->events & ~(handle->submitted_events_1 | in uv__slow_poll_process_poll_req()
449 handle->events = 0; in uv_poll_init_socket()
487 static int uv__poll_set(uv_poll_t* handle, int events, uv_poll_cb cb) { in uv__poll_set() argument
492 assert((events & ~(UV_READABLE | UV_WRITABLE | UV_DISCONNECT | in uv__poll_set()
495 handle->events = events; in uv__poll_set()
498 if (handle->events == 0) { in uv__poll_set()
506 if (handle->events & ~submitted_events) { in uv__poll_set()
518 int uv_poll_start(uv_poll_t* handle, int events, uv_poll_cb cb) { in uv_poll_start() argument
519 return uv__poll_set(handle, events, cb); in uv_poll_start()
542 handle->events = 0; in uv__poll_close()