| /external/python/cpython2/Lib/test/ |
| D | test_kqueue.py | 26 ev = select.kevent(fd)
28 self.assertEqual(ev.ident, fd)
29 self.assertEqual(ev.filter, select.KQ_FILTER_READ)
30 self.assertEqual(ev.flags, select.KQ_EV_ADD)
31 self.assertEqual(ev.fflags, 0)
32 self.assertEqual(ev.data, 0)
33 self.assertEqual(ev.udata, 0)
34 self.assertEqual(ev, ev)
35 self.assertNotEqual(ev, other)
36 self.assertEqual(cmp(ev, other), -1)
[all …]
|
| /external/python/cpython3/Lib/test/ |
| D | test_kqueue.py | 29 ev = select.kevent(fd)
31 self.assertEqual(ev.ident, fd)
32 self.assertEqual(ev.filter, select.KQ_FILTER_READ)
33 self.assertEqual(ev.flags, select.KQ_EV_ADD)
34 self.assertEqual(ev.fflags, 0)
35 self.assertEqual(ev.data, 0)
36 self.assertEqual(ev.udata, 0)
37 self.assertEqual(ev, ev)
38 self.assertNotEqual(ev, other)
39 self.assertTrue(ev < other)
[all …]
|
| /external/perf_data_converter/src/quipper/ |
| D | huge_page_deducer_test.cc | 21 MMapEvent* ev = events->Add()->mutable_mmap_event(); in AddMmap() local
22 ev->set_pid(pid); in AddMmap()
23 ev->set_start(mmap_start); in AddMmap()
24 ev->set_len(length); in AddMmap()
25 ev->set_pgoff(pgoff); in AddMmap()
26 ev->set_filename(file); in AddMmap()
32 MMapEvent* ev = events.Add()->mutable_mmap_event(); in TEST() local
33 ev->set_pid(1234); in TEST()
34 ev->set_start(0x40000000); in TEST()
35 ev->set_len(0x18000); in TEST()
[all …]
|
| /external/libevent/ |
| D | event.c | 145 static int event_del_(struct event *ev, int blocking);
159 static inline void event_signal_closure(struct event_base *, struct event *ev);
160 static inline void event_persist_closure(struct event_base *, struct event *ev);
165 struct event *ev);
232 #define event_debug_note_setup_(ev) do { \ in HT_PROTOTYPE() argument
235 find.ptr = (ev); \ in HT_PROTOTYPE()
245 dent->ptr = (ev); \ in HT_PROTOTYPE()
254 #define event_debug_note_teardown_(ev) do { \ argument
257 find.ptr = (ev); \
267 #define event_debug_note_add_(ev) do { \ argument
[all …]
|
| D | evmap.c | 266 evmap_io_add_(struct event_base *base, evutil_socket_t fd, struct event *ev) in evmap_io_add_() argument
275 EVUTIL_ASSERT(fd == ev->ev_fd); in evmap_io_add_()
300 if (ev->ev_events & EV_READ) { in evmap_io_add_()
304 if (ev->ev_events & EV_WRITE) { in evmap_io_add_()
308 if (ev->ev_events & EV_CLOSED) { in evmap_io_add_()
319 (old_ev->ev_events&EV_ET) != (ev->ev_events&EV_ET)) { in evmap_io_add_()
330 if (evsel->add(base, ev->ev_fd, in evmap_io_add_()
331 old, (ev->ev_events & EV_ET) | res, extra) == -1) in evmap_io_add_()
339 LIST_INSERT_HEAD(&ctx->events, ev, ev_io_next); in evmap_io_add_()
347 evmap_io_del_(struct event_base *base, evutil_socket_t fd, struct event *ev) in evmap_io_del_() argument
[all …]
|
| /external/libevent/test/ |
| D | test-dumpevents.c | 71 struct event *ev[N_EVENTS]; in main() local
110 ev[0] = event_new(base, pair1[0], EV_WRITE, callback1, NULL); in main()
111 ev[1] = event_new(base, pair1[1], EV_READ|EV_PERSIST, callback1, NULL); in main()
112 ev[2] = event_new(base, pair2[0], EV_WRITE|EV_PERSIST, callback2, NULL); in main()
113 ev[3] = event_new(base, pair2[1], EV_READ, callback2, NULL); in main()
116 ev[4] = evtimer_new(base, callback1, NULL); in main()
117 ev[5] = evtimer_new(base, callback1, NULL); in main()
118 ev[6] = evtimer_new(base, callback1, NULL); in main()
119 ev[7] = event_new(base, -1, EV_PERSIST, callback2, NULL); in main()
120 ev[8] = event_new(base, -1, EV_PERSIST, callback2, NULL); in main()
[all …]
|
| D | regress_finalize.c | 57 event_finalize_callback_1(struct event *ev, void *arg) in event_finalize_callback_1() argument
61 (void)ev; in event_finalize_callback_1()
78 struct event *ev; in test_fin_cb_invoked() local
87 ev = evtimer_new(base, timer_callback, &ev_called); in test_fin_cb_invoked()
89 event_free_finalize(0, ev, event_finalize_callback_1); in test_fin_cb_invoked()
102 ev = evtimer_new(base, timer_callback, &ev_called); in test_fin_cb_invoked()
105 event_active(ev, EV_TIMEOUT, 1); in test_fin_cb_invoked()
117 event_active(ev, EV_TIMEOUT, 1); in test_fin_cb_invoked()
119 event_free_finalize(0, ev, event_finalize_callback_1); in test_fin_cb_invoked()
132 ev = evtimer_new(base, timer_callback, &ev_called); in test_fin_cb_invoked()
[all …]
|
| D | regress.c | 104 struct event *ev; member
157 event_del(arg->ev); in basic_read_cb()
181 struct event *ev = arg; in multiple_write_cb() local
192 event_del(ev); in multiple_write_cb()
201 event_del(ev); in multiple_write_cb()
206 if (event_add(ev, NULL) == -1) in multiple_write_cb()
214 struct event *ev = arg; in multiple_read_cb() local
222 event_del(ev); in multiple_read_cb()
228 if (event_add(ev, NULL) == -1) in multiple_read_cb()
240 struct event ev; member
[all …]
|
| /external/libevent/include/event2/ |
| D | event_compat.h | 186 #define evtimer_set(ev, cb, arg) event_set((ev), -1, 0, (cb), (arg)) argument
187 #define evsignal_set(ev, x, cb, arg) \ argument
188 event_set((ev), (x), EV_SIGNAL|EV_PERSIST, (cb), (arg))
198 #define timeout_add(ev, tv) event_add((ev), (tv)) argument
199 #define timeout_set(ev, cb, arg) event_set((ev), -1, 0, (cb), (arg)) argument
200 #define timeout_del(ev) event_del(ev) argument
201 #define timeout_pending(ev, tv) event_pending((ev), EV_TIMEOUT, (tv)) argument
202 #define timeout_initialized(ev) event_initialized(ev) argument
212 #define signal_add(ev, tv) event_add((ev), (tv)) argument
213 #define signal_set(ev, x, cb, arg) \ argument
[all …]
|
| D | event.h | 968 #define evtimer_assign(ev, b, cb, arg) \ argument
969 event_assign((ev), (b), -1, 0, (cb), (arg))
971 #define evtimer_add(ev, tv) event_add((ev), (tv)) argument
972 #define evtimer_del(ev) event_del(ev) argument
973 #define evtimer_pending(ev, tv) event_pending((ev), EV_TIMEOUT, (tv)) argument
974 #define evtimer_initialized(ev) event_initialized(ev) argument
983 #define evsignal_add(ev, tv) event_add((ev), (tv)) argument
984 #define evsignal_assign(ev, b, x, cb, arg) \ argument
985 event_assign((ev), (b), (x), EV_SIGNAL|EV_PERSIST, cb, (arg))
988 #define evsignal_del(ev) event_del(ev) argument
[all …]
|
| /external/libchrome/base/synchronization/ |
| D | waitable_event_unittest.cc | 93 WaitableEvent* ev[5]; in TEST() local
95 ev[i] = new WaitableEvent(WaitableEvent::ResetPolicy::AUTOMATIC, in TEST()
99 ev[3]->Signal(); in TEST()
100 EXPECT_EQ(WaitableEvent::WaitMany(ev, 5), 3u); in TEST()
102 ev[3]->Signal(); in TEST()
103 EXPECT_EQ(WaitableEvent::WaitMany(ev, 5), 3u); in TEST()
105 ev[4]->Signal(); in TEST()
106 EXPECT_EQ(WaitableEvent::WaitMany(ev, 5), 4u); in TEST()
108 ev[0]->Signal(); in TEST()
109 EXPECT_EQ(WaitableEvent::WaitMany(ev, 5), 0u); in TEST()
[all …]
|
| /external/syzkaller/executor/ |
| D | common_windows.h | 50 static void event_init(event_t* ev) in event_init() argument
52 InitializeCriticalSection(&ev->cs); in event_init()
53 InitializeConditionVariable(&ev->cv); in event_init()
54 ev->state = 0; in event_init()
57 static void event_reset(event_t* ev) in event_reset() argument
59 ev->state = 0; in event_reset()
62 static void event_set(event_t* ev) in event_set() argument
64 EnterCriticalSection(&ev->cs); in event_set()
65 if (ev->state) in event_set()
67 ev->state = 1; in event_set()
[all …]
|
| /external/libcxx/src/ |
| D | system_error.cpp | 42 error_category::default_error_condition(int ev) const _NOEXCEPT in default_error_condition()
44 return error_condition(ev, *this); in default_error_condition()
65 string do_strerror_r(int ev);
68 string do_strerror_r(int ev) { in do_strerror_r() argument
70 if (::strerror_s(buffer, strerror_buff_size, ev) == 0) in do_strerror_r()
72 std::snprintf(buffer, strerror_buff_size, "unknown error %d", ev); in do_strerror_r()
112 string do_strerror_r(int ev) { in do_strerror_r() argument
118 ::strerror_r(ev, buffer, strerror_buff_size), buffer); in do_strerror_r()
121 std::snprintf(buffer, strerror_buff_size, "Unknown error %d", ev); in do_strerror_r()
132 __do_message::message(int ev) const in message()
[all …]
|
| /external/tensorflow/tensorflow/python/summary/writer/ |
| D | writer_test.py | 81 ev = next(rr)
82 self._assertRecent(ev.wall_time)
83 self.assertEquals("brain.Event:2", ev.file_version)
86 ev = next(rr)
87 self._assertRecent(ev.wall_time)
88 self.assertEquals(0, ev.step)
90 ev_graph.ParseFromString(ev.graph_def)
94 ev = next(rr)
95 self._assertRecent(ev.wall_time)
96 self.assertEquals(0, ev.step)
[all …]
|
| /external/grpc-grpc/test/core/iomgr/ |
| D | resource_quota_test.cc | 50 grpc_closure* set_event(gpr_event* ev) { in set_event() argument
51 return GRPC_CLOSURE_CREATE(set_event_cb, ev, grpc_schedule_on_exec_ctx); in set_event()
154 gpr_event ev; in test_simple_async_alloc() local
155 gpr_event_init(&ev); in test_simple_async_alloc()
157 grpc_resource_user_alloc(usr, 1024, set_event(&ev)); in test_simple_async_alloc()
159 GPR_ASSERT(gpr_event_wait(&ev, grpc_timeout_seconds_to_deadline(5)) != in test_simple_async_alloc()
176 gpr_event ev; in test_async_alloc_blocked_by_size() local
177 gpr_event_init(&ev); in test_async_alloc_blocked_by_size()
180 grpc_resource_user_alloc(usr, 1024, set_event(&ev)); in test_async_alloc_blocked_by_size()
183 &ev, grpc_timeout_milliseconds_to_deadline(100)) == nullptr); in test_async_alloc_blocked_by_size()
[all …]
|
| /external/toybox/toys/posix/ |
| D | env.c | 35 char **ev = toys.optargs; in env_main() local
38 if (*ev && **ev == '-' && !(*ev)[1]) { in env_main()
40 ev++; in env_main()
49 for (; *ev; ev++) { in env_main()
50 char *name = *ev, *val = strchr(name, '='); in env_main()
55 } else xexec(ev); in env_main()
58 if (environ) for (ev = environ; *ev; ev++) in env_main()
59 xprintf("%s%c", *ev, '\n'*!(toys.optflags&FLAG_0)); in env_main()
|
| /external/tinyalsa/ |
| D | mixer.c | 335 struct snd_ctl_elem_value ev; in mixer_ctl_get_value() local
341 memset(&ev, 0, sizeof(ev)); in mixer_ctl_get_value()
342 ev.id.numid = ctl->info->id.numid; in mixer_ctl_get_value()
343 ret = ioctl(ctl->mixer->fd, SNDRV_CTL_IOCTL_ELEM_READ, &ev); in mixer_ctl_get_value()
349 return !!ev.value.integer.value[id]; in mixer_ctl_get_value()
352 return ev.value.integer.value[id]; in mixer_ctl_get_value()
355 return ev.value.enumerated.item[id]; in mixer_ctl_get_value()
358 return ev.value.bytes.data[id]; in mixer_ctl_get_value()
374 struct snd_ctl_elem_value ev; in mixer_ctl_get_array() local
394 memset(&ev, 0, sizeof(ev)); in mixer_ctl_get_array()
[all …]
|
| /external/autotest/client/site_tests/hardware_Keyboard/src/ |
| D | evtest.c | 321 struct input_event ev[64]; in do_single_key_capture() local
326 rd = read(fd, ev, sizeof(struct input_event) * 64); in do_single_key_capture()
334 if (ev[i].type == EV_KEY) { in do_single_key_capture()
335 if (0 == state && 1 == ev[i].value) { in do_single_key_capture()
336 code = ev[i].code; in do_single_key_capture()
338 } else if (code == ev[i].code && in do_single_key_capture()
339 0 == ev[i].value && in do_single_key_capture()
343 names[ev[i].type][ev[i].code]); in do_single_key_capture()
394 struct input_event ev[64]; in do_evtest_dumpall() local
444 rd = read(fd, ev, sizeof(struct input_event) * 64); in do_evtest_dumpall()
[all …]
|
| /external/grpc-grpc/src/core/lib/gpr/ |
| D | sync.cc | 50 static struct sync_array_s* hash(gpr_event* ev) { in hash() argument
51 return &sync_array[((uintptr_t)ev) % event_sync_partitions]; in hash()
54 void gpr_event_init(gpr_event* ev) { in gpr_event_init() argument
56 ev->state = 0; in gpr_event_init()
59 void gpr_event_set(gpr_event* ev, void* value) { in gpr_event_set() argument
60 struct sync_array_s* s = hash(ev); in gpr_event_set()
62 GPR_ASSERT(gpr_atm_acq_load(&ev->state) == 0); in gpr_event_set()
63 gpr_atm_rel_store(&ev->state, (gpr_atm)value); in gpr_event_set()
69 void* gpr_event_get(gpr_event* ev) { in gpr_event_get() argument
70 return (void*)gpr_atm_acq_load(&ev->state); in gpr_event_get()
[all …]
|
| /external/compiler-rt/lib/tsan/tests/rtl/ |
| D | tsan_test_util_posix.cc | 287 void send(Event *ev);
288 void HandleEvent(Event *ev);
291 void ScopedThread::Impl::HandleEvent(Event *ev) { in HandleEvent() argument
293 expect_report = ev->expect_report; in HandleEvent()
295 expect_report_type = ev->report_type; in HandleEvent()
296 switch (ev->type) { in HandleEvent()
300 if (ev->type == Event::READ) { in HandleEvent()
301 switch (ev->arg /*size*/) { in HandleEvent()
309 switch (ev->arg /*size*/) { in HandleEvent()
324 tsan_mop(ev->ptr); in HandleEvent()
[all …]
|
| /external/mesa3d/src/gallium/state_trackers/clover/core/ |
| D | event.cpp | 32 for (auto &ev : deps) in event() local
33 ev.chain(*this); in event()
56 for (event &ev : trigger_self()) in trigger()
57 ev.trigger(); in trigger()
75 for (event &ev : abort_self(status)) in abort()
76 ev.abort(status); in abort()
97 event::chain(event &ev) { in chain() argument
99 std::unique_lock<std::mutex> lock_ev(ev.mutex, std::defer_lock); in chain()
103 ev._wait_count++; in chain()
104 _chain.push_back(ev); in chain()
[all …]
|
| /external/mesa3d/src/gallium/state_trackers/clover/api/ |
| D | event.cpp | 65 for (auto &ev : evs) { in clWaitForEvents() local
66 if (ev.context() != evs.front().context()) in clWaitForEvents()
69 if (ev.status() < 0) in clWaitForEvents()
90 auto &ev = obj(d_ev); in clGetEventInfo() local
94 buf.as_scalar<cl_command_queue>() = desc(ev.queue()); in clGetEventInfo()
98 buf.as_scalar<cl_context>() = desc(ev.context()); in clGetEventInfo()
102 buf.as_scalar<cl_command_type>() = ev.command(); in clGetEventInfo()
106 buf.as_scalar<cl_int>() = ev.status(); in clGetEventInfo()
110 buf.as_scalar<cl_uint>() = ev.ref_count(); in clGetEventInfo()
127 auto &ev = obj(d_ev); in clSetEventCallback() local
[all …]
|
| /external/strace/ |
| D | epoll.c | 56 const struct epoll_event *ev = elem_buf; in print_epoll_event() local
59 printflags(epollevents, ev->events, "EPOLL???"); in print_epoll_event()
63 ev->data.u32, ev->data.u64); in print_epoll_event()
79 struct epoll_event ev; in SYS_FUNC() local
82 else if (!umove_or_printaddr(tcp, tcp->u_arg[3], &ev)) in SYS_FUNC()
83 print_epoll_event(tcp, &ev, sizeof(ev), 0); in SYS_FUNC()
95 struct epoll_event ev; in epoll_wait_common() local
96 print_array(tcp, tcp->u_arg[1], tcp->u_rval, &ev, sizeof(ev), in epoll_wait_common()
|
| /external/strace/tests-mx32/ |
| D | epoll_ctl.c | 12 invoke_syscall(unsigned long epfd, unsigned long op, unsigned long fd, void *ev) in invoke_syscall() argument
15 fd, (unsigned long) ev); in invoke_syscall()
21 TAIL_ALLOC_OBJECT_CONST_PTR(struct epoll_event, ev); in main()
22 ev->events = EPOLLIN; in main()
24 long rc = invoke_syscall(-1U, EPOLL_CTL_ADD, -2U, ev); in main()
27 ev->data.u32, ev->data.u64, rc, errno2name()); in main()
29 rc = invoke_syscall(-3U, EPOLL_CTL_DEL, -4U, ev); in main()
31 ev, rc, errno2name()); in main()
|
| /external/strace/tests/ |
| D | epoll_ctl.c | 12 invoke_syscall(unsigned long epfd, unsigned long op, unsigned long fd, void *ev) in invoke_syscall() argument
15 fd, (unsigned long) ev); in invoke_syscall()
21 TAIL_ALLOC_OBJECT_CONST_PTR(struct epoll_event, ev); in main()
22 ev->events = EPOLLIN; in main()
24 long rc = invoke_syscall(-1U, EPOLL_CTL_ADD, -2U, ev); in main()
27 ev->data.u32, ev->data.u64, rc, errno2name()); in main()
29 rc = invoke_syscall(-3U, EPOLL_CTL_DEL, -4U, ev); in main()
31 ev, rc, errno2name()); in main()
|