Home
last modified time | relevance | path

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

1234

/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()
/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()
/external/autotest/scheduler/
Dmonitor_db_functional_test.py442 self._check_statuses(queue_entry, HqeStatus.RUNNING, HostStatus.RUNNING)
562 self._check_statuses(queue_entry, HqeStatus.RUNNING)
689 self._check_statuses(queue_entries[0], HqeStatus.RUNNING)
745 queue_entry.status = HqeStatus.RUNNING
748 queue_entry.host.status = HostStatus.RUNNING
859 self._check_statuses(queue_entry2, HqeStatus.RUNNING,
860 HostStatus.RUNNING)
879 self._check_statuses(queue_entry, HqeStatus.RUNNING, HostStatus.RUNNING)
975 _check_hqe_statuses(HqeStatus.RUNNING, HqeStatus.RUNNING,
976 HqeStatus.RUNNING)
[all …]
/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/python/cpython3/Lib/concurrent/futures/
D_base.py18 RUNNING = 'RUNNING' variable
27 RUNNING,
35 RUNNING: "running",
355 if self._state in [RUNNING, FINISHED]:
375 return self._state == RUNNING
502 self._state = RUNNING
/external/python/futures/concurrent/futures/
D_base.py20 RUNNING = 'RUNNING' variable
29 RUNNING,
37 RUNNING: "running",
378 if self._state in [RUNNING, FINISHED]:
398 return self._state == RUNNING
551 self._state = RUNNING
/external/google-benchmark/docs/
Dtools.md35 RUNNING: ./a.out --benchmark_out=/tmp/tmprBT5nW
51 RUNNING: ./a.out --benchmark_out=/tmp/tmpt1wwG_
100 RUNNING: ./a.out --benchmark_filter=BM_memcpy --benchmark_out=/tmp/tmpBWKk0k
111 RUNNING: ./a.out --benchmark_filter=BM_copy --benchmark_out=/tmp/tmpAvWcOM
151 RUNNING: ./a.out --benchmark_filter=BM_memcpy --benchmark_out=/tmp/tmp_FvbYg
162 RUNNING: ./a.out --benchmark_filter=BM_copy --benchmark_out=/tmp/tmpDfL5iE
/external/libcxx/utils/google-benchmark/docs/
Dtools.md35 RUNNING: ./a.out --benchmark_out=/tmp/tmprBT5nW
51 RUNNING: ./a.out --benchmark_out=/tmp/tmpt1wwG_
100 RUNNING: ./a.out --benchmark_filter=BM_memcpy --benchmark_out=/tmp/tmpBWKk0k
111 RUNNING: ./a.out --benchmark_filter=BM_copy --benchmark_out=/tmp/tmpAvWcOM
151 RUNNING: ./a.out --benchmark_filter=BM_memcpy --benchmark_out=/tmp/tmp_FvbYg
162 RUNNING: ./a.out --benchmark_filter=BM_copy --benchmark_out=/tmp/tmpDfL5iE
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DSerializingExecutor.java59 private static final int RUNNING = -1; field in SerializingExecutor
90 if (atomicHelper.runStateCompareAndSet(this, STOPPED, RUNNING)) { in schedule()
/external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/ThreadReference/
DStatusTest.java84 if (threadStatus != JDWPConstants.ThreadStatus.RUNNING) { in testStatus002()
141 if (threadStatus != JDWPConstants.ThreadStatus.RUNNING) { in testStatus001()
/external/robolectric-shadows/shadows/framework/src/main/java/org/robolectric/shadows/
DShadowAsyncTask.java85 status = AsyncTask.Status.RUNNING; in execute()
103 status = AsyncTask.Status.RUNNING; in executeOnExecutor()
/external/python/cpython3/Lib/turtledemo/
Dnim.py64 self.game.state = Nim.RUNNING
111 if self.game.state != Nim.RUNNING:
207 RUNNING = 1 variable in Nim
/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/python/cpython2/Demo/turtle/
Dtdemo_nim.py64 self.game.state = Nim.RUNNING
111 if self.game.state != Nim.RUNNING:
207 RUNNING = 1 variable in Nim
/external/grpc-grpc/src/python/grpcio_tests/tests/
D_result.py51 RUNNING = 'running' variable in CaseResult.Kind
74 elif kind is CaseResult.Kind.RUNNING:
152 id=case_id, name=test.id(), kind=CaseResult.Kind.RUNNING)
361 lambda case_result: case_result.kind is CaseResult.Kind.RUNNING))
/external/toolchain-utils/crosperf/
Drun_tests.sh14 echo RUNNING: ${test}
/external/ltp/runtest/
Dnet.rpc3 # PLEASE READ THE README FILE IN /rpc BEFORE RUNNING THESE.
Dnet.multicast3 # PLEASE READ THE README FILE IN /multicast BEFORE RUNNING THESE.
/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/walt/android/WALT/app/src/main/java/org/chromium/latency/walt/
DWaltTcpConnection.java97 connectionState = Utils.ListenerState.RUNNING; in connect()
124 return connectionState == Utils.ListenerState.RUNNING; in isConnected()

1234