Home
last modified time | relevance | path

Searched refs:task_runner_ (Results 1 – 25 of 67) sorted by relevance

123

/external/perfetto/src/ipc/
Dunix_socket_unittest.cc77 base::TestTaskRunner task_runner_; member in perfetto::ipc::__anonb03aa6e70111::UnixSocketTest
82 auto cli = UnixSocket::Connect(kSocketName, &event_listener_, &task_runner_); in TEST_F()
84 auto checkpoint = task_runner_.CreateCheckpoint("failure"); in TEST_F()
87 task_runner_.RunUntilCheckpoint("failure"); in TEST_F()
93 auto srv = UnixSocket::Listen(kSocketName, &event_listener_, &task_runner_); in TEST_F()
98 auto srv_did_shutdown = task_runner_.CreateCheckpoint("srv_did_shutdown"); in TEST_F()
107 auto checkpoint = task_runner_.CreateCheckpoint("cli_connected"); in TEST_F()
108 auto cli = UnixSocket::Connect(kSocketName, &event_listener_, &task_runner_); in TEST_F()
111 task_runner_.RunUntilCheckpoint("cli_connected"); in TEST_F()
112 task_runner_.RunUntilCheckpoint("srv_did_shutdown"); in TEST_F()
[all …]
Dhost_impl_unittest.cc168 task_runner_.reset(new base::TestTaskRunner()); in SetUp()
169 Host* host = Host::CreateInstance(kSockName, task_runner_.get()).release(); in SetUp()
172 cli_.reset(new FakeClient(task_runner_.get())); in SetUp()
173 auto on_connect = task_runner_->CreateCheckpoint("on_connect"); in SetUp()
175 task_runner_->RunUntilCheckpoint("on_connect"); in SetUp()
179 task_runner_->RunUntilIdle(); in TearDown()
182 task_runner_->RunUntilIdle(); in TearDown()
183 task_runner_.reset(); in TearDown()
188 std::unique_ptr<base::TestTaskRunner> task_runner_; member in perfetto::ipc::__anon38f9ad6a0111::HostImplTest
197 auto on_bind_failure = task_runner_->CreateCheckpoint("on_bind_failure"); in TEST_F()
[all …]
Dclient_impl_unittest.cc201 task_runner_.reset(new base::TestTaskRunner()); in SetUp()
202 host_.reset(new FakeHost(task_runner_.get())); in SetUp()
203 cli_ = Client::CreateInstance(kSockName, task_runner_.get()); in SetUp()
209 task_runner_->RunUntilIdle(); in TearDown()
210 task_runner_.reset(); in TearDown()
214 std::unique_ptr<base::TestTaskRunner> task_runner_; member in perfetto::ipc::__anon4e10636b0111::ClientImplTest
227 auto on_connect = task_runner_->CreateCheckpoint("on_connect"); in TEST_F()
229 task_runner_->RunUntilCheckpoint("on_connect"); in TEST_F()
245 auto on_invoke_reply = task_runner_->CreateCheckpoint("on_invoke_reply"); in TEST_F()
252 task_runner_->RunUntilCheckpoint("on_invoke_reply"); in TEST_F()
[all …]
/external/perfetto/src/base/test/
Dtest_task_runner.cc36 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/
Dtracing_integration_test.cc108 task_runner_.reset(new base::TestTaskRunner()); in SetUp()
111 svc_ = ServiceIPCHost::CreateInstance(task_runner_.get()); in SetUp()
117 task_runner_.get()); in SetUp()
119 task_runner_->CreateCheckpoint("on_producer_connect"); in SetUp()
121 task_runner_->RunUntilCheckpoint("on_producer_connect"); in SetUp()
130 kConsumerSockName, &consumer_, task_runner_.get()); in SetUp()
132 task_runner_->CreateCheckpoint("on_consumer_connect"); in SetUp()
134 task_runner_->RunUntilCheckpoint("on_consumer_connect"); in SetUp()
145 task_runner_->CreateCheckpoint("on_producer_disconnect"); in TearDown()
150 task_runner_->CreateCheckpoint("on_consumer_disconnect"); in TearDown()
[all …]
Dmock_consumer.cc28 : task_runner_(task_runner) {} in MockConsumer()
35 auto on_disconnect = task_runner_->CreateCheckpoint(checkpoint_name); in ~MockConsumer()
38 task_runner_->RunUntilCheckpoint(checkpoint_name); in ~MockConsumer()
45 auto on_connect = task_runner_->CreateCheckpoint(checkpoint_name); in Connect()
47 task_runner_->RunUntilCheckpoint(checkpoint_name); in Connect()
66 auto on_tracing_disabled = task_runner_->CreateCheckpoint(checkpoint_name); in WaitForTracingDisabled()
68 task_runner_->RunUntilCheckpoint(checkpoint_name); in WaitForTracingDisabled()
74 auto on_flush = task_runner_->CreateCheckpoint(checkpoint_name); in Flush()
81 base::TestTaskRunner* task_runner = task_runner_; in Flush()
95 auto on_read_buffers = task_runner_->CreateCheckpoint(checkpoint_name); in ReadBuffers()
[all …]
Dmock_producer.cc33 : task_runner_(task_runner) {} in MockProducer()
40 auto on_disconnect = task_runner_->CreateCheckpoint(checkpoint_name); in ~MockProducer()
43 task_runner_->RunUntilCheckpoint(checkpoint_name); in ~MockProducer()
54 auto on_connect = task_runner_->CreateCheckpoint(checkpoint_name); in Connect()
56 task_runner_->RunUntilCheckpoint(checkpoint_name); in Connect()
73 auto on_tracing_enabled = task_runner_->CreateCheckpoint(checkpoint_name); in WaitForTracingSetup()
75 task_runner_->RunUntilCheckpoint(checkpoint_name); in WaitForTracingSetup()
81 auto on_ds_start = task_runner_->CreateCheckpoint(checkpoint_name); in WaitForDataSourceStart()
92 task_runner_->RunUntilCheckpoint(checkpoint_name); in WaitForDataSourceStart()
98 auto on_ds_stop = task_runner_->CreateCheckpoint(checkpoint_name); in WaitForDataSourceStop()
[all …]
/external/webrtc/webrtc/base/
Dtask_unittest.cc138 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/perfetto/test/
Dtest_helper.cc43 : task_runner_(task_runner), in TestHelper()
88 WrapTask(task_runner_->CreateCheckpoint("producer.enabled")))); in ConnectFakeProducer()
95 on_connect_callback_ = task_runner_->CreateCheckpoint("consumer.connected"); in ConnectConsumer()
97 ConsumerIPCClient::Connect(TEST_CONSUMER_SOCK_NAME, this, task_runner_); in ConnectConsumer()
101 on_stop_tracing_callback_ = task_runner_->CreateCheckpoint("stop.tracing"); in StartTracing()
107 task_runner_->CreateCheckpoint("readback.complete"); in ReadData()
112 task_runner_->RunUntilCheckpoint("consumer.connected"); in WaitForConsumerConnect()
116 task_runner_->RunUntilCheckpoint("producer.enabled"); in WaitForProducerEnabled()
120 task_runner_->RunUntilCheckpoint("stop.tracing"); in WaitForTracingDisabled()
124 task_runner_->RunUntilCheckpoint("readback.complete"); in WaitForReadData()
[all …]
/external/libchrome/base/threading/
Dthread_task_runner_handle.cc29 return current->task_runner_; in Get()
64 ttrh->task_runner_.swap(overriding_task_runner); in OverrideForTesting()
71 DCHECK_EQ(expected_task_runner_before_restore, ttrh->task_runner_.get()) in OverrideForTesting()
75 ttrh->task_runner_.swap(task_runner_to_restore); in OverrideForTesting()
78 base::Unretained(ttrh->task_runner_.get()))); in OverrideForTesting()
83 : task_runner_(std::move(task_runner)) { in ThreadTaskRunnerHandle()
84 DCHECK(task_runner_->BelongsToCurrentThread()); in ThreadTaskRunnerHandle()
92 DCHECK(task_runner_->BelongsToCurrentThread()); in ~ThreadTaskRunnerHandle()
Dsequenced_task_runner_handle.cc47 return handle->task_runner_; in Get()
73 : task_runner_(std::move(task_runner)) { in SequencedTaskRunnerHandle()
74 DCHECK(task_runner_->RunsTasksOnCurrentThread()); in SequencedTaskRunnerHandle()
80 DCHECK(task_runner_->RunsTasksOnCurrentThread()); in ~SequencedTaskRunnerHandle()
/external/perfetto/src/ipc/test/
Dipc_integrationtest.cc69 perfetto::base::TestTaskRunner task_runner_; member in ipc_test::__anon30e3f86a0111::IPCIntegrationTest
74 std::unique_ptr<Host> host = Host::CreateInstance(kSockName, &task_runner_); in TEST_F()
80 auto on_connect = task_runner_.CreateCheckpoint("on_connect"); in TEST_F()
83 Client::CreateInstance(kSockName, &task_runner_); in TEST_F()
86 task_runner_.RunUntilCheckpoint("on_connect"); in TEST_F()
91 auto on_reply = task_runner_.CreateCheckpoint("on_hello_reply"); in TEST_F()
108 task_runner_.RunUntilCheckpoint("on_hello_reply"); in TEST_F()
114 auto on_reply = task_runner_.CreateCheckpoint("on_goodbye_reply"); in TEST_F()
131 task_runner_.RunUntilCheckpoint("on_goodbye_reply"); in TEST_F()
/external/libmojo/mojo/public/cpp/bindings/
Dthread_safe_interface_ptr.h46 task_runner_(task_runner), in ThreadSafeForwarder()
71 task_runner_->PostTask(FROM_HERE, in Accept()
86 task_runner_->PostTask( in AcceptWithResponder()
122 const scoped_refptr<base::SingleThreadTaskRunner> task_runner_; variable
189 : task_runner_(task_runner) {} in PtrWrapper()
193 task_runner_->PostTask(FROM_HERE, base::Bind(&PtrWrapper::Bind, this, in BindOnTaskRunner()
205 task_runner_->PostTask(FROM_HERE, base::Bind(&PtrWrapper::Bind, this, in BindOnTaskRunner()
211 task_runner_, base::Bind(&PtrWrapper::Accept, this), in CreateForwarder()
222 DCHECK(task_runner_->RunsTasksOnCurrentThread()); in Bind()
237 if (!task_runner_->RunsTasksOnCurrentThread()) { in DeleteOnCorrectThread()
[all …]
/external/perfetto/src/tracing/core/
Dshared_memory_arbiter_impl_unittest.cc54 task_runner_.reset(new base::TestTaskRunner()); in SetUp()
57 task_runner_.get())); in SetUp()
62 task_runner_.reset(); in TearDown()
65 std::unique_ptr<base::TestTaskRunner> task_runner_; member in perfetto::__anone73f96a70111::SharedMemoryArbiterImplTest
93 auto on_commit_1 = task_runner_->CreateCheckpoint("on_commit_1"); in TEST_P()
112 task_runner_->RunUntilCheckpoint("on_commit_1"); in TEST_P()
116 auto on_commit_2 = task_runner_->CreateCheckpoint("on_commit_2"); in TEST_P()
127 task_runner_->RunUntilCheckpoint("on_commit_2"); in TEST_P()
Dtrace_writer_impl_unittest.cc52 task_runner_.reset(new base::TestTaskRunner()); in SetUp()
55 task_runner_.get())); in SetUp()
60 task_runner_.reset(); in TearDown()
64 std::unique_ptr<base::TestTaskRunner> task_runner_; member in perfetto::__anonab3883bb0111::TraceWriterImplTest
Dservice_impl.cc83 : task_runner_(task_runner), in ServiceImpl()
88 PERFETTO_DCHECK(task_runner_); in ServiceImpl()
116 id, uid, this, task_runner_, producer, producer_name)); in ConnectProducer()
120 task_runner_->PostTask(std::bind(&Producer::OnConnect, endpoint->producer_)); in ConnectProducer()
156 new ConsumerEndpointImpl(this, task_runner_, consumer)); in ConnectConsumer()
159 task_runner_->PostTask(std::bind(&Consumer::OnConnect, endpoint->consumer_)); in ConnectConsumer()
328 task_runner_->PostDelayedTask( in EnableTracing()
339 task_runner_->PostDelayedTask( in EnableTracing()
437 task_runner_->PostDelayedTask( in Flush()
455 task_runner_->PostTask( in NotifyFlushDoneForProducer()
[all …]
/external/perfetto/src/tracing/ipc/service/
Dservice_ipc_host_impl.cc39 : 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_ = Service::CreateInstance(std::move(shm_factory), task_runner_); in DoStart()
/external/libmojo/mojo/public/cpp/bindings/lib/
Dinterface_endpoint_client.cc47 task_runner_(std::move(runner)) {} in ResponderThunk()
55 if (task_runner_->RunsTasksOnCurrentThread()) { in ~ResponderThunk()
64 task_runner_->PostTask( in ~ResponderThunk()
73 DCHECK(task_runner_->RunsTasksOnCurrentThread()); in Accept()
87 DCHECK(task_runner_->RunsTasksOnCurrentThread()); in IsValid()
92 if (task_runner_->RunsTasksOnCurrentThread()) { in DCheckInvalid()
95 task_runner_->PostTask( in DCheckInvalid()
103 scoped_refptr<base::SingleThreadTaskRunner> task_runner_; member in mojo::__anon5d57c4730111::ResponderThunk
146 task_runner_(std::move(runner)), in InterfaceEndpointClient()
346 task_runner_); in InitControllerIfNecessary()
[all …]
Dmultiplex_router.cc80 return task_runner_.get(); in task_runner()
92 task_runner_ = std::move(runner); in AttachClient()
101 DCHECK(task_runner_->BelongsToCurrentThread()); in DetachClient()
104 task_runner_ = nullptr; in DetachClient()
146 DCHECK(task_runner_->BelongsToCurrentThread()); in SendMessage()
152 DCHECK(task_runner_->BelongsToCurrentThread()); in AllowWokenUpBySyncWatchOnSameThread()
159 DCHECK(task_runner_->BelongsToCurrentThread()); in SyncWatch()
178 DCHECK(task_runner_->BelongsToCurrentThread()); in OnHandleReady()
204 DCHECK(task_runner_->BelongsToCurrentThread()); in EnsureSyncWatcherExists()
252 scoped_refptr<base::SingleThreadTaskRunner> task_runner_; member in mojo::internal::MultiplexRouter::InterfaceEndpoint
[all …]
/external/perfetto/src/traced/probes/
Dprobes_producer.cc86 return task_runner_->PostTask([this] { this->Restart(); }); in OnDisconnect()
90 task_runner_->PostDelayedTask([this] { this->Connect(); }, in OnDisconnect()
101 base::TaskRunner* task_runner = task_runner_; in Restart()
168 ftrace_ = FtraceController::Create(task_runner_); in CreateFtraceDataSourceInstance()
189 new SinkDelegate(session_id, task_runner_, std::move(trace_writer))); in CreateFtraceDataSourceInstance()
213 std::move(source_config), task_runner_, session_id, &system_inodes_, in CreateInodeFileDataSourceInstance()
285 task_runner_ = task_runner; in ConnectWithRetries()
293 socket_name_, this, "perfetto.traced_probes", task_runner_); in Connect()
310 task_runner_(task_runner), in SinkDelegate()
363 task_runner_->PostTask([weak_file_source, inodes] { in OnBundleComplete()
[all …]
/external/libmojo/mojo/public/cpp/system/
Dwatcher.cc17 : task_runner_(std::move(runner)), in Watcher()
18 is_default_task_runner_(task_runner_ == in Watcher()
22 DCHECK(task_runner_->BelongsToCurrentThread()); in Watcher()
104 watcher->task_runner_->RunsTasksOnCurrentThread() && in CallOnHandleReady()
111 watcher->task_runner_->PostTask( in CallOnHandleReady()
/external/perfetto/src/perfetto_cmd/
Dperfetto_cmd.cc241 ConsumerIPCClient::Connect(GetConsumerSocket(), this, &task_runner_); in Main()
243 task_runner_.Run(); in Main()
266 task_runner_.PostDelayedTask(std::bind(&PerfettoCmd::OnTimeout, this), in OnConnect()
273 task_runner_.Quit(); in OnDisconnect()
278 task_runner_.Quit(); in OnTimeout()
349 task_runner_.Quit(); in FinalizeTraceAndExit()
401 task_runner_.AddFileDescriptorWatch( in SetupCtrlCSignalHandler()
/external/libchrome/base/files/
Dfile_path_watcher.h59 return task_runner_; in task_runner()
63 task_runner_ = std::move(runner); in set_task_runner()
76 scoped_refptr<SequencedTaskRunner> task_runner_;
/external/libchrome/base/test/
Dtest_mock_time_task_runner.cc34 scoped_refptr<const TestMockTimeTaskRunner> task_runner_; member in base::__anon9dbca1a10111::MockTickClock
41 : task_runner_(task_runner) { in MockTickClock()
45 return task_runner_->NowTicks(); in NowTicks()
60 scoped_refptr<const TestMockTimeTaskRunner> task_runner_; member in base::__anon9dbca1a10111::MockClock
66 : task_runner_(task_runner) { in MockClock()
70 return task_runner_->Now(); in Now()
/external/perfetto/src/traced/probes/filesystem/
Dinode_file_data_source_unittest.cc70 cfg, &task_runner_, 0, &static_file_map_, &cache_, in GetInodeFileDataSource()
77 base::TestTaskRunner task_runner_; member in perfetto::__anon3e2209370111::InodeFileDataSourceTest
90 auto done = task_runner_.CreateCheckpoint("done"); in TEST_F()
97 task_runner_.RunUntilCheckpoint("done"); in TEST_F()

123