| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ChannelExecutorTest.java | 55 private Runnable task1; field in ChannelExecutorTest
73 executor.executeLater(task1); in singleThread()
75 InOrder inOrder = inOrder(task1, task2, task3); in singleThread()
78 inOrder.verify(task1).run(); in singleThread()
89 InOrder inOrder = inOrder(task1, task2); in multiThread()
110 }).when(task1).run(); in multiThread()
123 executor.executeLater(task1); in multiThread()
137 inOrder.verify(task1).run(); in multiThread()
151 InOrder inOrder = inOrder(task1, task2, task3); in taskThrows()
159 executor.executeLater(task1); in taskThrows()
[all …]
|
| /external/tensorflow/tensorflow/core/kernels/batching_util/ |
| D | batch_scheduler_test.cc | 57 auto task1 = new FakeTask(7); in TEST() local
58 batch.AddTask(std::unique_ptr<FakeTask>(task1)); in TEST()
62 EXPECT_EQ(task0->size() + task1->size(), batch.size()); in TEST()
63 EXPECT_EQ(task1->size(), batch.task(1).size()); in TEST()
64 EXPECT_EQ(task1->size(), batch.mutable_task(1)->size()); in TEST()
72 EXPECT_EQ(task0->size() + task1->size(), batch.size()); in TEST()
74 EXPECT_EQ(task1->size(), batch.task(1).size()); in TEST()
|
| /external/rust/crates/tokio/tests/ |
| D | sync_oneshot.rs | 225 let mut task1 = task::spawn(()); in receiver_changes_task() localVariable
228 assert_pending!(task1.enter(|cx, _| Pin::new(&mut rx).poll(cx))); in receiver_changes_task()
230 assert_eq!(2, task1.waker_ref_count()); in receiver_changes_task()
235 assert_eq!(1, task1.waker_ref_count()); in receiver_changes_task()
240 assert!(!task1.is_woken()); in receiver_changes_task()
250 let mut task1 = task::spawn(()); in sender_changes_task() localVariable
253 assert_pending!(task1.enter(|cx, _| tx.poll_closed(cx))); in sender_changes_task()
255 assert_eq!(2, task1.waker_ref_count()); in sender_changes_task()
260 assert_eq!(1, task1.waker_ref_count()); in sender_changes_task()
265 assert!(!task1.is_woken()); in sender_changes_task()
|
| D | sync_broadcast.rs | 152 let mut task1 = task::spawn(&mut recv); in change_tasks() localVariable
153 assert_pending!(task1.poll()); in change_tasks()
|
| /external/lottie/lottie/src/test/java/com/airbnb/lottie/ |
| D | LottieCompositionFactoryTest.java | 94 LottieTask<LottieComposition> task1 = LottieCompositionFactory.fromJsonReader(reader, null); in testNullMultipleTimesAsync() local
96 assertFalse(task1 == task2); in testNullMultipleTimesAsync()
102 … LottieResult<LottieComposition> task1 = LottieCompositionFactory.fromJsonReaderSync(reader, null); in testNullMultipleTimesSync() local
104 assertFalse(task1 == task2); in testNullMultipleTimesSync()
110 … LottieTask<LottieComposition> task1 = LottieCompositionFactory.fromJsonReader(reader, "foo"); in testCacheWorks() local
112 assertTrue(task1 == task2); in testCacheWorks()
|
| /external/robolectric-shadows/robolectric/src/test/java/org/robolectric/shadows/ |
| D | ShadowHandlerTest.java | 147 TestRunnable task1 = new TestRunnable(); in testPostDelayedTwiceThenRunMainLooperToNextTask_shouldRunMultipleTasks() local
150 new Handler().postDelayed(task1, 1); in testPostDelayedTwiceThenRunMainLooperToNextTask_shouldRunMultipleTasks()
154 assertThat(task1.wasRun).isTrue(); in testPostDelayedTwiceThenRunMainLooperToNextTask_shouldRunMultipleTasks()
160 TestRunnable task1 = new TestRunnable(); in testPostDelayedTwiceThenRunMainLooperOneTask_shouldRunOnlyOneTask() local
163 new Handler().postDelayed(task1, 1); in testPostDelayedTwiceThenRunMainLooperOneTask_shouldRunOnlyOneTask()
167 assertThat(task1.wasRun).isTrue(); in testPostDelayedTwiceThenRunMainLooperOneTask_shouldRunOnlyOneTask()
173 TestRunnable task1 = new TestRunnable(); in testPostDelayedMultipleThenRunMainLooperOneTask_shouldRunMultipleTask() local
177 new Handler().postDelayed(task1, 1); in testPostDelayedMultipleThenRunMainLooperOneTask_shouldRunMultipleTask()
182 assertThat(task1.wasRun).isTrue(); in testPostDelayedMultipleThenRunMainLooperOneTask_shouldRunMultipleTask()
189 TestRunnable task1 = new TestRunnable(); in testPostAtFrontOfQueueThenRunMainLooperOneTaskAtATime_shouldRunFrontOfQueueTaskFirst() local
[all …]
|
| D | ShadowActivityManagerTest.java | 57 …final ActivityManager.RunningTaskInfo task1 = buildTaskInfo(new ComponentName("org.robolectric", "… in getRunningTasks_shouldReturnTaskList() local
61 shadowOf(activityManager).setTasks(Lists.newArrayList(task1, task2)); in getRunningTasks_shouldReturnTaskList()
62 assertThat(activityManager.getRunningTasks(Integer.MAX_VALUE)).containsExactly(task1, task2); in getRunningTasks_shouldReturnTaskList()
69 final AppTask task1 = ShadowAppTask.newInstance(); in getAppTasks_shouldReturnAppTaskList() local
73 shadowOf(activityManager).setAppTasks(Lists.newArrayList(task1, task2)); in getAppTasks_shouldReturnAppTaskList()
74 assertThat(activityManager.getAppTasks()).containsExactly(task1, task2); in getAppTasks_shouldReturnAppTaskList()
|
| /external/llvm-project/lldb/test/API/python_api/type/ |
| D | main.cpp | 36 Task *task1 = new Task(1, NULL); in main() local
42 task_head->next = task1; in main()
43 task1->next = task2; in main()
|
| /external/llvm-project/lldb/test/API/python_api/value/linked_list/ |
| D | main.cpp | 17 Task *task1 = new Task(1, NULL); in main() local
23 task_head = task1; in main()
24 task1->next = task2; in main()
|
| /external/llvm-project/openmp/runtime/test/tasking/ |
| D | taskdep_if0.c | 10 void task1() { in task1() function
26 task1(); in main()
|
| /external/libchrome/base/debug/ |
| D | task_annotator_unittest.cc | 174 OnceClosure task1 = in TEST_F() local
181 ExpectedTrace({}), std::move(task1)); in TEST_F()
349 OnceClosure task1 = BindOnce( in TEST_F() local
361 ExpectedTrace({}), std::move(task1)); in TEST_F()
|
| D | activity_tracker_unittest.cc | 218 PendingTask task1(FROM_HERE, DoNothing()); in TEST_F() local
219 ScopedTaskRunActivity activity1(task1); in TEST_F()
|
| /external/webrtc/rtc_base/task_utils/ |
| D | to_queued_task_unittest.cc | 135 auto task1 = ToQueuedTask(flag, [&count]() { ++count; }); in TEST() local
139 RunTask(std::move(task1)); in TEST()
|
| /external/libchrome/base/test/ |
| D | test_mock_time_task_runner_unittest.cc | 238 CancelableClosure task1(Bind([]() {})); in TEST() local
239 task_runner->PostDelayedTask(FROM_HERE, task1.callback(), in TEST()
244 task1.Cancel(); in TEST()
|
| /external/libchrome/base/task/sequence_manager/ |
| D | sequence_manager_impl_unittest.cc | 1997 CancelableTask task1(GetTickClock()); in TEST_P() local
2003 task1.weak_factory_.GetWeakPtr(), &run_times), in TEST_P()
2011 task1.weak_factory_.InvalidateWeakPtrs(); in TEST_P()
2332 CancelableTask task1(GetTickClock()); in TEST_P() local
2344 task1.weak_factory_.GetWeakPtr(), &run_times), in TEST_P()
2383 CancelableTask task1(GetTickClock()); in TEST_P() local
2410 task1.weak_factory_.GetWeakPtr(), &run_times), in TEST_P()
2434 CancelableTask task1(GetTickClock()); in TEST_P() local
2446 task1.weak_factory_.GetWeakPtr(), &run_times), in TEST_P()
2473 task1.weak_factory_.InvalidateWeakPtrs(); in TEST_P()
[all …]
|
| D | task_queue_selector_unittest.cc | 804 TaskQueueImpl::Task task1(TaskQueue::PostedTask(test_closure_, FROM_HERE), in TEST_F() local
810 task_queue->immediate_work_queue()->Push(std::move(task1)); in TEST_F()
|
| /external/autotest/server/lib/ |
| D | status_history.py | 677 task1 = query1.order_by('time_started')[0]
679 task1.time_finished.strftime(time_utils.TIME_FMT)]
|
| /external/exoplayer/tree/library/core/src/test/java/com/google/android/exoplayer2/offline/ |
| D | DownloadManagerTest.java | 122 TaskWrapper task1 = new DownloadRunner(uri1).postDownloadRequest().getTask(); in requestsForDifferentContent_executedOnDifferentTasks() local
126 assertThat(task1).isNoneOf(task2, task3); in requestsForDifferentContent_executedOnDifferentTasks()
374 TaskWrapper task1 = new DownloadRunner(uri1).postDownloadRequest().getTask(); in getCurrentDownloads_returnsCurrentDownloads() local
383 String[] taskIds = {task1.taskId, task2.taskId, task3.taskId}; in getCurrentDownloads_returnsCurrentDownloads()
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_tasks.py | 2037 self.assertTrue(asyncio.current_task(loop=loop) is task1)
2039 self.assertTrue(asyncio.current_task(loop=loop) is task1)
2048 task1 = self.new_task(self.loop, coro1(self.loop))
2051 self.loop.run_until_complete(asyncio.wait((task1, task2)))
3084 task1 = mock.Mock()
3087 self._enter_task(loop, task1)
3090 self.assertIs(asyncio.current_task(loop), task1)
3091 self._leave_task(loop, task1)
3101 task1 = mock.Mock()
3104 self._enter_task(loop, task1)
[all …]
|
| /external/tensorflow/tensorflow/core/grappler/optimizers/ |
| D | memory_optimizer.cc | 1274 string task1; in CrossesTaskOrCpuGpuBoundary() local
1276 DeviceNameUtils::SplitDeviceName(node1.device(), &task1, &device1); in CrossesTaskOrCpuGpuBoundary()
1280 return task1 != task2 || in CrossesTaskOrCpuGpuBoundary()
|
| /external/python/cpython2/Doc/tutorial/ |
| D | stdlib2.rst | 312 >>> d = deque(["task1", "task2", "task3"])
315 Handling task1
|
| /external/python/cpython3/Doc/tutorial/ |
| D | stdlib2.rst | 314 >>> d = deque(["task1", "task2", "task3"])
317 Handling task1
|
| /external/python/cpython3/Doc/library/ |
| D | asyncio-task.rst | 83 task1 = asyncio.create_task(
93 await task1
|
| /external/libabigail/tools/ |
| D | abipkgdiff.cc | 2539 elf_size_is_greater(const task_sptr &task1, in elf_size_is_greater() argument
2542 compare_task_sptr t1 = dynamic_pointer_cast<compare_task>(task1); in elf_size_is_greater()
|
| /external/autotest/frontend/afe/ |
| D | rpc_interface_unittest.py | 929 self.task1 = models.SpecialTask.objects.create(
|