Home
last modified time | relevance | path

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

12345

/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/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()
Dplatform_handle_dispatcher_unittest.cc40 scoped_refptr<PlatformHandleDispatcher> dispatcher = in TEST() local
76 scoped_refptr<PlatformHandleDispatcher> dispatcher = in TEST() local
/external/kotlinx.coroutines/kotlinx-coroutines-test/test/
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.kt12 val dispatcher = TestCoroutineDispatcher() in testAdvanceTimeBy_progressesOnEachDelay() constant
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/
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.rx2.FlowableContextTest
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/
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/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
DRunInterruptibleStressTest.kt19 val dispatcher = ExecutorRule(4) 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-test/src/
DTestBuilders.kt46 val (safeContext, dispatcher) = context.checkArguments() in runBlockingTest() constant
84 val dispatcher = get(ContinuationInterceptor).run { in runBlockingTest() constant
/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/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/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/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/test/
DFluxContextTest.kt16 private val dispatcher = newSingleThreadContext("FluxContextTest") constant in kotlinx.coroutines.reactor.FluxContextTest
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/scheduling/
DSharingWorkerClassTest.kt16 val dispatcher = ExperimentalCoroutineDispatcher(1, schedulerName = "first") in <lambda>() constant
/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/reactive/kotlinx-coroutines-reactive/test/
DReactiveStreamTckTest.kt26 private val dispatcher: Dispatcher constant in kotlinx.coroutines.reactive.ReactiveStreamTckTest.ReactiveStreamTckTestSuite
48 enum class Dispatcher(val dispatcher: CoroutineDispatcher) { constant in kotlinx.coroutines.reactive.Dispatcher
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/
DCoroutineDispatcherOperatorFunInvokeTest.kt63 val dispatcher = coroutineContext[ContinuationInterceptor] as CoroutineDispatcher in String() constant
/external/kotlinx.coroutines/kotlinx-coroutines-core/js/src/
DWindow.kt36 private val dispatcher = window.asCoroutineDispatcher() constant in kotlinx.coroutines.WindowAnimationQueue

12345