Searched refs:messages_per_s (Results 1 – 1 of 1) sorted by relevance
61 uint32_t messages_per_s = mb_per_s * 1024 * 1024 / message_bytes; in BenchmarkProducer() local63 10000 + (messages_per_s == 0 ? 0 : message_count * 1000 / messages_per_s); in BenchmarkProducer()68 ds_config->mutable_for_testing()->set_max_messages_per_second(messages_per_s); in BenchmarkProducer()135 uint32_t messages_per_s = mb_per_s * 1024 * 1024 / message_bytes; in BenchmarkConsumer() local137 is_saturated_producer ? 0 : std::max(1u, message_count / messages_per_s); in BenchmarkConsumer()145 ds_config->mutable_for_testing()->set_max_messages_per_second(messages_per_s); in BenchmarkConsumer()