| /external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| D | MoreExecutorsTest.java | 232 assertFalse(executor.awaitTermination(20, TimeUnit.MILLISECONDS)); in testDirectExecutorServiceServiceTermination()
236 assertTrue(executor.awaitTermination(1, TimeUnit.SECONDS)); in testDirectExecutorServiceServiceTermination()
237 assertTrue(executor.awaitTermination(0, TimeUnit.SECONDS)); in testDirectExecutorServiceServiceTermination()
268 service.awaitTermination(1, TimeUnit.DAYS); in testDirectExecutorService_awaitTermination_missedSignal()
571 shutdownFirst.verify(service).awaitTermination(2, TimeUnit.SECONDS); in testAddDelayedShutdownHook_success()
578 when(service.awaitTermination(2, TimeUnit.SECONDS)).thenThrow(new InterruptedException()); in testAddDelayedShutdownHook_interrupted()
695 when(service.awaitTermination(HALF_SECOND_NANOS, NANOSECONDS)).thenReturn(true); in testShutdownAndAwaitTermination_immediateShutdownInternal()
699 verify(service).awaitTermination(HALF_SECOND_NANOS, NANOSECONDS); in testShutdownAndAwaitTermination_immediateShutdownInternal()
704 when(service.awaitTermination(HALF_SECOND_NANOS, NANOSECONDS)) in testShutdownAndAwaitTermination_forcedShutDownInternal()
710 verify(service, times(2)).awaitTermination(HALF_SECOND_NANOS, NANOSECONDS); in testShutdownAndAwaitTermination_forcedShutDownInternal()
[all …]
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | MoreExecutorsTest.java | 232 assertFalse(executor.awaitTermination(20, TimeUnit.MILLISECONDS)); in testDirectExecutorServiceServiceTermination()
236 assertTrue(executor.awaitTermination(1, TimeUnit.SECONDS)); in testDirectExecutorServiceServiceTermination()
237 assertTrue(executor.awaitTermination(0, TimeUnit.SECONDS)); in testDirectExecutorServiceServiceTermination()
268 service.awaitTermination(1, TimeUnit.DAYS); in testDirectExecutorService_awaitTermination_missedSignal()
571 shutdownFirst.verify(service).awaitTermination(2, TimeUnit.SECONDS); in testAddDelayedShutdownHook_success()
578 when(service.awaitTermination(2, TimeUnit.SECONDS)).thenThrow(new InterruptedException()); in testAddDelayedShutdownHook_interrupted()
695 when(service.awaitTermination(HALF_SECOND_NANOS, NANOSECONDS)).thenReturn(true); in testShutdownAndAwaitTermination_immediateShutdownInternal()
699 verify(service).awaitTermination(HALF_SECOND_NANOS, NANOSECONDS); in testShutdownAndAwaitTermination_immediateShutdownInternal()
704 when(service.awaitTermination(HALF_SECOND_NANOS, NANOSECONDS)) in testShutdownAndAwaitTermination_forcedShutDownInternal()
710 verify(service, times(2)).awaitTermination(HALF_SECOND_NANOS, NANOSECONDS); in testShutdownAndAwaitTermination_forcedShutDownInternal()
[all …]
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | Server.java | 129 public abstract boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException; in awaitTermination() method in Server
136 public abstract void awaitTermination() throws InterruptedException; in awaitTermination() method in Server
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ForwardingManagedChannelTest.java | 80 public void awaitTermination() throws Exception { in awaitTermination() method in ForwardingManagedChannelTest
83 forward.awaitTermination(timeout, unit); in awaitTermination()
84 verify(mock).awaitTermination(eq(timeout), eq(unit)); in awaitTermination()
|
| /external/testng/src/main/java/org/testng/internal/thread/ |
| D | ExecutorAdapter.java | 39 public boolean awaitTermination(long timeout) { in awaitTermination() method in ExecutorAdapter
42 result= super.awaitTermination(timeout, TimeUnit.MILLISECONDS); in awaitTermination()
|
| D | IExecutor.java | 13 boolean awaitTermination(long timeout); in awaitTermination() method
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | ForwardingManagedChannel.java | 56 public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException { in awaitTermination() method in ForwardingManagedChannel
57 return delegate.awaitTermination(timeout, unit); in awaitTermination()
|
| D | ManagedChannelOrphanWrapper.java | 69 public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException { in awaitTermination() method in ManagedChannelOrphanWrapper
70 boolean ret = super.awaitTermination(timeout, unit); in awaitTermination()
|
| /external/mockito/src/test/java/org/mockitousage/bugs/ |
| D | ShouldNotDeadlockAnswerExecutionTest.java | 41 if (!threads.awaitTermination(1000, TimeUnit.MILLISECONDS)) { in failIfMockIsSharedBetweenThreads()
68 if (!threads.awaitTermination(500, TimeUnit.MILLISECONDS)) { in successIfEveryThreadHasItsOwnMock()
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/testing/ |
| D | GrpcServerRule.java | 103 channel.awaitTermination(1, TimeUnit.MINUTES); in after()
104 server.awaitTermination(1, TimeUnit.MINUTES); in after()
|
| D | GrpcCleanupRule.java | 218 return channel.awaitTermination(duration, timeUnit);
246 return server.awaitTermination(duration, timeUnit);
|
| /external/grpc-grpc-java/benchmarks/src/jmh/java/io/grpc/benchmarks/ |
| D | TransportBenchmark.java | 162 channel.awaitTermination(1, TimeUnit.SECONDS); in tearDown()
163 server.awaitTermination(1, TimeUnit.SECONDS); in tearDown()
172 groupToShutdown.awaitTermination(1, TimeUnit.SECONDS); in tearDown()
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | ForwardingExecutorService.java | 48 public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException { in awaitTermination() method in ForwardingExecutorService
49 return delegate().awaitTermination(timeout, unit); in awaitTermination()
|
| D | MoreExecutors.java | 215 service.awaitTermination(terminationTimeout, timeUnit); in addDelayedShutdownHook()
299 public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException { in awaitTermination() method in MoreExecutors.DirectExecutorService
499 public final boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException { in awaitTermination() method in MoreExecutors.ListeningDecorator
500 return delegate.awaitTermination(timeout, unit); in awaitTermination()
942 if (!service.awaitTermination(halfTimeoutNanos, TimeUnit.NANOSECONDS)) {
946 service.awaitTermination(halfTimeoutNanos, TimeUnit.NANOSECONDS);
|
| D | WrappingExecutorService.java | 159 public final boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException {
160 return delegate.awaitTermination(timeout, unit);
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | ForwardingExecutorService.java | 48 public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException { in awaitTermination() method in ForwardingExecutorService
49 return delegate().awaitTermination(timeout, unit); in awaitTermination()
|
| D | MoreExecutors.java | 215 service.awaitTermination(terminationTimeout, timeUnit); in addDelayedShutdownHook()
299 public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException { in awaitTermination() method in MoreExecutors.DirectExecutorService
499 public final boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException { in awaitTermination() method in MoreExecutors.ListeningDecorator
500 return delegate.awaitTermination(timeout, unit); in awaitTermination()
942 if (!service.awaitTermination(halfTimeoutNanos, TimeUnit.NANOSECONDS)) {
946 service.awaitTermination(halfTimeoutNanos, TimeUnit.NANOSECONDS);
|
| D | WrappingExecutorService.java | 159 public final boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException {
160 return delegate.awaitTermination(timeout, unit);
|
| /external/guice/extensions/servlet/test/com/google/inject/servlet/ |
| D | ContinuingRequestIntegrationTest.java | 79 public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException {
148 executor.awaitTermination(10, TimeUnit.SECONDS); in testRequestContinuesInOtherThread()
191 executor.awaitTermination(10, TimeUnit.SECONDS); in testRequestContinuationDiesInHttpRequestThread()
|
| /external/grpc-grpc-java/netty/shaded/src/testShadow/java/io/grpc/netty/shaded/ |
| D | ShadingTest.java | 53 channel.awaitTermination(1, TimeUnit.SECONDS); in tearDown()
57 server.awaitTermination(1, TimeUnit.SECONDS); in tearDown()
|
| /external/robolectric-shadows/robolectric/src/test/java/org/robolectric/android/util/concurrent/ |
| D | RoboExecutorServiceTest.java | 123 assertThat(executorService.awaitTermination(0, TimeUnit.MILLISECONDS)).isTrue(); in whenAwaitingTerminationAfterShutdown_TrueIsReturned()
130 assertThat(executorService.awaitTermination(500, TimeUnit.MILLISECONDS)).isFalse(); in whenAwaitingTermination_AllTasksAreRunByDefault()
|
| /external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/ |
| D | TestServiceServer.java | 162 if (!server.awaitTermination(5, TimeUnit.SECONDS)) { in stop()
176 server.awaitTermination(); in blockUntilShutdown()
|
| /external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/ |
| D | AbstractListenableFutureTest.java | 198 exec.awaitTermination(100, TimeUnit.MILLISECONDS); in testListenersNotifiedOnError()
245 exec.awaitTermination(500, TimeUnit.MILLISECONDS); in testAllListenersCompleteSuccessfully()
|
| /external/guava/android/guava-testlib/src/com/google/common/util/concurrent/testing/ |
| D | AbstractListenableFutureTest.java | 198 exec.awaitTermination(100, TimeUnit.MILLISECONDS); in testListenersNotifiedOnError()
245 exec.awaitTermination(500, TimeUnit.MILLISECONDS); in testAllListenersCompleteSuccessfully()
|
| /external/testng/src/main/java/org/testng/remote/adapter/ |
| D | IMasterAdapter.java | 39 public void awaitTermination(long timeout) throws InterruptedException; in awaitTermination() method
|