| /external/perfetto/src/ipc/ |
| D | host_impl_unittest.cc | 172 task_runner_.reset(new base::TestTaskRunner()); in SetUp()
173 Host* host = Host::CreateInstance(kSockName, task_runner_.get()).release(); in SetUp()
176 cli_.reset(new FakeClient(task_runner_.get())); in SetUp()
177 auto on_connect = task_runner_->CreateCheckpoint("on_connect"); in SetUp()
179 task_runner_->RunUntilCheckpoint("on_connect"); in SetUp()
183 task_runner_->RunUntilIdle(); in TearDown()
186 task_runner_->RunUntilIdle(); in TearDown()
187 task_runner_.reset(); in TearDown()
192 std::unique_ptr<base::TestTaskRunner> task_runner_; member in perfetto::ipc::__anon7dc9a4780111::HostImplTest
201 auto on_bind_failure = task_runner_->CreateCheckpoint("on_bind_failure"); in TEST_F()
[all …]
|
| D | client_impl_unittest.cc | 206 task_runner_.reset(new base::TestTaskRunner()); in SetUp()
207 host_.reset(new FakeHost(task_runner_.get())); in SetUp()
208 cli_ = Client::CreateInstance(kSockName, task_runner_.get()); in SetUp()
214 task_runner_->RunUntilIdle(); in TearDown()
215 task_runner_.reset(); in TearDown()
219 std::unique_ptr<base::TestTaskRunner> task_runner_; member in perfetto::ipc::__anon06ba55f90111::ClientImplTest
232 auto on_connect = task_runner_->CreateCheckpoint("on_connect"); in TEST_F()
234 task_runner_->RunUntilCheckpoint("on_connect"); in TEST_F()
250 auto on_invoke_reply = task_runner_->CreateCheckpoint("on_invoke_reply"); in TEST_F()
257 task_runner_->RunUntilCheckpoint("on_invoke_reply"); in TEST_F()
[all …]
|
| /external/perfetto/src/base/test/ |
| D | test_task_runner.cc | 36 task_runner_.Run(); in Run()
41 task_runner_.PostTask(std::bind(&TestTaskRunner::QuitIfIdle, this)); in RunUntilIdle()
42 task_runner_.Run(); in RunUntilIdle()
47 if (task_runner_.IsIdleForTesting()) { in QuitIfIdle()
48 task_runner_.Quit(); in QuitIfIdle()
51 task_runner_.PostTask(std::bind(&TestTaskRunner::QuitIfIdle, this)); in QuitIfIdle()
65 task_runner_.PostDelayedTask( in RunUntilCheckpoint()
76 task_runner_.Run(); in RunUntilCheckpoint()
89 task_runner_.Quit(); in CreateCheckpoint()
96 task_runner_.PostTask(std::move(closure)); in PostTask()
[all …]
|
| /external/perfetto/src/tracing/test/ |
| D | tracing_integration_test.cc | 124 task_runner_.reset(new base::TestTaskRunner()); in SetUp()
127 svc_ = ServiceIPCHost::CreateInstance(task_runner_.get()); in SetUp()
133 task_runner_.get(), GetProducerSMBScrapingMode()); in SetUp()
135 task_runner_->CreateCheckpoint("on_producer_connect"); in SetUp()
137 task_runner_->RunUntilCheckpoint("on_producer_connect"); in SetUp()
146 kConsumerSockName, &consumer_, task_runner_.get()); in SetUp()
148 task_runner_->CreateCheckpoint("on_consumer_connect"); in SetUp()
150 task_runner_->RunUntilCheckpoint("on_consumer_connect"); in SetUp()
161 task_runner_->CreateCheckpoint("on_producer_disconnect"); in TearDown()
166 task_runner_->CreateCheckpoint("on_consumer_disconnect"); in TearDown()
[all …]
|
| D | mock_consumer.cc | 29 : task_runner_(task_runner) {} in MockConsumer()
36 auto on_disconnect = task_runner_->CreateCheckpoint(checkpoint_name); in ~MockConsumer()
39 task_runner_->RunUntilCheckpoint(checkpoint_name); in ~MockConsumer()
46 auto on_connect = task_runner_->CreateCheckpoint(checkpoint_name); in Connect()
48 task_runner_->RunUntilCheckpoint(checkpoint_name); in Connect()
75 auto on_tracing_disabled = task_runner_->CreateCheckpoint(checkpoint_name); in WaitForTracingDisabled()
77 task_runner_->RunUntilCheckpoint(checkpoint_name, timeout_ms); in WaitForTracingDisabled()
83 auto on_flush = task_runner_->CreateCheckpoint(checkpoint_name); in Flush()
90 base::TestTaskRunner* task_runner = task_runner_; in Flush()
104 auto on_read_buffers = task_runner_->CreateCheckpoint(checkpoint_name); in ReadBuffers()
[all …]
|
| D | mock_producer.cc | 34 : task_runner_(task_runner) {} in MockProducer()
41 auto on_disconnect = task_runner_->CreateCheckpoint(checkpoint_name); in ~MockProducer()
44 task_runner_->RunUntilCheckpoint(checkpoint_name); in ~MockProducer()
59 auto on_connect = task_runner_->CreateCheckpoint(checkpoint_name); in Connect()
61 task_runner_->RunUntilCheckpoint(checkpoint_name); in Connect()
93 auto on_tracing_enabled = task_runner_->CreateCheckpoint(checkpoint_name); in WaitForTracingSetup()
95 task_runner_->RunUntilCheckpoint(checkpoint_name); in WaitForTracingSetup()
101 auto on_ds_start = task_runner_->CreateCheckpoint(checkpoint_name); in WaitForDataSourceSetup()
114 task_runner_->RunUntilCheckpoint(checkpoint_name); in WaitForDataSourceSetup()
120 auto on_ds_start = task_runner_->CreateCheckpoint(checkpoint_name); in WaitForDataSourceStart()
[all …]
|
| /external/perfetto/src/base/ |
| D | unix_socket_unittest.cc | 81 TestTaskRunner task_runner_; member in perfetto::base::__anon8c91df540111::UnixSocketTest
86 auto cli = UnixSocket::Connect(kSocketName, &event_listener_, &task_runner_, in TEST_F()
89 auto checkpoint = task_runner_.CreateCheckpoint("failure"); in TEST_F()
92 task_runner_.RunUntilCheckpoint("failure"); in TEST_F()
98 auto srv = UnixSocket::Listen(kSocketName, &event_listener_, &task_runner_, in TEST_F()
104 auto srv_did_shutdown = task_runner_.CreateCheckpoint("srv_did_shutdown"); in TEST_F()
113 auto checkpoint = task_runner_.CreateCheckpoint("cli_connected"); in TEST_F()
114 auto cli = UnixSocket::Connect(kSocketName, &event_listener_, &task_runner_, in TEST_F()
118 task_runner_.RunUntilCheckpoint("cli_connected"); in TEST_F()
119 task_runner_.RunUntilCheckpoint("srv_did_shutdown"); in TEST_F()
[all …]
|
| D | thread_task_runner.cc | 40 : thread_(std::move(other.thread_)), task_runner_(other.task_runner_) { in ThreadTaskRunner()
41 other.task_runner_ = nullptr; in ThreadTaskRunner()
51 if (task_runner_) { in ~ThreadTaskRunner()
52 PERFETTO_CHECK(!task_runner_->QuitCalled()); in ~ThreadTaskRunner()
53 task_runner_->Quit(); in ~ThreadTaskRunner()
68 task_runner_ = task_runner; in ThreadTaskRunner()
80 init_cv.wait(lock, [this] { return !!task_runner_; }); in ThreadTaskRunner()
100 task_runner_->PostTask([&mutex, &cv, &done, &fn] { in PostTaskAndWaitForTesting()
|
| D | metatrace_unittest.cc | 37 task_runner_.RunUntilIdle(); in TearDown()
42 m::Enable([this] { ReadCallback(); }, &task_runner_, tags); in Enable()
46 base::TestTaskRunner task_runner_; member in perfetto::__anon30d5635e0111::MetatraceTest
138 auto checkpoint = task_runner_.CreateCheckpoint(checkpoint_name); in TEST_F()
157 task_runner_.RunUntilCheckpoint(checkpoint_name); in TEST_F()
186 auto writer_done = task_runner_.CreateCheckpoint("writer_done"); in TEST_F()
196 task_runner_.PostTask(writer_done); in TEST_F()
199 task_runner_.RunUntilCheckpoint("writer_done"); in TEST_F()
216 auto checkpoint = task_runner_.CreateCheckpoint(checkpoint_name); in TEST_F()
232 task_runner_.RunUntilCheckpoint(checkpoint_name); in TEST_F()
|
| /external/webrtc/webrtc/base/ |
| D | task_unittest.cc | 138 stuck_[i].task_ = new StuckTask(&task_runner_); in Start()
149 happy_[i].task_ = new HappyTask(&task_runner_); in Start()
188 task_runner_.RunTasks(); in Start()
193 for (int i = 0; !task_runner_.AllChildrenDone() && i < STUCK_TASK_COUNT; in Start()
202 task_runner_.PollTasks(); in Start()
259 EXPECT_TRUE(task_runner_.AllChildrenDone()); in check_passed()
285 MyTaskRunner task_runner_; member in rtc::TaskTest
320 Task *abort_task = new AbortTask(&task_runner_); in Start()
325 task_runner_.RunTasks(); in Start()
333 MyTaskRunner task_runner_; member in rtc::TaskAbortTest
[all …]
|
| /external/libchrome/base/threading/ |
| D | thread_task_runner_handle.cc | 32 return current->task_runner_; in Get()
67 ttrh->task_runner_.swap(overriding_task_runner); in OverrideForTesting()
79 DCHECK_EQ(expected_task_runner_before_restore, ttrh->task_runner_.get()) in OverrideForTesting()
83 ttrh->task_runner_.swap(task_runner_to_restore); in OverrideForTesting()
86 base::Unretained(ttrh->task_runner_.get()), in OverrideForTesting()
92 : task_runner_(std::move(task_runner)) { in ThreadTaskRunnerHandle()
93 DCHECK(task_runner_->BelongsToCurrentThread()); in ThreadTaskRunnerHandle()
101 DCHECK(task_runner_->BelongsToCurrentThread()); in ~ThreadTaskRunnerHandle()
|
| D | sequenced_task_runner_handle.cc | 29 return handle->task_runner_; in Get()
47 : task_runner_(std::move(task_runner)) { in SequencedTaskRunnerHandle()
48 DCHECK(task_runner_->RunsTasksInCurrentSequence()); in SequencedTaskRunnerHandle()
54 DCHECK(task_runner_->RunsTasksInCurrentSequence()); in ~SequencedTaskRunnerHandle()
|
| /external/perfetto/src/tracing/core/ |
| D | shared_memory_arbiter_impl_unittest.cc | 69 task_runner_.reset(new base::TestTaskRunner()); in SetUp()
72 task_runner_.get())); in SetUp()
79 task_runner_.reset(); in TearDown()
82 std::unique_ptr<base::TestTaskRunner> task_runner_; member in perfetto::SharedMemoryArbiterImplTest
110 auto on_commit_1 = task_runner_->CreateCheckpoint("on_commit_1"); in TEST_P()
131 task_runner_->RunUntilCheckpoint("on_commit_1"); in TEST_P()
135 auto on_commit_2 = task_runner_->CreateCheckpoint("on_commit_2"); in TEST_P()
146 task_runner_->RunUntilCheckpoint("on_commit_2"); in TEST_P()
186 auto checkpoint = task_runner_->CreateCheckpoint("last_unregistered"); in TEST_P()
191 task_runner_.get())); in TEST_P()
[all …]
|
| D | shared_memory_arbiter_impl.cc | 86 task_runner_(task_runner), in SharedMemoryArbiterImpl()
120 task_runner_ && task_runner_->RunsTasksOnCurrentThread(); in GetNewChunk()
264 task_runner_to_post_callback_on = task_runner_; in UpdateCommitDataRequest()
348 base::TaskRunner* task_runner = task_runner_; in FlushPendingCommitDataRequests()
416 PERFETTO_CHECK(!producer_endpoint_ && !task_runner_); in BindToProducerEndpoint()
419 task_runner_ = task_runner; in BindToProducerEndpoint()
459 PERFETTO_CHECK(task_runner_); in BindStartupTargetBuffer()
460 PERFETTO_CHECK(task_runner_->RunsTasksOnCurrentThread()); in BindStartupTargetBuffer()
474 if (task_runner_ && !task_runner_->RunsTasksOnCurrentThread()) { in AbortStartupTracingForReservation()
476 auto* task_runner = task_runner_; in AbortStartupTracingForReservation()
[all …]
|
| /external/perfetto/src/ipc/test/ |
| D | ipc_integrationtest.cc | 70 perfetto::base::TestTaskRunner task_runner_; member in ipc_test::__anon3b4081f80111::IPCIntegrationTest
75 std::unique_ptr<Host> host = Host::CreateInstance(kSockName, &task_runner_); in TEST_F()
81 auto on_connect = task_runner_.CreateCheckpoint("on_connect"); in TEST_F()
84 Client::CreateInstance(kSockName, &task_runner_); in TEST_F()
87 task_runner_.RunUntilCheckpoint("on_connect"); in TEST_F()
92 auto on_reply = task_runner_.CreateCheckpoint("on_hello_reply"); in TEST_F()
109 task_runner_.RunUntilCheckpoint("on_hello_reply"); in TEST_F()
115 auto on_reply = task_runner_.CreateCheckpoint("on_goodbye_reply"); in TEST_F()
132 task_runner_.RunUntilCheckpoint("on_goodbye_reply"); in TEST_F()
|
| /external/perfetto/test/ |
| D | fake_producer.cc | 43 : name_(name), task_runner_(task_runner) {} in FakeProducer()
54 socket_name, this, "android.perfetto.FakeProducer", task_runner_, in Connect()
70 auto task_runner = task_runner_; in OnConnect()
83 task_runner_->PostTask(on_setup_data_source_instance_); in SetupDataSource()
103 task_runner_->PostTask(on_create_data_source_instance_); in StartDataSource()
117 task_runner_->PostTask([this, config, arbiter, callback] { in ProduceStartupEventBatch()
134 task_runner_->PostTask( in ProduceEventBatch()
139 task_runner_->PostTask([this, desc] { endpoint_->RegisterDataSource(desc); }); in RegisterDataSource()
144 task_runner_->PostTask( in CommitData()
149 task_runner_->PostTask([this, callback] { endpoint_->Sync(callback); }); in Sync()
|
| /external/libchrome/mojo/public/cpp/bindings/ |
| D | thread_safe_interface_ptr.h | 61 task_runner_(task_runner), in ThreadSafeForwarder()
99 task_runner_->PostTask(FROM_HERE, in Accept()
119 task_runner_->PostTask( in AcceptWithResponder()
128 if (task_runner_->RunsTasksInCurrentSequence()) { in AcceptWithResponder()
138 task_runner_->PostTask( in AcceptWithResponder()
249 const scoped_refptr<base::SequencedTaskRunner> task_runner_; variable
317 : task_runner_(task_runner) {} in PtrWrapper()
321 task_runner_->PostTask(FROM_HERE, base::Bind(&PtrWrapper::Bind, this, in BindOnTaskRunner()
333 task_runner_->PostTask(FROM_HERE, base::Bind(&PtrWrapper::Bind, this, in BindOnTaskRunner()
339 task_runner_, base::Bind(&PtrWrapper::Accept, this), in CreateForwarder()
[all …]
|
| /external/perfetto/src/tracing/ipc/service/ |
| D | service_ipc_host_impl.cc | 39 : task_runner_(task_runner) {} in ServiceIPCHostImpl()
49 ipc::Host::CreateInstance(producer_socket_name, task_runner_); in Start()
51 ipc::Host::CreateInstance(consumer_socket_name, task_runner_); in Start()
61 ipc::Host::CreateInstance(std::move(producer_socket_fd), task_runner_); in Start()
63 ipc::Host::CreateInstance(std::move(consumer_socket_fd), task_runner_); in Start()
71 svc_ = TracingService::CreateInstance(std::move(shm_factory), task_runner_); in DoStart()
|
| /external/perfetto/src/tracing/consumer_api_deprecated/ |
| D | consumer_api_deprecated.cc | 104 base::TaskRunner* const task_runner_; member in perfetto::consumer::__anoneea8fbaf0111::TracingSession
125 : task_runner_(task_runner), in TracingSession()
168 ConsumerIPCClient::Connect(GetConsumerSocket(), this, task_runner_); in Initialize()
253 task_runner_->PostTask([endpoint] { delete endpoint; }); in DestroyConnection()
269 task_runner_->PostTask([callback, callback_arg, handle, state] { in NotifyCallback()
291 std::unique_ptr<base::UnixTaskRunner> task_runner_; member in perfetto::consumer::__anoneea8fbaf0111::TracingController
305 task_runner_initialized_.wait(lock, [this] { return !!task_runner_; }); in TracingController()
311 task_runner_.reset(new base::UnixTaskRunner()); in ThreadMain()
314 task_runner_->Run(); in ThreadMain()
335 auto* session = new TracingSession(task_runner_.get(), handle, callback, in Create()
[all …]
|
| /external/libchrome/mojo/public/cpp/bindings/lib/ |
| D | interface_endpoint_client.cc | 46 task_runner_(std::move(runner)) {} in ResponderThunk()
54 if (task_runner_->RunsTasksInCurrentSequence()) { in ~ResponderThunk()
63 task_runner_->PostTask( in ~ResponderThunk()
76 DCHECK(task_runner_->RunsTasksInCurrentSequence()); in Accept()
90 DCHECK(task_runner_->RunsTasksInCurrentSequence()); in IsConnected()
95 if (task_runner_->RunsTasksInCurrentSequence()) { in IsConnectedAsync()
98 task_runner_->PostTask( in IsConnectedAsync()
107 scoped_refptr<base::SequencedTaskRunner> task_runner_; member in mojo::__anon051bc9aa0111::ResponderThunk
150 task_runner_(std::move(runner)), in InterfaceEndpointClient()
355 task_runner_); in InitControllerIfNecessary()
[all …]
|
| /external/libchrome/mojo/public/cpp/system/ |
| D | simple_watcher.cc | 77 task_runner_(task_runner), in Context()
100 task_runner_->RunsTasksInCurrentSequence() && weak_watcher_ && in Notify()
107 task_runner_->PostTask( in Notify()
114 const scoped_refptr<base::SequencedTaskRunner> task_runner_; member in mojo::SimpleWatcher::Context
127 task_runner_(std::move(runner)), in SimpleWatcher()
129 task_runner_ == in SimpleWatcher()
135 DCHECK(task_runner_->RunsTasksInCurrentSequence()); in SimpleWatcher()
161 context_ = Context::Create(weak_factory_.GetWeakPtr(), task_runner_, in Watch()
243 task_runner_->PostTask( in ArmOrNotify()
|
| /external/perfetto/src/profiling/perf/ |
| D | unwinding.h | 195 base::UnixTaskRunner* const task_runner_; variable
217 task_runner_ = task_runner; in UnwinderHandle()
230 init_cv.wait(lock, [this] { return !!task_runner_ && !!unwinder_; }); in UnwinderHandle()
234 if (task_runner_) { in ~UnwinderHandle()
235 PERFETTO_CHECK(!task_runner_->QuitCalled()); in ~UnwinderHandle()
236 task_runner_->Quit(); in ~UnwinderHandle()
258 base::UnixTaskRunner* task_runner_ = nullptr; variable
|
| /external/perfetto/src/tracing/internal/ |
| D | tracing_muxer_impl.cc | 208 muxer_->task_runner_->PostTask( in NotifyStartComplete()
217 muxer_->task_runner_->PostTask(std::move(stop_complete_callback_)); in NotifyStopComplete()
221 muxer_->task_runner_->PostTask(std::move(blocking_stop_complete_callback_)); in NotifyStopComplete()
254 muxer_->task_runner_->PostTask([callback, buf, has_more] { in OnTraceData()
310 muxer->task_runner_->PostTask( in ~TracingSessionImpl()
324 muxer->task_runner_->PostTask([muxer, session_id, trace_config, fd] { in Setup()
333 muxer->task_runner_->PostTask( in Start()
339 PERFETTO_DCHECK(!muxer_->task_runner_->RunsTasksOnCurrentThread()); in StartBlocking()
343 muxer->task_runner_->PostTask([muxer, session_id, &tracing_started] { in StartBlocking()
358 muxer->task_runner_->PostTask( in Stop()
[all …]
|
| /external/perfetto/src/traced/probes/ |
| D | probes_producer.cc | 119 return task_runner_->PostTask([this] { this->Restart(); }); in OnDisconnect()
123 task_runner_->PostDelayedTask([this] { this->Connect(); }, in OnDisconnect()
134 base::TaskRunner* task_runner = task_runner_; in Restart()
218 ftrace_ = FtraceController::Create(task_runner_, this); in CreateFtraceDataSource()
253 std::move(source_config), task_runner_, session_id, &system_inodes_, in CreateInodeFileDataSource()
262 task_runner_, session_id, endpoint_->CreateTraceWriter(buffer_id), config, in CreateProcessStatsDataSource()
271 new AndroidPowerDataSource(config, task_runner_, session_id, in CreateAndroidPowerDataSource()
280 new AndroidLogDataSource(config, task_runner_, session_id, in CreateAndroidLogDataSource()
297 new SysStatsDataSource(task_runner_, session_id, in CreateSysStatsDataSource()
306 task_runner_, session_id, endpoint_->CreateTraceWriter(buffer_id))); in CreateMetatraceDataSource()
[all …]
|
| /external/libchrome/base/task/sequence_manager/ |
| D | thread_controller_impl.cc | 24 task_runner_(task_runner), in ThreadControllerImpl()
76 task_runner_->PostTask(FROM_HERE, immediate_do_work_closure_); in ScheduleWork()
116 task_runner_->PostDelayedTask( in SetNextDelayedDoWork()
121 return task_runner_->RunsTasksInCurrentSequence(); in RunsTasksInCurrentSequence()
199 task_runner_->PostTask(FROM_HERE, immediate_do_work_closure_); in DoWork()
208 task_runner_->PostDelayedTask( in DoWork()
245 task_runner_->PostTask(FROM_HERE, immediate_do_work_closure_); in OnBeginNestedRunLoop()
|