| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | AbstractService.java | 22 import static com.google.common.util.concurrent.Service.State.RUNNING;
80 stoppingEvent(RUNNING);
87 terminatedEvent(RUNNING);
145 return state().compareTo(RUNNING) <= 0;
159 return state().compareTo(RUNNING) >= 0;
278 case RUNNING:
280 enqueueStoppingEvent(RUNNING);
303 checkCurrentState(RUNNING);
319 checkCurrentState(RUNNING);
411 snapshot = new StateSnapshot(RUNNING);
[all …]
|
| D | SequentialExecutor.java | 21 import static com.google.common.util.concurrent.SequentialExecutor.WorkerRunningState.RUNNING;
60 RUNNING, enumConstant
104 if (workerRunningState == RUNNING || workerRunningState == QUEUED) { in execute()
210 if (workerRunningState == RUNNING) { in workOnQueue()
218 workerRunningState = RUNNING; in workOnQueue()
|
| D | ServiceManager.java | 28 import static com.google.common.util.concurrent.Service.State.RUNNING;
477 return states.count(RUNNING) == numberOfServices in isSatisfied()
688 if (to.compareTo(RUNNING) >= 0 && stopwatch.isRunning()) { in transitionService()
702 if (states.count(RUNNING) == numberOfServices) { in transitionService()
749 if (states.count(RUNNING) != numberOfServices) { in checkHealthy()
753 + Multimaps.filterKeys(servicesByState, not(equalTo(RUNNING)))); in checkHealthy()
793 state.transitionService(service, STARTING, RUNNING); in running()
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | AbstractService.java | 22 import static com.google.common.util.concurrent.Service.State.RUNNING;
79 stoppingEvent(RUNNING);
86 terminatedEvent(RUNNING);
144 return state().compareTo(RUNNING) <= 0;
158 return state().compareTo(RUNNING) >= 0;
277 case RUNNING:
279 enqueueStoppingEvent(RUNNING);
302 checkCurrentState(RUNNING);
312 checkCurrentState(RUNNING);
398 snapshot = new StateSnapshot(RUNNING);
[all …]
|
| D | SequentialExecutor.java | 21 import static com.google.common.util.concurrent.SequentialExecutor.WorkerRunningState.RUNNING;
60 RUNNING, enumConstant
104 if (workerRunningState == RUNNING || workerRunningState == QUEUED) { in execute()
210 if (workerRunningState == RUNNING) { in workOnQueue()
218 workerRunningState = RUNNING; in workOnQueue()
|
| D | ServiceManager.java | 27 import static com.google.common.util.concurrent.Service.State.RUNNING;
447 return states.count(RUNNING) == numberOfServices in isSatisfied()
658 if (to.compareTo(RUNNING) >= 0 && stopwatch.isRunning()) { in transitionService()
672 if (states.count(RUNNING) == numberOfServices) { in transitionService()
719 if (states.count(RUNNING) != numberOfServices) { in checkHealthy()
723 + Multimaps.filterKeys(servicesByState, not(equalTo(RUNNING)))); in checkHealthy()
760 state.transitionService(service, STARTING, RUNNING); in running()
|
| /external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| D | AbstractServiceTest.java | 58 assertEquals(State.RUNNING, service.state()); in testNoOpServiceStartStop()
67 ImmutableList.of(State.STARTING, State.RUNNING, State.STOPPING, State.TERMINATED), in testNoOpServiceStartStop()
75 assertEquals(State.RUNNING, service.state()); in testNoOpServiceStartAndWaitStopAndWait()
85 assertEquals(State.RUNNING, service.state()); in testNoOpServiceStartAsyncAndAwaitStopAsyncAndAwait()
95 assertEquals(State.RUNNING, service.state()); in testNoOpServiceStopIdempotence()
101 ImmutableList.of(State.STARTING, State.RUNNING, State.STOPPING, State.TERMINATED), in testNoOpServiceStopIdempotence()
119 assertEquals(State.RUNNING, service.state()); in testNoOpServiceStopIdempotenceDoubleWait()
132 assertEquals(State.RUNNING, service.state()); in testNoOpServiceStartStopAndWaitUninterruptible()
171 assertEquals(State.RUNNING, service.state()); in testManualServiceStartStop()
183 ImmutableList.of(State.STARTING, State.RUNNING, State.STOPPING, State.TERMINATED), in testManualServiceStartStop()
[all …]
|
| D | ServiceTest.java | 21 import static com.google.common.util.concurrent.Service.State.RUNNING;
38 assertLessThan(STARTING, RUNNING); in testStateOrdering()
42 assertLessThan(RUNNING, STOPPING); in testStateOrdering()
43 assertLessThan(RUNNING, FAILED); in testStateOrdering()
|
| D | AbstractExecutionThreadServiceTest.java | 77 assertEquals(Service.State.RUNNING, service.state()); in testServiceStartStop()
105 service.expectedShutdownState = Service.State.RUNNING; in testServiceExitingOnItsOwn()
109 assertEquals(Service.State.RUNNING, service.state()); in testServiceExitingOnItsOwn()
143 assertEquals(State.RUNNING, state()); in run()
272 assertEquals(Service.State.RUNNING, service.state()); in testServiceThrowOnShutDown()
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | AbstractServiceTest.java | 58 assertEquals(State.RUNNING, service.state()); in testNoOpServiceStartStop()
67 ImmutableList.of(State.STARTING, State.RUNNING, State.STOPPING, State.TERMINATED), in testNoOpServiceStartStop()
75 assertEquals(State.RUNNING, service.state()); in testNoOpServiceStartAndWaitStopAndWait()
85 assertEquals(State.RUNNING, service.state()); in testNoOpServiceStartAsyncAndAwaitStopAsyncAndAwait()
95 assertEquals(State.RUNNING, service.state()); in testNoOpServiceStopIdempotence()
101 ImmutableList.of(State.STARTING, State.RUNNING, State.STOPPING, State.TERMINATED), in testNoOpServiceStopIdempotence()
119 assertEquals(State.RUNNING, service.state()); in testNoOpServiceStopIdempotenceDoubleWait()
132 assertEquals(State.RUNNING, service.state()); in testNoOpServiceStartStopAndWaitUninterruptible()
171 assertEquals(State.RUNNING, service.state()); in testManualServiceStartStop()
183 ImmutableList.of(State.STARTING, State.RUNNING, State.STOPPING, State.TERMINATED), in testManualServiceStartStop()
[all …]
|
| D | ServiceTest.java | 21 import static com.google.common.util.concurrent.Service.State.RUNNING;
38 assertLessThan(STARTING, RUNNING); in testStateOrdering()
42 assertLessThan(RUNNING, STOPPING); in testStateOrdering()
43 assertLessThan(RUNNING, FAILED); in testStateOrdering()
|
| D | AbstractExecutionThreadServiceTest.java | 77 assertEquals(Service.State.RUNNING, service.state()); in testServiceStartStop()
105 service.expectedShutdownState = Service.State.RUNNING; in testServiceExitingOnItsOwn()
109 assertEquals(Service.State.RUNNING, service.state()); in testServiceExitingOnItsOwn()
143 assertEquals(State.RUNNING, state()); in run()
272 assertEquals(Service.State.RUNNING, service.state()); in testServiceThrowOnShutDown()
|
| /external/rust/crates/tokio/src/runtime/task/ |
| D | state.rs | 18 const RUNNING: usize = 0b0001; constant
136 const DELTA: usize = RUNNING | COMPLETE; in transition_to_complete()
347 self.0 & (RUNNING | COMPLETE) == 0 in is_idle()
360 self.0 & RUNNING == RUNNING in is_running()
364 self.0 |= RUNNING; in set_running()
368 self.0 &= !RUNNING; in unset_running()
|
| /external/rust/crates/async-task/src/ |
| D | raw.rs | 231 if state & RUNNING == 0 { in wake()
274 let new = if state & RUNNING == 0 { in wake_by_ref()
289 if state & RUNNING == 0 { in wake_by_ref()
473 (state & !SCHEDULED) | RUNNING, in run()
479 state = (state & !SCHEDULED) | RUNNING; in run()
502 (state & !RUNNING & !SCHEDULED) | COMPLETED | CLOSED in run()
504 (state & !RUNNING & !SCHEDULED) | COMPLETED in run()
549 state & !RUNNING & !SCHEDULED in run()
551 state & !RUNNING in run()
634 .fetch_and(!RUNNING & !SCHEDULED, Ordering::AcqRel); in run()
[all …]
|
| D | task.rs | 156 let new = if state & (SCHEDULED | RUNNING) == 0 { in set_canceled()
172 if state & (SCHEDULED | RUNNING) == 0 { in set_canceled()
290 if state & (SCHEDULED | RUNNING) != 0 { in poll_task()
300 if state & (SCHEDULED | RUNNING) != 0 { in poll_task()
|
| /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/rust/crates/once_cell/src/ |
| D | imp_std.rs | 40 const RUNNING: usize = 0x1; constant
159 RUNNING, in initialize_inner()
178 assert!(state_and_queue & STATE_MASK == RUNNING); in initialize_inner()
189 if current_state & STATE_MASK != RUNNING { in wait()
202 me | RUNNING, in wait()
224 assert_eq!(state_and_queue & STATE_MASK, RUNNING); in drop()
|
| /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/pigweed/pw_watch/py/pw_watch/ |
| D | debounce.py | 52 RUNNING = 3 # ---- Transistions to: INTERRUPTED or COOLDOWN variable in State
94 elif self.state == State.RUNNING:
139 self._transition(State.RUNNING)
148 if self.state == State.RUNNING:
|
| /external/webrtc/sdk/android/src/java/org/webrtc/ |
| D | Camera1Session.java | 34 private static enum SessionState { RUNNING, STOPPED } enumConstant
195 state = SessionState.RUNNING; in startCapturing()
252 if (state != SessionState.RUNNING) { in listenForTextureFrames()
288 if (state != SessionState.RUNNING) { in listenForBytebufferFrames()
304 if (state == SessionState.RUNNING) { in listenForBytebufferFrames()
|
| /external/python/cpython3/Lib/concurrent/futures/ |
| D | _base.py | 19 RUNNING = 'RUNNING' variable
28 RUNNING,
36 RUNNING: "running",
360 if self._state in [RUNNING, FINISHED]:
380 return self._state == RUNNING
510 self._state = RUNNING
|
| /external/libchrome/base/profiler/ |
| D | stack_sampling_profiler.cc | 219 RUNNING, enumerator
303 if (state == RUNNING) { in Reset()
339 DCHECK_EQ(RUNNING, state); in ShutdownAssumingIdle()
402 if (state != RUNNING) in Remove()
422 if (thread_execution_state_ == RUNNING) { in GetOrCreateTaskRunnerForAdd()
454 thread_execution_state_ = RUNNING; in GetOrCreateTaskRunnerForAdd()
470 if (thread_execution_state_ == RUNNING) { in GetTaskRunner()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/debug/internal/ |
| D | DebugCoroutineInfoImpl.kt | 12 internal const val RUNNING = "RUNNING" constant
92 lastObservedThread = if (state == RUNNING) { in updateState()
|
| /external/python/futures/concurrent/futures/ |
| D | _base.py | 20 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/llvm-project/llvm/utils/benchmark/docs/ |
| D | tools.md | 43 RUNNING: test/basic_test --benchmark_filter=BM_empty.* --benchmark_out=/tmp/tmpN7LF3a
53 RUNNING: /test/basic_test --benchmark_filter=BM_empty.* --benchmark_out=/tmp/tmplvrIp8
94 RUNNING: ./a.out --benchmark_out=/tmp/tmprBT5nW
110 RUNNING: ./a.out --benchmark_out=/tmp/tmpt1wwG_
159 RUNNING: ./a.out --benchmark_filter=BM_memcpy --benchmark_out=/tmp/tmpBWKk0k
170 RUNNING: ./a.out --benchmark_filter=BM_copy --benchmark_out=/tmp/tmpAvWcOM
210 RUNNING: ./a.out --benchmark_filter=BM_memcpy --benchmark_out=/tmp/tmp_FvbYg
221 RUNNING: ./a.out --benchmark_filter=BM_copy --benchmark_out=/tmp/tmpDfL5iE
|