Searched refs:cur_consumer_num_ (Results 1 – 2 of 2) sorted by relevance
99 cur_consumer_num_++; in ConnectConsumer()101 std::to_string(cur_consumer_num_)); in ConnectConsumer()151 RunUntilCheckpoint("consumer.connected." + std::to_string(cur_consumer_num_)); in WaitForConsumerConnect()
90 int cur_consumer_num_ = 0; variable