Home
last modified time | relevance | path

Searched refs:task_runner (Results 1 – 25 of 122) sorted by relevance

12345

/external/perfetto/src/base/
Dtask_runner_unittest.cc37 T task_runner; member in perfetto::base::__anon449ea1060111::TaskRunnerTest
73 auto& task_runner = this->task_runner; in TYPED_TEST() local
75 task_runner.PostTask([&counter] { counter = (counter << 4) | 1; }); in TYPED_TEST()
76 task_runner.PostTask([&counter] { counter = (counter << 4) | 2; }); in TYPED_TEST()
77 task_runner.PostTask([&counter] { counter = (counter << 4) | 3; }); in TYPED_TEST()
78 task_runner.PostTask([&counter] { counter = (counter << 4) | 4; }); in TYPED_TEST()
79 task_runner.PostTask([&task_runner] { task_runner.Quit(); }); in TYPED_TEST()
80 task_runner.Run(); in TYPED_TEST()
85 auto& task_runner = this->task_runner; in TYPED_TEST() local
87 task_runner.PostDelayedTask([&counter] { counter = (counter << 4) | 1; }, 5); in TYPED_TEST()
[all …]
/external/libchrome/base/message_loop/
Dmessage_loop_task_runner_unittest.cc40 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()
156 task_runner->PostTaskAndReply(FROM_HERE, Bind(&RecordLoop, task_recorder), 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(FROM_HERE, in Quit()
270 ASSERT_TRUE(io_thread_->task_runner()->BelongsToCurrentThread()); in AssertOnIOThread()
271 ASSERT_EQ(io_thread_->task_runner(), ThreadTaskRunnerHandle::Get()); in AssertOnIOThread()
[all …]
Dmessage_loop_unittest.cc113 java_thread->message_loop()->task_runner()->PostDelayedTask( in RunTest_AbortDontRunMoreTasks()
116 java_thread->message_loop()->task_runner()->PostTask( in RunTest_AbortDontRunMoreTasks()
185 message_loop.task_runner()->PostTask(FROM_HERE, Bind(&SubPumpFunc)); in RunTest_PostDelayedTask_SharedTimer_SubPump()
188 message_loop.task_runner()->PostDelayedTask( in RunTest_PostDelayedTask_SharedTimer_SubPump()
193 message_loop.task_runner()->PostDelayedTask( in RunTest_PostDelayedTask_SharedTimer_SubPump()
338 void RecursiveFuncWin(scoped_refptr<SingleThreadTaskRunner> task_runner, in RecursiveFuncWin() argument
343 task_runner->PostTask(FROM_HERE, in RecursiveFuncWin()
345 task_runner->PostTask(FROM_HERE, in RecursiveFuncWin()
347 task_runner->PostTask(FROM_HERE, in RecursiveFuncWin()
355 task_runner->PostTask(FROM_HERE, Bind(&EndDialogFunc, order, 4)); in RecursiveFuncWin()
[all …]
/external/libchrome/base/trace_event/
Dmemory_dump_manager.cc286 scoped_refptr<SingleThreadTaskRunner> task_runner, in RegisterDumpProvider() argument
289 RegisterDumpProviderInternal(mdp, name, std::move(task_runner), options); in RegisterDumpProvider()
295 scoped_refptr<SingleThreadTaskRunner> task_runner) { in RegisterDumpProvider() argument
300 RegisterDumpProviderInternal(mdp, name, std::move(task_runner), options); in RegisterDumpProvider()
306 scoped_refptr<SequencedTaskRunner> task_runner, in RegisterDumpProviderWithSequencedTaskRunner() argument
308 DCHECK(task_runner); in RegisterDumpProviderWithSequencedTaskRunner()
310 RegisterDumpProviderInternal(mdp, name, std::move(task_runner), options); in RegisterDumpProviderWithSequencedTaskRunner()
316 scoped_refptr<SequencedTaskRunner> task_runner, in RegisterDumpProviderInternal() argument
323 new MemoryDumpProviderInfo(mdp, name, std::move(task_runner), options, in RegisterDumpProviderInternal()
327 DCHECK(!mdpinfo->task_runner) << "MemoryDumpProviders capable of fast " in RegisterDumpProviderInternal()
[all …]
Dmemory_dump_provider_info.cc17 scoped_refptr<SequencedTaskRunner> task_runner, in MemoryDumpProviderInfo() argument
23 task_runner(std::move(task_runner)), in MemoryDumpProviderInfo()
38 return std::tie(a->task_runner, a->dump_provider) > in operator ()()
39 std::tie(b->task_runner, b->dump_provider); in operator ()()
Dmemory_dump_manager_unittest.cc70 scoped_refptr<base::SingleThreadTaskRunner> task_runner, in RegisterDumpProvider() argument
75 mdm->RegisterDumpProvider(mdp, name, std::move(task_runner), options); in RegisterDumpProvider()
81 scoped_refptr<base::SingleThreadTaskRunner> task_runner) { in RegisterDumpProvider() argument
82 RegisterDumpProvider(mdp, task_runner, MemoryDumpProvider::Options()); in RegisterDumpProvider()
87 scoped_refptr<base::SequencedTaskRunner> task_runner, in RegisterDumpProviderWithSequencedTaskRunner() argument
91 mdm->RegisterDumpProviderWithSequencedTaskRunner(mdp, kMDPName, task_runner, in RegisterDumpProviderWithSequencedTaskRunner()
107 SequencedTaskRunner* task_runner, in PostTaskAndWait() argument
111 task_runner->PostTask(from_here, std::move(task)); in PostTaskAndWait()
112 task_runner->PostTask( in PostTaskAndWait()
239 void DumpCallbackAdapter(scoped_refptr<SingleThreadTaskRunner> task_runner, in DumpCallbackAdapter() argument
[all …]
/external/v4l2_codec2/vda/
Dv4l2_video_decode_accelerator.cc223 decoder_thread_.task_runner()->PostTask( in Initialize()
232 DCHECK(decoder_thread_.task_runner()->BelongsToCurrentThread()); in InitializeTask()
267 decoder_thread_.task_runner()->PostTask( in Decode()
277 decoder_thread_.task_runner()->PostTask( in AssignPictureBuffers()
286 DCHECK(decoder_thread_.task_runner()->BelongsToCurrentThread()); in AssignPictureBuffersTask()
361 decoder_thread_.task_runner()->PostTask( in ImportBufferForPicture()
373 DCHECK(decoder_thread_.task_runner()->BelongsToCurrentThread()); in ImportBufferForPictureTask()
418 decoder_thread_.task_runner()->PostTask( in ReusePictureBuffer()
426 decoder_thread_.task_runner()->PostTask( in Flush()
434 decoder_thread_.task_runner()->PostTask( in Reset()
[all …]
/external/perfetto/test/
Dend_to_end_shared_memory_fuzzer.cc68 void Connect(const char* socket_name, base::TaskRunner* task_runner) { in Connect() argument
70 socket_name, this, "android.perfetto.FakeProducer", task_runner); in Connect()
121 void Initialize(base::TaskRunner* task_runner) override { in Initialize() argument
124 producer_->Connect(TEST_PRODUCER_SOCK_NAME, task_runner); in Initialize()
137 base::TestTaskRunner task_runner; in FuzzSharedMemory() local
139 TestHelper helper(&task_runner); in FuzzSharedMemory()
145 helper.WrapTask(task_runner.CreateCheckpoint( in FuzzSharedMemory()
159 task_runner.RunUntilCheckpoint("produced.and.committed"); in FuzzSharedMemory()
Dtask_runner_thread_delegates.h34 void Initialize(base::TaskRunner* task_runner) override { in Initialize() argument
35 svc_ = ServiceIPCHost::CreateInstance(task_runner); in Initialize()
54 void Initialize(base::TaskRunner* task_runner) override { in Initialize() argument
56 producer_->ConnectWithRetries(producer_socket_.c_str(), task_runner); in Initialize()
72 void Initialize(base::TaskRunner* task_runner) override { in Initialize() argument
74 producer_->Connect(producer_socket_.c_str(), task_runner, in Initialize()
Dend_to_end_integrationtest.cc58 base::TestTaskRunner task_runner; in TEST() local
60 TestHelper helper(&task_runner); in TEST()
101 base::TestTaskRunner task_runner; in TEST() local
103 TestHelper helper(&task_runner); in TEST()
142 base::TestTaskRunner task_runner; in TEST() local
144 TestHelper helper(&task_runner); in TEST()
Dtask_runner_thread.cc88 base::PlatformTaskRunner task_runner; in Run() local
89 delegate->Initialize(&task_runner); in Run()
94 runner_ = &task_runner; in Run()
101 task_runner.Run(); in Run()
/external/perfetto/src/traced/probes/filesystem/
Dfile_scanner_unittest.cc118 base::TestTaskRunner task_runner; in TEST() local
125 task_runner.CreateCheckpoint("done")); in TEST()
128 fs.Scan(&task_runner); in TEST()
130 task_runner.RunUntilCheckpoint("done"); in TEST()
162 base::TestTaskRunner task_runner; in TEST() local
171 task_runner.CreateCheckpoint("done")); in TEST()
174 fs.Scan(&task_runner); in TEST()
176 task_runner.RunUntilCheckpoint("done"); in TEST()
/external/libchrome/base/timer/
Dtimer_unittest.cc111 void SetTaskRunner(scoped_refptr<SingleThreadTaskRunner> task_runner) { in SetTaskRunner() argument
112 timer_->SetTaskRunner(std::move(task_runner)); in SetTaskRunner()
422 f.SetTaskRunner(other_thread.task_runner()); in TEST()
437 scoped_refptr<TestMockTimeTaskRunner> task_runner( in TEST() local
439 std::unique_ptr<TickClock> tick_clock(task_runner->GetMockTickClock()); in TEST()
441 message_loop.SetTaskRunner(task_runner); in TEST()
446 task_runner->FastForwardBy(TimeDelta::FromSeconds(1)); in TEST()
479 scoped_refptr<TestMockTimeTaskRunner> task_runner( in TEST() local
481 std::unique_ptr<TickClock> tick_clock(task_runner->GetMockTickClock()); in TEST()
483 message_loop.SetTaskRunner(task_runner); in TEST()
[all …]
/external/libmojo/mojo/public/cpp/bindings/tests/
Dbind_task_runner_unittest.cc247 scoped_refptr<TestTaskRunner> task_runner) { in DoSetFlagAndQuitTaskRunner() argument
249 if (task_runner) in DoSetFlagAndQuitTaskRunner()
250 task_runner->Quit(); in DoSetFlagAndQuitTaskRunner()
256 scoped_refptr<TestTaskRunner> task_runner, in DoExpectValueSetFlagAndQuitTaskRunner() argument
259 DoSetFlagAndQuitTaskRunner(flag, task_runner); in DoExpectValueSetFlagAndQuitTaskRunner()
265 scoped_refptr<TestTaskRunner> task_runner, in DoExpectValueSetFlagForwardValueAndQuitTaskRunner() argument
271 task_runner->Quit(); in DoExpectValueSetFlagForwardValueAndQuitTaskRunner()
276 scoped_refptr<TestTaskRunner> task_runner) { in SetFlagAndQuitTaskRunner() argument
277 return base::Bind(&DoSetFlagAndQuitTaskRunner, flag, task_runner); in SetFlagAndQuitTaskRunner()
283 scoped_refptr<TestTaskRunner> task_runner) { in ExpectValueSetFlagAndQuitTaskRunner() argument
[all …]
Dassociated_interface_unittest.cc122 if (loop_.task_runner()->BelongsToCurrentThread()) { in QuitRunLoop()
125 loop_.task_runner()->PostTask( in QuitRunLoop()
236 CHECK(sender_thread_.task_runner()->BelongsToCurrentThread()); in SetUp()
244 CHECK(sender_thread_.task_runner()->BelongsToCurrentThread()); in Send()
251 next_sender_->sender_thread()->task_runner()->PostTask( in Send()
257 CHECK(sender_thread_.task_runner()->BelongsToCurrentThread()); in TearDown()
282 CHECK(receiver_thread_.task_runner()->BelongsToCurrentThread()); in SetUp()
296 CHECK(receiver_thread_.task_runner()->BelongsToCurrentThread()); in TearDown()
378 senders[i].sender_thread()->task_runner()->PostTask( in TEST_F()
390 receivers[i].receiver_thread()->task_runner()->PostTask( in TEST_F()
[all …]
/external/libchrome/base/task/
Dcancelable_task_tracker.cc44 void RunOrPostToTaskRunner(TaskRunner* task_runner, const Closure& closure) { in RunOrPostToTaskRunner() argument
45 if (task_runner->RunsTasksOnCurrentThread()) in RunOrPostToTaskRunner()
48 task_runner->PostTask(FROM_HERE, closure); in RunOrPostToTaskRunner()
66 TaskRunner* task_runner, in PostTask() argument
71 return PostTaskAndReply(task_runner, from_here, task, Bind(&base::DoNothing)); in PostTask()
75 TaskRunner* task_runner, in PostTaskAndReply() argument
92 bool success = task_runner->PostTaskAndReply( in PostTaskAndReply()
Dcancelable_task_tracker_unittest.cc88 ignore_result(task_tracker_.PostTask(worker_thread.task_runner().get(), in TEST_F()
93 worker_thread.task_runner().get(), FROM_HERE, in TEST_F()
169 worker_thread.task_runner().get(), FROM_HERE, Bind(&DoNothing), in TEST_F()
196 other_thread.task_runner()->PostTask( in TEST_F()
203 other_thread.task_runner()->PostTask( in TEST_F()
366 bad_thread.task_runner()->PostTask( in TEST_F()
387 bad_thread.task_runner()->PostTask( in TEST_F()
405 bad_thread.task_runner()->PostTask( in TEST_F()
Dcancelable_task_tracker.h73 TaskId PostTask(base::TaskRunner* task_runner,
77 TaskId PostTaskAndReply(base::TaskRunner* task_runner,
83 TaskId PostTaskAndReplyWithResult(base::TaskRunner* task_runner, in PostTaskAndReplyWithResult() argument
89 task_runner, from_here, in PostTaskAndReplyWithResult()
/external/perfetto/src/tracing/test/
Dmock_consumer.cc27 MockConsumer::MockConsumer(base::TestTaskRunner* task_runner) in MockConsumer() argument
28 : task_runner_(task_runner) {} in MockConsumer()
81 base::TestTaskRunner* task_runner = task_runner_; in Flush() local
82 auto wait_for_flush_completion = [result, task_runner, in Flush()
84 task_runner->RunUntilCheckpoint(checkpoint_name); in Flush()
/external/libchrome/base/threading/
Dthread_unittest.cc158 a.task_runner()->PostTask(FROM_HERE, base::Bind(&base::WaitableEvent::Signal, in TEST_F()
191 a->task_runner()->PostTask( in TEST_F()
217 a.task_runner()->PostTask( in TEST_F()
221 a.task_runner()->PostTask(FROM_HERE, in TEST_F()
288 b.task_runner()->PostTask(FROM_HERE, in TEST_F()
309 b.task_runner()->PostTask( in TEST_F()
364 a->task_runner()->PostTask(FROM_HERE, in TEST_F()
401 a.task_runner()->PostTask( in TEST_F()
460 t.task_runner()->PostTask( in TEST_F()
476 EXPECT_FALSE(a.task_runner()); in TEST_F()
[all …]
/external/perfetto/src/tracing/ipc/service/
Dservice_ipc_host_impl.cc34 base::TaskRunner* task_runner) { in CreateInstance() argument
35 return std::unique_ptr<ServiceIPCHost>(new ServiceIPCHostImpl(task_runner)); in CreateInstance()
38 ServiceIPCHostImpl::ServiceIPCHostImpl(base::TaskRunner* task_runner) in ServiceIPCHostImpl() argument
39 : task_runner_(task_runner) {} in ServiceIPCHostImpl()
/external/perfetto/src/ipc/
Dunix_socket.cc110 base::TaskRunner* task_runner) { in Listen() argument
112 return Listen(CreateAndBind(socket_name), event_listener, task_runner); in Listen()
118 base::TaskRunner* task_runner) { in Listen() argument
120 event_listener, task_runner, std::move(socket_fd), State::kListening)); in Listen()
127 base::TaskRunner* task_runner) { in Connect() argument
128 std::unique_ptr<UnixSocket> sock(new UnixSocket(event_listener, task_runner)); in Connect()
134 base::TaskRunner* task_runner) in UnixSocket() argument
136 task_runner, in UnixSocket()
141 base::TaskRunner* task_runner, in UnixSocket() argument
145 task_runner_(task_runner), in UnixSocket()
Dhost_impl.cc38 base::TaskRunner* task_runner) { in CreateInstance() argument
39 std::unique_ptr<HostImpl> host(new HostImpl(socket_name, task_runner)); in CreateInstance()
47 base::TaskRunner* task_runner) { in CreateInstance() argument
49 new HostImpl(std::move(socket_fd), task_runner)); in CreateInstance()
55 HostImpl::HostImpl(base::ScopedFile socket_fd, base::TaskRunner* task_runner) in HostImpl() argument
56 : task_runner_(task_runner), weak_ptr_factory_(this) { in HostImpl()
62 HostImpl::HostImpl(const char* socket_name, base::TaskRunner* task_runner) in HostImpl() argument
63 : task_runner_(task_runner), weak_ptr_factory_(this) { in HostImpl()
/external/perfetto/test/cts/producer/jni/
Dfake_producer_jni.cc29 base::TestTaskRunner task_runner; in ListenAndRespond() local
31 producer.Connect(GetProducerSocket(), &task_runner, [] {}); in ListenAndRespond()
32 task_runner.Run(); in ListenAndRespond()
/external/webrtc/webrtc/base/
Dtask_unittest.cc499 DeleteTestTaskRunner task_runner; in TEST() local
500 HappyTask* happy_task = new HappyTask(&task_runner); in TEST()
508 task_runner.RunTasks(); in TEST()
515 DeleteTestTaskRunner task_runner; in TEST() local
516 HappyTask* happy_task = new HappyTask(&task_runner); in TEST()
529 DeleteTestTaskRunner task_runner; in TEST() local
530 HappyTask* happy_task = new HappyTask(&task_runner); in TEST()
539 task_runner.RunTasks(); in TEST()

12345