Searched refs:awaitRunning (Results 1 – 14 of 14) sorted by relevance
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | AbstractIdleServiceTest.java | 51 service.startAsync().awaitRunning(); in testServiceStartStop()
65 service.startAsync().awaitRunning(); in testStart_failed()
80 service.startAsync().awaitRunning(); in testStop_failed()
94 service.startAsync().awaitRunning(); in testStart()
110 service.startAsync().awaitRunning(); in testStart_failed()
131 service.startAsync().awaitRunning(); in testStop_afterStart()
150 service.startAsync().awaitRunning(); in testStop_failed()
169 service.startAsync().awaitRunning(); in testServiceToString()
185 service.startAsync().awaitRunning(1, TimeUnit.MILLISECONDS); in testTimeout()
|
| D | AbstractServiceTest.java | 80 service.startAsync().awaitRunning(); in testNoOpServiceStartAndWaitStopAndWait()
90 service.startAsync().awaitRunning(); in testNoOpServiceStartAsyncAndAwaitStopAsyncAndAwait()
100 service.startAsync().awaitRunning(); in testNoOpServiceStopIdempotence()
118 service.startAsync().awaitRunning(); in testNoOpServiceStopIdempotenceAfterWait()
128 service.startAsync().awaitRunning(); in testNoOpServiceStopIdempotenceDoubleWait()
142 service.startAsync().awaitRunning(); in testNoOpServiceStartStopAndWaitUninterruptible()
355 service.startAsync().awaitRunning(); in testAwaitTerminated()
390 service.startAsync().awaitRunning(); in testThreadedServiceStartAndWaitStopAndWait()
411 service.startAsync().awaitRunning(); in testThreadedServiceStopIdempotence()
427 service.startAsync().awaitRunning(); in testThreadedServiceStopIdempotenceAfterWait()
[all …]
|
| D | AbstractScheduledServiceTest.java | 61 service.startAsync().awaitRunning(); in testServiceStartStop()
76 service.startAsync().awaitRunning(); in testFailOnExceptionFromRun()
94 service.startAsync().awaitRunning(); in testFailOnExceptionFromStartUp()
106 service.startAsync().awaitRunning(); in testFailOnExceptionFromShutDown()
121 service.startAsync().awaitRunning(); in testRunOneIterationCalledMultipleTimes()
135 service.startAsync().awaitRunning(); in testExecutorOnlyCalledOnce()
168 service.awaitRunning(); in testDefaultExecutorIsShutdownWhenServiceIsStopped()
194 service.startAsync().awaitRunning(); in testDefaultExecutorIsShutdownWhenServiceFails()
203 service.startAsync().awaitRunning(); in testSchedulerOnlyCalledOnce()
365 service.startAsync().awaitRunning(); in testCustomSchedulerServiceStop()
[all …]
|
| D | AbstractExecutionThreadServiceTest.java | 67 service.startAsync().awaitRunning(); in testServiceStartStop()
83 service.startAsync().awaitRunning(); in testServiceStopIdempotence()
101 service.startAsync().awaitRunning(); in testServiceExitingOnItsOwn()
169 service.awaitRunning(); in testServiceThrowOnStartUp()
255 service.startAsync().awaitRunning(); in testServiceThrowOnShutDown()
288 service.startAsync().awaitRunning(1, TimeUnit.MILLISECONDS); in testServiceTimeoutOnStartUp()
337 service.startAsync().awaitRunning(); in testDefaultService()
|
| D | ServiceManagerTest.java | 467 @Override public final void awaitRunning() { in testPartiallyConstructedManager_transitionAfterAddListenerBeforeStateIsReady()
468 delegate.awaitRunning(); in testPartiallyConstructedManager_transitionAfterAddListenerBeforeStateIsReady()
471 @Override public final void awaitRunning(long timeout, TimeUnit unit) in testPartiallyConstructedManager_transitionAfterAddListenerBeforeStateIsReady()
473 delegate.awaitRunning(timeout, unit); in testPartiallyConstructedManager_transitionAfterAddListenerBeforeStateIsReady()
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | AbstractIdleService.java | 150 @Override public final void awaitRunning() {
151 delegate.awaitRunning();
157 @Override public final void awaitRunning(long timeout, TimeUnit unit) throws TimeoutException {
158 delegate.awaitRunning(timeout, unit);
|
| D | AbstractExecutionThreadService.java | 196 @Override public final void awaitRunning() {
197 delegate.awaitRunning();
203 @Override public final void awaitRunning(long timeout, TimeUnit unit) throws TimeoutException {
204 delegate.awaitRunning(timeout, unit);
|
| D | Service.java | 99 void awaitRunning(); in awaitRunning() method
115 void awaitRunning(long timeout, TimeUnit unit) throws TimeoutException; in awaitRunning() method
|
| D | AbstractScheduledService.java | 364 @Override public final void awaitRunning() {
365 delegate.awaitRunning();
371 @Override public final void awaitRunning(long timeout, TimeUnit unit) throws TimeoutException {
372 delegate.awaitRunning(timeout, unit);
|
| D | AbstractService.java | 226 @Override public final void awaitRunning() {
235 @Override public final void awaitRunning(long timeout, TimeUnit unit) throws TimeoutException {
|
| /external/caliper/caliper/src/test/java/com/google/caliper/runner/ |
| D | StreamServiceTest.java | 93 service.startAsync().awaitRunning(); in testReadOutput()
111 service.startAsync().awaitRunning(); in failingProcess()
120 service.startAsync().awaitRunning(); in processDoesntExit()
131 service.startAsync().awaitRunning(); in testSocketInputOutput()
147 service.startAsync().awaitRunning(); in testSocketClosesBeforeProcess()
165 service.startAsync().awaitRunning(); in failsToAcceptConnection()
|
| D | ServerSocketServiceTest.java | 49 service.startAsync().awaitRunning(); in startService()
|
| /external/caliper/caliper/src/main/java/com/google/caliper/runner/ |
| D | ServerSocketService.java | 120 awaitRunning(); in getPort()
|
| D | TrialRunLoop.java | 85 streamService.startAsync().awaitRunning(); in call()
|