| /external/perfetto/src/base/ |
| task_runner_unittest.cc | 37 T task_runner; member in class:perfetto::base::__anon31959::TaskRunnerTest
73 auto& task_runner = this->task_runner; local
75 task_runner.PostTask([&counter] { counter = (counter << 4) | 1; });
76 task_runner.PostTask([&counter] { counter = (counter << 4) | 2; });
77 task_runner.PostTask([&counter] { counter = (counter << 4) | 3; });
78 task_runner.PostTask([&counter] { counter = (counter << 4) | 4; });
79 task_runner.PostTask([&task_runner] { task_runner.Quit(); })
85 auto& task_runner = this->task_runner; local
97 auto& task_runner = this->task_runner; local
105 auto& task_runner = this->task_runner; local
113 auto& task_runner = this->task_runner; local
132 auto& task_runner = this->task_runner; local
141 auto& task_runner = this->task_runner; local
149 auto& task_runner = this->task_runner; local
163 auto& task_runner = this->task_runner; local
179 auto& task_runner = this->task_runner; local
193 auto& task_runner = this->task_runner; local
212 auto& task_runner = this->task_runner; local
231 auto& task_runner = this->task_runner; local
243 auto& task_runner = this->task_runner; local
261 auto& task_runner = this->task_runner; local
276 auto& task_runner = this->task_runner; local
284 auto& task_runner = this->task_runner; local
305 auto& task_runner = this->task_runner; local
324 auto& task_runner = this->task_runner; local
340 auto& task_runner = this->task_runner; local
359 auto& task_runner = this->task_runner; local
[all...] |
| /external/perfetto/test/cts/producer/jni/ |
| fake_producer_jni.cc | 29 base::TestTaskRunner task_runner; local
31 producer.Connect(GetProducerSocket(), &task_runner, [] {}); local
32 task_runner.Run();
|
| /external/libchrome/base/trace_event/ |
| memory_dump_provider_info.cc | 17 scoped_refptr<SequencedTaskRunner> task_runner,
23 task_runner(std::move(task_runner)),
35 // Ensure that unbound providers (task_runner == nullptr) always run last.
38 return std::tie(a->task_runner, a->dump_provider) >
39 std::tie(b->task_runner, b->dump_provider);
|
| memory_dump_provider_info.h | 48 // Define a total order based on the |task_runner| affinity, so that MDPs
59 scoped_refptr<SequencedTaskRunner> task_runner,
78 const scoped_refptr<SequencedTaskRunner> task_runner; member in struct:base::trace_event::MemoryDumpProviderInfo
84 // - On the |task_runner|, when not null (i.e. for thread-bound MDPS).
|
| /external/libchrome/base/threading/ |
| sequenced_task_runner_handle.h | 33 // Binds |task_runner| to the current thread.
35 scoped_refptr<SequencedTaskRunner> task_runner);
|
| thread_task_runner_handle.h | 41 // Binds |task_runner| to the current thread. |task_runner| must belong
44 scoped_refptr<SingleThreadTaskRunner> task_runner);
|
| /external/libchrome/base/test/ |
| test_io_thread.h | 12 #include "base/task_runner.h"
24 // - PostTask()/message_loop()/task_runner() are also safe to call from the
26 // task_runner() from the main thread first, it is then safe to pass _it_
48 scoped_refptr<SingleThreadTaskRunner> task_runner() { function in class:base::TestIOThread
49 return message_loop()->task_runner();
|
| /external/perfetto/test/ |
| task_runner_thread_delegates.h | 34 void Initialize(base::TaskRunner* task_runner) override {
35 svc_ = ServiceIPCHost::CreateInstance(task_runner);
54 void Initialize(base::TaskRunner* task_runner) override {
56 producer_->ConnectWithRetries(producer_socket_.c_str(), task_runner);
72 void Initialize(base::TaskRunner* task_runner) override {
74 producer_->Connect(producer_socket_.c_str(), task_runner,
|
| end_to_end_shared_memory_fuzzer.cc | 22 #include "perfetto/base/task_runner.h"
68 void Connect(const char* socket_name, base::TaskRunner* task_runner) {
70 socket_name, this, "android.perfetto.FakeProducer", task_runner);
121 void Initialize(base::TaskRunner* task_runner) override {
124 producer_->Connect(TEST_PRODUCER_SOCK_NAME, task_runner);
137 base::TestTaskRunner task_runner; local
139 TestHelper helper(&task_runner);
145 helper.WrapTask(task_runner.CreateCheckpoint(
159 task_runner.RunUntilCheckpoint("produced.and.committed");
|
| task_runner_thread.cc | 88 base::PlatformTaskRunner task_runner; local
89 delegate->Initialize(&task_runner);
94 runner_ = &task_runner;
101 task_runner.Run();
|
| end_to_end_integrationtest.cc | 58 base::TestTaskRunner task_runner; local
60 TestHelper helper(&task_runner);
101 base::TestTaskRunner task_runner; local
103 TestHelper helper(&task_runner);
142 base::TestTaskRunner task_runner; local
144 TestHelper helper(&task_runner);
|
| /external/perfetto/src/traced/probes/ |
| probes.cc | 70 base::UnixTaskRunner task_runner; local
72 producer.ConnectWithRetries(GetProducerSocket(), &task_runner); local
73 task_runner.Run();
|
| /external/perfetto/src/traced/service/ |
| service.cc | 26 base::UnixTaskRunner task_runner; local
28 svc = ServiceIPCHost::CreateInstance(&task_runner);
55 task_runner.Run();
|
| /external/libchrome/base/ |
| sequenced_task_runner.cc | 28 scoped_refptr<SequencedTaskRunner> task_runner)
29 : task_runner_(std::move(task_runner)) {
|
| task_runner_util.h | 15 #include "base/task_runner.h"
29 // target_thread_.task_runner(),
34 bool PostTaskAndReplyWithResult(TaskRunner* task_runner,
41 return task_runner->PostTaskAndReply(
|
| /external/libchrome/base/message_loop/ |
| message_loop_task_runner_unittest.cc | 40 task_thread_.task_runner()->PostTask(
116 ASSERT_TRUE(task_thread_.task_runner()->PostTaskAndReply(
150 scoped_refptr<SingleThreadTaskRunner> task_runner = local
151 task_thread_.task_runner();
156 task_runner->PostTaskAndReply(FROM_HERE, Bind(&RecordLoop, task_recorder),
184 ASSERT_TRUE(current_loop_->task_runner()->PostTaskAndReply(
220 task_thread_.task_runner()->PostTaskAndReply(
265 loop_.task_runner()->PostTask(FROM_HERE,
270 ASSERT_TRUE(io_thread_->task_runner()->BelongsToCurrentThread());
271 ASSERT_EQ(io_thread_->task_runner(), ThreadTaskRunnerHandle::Get())
343 scoped_refptr<SingleThreadTaskRunner> task_runner = local
353 scoped_refptr<SingleThreadTaskRunner> task_runner; local
[all...] |
| /external/libchrome/base/metrics/ |
| user_metrics.h | 69 scoped_refptr<SingleThreadTaskRunner> task_runner);
|
| user_metrics.cc | 68 scoped_refptr<SingleThreadTaskRunner> task_runner) {
69 DCHECK(task_runner->BelongsToCurrentThread());
71 g_task_runner.Get() = task_runner;
|
| /external/libchrome/base/files/ |
| important_file_writer.h | 60 // |task_runner| is the SequencedTaskRunner instance where on which we will
64 scoped_refptr<SequencedTaskRunner> task_runner);
68 scoped_refptr<SequencedTaskRunner> task_runner,
102 // If called more than once before a write is scheduled on |task_runner|, the
|
| /external/perfetto/src/traced/probes/filesystem/ |
| file_scanner_unittest.cc | 118 base::TestTaskRunner task_runner; local
125 task_runner.CreateCheckpoint("done"));
128 fs.Scan(&task_runner);
130 task_runner.RunUntilCheckpoint("done");
162 base::TestTaskRunner task_runner; local
171 task_runner.CreateCheckpoint("done"));
174 fs.Scan(&task_runner);
176 task_runner.RunUntilCheckpoint("done");
|
| /external/libchrome/base/task/ |
| cancelable_task_tracker.h | 73 TaskId PostTask(base::TaskRunner* task_runner,
77 TaskId PostTaskAndReply(base::TaskRunner* task_runner,
83 TaskId PostTaskAndReplyWithResult(base::TaskRunner* task_runner,
89 task_runner, from_here,
|
| cancelable_task_tracker.cc | 15 #include "base/task_runner.h"
44 void RunOrPostToTaskRunner(TaskRunner* task_runner, const Closure& closure) {
45 if (task_runner->RunsTasksOnCurrentThread())
48 task_runner->PostTask(FROM_HERE, closure);
66 TaskRunner* task_runner,
71 return PostTaskAndReply(task_runner, from_here, task, Bind(&base::DoNothing));
75 TaskRunner* task_runner,
92 bool success = task_runner->PostTaskAndReply(
|
| /external/libmojo/mojo/edk/test/ |
| run_all_perftests.cc | 21 test_io_thread.task_runner(),
|
| /external/perfetto/src/tracing/ipc/service/ |
| service_ipc_host_impl.cc | 20 #include "perfetto/base/task_runner.h"
34 base::TaskRunner* task_runner) {
35 return std::unique_ptr<ServiceIPCHost>(new ServiceIPCHostImpl(task_runner));
38 ServiceIPCHostImpl::ServiceIPCHostImpl(base::TaskRunner* task_runner)
39 : task_runner_(task_runner) {}
|
| /external/perfetto/src/tracing/test/ |
| mock_consumer.cc | 27 MockConsumer::MockConsumer(base::TestTaskRunner* task_runner)
28 : task_runner_(task_runner) {}
81 base::TestTaskRunner* task_runner = task_runner_; local
82 auto wait_for_flush_completion = [result, task_runner,
84 task_runner->RunUntilCheckpoint(checkpoint_name);
|
