57   uint32_t message_count = static_cast<uint32_t>(state.range(0));  in BenchmarkProducer()  local
63       10000 + (messages_per_s == 0 ? 0 : message_count * 1000 / messages_per_s);  in BenchmarkProducer()
66   ds_config->mutable_for_testing()->set_message_count(message_count);  in BenchmarkProducer()
92       benchmark::Counter(1.0 * service_ns / message_count);  in BenchmarkProducer()
94   state.SetBytesProcessed(iterations * message_bytes * message_count);  in BenchmarkProducer()
134   uint32_t message_count = kBufferSizeBytes / message_bytes;  in BenchmarkConsumer()  local
137       is_saturated_producer ? 0 : std::max(1u, message_count / messages_per_s);  in BenchmarkConsumer()
143   ds_config->mutable_for_testing()->set_message_count(message_count);  in BenchmarkConsumer()
203       benchmark::Counter(1.0 * service_ns / message_count);  in BenchmarkConsumer()
223   int message_count = IsBenchmarkFunctionalOnly() ? 2 * 1024 : 128 * 1024;  in ConstantRateProducerArgs()  local
227     b->Args({message_count, 128, speed});  in ConstantRateProducerArgs()
228     b->Args({message_count, 256, speed});  in ConstantRateProducerArgs()