| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | AbstractService.java | 24 import static com.google.common.util.concurrent.Service.State.RUNNING;
72 stoppingCallback(RUNNING);
77 terminatedCallback(RUNNING);
107 return state().compareTo(RUNNING) <= 0;
113 return state().compareTo(RUNNING) >= 0;
201 case RUNNING:
203 stopping(RUNNING);
229 checkCurrentState(RUNNING);
238 checkCurrentState(RUNNING);
317 snapshot = new StateSnapshot(RUNNING);
[all …]
|
| D | ServiceManager.java | 28 import static com.google.common.util.concurrent.Service.State.RUNNING;
444 return states.count(RUNNING) == numberOfServices
650 if (to.compareTo(RUNNING) >= 0 && stopwatch.isRunning()) { in transitionService()
664 if (states.count(RUNNING) == numberOfServices) { in transitionService()
709 if (states.count(RUNNING) != numberOfServices) { in checkHealthy()
712 + Multimaps.filterKeys(servicesByState, not(equalTo(RUNNING)))); in checkHealthy()
747 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 | 207 RUNNING { enumConstant
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | AbstractServiceTest.java | 60 assertEquals(State.RUNNING, service.state()); in testNoOpServiceStartStop()
71 State.RUNNING, in testNoOpServiceStartStop()
81 assertEquals(State.RUNNING, service.state()); in testNoOpServiceStartAndWaitStopAndWait()
91 assertEquals(State.RUNNING, service.state()); in testNoOpServiceStartAsyncAndAwaitStopAsyncAndAwait()
101 assertEquals(State.RUNNING, service.state()); in testNoOpServiceStopIdempotence()
109 State.RUNNING, in testNoOpServiceStopIdempotence()
129 assertEquals(State.RUNNING, service.state()); in testNoOpServiceStopIdempotenceDoubleWait()
143 assertEquals(State.RUNNING, service.state()); in testNoOpServiceStartStopAndWaitUninterruptible()
180 assertEquals(State.RUNNING, service.state()); in testManualServiceStartStop()
194 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 | 52 assertEquals(Service.State.RUNNING, service.state()); in testServiceStartStop()
96 assertEquals(Service.State.RUNNING, service.state()); in testStart()
|
| /external/testng/src/test/java/test/ |
| D | DynamicGraphTest.java | 36 dg.setStatus(freeNodes, Status.RUNNING); in test8()
43 dg.setStatus("b2", Status.RUNNING); in test8()
63 dg.setStatus(freeNodes, Status.RUNNING); in test2()
70 dg.setStatus("b2", Status.RUNNING); in test2()
|
| /external/autotest/scheduler/ |
| D | monitor_db_functional_test.py | 436 self._check_statuses(queue_entry, HqeStatus.RUNNING, HostStatus.RUNNING)
558 self._check_statuses(queue_entry, HqeStatus.RUNNING)
689 self._check_statuses(queue_entries[0], HqeStatus.RUNNING)
743 queue_entry.status = HqeStatus.RUNNING
746 queue_entry.host.status = HostStatus.RUNNING
857 self._check_statuses(queue_entry2, HqeStatus.RUNNING,
858 HostStatus.RUNNING)
877 self._check_statuses(queue_entry, HqeStatus.RUNNING, HostStatus.RUNNING)
973 _check_hqe_statuses(HqeStatus.RUNNING, HqeStatus.RUNNING,
974 HqeStatus.RUNNING)
[all …]
|
| D | monitor_db.py | 524 models.HostQueueEntry.Status.RUNNING,
574 models.HostQueueEntry.Status.RUNNING):
1211 queue_entry.set_status(models.HostQueueEntry.Status.RUNNING)
1296 models.HostQueueEntry.Status.RUNNING),
1298 models.Host.Status.RUNNING))
1304 queue_entry.host.set_status(models.Host.Status.RUNNING)
1313 queue_entry.host.set_status(models.Host.Status.RUNNING)
|
| /external/testng/src/main/java/org/testng/internal/ |
| D | DynamicGraph.java | 31 READY, RUNNING, FINISHED enumConstant
114 case RUNNING: m_nodesRunning.add(node); break; in setStatus()
139 case RUNNING: return m_nodesRunning.size(); in getNodeCountWithStatus()
181 String RUNNING = "[style=filled color=green]"; in toDot() local
191 color = freeNodes.contains(n) ? FREE : RUNNING; in toDot()
|
| /external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/ThreadReference/ |
| D | StatusTest.java | 84 if (threadStatus != JDWPConstants.ThreadStatus.RUNNING) { in testStatus002()
141 if (threadStatus != JDWPConstants.ThreadStatus.RUNNING) { in testStatus001()
|
| /external/caliper/caliper/src/test/java/com/google/caliper/runner/ |
| D | StreamServiceTest.java | 102 assertEquals(State.RUNNING, service.state()); in testReadOutput()
136 assertEquals(State.RUNNING, service.state()); in testSocketInputOutput()
155 assertEquals(State.RUNNING, service.state()); in testSocketClosesBeforeProcess()
|
| /external/toolchain-utils/crosperf/ |
| D | run_tests.sh | 14 echo RUNNING: ${test}
|
| /external/ltp/runtest/ |
| D | net.rpc | 3 # PLEASE READ THE README FILE IN /rpc BEFORE RUNNING THESE.
|
| D | net.multicast | 3 # PLEASE READ THE README FILE IN /multicast BEFORE RUNNING THESE.
|
| D | net.tcp_cmds | 3 # PLEASE READ THE README FILE IN /tcp_cmds BEFORE RUNNING THESE.
|
| /external/libchrome/base/ |
| D | tracked_objects.cc | 830 DCHECK(state_ != RUNNING); in ~TaskStopwatch()
838 state_ = RUNNING; in Start()
850 DCHECK(parent_->state_ == RUNNING); in Start()
861 DCHECK(state_ == RUNNING); in Stop()
879 DCHECK(parent_->state_ == RUNNING); in Stop()
|
| /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/autotest/client/common_lib/ |
| D | host_queue_entry_states.py | 17 Status.PROVISIONING, Status.PENDING, Status.RUNNING,
|
| /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/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 | MethodExitTest.java | 76 checkThreadState(eventThreadID, JDWPConstants.ThreadStatus.RUNNING, in testMethodExit()
|
| /external/autotest/site_utils/ |
| D | job_overhead.py | 27 _qs.RUNNING, _qs.GATHERING, _qs.PARSING]
|