45     if (!runner_)  in ~ServiceThread()
47     runner_->PostTaskAndWaitForTesting([this]() { svc_.reset(); });  in ~ServiceThread()
51     runner_ = base::ThreadTaskRunner::CreateAndStart("perfetto.svc");  in Start()
52     runner_->PostTaskAndWaitForTesting([this]() {  in Start()
53       svc_ = ServiceIPCHost::CreateInstance(runner_->get());  in Start()
63   base::ThreadTaskRunner* runner() { return runner_ ? &*runner_ : nullptr; }  in runner()
66   base::Optional<base::ThreadTaskRunner> runner_;  // Keep first.
80     if (!runner_)  in ~ProbesProducerThread()
82     runner_->PostTaskAndWaitForTesting([this]() { producer_.reset(); });  in ~ProbesProducerThread()
86     runner_ = base::ThreadTaskRunner::CreateAndStart("perfetto.prd.probes");  in Connect()
87     runner_->PostTaskAndWaitForTesting([this]() {  in Connect()
89       producer_->ConnectWithRetries(producer_socket_.c_str(), runner_->get());  in Connect()
94   base::Optional<base::ThreadTaskRunner> runner_;  // Keep first.
110     runner_ = base::ThreadTaskRunner::CreateAndStart("perfetto.prd.fake");  in FakeProducerThread()
111     runner_->PostTaskAndWaitForTesting([this]() {  in FakeProducerThread()
113           new FakeProducer("android.perfetto.FakeProducer", runner_->get()));  in FakeProducerThread()
118     runner_->PostTaskAndWaitForTesting([this]() { producer_.reset(); });  in ~FakeProducerThread()
122     runner_->PostTaskAndWaitForTesting([this]() {  in Connect()
129   base::ThreadTaskRunner* runner() { return runner_ ? &*runner_ : nullptr; }  in runner()
147   base::Optional<base::ThreadTaskRunner> runner_;  // Keep first.