/third_party/node/benchmark/events/ |
H A D | ee-listen-unique.js | 3 const { EventEmitter } = require('events'); 6 events: [1, 2, 3, 5, 10, 20], 10 function main({ events, n }) { 18 for (let k = 0; k < events; ++k)
|
/third_party/libinput/test/ |
H A D | litest-device-cyborg-rat-5.c | 35 static int events[] = { variable 60 .events = events,
|
H A D | litest-device-mouse-low-dpi.c | 35 static int events[] = { variable 56 .events = events,
|
H A D | litest-device-absinfo-override.c | 35 static int events[] = { variable 69 .events = events,
|
H A D | litest-device-hp-wmi-hotkeys.c | 35 static int events[] = { variable 57 .events = events,
|
H A D | litest-device-wacom-cintiq-pro-16-pad.c | 55 static int events[] = { variable 70 .events = events,
|
H A D | litest-device-ms-nano-transceiver-mouse.c | 35 static int events[] = { variable 57 .events = events,
|
H A D | litest-device-mouse-wheel-tilt.c | 35 static int events[] = { variable 54 .events = events,
|
H A D | litest-device-wacom-bamboo-2fg-pad.c | 55 static int events[] = { variable 71 .events = events,
|
/third_party/libinput/tools/ |
H A D | libinput-analyze-recording.py | 112 if not device["events"]: 113 print(f"No events found in recording") 116 def events(): function 120 for event in device["events"]: 129 def interesting_axes(events): 134 for e in events: 143 interesting_axes(events()), key=lambda x: x.type.value * 1000 + x.value 159 axes_in_use = {} # to print axes never sending events 166 for e in events(): 204 # Print out any rel/abs axes that not generate events i [all...] |
/third_party/pulseaudio/src/pulsecore/ |
H A D | thread-mq.c | 37 static void asyncmsgq_read_cb(pa_mainloop_api *api, pa_io_event *e, int fd, pa_io_event_flags_t events, void *userdata) { in asyncmsgq_read_cb() argument 41 pa_assert(events == PA_IO_EVENT_INPUT); in asyncmsgq_read_cb() 80 static void asyncmsgq_write_inq_cb(pa_mainloop_api *api, pa_io_event *e, int fd, pa_io_event_flags_t events, void *userdata) { in asyncmsgq_write_inq_cb() argument 84 pa_assert(events == PA_IO_EVENT_INPUT); in asyncmsgq_write_inq_cb() 90 static void asyncmsgq_write_outq_cb(pa_mainloop_api *api, pa_io_event *e, int fd, pa_io_event_flags_t events, void *userdata) { in asyncmsgq_write_outq_cb() argument 94 pa_assert(events == PA_IO_EVENT_INPUT); in asyncmsgq_write_outq_cb()
|
/third_party/PyYAML/tests/lib/ |
H A D | test_yaml_ext.py | 45 def new_emit(events, stream=None, Dumper=yaml.CDumper, **kwds): 46 return old_emit(events, stream, Dumper, **kwds) 203 events = list(yaml.parse(data, Loader=yaml.PyLoader)) 204 c_data = yaml.emit(events, Dumper=yaml.CDumper) 210 assert len(events) == len(py_events), (len(events), len(py_events)) 211 assert len(events) == len(c_events), (len(events), len(c_events)) 212 for event, py_event, c_event in zip(events, py_events, c_events): 228 pprint.pprint(events) [all...] |
/third_party/libbpf/src/ |
H A D | ringbuf.c | 36 struct epoll_event *events; member 107 tmp = libbpf_reallocarray(rb->events, rb->ring_cnt + 1, sizeof(*rb->events)); in ring_buffer__add() 110 rb->events = tmp; in ring_buffer__add() 152 e = &rb->events[rb->ring_cnt]; in ring_buffer__add() 155 e->events = EPOLLIN; in ring_buffer__add() 184 free(rb->events); in ring_buffer__free() 309 cnt = epoll_wait(rb->epoll_fd, rb->events, rb->ring_cnt, timeout_ms); in ring_buffer__poll() 314 __u32 ring_id = rb->events[i].data.fd; in ring_buffer__poll() 469 rb_epoll->events in user_ringbuf_map() [all...] |
/third_party/python/Lib/test/ |
H A D | test_htmlparser.py | 11 self.events = [] 12 self.append = self.events.append 16 # Normalize the list of events so that buffer artefacts don't 20 for event in self.events: 27 self.events = L 93 events = parser.get_events() 94 if events != expected_events: 95 self.fail("received events did not match expected events" + 98 "\nReceived:\n" + pprint.pformat(events)) [all...] |
/third_party/libuv/docs/code/onchange/ |
H A D | main.c | 9 void run_command(uv_fs_event_t *handle, const char *filename, int events, int status) { in run_command() argument 17 if (events & UV_RENAME) in run_command() 19 if (events & UV_CHANGE) in run_command()
|
/third_party/musl/libc-test/src/functionalext/supplement/linux/linux_gtest/ |
H A D | linux_epoll_wait_test.cpp | 19 * @tc.desc: This test verifies epoll can the wait function correctly wait for events in the epoll instance and return 30 ev.events = EPOLLIN; in HWTEST_F() 34 epoll_event events[MAX_EVENTS]; in HWTEST_F() local 35 int numEvents = epoll_wait(epollFd, events, MAX_EVENTS, -1); in HWTEST_F()
|
/third_party/libuv/src/unix/ |
H A D | fsevents.c | 90 int events; member 153 struct uv__queue events; \ 158 /* Split-off all events and empty original queue */ \ 159 uv__queue_move(&(handle)->cf_events, &events); \ 164 /* Loop through events, deallocating each after processing */ \ 165 while (!uv__queue_empty(&events)) { \ 166 q = uv__queue_head(&events); \ 182 /* Runs in UV loop's thread, when there're events to report to handle */ 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() 195 uv__fsevents_push_event(uv_fs_event_t* handle, struct uv__queue* events, int err) uv__fsevents_push_event() argument [all...] |
H A D | posix-poll.c | 27 * events to pass as the first argument to poll(). 71 loop->poll_fds[i].events = 0; in uv__pollfds_maybe_resize() 85 /* Add a watcher's fd to our poll fds array with its pending events. */ 90 /* If the fd is already in the set just update its events. */ in uv__pollfds_add() 94 loop->poll_fds[i].events = w->pevents; in uv__pollfds_add() 103 pe->events = w->pevents; in uv__pollfds_add() 116 loop->poll_fds[loop->poll_fds_used].events = 0; in uv__pollfds_del() 171 w->events = w->pevents; in uv__io_poll() 206 * of events in the callback were waiting when poll was called. in uv__io_poll() 262 /* Initialize a count of events tha in uv__io_poll() [all...] |
/third_party/node/deps/openssl/openssl/engines/ |
H A D | e_afalg.c | 135 struct io_event *events, in io_getevents() 141 int ret = syscall(__NR_io_pgetevents_time64, ctx, min, max, events, in io_getevents() 154 return syscall(__NR_io_getevents, ctx, min, max, events, timeout); in io_getevents() 168 return syscall(__NR_io_getevents, ctx, min, max, events, ts32); in io_getevents() 170 return syscall(__NR_io_getevents, ctx, min, max, events, NULL); in io_getevents() 272 struct io_event events[MAX_INFLIGHTS]; in afalg_fin_cipher_aio() local 333 memset(events, 0, sizeof(events)); in afalg_fin_cipher_aio() 338 events, &timeout); in afalg_fin_cipher_aio() 341 * events in afalg_fin_cipher_aio() 134 io_getevents(aio_context_t ctx, long min, long max, struct io_event *events, struct timespec *timeout) io_getevents() argument [all...] |
/third_party/node/deps/uv/src/unix/ |
H A D | fsevents.c | 90 int events; member 155 QUEUE events; \ 160 /* Split-off all events and empty original queue */ \ 161 QUEUE_MOVE(&(handle)->cf_events, &events); \ 166 /* Loop through events, deallocating each after processing */ \ 167 while (!QUEUE_EMPTY(&events)) { \ 168 q = QUEUE_HEAD(&events); \ 184 /* Runs in UV loop's thread, when there're events to report to handle */ 191 handle->cb(handle, event->path[0] ? event->path : NULL, event->events, 0); in uv__fsevents_cb() 198 QUEUE* events, in uv__fsevents_push_event() 197 uv__fsevents_push_event(uv_fs_event_t* handle, QUEUE* events, int err) uv__fsevents_push_event() argument [all...] |
H A D | posix-poll.c | 27 * events to pass as the first argument to poll(). 71 loop->poll_fds[i].events = 0; in uv__pollfds_maybe_resize() 85 /* Add a watcher's fd to our poll fds array with its pending events. */ 90 /* If the fd is already in the set just update its events. */ in uv__pollfds_add() 94 loop->poll_fds[i].events = w->pevents; in uv__pollfds_add() 103 pe->events = w->pevents; in uv__pollfds_add() 116 loop->poll_fds[loop->poll_fds_used].events = 0; in uv__pollfds_del() 168 w->events = w->pevents; in uv__io_poll() 253 /* Initialize a count of events that we care about. */ in uv__io_poll() 257 /* Loop over the entire poll fds array looking for returned events in uv__io_poll() [all...] |
/third_party/openssl/engines/ |
H A D | e_afalg.c | 135 struct io_event *events, in io_getevents() 141 int ret = syscall(__NR_io_pgetevents_time64, ctx, min, max, events, in io_getevents() 154 return syscall(__NR_io_getevents, ctx, min, max, events, timeout); in io_getevents() 168 return syscall(__NR_io_getevents, ctx, min, max, events, ts32); in io_getevents() 170 return syscall(__NR_io_getevents, ctx, min, max, events, NULL); in io_getevents() 272 struct io_event events[MAX_INFLIGHTS]; in afalg_fin_cipher_aio() local 333 memset(events, 0, sizeof(events)); in afalg_fin_cipher_aio() 338 events, &timeout); in afalg_fin_cipher_aio() 341 * events in afalg_fin_cipher_aio() 134 io_getevents(aio_context_t ctx, long min, long max, struct io_event *events, struct timespec *timeout) io_getevents() argument [all...] |
/third_party/skia/third_party/externals/swiftshader/src/Vulkan/ |
H A D | VkQueue.cpp | 194 task.events = fence->getCountedEvent(); in submit() 195 task.events->add(); in submit() 233 executionState.events = task.events.get(); in submitQueue() 263 if(task.events) in submitQueue() 268 task.events->done(); in submitQueue() 304 task.events = event; in waitIdle()
|
/third_party/node/test/fixtures/wpt/streams/writable-streams/ |
H A D | start.any.js | 27 assert_array_equals(ws.events, [], 'write should not be called until start promise resolves'); 31 .then(() => assert_array_equals(ws.events, ['write', 'a'], 52 assert_array_equals(ws.events, [], 'close should not be called until start promise resolves'); 91 .then(() => assert_array_equals(ws.events, [], 'write and close should not be called')); 113 assert_array_equals(ws.events, [], 'sink write() should not have been called'); 137 assert_array_equals(ws.events, [], 'sink write() and close() should not have been called'); 142 const events = []; 147 events.push(name); 161 assert_array_equals(events, ['ready', 'write', 'closed'], 'promises should reject in standard order');
|
/third_party/ltp/testcases/kernel/input/ |
H A D | input06.c | 40 struct input_event events[64]; variable 120 int rd = read(fd2, events, sizeof(events)); in read_events() 125 tst_brkm(TBROK, cleanup, "Failed to read events"); in read_events() 146 return &events[ev_iter++]; in next_event() 184 "Didn't get autorepeat events for the key - KEY_X"); in parse_key()
|