/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/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/autotest/scheduler/ |
D | monitor_db_functional_test.py | 447 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 …]
|
D | monitor_db.py | 501 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/ |
D | map_job_control.py | 22 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/ |
D | protorpc.js | 85 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/ |
D | transport.py | 69 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/ |
D | StatusTest.java | 83 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/ |
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/autotest/client/common_lib/ |
D | host_queue_entry_states.py | 17 Status.PROVISIONING, Status.PENDING, Status.RUNNING,
|
/external/libchrome/base/ |
D | tracked_objects.cc | 869 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/ |
D | JDWPConstants.java | 42 public static final byte RUNNING = 1; field in JDWPConstants.ThreadStatus 61 case RUNNING: in getName()
|
/external/autotest/site_utils/ |
D | job_overhead.py | 27 _qs.RUNNING, _qs.GATHERING, _qs.PARSING]
|
/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()
|
/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()
|