| /external/cronet/tot/net/third_party/quiche/src/quiche/quic/test_tools/ |
| D | quic_dispatcher_peer.cc | 20 QuicDispatcher* dispatcher) { in GetTimeWaitListManager()
26 QuicDispatcher* dispatcher, in SetTimeWaitListManager()
32 void QuicDispatcherPeer::UseWriter(QuicDispatcher* dispatcher, in UseWriter()
39 QuicPacketWriter* QuicDispatcherPeer::GetWriter(QuicDispatcher* dispatcher) { in GetWriter()
45 QuicDispatcher* dispatcher) { in GetCache()
51 QuicDispatcher* dispatcher) { in GetHelper()
57 QuicDispatcher* dispatcher) { in GetAlarmFactory()
63 QuicDispatcher* dispatcher) { in GetWriteBlockedList()
69 QuicDispatcher* dispatcher) { in GetAndClearLastError()
77 QuicDispatcher* dispatcher) { in GetBufferedPackets()
[all …]
|
| /external/cronet/stable/net/third_party/quiche/src/quiche/quic/test_tools/ |
| D | quic_dispatcher_peer.cc | 20 QuicDispatcher* dispatcher) { in GetTimeWaitListManager()
26 QuicDispatcher* dispatcher, in SetTimeWaitListManager()
32 void QuicDispatcherPeer::UseWriter(QuicDispatcher* dispatcher, in UseWriter()
39 QuicPacketWriter* QuicDispatcherPeer::GetWriter(QuicDispatcher* dispatcher) { in GetWriter()
45 QuicDispatcher* dispatcher) { in GetCache()
51 QuicDispatcher* dispatcher) { in GetHelper()
57 QuicDispatcher* dispatcher) { in GetAlarmFactory()
63 QuicDispatcher* dispatcher) { in GetWriteBlockedList()
69 QuicDispatcher* dispatcher) { in GetAndClearLastError()
77 QuicDispatcher* dispatcher) { in GetBufferedPackets()
[all …]
|
| /external/pigweed/pw_async/ |
| D | fake_dispatcher_test.cc | 61 FakeDispatcher dispatcher; in TEST() local
69 FakeDispatcher dispatcher; in TEST() local
78 FakeDispatcher dispatcher; in TEST() local
88 FakeDispatcher dispatcher; in TEST() local
100 FakeDispatcher dispatcher; in TEST() local
113 FakeDispatcher dispatcher; in TEST() local
127 FakeDispatcher dispatcher; in TEST() local
137 FakeDispatcher dispatcher; in TEST() local
147 FakeDispatcher dispatcher; in TEST() local
157 FakeDispatcher dispatcher; in TEST() local
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | ExecutorsTest.kt | 49 val dispatcher: CoroutineDispatcher = executor.asCoroutineDispatcher() in <lambda>() constant
67 val dispatcher = object : CoroutineDispatcher() { in <lambda>() constant
84 val dispatcher = object : CoroutineDispatcher() { in <lambda>() constant
115 val dispatcher = executorService.asCoroutineDispatcher() in <lambda>() constant
127 val dispatcher = newSingleThreadContext("Ctx") in <lambda>() constant
146 val dispatcher = object : CoroutineDispatcher() { in <lambda>() constant
173 val dispatcher = object : CoroutineDispatcher() { in <lambda>() constant
|
| /external/pigweed/pw_async2/ |
| D | dispatcher_test.cc | 55 Dispatcher dispatcher; in TEST() local
67 Dispatcher dispatcher; in TEST() local
77 Dispatcher dispatcher; in TEST() local
96 Dispatcher dispatcher; in TEST() local
139 Dispatcher dispatcher; in TEST() local
154 Dispatcher dispatcher; in TEST() local
161 Dispatcher dispatcher; in TEST() local
168 Dispatcher dispatcher; in TEST() local
190 Dispatcher dispatcher; in TEST() local
200 Dispatcher dispatcher; in TEST() local
[all …]
|
| D | once_sender_test.cc | 89 Dispatcher dispatcher; in TEST() local
103 Dispatcher dispatcher; in TEST() local
117 Dispatcher dispatcher; in TEST() local
132 Dispatcher dispatcher; in TEST() local
147 Dispatcher dispatcher; in TEST() local
201 Dispatcher dispatcher; in TEST() local
214 Dispatcher dispatcher; in TEST() local
227 Dispatcher dispatcher; in TEST() local
245 Dispatcher dispatcher; in TEST() local
287 Dispatcher dispatcher; in TEST() local
[all …]
|
| D | simulated_time_provider_test.cc | 82 Dispatcher dispatcher; in TEST() local
93 Dispatcher dispatcher; in TEST() local
125 Dispatcher dispatcher; in TEST() local
142 Dispatcher dispatcher; in TEST() local
157 Dispatcher dispatcher; in TEST() local
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/ |
| D | SchedulerStressTest.kt | 20 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
27 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
59 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
66 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
|
| D | SchedulerTest.kt | 57 newFixedThreadPoolContext(nThreads, "test").use { dispatcher -> in <lambda>() method
185 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
331 val dispatcher = originalScheduler.asCoroutineDispatcher() in <lambda>() constant
340 val dispatcher = scheduler.asCoroutineDispatcher() in <lambda>() constant
346 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
353 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
374 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
381 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
473 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
|
| D | LeakedExceptionTest.kt | 22 withFixedThreadPool(4) { dispatcher -> in <lambda>() method
36 withFixedThreadPool(4) { dispatcher -> in <lambda>() method
52 withFixedThreadPool(4) { dispatcher -> in <lambda>() method
77 withFixedThreadPool(4) { dispatcher -> in <lambda>() method
97 val dispatcher = pool.asCoroutineDispatcher() in <lambda>() constant
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/ |
| D | SchedulerStressTest.kt | 20 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
27 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
59 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
66 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
|
| D | SchedulerTest.kt | 57 newFixedThreadPoolContext(nThreads, "test").use { dispatcher -> in <lambda>() method
185 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
331 val dispatcher = originalScheduler.asCoroutineDispatcher() in <lambda>() constant
340 val dispatcher = scheduler.asCoroutineDispatcher() in <lambda>() constant
346 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
353 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
374 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
381 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
473 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
|
| D | LeakedExceptionTest.kt | 22 withFixedThreadPool(4) { dispatcher -> in <lambda>() method
36 withFixedThreadPool(4) { dispatcher -> in <lambda>() method
52 withFixedThreadPool(4) { dispatcher -> in <lambda>() method
77 withFixedThreadPool(4) { dispatcher -> in <lambda>() method
97 val dispatcher = pool.asCoroutineDispatcher() in <lambda>() constant
|
| /external/pigweed/pw_async_fuchsia/public/pw_async_fuchsia/ |
| D | dispatcher.h | 31 inline void PostAt(pw::async::Dispatcher* dispatcher, in PostAt()
43 inline void PostAfter(pw::async::Dispatcher* dispatcher, in PostAfter()
49 inline void Post(pw::async::Dispatcher* dispatcher, in Post()
56 explicit FuchsiaDispatcher(async_dispatcher_t* dispatcher) in FuchsiaDispatcher()
|
| /external/libchrome/mojo/core/ |
| D | handle_table.cc | 51 MojoHandle HandleTable::AddDispatcher(scoped_refptr<Dispatcher> dispatcher) { in AddDispatcher()
105 scoped_refptr<Dispatcher>* dispatcher) { in GetAndRemoveDispatcher()
142 for (const auto& dispatcher : dispatchers) { in CompleteTransitAndClose() local
152 for (const auto& dispatcher : dispatchers) { in CancelTransit() local
202 HandleTable::Entry::Entry(scoped_refptr<Dispatcher> dispatcher) in Entry()
|
| D | core.cc | 166 scoped_refptr<Dispatcher> dispatcher; in GetAndRemoveDispatcher() local
228 MojoHandle Core::AddDispatcher(scoped_refptr<Dispatcher> dispatcher) { in AddDispatcher()
293 scoped_refptr<Dispatcher> dispatcher; in Close() local
308 scoped_refptr<Dispatcher> dispatcher = GetDispatcher(handle); in QueryHandleSignalsState() local
344 scoped_refptr<Dispatcher> dispatcher = GetDispatcher(handle); in AddTrigger() local
569 auto dispatcher = GetDispatcher(message_pipe_handle); in WriteMessage() local
579 auto dispatcher = GetDispatcher(message_pipe_handle); in ReadMessage() local
744 scoped_refptr<Dispatcher> dispatcher( in WriteData() local
770 scoped_refptr<Dispatcher> dispatcher( in BeginWriteData() local
787 scoped_refptr<Dispatcher> dispatcher( in EndWriteData() local
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/selects/ |
| D | SelectOld.kt | 127 val dispatcher = context[CoroutineDispatcher] in resumeUndispatched() constant
137 val dispatcher = context[CoroutineDispatcher] in CancellableContinuation() constant
|
| /external/pigweed/pw_channel/ |
| D | loopback_channel_test.cc | 74 Dispatcher dispatcher; in TEST() local
94 Dispatcher dispatcher; in TEST() local
114 Dispatcher dispatcher; in TEST() local
134 Dispatcher dispatcher; in TEST() local
|
| D | epoll_channel_test.cc | 128 Dispatcher dispatcher; in TEST_F() local
163 Dispatcher dispatcher; in TEST_F() local
240 Dispatcher dispatcher; in TEST_F() local
266 Dispatcher dispatcher; in TEST_F() local
286 Dispatcher dispatcher; in TEST_F() local
306 Dispatcher dispatcher; in TEST_F() local
321 Dispatcher dispatcher; in TEST_F() local
|
| D | forwarding_channel_test.cc | 90 pw::async2::Dispatcher dispatcher; in TEST() local
146 pw::async2::Dispatcher dispatcher; in TEST() local
193 pw::async2::Dispatcher dispatcher; in TEST() local
277 pw::async2::Dispatcher dispatcher; in TEST() local
313 pw::async2::Dispatcher dispatcher; in TEST() local
401 pw::async2::Dispatcher dispatcher; in TEST() local
412 pw::async2::Dispatcher dispatcher; in TEST() local
497 pw::async2::Dispatcher dispatcher; in TEST() local
|
| /external/pigweed/pw_async_basic/ |
| D | dispatcher_test.cc | 42 BasicDispatcher dispatcher; in TEST() local
71 BasicDispatcher dispatcher; in TEST() local
102 BasicDispatcher dispatcher; in TEST() local
133 BasicDispatcher dispatcher; in TEST() local
159 BasicDispatcher dispatcher; in TEST() local
187 BasicDispatcher dispatcher; in TEST() local
204 BasicDispatcher dispatcher; in TEST() local
222 BasicDispatcher dispatcher; in TEST() local
270 BasicDispatcherExecuteTask dispatcher(tasks, OkStatus()); in TEST() local
296 BasicDispatcherExecuteTask dispatcher(tasks, Status::Cancelled()); in TEST() local
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/concurrent/test/ |
| D | DefaultDispatchersConcurrencyTest.kt | 4 override val dispatcher: CoroutineDispatcher = Dispatchers.Default constant in kotlinx.coroutines.DefaultDispatcherConcurrencyTest
8 override val dispatcher: CoroutineDispatcher = Dispatchers.IO constant in kotlinx.coroutines.IoDispatcherConcurrencyTest
|
| /external/pytorch/aten/src/ATen/core/dispatch/ |
| D | OperatorEntry.cpp | 105 const c10::Dispatcher& dispatcher, in registerKernel()
185 const c10::Dispatcher& dispatcher, in registerKernel()
206 void OperatorEntry::updateFallback(const c10::Dispatcher& dispatcher, DispatchKey dispatch_key) { in registerKernel()
210 const KernelFunction& OperatorEntry::computeDispatchTableEntry(const c10::Dispatcher& dispatcher, D… in registerKernel() argument
263 …st char*> OperatorEntry::computeDispatchTableEntryWithDebug(const c10::Dispatcher& dispatcher, Dis… in registerKernel() argument
390 void OperatorEntry::updateDispatchTableEntry_(const c10::Dispatcher& dispatcher, DispatchKey dispat… in registerKernel()
404 void OperatorEntry::updateDispatchTable_(const c10::Dispatcher& dispatcher, DispatchKey dispatch_ke… in registerKernel()
443 void OperatorEntry::updateDispatchTableFull_(const c10::Dispatcher& dispatcher) { in registerKernel()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/native/test/ |
| D | MultithreadedDispatchersTest.kt | 44 val dispatcher = newFixedThreadPoolContext(64, "test") in testNotAllocatingExtraDispatchers() constant
69 val dispatcher = WorkerDispatcher("test") in <lambda>() constant
|
| /external/pigweed/pw_bluetooth_sapphire/fuchsia/bt_host/ |
| D | host.cc | 32 BtHostComponent::BtHostComponent(async_dispatcher_t* dispatcher, in BtHostComponent()
53 async_dispatcher_t* dispatcher, const std::string& device_path) { in Create()
61 async_dispatcher_t* dispatcher, const std::string& device_path) { in CreateForTesting()
|