/dports/x11/alacritty/alacritty-0.9.0/cargo-crates/calloop-0.6.5/src/sources/ |
H A D | timer.rs | 366 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 D | test_asyncioreactor.py | 102 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 D | conftest.py | 171 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 D | conftest.py | 350 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 D | issue-5192.rs | 27 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 D | qt.py | 58 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 D | transparent.rs | 3 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 D | request_redraw.rs | 3 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 D | min_max_size.rs | 4 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 D | window.rs | 3 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 D | request_redraw_threaded.rs | 5 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 D | minimize.rs | 4 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 D | ssl_util.c | 64 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 D | is_on_callers_thread.c | 19 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 D | unsubscribe.c | 30 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 D | new_destroy.c | 253 #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 D | transparent.rs | 4 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 D | min_max_size.rs | 5 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 D | request_redraw.rs | 4 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 D | window.rs | 4 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 D | minimize.rs | 5 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 D | run_inotify.cxx | 54 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 D | aconnect.cxx | 50 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 D | smvstui.cc | 37 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 D | feedback.cc | 200 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()
|