| /external/python/pyee/tests/ |
| D | test_async.py | 24 async def test_asyncio_emit(event_loop): argument
29 ee = AsyncIOEventEmitter(loop=event_loop)
31 should_call = Future(loop=event_loop)
45 async def test_asyncio_once_emit(event_loop): argument
50 ee = AsyncIOEventEmitter(loop=event_loop)
52 should_call = Future(loop=event_loop)
66 async def test_asyncio_error(event_loop): argument
70 ee = AsyncIOEventEmitter(loop=event_loop)
72 should_call = Future(loop=event_loop)
90 async def test_asyncio_cancellation(event_loop): argument
[all …]
|
| /external/cronet/net/third_party/quiche/src/quiche/quic/tools/ |
| D | quic_default_client.cc | 20 QuicEventLoop* event_loop, std::unique_ptr<ProofVerifier> proof_verifier) in QuicDefaultClient() argument
23 event_loop, in QuicDefaultClient()
24 std::make_unique<QuicClientDefaultNetworkHelper>(event_loop, this), in QuicDefaultClient()
30 QuicEventLoop* event_loop, std::unique_ptr<ProofVerifier> proof_verifier, in QuicDefaultClient() argument
34 event_loop, in QuicDefaultClient()
35 std::make_unique<QuicClientDefaultNetworkHelper>(event_loop, this), in QuicDefaultClient()
41 QuicEventLoop* event_loop, std::unique_ptr<ProofVerifier> proof_verifier, in QuicDefaultClient() argument
44 server_address, server_id, supported_versions, config, event_loop, in QuicDefaultClient()
45 std::make_unique<QuicClientDefaultNetworkHelper>(event_loop, this), in QuicDefaultClient()
51 QuicEventLoop* event_loop, in QuicDefaultClient() argument
[all …]
|
| D | quic_default_client.h | 34 QuicEventLoop* event_loop,
39 QuicEventLoop* event_loop,
45 const QuicConfig& config, QuicEventLoop* event_loop,
52 QuicEventLoop* event_loop,
58 const QuicConfig& config, QuicEventLoop* event_loop,
64 const QuicConfig& config, QuicEventLoop* event_loop,
|
| D | quic_client_default_network_helper.h | 31 QuicClientDefaultNetworkHelper(QuicEventLoop* event_loop,
41 void OnSocketEvent(QuicEventLoop* event_loop, QuicUdpSocketFd fd,
60 QuicEventLoop* event_loop() { return event_loop_; } in event_loop() function
|
| D | quic_client_default_network_helper.cc | 25 explicit LevelTriggeredPacketWriter(int fd, QuicEventLoop* event_loop) in LevelTriggeredPacketWriter() argument
26 : QuicDefaultPacketWriter(fd), event_loop_(event_loop) { in LevelTriggeredPacketWriter()
27 QUICHE_DCHECK(!event_loop->SupportsEdgeTriggered()); in LevelTriggeredPacketWriter()
50 QuicEventLoop* event_loop, QuicClientBase* client) in QuicClientDefaultNetworkHelper() argument
51 : event_loop_(event_loop), in QuicClientDefaultNetworkHelper()
|
| /external/python/pybind11/tests/ |
| D | test_async.py | 9 def event_loop(): function
19 def test_await(event_loop): argument
20 assert 5 == event_loop.run_until_complete(get_await_result(m.SupportsAsync()))
23 def test_await_missing(event_loop): argument
25 event_loop.run_until_complete(get_await_result(m.DoesNotSupportAsync()))
|
| /external/crosvm/devices/src/usb/host_backend/ |
| D | host_backend_device_provider.rs | 65 event_loop: Arc<EventLoop>, in start_helper()
71 AsyncJobQueue::init(&event_loop).map_err(Error::StartAsyncJobQueue)?; in start_helper()
75 event_loop.clone(), in start_helper()
80 event_loop in start_helper()
106 event_loop: Arc<EventLoop>, in start()
109 self.start_helper(fail_handle, event_loop, hub) in start()
131 event_loop: Arc<EventLoop>, field
148 event_loop: Arc<EventLoop>, in new()
155 event_loop, in new()
179 if let Err(e) = self.event_loop.add_event( in handle_attach_device()
[all …]
|
| /external/cronet/net/third_party/quiche/src/quiche/quic/qbone/ |
| D | qbone_client.cc | 18 QuicEventLoop* event_loop, QboneClient* client) { in CreateNetworkHelper() argument
20 std::make_unique<QuicClientDefaultNetworkHelper>(event_loop, client); in CreateNetworkHelper()
30 const QuicConfig& config, QuicEventLoop* event_loop, in QboneClient() argument
36 event_loop->CreateAlarmFactory().release(), in QboneClient()
37 CreateNetworkHelper(event_loop, this), in QboneClient()
|
| D | qbone_client_test.cc | 147 event_loop()->CreateAlarmFactory(), &writer_, in CreateQuicDispatcher()
162 QuicEventLoop* event_loop, in QboneTestClient() argument
165 /*session_owner=*/nullptr, QuicConfig(), event_loop, in QboneTestClient()
219 std::unique_ptr<QuicEventLoop> event_loop = in TEST_P() local
224 ParsedQuicVersionVector{GetParam()}, event_loop.get(), in TEST_P()
|
| /external/python/portpicker/src/ |
| D | portserver.py | 370 event_loop = asyncio.get_event_loop()
376 event_loop.call_later(0.5, listen_for_signal)
378 event_loop.call_later(0.5, listen_for_signal)
384 event_loop.add_signal_handler(
387 old_py_loop = {'loop': event_loop} if sys.version_info < (3, 10) else {}
395 server = event_loop.run_until_complete(coro)
398 event_loop.run_forever()
406 event_loop.run_until_complete(server.wait_closed())
407 event_loop.remove_signal_handler(signal.SIGUSR1) # pylint: disable=no-member
409 event_loop.close()
|
| /external/cronet/net/third_party/quiche/src/quiche/quic/masque/ |
| D | masque_client_bin.cc | 65 MasqueTunSession(QuicEventLoop* event_loop, MasqueClientSession* session) in MasqueTunSession() argument
66 : event_loop_(event_loop), session_(session) {} in MasqueTunSession()
164 std::unique_ptr<QuicEventLoop> event_loop = in RunMasqueClient() local
219 uri_template, masque_mode, event_loop.get(), std::move(proof_verifier)); in RunMasqueClient()
229 MasqueTunSession tun_session(event_loop.get(), in RunMasqueClient()
234 event_loop->RunEventLoopOnce(QuicTime::Delta::FromMilliseconds(50)); in RunMasqueClient()
244 masque_client.get(), event_loop.get(), urls[i], in RunMasqueClient()
|
| D | masque_client.cc | 19 MasqueMode masque_mode, QuicEventLoop* event_loop, in MasqueClient() argument
23 event_loop, std::move(proof_verifier)), in MasqueClient()
53 QuicEventLoop* event_loop, std::unique_ptr<ProofVerifier> proof_verifier) { in Create() argument
68 new MasqueClient(addr, server_id, masque_mode, event_loop, in Create()
|
| D | masque_encapsulated_client.cc | 217 MasqueClientDefaultNetworkHelper(QuicEventLoop* event_loop, in MasqueClientDefaultNetworkHelper() argument
219 : QuicClientDefaultNetworkHelper(event_loop, client), client_(client) {} in MasqueClientDefaultNetworkHelper()
232 QuicEventLoop* event_loop, std::unique_ptr<ProofVerifier> proof_verifier, in MasqueEncapsulatedClient() argument
236 MasqueEncapsulatedConfig(), event_loop, in MasqueEncapsulatedClient()
237 std::make_unique<MasqueClientDefaultNetworkHelper>(event_loop, this), in MasqueEncapsulatedClient()
|
| D | masque_server.cc | 25 event_loop(), std::make_unique<QuicDefaultConnectionHelper>(), in CreateQuicDispatcher()
27 event_loop()->CreateAlarmFactory(), masque_server_backend_, in CreateQuicDispatcher()
|
| D | masque_server_session.h | 29 QuicEventLoop* event_loop, QuicCryptoServerStreamBase::Helper* helper,
52 void OnSocketEvent(QuicEventLoop* event_loop, QuicUdpSocketFd fd,
55 QuicEventLoop* event_loop() const { return event_loop_; } in event_loop() function
|
| D | masque_client.h | 25 QuicEventLoop* event_loop, std::unique_ptr<ProofVerifier> proof_verifier);
46 MasqueMode masque_mode, QuicEventLoop* event_loop,
|
| /external/cronet/net/third_party/quiche/src/quiche/quic/bindings/ |
| D | quic_libevent_test.cc | 50 LibeventQuicEventLoop* event_loop = in TEST() local
53 event_loop->CreateAlarmFactory(); in TEST()
60 LoopBreakThread thread(event_loop); in TEST()
62 event_loop->RunEventLoopOnce(QuicTime::Delta::FromSeconds(5 * 60)); in TEST()
|
| /external/cronet/net/third_party/quiche/src/quiche/quic/qbone/bonnet/ |
| D | icmp_reachable.cc | 34 QuicEventLoop* event_loop, StatsInterface* stats) in IcmpReachable() argument
36 event_loop_(event_loop), in IcmpReachable()
37 clock_(event_loop->GetClock()), in IcmpReachable()
38 alarm_factory_(event_loop->CreateAlarmFactory()), in IcmpReachable()
198 void IcmpReachable::EpollCallback::OnSocketEvent(QuicEventLoop* event_loop, in OnSocketEvent() argument
204 event_loop->ArtificiallyNotifyEvent(fd, kSocketEventReadable); in OnSocketEvent()
|
| /external/crosvm/devices/src/usb/xhci/ |
| D | xhci.rs | 77 event_loop: Arc<EventLoop>, field
97 let (event_loop, join_handle) = in new()
105 let event_loop = Arc::new(event_loop); in new() localVariable
111 IntrResampleHandler::start(&event_loop, interrupter.clone(), irq_resample_evt) in new()
117 .start(fail_handle.clone(), event_loop.clone(), hub.clone()) in new()
125 event_loop.clone(), in new()
130 event_loop.clone(), in new()
143 event_loop, in new()
412 self.event_loop.stop(); in drop()
|
| D | ring_buffer_controller.rs | 83 event_loop: Arc<EventLoop>, field
101 event_loop: Arc<EventLoop>, in new_with_handler()
111 event_loop: event_loop.clone(), in new_with_handler()
115 event_loop in new_with_handler()
178 if let Err(e) = self.event_loop.remove_event_for_descriptor(&self.event) { in drop()
|
| D | intr_resample_handler.rs | 26 event_loop: &EventLoop, in start()
35 if let Err(e) = event_loop.add_event( in start()
|
| /external/crosvm/devices/src/utils/ |
| D | mod.rs | 7 mod event_loop; module
11 pub use self::event_loop::*;
|
| /external/cronet/net/third_party/quiche/src/quiche/quic/test_tools/ |
| D | quic_test_client.h | 38 QuicEventLoop* event_loop);
43 QuicEventLoop* event_loop);
48 QuicEventLoop* event_loop,
54 QuicEventLoop* event_loop,
110 std::unique_ptr<QuicEventLoop> event_loop);
290 QuicEventLoop* event_loop() { return event_loop_.get(); } in event_loop() function
|
| D | quic_test_client.cc | 192 QuicEventLoop* event_loop) in MockableQuicClient() argument
194 supported_versions, event_loop) {} in MockableQuicClient()
199 QuicEventLoop* event_loop) in MockableQuicClient() argument
201 event_loop, nullptr) {} in MockableQuicClient()
206 QuicEventLoop* event_loop, std::unique_ptr<ProofVerifier> proof_verifier) in MockableQuicClient() argument
208 event_loop, std::move(proof_verifier), nullptr) {} in MockableQuicClient()
213 QuicEventLoop* event_loop, std::unique_ptr<ProofVerifier> proof_verifier, in MockableQuicClient() argument
216 server_address, server_id, supported_versions, config, event_loop, in MockableQuicClient()
217 std::make_unique<MockableQuicClientDefaultNetworkHelper>(event_loop, in MockableQuicClient()
331 std::unique_ptr<QuicEventLoop> event_loop) in QuicTestClient() argument
[all …]
|
| /external/cronet/net/third_party/quiche/src/quiche/quic/core/io/ |
| D | event_loop_socket_factory.cc | 21 QuicEventLoop* event_loop, quiche::QuicheBufferAllocator* buffer_allocator) in EventLoopSocketFactory() argument
22 : event_loop_(event_loop), buffer_allocator_(buffer_allocator) { in EventLoopSocketFactory()
|