Searched refs:RUNNING (Results 1 - 25 of 83) sorted by relevance

1234

/external/guava/guava-tests/test/com/google/common/util/concurrent/
H A DServiceTest.java21 import static com.google.common.util.concurrent.Service.State.RUNNING;
39 assertLessThan(STARTING, RUNNING);
43 assertLessThan(RUNNING, STOPPING);
44 assertLessThan(RUNNING, FAILED);
H A DAbstractServiceTest.java60 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 DAbstractExecutionThreadServiceTest.java69 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 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);
247 throw new TimeoutException("Timed out waiting for " + this + " to reach the RUNNING stat
[all...]
H A DService.java34 * <li>{@linkplain State#RUNNING RUNNING} -&gt;
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 DAbstractFuture.java217 * 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 DServiceManager.java28 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 Dhost_queue_entry_states.py17 Status.PROVISIONING, Status.PENDING, Status.RUNNING,
/external/testng/src/test/java/test/
H A DDynamicGraphTest.java36 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 DDynamicGraph.java31 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 Dmap_job_control.py22 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 DBreakpoint002Test.java169 checkThreadState(eventThreadID, JDWPConstants.ThreadStatus.RUNNING,
H A DMethodEntryTest.java75 checkThreadState(eventThreadID, JDWPConstants.ThreadStatus.RUNNING,
H A DMethodExitTest.java75 checkThreadState(eventThreadID, JDWPConstants.ThreadStatus.RUNNING,
H A DBreakpointTest.java79 checkThreadState(eventThreadID, JDWPConstants.ThreadStatus.RUNNING,
H A DFieldAccessTest.java74 checkThreadState(eventThreadID, JDWPConstants.ThreadStatus.RUNNING,
H A DFieldModificationTest.java74 checkThreadState(eventThreadID, JDWPConstants.ThreadStatus.RUNNING,
/external/autotest/site_utils/
H A Djob_overhead.py27 _qs.RUNNING, _qs.GATHERING, _qs.PARSING]
/external/autotest/scheduler/
H A 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)
[all...]
/external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/ThreadReference/
H A DStatusTest.java53 * <BR>&nbsp;&nbsp; - returned thread status is RUNNING status;
83 if (threadStatus != JDWPConstants.ThreadStatus.RUNNING) {
112 * <BR>&nbsp;&nbsp; - returned thread status is RUNNING status;
140 if (threadStatus != JDWPConstants.ThreadStatus.RUNNING) {
/external/valgrind/memcheck/tests/
H A Dclient-msg-as-xml.stderr.exp27 <state>RUNNING</state>
H A Dlong_namespace_xml.stderr.exp27 <state>RUNNING</state>
/external/chromium-trace/catapult/third_party/gsutil/third_party/protorpc/protorpc/
H A Dtransport.py69 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 DHotSwapHandler.java141 throw new IllegalStateException(RUNNING);
/external/chromium-trace/catapult/third_party/gsutil/third_party/protorpc/experimental/javascript/
H A Dprotorpc.js85 RUNNING: 'RUNNING',
145 ProtoRpc.RPC.prototype.state_ = ProtoRpc.RPC.State.RUNNING;
169 if (this.state_ != ProtoRpc.RPC.State.RUNNING) {

Completed in 4002 milliseconds

1234