| /external/perfetto/src/base/ |
| D | task_runner_unittest.cc | 36 UnixTaskRunner task_runner; member in perfetto::base::__anonc7328b3f0111::TaskRunnerTest
40 auto& task_runner = this->task_runner; in TEST_F() local
42 task_runner.PostTask([&counter] { counter = (counter << 4) | 1; }); in TEST_F()
43 task_runner.PostTask([&counter] { counter = (counter << 4) | 2; }); in TEST_F()
44 task_runner.PostTask([&counter] { counter = (counter << 4) | 3; }); in TEST_F()
45 task_runner.PostTask([&counter] { counter = (counter << 4) | 4; }); in TEST_F()
46 task_runner.PostTask([&task_runner] { task_runner.Quit(); }); in TEST_F()
47 task_runner.Run(); in TEST_F()
52 auto& task_runner = this->task_runner; in TEST_F() local
54 task_runner.PostDelayedTask([&counter] { counter = (counter << 4) | 1; }, 5); in TEST_F()
[all …]
|
| D | periodic_task_unittest.cc | 37 TestTaskRunner task_runner; in TEST() local
38 PeriodicTask pt(&task_runner); in TEST()
40 auto quit_closure = task_runner.CreateCheckpoint("all_timers_done"); in TEST()
51 task_runner.RunUntilCheckpoint("all_timers_done"); in TEST()
56 TestTaskRunner task_runner; in TEST() local
57 PeriodicTask pt(&task_runner); in TEST()
59 auto quit_closure = task_runner.CreateCheckpoint("one_shot_done"); in TEST()
71 task_runner.RunUntilCheckpoint("one_shot_done"); in TEST()
77 TestTaskRunner task_runner; in TEST() local
78 PeriodicTask pt(&task_runner); in TEST()
[all …]
|
| D | thread_task_runner_unittest.cc | 35 ThreadTaskRunner task_runner = ThreadTaskRunner::CreateAndStart(); in TEST_F() local
36 task_runner.get()->PostTask([this] { atomic_flag_ = true; }); in TEST_F()
44 ThreadTaskRunner task_runner = ThreadTaskRunner::CreateAndStart(); in TEST_F() local
45 EXPECT_FALSE(task_runner.get()->RunsTasksOnCurrentThread()); in TEST_F()
48 task_runner.get()->PostTask([&thread_checker] { in TEST_F()
53 task_runner.get()->PostTask([this, &thread_checker] { in TEST_F()
67 ThreadTaskRunner& task_runner = ttr.ref(); in TEST_F() local
69 UnixTaskRunner* runner_ptr = task_runner.get(); in TEST_F()
73 task_runner.get()->PostTask([&thread_checker] { in TEST_F()
80 ThreadTaskRunner task_runner2 = std::move(task_runner); in TEST_F()
[all …]
|
| D | metatrace.cc | 49 base::TaskRunner* task_runner = nullptr; member
56 base::TaskRunner* task_runner, in Enable() argument
59 PERFETTO_DCHECK(task_runner->RunsTasksOnCurrentThread()); in Enable()
64 dg->task_runner = task_runner; in Enable()
75 PERFETTO_DCHECK(!dg->task_runner || in Disable()
76 dg->task_runner->RunsTasksOnCurrentThread()); in Disable()
77 dg->task_runner = nullptr; in Disable()
109 if (dg->task_runner) { in AppendNewRecord()
110 dg->task_runner->PostTask([] { in AppendNewRecord()
136 auto* task_runner = Delegate::GetInstance()->task_runner; in IsOnValidTaskRunner() local
[all …]
|
| /external/openscreen/platform/api/ |
| D | serial_delete_ptr.h | 24 explicit SerialDelete(TaskRunner* task_runner) in SerialDelete() argument
25 : task_runner_(task_runner), deleter_() { in SerialDelete()
26 assert(task_runner); in SerialDelete()
30 SerialDelete(TaskRunner* task_runner, DT&& deleter) in SerialDelete() argument
31 : task_runner_(task_runner), deleter_(std::forward<DT>(deleter)) { in SerialDelete()
32 assert(task_runner); in SerialDelete()
60 explicit SerialDeletePtr(TaskRunner* task_runner) noexcept in SerialDeletePtr() argument
63 SerialDelete<Type, DeleterType>(task_runner)) { in SerialDeletePtr()
64 assert(task_runner); in SerialDeletePtr()
67 SerialDeletePtr(TaskRunner* task_runner, std::nullptr_t) noexcept in SerialDeletePtr() argument
[all …]
|
| /external/libchrome/base/test/ |
| D | test_mock_time_task_runner_unittest.cc | 196 auto task_runner = MakeRefCounted<TestMockTimeTaskRunner>( in TEST() local
199 task_runner->PostTask(FROM_HERE, base::BindLambdaForTesting([&]() { in TEST()
202 task_runner->RunUntilIdle(); in TEST()
223 quitting_thread.task_runner()->PostDelayedTask( in TEST()
229 auto task_runner = MakeRefCounted<TestMockTimeTaskRunner>(); in TEST() local
230 task_runner->PostTask(FROM_HERE, Bind([]() {})); in TEST()
231 EXPECT_TRUE(task_runner->HasPendingTask()); in TEST()
232 EXPECT_EQ(1u, task_runner->TakePendingTasks().size()); in TEST()
233 EXPECT_FALSE(task_runner->HasPendingTask()); in TEST()
237 auto task_runner = MakeRefCounted<TestMockTimeTaskRunner>(); in TEST() local
[all …]
|
| D | sequenced_task_runner_test_template.h | 44 void PostWrappedNonNestableTask(SequencedTaskRunner* task_runner,
48 void PostWrappedNestableTask(SequencedTaskRunner* task_runner,
52 void PostWrappedDelayedNonNestableTask(SequencedTaskRunner* task_runner,
57 void PostNonNestableTasks(SequencedTaskRunner* task_runner, int task_count);
135 const scoped_refptr<SequencedTaskRunner> task_runner = in TYPED_TEST_P() local
139 task_runner.get(), in TYPED_TEST_P()
142 this->task_tracker_->PostWrappedNonNestableTask(task_runner.get(), in TYPED_TEST_P()
159 const scoped_refptr<SequencedTaskRunner> task_runner = in TYPED_TEST_P() local
163 task_runner.get(), in TYPED_TEST_P()
166 this->task_tracker_->PostWrappedNestableTask(task_runner.get(), Closure()); in TYPED_TEST_P()
[all …]
|
| /external/perfetto/src/traced/service/ |
| D | builtin_producer_unittest.cc | 55 MockBuiltinProducer(base::TaskRunner* task_runner) in MockBuiltinProducer() argument
56 : BuiltinProducer(task_runner, /*lazy_stop_delay_ms=*/0) {} in MockBuiltinProducer()
67 base::TestTaskRunner task_runner; in TEST() local
68 auto done = task_runner.CreateCheckpoint("done"); in TEST()
69 StrictMock<MockBuiltinProducer> p(&task_runner); in TEST()
80 task_runner.RunUntilCheckpoint("done"); in TEST()
86 base::TestTaskRunner task_runner; in TEST() local
87 auto done = task_runner.CreateCheckpoint("done"); in TEST()
88 StrictMock<MockBuiltinProducer> p(&task_runner); in TEST()
99 task_runner.RunUntilCheckpoint("done"); in TEST()
[all …]
|
| /external/perfetto/src/traced_relay/ |
| D | relay_service_unittest.cc | 62 base::TestTaskRunner task_runner; in TEST() local
63 auto relay_service = std::make_unique<RelayService>(&task_runner); in TEST()
71 "127.0.0.1:0", &tcp_listener, &task_runner, base::SockFamily::kInet, in TEST()
83 unix_sock_name, &producer_listener, &task_runner, base::SockFamily::kUnix, in TEST()
85 auto producer_connected = task_runner.CreateCheckpoint("producer_connected"); in TEST()
92 task_runner.RunUntilCheckpoint("producer_connected"); in TEST()
102 task_runner.CreateCheckpoint("tcp_client_connected"); in TEST()
108 task_runner.RunUntilCheckpoint("tcp_client_connected"); in TEST()
111 auto peer_identity_recv = task_runner.CreateCheckpoint("peer_identity_recv"); in TEST()
133 task_runner.RunUntilCheckpoint("peer_identity_recv"); in TEST()
[all …]
|
| D | relay_service_integrationtest.cc | 47 base::TestTaskRunner task_runner; in TEST() local
54 &task_runner, base::SockFamily::kInet, in TEST()
62 TestHelper helper(&task_runner, TestHelper::Mode::kStartDaemons, in TEST()
67 auto relay_service = std::make_unique<RelayService>(&task_runner); in TEST()
74 task_runner.CreateCheckpoint("perfetto.FakeProducer.connected"); in TEST()
76 auto connected = [&]() { task_runner.PostTask(producer_connected); }; in TEST()
82 task_runner.RunUntilCheckpoint("perfetto.FakeProducer.connected"); in TEST()
128 base::TestTaskRunner task_runner; in TEST() local
136 "127.0.0.1:0", &event_listener, &task_runner, base::SockFamily::kInet, in TEST()
140 param.relay_service = std::make_unique<RelayService>(&task_runner); in TEST()
[all …]
|
| /external/cronet/tot/base/test/ |
| D | test_mock_time_task_runner_unittest.cc | 204 auto task_runner = MakeRefCounted<TestMockTimeTaskRunner>( in TEST() local
207 task_runner->PostTask(FROM_HERE, base::BindLambdaForTesting([&] { in TEST()
211 task_runner->RunUntilIdle(); in TEST()
232 quitting_thread.task_runner()->PostDelayedTask( in TEST()
238 auto task_runner = MakeRefCounted<TestMockTimeTaskRunner>(); in TEST() local
239 task_runner->PostTask(FROM_HERE, DoNothing()); in TEST()
240 EXPECT_TRUE(task_runner->HasPendingTask()); in TEST()
241 EXPECT_EQ(1u, task_runner->TakePendingTasks().size()); in TEST()
242 EXPECT_FALSE(task_runner->HasPendingTask()); in TEST()
246 auto task_runner = MakeRefCounted<TestMockTimeTaskRunner>(); in TEST() local
[all …]
|
| D | sequenced_task_runner_test_template.h | 47 void PostWrappedNonNestableTask(SequencedTaskRunner* task_runner,
51 void PostWrappedNestableTask(SequencedTaskRunner* task_runner,
55 void PostWrappedDelayedNonNestableTask(SequencedTaskRunner* task_runner,
60 void PostNonNestableTasks(SequencedTaskRunner* task_runner, int task_count);
136 const scoped_refptr<SequencedTaskRunner> task_runner = in TYPED_TEST_P() local
140 task_runner.get(), BindOnce(&PlatformThread::Sleep, Seconds(1))); in TYPED_TEST_P()
142 this->task_tracker_->PostWrappedNonNestableTask(task_runner.get(), in TYPED_TEST_P()
159 const scoped_refptr<SequencedTaskRunner> task_runner = in TYPED_TEST_P() local
163 task_runner.get(), BindOnce(&PlatformThread::Sleep, Seconds(1))); in TYPED_TEST_P()
165 this->task_tracker_->PostWrappedNestableTask(task_runner.get(), in TYPED_TEST_P()
[all …]
|
| /external/cronet/stable/base/test/ |
| D | test_mock_time_task_runner_unittest.cc | 204 auto task_runner = MakeRefCounted<TestMockTimeTaskRunner>( in TEST() local
207 task_runner->PostTask(FROM_HERE, base::BindLambdaForTesting([&] { in TEST()
211 task_runner->RunUntilIdle(); in TEST()
232 quitting_thread.task_runner()->PostDelayedTask( in TEST()
238 auto task_runner = MakeRefCounted<TestMockTimeTaskRunner>(); in TEST() local
239 task_runner->PostTask(FROM_HERE, DoNothing()); in TEST()
240 EXPECT_TRUE(task_runner->HasPendingTask()); in TEST()
241 EXPECT_EQ(1u, task_runner->TakePendingTasks().size()); in TEST()
242 EXPECT_FALSE(task_runner->HasPendingTask()); in TEST()
246 auto task_runner = MakeRefCounted<TestMockTimeTaskRunner>(); in TEST() local
[all …]
|
| D | sequenced_task_runner_test_template.h | 47 void PostWrappedNonNestableTask(SequencedTaskRunner* task_runner,
51 void PostWrappedNestableTask(SequencedTaskRunner* task_runner,
55 void PostWrappedDelayedNonNestableTask(SequencedTaskRunner* task_runner,
60 void PostNonNestableTasks(SequencedTaskRunner* task_runner, int task_count);
136 const scoped_refptr<SequencedTaskRunner> task_runner = in TYPED_TEST_P() local
140 task_runner.get(), BindOnce(&PlatformThread::Sleep, Seconds(1))); in TYPED_TEST_P()
142 this->task_tracker_->PostWrappedNonNestableTask(task_runner.get(), in TYPED_TEST_P()
159 const scoped_refptr<SequencedTaskRunner> task_runner = in TYPED_TEST_P() local
163 task_runner.get(), BindOnce(&PlatformThread::Sleep, Seconds(1))); in TYPED_TEST_P()
165 this->task_tracker_->PostWrappedNestableTask(task_runner.get(), in TYPED_TEST_P()
[all …]
|
| /external/cronet/tot/base/task/sequence_manager/ |
| D | sequence_manager_impl_unittest.cc | 614 queue->task_runner()->PostTask( in TEST_P()
616 EXPECT_EQ(queue->task_runner(), in TEST_P()
628 queues[0]->task_runner()->PostTask(FROM_HERE, BindOnce(&NopTask)); in TEST_P()
629 queues[0]->task_runner()->PostTask(FROM_HERE, BindOnce(&NopTask)); in TEST_P()
630 queues[1]->task_runner()->PostTask(FROM_HERE, BindOnce(&NopTask)); in TEST_P()
631 queues[1]->task_runner()->PostTask(FROM_HERE, BindOnce(&NopTask)); in TEST_P()
632 queues[2]->task_runner()->PostTask(FROM_HERE, BindOnce(&NopTask)); in TEST_P()
633 queues[2]->task_runner()->PostTask(FROM_HERE, BindOnce(&NopTask)); in TEST_P()
656 queues[0]->task_runner()->PostTask(FROM_HERE, BindOnce(&NopTask)); in TEST_P()
657 queues[0]->task_runner()->PostTask(FROM_HERE, BindOnce(&NopTask)); in TEST_P()
[all …]
|
| /external/cronet/stable/base/task/sequence_manager/ |
| D | sequence_manager_impl_unittest.cc | 614 queue->task_runner()->PostTask( in TEST_P()
616 EXPECT_EQ(queue->task_runner(), in TEST_P()
628 queues[0]->task_runner()->PostTask(FROM_HERE, BindOnce(&NopTask)); in TEST_P()
629 queues[0]->task_runner()->PostTask(FROM_HERE, BindOnce(&NopTask)); in TEST_P()
630 queues[1]->task_runner()->PostTask(FROM_HERE, BindOnce(&NopTask)); in TEST_P()
631 queues[1]->task_runner()->PostTask(FROM_HERE, BindOnce(&NopTask)); in TEST_P()
632 queues[2]->task_runner()->PostTask(FROM_HERE, BindOnce(&NopTask)); in TEST_P()
633 queues[2]->task_runner()->PostTask(FROM_HERE, BindOnce(&NopTask)); in TEST_P()
656 queues[0]->task_runner()->PostTask(FROM_HERE, BindOnce(&NopTask)); in TEST_P()
657 queues[0]->task_runner()->PostTask(FROM_HERE, BindOnce(&NopTask)); in TEST_P()
[all …]
|
| /external/perfetto/test/ |
| D | android_test_utils.cc | 30 base::TestTaskRunner* task_runner, in PollRunState() argument
38 task_runner->PostDelayedTask( in PollRunState()
39 [desired_run_state, task_runner, name, callback] { in PollRunState()
40 PollRunState(desired_run_state, task_runner, name, std::move(callback)); in PollRunState()
89 base::TestTaskRunner* task_runner, in WaitForProcess() argument
92 const auto checkpoint = task_runner->CreateCheckpoint(checkpoint_name); in WaitForProcess()
93 task_runner->PostDelayedTask( in WaitForProcess()
94 [desired_run_state, task_runner, process, checkpoint] { in WaitForProcess()
95 PollRunState(desired_run_state, task_runner, process, in WaitForProcess()
104 base::TestTaskRunner* task_runner, in StartAppActivity() argument
[all …]
|
| /external/perfetto/test/cts/art_module/ |
| D | heapprofd_java_test_cts.cc | 66 base::TestTaskRunner task_runner; in ProfileHeapGraphRuntime() local
70 StopApp(app_name, "old.app.stopped", &task_runner); in ProfileHeapGraphRuntime()
71 task_runner.RunUntilCheckpoint("old.app.stopped", 10000 /*ms*/); in ProfileHeapGraphRuntime()
73 StartAppActivity(app_name, "NoopActivity", "target.app.running", &task_runner, in ProfileHeapGraphRuntime()
75 task_runner.RunUntilCheckpoint("target.app.running", 10000 /*ms*/); in ProfileHeapGraphRuntime()
80 TestHelper helper(&task_runner); in ProfileHeapGraphRuntime()
104 StopApp(app_name, "new.app.stopped", &task_runner); in ProfileHeapGraphRuntime()
105 task_runner.RunUntilCheckpoint("new.app.stopped", 10000 /*ms*/); in ProfileHeapGraphRuntime()
112 base::TestTaskRunner task_runner; in TriggerOomHeapDump() local
116 StopApp(app_name, "old.app.stopped", &task_runner); in TriggerOomHeapDump()
[all …]
|
| /external/cronet/stable/base/task/ |
| D | sequenced_task_runner_unittest.cc | 63 foreign_runner_ = foreign_thread_.task_runner(); in SetUp()
115 auto task_runner = MakeRefCounted<TestMockTimeTaskRunner>(); in TEST_F() local
119 task_runner->PostCancelableDelayedTask( in TEST_F()
123 EXPECT_TRUE(task_runner->HasPendingTask()); in TEST_F()
126 task_runner->FastForwardUntilNoTasksRemain(); in TEST_F()
129 EXPECT_FALSE(task_runner->HasPendingTask()); in TEST_F()
134 auto task_runner = MakeRefCounted<TestMockTimeTaskRunner>(); in TEST_F() local
138 task_runner->PostCancelableDelayedTask( in TEST_F()
142 EXPECT_TRUE(task_runner->HasPendingTask()); in TEST_F()
148 EXPECT_FALSE(task_runner->HasPendingTask()); in TEST_F()
[all …]
|
| /external/cronet/tot/base/task/ |
| D | sequenced_task_runner_unittest.cc | 63 foreign_runner_ = foreign_thread_.task_runner(); in SetUp()
115 auto task_runner = MakeRefCounted<TestMockTimeTaskRunner>(); in TEST_F() local
119 task_runner->PostCancelableDelayedTask( in TEST_F()
123 EXPECT_TRUE(task_runner->HasPendingTask()); in TEST_F()
126 task_runner->FastForwardUntilNoTasksRemain(); in TEST_F()
129 EXPECT_FALSE(task_runner->HasPendingTask()); in TEST_F()
134 auto task_runner = MakeRefCounted<TestMockTimeTaskRunner>(); in TEST_F() local
138 task_runner->PostCancelableDelayedTask( in TEST_F()
142 EXPECT_TRUE(task_runner->HasPendingTask()); in TEST_F()
148 EXPECT_FALSE(task_runner->HasPendingTask()); in TEST_F()
[all …]
|
| /external/cronet/stable/net/base/ |
| D | prioritized_task_runner_unittest.cc | 70 void ProcessTaskRunner(base::TaskRunner* task_runner) { in ProcessTaskRunner() argument
75 task_runner->PostTask(FROM_HERE, in ProcessTaskRunner()
88 void BlockTaskRunner(base::TaskRunner* task_runner) { in BlockTaskRunner() argument
95 task_runner->PostTask(FROM_HERE, in BlockTaskRunner()
112 auto task_runner = base::ThreadPool::CreateSequencedTaskRunner({}); in TEST_F() local
115 prioritized_task_runner->SetTaskRunnerForTesting(task_runner); in TEST_F()
127 FROM_HERE, base::BindOnce(thread_check, task_runner, base::DoNothing()), in TEST_F()
136 auto task_runner = base::ThreadPool::CreateSequencedTaskRunner({}); in TEST_F() local
139 prioritized_task_runner->SetTaskRunnerForTesting(task_runner); in TEST_F()
155 auto task_runner = base::ThreadPool::CreateSequencedTaskRunner({}); in TEST_F() local
[all …]
|
| /external/cronet/tot/net/base/ |
| D | prioritized_task_runner_unittest.cc | 70 void ProcessTaskRunner(base::TaskRunner* task_runner) { in ProcessTaskRunner() argument
75 task_runner->PostTask(FROM_HERE, in ProcessTaskRunner()
88 void BlockTaskRunner(base::TaskRunner* task_runner) { in BlockTaskRunner() argument
95 task_runner->PostTask(FROM_HERE, in BlockTaskRunner()
112 auto task_runner = base::ThreadPool::CreateSequencedTaskRunner({}); in TEST_F() local
115 prioritized_task_runner->SetTaskRunnerForTesting(task_runner); in TEST_F()
127 FROM_HERE, base::BindOnce(thread_check, task_runner, base::DoNothing()), in TEST_F()
136 auto task_runner = base::ThreadPool::CreateSequencedTaskRunner({}); in TEST_F() local
139 prioritized_task_runner->SetTaskRunnerForTesting(task_runner); in TEST_F()
155 auto task_runner = base::ThreadPool::CreateSequencedTaskRunner({}); in TEST_F() local
[all …]
|
| /external/libchrome/base/message_loop/ |
| D | message_loop_task_runner_unittest.cc | 40 task_thread_.task_runner()->PostTask( in SetUp()
116 ASSERT_TRUE(task_thread_.task_runner()->PostTaskAndReply( in TEST_F()
150 scoped_refptr<SingleThreadTaskRunner> task_runner = in TEST_F() local
151 task_thread_.task_runner(); in TEST_F()
155 ASSERT_FALSE(task_runner->PostTaskAndReply( in TEST_F()
184 ASSERT_TRUE(current_loop_->task_runner()->PostTaskAndReply( in TEST_F()
220 task_thread_.task_runner()->PostTaskAndReply( in TEST_F()
265 loop_.task_runner()->PostTask( in Quit()
270 ASSERT_TRUE(io_thread_->task_runner()->BelongsToCurrentThread()); in AssertOnIOThread()
271 ASSERT_EQ(io_thread_->task_runner(), ThreadTaskRunnerHandle::Get()); in AssertOnIOThread()
[all …]
|
| /external/cronet/stable/base/threading/ |
| D | thread_unittest.cc | 178 EXPECT_TRUE(a.task_runner()); in TEST_F()
183 a.task_runner()->PostTask( in TEST_F()
200 EXPECT_TRUE(a->task_runner()); in TEST_F()
215 a->task_runner()->PostTask( in TEST_F()
235 EXPECT_TRUE(a.task_runner()); in TEST_F()
240 a.task_runner()->PostTask( in TEST_F()
244 a.task_runner()->PostTask(FROM_HERE, BindOnce(&ToggleValue, &was_invoked)); in TEST_F()
274 EXPECT_TRUE(a.task_runner()); in TEST_F()
278 EXPECT_FALSE(a.task_runner()); in TEST_F()
285 EXPECT_TRUE(a.task_runner()); in TEST_F()
[all …]
|
| /external/cronet/tot/base/threading/ |
| D | thread_unittest.cc | 178 EXPECT_TRUE(a.task_runner()); in TEST_F()
183 a.task_runner()->PostTask( in TEST_F()
200 EXPECT_TRUE(a->task_runner()); in TEST_F()
215 a->task_runner()->PostTask( in TEST_F()
235 EXPECT_TRUE(a.task_runner()); in TEST_F()
240 a.task_runner()->PostTask( in TEST_F()
244 a.task_runner()->PostTask(FROM_HERE, BindOnce(&ToggleValue, &was_invoked)); in TEST_F()
274 EXPECT_TRUE(a.task_runner()); in TEST_F()
278 EXPECT_FALSE(a.task_runner()); in TEST_F()
285 EXPECT_TRUE(a.task_runner()); in TEST_F()
[all …]
|