Home
last modified time | relevance | path

Searched defs:dispatcher (Results 1 – 25 of 179) sorted by relevance

12345678

/external/cronet/net/third_party/quiche/src/quiche/quic/test_tools/
Dquic_dispatcher_peer.cc15 QuicDispatcher* dispatcher) { in GetTimeWaitListManager()
21 QuicDispatcher* dispatcher, in SetTimeWaitListManager()
27 void QuicDispatcherPeer::UseWriter(QuicDispatcher* dispatcher, in UseWriter()
34 QuicPacketWriter* QuicDispatcherPeer::GetWriter(QuicDispatcher* dispatcher) { in GetWriter()
40 QuicDispatcher* dispatcher) { in GetCache()
46 QuicDispatcher* dispatcher) { in GetHelper()
52 QuicDispatcher* dispatcher) { in GetAlarmFactory()
58 QuicDispatcher* dispatcher) { in GetWriteBlockedList()
64 QuicDispatcher* dispatcher) { in GetAndClearLastError()
72 QuicDispatcher* dispatcher) { in GetBufferedPackets()
[all …]
/external/fmtlib/include/fmt/
Dchrono.h293 struct dispatcher { in localtime() struct
294 std::time_t time_; in localtime()
295 std::tm tm_; in localtime()
297 dispatcher(std::time_t t) : time_(t) {} in localtime() function
299 bool run() { in localtime()
304 bool handle(std::tm* tm) { return tm != nullptr; } in localtime()
306 bool handle(detail::null<>) { in localtime()
311 bool fallback(int res) { return res == 0; } in localtime()
314 bool fallback(detail::null<>) { in localtime()
335 struct dispatcher { in gmtime() struct
[all …]
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/
DSchedulerStressTest.kt23 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
30 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
62 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
69 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
DSchedulerTest.kt60 newFixedThreadPoolContext(nThreads, "test").use { dispatcher -> in <lambda>() method
188 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
334 val dispatcher = originalScheduler.asCoroutineDispatcher() in <lambda>() constant
343 val dispatcher = scheduler.asCoroutineDispatcher() in <lambda>() constant
349 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
356 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
377 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
384 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
476 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
DLeakedExceptionTest.kt25 withFixedThreadPool(4) { dispatcher -> in <lambda>() method
39 withFixedThreadPool(4) { dispatcher -> in <lambda>() method
55 withFixedThreadPool(4) { dispatcher -> in <lambda>() method
80 withFixedThreadPool(4) { dispatcher -> in <lambda>() method
100 val dispatcher = pool.asCoroutineDispatcher() in <lambda>() constant
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/
DSchedulerStressTest.kt23 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
30 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
62 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
69 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
DSchedulerTest.kt60 newFixedThreadPoolContext(nThreads, "test").use { dispatcher -> in <lambda>() method
188 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
334 val dispatcher = originalScheduler.asCoroutineDispatcher() in <lambda>() constant
343 val dispatcher = scheduler.asCoroutineDispatcher() in <lambda>() constant
349 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
356 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
377 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
384 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
476 val dispatcher = currentDispatcher() as CoroutineDispatcher in <lambda>() constant
DLeakedExceptionTest.kt25 withFixedThreadPool(4) { dispatcher -> in <lambda>() method
39 withFixedThreadPool(4) { dispatcher -> in <lambda>() method
55 withFixedThreadPool(4) { dispatcher -> in <lambda>() method
80 withFixedThreadPool(4) { dispatcher -> in <lambda>() method
100 val dispatcher = pool.asCoroutineDispatcher() in <lambda>() constant
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/
DExecutorsTest.kt52 val dispatcher: CoroutineDispatcher = executor.asCoroutineDispatcher() in <lambda>() constant
70 val dispatcher = object : CoroutineDispatcher() { in <lambda>() constant
87 val dispatcher = object : CoroutineDispatcher() { in <lambda>() constant
118 val dispatcher = executorService.asCoroutineDispatcher() in <lambda>() constant
/external/libchrome/mojo/core/
Dhandle_table.cc51 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()
Dcore.cc166 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 …]
Dshared_buffer_dispatcher_unittest.cc112 scoped_refptr<SharedBufferDispatcher> dispatcher; in TEST_F() local
147 scoped_refptr<SharedBufferDispatcher> dispatcher; in TEST_F() local
298 scoped_refptr<SharedBufferDispatcher> dispatcher; in TEST_F() local
314 scoped_refptr<SharedBufferDispatcher> dispatcher; in TEST_F() local
/external/kotlinx.coroutines/kotlinx-coroutines-test/jvm/test/migration/
DTestBuildersTest.kt24 val dispatcher = TestCoroutineDispatcher() in dispatcherRunBlocking_passesDispatcher() constant
47 val dispatcher = TestCoroutineDispatcher() in dispatcherRunBlocking_advancesPreviousDelay() constant
85 val dispatcher = TestCoroutineDispatcher() in whenInAsync_runBlocking_nestsProperly() constant
DTestCoroutineDispatcherOrderTest.kt16 val dispatcher = TestCoroutineDispatcher() in testAdvanceTimeBy_progressesOnEachDelay() constant
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/selects/
DSelectOld.kt131 val dispatcher = context[CoroutineDispatcher] in resumeUndispatched() constant
141 val dispatcher = context[CoroutineDispatcher] in CancellableContinuation() constant
/external/pigweed/pw_async_basic/
Ddispatcher_test.cc38 BasicDispatcher dispatcher; in TEST() local
74 BasicDispatcher dispatcher; in TEST() local
101 BasicDispatcher dispatcher; in TEST() local
127 BasicDispatcher dispatcher; in TEST() local
155 BasicDispatcher dispatcher; in TEST() local
172 BasicDispatcher dispatcher; in TEST() local
190 BasicDispatcher dispatcher; in TEST() local
/external/pigweed/pw_async/
Dfake_dispatcher_test.cc28 FakeDispatcher dispatcher; in TEST() local
68 FakeDispatcher dispatcher; in TEST() local
101 FakeDispatcher dispatcher; in TEST() local
132 FakeDispatcher dispatcher; in TEST() local
158 FakeDispatcher dispatcher; in TEST() local
189 FakeDispatcher dispatcher; in TEST() local
206 FakeDispatcher dispatcher; in TEST() local
/external/kotlinx.coroutines/kotlinx-coroutines-core/concurrent/test/
DDefaultDispatchersConcurrencyTest.kt7 override val dispatcher: CoroutineDispatcher = Dispatchers.Default constant in kotlinx.coroutines.DefaultDispatcherConcurrencyTest
11 override val dispatcher: CoroutineDispatcher = Dispatchers.IO constant in kotlinx.coroutines.IoDispatcherConcurrencyTest
DMultithreadedDispatcherStressTest.kt22 val dispatcher = newFixedThreadPoolContext(nThreads, "testMultiThreadedContext") in testClosingNotDroppingTasks() constant
/external/kotlinx.coroutines/kotlinx-coroutines-core/native/test/
DMultithreadedDispatchersTest.kt48 val dispatcher = newFixedThreadPoolContext(64, "test") in testNotAllocatingExtraDispatchers() constant
73 val dispatcher = WorkerDispatcher("test") in <lambda>() constant
/external/arm-trusted-firmware/docs/design/
Dinterrupt-framework-design.rst686 Interrupt entry
746 Interrupt exit
755 Test secure payload dispatcher Secure-EL1 interrupt handling
820 Test secure payload dispatcher non-secure interrupt handling
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/exceptions/
DStackTraceRecoveryResumeModeTest.kt45 val dispatcher = wrapperDispatcher() in <lambda>() constant
106 val dispatcher = wrapperDispatcher() in <lambda>() constant
/external/kotlinx.coroutines/kotlinx-coroutines-test/jvm/src/internal/
DTestMainDispatcherJvm.kt15 val dispatcher = secondBestFactory.tryCreateDispatcher(otherFactories) in createDispatcher() constant
/external/mockwebserver/src/test/java/com/google/mockwebserver/
DCustomDispatcherTest.java40 final Dispatcher dispatcher = new Dispatcher() { in testSimpleDispatch() local
63 final Dispatcher dispatcher = new Dispatcher() { in testOutOfOrderResponses() local
/external/okhttp/mockwebserver/src/test/java/com/squareup/okhttp/mockwebserver/
DCustomDispatcherTest.java40 final Dispatcher dispatcher = new Dispatcher() { in simpleDispatch() local
63 final Dispatcher dispatcher = new Dispatcher() { in outOfOrderResponses() local

12345678