| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | AbstractService.java | 24 import static com.google.common.util.concurrent.Service.State.RUNNING;
73 stoppingCallback(RUNNING);
78 terminatedCallback(RUNNING);
111 return state().compareTo(RUNNING) <= 0;
117 return state().compareTo(RUNNING) >= 0;
154 startup.set(RUNNING);
176 case RUNNING:
268 case RUNNING:
270 stopping(RUNNING);
314 checkCurrentState(RUNNING);
[all …]
|
| D | ServiceManager.java | 27 import static com.google.common.util.concurrent.Service.State.RUNNING;
451 return states.count(RUNNING) == numberOfServices
647 if (to.compareTo(RUNNING) >= 0 && stopwatch.isRunning()) { in transitionService()
661 if (states.count(RUNNING) == numberOfServices) { in transitionService()
706 if (states.count(RUNNING) != numberOfServices) { in checkHealthy()
709 Multimaps.filterKeys(servicesByState, not(equalTo(RUNNING)))); in checkHealthy()
743 state.transitionService(service, STARTING, RUNNING); in running()
|
| D | AbstractFuture.java | 229 static final int RUNNING = 0; field in AbstractFuture.Sync
372 boolean doCompletion = compareAndSetState(RUNNING, COMPLETING); in complete()
|
| D | Service.java | 277 RUNNING { enumConstant
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | AbstractServiceTest.java | 59 assertEquals(State.RUNNING, service.state()); in testNoOpServiceStartStop()
70 State.RUNNING, in testNoOpServiceStartStop()
80 assertEquals(State.RUNNING, service.state()); in testNoOpServiceStartAndWaitStopAndWait()
90 assertEquals(State.RUNNING, service.state()); in testNoOpServiceStartAsyncAndAwaitStopAsyncAndAwait()
100 assertEquals(State.RUNNING, service.state()); in testNoOpServiceStopIdempotence()
108 State.RUNNING, in testNoOpServiceStopIdempotence()
128 assertEquals(State.RUNNING, service.state()); in testNoOpServiceStopIdempotenceDoubleWait()
142 assertEquals(State.RUNNING, service.state()); in testNoOpServiceStartStopAndWaitUninterruptible()
179 assertEquals(State.RUNNING, service.state()); in testManualServiceStartStop()
193 State.RUNNING, in testManualServiceStartStop()
[all …]
|
| D | ServiceTest.java | 21 import static com.google.common.util.concurrent.Service.State.RUNNING;
39 assertLessThan(STARTING, RUNNING); in testStateOrdering()
43 assertLessThan(RUNNING, STOPPING); in testStateOrdering()
44 assertLessThan(RUNNING, FAILED); in testStateOrdering()
|
| D | AbstractExecutionThreadServiceTest.java | 69 assertEquals(Service.State.RUNNING, service.state()); in testServiceStartStop()
99 service.expectedShutdownState = Service.State.RUNNING; in testServiceExitingOnItsOwn()
103 assertEquals(Service.State.RUNNING, service.state()); in testServiceExitingOnItsOwn()
136 assertEquals(State.RUNNING, state()); in run()
256 assertEquals(Service.State.RUNNING, service.state()); in testServiceThrowOnShutDown()
|
| D | AbstractIdleServiceTest.java | 51 assertEquals(Service.State.RUNNING, service.state()); in testServiceStartStop()
95 assertEquals(Service.State.RUNNING, service.state()); in testStart()
|
| D | ServiceManagerTest.java | 130 assertState(manager, Service.State.RUNNING, a, b); in testServiceStartStop()
158 assertState(manager, Service.State.RUNNING, a, c, e); in testFailStart()
296 assertEquals(service.toString(), service.isRunning(), state == Service.State.RUNNING); in assertState()
|
| /external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/ThreadReference/ |
| D | StatusTest.java | 83 if (threadStatus != JDWPConstants.ThreadStatus.RUNNING) { in testStatus002()
140 if (threadStatus != JDWPConstants.ThreadStatus.RUNNING) { in testStatus001()
|
| /external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/framework/jdwp/ |
| D | JDWPConstants.java | 42 public static final byte RUNNING = 1; field in JDWPConstants.ThreadStatus
61 case RUNNING: in getName()
|
| /external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/Events/ |
| D | Breakpoint002Test.java | 169 checkThreadState(eventThreadID, JDWPConstants.ThreadStatus.RUNNING, in testBreakpointIn()
|
| D | MethodEntryTest.java | 75 checkThreadState(eventThreadID, JDWPConstants.ThreadStatus.RUNNING, in testMethodEntry()
|
| D | MethodExitTest.java | 75 checkThreadState(eventThreadID, JDWPConstants.ThreadStatus.RUNNING, in testMethodExit()
|
| D | BreakpointTest.java | 79 checkThreadState(eventThreadID, JDWPConstants.ThreadStatus.RUNNING, in testSetBreakpointEvent()
|
| D | FieldAccessTest.java | 83 checkThreadState(eventThreadID, JDWPConstants.ThreadStatus.RUNNING, in testFieldAccessEvent()
|
| D | FieldModificationTest.java | 83 checkThreadState(eventThreadID, JDWPConstants.ThreadStatus.RUNNING, in testFieldModifyEvent()
|
| D | BreakpointOnCatchTest.java | 91 checkThreadState(eventThreadID, JDWPConstants.ThreadStatus.RUNNING, in testBreakpointOnCatch()
|
| D | ExceptionBaseTest.java | 58 checkThreadState(eventThreadID, JDWPConstants.ThreadStatus.RUNNING, in receiveAndCheckExceptionEvent()
|
| D | CombinedExceptionEventsTest.java | 156 checkThreadState(eventThreadID, JDWPConstants.ThreadStatus.RUNNING, in runCombinedExceptionEventsTest()
|
| /external/glide/library/src/main/java/com/bumptech/glide/request/ |
| D | GenericRequest.java | 44 RUNNING, enumConstant
332 return status == Status.RUNNING || status == Status.WAITING_FOR_SIZE; in isRunning()
404 status = Status.RUNNING; in onSizeReady()
|
| /external/jetty/src/java/org/eclipse/jetty/server/handler/ |
| D | HotSwapHandler.java | 141 throw new IllegalStateException(RUNNING); in setServer()
|
| /external/robolectric/src/main/java/com/xtremelabs/robolectric/shadows/ |
| D | ShadowAsyncTask.java | 77 status = AsyncTask.Status.RUNNING; in execute()
|
| /external/jetty/src/java/org/eclipse/jetty/util/component/ |
| D | AbstractLifeCycle.java | 39 public static final String RUNNING="RUNNING"; field in AbstractLifeCycle
|
| /external/robolectric/src/test/java/com/xtremelabs/robolectric/shadows/ |
| D | AsyncTaskTest.java | 118 assertThat(asyncTask.getStatus(), is(AsyncTask.Status.RUNNING)); in shouldGetStatusForAsyncTask()
|