| /external/python/cpython3/Lib/concurrent/futures/ |
| D | _base.py | 24 FINISHED = 'FINISHED' variable
31 FINISHED
39 FINISHED: "finished"
164 f._state not in [CANCELLED_AND_NOTIFIED, FINISHED] for f in fs)
227 if f._state in [CANCELLED_AND_NOTIFIED, FINISHED])
291 if f._state in [CANCELLED_AND_NOTIFIED, FINISHED])
335 if self._state == FINISHED:
360 if self._state in [RUNNING, FINISHED]:
385 return self._state in [CANCELLED, CANCELLED_AND_NOTIFIED, FINISHED]
405 if self._state not in [CANCELLED, CANCELLED_AND_NOTIFIED, FINISHED]:
[all …]
|
| /external/testng/src/test/java/test/ |
| D | DynamicGraphTest.java | 37 dg.setStatus("a1", Status.FINISHED); in test8()
40 dg.setStatus("a2", Status.FINISHED); in test8()
44 dg.setStatus("b1", Status.FINISHED); in test8()
47 dg.setStatus("b2", Status.FINISHED); in test8()
64 dg.setStatus("a1", Status.FINISHED); in test2()
67 dg.setStatus("a2", Status.FINISHED); in test2()
71 dg.setStatus("b1", Status.FINISHED); in test2()
|
| /external/python/futures/concurrent/futures/ |
| D | _base.py | 25 FINISHED = 'FINISHED' variable
32 FINISHED
40 FINISHED: "finished"
161 f._state not in [CANCELLED_AND_NOTIFIED, FINISHED] for f in fs)
224 if f._state in [CANCELLED_AND_NOTIFIED, FINISHED])
292 if f._state in [CANCELLED_AND_NOTIFIED, FINISHED])
353 if self._state == FINISHED:
378 if self._state in [RUNNING, FINISHED]:
403 return self._state in [CANCELLED, CANCELLED_AND_NOTIFIED, FINISHED]
430 if self._state not in [CANCELLED, CANCELLED_AND_NOTIFIED, FINISHED]:
[all …]
|
| /external/oboe/apps/OboeTester/app/src/main/java/com/mobileer/miditools/synth/ |
| D | EnvelopeADSR.java | 30 private static final int FINISHED = 5; field in EnvelopeADSR
104 mSstate = FINISHED; in render()
112 return mSstate == FINISHED; in isDone()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/ |
| D | Interruptible.kt | 56 private const val FINISHED = 1 constant
116 WORKING -> if (_state.compareAndSet(state, FINISHED)) { in clearInterrupt()
149 FINISHED, INTERRUPTING, INTERRUPTED -> return in invoke()
|
| /external/testng/src/main/java/org/testng/internal/ |
| D | DynamicGraph.java | 31 READY, RUNNING, FINISHED enumConstant
115 case FINISHED: m_nodesFinished.add(node); break; in setStatus()
140 case FINISHED: return m_nodesFinished.size(); in getNodeCountWithStatus()
182 String FINISHED = "[style=filled color=grey]"; in toDot() local
195 result.append(" " + getName(n) + FINISHED+ "\n"); in toDot()
|
| /external/testng/src/main/java/org/testng/internal/thread/graph/ |
| D | GraphThreadPoolExecutor.java | 81 if (status == Status.FINISHED) { in setStatus()
94 setStatus((IWorker<T>) r, Status.FINISHED); in afterExecute()
97 + m_graph.getNodeCountWithStatus(Status.FINISHED) + " finished"); in afterExecute()
98 if (m_graph.getNodeCount() == m_graph.getNodeCountWithStatus(Status.FINISHED)) { in afterExecute()
|
| /external/guava/guava-tests/benchmark/com/google/common/util/concurrent/ |
| D | AbstractFutureFootprintBenchmark.java | 36 FINISHED, enumConstant
92 case FINISHED: in measureSize()
|
| /external/guava/android/guava-tests/benchmark/com/google/common/util/concurrent/ |
| D | AbstractFutureFootprintBenchmark.java | 36 FINISHED, enumConstant
92 case FINISHED: in measureSize()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_response_cache.cc | 30 if (entry.state == ResponseCacheEntry::State::FINISHED) { in QueueRequest()
82 entry.state = ResponseCacheEntry::State::FINISHED; in OnRequestFinished()
|
| /external/tensorflow/tensorflow/core/platform/cloud/ |
| D | ram_file_block_cache.cc | 26 if (block->state != FetchState::FINISHED) { in BlockNotStale()
147 block->state = FetchState::FINISHED; in MaybeFetch()
155 if (block->state == FetchState::FINISHED) { in MaybeFetch()
160 case FetchState::FINISHED: in MaybeFetch()
|
| /external/tensorflow/tensorflow/c/experimental/filesystem/plugins/gcs/ |
| D | ram_file_block_cache.cc | 29 if (block->state != FetchState::FINISHED) { in BlockNotStale()
146 block->state = FetchState::FINISHED; in MaybeFetch()
154 if (block->state == FetchState::FINISHED) { in MaybeFetch()
159 case FetchState::FINISHED: in MaybeFetch()
|
| /external/python/futures/ |
| D | test_futures.py | 17 PENDING, RUNNING, CANCELLED, CANCELLED_AND_NOTIFIED, FINISHED, Future)
118 EXCEPTION_FUTURE = create_future(state=FINISHED, exception=IOError())
119 SUCCESSFUL_FUTURE = create_future(state=FINISHED, result=42)
650 f5 = create_future(state=FINISHED, exception=IOError())
651 f6 = create_future(state=FINISHED, result=5)
666 self.assertEqual(f5._state, FINISHED)
669 self.assertEqual(f6._state, FINISHED)
751 f1._state = FINISHED
|
| /external/swiftshader/src/Vulkan/ |
| D | VkQueryPool.cpp | 41 ASSERT(prevState != FINISHED); // Must be reset first in start()
49 auto prevState = state.exchange(FINISHED); in finish()
|
| /external/ltp/testcases/kernel/controllers/freezer/ |
| D | write_freezing.sh | 45 result=$FINISHED
|
| D | freeze_write_freezing.sh | 47 result=$FINISHED
|
| D | freeze_cancel.sh | 50 result=$FINISHED
|
| D | freeze_thaw.sh | 52 result=$FINISHED
|
| D | freeze_kill_thaw.sh | 72 result=$FINISHED
|
| D | freeze_sleep_thaw.sh | 69 result=$FINISHED
|
| D | fork_freeze.sh | 57 result=$FINISHED
|
| D | stop_freeze_thaw_cont.sh | 68 result=$FINISHED
|
| D | freeze_move_thaw.sh | 95 result=$FINISHED
|
| D | stop_freeze_sleep_thaw_cont.sh | 72 result=$FINISHED
|
| D | freeze_self_thaw.sh | 74 result=$FINISHED
|