Lines Matching refs:task_runner_

43     : 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()
129   return [this, function] { task_runner_->PostTask(function); };  in WrapTask()