/dports/x11/alacritty/alacritty-0.9.0/cargo-crates/winit-0.24.0/examples/ |
H A D | request_redraw_threaded.rs | 6 event_loop::{ControlFlow, EventLoop}, 12 let event_loop = EventLoop::new(); in main() localVariable 16 .build(&event_loop) in main() 24 event_loop.run(move |event, _, control_flow| { in main()
|
H A D | handling_close.rs | 4 event_loop::{ControlFlow, EventLoop}, 10 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 | timer.rs | 7 event_loop::{ControlFlow, EventLoop}, 13 let event_loop = EventLoop::new(); in main() localVariable 17 .build(&event_loop) in main() 22 event_loop.run(move |event, _, control_flow| { in main()
|
H A D | set_ime_position.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() 20 event_loop.run(move |event, _, control_flow| { in main()
|
H A D | resizable.rs | 5 event_loop::{ControlFlow, EventLoop}, 11 let event_loop = EventLoop::new(); in main() localVariable 19 .build(&event_loop) in main() 22 event_loop.run(move |event, _, control_flow| { in main()
|
H A D | window_run_return.rs | 17 event_loop::{ControlFlow, EventLoop}, in main() 21 let mut event_loop = EventLoop::new(); in main() localVariable 26 .build(&event_loop) in main() 32 event_loop.run_return(|event, _, control_flow| { in main()
|
/dports/mail/rspamd/rspamd-3.1/src/libserver/ |
H A D | ssl_util.c | 64 struct ev_loop *event_loop; member 509 rspamd_ev_watcher_stop (conn->event_loop, conn->ev); in rspamd_ssl_shutdown() 545 rspamd_ev_watcher_stop (conn->event_loop, conn->ev); in rspamd_ssl_event_handler() 564 rspamd_ev_watcher_stop (conn->event_loop, conn->ev); in rspamd_ssl_event_handler() 587 rspamd_ev_watcher_stop (conn->event_loop, conn->ev); in rspamd_ssl_event_handler() 617 rspamd_ev_watcher_stop (conn->event_loop, conn->ev); in rspamd_ssl_event_handler() 636 conn->event_loop = ev_base; in rspamd_ssl_connection_new() 666 ev_now (conn->event_loop)); in rspamd_ssl_connect_fd() 716 rspamd_ev_watcher_stop (conn->event_loop, ev); in rspamd_ssl_connect_fd() 718 rspamd_ev_watcher_start (conn->event_loop, ev, timeout); in rspamd_ssl_connect_fd() [all …]
|
/dports/mail/py-postfix-mta-sts-resolver/postfix-mta-sts-resolver-1.1.1/tests/ |
H A D | test_proactive_fetcher.py | 32 async def test_cache_update(event_loop, cache, argument 43 pf = STSProactiveFetcher(cfg, event_loop, cache) 71 async def test_no_cache_update_during_grace_period(event_loop, cache): argument 81 pf = STSProactiveFetcher(cfg, event_loop, cache) 97 async def test_respect_previous_proactive_fetch_ts(event_loop, cache): argument 109 pf = STSProactiveFetcher(cfg, event_loop, cache)
|
/dports/devel/py-urwid/urwid-2.1.2/urwid/ |
H A D | main_loop.py | 108 event_loop=None, pop_ups=False): argument 127 ) and event_loop is not None: 130 if event_loop is None: 131 event_loop = SelectEventLoop() 132 self.event_loop = event_loop 174 return self.event_loop.alarm(sec, cb) 197 return self.event_loop.remove_alarm(handle) 367 self.screen.unhook_event_loop(self.event_loop) 372 self.screen.unhook_event_loop(self.event_loop) 385 self.event_loop.run() [all …]
|
/dports/games/abstreet/winit-a87ae2661263ff241e8868cbf3ce65aab205863a/examples/ |
H A D | timer.rs | 5 event_loop::{ControlFlow, EventLoop}, 11 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 | resizable.rs | 4 event_loop::{ControlFlow, EventLoop}, 10 let event_loop = EventLoop::new(); in main() localVariable 18 .build(&event_loop) in main() 21 event_loop.run(move |event, _, control_flow| { in main()
|
H A D | handling_close.rs | 3 event_loop::{ControlFlow, EventLoop}, 9 let event_loop = EventLoop::new(); in main() localVariable 13 .build(&event_loop) in main() 18 event_loop.run(move |event, _, control_flow| { in main()
|
H A D | window_run_return.rs | 15 event_loop::{ControlFlow, EventLoop}, in main() 19 let mut event_loop = EventLoop::new(); in main() localVariable 24 .build(&event_loop) in main() 30 event_loop.run_return(|event, _, control_flow| { in main()
|
/dports/www/firefox-esr/firefox-91.8.0/testing/web-platform/tests/tools/third_party/pytest-asyncio/ |
H A D | README.rst | 55 ``event_loop`` 72 def test_http_client(event_loop): 74 resp = event_loop.run_until_complete(http_client(url)) 80 ``pytest.mark.asyncio`` marker and not the ``event_loop`` fixture directly. 85 def event_loop(): 126 to redefine the ``event_loop`` fixture to have the same or broader scope. 128 than the ``event_loop`` fixture. 169 async def test_example(event_loop): 171 await asyncio.sleep(0, loop=event_loop) 237 - The ``event_loop`` fixture is again responsible for closing itself. [all …]
|
/dports/www/firefox/firefox-99.0/testing/web-platform/tests/tools/third_party/pytest-asyncio/ |
H A D | README.rst | 55 ``event_loop`` 72 def test_http_client(event_loop): 74 resp = event_loop.run_until_complete(http_client(url)) 80 ``pytest.mark.asyncio`` marker and not the ``event_loop`` fixture directly. 85 def event_loop(): 126 to redefine the ``event_loop`` fixture to have the same or broader scope. 128 than the ``event_loop`` fixture. 169 async def test_example(event_loop): 171 await asyncio.sleep(0, loop=event_loop) 237 - The ``event_loop`` fixture is again responsible for closing itself. [all …]
|
/dports/mail/thunderbird/thunderbird-91.8.0/testing/web-platform/tests/tools/third_party/pytest-asyncio/ |
H A D | README.rst | 55 ``event_loop`` 72 def test_http_client(event_loop): 74 resp = event_loop.run_until_complete(http_client(url)) 80 ``pytest.mark.asyncio`` marker and not the ``event_loop`` fixture directly. 85 def event_loop(): 126 to redefine the ``event_loop`` fixture to have the same or broader scope. 128 than the ``event_loop`` fixture. 169 async def test_example(event_loop): 171 await asyncio.sleep(0, loop=event_loop) 237 - The ``event_loop`` fixture is again responsible for closing itself. [all …]
|
/dports/audio/musicpd/mpd-0.23.6/src/lib/dbus/ |
H A D | Watch.hxx | 67 Watch(EventLoop &event_loop, WatchManager &_parent, 81 WatchManager(EventLoop &event_loop, in WatchManager() argument 84 defer_dispatch(event_loop, BIND_THIS_METHOD(Dispatch)) in WatchManager() 89 WatchManager(EventLoop &event_loop, WatchManagerObserver &_observer, in WatchManager() argument 91 :WatchManager(event_loop, _observer) in WatchManager()
|
/dports/audio/musicpd/mpd-0.23.6/src/neighbor/plugins/ |
H A D | UpnpNeighborPlugin.cxx | 54 EventLoop &event_loop; member in UpnpNeighborExplorer 61 :NeighborExplorer(_listener), event_loop(_event_loop) {} in UpnpNeighborExplorer() 79 discovery = new UPnPDeviceDirectory(event_loop, handle, this); in Open() 129 upnp_neighbor_create(EventLoop &event_loop, in upnp_neighbor_create() argument 133 return std::make_unique<UpnpNeighborExplorer>(event_loop, listener); in upnp_neighbor_create()
|
/dports/devel/py-urwid/urwid-2.1.2/examples/ |
H A D | asyncio_socket_server.py | 73 event_loop=urwid.AsyncioEventLoop(loop=loop), 104 def hook_event_loop(self, event_loop, callback): argument 120 event_loop, callback, bytearray(fut.result())) 129 self._pending_task = event_loop._loop.create_task( 135 def unhook_event_loop(self, event_loop): argument 157 event_loop=urwid.AsyncioEventLoop(loop=loop),
|
/dports/editors/kak-lsp/kak-lsp-11.1.0/src/ |
H A D | session.rs | 43 'event_loop: loop { in start() 53 break 'event_loop in start() 61 break 'event_loop; in start() 69 break 'event_loop; in start() 74 continue 'event_loop; in start() 83 continue 'event_loop; in start() 105 continue 'event_loop; in start()
|
/dports/x11/alacritty/alacritty-0.9.0/cargo-crates/winit-0.24.0/src/platform_impl/linux/wayland/event_loop/ |
H A D | mod.rs | 19 use crate::event_loop::{ControlFlow, EventLoopWindowTarget as RootEventLoopWindowTarget}; 73 event_loop: calloop::EventLoop<WinitState>, field 105 let event_loop = calloop::EventLoop::<WinitState>::new()?; in new() localVariable 128 event_loop in new() 140 event_loop.handle().insert_source( in new() 147 let event_loop_handle = event_loop.handle(); in new() 171 let event_loop = Self { in new() localVariable 172 event_loop, in new() 184 Ok(event_loop) in new() 406 let handle = self.event_loop.handle(); in run_return() [all …]
|
/dports/audio/musicpd/mpd-0.23.6/src/ |
H A D | Main.cxx | 187 InitStorage(Instance &instance, EventLoop &event_loop, in InitStorage() argument 190 auto storage = CreateConfiguredStorage(config, event_loop); in InitStorage() 243 instance.event_loop, *sdb, in glue_db_init_and_load() 286 instance.event_loop); in glue_state_file_init() 504 auto &event_loop = instance.io_thread.GetEventLoop(); in MainConfigured() local 505 BlockingCall(event_loop, [&](){ in MainConfigured() 506 zeroconf = ZeroconfInit(raw_config, event_loop); in MainConfigured() 515 auto &event_loop = instance.io_thread.GetEventLoop(); in MainConfigured() local 516 BlockingCall(event_loop, [&](){ in MainConfigured() 540 mpd_inotify_init(instance.event_loop, in MainConfigured() [all …]
|
/dports/audio/musicpd/mpd-0.23.6/src/storage/ |
H A D | Configured.cxx | 31 CreateConfiguredStorageUri(EventLoop &event_loop, const char *uri) in CreateConfiguredStorageUri() argument 33 auto storage = CreateStorageURI(event_loop, uri); in CreateConfiguredStorageUri() 63 CreateConfiguredStorage(const ConfigData &config, EventLoop &event_loop) in CreateConfiguredStorage() argument 67 return CreateConfiguredStorageUri(event_loop, uri); in CreateConfiguredStorage()
|
/dports/audio/ncmpc/ncmpc-0.41/src/ |
H A D | AsyncUserInput.cxx | 81 AsyncUserInput::AsyncUserInput(EventLoop &event_loop, WINDOW &_w) noexcept in AsyncUserInput() argument 82 :socket_event(event_loop, BIND_THIS_METHOD(OnSocketReady), in AsyncUserInput() 90 keyboard_unread(EventLoop &event_loop, int key) in keyboard_unread() argument 97 do_input_event(event_loop, cmd); in keyboard_unread()
|
/dports/devel/aws-c-io/aws-c-io-0.10.12/tests/vcc/ |
H A D | process_task_pre_queue.c | 27 static void s_process_task_pre_queue(struct aws_event_loop *event_loop _(ghost \claim(c_event_loop)… in s_process_task_pre_queue() 28 _(assert \always_by_claim(c_event_loop, event_loop)) in s_process_task_pre_queue() 29 struct epoll_loop *epoll_loop = event_loop->impl_data; in s_process_task_pre_queue() 36 … AWS_LOGF_TRACE(AWS_LS_IO_EVENT_LOOP, "id=%p: processing cross-thread tasks", (void *)event_loop); in s_process_task_pre_queue() 76 (void *)event_loop, in s_process_task_pre_queue()
|