/external/guava/guava-tests/test/com/google/common/util/concurrent/ |
H A D | ServiceTest.java | 21 import static com.google.common.util.concurrent.Service.State.RUNNING; 39 assertLessThan(STARTING, RUNNING); 43 assertLessThan(RUNNING, STOPPING); 44 assertLessThan(RUNNING, FAILED);
|
H A D | AbstractServiceTest.java | 60 assertEquals(State.RUNNING, service.state()); 71 State.RUNNING, 81 assertEquals(State.RUNNING, service.state()); 91 assertEquals(State.RUNNING, service.state()); 101 assertEquals(State.RUNNING, service.state()); 109 State.RUNNING, 129 assertEquals(State.RUNNING, service.state()); 143 assertEquals(State.RUNNING, service.state()); 180 assertEquals(State.RUNNING, service.state()); 194 State.RUNNING, [all...] |
H A D | AbstractExecutionThreadServiceTest.java | 69 assertEquals(Service.State.RUNNING, service.state()); 99 service.expectedShutdownState = Service.State.RUNNING; 103 assertEquals(Service.State.RUNNING, service.state()); 136 assertEquals(State.RUNNING, state()); 256 assertEquals(Service.State.RUNNING, service.state());
|
/external/guava/guava/src/com/google/common/util/concurrent/ |
H A 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); 247 throw new TimeoutException("Timed out waiting for " + this + " to reach the RUNNING stat [all...] |
H A D | Service.java | 34 * <li>{@linkplain State#RUNNING RUNNING} -> 40 * before the {@link Service} reaches the {@linkplain State#RUNNING RUNNING} state. The set of legal 68 * Returns {@code true} if this service is {@linkplain State#RUNNING running}. 78 * If the service is {@linkplain State#STARTING starting} or {@linkplain State#RUNNING running}, 90 * Waits for the {@link Service} to reach the {@linkplain State#RUNNING running state}. 93 * enter the {@link State#RUNNING} state. e.g. if the {@code state} is 102 * Waits for the {@link Service} to reach the {@linkplain State#RUNNING running state} for no 109 * enter the {@link State#RUNNING RUNNIN 207 RUNNING { enum constant in enum:Service.State [all...] |
H A D | AbstractFuture.java | 217 * RUNNING to COMPLETING, that thread will then set the result of the 229 static final int RUNNING = 0; field in class:AbstractFuture.Sync 361 * from {@link #RUNNING}. If the state is not in the RUNNING state we 372 boolean doCompletion = compareAndSetState(RUNNING, COMPLETING);
|
H A D | ServiceManager.java | 28 import static com.google.common.util.concurrent.Service.State.RUNNING; 154 * {@linkplain State#RUNNING running} state. If any services fail during start up or 156 * services have started {@linkplain State#RUNNING running} then this method will not be called. 294 * will become healthy after all the component services have reached the {@linkplain State#RUNNING 307 * reached the {@linkplain State#RUNNING running} state. 355 * Returns true if all services are currently in the {@linkplain State#RUNNING running} state. 444 return states.count(RUNNING) == numberOfServices 650 if (to.compareTo(RUNNING) >= 0 && stopwatch.isRunning()) { 664 if (states.count(RUNNING) == numberOfServices) { 709 if (states.count(RUNNING) ! [all...] |
/external/autotest/client/common_lib/ |
H A D | host_queue_entry_states.py | 17 Status.PROVISIONING, Status.PENDING, Status.RUNNING,
|
/external/testng/src/test/java/test/ |
H A D | DynamicGraphTest.java | 36 dg.setStatus(freeNodes, Status.RUNNING); 43 dg.setStatus("b2", Status.RUNNING); 63 dg.setStatus(freeNodes, Status.RUNNING); 70 dg.setStatus("b2", Status.RUNNING);
|
/external/testng/src/main/java/org/testng/internal/ |
H A D | DynamicGraph.java | 31 READY, RUNNING, FINISHED enum constant in enum:DynamicGraph.Status 114 case RUNNING: m_nodesRunning.add(node); break; 139 case RUNNING: return m_nodesRunning.size(); 181 String RUNNING = "[style=filled color=green]"; 191 color = freeNodes.contains(n) ? FREE : RUNNING;
|
/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/api/map_job/ |
H A D | map_job_control.py | 22 RUNNING = "running" variable in class:Job 27 STATUS_ENUM = [RUNNING, FAILED, ABORTED, SUCCESS] 65 return self.RUNNING
|
/external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/Events/ |
H A D | Breakpoint002Test.java | 169 checkThreadState(eventThreadID, JDWPConstants.ThreadStatus.RUNNING,
|
H A D | MethodEntryTest.java | 75 checkThreadState(eventThreadID, JDWPConstants.ThreadStatus.RUNNING,
|
H A D | MethodExitTest.java | 75 checkThreadState(eventThreadID, JDWPConstants.ThreadStatus.RUNNING,
|
H A D | BreakpointTest.java | 79 checkThreadState(eventThreadID, JDWPConstants.ThreadStatus.RUNNING,
|
H A D | FieldAccessTest.java | 74 checkThreadState(eventThreadID, JDWPConstants.ThreadStatus.RUNNING,
|
H A D | FieldModificationTest.java | 74 checkThreadState(eventThreadID, JDWPConstants.ThreadStatus.RUNNING,
|
/external/autotest/site_utils/ |
H A D | job_overhead.py | 27 _qs.RUNNING, _qs.GATHERING, _qs.PARSING]
|
/external/autotest/scheduler/ |
H A 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) [all...] |
/external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/ThreadReference/ |
H A D | StatusTest.java | 53 * <BR> - returned thread status is RUNNING status; 83 if (threadStatus != JDWPConstants.ThreadStatus.RUNNING) { 112 * <BR> - returned thread status is RUNNING status; 140 if (threadStatus != JDWPConstants.ThreadStatus.RUNNING) {
|
/external/valgrind/memcheck/tests/ |
H A D | client-msg-as-xml.stderr.exp | 27 <state>RUNNING</state>
|
H A D | long_namespace_xml.stderr.exp | 27 <state>RUNNING</state>
|
/external/chromium-trace/catapult/third_party/gsutil/third_party/protorpc/protorpc/ |
H A D | transport.py | 69 self.__state = remote.RpcState.RUNNING 104 if self.__state == remote.RpcState.RUNNING: 120 if self.__state != remote.RpcState.RUNNING: 122 'RPC must be in RUNNING state to change to %s' % state) 123 if state == remote.RpcState.RUNNING: 124 raise RpcStateError('RPC is already in RUNNING state')
|
/external/jetty/src/java/org/eclipse/jetty/server/handler/ |
H A D | HotSwapHandler.java | 141 throw new IllegalStateException(RUNNING);
|
/external/chromium-trace/catapult/third_party/gsutil/third_party/protorpc/experimental/javascript/ |
H A D | protorpc.js | 85 RUNNING: 'RUNNING', 145 ProtoRpc.RPC.prototype.state_ = ProtoRpc.RPC.State.RUNNING; 169 if (this.state_ != ProtoRpc.RPC.State.RUNNING) {
|