Home
last modified time | relevance | path

Searched refs:RUNNING (Results 1 – 25 of 69) sorted by relevance

123

/external/guava/guava/src/com/google/common/util/concurrent/
DAbstractService.java24 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 …]
DServiceManager.java28 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()
DAbstractFuture.java229 static final int RUNNING = 0; field in AbstractFuture.Sync
372 boolean doCompletion = compareAndSetState(RUNNING, COMPLETING); in complete()
DService.java207 RUNNING { enumConstant
/external/guava/guava-tests/test/com/google/common/util/concurrent/
DAbstractServiceTest.java60 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 …]
DServiceTest.java21 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()
DAbstractExecutionThreadServiceTest.java69 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()
DAbstractIdleServiceTest.java52 assertEquals(Service.State.RUNNING, service.state()); in testServiceStartStop()
96 assertEquals(Service.State.RUNNING, service.state()); in testStart()
/external/testng/src/test/java/test/
DDynamicGraphTest.java36 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/testng/src/main/java/org/testng/internal/
DDynamicGraph.java31 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/autotest/scheduler/
Dmonitor_db_functional_test.py447 self._check_statuses(queue_entry, HqeStatus.RUNNING, HostStatus.RUNNING)
569 self._check_statuses(queue_entry, HqeStatus.RUNNING)
700 self._check_statuses(queue_entries[0], HqeStatus.RUNNING)
754 queue_entry.status = HqeStatus.RUNNING
757 queue_entry.host.status = HostStatus.RUNNING
881 self._check_statuses(queue_entry2, HqeStatus.RUNNING,
882 HostStatus.RUNNING)
901 self._check_statuses(queue_entry, HqeStatus.RUNNING, HostStatus.RUNNING)
997 _check_hqe_statuses(HqeStatus.RUNNING, HqeStatus.RUNNING,
998 HqeStatus.RUNNING)
[all …]
Dmonitor_db.py501 models.HostQueueEntry.Status.RUNNING,
544 models.HostQueueEntry.Status.RUNNING):
1203 queue_entry.set_status(models.HostQueueEntry.Status.RUNNING)
1284 models.HostQueueEntry.Status.RUNNING),
1286 models.Host.Status.RUNNING))
1292 queue_entry.host.set_status(models.Host.Status.RUNNING)
1301 queue_entry.host.set_status(models.Host.Status.RUNNING)
/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/api/map_job/
Dmap_job_control.py22 RUNNING = "running" variable in Job
27 STATUS_ENUM = [RUNNING, FAILED, ABORTED, SUCCESS]
65 return self.RUNNING
/external/chromium-trace/catapult/third_party/gsutil/third_party/protorpc/experimental/javascript/
Dprotorpc.js85 RUNNING: 'RUNNING', property
145 ProtoRpc.RPC.prototype.state_ = ProtoRpc.RPC.State.RUNNING;
169 if (this.state_ != ProtoRpc.RPC.State.RUNNING) {
/external/chromium-trace/catapult/third_party/gsutil/third_party/protorpc/protorpc/
Dtransport.py69 self.__state = remote.RpcState.RUNNING
104 if self.__state == remote.RpcState.RUNNING:
120 if self.__state != remote.RpcState.RUNNING:
123 if state == remote.RpcState.RUNNING:
/external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/ThreadReference/
DStatusTest.java83 if (threadStatus != JDWPConstants.ThreadStatus.RUNNING) { in testStatus002()
140 if (threadStatus != JDWPConstants.ThreadStatus.RUNNING) { in testStatus001()
/external/caliper/caliper/src/test/java/com/google/caliper/runner/
DStreamServiceTest.java102 assertEquals(State.RUNNING, service.state()); in testReadOutput()
136 assertEquals(State.RUNNING, service.state()); in testSocketInputOutput()
155 assertEquals(State.RUNNING, service.state()); in testSocketClosesBeforeProcess()
/external/autotest/client/common_lib/
Dhost_queue_entry_states.py17 Status.PROVISIONING, Status.PENDING, Status.RUNNING,
/external/libchrome/base/
Dtracked_objects.cc869 DCHECK(state_ != RUNNING); in ~TaskStopwatch()
877 state_ = RUNNING; in Start()
889 DCHECK(parent_->state_ == RUNNING); in Start()
900 DCHECK(state_ == RUNNING); in Stop()
918 DCHECK(parent_->state_ == RUNNING); in Stop()
/external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/framework/jdwp/
DJDWPConstants.java42 public static final byte RUNNING = 1; field in JDWPConstants.ThreadStatus
61 case RUNNING: in getName()
/external/autotest/site_utils/
Djob_overhead.py27 _qs.RUNNING, _qs.GATHERING, _qs.PARSING]
/external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/Events/
DBreakpoint002Test.java169 checkThreadState(eventThreadID, JDWPConstants.ThreadStatus.RUNNING, in testBreakpointIn()
DMethodEntryTest.java75 checkThreadState(eventThreadID, JDWPConstants.ThreadStatus.RUNNING, in testMethodEntry()
DMethodExitTest.java75 checkThreadState(eventThreadID, JDWPConstants.ThreadStatus.RUNNING, in testMethodExit()
/external/glide/library/src/main/java/com/bumptech/glide/request/
DGenericRequest.java44 RUNNING, enumConstant
332 return status == Status.RUNNING || status == Status.WAITING_FOR_SIZE; in isRunning()
404 status = Status.RUNNING; in onSizeReady()

123