Home
last modified time | relevance | path

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

123456

/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-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
DFlowableContextTest.kt16 private val dispatcher = newSingleThreadContext("FlowableContextTest") constant
/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
DFlowableContextTest.kt16 private val dispatcher = newSingleThreadContext("FlowableContextTest") constant in kotlinx.coroutines.rx3.FlowableContextTest
/external/libchrome/mojo/core/
Dhandle_table.cc51 MojoHandle HandleTable::AddDispatcher(scoped_refptr<Dispatcher> dispatcher) { in AddDispatcher()
99 scoped_refptr<Dispatcher>* dispatcher) { in GetAndRemoveDispatcher()
136 for (const auto& dispatcher : dispatchers) { in CompleteTransitAndClose() local
146 for (const auto& dispatcher : dispatchers) { in CancelTransit() local
196 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
Dwatcher_dispatcher.cc21 void WatcherDispatcher::NotifyHandleState(Dispatcher* dispatcher, in NotifyHandleState()
40 void WatcherDispatcher::NotifyHandleClosed(Dispatcher* dispatcher) { in NotifyHandleClosed()
120 scoped_refptr<Dispatcher> dispatcher, in WatchDispatcher()
/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/jvm/test/
DExecutorsTest.kt52 val dispatcher: CoroutineDispatcher = executor.asCoroutineDispatcher() in <lambda>() constant
70 val dispatcher = object : CoroutineDispatcher() { in <lambda>() constant
102 val dispatcher = executorService.asCoroutineDispatcher() 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
/external/skia/experimental/graphite/src/
DDrawWriter.cpp15 DrawWriter::DrawWriter(DrawDispatcher* dispatcher, DrawBufferManager* bufferManager) in DrawWriter()
18 DrawWriter::DrawWriter(DrawDispatcher* dispatcher, in DrawWriter()
/external/guice/extensions/servlet/test/com/google/inject/servlet/
DServletPipelineRequestDispatcherTest.java110 final RequestDispatcher dispatcher = in testIncludeManagedServlet() local
177 final RequestDispatcher dispatcher = in testForwardToManagedServlet() local
247 final RequestDispatcher dispatcher = in forwardToManagedServletFailureOnCommittedBuffer() local
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/scheduling/
DSharingWorkerClassTest.kt16 val dispatcher = SchedulerCoroutineDispatcher(1, schedulerName = "first") in <lambda>() constant
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/test/
DFluxContextTest.kt16 private val dispatcher = newSingleThreadContext("FluxContextTest") constant

123456