Home
last modified time | relevance | path

Searched refs:event_loop (Results 226 – 250 of 1817) sorted by relevance

12345678910>>...73

/dports/x11/alacritty/alacritty-0.9.0/cargo-crates/winit-0.24.0/examples/
H A Drequest_redraw_threaded.rs6 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 Dhandling_close.rs4 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 Dtimer.rs7 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 Dset_ime_position.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()
20 event_loop.run(move |event, _, control_flow| { in main()
H A Dresizable.rs5 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 Dwindow_run_return.rs17 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 Dssl_util.c64 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 Dtest_proactive_fetcher.py32 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 Dmain_loop.py108 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 Dtimer.rs5 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 Dresizable.rs4 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 Dhandling_close.rs3 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 Dwindow_run_return.rs15 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 DREADME.rst55 ``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 DREADME.rst55 ``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 DREADME.rst55 ``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 DWatch.hxx67 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 DUpnpNeighborPlugin.cxx54 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 Dasyncio_socket_server.py73 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 Dsession.rs43 '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 Dmod.rs19 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 DMain.cxx187 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 DConfigured.cxx31 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 DAsyncUserInput.cxx81 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 Dprocess_task_pre_queue.c27 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()

12345678910>>...73