| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | AbstractService.java | 22 import static com.google.common.util.concurrent.Service.State.RUNNING;
82 stoppingEvent(RUNNING);
89 terminatedEvent(RUNNING);
147 return state().compareTo(RUNNING) <= 0;
161 return state().compareTo(RUNNING) >= 0;
280 case RUNNING:
282 enqueueStoppingEvent(RUNNING);
305 checkCurrentState(RUNNING);
321 checkCurrentState(RUNNING);
413 snapshot = new StateSnapshot(RUNNING);
[all …]
|
| D | SequentialExecutor.java | 21 import static com.google.common.util.concurrent.SequentialExecutor.WorkerRunningState.RUNNING;
62 RUNNING, enumConstant
106 if (workerRunningState == RUNNING || workerRunningState == QUEUED) { in execute()
212 if (workerRunningState == RUNNING) { in workOnQueue()
220 workerRunningState = RUNNING; in workOnQueue()
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | AbstractService.java | 22 import static com.google.common.util.concurrent.Service.State.RUNNING;
81 stoppingEvent(RUNNING);
88 terminatedEvent(RUNNING);
146 return state().compareTo(RUNNING) <= 0;
160 return state().compareTo(RUNNING) >= 0;
279 case RUNNING:
281 enqueueStoppingEvent(RUNNING);
304 checkCurrentState(RUNNING);
314 checkCurrentState(RUNNING);
400 snapshot = new StateSnapshot(RUNNING);
[all …]
|
| D | SequentialExecutor.java | 21 import static com.google.common.util.concurrent.SequentialExecutor.WorkerRunningState.RUNNING;
62 RUNNING, enumConstant
106 if (workerRunningState == RUNNING || workerRunningState == QUEUED) { in execute()
212 if (workerRunningState == RUNNING) { in workOnQueue()
220 workerRunningState = RUNNING; in workOnQueue()
|
| /external/apache-commons-lang/src/main/java/org/apache/commons/lang3/time/ |
| D | StopWatch.java | 75 RUNNING { enumConstant
290 if (this.runningState == State.RUNNING) { in getNanoTime()
459 this.runningState = State.RUNNING; in resume()
474 if (this.runningState != State.RUNNING) { in split()
500 this.runningState = State.RUNNING; in start()
514 if (this.runningState != State.RUNNING && this.runningState != State.SUSPENDED) { in stop()
517 if (this.runningState == State.RUNNING) { in stop()
536 if (this.runningState != State.RUNNING) { in suspend()
|
| /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/async-task/src/ |
| D | raw.rs | 253 if state & RUNNING == 0 { in wake()
296 let new = if state & RUNNING == 0 { in wake_by_ref()
311 if state & RUNNING == 0 { in wake_by_ref()
495 (state & !SCHEDULED) | RUNNING, in run()
501 state = (state & !SCHEDULED) | RUNNING; in run()
524 (state & !RUNNING & !SCHEDULED) | COMPLETED | CLOSED in run()
526 (state & !RUNNING & !SCHEDULED) | COMPLETED in run()
571 state & !RUNNING & !SCHEDULED in run()
573 state & !RUNNING in run()
656 .fetch_and(!RUNNING & !SCHEDULED, Ordering::AcqRel); in run()
[all …]
|
| D | task.rs | 195 let new = if state & (SCHEDULED | RUNNING) == 0 { in set_canceled()
211 if state & (SCHEDULED | RUNNING) == 0 { in set_canceled()
329 if state & (SCHEDULED | RUNNING) != 0 { in poll_task()
339 if state & (SCHEDULED | RUNNING) != 0 { in poll_task()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/debug/internal/ |
| D | DebugCoroutineInfoImpl.kt | 12 internal const val RUNNING = "RUNNING" constant
91 if (_state == RUNNING && state == RUNNING && shouldBeMatched) { in updateState()
121 lastObservedThread = if (state == RUNNING) { in updateState()
|
| /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/tracing-core/src/spin/ |
| D | once.rs | 34 const RUNNING: usize = 0x1; constant
79 RUNNING, in call_once()
109 RUNNING => { in call_once()
136 RUNNING => { in wait()
|
| /external/rust/crates/tokio/src/runtime/task/ |
| D | state.rs | 18 const RUNNING: usize = 0b0001; constant
184 const DELTA: usize = RUNNING | COMPLETE; in transition_to_complete()
500 self.0 & (RUNNING | COMPLETE) == 0 in is_idle()
517 self.0 & RUNNING == RUNNING in is_running()
521 self.0 |= RUNNING; in set_running()
525 self.0 &= !RUNNING; in unset_running()
|
| /external/rust/crates/once_cell/src/ |
| D | imp_pl.rs | 13 const RUNNING: u8 = 0x1; constant
142 state.compare_exchange_weak(INCOMPLETE, RUNNING, Ordering::Acquire, Ordering::Acquire); in initialize_inner()
152 Err(RUNNING) => unsafe { in initialize_inner()
156 || state.load(Ordering::Relaxed) == RUNNING, in initialize_inner()
|
| /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 | 57 RUNNING = 3 # ---- Transistions to: INTERRUPTED or COOLDOWN variable in State
100 elif self.state == State.RUNNING:
149 self._transition(State.RUNNING)
158 if self.state == State.RUNNING:
|
| /external/cronet/base/android/java/src/org/chromium/base/task/ |
| D | AsyncTask.java | 82 @IntDef({Status.PENDING, Status.RUNNING, Status.FINISHED})
92 int RUNNING = 1; field
170 if (mStatus == Status.RUNNING && !mTaskInvoked.get()) return Status.PENDING; in getUmaStatus()
372 case Status.RUNNING: in executionPreamble()
382 mStatus = Status.RUNNING; in executionPreamble()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-debug/test/ |
| D | DebugProbesTest.kt | 119 assertEquals(setOf(State.RUNNING, State.SUSPENDED), infos.map { it.state }.toSet()) in testMultipleConsecutiveProbeResumed()
143 assertEquals(setOf(State.RUNNING, State.RUNNING), infos.map { it.state }.toSet()) in <lambda>()
|
| /external/cronet/base/profiler/ |
| D | stack_sampling_profiler.cc | 211 RUNNING, enumerator
310 if (state == RUNNING) { in Reset()
346 DCHECK_EQ(RUNNING, state); in ShutdownAssumingIdle()
409 if (state != RUNNING) in AddAuxUnwinder()
426 if (state != RUNNING) in ApplyMetadataToPastSamples()
442 if (state != RUNNING) { in AddProfileMetadata()
456 if (state != RUNNING) in Remove()
476 if (thread_execution_state_ == RUNNING) { in GetOrCreateTaskRunnerForAdd()
508 thread_execution_state_ = RUNNING; in GetOrCreateTaskRunnerForAdd()
524 if (thread_execution_state_ == RUNNING) { in GetTaskRunner()
|
| /external/cronet/base/android/junit/src/org/chromium/base/task/ |
| D | AsyncTaskThreadTest.java | 173 assertEquals(Status.RUNNING, mTask.getStatus()); in testCancel_CanReturnTrueEvenAfterTaskStarts()
192 assertEquals(Status.RUNNING, mTask.getStatus()); in testCancel_CanReturnTrueEvenAfterTaskStarts()
226 assertEquals(Status.RUNNING, mTask.getStatus()); in testCancel_MayInterrupt_TaskIsInterrupted()
247 assertEquals(Status.RUNNING, mTask.getStatus()); in testCancel_MayInterrupt_TaskIsInterrupted()
|
| /external/webrtc/sdk/android/src/java/org/webrtc/ |
| D | Camera1Session.java | 35 private static enum SessionState { RUNNING, STOPPED } enumConstant
207 state = SessionState.RUNNING; in startCapturing()
264 if (state != SessionState.RUNNING) { in listenForTextureFrames()
300 if (state != SessionState.RUNNING) { in listenForBytebufferFrames()
316 if (state == SessionState.RUNNING) { in listenForBytebufferFrames()
|