| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | ExecutionListTest.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
61 }, directExecutor()); in testExecute_idempotent()
81 }, directExecutor()); in testExecute_idempotentConcurrently()
118 MoreExecutors.directExecutor()); in testOrdering()
137 list.add(THROWING_RUNNABLE, directExecutor()); in testExceptionsCaught()
139 list.add(THROWING_RUNNABLE, directExecutor()); in testExceptionsCaught()
|
| D | JdkFutureAdaptersTest.java | 22 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
59 ExecutorSpy spy = new ExecutorSpy(directExecutor()); in testListenInPoolThreadIgnoresExecutorWhenDelegateIsDone()
72 listenableFuture.addListener(singleCallListener, directExecutor()); in testListenInPoolThreadIgnoresExecutorWhenDelegateIsDone()
131 listenableFuture.addListener(singleCallListener, directExecutor()); in testListenInPoolThreadCustomExecutorInterrupted()
238 listenable.addListener(earlyListener, directExecutor()); in testListenInPoolThreadRunsListenerAfterRuntimeException()
246 listenable.addListener(lateListener, directExecutor()); in testListenInPoolThreadRunsListenerAfterRuntimeException()
|
| D | ListenerCallQueueTest.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
44 new ListenerCallQueue<Object>(listenerInstance, directExecutor()); in testAddAndExecute()
59 new ListenerCallQueue<Object>(listenerInstance, directExecutor()); in testAddAndExecute_withExceptions()
|
| D | ListenableFutureTaskTest.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
69 }, directExecutor()); in setUp()
|
| /external/dagger2/compiler/src/it/producers-functional-tests/src/test/java/producerstest/ |
| D | DependentTest.java | 33 .executor(MoreExecutors.directExecutor()) in dependentComponent()
36 .executor(MoreExecutors.directExecutor()) in dependentComponent()
46 .executor(MoreExecutors.directExecutor()); in reuseBuilderWithDependentComponent()
50 .executor(MoreExecutors.directExecutor()) in reuseBuilderWithDependentComponent()
|
| D | ProducerFactoryTest.java | 67 MoreExecutors.directExecutor(), componentMonitorProvider); in noArgMethod()
82 MoreExecutors.directExecutor(), componentMonitorProvider, intProducer); in singleArgMethod()
97 MoreExecutors.directExecutor(), componentMonitorProvider, strFutureProducer); in successMonitor()
124 MoreExecutors.directExecutor(), componentMonitorProvider, strFutureProducer); in failureMonitor()
154 MoreExecutors.directExecutor(), componentMonitorProvider); in failureMonitorDueToThrowingProducer()
175 new SimpleProducerModule_StrFactory(MoreExecutors.directExecutor(), null); in nullComponentMonitorProvider()
|
| D | MultibindingTest.java | 35 DaggerMultibindingComponent.builder().executor(MoreExecutors.directExecutor()).build(); in setBinding()
44 DaggerMultibindingComponent.builder().executor(MoreExecutors.directExecutor()).build(); in setBindingOfProduced()
58 DaggerMultibindingComponent.builder().executor(MoreExecutors.directExecutor()).build(); in setBindingOfProducedWithFailures()
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | Futures.java | 22 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
379 return withFallback(input, fallback, directExecutor()); in withFallback()
490 }, directExecutor()); in FallbackFuture()
567 input.addListener(output, directExecutor()); in transform()
616 input.addListener(rejectionPropagatingRunnable(output, output, executor), directExecutor()); in transform()
708 input.addListener(output, directExecutor());
933 }, directExecutor());
1005 return listFuture(ImmutableList.copyOf(futures), true, directExecutor());
1027 return listFuture(ImmutableList.copyOf(futures), true, directExecutor());
1115 }, directExecutor());
[all …]
|
| /external/opencensus-java/contrib/agent/src/jmh/java/io/opencensus/contrib/agent/instrumentation/ |
| D | ExecutorInstrumentationBenchmark.java | 56 MoreExecutors.directExecutor().execute(new MyRunnable(blackhole)); in none()
69 MoreExecutors.directExecutor().execute(Context.current().wrap(new MyRunnable(blackhole))); in manual()
82 MoreExecutors.directExecutor().execute(new MyRunnable(blackhole)); in automatic()
|
| /external/dagger2/compiler/src/it/producers-functional-tests/src/test/java/producerstest/builder/ |
| D | ProductionComponentBuilderTest.java | 35 .executor(MoreExecutors.directExecutor()) in successfulBuild()
47 .executor(MoreExecutors.directExecutor()) in successfulBuild_withMissingZeroArgModule()
65 .executor(MoreExecutors.directExecutor()) in missingDepComponent()
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/testing/ |
| D | GrpcServerRule.java | 56 public final GrpcServerRule directExecutor() { in directExecutor() method in GrpcServerRule
130 serverBuilder.directExecutor(); in before()
138 channelBuilder.directExecutor(); in before()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ClientCallImplTest.java | 276 MoreExecutors.directExecutor(), in advertisedEncodingsAreSent()
300 MoreExecutors.directExecutor(), in authorityPropagatedToStream()
317 MoreExecutors.directExecutor(), in callOptionsPropagatedToTransport()
335 MoreExecutors.directExecutor(), in authorityNotPropagatedToStream()
683 MoreExecutors.directExecutor(), in contextDeadlineShouldBePropagatedToStream()
708 MoreExecutors.directExecutor(), in contextDeadlineShouldOverrideLargerCallOptionsDeadline()
733 MoreExecutors.directExecutor(), in contextDeadlineShouldNotOverrideSmallerCallOptionsDeadline()
754 MoreExecutors.directExecutor(), in callOptionsDeadlineShouldBePropagatedToStream()
772 MoreExecutors.directExecutor(), in noDeadlineShouldBePropagatedToStream()
790 MoreExecutors.directExecutor(), in expiredDeadlineCancelsStream_CallOptions()
[all …]
|
| /external/grpc-grpc-java/context/src/test/java/io/grpc/ |
| D | ContextTest.java | 137 root.addListener(cancellationListener, MoreExecutors.directExecutor()); in rootCanNeverHaveAListener()
288 base.addListener(new SetContextCancellationListener(observed1), MoreExecutors.directExecutor()); in notifyListenersOnCancel()
290 base.addListener(new SetContextCancellationListener(observed2), MoreExecutors.directExecutor()); in notifyListenersOnCancel()
298 base.addListener(new SetContextCancellationListener(observed3), MoreExecutors.directExecutor()); in notifyListenersOnCancel()
367 child.addListener(cancellationListener, MoreExecutors.directExecutor()); in cascadingCancellationNotifiesChild()
410 attached.addListener(cancellationListener, MoreExecutors.directExecutor()); in cancellableContextIsAttached()
425 child.addListener(cancellationListener, MoreExecutors.directExecutor()); in cancellableContextCascadesFromCancellableParent()
443 fork.addListener(cancellationListener, MoreExecutors.directExecutor()); in nonCascadingCancellationDoesNotNotifyForked()
611 }, MoreExecutors.directExecutor()); in earlierParentDeadlineTakesPrecedenceOverLaterChildDeadline()
648 child.addListener(cancellationListener, MoreExecutors.directExecutor()); in absoluteDeadlineTriggersAndPropagates()
[all …]
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| D | CallOptionsTest.java | 21 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
58 .withExecutor(directExecutor())
88 assertThat(allSet.getExecutor()).isSameAs(directExecutor()); in allWiths()
123 Executor executor = directExecutor(); in mutateExecutor()
145 .withExecutor(new SerializingExecutor(directExecutor())) in toStringMatches_noDeadline_default()
|
| /external/grpc-grpc-java/examples/example-kotlin/src/test/kotlin/io/grpc/examples/helloworld/ |
| D | HelloWorldServerTest.kt | 60 .forName(serverName).directExecutor().addService(GreeterImpl()).build().start()) in greeterImpl_replyMessage()
64 grpcCleanup.register(InProcessChannelBuilder.forName(serverName).directExecutor() in greeterImpl_replyMessage()
|
| D | HelloWorldClientTest.kt | 68 .forName(serverName).directExecutor().addService(serviceImpl).build().start()) in setUp()
72 InProcessChannelBuilder.forName(serverName).directExecutor().build()) in setUp()
|
| /external/grpc-grpc-java/examples/src/test/java/io/grpc/examples/helloworld/ |
| D | HelloWorldServerTest.java | 58 .forName(serverName).directExecutor().addService(new GreeterImpl()).build().start()); in greeterImpl_replyMessage()
62 grpcCleanup.register(InProcessChannelBuilder.forName(serverName).directExecutor().build())); in greeterImpl_replyMessage()
|
| D | HelloWorldClientTest.java | 65 .forName(serverName).directExecutor().addService(serviceImpl).build().start()); in setUp()
69 InProcessChannelBuilder.forName(serverName).directExecutor().build()); in setUp()
|
| /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/qps/ |
| D | ClientConfiguration.java | 49 boolean directExecutor; field in ClientConfiguration
70 flowControlWindow, directExecutor); in newChannel()
199 + "in the transport thread.", "" + DEFAULT.directExecutor) {
202 config.directExecutor = parseBoolean(value); in setClientValue()
|
| D | ServerConfiguration.java | 41 boolean directExecutor; field in ServerConfiguration
168 + "in the transport thread.", "" + DEFAULT.directExecutor) {
171 config.directExecutor = parseBoolean(value); in setServerValue()
|
| /external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/ |
| D | HandshakerServiceChannel.java | 48 .directExecutor()
75 .directExecutor() in getHandshakerChannelPoolForTesting()
|
| /external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/ |
| D | MockFutureListener.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
46 future.addListener(this, directExecutor()); in MockFutureListener()
|
| /external/guava/guava-tests/benchmark/com/google/common/util/concurrent/ |
| D | ExecutionListBenchmark.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
190 list.add(listener, directExecutor());
201 list.add(listener, directExecutor());
217 list.add(listener, directExecutor());
235 list.add(listener, directExecutor());
257 list.add(listener, directExecutor());
|
| D | MoreExecutorsDirectExecutorBenchmark.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
48 return directExecutor(); in executor()
|
| /external/grpc-grpc-java/examples/src/test/java/io/grpc/examples/header/ |
| D | HeaderClientInterceptorTest.java | 80 grpcCleanup.register(InProcessServerBuilder.forName(serverName).directExecutor() in clientHeaderDeliveredToServer()
85 InProcessChannelBuilder.forName(serverName).directExecutor().build()); in clientHeaderDeliveredToServer()
|