Home
last modified time | relevance | path

Searched refs:event_loop (Results 201 – 225 of 1817) sorted by relevance

12345678910>>...73

/dports/x11/alacritty/alacritty-0.9.0/cargo-crates/calloop-0.6.5/src/sources/
H A Dtimer.rs366 let evl_handle = event_loop.handle(); in single_timer()
381 event_loop in single_timer()
388 event_loop.dispatch(None, &mut fired).unwrap(); in single_timer()
398 let evl_handle = event_loop.handle(); in multi_timout_order()
418 event_loop in multi_timout_order()
424 event_loop in multi_timout_order()
430 event_loop in multi_timout_order()
441 let evl_handle = event_loop.handle(); in timer_cancel()
462 event_loop in timer_cancel()
472 event_loop in timer_cancel()
[all …]
/dports/devel/py-twisted/Twisted-22.1.0/src/twisted/internet/test/
H A Dtest_asyncioreactor.py102 event_loop = DefaultEventLoopPolicy().new_event_loop()
103 reactor = AsyncioSelectorReactor(event_loop)
104 set_event_loop(event_loop)
138 event_loop = WindowsProactorEventLoopPolicy().new_event_loop()
139 self.assertRaises(TypeError, AsyncioSelectorReactor, event_loop)
149 event_loop = WindowsSelectorEventLoopPolicy().new_event_loop()
150 reactor = AsyncioSelectorReactor(event_loop)
151 set_event_loop(event_loop)
/dports/net/py-saltyrtc.server/saltyrtc.server-5.0.1/tests/
H A Dconftest.py171 def event_loop(request): function
229 def sleep(event_loop): argument
234 kwargs.setdefault('loop', event_loop)
313 event_loop.set_debug(True)
340 loop=event_loop,
343 server_ = event_loop.run_until_complete(coroutine)
456 def client_kwargs(event_loop): argument
461 'loop': event_loop,
596 def unpack_message(request, event_loop): argument
635 def pack_message(request, event_loop): argument
[all …]
/dports/devel/py-threema-msgapi/threema-msgapi-sdk-python-3.0.6/tests/
H A Dconftest.py350 def event_loop(request): function
386 server_ = event_loop.run_until_complete(coroutine)
391 event_loop.run_until_complete(server_.wait_closed())
392 event_loop.run_until_complete(app.cleanup())
468 def blob_id(event_loop, connection, blob): argument
470 return event_loop.run_until_complete(coroutine)
474 def cli(api_server, api_server_port, event_loop): argument
561 def callback(event_loop, connection): argument
562 return Callback(connection, loop=event_loop)
579 event_loop.run_until_complete(callback.close())
[all …]
/dports/lang/rust/rustc-1.58.1-src/src/test/ui/issues/
H A Dissue-5192.rs27 event_loop: Box<dyn EventLoop+'static>, field
32 pub fn new(event_loop: Box<dyn EventLoop+'static>) -> Scheduler { in new()
34 event_loop: event_loop, in new()
/dports/devel/ipython/ipython-7.29.0/IPython/terminal/pt_inputhooks/
H A Dqt.py58 event_loop = QtCore.QEventLoop(app)
64 timer.timeout.connect(event_loop.quit)
67 _exec(event_loop)
77 notifier.activated.connect(lambda: event_loop.exit())
81 _exec(event_loop)
/dports/games/abstreet/winit-a87ae2661263ff241e8868cbf3ce65aab205863a/examples/
H A Dtransparent.rs3 event_loop::{ControlFlow, EventLoop},
9 let event_loop = EventLoop::new(); in main() localVariable
14 .build(&event_loop) in main()
19 event_loop.run(move |event, _, control_flow| { in main()
H A Drequest_redraw.rs3 event_loop::{ControlFlow, EventLoop},
9 let event_loop = EventLoop::new(); in main() localVariable
13 .build(&event_loop) in main()
16 event_loop.run(move |event, _, control_flow| { in main()
H A Dmin_max_size.rs4 event_loop::{ControlFlow, EventLoop},
10 let event_loop = EventLoop::new(); in main() localVariable
12 let window = WindowBuilder::new().build(&event_loop).unwrap(); in main()
17 event_loop.run(move |event, _, control_flow| { in main()
H A Dwindow.rs3 event_loop::{ControlFlow, EventLoop},
9 let event_loop = EventLoop::new(); in main() localVariable
14 .build(&event_loop) in main()
17 event_loop.run(move |event, _, control_flow| { in main()
H A Drequest_redraw_threaded.rs5 event_loop::{ControlFlow, EventLoop},
11 let event_loop = EventLoop::new(); in main() localVariable
15 .build(&event_loop) in main()
23 event_loop.run(move |event, _, control_flow| { in main()
H A Dminimize.rs4 use winit::event_loop::{ControlFlow, EventLoop};
9 let event_loop = EventLoop::new(); in main() localVariable
13 .build(&event_loop) in main()
16 event_loop.run(move |event, _, control_flow| { in main()
/dports/mail/rspamd-devel/rspamd-93430bb/src/libserver/
H A Dssl_util.c64 struct ev_loop *event_loop; member
441 rspamd_ev_watcher_stop (conn->event_loop, conn->ev); in rspamd_ssl_connection_dtor()
516 rspamd_ev_watcher_stop (conn->event_loop, conn->ev); in rspamd_ssl_shutdown()
552 rspamd_ev_watcher_stop (conn->event_loop, conn->ev); in rspamd_ssl_event_handler()
571 rspamd_ev_watcher_stop (conn->event_loop, conn->ev); in rspamd_ssl_event_handler()
624 rspamd_ev_watcher_stop (conn->event_loop, conn->ev); in rspamd_ssl_event_handler()
643 conn->event_loop = ev_base; in rspamd_ssl_connection_new()
675 ev_now (conn->event_loop)); in rspamd_ssl_connect_fd()
725 rspamd_ev_watcher_stop (conn->event_loop, ev); in rspamd_ssl_connect_fd()
750 rspamd_ev_watcher_stop (conn->event_loop, ev); in rspamd_ssl_connect_fd()
[all …]
/dports/devel/aws-c-io/aws-c-io-0.10.12/tests/vcc/
H A Dis_on_callers_thread.c19 static bool s_is_on_callers_thread(struct aws_event_loop *event_loop in s_is_on_callers_thread()
22 _(assert \always_by_claim(c_event_loop, event_loop)) in s_is_on_callers_thread()
23 struct epoll_loop *epoll_loop = event_loop->impl_data; in s_is_on_callers_thread()
29 _(assume thread_id == NULL || *thread_id == \addr(event_loop->\owner)) in s_is_on_callers_thread()
H A Dunsubscribe.c30 static int s_unsubscribe_from_io_events(struct aws_event_loop *event_loop, struct aws_io_handle *ha… in s_unsubscribe_from_io_events() argument
35 …AWS_LS_IO_EVENT_LOOP, "id=%p: un-subscribing from events on fd %d", (void *)event_loop, handle->da… in s_unsubscribe_from_io_events()
36 struct epoll_loop *epoll_loop = event_loop->impl_data; in s_unsubscribe_from_io_events()
49 (void *)event_loop, in s_unsubscribe_from_io_events()
66 …s_schedule_task_now(event_loop, &additional_handle_data->cleanup_task _(ghost c_event_loop) _(ghos… in s_unsubscribe_from_io_events()
H A Dnew_destroy.c253 #define aws_event_loop_stop(event_loop) \ argument
254 s_stop(event_loop _(ghost c_event_loop) _(ghost c_mutex));
256 static void s_destroy(struct aws_event_loop *event_loop in s_destroy()
261 struct epoll_loop *epoll_loop = event_loop->impl_data; in s_destroy()
265 aws_event_loop_stop(event_loop); in s_destroy()
266 s_wait_for_stop_completion(event_loop _(ghost c_event_loop) _(ghost c_mutex)); in s_destroy()
267 epoll_loop = event_loop->impl_data; /*< VCC change: refresh epoll_loop reference */ in s_destroy()
268 _(unwrap(event_loop)) in s_destroy()
337 aws_mem_release(event_loop->alloc, epoll_loop); in s_destroy()
338 aws_event_loop_clean_up_base(event_loop); in s_destroy()
[all …]
/dports/x11/alacritty/alacritty-0.9.0/cargo-crates/winit-0.24.0/examples/
H A Dtransparent.rs4 event_loop::{ControlFlow, EventLoop},
10 let event_loop = EventLoop::new(); in main() localVariable
15 .build(&event_loop) in main()
20 event_loop.run(move |event, _, control_flow| { in main()
H A Dmin_max_size.rs5 event_loop::{ControlFlow, EventLoop},
11 let event_loop = EventLoop::new(); in main() localVariable
13 let window = WindowBuilder::new().build(&event_loop).unwrap(); in main()
18 event_loop.run(move |event, _, control_flow| { in main()
H A Drequest_redraw.rs4 event_loop::{ControlFlow, EventLoop},
10 let event_loop = EventLoop::new(); in main() localVariable
14 .build(&event_loop) in main()
17 event_loop.run(move |event, _, control_flow| { in main()
H A Dwindow.rs4 event_loop::{ControlFlow, EventLoop},
10 let event_loop = EventLoop::new(); in main() localVariable
15 .build(&event_loop) in main()
18 event_loop.run(move |event, _, control_flow| { in main()
H A Dminimize.rs5 use winit::event_loop::{ControlFlow, EventLoop};
10 let event_loop = EventLoop::new(); in main() localVariable
14 .build(&event_loop) in main()
17 event_loop.run(move |event, _, control_flow| { in main()
/dports/audio/musicpd/mpd-0.23.6/test/
H A Drun_inotify.cxx54 EventLoop event_loop; in main() local
55 const ShutdownHandler shutdown_handler(event_loop); in main()
57 InotifySource source(event_loop, my_inotify_callback, nullptr); in main()
60 event_loop.Run(); in main()
/dports/audio/ncmpc/ncmpc-0.41/src/
H A Daconnect.cxx50 explicit AsyncMpdConnect(EventLoop &event_loop, in AsyncMpdConnect()
53 rconnect(event_loop, *this), in AsyncMpdConnect()
54 socket(event_loop, BIND_THIS_METHOD(OnReceive)) {} in AsyncMpdConnect()
110 aconnect_start(EventLoop &event_loop, in aconnect_start() argument
115 auto *ac = new AsyncMpdConnect(event_loop, handler); in aconnect_start()
/dports/audio/spectmorph/spectmorph-0.5.2/vst/
H A Dsmvstui.cc37 event_loop = new EventLoop();
38 widget = new MorphPlanWindow (*event_loop, "SpectMorph VST", win_id, false, morph_plan);
68 delete event_loop;
69 event_loop = nullptr;
76 event_loop->process_events();
/dports/audio/ardour6/Ardour-6.8.0/libs/surfaces/websockets/
H A Dfeedback.cc200 ArdourFeedback::event_loop () const in event_loop() function in ArdourFeedback
205 return SurfaceComponent::event_loop (); in event_loop()
229 boost::bind<void> (TransportObserver (), this), event_loop ()); in observe_transport()
231 boost::bind<void> (RecordStateObserver (), this), event_loop ()); in observe_transport()
233 boost::bind<void> (TempoObserver (), this), event_loop ()); in observe_transport()
246 … boost::bind<void> (StripGainObserver (), this, strip_id), event_loop ()); in observe_mixer()
250 … boost::bind<void> (StripPanObserver (), this, strip_id), event_loop ()); in observe_mixer()
254 … boost::bind<void> (StripMuteObserver (), this, strip_id), event_loop ()); in observe_mixer()
273 … boost::bind<void> (PluginBypassObserver (), this, strip_id, plugin_id), event_loop ()); in observe_strip_plugins()
283 event_loop ()); in observe_strip_plugins()

12345678910>>...73