Searched refs:cur_consumer_num_ (Results 1 – 2 of 2) sorted by relevance
127 cur_consumer_num_++; in ConnectConsumer()129 std::to_string(cur_consumer_num_)); in ConnectConsumer()212 RunUntilCheckpoint("consumer.connected." + std::to_string(cur_consumer_num_)); in WaitForConsumerConnect()
282 int cur_consumer_num_ = 0; variable