Searched refs:on_produced_and_committed (Results 1 – 2 of 2) sorted by relevance
58 std::function<void()> on_produced_and_committed) in FakeProducer() argument62 on_produced_and_committed_(on_produced_and_committed) {} in FakeProducer()114 std::function<void()> on_produced_and_committed) in FuzzerFakeProducerThread() argument117 on_produced_and_committed_(on_produced_and_committed) {} in FuzzerFakeProducerThread()
81 auto on_produced_and_committed = task_runner.CreateCheckpoint(cname); in BenchmarkProducer() local82 producer->ProduceEventBatch(helper.WrapTask(on_produced_and_committed)); in BenchmarkProducer()167 auto on_produced_and_committed = task_runner.CreateCheckpoint(cname); in BenchmarkConsumer() local168 producer->ProduceEventBatch(helper.WrapTask(on_produced_and_committed)); in BenchmarkConsumer()