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()
97       static_cast<double>(service_ns) / static_cast<double>(message_count));  in BenchmarkProducer()
100   state.SetBytesProcessed(iterations * message_bytes * message_count);  in BenchmarkProducer()
140   uint32_t message_count = kBufferSizeBytes / message_bytes;  in BenchmarkConsumer()  local
143       is_saturated_producer ? 0 : std::max(1u, message_count / messages_per_s);  in BenchmarkConsumer()
149   ds_config->mutable_for_testing()->set_message_count(message_count);  in BenchmarkConsumer()
212                          static_cast<double>(message_count));  in BenchmarkConsumer()
234   int message_count = IsBenchmarkFunctionalOnly() ? 2 * 1024 : 128 * 1024;  in ConstantRateProducerArgs()  local
238     b->Args({message_count, 128, speed});  in ConstantRateProducerArgs()
239     b->Args({message_count, 256, speed});  in ConstantRateProducerArgs()