| /dports/devel/aws-c-io/aws-c-io-0.10.12/source/ |
| H A D | event_loop.c | 376 AWS_ASSERT(event_loop->vtable && event_loop->vtable->destroy); in aws_event_loop_destroy()
379 event_loop->vtable->destroy(event_loop); in aws_event_loop_destroy()
439 AWS_ASSERT(event_loop->vtable && event_loop->vtable->run); in aws_event_loop_run()
440 return event_loop->vtable->run(event_loop); in aws_event_loop_run()
444 AWS_ASSERT(event_loop->vtable && event_loop->vtable->stop); in aws_event_loop_stop()
445 return event_loop->vtable->stop(event_loop); in aws_event_loop_stop()
451 return event_loop->vtable->wait_for_stop_completion(event_loop); in aws_event_loop_wait_for_stop_completion()
457 event_loop->vtable->schedule_task_now(event_loop, task); in aws_event_loop_schedule_task_now()
471 AWS_ASSERT(event_loop->vtable && event_loop->vtable->cancel_task); in aws_event_loop_cancel_task()
474 event_loop->vtable->cancel_task(event_loop, task); in aws_event_loop_cancel_task()
[all …]
|
| /dports/databases/cassandra-cpp-driver/cpp-driver-2.16.0/tests/src/unit/tests/ |
| H A D | test_event_loop.cpp | 54 virtual void run(EventLoop* event_loop) { event_loop->maybe_start_io_time(); } in run() argument
109 EventLoop event_loop; in TEST_F() local
117 event_loop.close_handles(); in TEST_F()
118 event_loop.join(); in TEST_F()
123 EventLoop event_loop; in TEST_F() local
129 event_loop.add(new MarkIsRunningOn(this, &event_loop)); in TEST_F()
132 event_loop.join(); in TEST_F()
137 EventLoop event_loop; in TEST_F() local
153 event_loop.join(); in TEST_F()
158 TestEventLoop event_loop; in TEST_F() local
[all …]
|
| /dports/devel/aws-c-io/aws-c-io-0.10.12/source/windows/iocp/ |
| H A D | iocp_event_loop.c | 175 if (!event_loop) { in aws_event_loop_new_default_with_options()
209 (void *)event_loop, in aws_event_loop_new_default_with_options()
240 return event_loop; in aws_event_loop_new_default_with_options()
268 if (event_loop) { in aws_event_loop_new_default_with_options()
319 aws_mem_release(event_loop->alloc, event_loop); in s_destroy()
431 (void *)event_loop, in s_schedule_task_common()
445 (void *)event_loop, in s_schedule_task_common()
505 (void *)event_loop, in s_connect_to_io_completion_port()
602 (void)event_loop; in s_unsubscribe_from_io_events()
606 (void *)event_loop, in s_unsubscribe_from_io_events()
[all …]
|
| /dports/devel/libspice-server/spice-0.15.0/server/tests/ |
| H A D | test-listen.c | 66 event_loop->core->timer_start(event_loop->exit_mainloop_timer, 0); in test_event_loop_quit()
72 event_loop->timeout_timer = event_loop->core->timer_add(timeout_cb, NULL); in test_event_loop_init()
73 event_loop->exit_mainloop_timer = event_loop->core->timer_add(exit_mainloop_cb, NULL); in test_event_loop_init()
79 event_loop->core->timer_remove(event_loop->timeout_timer); in test_event_loop_destroy()
83 event_loop->core->timer_remove(event_loop->exit_mainloop_timer); in test_event_loop_destroy()
87 event_loop->core = NULL; in test_event_loop_destroy()
92 event_loop->core->timer_start(event_loop->timeout_timer, 50000); in test_event_loop_run()
160 TestEventLoop *event_loop; member
227 thread_data->event_loop = event_loop; in fake_client_new()
252 test_event_loop_run(&event_loop); in test_connect_plain()
[all …]
|
| /dports/devel/py-pyface/pyface-7.2.0/pyface/tests/ |
| H A D | test_application_window.py | 58 with self.event_loop():
61 with self.event_loop():
63 with self.event_loop():
68 with self.event_loop():
70 with self.event_loop():
72 with self.event_loop():
78 with self.event_loop():
80 with self.event_loop():
85 with self.event_loop():
87 with self.event_loop():
[all …]
|
| H A D | test_python_shell.py | 48 with self.event_loop():
50 with self.event_loop():
55 with self.event_loop():
57 with self.event_loop():
62 with self.event_loop():
67 with self.event_loop():
76 with self.event_loop():
81 with self.event_loop():
90 with self.event_loop():
95 with self.event_loop():
[all …]
|
| H A D | test_window.py | 50 with self.event_loop():
67 with self.event_loop():
69 with self.event_loop():
71 with self.event_loop():
73 with self.event_loop():
78 with self.event_loop():
80 with self.event_loop():
82 with self.event_loop():
88 with self.event_loop():
90 with self.event_loop():
[all …]
|
| /dports/devel/aws-c-io/aws-c-io-0.10.12/source/bsd/ |
| H A D | kqueue_event_loop.c | 151 if (!event_loop) { in aws_event_loop_new_default_with_options()
201 (void *)event_loop, in aws_event_loop_new_default_with_options()
256 return event_loop; in aws_event_loop_new_default_with_options()
299 s_stop(event_loop); in s_destroy()
354 aws_mem_release(event_loop->alloc, event_loop); in s_destroy()
473 (void *)event_loop, in s_schedule_task_common()
515 struct aws_event_loop *event_loop = handle_data->event_loop; in s_subscribe_task() local
594 (void *)event_loop, in s_subscribe_task()
622 AWS_ASSERT(event_loop); in s_subscribe_to_io_events()
635 handle_data->event_loop = event_loop; in s_subscribe_to_io_events()
[all …]
|
| /dports/graphics/py-pyglet150/pyglet-1.5.0/tests/interactive/media/ |
| H A D | test_player.py | 23 event_loop.run_event_loop()
31 event_loop.run_event_loop()
43 event_loop.run_event_loop()
49 def test_play_queue(event_loop): argument
56 event_loop.run_event_loop()
61 def test_queue_play(event_loop): argument
68 event_loop.run_event_loop()
73 def test_pause_queue(event_loop): argument
86 def test_pause_sound(event_loop): argument
115 event_loop.run_event_loop()
[all …]
|
| /dports/graphics/py-pyglet/pyglet-1.5.21/tests/interactive/media/ |
| H A D | test_player.py | 23 event_loop.run_event_loop()
31 event_loop.run_event_loop()
43 event_loop.run_event_loop()
49 def test_play_queue(event_loop): argument
56 event_loop.run_event_loop()
61 def test_queue_play(event_loop): argument
68 event_loop.run_event_loop()
73 def test_pause_queue(event_loop): argument
86 def test_pause_sound(event_loop): argument
115 event_loop.run_event_loop()
[all …]
|
| /dports/devel/aws-c-io/aws-c-io-0.10.12/source/linux/ |
| H A D | epoll_event_loop.c | 54 struct aws_event_loop *event_loop,
238 aws_event_loop_stop(event_loop); in s_destroy()
265 aws_mem_release(event_loop->alloc, event_loop); in s_destroy()
333 (void *)event_loop, in s_schedule_task_common()
348 (void *)event_loop, in s_schedule_task_common()
388 struct aws_event_loop *event_loop, in s_subscribe_to_io_events() argument
462 (void *)event_loop, in s_unsubscribe_from_io_events()
492 struct aws_event_loop *event_loop, in s_on_tasks_to_schedule() argument
539 (void *)event_loop, in s_process_task_pre_queue()
571 (void *)event_loop, in s_main_loop()
[all …]
|
| /dports/graphics/py-pyglet/pyglet-1.5.21/tests/integration/app/ |
| H A D | test_eventloop.py | 6 from pyglet.app import event_loop
11 assert event_loop.is_running
16 event_loop.clock.schedule_once(lambda dt: event_loop.exit(), .2)
18 event_loop.run()
34 event_loop.clock.schedule_once(lambda dt: event_loop.exit(), .1)
35 event_loop.run()
43 event_loop.clock.schedule_once(lambda dt: event_loop.on_window_close(None), .1)
44 event_loop.run()
50 event_loop.sleep(100.)
56 event_loop.clock.schedule_once(lambda dt: event_loop.exit(), .2)
[all …]
|
| /dports/graphics/py-pyglet150/pyglet-1.5.0/tests/integration/app/ |
| H A D | test_eventloop.py | 6 from pyglet.app import event_loop
11 assert event_loop.is_running
16 event_loop.clock.schedule_once(lambda dt: event_loop.exit(), .2)
18 event_loop.run()
34 event_loop.clock.schedule_once(lambda dt: event_loop.exit(), .1)
35 event_loop.run()
43 event_loop.clock.schedule_once(lambda dt: event_loop.on_window_close(None), .1)
44 event_loop.run()
50 event_loop.sleep(100.)
56 event_loop.clock.schedule_once(lambda dt: event_loop.exit(), .2)
[all …]
|
| /dports/devel/aws-c-io/aws-c-io-0.10.12/include/aws/io/ |
| H A D | event_loop.h | 33 struct aws_event_loop *event_loop,
55 struct aws_event_loop *event_loop,
63 void (*destroy)(struct aws_event_loop *event_loop);
64 int (*run)(struct aws_event_loop *event_loop);
65 int (*stop)(struct aws_event_loop *event_loop);
74 struct aws_event_loop *event_loop,
188 struct aws_event_loop *event_loop,
208 struct aws_event_loop *event_loop,
283 struct aws_event_loop *event_loop,
310 struct aws_event_loop *event_loop,
[all …]
|
| /dports/devel/aws-c-io/aws-c-io-0.10.12/tests/vcc/ |
| H A D | lifecycle.c | 23 struct aws_event_loop *event_loop = args; in s_stop_task() local
24 struct epoll_loop *epoll_loop = event_loop->impl_data; in s_stop_task()
40 static int s_stop(struct aws_event_loop *event_loop in s_stop()
44 _(assert \always_by_claim(c_event_loop, event_loop)) in s_stop()
45 struct epoll_loop *epoll_loop = event_loop->impl_data; in s_stop()
67 …pped0(c_event_loop) && \claims(c_event_loop, event_loop->\closed) && \claims_object(c_event_loop, …
68 _(writes c_event_loop, event_loop)
70 _(ensures \wrapped0(event_loop) && \nested(epoll_loop_of(event_loop)))
73 _(maintains \malloc_root(epoll_loop_of(event_loop)))
77 static int s_wait_for_stop_completion(struct aws_event_loop *event_loop in s_wait_for_stop_completion()
[all …]
|
| H A D | client.c | 37 if (!event_loop) return; in test_new_destroy()
39 _(ghost c_event_loop = \make_claim({event_loop}, event_loop->\closed);) in test_new_destroy()
44 struct aws_event_loop *event_loop,
54 _(always c_event_loop, event_loop->\closed) in test_subscribe_unsubscribe()
56 _(writes event_loop) in test_subscribe_unsubscribe()
57 _(updates &epoll_loop_of(event_loop)->scheduler) in test_subscribe_unsubscribe()
78 void test_schedule_cancel(struct aws_event_loop *event_loop in test_schedule_cancel()
82 _(requires \wrapped(event_loop)) in test_schedule_cancel()
83 _(always c_event_loop, event_loop->\closed) in test_schedule_cancel()
85 _(updates &epoll_loop_of(event_loop)->scheduler) in test_schedule_cancel()
[all …]
|
| H A D | main_loop.c | 23 struct aws_event_loop *event_loop, in s_on_tasks_to_schedule() argument
32 struct epoll_loop *epoll_loop = event_loop->impl_data; in s_on_tasks_to_schedule()
39 struct aws_event_loop *event_loop = args; in s_main_loop() local
40 AWS_LOGF_INFO(AWS_LS_IO_EVENT_LOOP, "id=%p: main loop started", (void *)event_loop); in s_main_loop()
41 struct epoll_loop *epoll_loop = event_loop->impl_data; in s_main_loop()
43 _(ghost c_event_loop = \make_claim({event_loop}, event_loop->\closed);) in s_main_loop()
63 (void *)event_loop, in s_main_loop()
122 (void *)event_loop, in s_main_loop()
129 s_process_task_pre_queue(event_loop _(ghost c_event_loop) _(ghost c_mutex)); in s_main_loop()
141 if (event_loop->clock(&now_ns)) { in s_main_loop()
[all …]
|
| /dports/devel/py-azure-mgmt-compute/azure-mgmt-compute-23.0.0/tests/ |
| H A D | test_mgmt_compute_base_async.py | 145 result = self.event_loop.run_until_complete(
148 result = self.event_loop.run_until_complete(
160 result = self.event_loop.run_until_complete(
163 result = self.event_loop.run_until_complete(
168 result = self.event_loop.run_until_complete(
173 result = self.event_loop.run_until_complete(
179 result = self.event_loop.run_until_complete(
189 result = self.event_loop.run_until_complete(
204 result = self.event_loop.run_until_complete(
227 result = self.event_loop.run_until_complete(
[all …]
|
| /dports/devel/aws-c-io/aws-c-io-0.10.12/tests/ |
| H A D | event_loop_test.c | 92 aws_event_loop_destroy(event_loop); in s_test_event_loop_xthread_scheduled_tasks_execute()
212 struct aws_event_loop *event_loop; member
238 data->event_loop = event_loop; in s_on_overlapped_operation_complete()
257 ASSERT_NOT_NULL(event_loop); in s_test_event_loop_completion_events()
291 ASSERT_PTR_EQUALS(event_loop, completion_data.event_loop); in s_test_event_loop_completion_events()
382 (void)event_loop;
541 ASSERT_NOT_NULL(event_loop);
548 .event_loop = event_loop,
728 (void)event_loop;
1040 ASSERT_NOT_NULL(event_loop); in AWS_TEST_CASE()
[all …]
|
| /dports/devel/py-azure-mgmt-storage/azure-mgmt-storage-19.0.0/tests/ |
| H A D | test_cli_mgmt_storage_async.py | 143 result = self.event_loop.run_until_complete(
223 result = self.event_loop.run_until_complete(
296 result = self.event_loop.run_until_complete(
305 result = self.event_loop.run_until_complete(
350 result = self.event_loop.run_until_complete(
374 result = self.event_loop.run_until_complete(
379 result = self.event_loop.run_until_complete(
388 result = self.event_loop.run_until_complete(
398 result = self.event_loop.run_until_complete(
407 result = self.event_loop.run_until_complete(
[all …]
|
| /dports/devel/fossology-nomos-standalone/fossology-3.11.0/src/scheduler/agent/ |
| H A D | event.c | 88 g_async_queue_push(event_loop->queue, e); in event_loop_put()
110 if(event_loop->terminated) in event_loop_take()
240 g_async_queue_lock(event_loop->queue); in event_loop_enter()
241 if(event_loop->occupied) in event_loop_enter()
246 event_loop->occupied = 1; in event_loop_enter()
247 event_loop->terminated = 0; in event_loop_enter()
248 g_async_queue_unlock(event_loop->queue); in event_loop_enter()
254 while(!event_loop->terminated) in event_loop_enter()
256 e = event_loop_take(event_loop); in event_loop_enter()
290 event_loop->terminated = 1; in event_loop_terminate()
[all …]
|
| /dports/multimedia/scte35dump/scte35dump-0.1.6/cargo-crates/mio-0.6.19/test/ |
| H A D | test_battery.rs | 40 event_loop.reregister(&self.sock, self.token.unwrap(), in writable()
57 event_loop.shutdown(); in readable()
93 fn conn_readable(&mut self, event_loop: &mut EventLoop<Echo>, in conn_readable()
96 self.conn(tok).readable(event_loop) in conn_readable()
102 self.conn(tok).writable(event_loop) in conn_writable()
212 event_loop.reregister( in notify()
232 let mut event_loop = b.build().unwrap(); in test_echo_server() localVariable
239 event_loop.register(&srv, SERVER, Ready::readable(), in test_echo_server()
245 event_loop.register(&sock, CLIENT, Ready::writable(), in test_echo_server()
247 let chan = event_loop.channel(); in test_echo_server()
[all …]
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/mio-0.6.21/test/ |
| H A D | test_battery.rs | 40 event_loop.reregister(&self.sock, self.token.unwrap(), in writable()
57 event_loop.shutdown(); in readable()
93 fn conn_readable(&mut self, event_loop: &mut EventLoop<Echo>, in conn_readable()
96 self.conn(tok).readable(event_loop) in conn_readable()
102 self.conn(tok).writable(event_loop) in conn_writable()
212 event_loop.reregister( in notify()
232 let mut event_loop = b.build().unwrap(); in test_echo_server() localVariable
239 event_loop.register(&srv, SERVER, Ready::readable(), in test_echo_server()
245 event_loop.register(&sock, CLIENT, Ready::writable(), in test_echo_server()
247 let chan = event_loop.channel(); in test_echo_server()
[all …]
|
| /dports/editors/xi-term/xi-term-d264767/cargo-crates/mio-0.6.19/test/ |
| H A D | test_battery.rs | 40 event_loop.reregister(&self.sock, self.token.unwrap(), in writable()
57 event_loop.shutdown(); in readable()
93 fn conn_readable(&mut self, event_loop: &mut EventLoop<Echo>, in conn_readable()
96 self.conn(tok).readable(event_loop) in conn_readable()
102 self.conn(tok).writable(event_loop) in conn_writable()
212 event_loop.reregister( in notify()
232 let mut event_loop = b.build().unwrap(); in test_echo_server() localVariable
239 event_loop.register(&srv, SERVER, Ready::readable(), in test_echo_server()
245 event_loop.register(&sock, CLIENT, Ready::writable(), in test_echo_server()
247 let chan = event_loop.channel(); in test_echo_server()
[all …]
|
| /dports/games/abstreet/abstreet-0.2.9-49-g74aca40c0/cargo-crates/mio-0.6.21/test/ |
| H A D | test_battery.rs | 40 event_loop.reregister(&self.sock, self.token.unwrap(), in writable()
57 event_loop.shutdown(); in readable()
93 fn conn_readable(&mut self, event_loop: &mut EventLoop<Echo>, in conn_readable()
96 self.conn(tok).readable(event_loop) in conn_readable()
102 self.conn(tok).writable(event_loop) in conn_writable()
212 event_loop.reregister( in notify()
232 let mut event_loop = b.build().unwrap(); in test_echo_server() localVariable
239 event_loop.register(&srv, SERVER, Ready::readable(), in test_echo_server()
245 event_loop.register(&sock, CLIENT, Ready::writable(), in test_echo_server()
247 let chan = event_loop.channel(); in test_echo_server()
[all …]
|