| /external/libchrome/mojo/core/ |
| D | handle_table.cc | 51 MojoHandle HandleTable::AddDispatcher(scoped_refptr<Dispatcher> dispatcher) { in AddDispatcher() argument
58 handles_.insert(std::make_pair(handle, Entry(std::move(dispatcher)))); in AddDispatcher()
78 if (dispatchers[i].dispatcher) { in AddDispatchersFromTransit()
81 std::make_pair(handle, Entry(dispatchers[i].dispatcher))); in AddDispatchersFromTransit()
94 return it->second.dispatcher; in GetDispatcher()
99 scoped_refptr<Dispatcher>* dispatcher) { in GetAndRemoveDispatcher() argument
106 *dispatcher = std::move(it->second.dispatcher); in GetAndRemoveDispatcher()
125 d.dispatcher = it->second.dispatcher; in BeginTransit()
126 if (!d.dispatcher->BeginTransit()) in BeginTransit()
136 for (const auto& dispatcher : dispatchers) { in CompleteTransitAndClose() local
[all …]
|
| D | platform_handle_dispatcher_unittest.cc | 40 scoped_refptr<PlatformHandleDispatcher> dispatcher = in TEST() local
43 EXPECT_EQ(Dispatcher::Type::PLATFORM_HANDLE, dispatcher->GetType()); in TEST()
45 h = dispatcher->TakePlatformHandle(); in TEST()
59 auto internal_handle = dispatcher->TakePlatformHandle(); in TEST()
62 EXPECT_EQ(MOJO_RESULT_OK, dispatcher->Close()); in TEST()
76 scoped_refptr<PlatformHandleDispatcher> dispatcher = in TEST() local
83 EXPECT_TRUE(dispatcher->BeginTransit()); in TEST()
84 dispatcher->StartSerialize(&num_bytes, &num_ports, &num_handles); in TEST()
91 EXPECT_TRUE(dispatcher->EndSerialize(nullptr, nullptr, &received_handle)); in TEST()
93 dispatcher->CompleteTransitAndClose(); in TEST()
[all …]
|
| D | shared_buffer_dispatcher_unittest.cc | 112 scoped_refptr<SharedBufferDispatcher> dispatcher; in TEST_F() local
115 nullptr, 100, &dispatcher)); in TEST_F()
116 ASSERT_TRUE(dispatcher); in TEST_F()
117 EXPECT_EQ(Dispatcher::Type::SHARED_BUFFER, dispatcher->GetType()); in TEST_F()
121 EXPECT_EQ(MOJO_RESULT_OK, dispatcher->MapBuffer(0, 100, &mapping1)); in TEST_F()
129 EXPECT_EQ(MOJO_RESULT_OK, dispatcher->MapBuffer(50, 50, &mapping2)); in TEST_F()
135 EXPECT_EQ(MOJO_RESULT_OK, dispatcher->Close()); in TEST_F()
147 scoped_refptr<SharedBufferDispatcher> dispatcher; in TEST_F() local
152 &dispatcher)); in TEST_F()
153 ASSERT_TRUE(dispatcher); in TEST_F()
[all …]
|
| D | core.cc | 166 scoped_refptr<Dispatcher> dispatcher; in GetAndRemoveDispatcher() local
168 handles_->GetAndRemoveDispatcher(handle, &dispatcher); in GetAndRemoveDispatcher()
169 return dispatcher; in GetAndRemoveDispatcher()
228 MojoHandle Core::AddDispatcher(scoped_refptr<Dispatcher> dispatcher) { in AddDispatcher() argument
230 return handles_->AddDispatcher(dispatcher); in AddDispatcher()
244 if (d.dispatcher) in AddDispatchersFromTransit()
245 d.dispatcher->Close(); in AddDispatchersFromTransit()
293 scoped_refptr<Dispatcher> dispatcher; in Close() local
296 MojoResult rv = handles_->GetAndRemoveDispatcher(handle, &dispatcher); in Close()
300 dispatcher->Close(); in Close()
[all …]
|
| D | watcher_dispatcher.cc | 21 void WatcherDispatcher::NotifyHandleState(Dispatcher* dispatcher, in NotifyHandleState() argument
24 auto it = watched_handles_.find(dispatcher); in NotifyHandleState()
40 void WatcherDispatcher::NotifyHandleClosed(Dispatcher* dispatcher) { in NotifyHandleClosed() argument
44 auto it = watched_handles_.find(dispatcher); in NotifyHandleClosed()
112 entry.second->dispatcher()->RemoveWatcherRef(this, entry.first); in Close()
120 scoped_refptr<Dispatcher> dispatcher, in WatchDispatcher() argument
132 if (watches_.count(context) || watched_handles_.count(dispatcher.get())) in WatchDispatcher()
136 new Watch(this, dispatcher, context, signals, condition); in WatchDispatcher()
139 watched_handles_.insert(std::make_pair(dispatcher.get(), watch)); in WatchDispatcher()
143 MojoResult rv = dispatcher->AddWatcherRef(this, context); in WatchDispatcher()
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/scheduling/ |
| D | CoroutineDispatcherTest.kt | 23 withContext(dispatcher) { in <lambda>()
45 val outerJob = launch(dispatcher) { in <lambda>()
46 val d1 = launch(dispatcher) { expect(3) } in <lambda>()
47 val d2 = launch(dispatcher) { expect(4) } in <lambda>()
48 val d3 = launch(dispatcher) { expect(2) } in <lambda>()
60 val job = async(context = dispatcher) { in <lambda>()
84 withContext(dispatcher) { in <lambda>()
86 val job = async(dispatcher) { in <lambda>()
88 val innerJob = async(dispatcher) { in <lambda>()
104 withContext(dispatcher) { in <lambda>()
[all …]
|
| D | BlockingCoroutineDispatcherTest.kt | 21 val nonBlockingJob = launch(dispatcher) { in <lambda>()
36 launch(dispatcher) { in <lambda>()
68 val cpuTask = launch(dispatcher) { in <lambda>()
91 launch(dispatcher) { in <lambda>()
113 launch(dispatcher) { in <lambda>()
131 val task = async(dispatcher) { in <lambda>()
134 val nonBlocking = async(dispatcher) { in <lambda>()
160 val task = async(dispatcher) { in testBoundedBlockingFairness()
163 val nonBlocking = async(dispatcher) { in testBoundedBlockingFairness()
171 val secondNonBlocking = async(dispatcher) { in testBoundedBlockingFairness()
|
| D | CoroutineSchedulerStressTest.kt | 19 private var dispatcher: ExperimentalCoroutineDispatcher = ExperimentalCoroutineDispatcher() variable in kotlinx.coroutines.scheduling.CoroutineSchedulerStressTest
36 dispatcher.close() in tearDown()
48 stressTest(dispatcher) in testInternalTasksSubmission()
59 dispatcher.dispatch(EmptyCoroutineContext, Runnable { in testStealingFromBlocking()
66 dispatcher.dispatch(EmptyCoroutineContext, Runnable { in testStealingFromBlocking()
93 dispatcher.dispatch(EmptyCoroutineContext, Runnable { in stressTest()
|
| D | BlockingCoroutineDispatcherStressTest.kt | 54 val dispatcher = ExperimentalCoroutineDispatcher(CORES_COUNT) in <lambda>() constant
55 val blockingDispatcher = dispatcher.blocking(100) in <lambda>()
64 async(dispatcher) { in <lambda>()
71 cpuTasks += async(dispatcher) { cpuBarrier.await() } in <lambda>()
84 dispatcher.close() in <lambda>()
114 val cpuTasks = (1..CORES_COUNT).map { async(dispatcher) { while (true) delay(1) } } in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-test/test/ |
| D | TestCoroutineDispatcherOrderTest.kt | 12 val dispatcher = TestCoroutineDispatcher() in testAdvanceTimeBy_progressesOnEachDelay() constant
13 val scope = TestCoroutineScope(dispatcher) in testAdvanceTimeBy_progressesOnEachDelay()
19 assertEquals(1_000, dispatcher.currentTime) in testAdvanceTimeBy_progressesOnEachDelay()
22 assertEquals(1_500, dispatcher.currentTime) in testAdvanceTimeBy_progressesOnEachDelay()
25 assertEquals(2_001, dispatcher.currentTime) in testAdvanceTimeBy_progressesOnEachDelay()
29 assertEquals(0, dispatcher.currentTime) in testAdvanceTimeBy_progressesOnEachDelay()
30 dispatcher.advanceTimeBy(2_000) in testAdvanceTimeBy_progressesOnEachDelay()
32 assertEquals(2_000, dispatcher.currentTime) in testAdvanceTimeBy_progressesOnEachDelay()
33 dispatcher.advanceTimeBy(2) in testAdvanceTimeBy_progressesOnEachDelay()
35 assertEquals(2_002, dispatcher.currentTime) in testAdvanceTimeBy_progressesOnEachDelay()
|
| D | TestBuildersTest.kt | 24 val dispatcher = TestCoroutineDispatcher() in dispatcherRunBlocking_passesDispatcher() constant
25 dispatcher.runBlockingTest { in dispatcherRunBlocking_passesDispatcher()
26 assertSame(dispatcher, coroutineContext[ContinuationInterceptor]) in dispatcherRunBlocking_passesDispatcher()
47 val dispatcher = TestCoroutineDispatcher() in dispatcherRunBlocking_advancesPreviousDelay() constant
48 val scope = CoroutineScope(dispatcher) in dispatcherRunBlocking_advancesPreviousDelay()
54 dispatcher.runBlockingTest { in dispatcherRunBlocking_advancesPreviousDelay()
85 val dispatcher = TestCoroutineDispatcher() in whenInAsync_runBlocking_nestsProperly() constant
86 val scope = TestCoroutineScope(dispatcher) in whenInAsync_runBlocking_nestsProperly()
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
| D | DispatcherTest.java | 19 Dispatcher dispatcher = new Dispatcher(executor); field in DispatcherTest
20 OkHttpClient client = new OkHttpClient().setDispatcher(dispatcher);
23 dispatcher.setMaxRequests(20); in setUp()
24 dispatcher.setMaxRequestsPerHost(10); in setUp()
29 dispatcher.setMaxRequests(0); in maxRequestsZero()
37 dispatcher.setMaxRequestsPerHost(0); in maxPerHostZero()
49 dispatcher.setMaxRequests(3); in maxRequestsEnforced()
58 dispatcher.setMaxRequestsPerHost(2); in maxPerHostEnforced()
66 dispatcher.setMaxRequests(2); in increasingMaxRequestsPromotesJobsImmediately()
72 dispatcher.setMaxRequests(4); in increasingMaxRequestsPromotesJobsImmediately()
[all …]
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/ |
| D | ReactiveStreamTckTest.kt | 17 fun createTests(dispatcher: Dispatcher): Array<Any> { in createTests()
18 return arrayOf(ReactiveStreamTckTestSuite(dispatcher)) in createTests()
26 private val dispatcher: Dispatcher constant in kotlinx.coroutines.reactive.ReactiveStreamTckTest.ReactiveStreamTckTestSuite
30 publish(dispatcher.dispatcher) { in createPublisher()
35 publish(dispatcher.dispatcher) { in createFailedPublisher()
48 enum class Dispatcher(val dispatcher: CoroutineDispatcher) { constant in kotlinx.coroutines.reactive.Dispatcher
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/ |
| D | ParametrizedDispatcherBase.kt | 23 abstract var dispatcher: String variable in benchmarks.ParametrizedDispatcherBase
31 dispatcher == "fjp" -> ForkJoinPool.commonPool().asCoroutineDispatcher() in setup()
32 dispatcher == "experimental" -> { in setup()
35 dispatcher.startsWith("ftp") -> { in setup()
36 … newFixedThreadPoolContext(dispatcher.substring(4).toInt(), dispatcher).also { closeable = it } in setup()
38 else -> error("Unexpected dispatcher: $dispatcher") in setup()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | ExecutorsTest.kt | 48 val dispatcher: CoroutineDispatcher = executor.asCoroutineDispatcher() in <lambda>() constant
49 assertSame(executor, dispatcher.asExecutor()) in <lambda>()
66 val dispatcher = object : CoroutineDispatcher() { in <lambda>() constant
72 val executor = dispatcher.asExecutor() in <lambda>()
73 assertSame(dispatcher, executor.asCoroutineDispatcher()) in <lambda>()
98 val dispatcher = executorService.asCoroutineDispatcher() in <lambda>() constant
99 runBlocking (dispatcher) { in <lambda>()
102 dispatcher.close() in <lambda>()
|
| D | FailingCoroutinesMachineryTest.kt | 18 private val dispatcher: CoroutineDispatcher in <lambda>() constant in kotlinx.coroutines.FailingCoroutinesMachineryTest
78 runCatching { (dispatcher as? ExecutorCoroutineDispatcher)?.close() } in <lambda>()
96 dispatchers.map { dispatcher -> in <lambda>() method
97 arrayOf(element, dispatcher) in <lambda>()
105 launch(NonCancellable + dispatcher + exceptionHandler + element) {} in <lambda>()
111 launch(NonCancellable + dispatcher + exceptionHandler) { in <lambda>()
120 launch(element + dispatcher) { } in <lambda>()
|
| D | CancellableContinuationResumeCloseStressTest.kt | 14 private val dispatcher = in <lambda>() constant in kotlinx.coroutines.CancellableContinuationResumeCloseStressTest
25 dispatcher.close() in <lambda>()
48 private fun CoroutineScope.testJob(): Job = launch(dispatcher, start = CoroutineStart.ATOMIC) { in <lambda>()
55 dispatcher.executor.execute { in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | Dispatched.kt | 77 @JvmField val dispatcher: CoroutineDispatcher, constant in kotlinx.coroutines.DispatchedContinuation
101 if (dispatcher.isDispatchNeeded(context)) { in <lambda>()
104 dispatcher.dispatch(context, this) in <lambda>()
116 if (dispatcher.isDispatchNeeded(context)) { in <lambda>()
119 dispatcher.dispatch(context, this) in <lambda>()
133 if (dispatcher.isDispatchNeeded(context)) { in <lambda>()
136 dispatcher.dispatch(context, this) in <lambda>()
176 dispatcher.dispatchYield(context, this) in <lambda>()
180 "DispatchedContinuation[$dispatcher, ${continuation.toDebugString()}]" in <lambda>()
293 val dispatcher = delegate.dispatcher in dispatch() constant
[all …]
|
| /external/guava/android/guava-tests/test/com/google/common/eventbus/ |
| D | DispatcherTest.java | 58 private Dispatcher dispatcher; field in DispatcherTest
61 dispatcher = Dispatcher.perThreadDispatchQueue(); in testPerThreadQueuedDispatcher()
62 dispatcher.dispatch(1, integerSubscribers.iterator()); in testPerThreadQueuedDispatcher()
80 dispatcher = Dispatcher.legacyAsync(); in testLegacyAsyncDispatcher()
95 dispatcher.dispatch(2, integerSubscribers.iterator()); in testLegacyAsyncDispatcher()
111 dispatcher.dispatch("foo", stringSubscribers.iterator()); in testLegacyAsyncDispatcher()
126 dispatcher = Dispatcher.immediate(); in testImmediateDispatcher()
127 dispatcher.dispatch(1, integerSubscribers.iterator()); in testImmediateDispatcher()
155 dispatcher.dispatch("hello", stringSubscribers.iterator()); in handleInteger()
|
| /external/guava/guava-tests/test/com/google/common/eventbus/ |
| D | DispatcherTest.java | 58 private Dispatcher dispatcher; field in DispatcherTest
61 dispatcher = Dispatcher.perThreadDispatchQueue(); in testPerThreadQueuedDispatcher()
62 dispatcher.dispatch(1, integerSubscribers.iterator()); in testPerThreadQueuedDispatcher()
80 dispatcher = Dispatcher.legacyAsync(); in testLegacyAsyncDispatcher()
95 dispatcher.dispatch(2, integerSubscribers.iterator()); in testLegacyAsyncDispatcher()
111 dispatcher.dispatch("foo", stringSubscribers.iterator()); in testLegacyAsyncDispatcher()
126 dispatcher = Dispatcher.immediate(); in testImmediateDispatcher()
127 dispatcher.dispatch(1, integerSubscribers.iterator()); in testImmediateDispatcher()
155 dispatcher.dispatch("hello", stringSubscribers.iterator()); in handleInteger()
|
| /external/dexmaker/dexmaker-mockito-inline/src/main/resources/ |
| D | README.txt | 1 dispatcher.jar is the classes.dex of the apk created by dexmaker-mockito-inline-dispatcher
4 unzip dexmaker-mockito-inline-dispatcher/build/outputs/apk/release/dexmaker-mockito-inline
5 -dispatcher-release-unsigned.apk classes.dex
6 jar -cf dexmaker-mockito-inline/src/main/resources/dispatcher.jar classes.dex
|
| /external/kotlinx.coroutines/kotlinx-coroutines-test/src/ |
| D | TestBuilders.kt | 46 val (safeContext, dispatcher) = context.checkArguments() in runBlockingTest() constant
52 dispatcher.advanceUntilIdle() in runBlockingTest()
82 val dispatcher = get(ContinuationInterceptor).run { in runBlockingTest() constant
95 return Pair(this + dispatcher + exceptionHandler + job, dispatcher as DelayController) in runBlockingTest()
|
| /external/autotest/site_utils/rpm_control_system/ |
| D | rpm_dispatcher_unittest.py | 48 self.dispatcher = rpm_dispatcher.RPMDispatcher(FAKE_DISPATCHER_URI,
66 controller1 = self.dispatcher._get_rpm_controller(RPM_HOSTNAME)
67 controller2 = self.dispatcher._get_rpm_controller(RPM_HOSTNAME)
77 controller1 = self.dispatcher._get_rpm_controller(DUT_SAME_RPM1)
78 controller2 = self.dispatcher._get_rpm_controller(DUT_DIFFERENT_RPM)
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/ |
| D | Executors.kt | 45 (this as? DispatcherExecutor)?.dispatcher ?: ExecutorCoroutineDispatcherImpl(this) in close()
55 private class DispatcherExecutor(@JvmField val dispatcher: CoroutineDispatcher) : Executor { in close() constant in kotlinx.coroutines.DispatcherExecutor
56 override fun execute(block: Runnable) = dispatcher.dispatch(EmptyCoroutineContext, block) in close()
57 override fun toString(): String = dispatcher.toString() in close()
131 private val dispatcher: CoroutineDispatcher, in toString() constant in kotlinx.coroutines.ResumeUndispatchedRunnable
135 with(continuation) { dispatcher.resumeUndispatched(Unit) } in toString()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/ |
| D | CoroutineDispatcherOperatorFunInvokeTest.kt | 63 val dispatcher = coroutineContext[ContinuationInterceptor] as CoroutineDispatcher in String() constant
65 dispatcher.dispatch(context, block) in String()
70 return dispatcher.isDispatchNeeded(context) in String()
75 dispatcher.dispatchYield(context, block) in String()
|