| /external/vogar/src/vogar/tasks/ |
| D | TaskQueue.java | 94 for (Task blocker : task.tasksThatMustFinishFirst) { in printTasks()
95 message.append("\n depends on completed task: ").append(blocker); in printTasks()
97 for (Task blocker : task.tasksThatMustFinishSuccessfullyFirst) { in printTasks()
98 message.append("\n depends on successful task: ").append(blocker); in printTasks()
123 for (Task blocker : task.tasksThatMustFinishFirst) { in printProblemTasks()
124 if (blocker.result == null) { in printProblemTasks()
125 message.append("\n blocked by unexecuted task: ").append(blocker); in printProblemTasks()
128 for (Task blocker : task.tasksThatMustFinishSuccessfullyFirst) { in printProblemTasks()
129 if (blocker.result == null) { in printProblemTasks()
130 message.append("\n blocked by unexecuted task: ").append(blocker); in printProblemTasks()
[all …]
|
| /external/webrtc/modules/audio_processing/aec3/ |
| D | frame_blocker_unittest.cc | 116 FrameBlocker blocker(num_bands, num_channels); in RunBlockerTest() local
124 blocker.InsertSubFrameAndExtractBlock(input_sub_frame_view, &block); in RunBlockerTest()
128 EXPECT_TRUE(blocker.IsBlockAvailable()); in RunBlockerTest()
130 EXPECT_FALSE(blocker.IsBlockAvailable()); in RunBlockerTest()
132 if (blocker.IsBlockAvailable()) { in RunBlockerTest()
133 blocker.ExtractBlock(&block); in RunBlockerTest()
156 FrameBlocker blocker(num_bands, num_channels); in RunBlockerAndFramerTest() local
166 blocker.InsertSubFrameAndExtractBlock(input_sub_frame_view, &block); in RunBlockerAndFramerTest()
170 EXPECT_TRUE(blocker.IsBlockAvailable()); in RunBlockerAndFramerTest()
172 EXPECT_FALSE(blocker.IsBlockAvailable()); in RunBlockerAndFramerTest()
[all …]
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | InterruptibleTaskTest.java | 155 Object blocker = LockSupport.getBlocker(runner); in testInterruptIsSlow() local
156 assertThat(blocker).isInstanceOf(AbstractOwnableSynchronizer.class); in testInterruptIsSlow()
160 Thread owner = (Thread) getExclusiveOwnerThread.invoke(blocker); in testInterruptIsSlow()
171 private static void awaitBlockedOnInstanceOf(Thread t, Class<?> blocker) in awaitBlockedOnInstanceOf() argument
173 while (!isThreadBlockedOnInstanceOf(t, blocker)) { in awaitBlockedOnInstanceOf()
181 private static boolean isThreadBlockedOnInstanceOf(Thread t, Class<?> blocker) { in isThreadBlockedOnInstanceOf() argument
182 return t.getState() == Thread.State.WAITING && blocker.isInstance(LockSupport.getBlocker(t)); in isThreadBlockedOnInstanceOf()
|
| /external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| D | InterruptibleTaskTest.java | 155 Object blocker = LockSupport.getBlocker(runner); in testInterruptIsSlow() local
156 assertThat(blocker).isInstanceOf(AbstractOwnableSynchronizer.class); in testInterruptIsSlow()
160 Thread owner = (Thread) getExclusiveOwnerThread.invoke(blocker); in testInterruptIsSlow()
171 private static void awaitBlockedOnInstanceOf(Thread t, Class<?> blocker) in awaitBlockedOnInstanceOf() argument
173 while (!isThreadBlockedOnInstanceOf(t, blocker)) { in awaitBlockedOnInstanceOf()
181 private static boolean isThreadBlockedOnInstanceOf(Thread t, Class<?> blocker) { in isThreadBlockedOnInstanceOf() argument
182 return t.getState() == Thread.State.WAITING && blocker.isInstance(LockSupport.getBlocker(t)); in isThreadBlockedOnInstanceOf()
|
| /external/webrtc/modules/audio_coding/codecs/opus/test/ |
| D | blocker_unittest.cc | 61 void RunTest(Blocker* blocker, in RunTest() argument
74 blocker->ProcessChunk(input_chunk, chunk_size, num_input_channels, in RunTest()
151 Blocker blocker(kChunkSize, kBlockSize, kNumInputChannels, kNumOutputChannels, in TEST_F() local
154 RunTest(&blocker, kChunkSize, kNumFrames, input_cb.channels(), in TEST_F()
192 Blocker blocker(kChunkSize, kBlockSize, kNumInputChannels, kNumOutputChannels, in TEST_F() local
195 RunTest(&blocker, kChunkSize, kNumFrames, input_cb.channels(), in TEST_F()
233 Blocker blocker(kChunkSize, kBlockSize, kNumInputChannels, kNumOutputChannels, in TEST_F() local
236 RunTest(&blocker, kChunkSize, kNumFrames, input_cb.channels(), in TEST_F()
280 Blocker blocker(kChunkSize[i], kBlockSize[i], kNumInputChannels, in TEST_F() local
284 RunTest(&blocker, kChunkSize[i], kNumFrames, input_cb.channels(), in TEST_F()
|
| D | BUILD.gn | 23 "blocker.cc",
24 "blocker.h",
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | InterruptibleTask.java | 116 Blocker blocker = null; in waitForInterrupt() local
119 blocker = (Blocker) state; in waitForInterrupt()
143 LockSupport.park(blocker); in waitForInterrupt()
195 Blocker blocker = new Blocker(this); in interruptTask() local
196 blocker.setOwner(Thread.currentThread()); in interruptTask()
197 if (compareAndSet(currentRunner, blocker)) { in interruptTask()
|
| D | OverflowAvoidingLockSupport.java | 33 static void parkNanos(@CheckForNull Object blocker, long nanos) { in parkNanos() argument
36 LockSupport.parkNanos(blocker, min(nanos, MAX_NANOSECONDS_THRESHOLD)); in parkNanos()
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | InterruptibleTask.java | 116 Blocker blocker = null; in waitForInterrupt() local
119 blocker = (Blocker) state; in waitForInterrupt()
143 LockSupport.park(blocker); in waitForInterrupt()
195 Blocker blocker = new Blocker(this); in interruptTask() local
196 blocker.setOwner(Thread.currentThread()); in interruptTask()
197 if (compareAndSet(currentRunner, blocker)) { in interruptTask()
|
| D | OverflowAvoidingLockSupport.java | 33 static void parkNanos(@CheckForNull Object blocker, long nanos) { in parkNanos() argument
36 LockSupport.parkNanos(blocker, min(nanos, MAX_NANOSECONDS_THRESHOLD)); in parkNanos()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/ |
| D | AbstractTimeSource.kt | 21 abstract fun parkNanos(blocker: Any, nanos: Long) // should return immediately when nanos <= 0 in currentTimeMillis()
62 internal inline fun parkNanos(blocker: Any, nanos: Long) { in parkNanos()
63 timeSource?.parkNanos(blocker, nanos) ?: LockSupport.parkNanos(blocker, nanos) in parkNanos()
|
| /external/webrtc/api/ |
| D | sequence_checker_unittest.cc | 128 rtc::Event blocker; in TEST() local
129 queue1.PostTask([&blocker, &sequence_checker]() { in TEST()
131 blocker.Set(); in TEST()
134 blocker.Wait(rtc::Event::kForever); in TEST()
|
| /external/webrtc/api/task_queue/ |
| D | pending_task_safety_flag_unittest.cc | 134 rtc::Event blocker; in TEST() local
135 tq1.PostTask([&blocker, &owner]() { in TEST()
136 blocker.Wait(rtc::Event::kForever); in TEST()
144 blocker.Set(); in TEST()
|
| /external/cldr/tools/cldr-code/src/main/java/org/unicode/cldr/draft/ |
| D | ShortestCanonicalForm.java | 93 final int blocker = nfc.codePointAt(0);
94 if (!blockers.contains(blocker)) {
95 blockers.add(blocker);
96 … System.out.println("Adding blocker: " + Utility.hex(blocker, 4) + "\t"
97 + UTF16.valueOf(blocker));
|
| /external/mesa3d/src/gallium/auxiliary/rbug/ |
| D | rbug_context.h | 120 rbug_block_t blocker; member
181 rbug_block_t blocker,
|
| D | rbug_context.c | 378 rbug_block_t blocker, in rbug_send_context_info_reply() argument
412 WRITE(4, rbug_block_t, blocker); /* blocker */ in rbug_send_context_info_reply()
716 READ(4, rbug_block_t, blocker); /* blocker */ in rbug_demarshal_context_info_reply()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | VirtualTimeSource.kt | 97 override fun parkNanos(blocker: Any, nanos: Long) { in toString()
109 LockSupport.parkNanos(blocker, REAL_PARK_NANOS) in toString()
|
| /external/exoplayer/tree_8e57d3715f9092d5ec54ebe2e538f34bfcc34479/library/core/src/test/java/com/google/android/exoplayer2/offline/ |
| D | DownloadManagerTest.java | 890 private final ConditionVariable blocker; field in DownloadManagerTest.FakeDownloader
902 blocker = createRobolectricConditionVariable(); in FakeDownloader()
910 blocker.open(); in cancel()
948 blocker.open(); in finish()
955 blocker.open(); in fail()
991 blocker.block(); in block()
995 blocker.close(); in block()
|
| /external/exoplayer/tree_15dc86382f17a24a3e881e52e31a810c1ea44b49/library/core/src/test/java/com/google/android/exoplayer2/offline/ |
| D | DownloadManagerTest.java | 890 private final ConditionVariable blocker; field in DownloadManagerTest.FakeDownloader
902 blocker = createRobolectricConditionVariable(); in FakeDownloader()
910 blocker.open(); in cancel()
948 blocker.open(); in finish()
955 blocker.open(); in fail()
991 blocker.block(); in block()
995 blocker.close(); in block()
|
| /external/linux-kselftest/tools/testing/selftests/futex/functional/ |
| D | futex_requeue_pi.c | 283 pthread_t waiter[THREAD_MAX], waker, blocker; in unit_test() local
306 if (create_rt_thread(&blocker, third_party_blocker, in unit_test()
343 pthread_join(blocker, NULL); in unit_test()
|
| /external/mesa3d/src/gallium/auxiliary/driver_rbug/ |
| D | rbug_context.h | 73 int blocker; member
|
| /external/autotest/server/site_tests/audio_AudioTestAssumptionCheck/ |
| D | control.suspend | 31 # blocker is fixed
|
| /external/perfetto/infra/ui.perfetto.dev/ |
| D | README.md | 15 direct backing by a GCS bucket. The only blocker for that is figuring out
|
| /external/harfbuzz_ng/ |
| D | RELEASING.md | 15 …ward-incompatible API change (including deletions for API used anywhere), that's a release blocker.
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_locks.py | 171 async def lockit(name, blocker): argument
174 if blocker is not None:
175 await blocker
|