61     if (!runner_)  in ~ServiceThread()
63     runner_->PostTaskAndWaitForTesting([this]() { svc_.reset(); });  in ~ServiceThread()
67     runner_ = base::ThreadTaskRunner::CreateAndStart("perfetto.svc");  in Start()
68     runner_->PostTaskAndWaitForTesting([this]() {  in Start()
69       svc_ = ServiceIPCHost::CreateInstance(runner_->get());  in Start()
89   base::ThreadTaskRunner* runner() { return runner_ ? &*runner_ : nullptr; }  in runner()
92   base::Optional<base::ThreadTaskRunner> runner_;  // Keep first.
115     if (!runner_)  in ~ProbesProducerThread()
117     runner_->PostTaskAndWaitForTesting([this]() { producer_.reset(); });  in ~ProbesProducerThread()
121     runner_ = base::ThreadTaskRunner::CreateAndStart("perfetto.prd.probes");  in Connect()
122     runner_->PostTaskAndWaitForTesting([this]() {  in Connect()
124       producer_->ConnectWithRetries(producer_socket_.c_str(), runner_->get());  in Connect()
129   base::Optional<base::ThreadTaskRunner> runner_;  // Keep first.
146     runner_ = base::ThreadTaskRunner::CreateAndStart("perfetto.prd.fake");  in FakeProducerThread()
147     runner_->PostTaskAndWaitForTesting([this]() {  in FakeProducerThread()
149           new FakeProducer("android.perfetto.FakeProducer", runner_->get()));  in FakeProducerThread()
154     runner_->PostTaskAndWaitForTesting([this]() { producer_.reset(); });  in ~FakeProducerThread()
158     runner_->PostTaskAndWaitForTesting([this]() {  in Connect()
165   base::ThreadTaskRunner* runner() { return runner_ ? &*runner_ : nullptr; }  in runner()
186   base::Optional<base::ThreadTaskRunner> runner_;  // Keep first.