Home
last modified time | relevance | path

Searched refs:events (Results 1 – 25 of 49) sorted by last modified time

12

/libuv/src/unix/
H A Dfs.c917 pfd.events = POLLOUT; in uv__fs_sendfile_emul()
H A Dstream.c52 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 Dlinux.c579 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 Dfsevents.c90 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 Dcore.c900 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 Dinternal.h67 # 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 Dsignal.c48 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 Dkqueue.c134 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 Dprocesses.rst157 pending events, while UV_RUN_NOWAIT will return immediately. We use NOWAIT
/libuv/test/
H A Dtest-fs-event.c65 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 Dtest-poll.c66 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 Dtest-metrics.c161 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 Dtest-poll-close-doesnt-corrupt-stack.c45 static void poll_cb(uv_poll_t* h, int status, int events) { in poll_cb() argument
H A Dtest-poll-closesocket.c39 static void poll_cb(uv_poll_t* h, int status, int events) { in poll_cb() argument
H A Dtest-poll-multiple-handles.c41 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 Dtest-poll-oob.c68 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 Dtest-queue-foreach-delete.c130 int events,
H A Dtest-embed.c66 p.events = POLLIN; in TEST_IMPL()
H A Dtest-fork.c51 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 Dbenchmark-queue-work.c26 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 Dwin.h38 short events; member
550 unsigned char events;
H A Dunix.h90 unsigned int events);
98 unsigned int events; /* Current event mask. */ member
/libuv/
H A DChangeLog510 * 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 Duv.h332 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 Dfs_event.rst22 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

Completed in 124 milliseconds

12