| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ChannelExecutorTest.java | 58 private Runnable task2; field in ChannelExecutorTest
74 executor.executeLater(task2); in singleThread()
75 InOrder inOrder = inOrder(task1, task2, task3); in singleThread()
79 inOrder.verify(task2).run(); in singleThread()
89 InOrder inOrder = inOrder(task1, task2); in multiThread()
118 }).when(task2).run(); in multiThread()
132 executor.executeLater(task2); in multiThread()
143 inOrder.verify(task2).run(); in multiThread()
151 InOrder inOrder = inOrder(task1, task2, task3); in taskThrows()
158 }).when(task2).run(); in taskThrows()
[all …]
|
| /external/rust/crates/tokio/tests/ |
| D | sync_oneshot.rs | 226 let mut task2 = task::spawn(()); in receiver_changes_task() localVariable
231 assert_eq!(1, task2.waker_ref_count()); in receiver_changes_task()
233 assert_pending!(task2.enter(|cx, _| Pin::new(&mut rx).poll(cx))); in receiver_changes_task()
236 assert_eq!(2, task2.waker_ref_count()); in receiver_changes_task()
241 assert!(task2.is_woken()); in receiver_changes_task()
243 assert_ready_ok!(task2.enter(|cx, _| Pin::new(&mut rx).poll(cx))); in receiver_changes_task()
251 let mut task2 = task::spawn(()); in sender_changes_task() localVariable
256 assert_eq!(1, task2.waker_ref_count()); in sender_changes_task()
258 assert_pending!(task2.enter(|cx, _| tx.poll_closed(cx))); in sender_changes_task()
261 assert_eq!(2, task2.waker_ref_count()); in sender_changes_task()
[all …]
|
| D | sync_broadcast.rs | 155 let mut task2 = task::spawn(&mut recv); in change_tasks() localVariable
156 assert_pending!(task2.poll()); in change_tasks()
160 assert!(task2.is_woken()); in change_tasks()
|
| D | task_local_set.rs | 417 let task2 = task::spawn(async move { in local_tasks_are_polled_after_tick() localVariable
453 task2.await.unwrap(); in local_tasks_are_polled_after_tick()
|
| /external/lottie/lottie/src/test/java/com/airbnb/lottie/ |
| D | LottieCompositionFactoryTest.java | 95 LottieTask<LottieComposition> task2 = LottieCompositionFactory.fromJsonReader(reader, null); in testNullMultipleTimesAsync() local
96 assertFalse(task1 == task2); in testNullMultipleTimesAsync()
103 … LottieResult<LottieComposition> task2 = LottieCompositionFactory.fromJsonReaderSync(reader, null); in testNullMultipleTimesSync() local
104 assertFalse(task1 == task2); in testNullMultipleTimesSync()
111 … LottieTask<LottieComposition> task2 = 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 | 148 TestRunnable task2 = new TestRunnable(); in testPostDelayedTwiceThenRunMainLooperToNextTask_shouldRunMultipleTasks() local
151 new Handler().postDelayed(task2, 1); in testPostDelayedTwiceThenRunMainLooperToNextTask_shouldRunMultipleTasks()
155 assertThat(task2.wasRun).isTrue(); in testPostDelayedTwiceThenRunMainLooperToNextTask_shouldRunMultipleTasks()
161 TestRunnable task2 = new TestRunnable(); in testPostDelayedTwiceThenRunMainLooperOneTask_shouldRunOnlyOneTask() local
164 new Handler().postDelayed(task2, 1); in testPostDelayedTwiceThenRunMainLooperOneTask_shouldRunOnlyOneTask()
168 assertThat(task2.wasRun).isFalse(); in testPostDelayedTwiceThenRunMainLooperOneTask_shouldRunOnlyOneTask()
174 TestRunnable task2 = new TestRunnable(); in testPostDelayedMultipleThenRunMainLooperOneTask_shouldRunMultipleTask() local
178 new Handler().postDelayed(task2, 10); in testPostDelayedMultipleThenRunMainLooperOneTask_shouldRunMultipleTask()
183 assertThat(task2.wasRun).isTrue(); in testPostDelayedMultipleThenRunMainLooperOneTask_shouldRunMultipleTask()
190 TestRunnable task2 = new TestRunnable(); in testPostAtFrontOfQueueThenRunMainLooperOneTaskAtATime_shouldRunFrontOfQueueTaskFirst() local
[all …]
|
| D | ShadowActivityManagerTest.java | 58 …final ActivityManager.RunningTaskInfo task2 = 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()
70 final AppTask task2 = 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 | 37 Task *task2 = new Task(2, NULL); in main() local
43 task1->next = task2; in main()
44 task2->next = task4; in main()
|
| /external/llvm-project/lldb/test/API/python_api/value/linked_list/ |
| D | main.cpp | 18 Task *task2 = new Task(2, NULL); in main() local
24 task1->next = task2; in main()
25 task2->next = task4; in main()
|
| /external/libcxx/test/std/utilities/function.objects/bind/func.bind/func.bind.bind/ |
| D | copy.pass.cpp | 34 auto task2(task); in main() local
36 assert(task2() == 16); in main()
|
| /external/llvm-project/libcxx/test/std/utilities/function.objects/bind/func.bind/func.bind.bind/ |
| D | copy.pass.cpp | 35 auto task2(task); in main() local
37 assert(task2() == 16); in main()
|
| /external/libchrome/base/debug/ |
| D | task_annotator_unittest.cc | 169 OnceClosure task2 = BindOnce( in TEST_F() local
177 ExpectedTrace({location0.program_counter()}), std::move(task2)); in TEST_F()
339 OnceClosure task2 = BindOnce( in TEST_F() local
351 OnceClosure task2) { in TEST_F() argument
354 ThreadTaskRunnerHandle::Get()->PostTask(location2, std::move(task2)); in TEST_F()
356 Unretained(&nested_run_loop2), location2, std::move(task2)); in TEST_F()
|
| D | activity_tracker_unittest.cc | 229 PendingTask task2(FROM_HERE, DoNothing()); in TEST_F() local
230 ScopedTaskRunActivity activity2(task2); in TEST_F()
|
| /external/llvm-project/openmp/runtime/test/tasking/ |
| D | taskdep_if0.c | 15 void task2() { in task2() function
29 task2(); in main()
|
| /external/webrtc/rtc_base/task_utils/ |
| D | to_queued_task_unittest.cc | 136 auto task2 = ToQueuedTask(flag, [&count]() { ++count; }); in TEST() local
143 RunTask(std::move(task2)); in TEST()
|
| /external/libchrome/base/test/ |
| D | test_mock_time_task_runner_unittest.cc | 247 CancelableClosure task2(Bind([]() {})); in TEST() local
248 task_runner->PostDelayedTask(FROM_HERE, task2.callback(), in TEST()
250 task2.Cancel(); in TEST()
|
| /external/exoplayer/tree/library/core/src/test/java/com/google/android/exoplayer2/offline/ |
| D | DownloadManagerTest.java | 123 TaskWrapper task2 = new DownloadRunner(uri2).postDownloadRequest().getTask(); in requestsForDifferentContent_executedOnDifferentTasks() local
126 assertThat(task1).isNoneOf(task2, task3); in requestsForDifferentContent_executedOnDifferentTasks()
127 assertThat(task2).isNotEqualTo(task3); in requestsForDifferentContent_executedOnDifferentTasks()
375 TaskWrapper task2 = new DownloadRunner(uri2).postDownloadRequest().getTask(); in getCurrentDownloads_returnsCurrentDownloads() local
383 String[] taskIds = {task1.taskId, task2.taskId, task3.taskId}; in getCurrentDownloads_returnsCurrentDownloads()
|
| /external/python/cpython2/Lib/test/ |
| D | test_thread.py | 193 thread.start_new_thread(self.task2, (i,))
198 def task2(self, ident): member in BarrierTest
|
| /external/python/cpython3/Lib/test/ |
| D | test_thread.py | 187 thread.start_new_thread(self.task2, (i,))
192 def task2(self, ident): member in BarrierTest
|
| /external/libchrome/base/task/sequence_manager/ |
| D | sequence_manager_impl_unittest.cc | 1998 CancelableTask task2(GetTickClock()); in TEST_P() local
2008 task2.weak_factory_.GetWeakPtr(), &run_times), in TEST_P()
2333 CancelableTask task2(GetTickClock()); in TEST_P() local
2349 task2.weak_factory_.GetWeakPtr(), &run_times), in TEST_P()
2362 task2.weak_factory_.InvalidateWeakPtrs(); in TEST_P()
2384 CancelableTask task2(GetTickClock()); in TEST_P() local
2405 task2.weak_factory_.GetWeakPtr(), &run_times), in TEST_P()
2413 task2.weak_factory_.InvalidateWeakPtrs(); in TEST_P()
2435 CancelableTask task2(GetTickClock()); in TEST_P() local
2451 task2.weak_factory_.GetWeakPtr(), &run_times), in TEST_P()
[all …]
|
| D | task_queue_selector_unittest.cc | 807 TaskQueueImpl::Task task2(TaskQueue::PostedTask(test_closure_, FROM_HERE), in TEST_F() local
811 task_queue2->immediate_work_queue()->Push(std::move(task2)); in TEST_F()
|
| /external/tensorflow/tensorflow/core/grappler/optimizers/ |
| D | memory_optimizer.cc | 1277 string task2; in CrossesTaskOrCpuGpuBoundary() local
1279 DeviceNameUtils::SplitDeviceName(node2.device(), &task2, &device2); in CrossesTaskOrCpuGpuBoundary()
1280 return task1 != task2 || in CrossesTaskOrCpuGpuBoundary()
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_tasks.py | 2043 self.assertTrue(asyncio.current_task(loop=loop) is task2)
2046 self.assertTrue(asyncio.current_task(loop=loop) is task2)
2049 task2 = self.new_task(self.loop, coro2(self.loop))
2051 self.loop.run_until_complete(asyncio.wait((task1, task2)))
3085 task2 = mock.Mock()
3089 self._enter_task(loop, task2)
3102 task2 = mock.Mock()
3106 self._leave_task(loop, task2)
|
| /external/autotest/frontend/afe/ |
| D | rpc_interface_unittest.py | 933 self.task2 = models.SpecialTask.objects.create(
955 self.task2.time_started = datetime.datetime(2009, 1, 2)
956 self.task2.save()
|
| /external/python/cpython3/Doc/library/ |
| D | asyncio-task.rst | 86 task2 = asyncio.create_task(
94 await task2
|