/libuv/src/unix/ |
H A D | fs.c | 917 pfd.events = POLLOUT; in uv__fs_sendfile_emul()
|
H A D | stream.c | 52 int events; member 150 int events; in uv__stream_osx_select() local 214 events = 0; in uv__stream_osx_select() 216 events |= POLLIN; in uv__stream_osx_select() 221 if (events != 0) { in uv__stream_osx_select() 222 ACCESS_ONCE(int, s->events) = events; in uv__stream_osx_select() 237 int events; in uv__stream_osx_select_cb() local 243 events = s->events; in uv__stream_osx_select_cb() 246 assert(events != 0); in uv__stream_osx_select_cb() 247 assert(events == (events & (POLLIN | POLLOUT))); in uv__stream_osx_select_cb() [all …]
|
H A D | linux.c | 579 e.events = POLLIN; in uv__iou_init() 734 e.events = POLLIN; in uv__io_check_fd() 1281 memcpy(oldevents, *events, sizeof(*events)); in uv__epoll_ctl_flush() 1383 if (w->events == 0) in uv__io_poll() 1407 inv.events = events; in uv__io_poll() 1469 pe = events + i; in uv__io_poll() 1523 if (pe->events == POLLERR || pe->events == POLLHUP) in uv__io_poll() 1524 pe->events |= in uv__io_poll() 2546 events = 0; in uv__inotify_read() 2605 int events; in uv_fs_event_start() local [all …]
|
H A D | fsevents.c | 90 int events; member 153 struct uv__queue events; \ 159 uv__queue_move(&(handle)->cf_events, &events); \ 165 while (!uv__queue_empty(&events)) { \ 189 handle->cb(handle, event->path[0] ? event->path : NULL, event->events, 0); in uv__fsevents_cb() 196 struct uv__queue* events, in uv__fsevents_push_event() argument 198 assert(events != NULL || err != 0); in uv__fsevents_push_event() 202 if (events != NULL) in uv__fsevents_push_event() 203 uv__queue_add(&handle->cf_events, events); in uv__fsevents_push_event() 313 event->events = UV_RENAME; in uv__fsevents_event_cb() [all …]
|
H A D | core.c | 900 w->events = 0; in uv__io_init() 907 assert(0 != events); in uv__io_start() 911 w->pevents |= events; in uv__io_start() 919 if (w->events == w->pevents) in uv__io_start() 933 void uv__io_stop(uv_loop_t* loop, uv__io_t* w, unsigned int events) { in uv__io_stop() argument 935 assert(0 != events); in uv__io_stop() 946 w->pevents &= ~events; in uv__io_stop() 951 w->events = 0; in uv__io_stop() 980 int uv__io_active(const uv__io_t* w, unsigned int events) { in uv__io_active() argument 982 assert(0 != events); in uv__io_active() [all …]
|
H A D | internal.h | 67 # define reqevents events 251 void uv__io_start(uv_loop_t* loop, uv__io_t* w, unsigned int events); 252 void uv__io_stop(uv_loop_t* loop, uv__io_t* w, unsigned int events); 255 int uv__io_active(const uv__io_t* w, unsigned int events); 279 void uv__server_io(uv_loop_t* loop, uv__io_t* w, unsigned int events);
|
H A D | signal.c | 48 static void uv__signal_event(uv_loop_t* loop, uv__io_t* w, unsigned int events); 435 unsigned int events) { in uv__signal_event() argument
|
H A D | kqueue.c | 134 struct kevent events[1024]; in uv__io_poll() local 216 w->events = w->pevents; in uv__io_poll() 260 events, in uv__io_poll() 262 events, in uv__io_poll() 309 ev = events + i; in uv__io_poll() 442 struct kevent* events; in uv__platform_invalidate_fd() local 451 if (events == NULL) in uv__platform_invalidate_fd() 456 if ((int) events[i].ident == fd && events[i].filter != EVFILT_PROC) in uv__platform_invalidate_fd() 464 int events; in uv__fs_event() local 474 events = UV_CHANGE; in uv__fs_event() [all …]
|
/libuv/docs/src/guide/ |
H A D | processes.rst | 157 pending events, while UV_RUN_NOWAIT will return immediately. We use NOWAIT
|
/libuv/test/ |
H A D | test-fs-event.c | 65 int events, in fs_event_fail() argument 122 int events, in fail_cb() argument 128 int events, int status) { in fs_event_cb_dir() argument 132 ASSERT_EQ(events, UV_CHANGE); in fs_event_cb_dir() 199 ASSERT(events == UV_CHANGE || events == UV_RENAME); in fs_event_cb_dir_multi_file() 293 ASSERT(events == UV_CHANGE || events == UV_RENAME); in fs_event_cb_dir_multi_file_in_subdir() 322 int events, int status) { in fs_event_cb_file() argument 326 ASSERT_EQ(events, UV_CHANGE); in fs_event_cb_file() 342 ASSERT_EQ(events, UV_CHANGE); in fs_event_cb_file_current_dir() 1126 event = &events[i]; in TEST_IMPL() [all …]
|
H A D | test-poll.c | 66 unsigned int events, delayed_events; member 158 context->events = 0; in create_connection_context() 213 ASSERT(events & context->events); 214 ASSERT(!(events & ~context->events)); 216 new_events = context->events; 218 if (events & UV_READABLE) { 297 if (events & UV_WRITABLE) { 413 if (events & UV_DISCONNECT) { 426 context->events = 0; 430 context->events = new_events; [all …]
|
H A D | test-metrics.c | 161 ASSERT_UINT64_GT(metrics.events, last_events_count); in close_cb() 164 last_events_count = metrics.events; in close_cb() 173 ASSERT_UINT64_GT(metrics.events, last_events_count); in write_cb() 177 last_events_count = metrics.events; in write_cb() 195 last_events_count = metrics.events; in create_cb() 215 ASSERT_UINT64_EQ(0, metrics.events); in prepare_cb() 251 ASSERT_EQ(metrics.events, metrics.events_waiting); in fs_prepare_cb() 377 ASSERT_GE(metrics.events, 7); in TEST_IMPL()
|
H A D | test-poll-close-doesnt-corrupt-stack.c | 45 static void poll_cb(uv_poll_t* h, int status, int events) { in poll_cb() argument
|
H A D | test-poll-closesocket.c | 39 static void poll_cb(uv_poll_t* h, int status, int events) { in poll_cb() argument
|
H A D | test-poll-multiple-handles.c | 41 static void poll_cb(uv_poll_t* handle, int status, int events) { in poll_cb() argument 43 ASSERT_EQ(events, UV_READABLE); in poll_cb()
|
H A D | test-poll-oob.c | 68 static void poll_cb(uv_poll_t* handle, int status, int events) { in poll_cb() argument 76 if (events & UV_PRIORITIZED) { in poll_cb() 87 if (events & UV_READABLE) { in poll_cb() 127 if (events & UV_WRITABLE) { in poll_cb()
|
H A D | test-queue-foreach-delete.c | 130 int events,
|
H A D | test-embed.c | 66 p.events = POLLIN; in TEST_IMPL()
|
H A D | test-fork.c | 51 static void socket_cb(uv_poll_t* poll, int status, int events) { in socket_cb() argument 55 printf("Socket cb got events %d\n", events); in socket_cb() 56 ASSERT_EQ(UV_READABLE, (events & UV_READABLE)); in socket_cb() 470 int events, in fs_event_cb_file_current_dir() argument
|
H A D | benchmark-queue-work.c | 26 static unsigned events = 0; variable 41 events++; in after_work_cb() 65 fmt(&fmtbuf[0], events), in BENCHMARK_IMPL() 67 fmt(&fmtbuf[1], events / (timeout / 1000.))); in BENCHMARK_IMPL()
|
/libuv/include/uv/ |
H A D | win.h | 38 short events; member 550 unsigned char events;
|
H A D | unix.h | 90 unsigned int events); 98 unsigned int events; /* Current event mask. */ member
|
/libuv/ |
H A D | ChangeLog | 510 * src: fix events/events_waiting metrics counter (Trevor Norris) 633 * loop: better align order-of-events behavior between platforms (Jameson Nash) 1364 * zos: explicitly mark message queue events (Irek Fakhrutdinov) 2351 * zos: clear poll events on every iteration (jBarz) 3354 * win: compare entire filename in watch events (cjihrig) 3702 * win: fix buffer overflow in fs events (Joran Dirk Greef) 3813 * win: fix path for removed and renamed fs events (Joran Dirk Greef) 5208 * unix: update events from pevents between polls (Fedor Indutny) 5249 * unix: update events from pevents between polls (Fedor Indutny)
|
/libuv/include/ |
H A D | uv.h | 332 typedef void (*uv_poll_cb)(uv_poll_t* handle, int status, int events); 404 int events, 874 UV_EXTERN int uv_poll_start(uv_poll_t* handle, int events, uv_poll_cb cb); 1343 uint64_t events; member
|
/libuv/docs/src/ |
H A D | fs_event.rst | 22 The z/OS file system events monitoring infrastructure does not notify of file 39 .. c:type:: void (*uv_fs_event_cb)(uv_fs_event_t* handle, const char* filename, int events, int sta… 48 The `events` parameter is an ORed mask of :c:type:`uv_fs_event` elements. 71 * watch for all events in that directory. This flags overrides this behavior 79 * or kqueue to detect events. This may not work on remote file systems such
|