42   TestHelper helper(&task_runner);  in BenchmarkProducer()  local
43   helper.StartServiceIfRequired();  in BenchmarkProducer()
45   FakeProducer* producer = helper.ConnectFakeProducer();  in BenchmarkProducer()
46   helper.ConnectConsumer();  in BenchmarkProducer()
47   helper.WaitForConsumerConnect();  in BenchmarkProducer()
70   helper.StartTracing(trace_config);  in BenchmarkProducer()
71   helper.WaitForProducerEnabled();  in BenchmarkProducer()
74   uint64_t service_start_ns = helper.service_thread()->GetThreadCPUTimeNs();  in BenchmarkProducer()
75   uint64_t producer_start_ns = helper.producer_thread()->GetThreadCPUTimeNs();  in BenchmarkProducer()
80     producer->ProduceEventBatch(helper.WrapTask(on_produced_and_committed));  in BenchmarkProducer()
84       helper.service_thread()->GetThreadCPUTimeNs() - service_start_ns;  in BenchmarkProducer()
86       helper.producer_thread()->GetThreadCPUTimeNs() - producer_start_ns;  in BenchmarkProducer()
97   helper.ReadData();  in BenchmarkProducer()
98   helper.WaitForReadData();  in BenchmarkProducer()
102   for (const auto& packet : helper.trace()) {  in BenchmarkProducer()
116   TestHelper helper(&task_runner);  in BenchmarkConsumer()  local
117   helper.StartServiceIfRequired();  in BenchmarkConsumer()
119   FakeProducer* producer = helper.ConnectFakeProducer();  in BenchmarkConsumer()
120   helper.ConnectConsumer();  in BenchmarkConsumer()
121   helper.WaitForConsumerConnect();  in BenchmarkConsumer()
147   helper.StartTracing(trace_config);  in BenchmarkConsumer()
148   helper.WaitForProducerEnabled();  in BenchmarkConsumer()
152       static_cast<uint64_t>(helper.service_thread()->GetThreadCPUTimeNs());  in BenchmarkConsumer()
162     producer->ProduceEventBatch(helper.WrapTask(on_produced_and_committed));  in BenchmarkConsumer()
171       helper.ReadData(counter);  in BenchmarkConsumer()
172       helper.WaitForReadData(counter++);  in BenchmarkConsumer()
186         helper.ReadData(counter);  in BenchmarkConsumer()
187         helper.WaitForReadData(counter++);  in BenchmarkConsumer()
194       helper.service_thread()->GetThreadCPUTimeNs() - service_start_ns;  in BenchmarkConsumer()