Method GetQueueByRank

phxqueue/config/topicconfig.cpp:416–433

}

comm::RetCode TopicConfig::GetQueueByRank(const int queue_info_id, const uint64_t rank, int &queue) const {
    auto &&it = impl_->queue_info_id2ranges.find(queue_info_id);
    if (it == impl_->queue_info_id2ranges.end()) return comm::RetCode::RET_ERR_RANGE_QUEUE_INFO;
    auto &&ranges = it->second;

    if (0 == ranges.size()) return comm::RetCode::RET_ERR_RANGE_RANK;

    uint64_t r{rank};
    for (auto &&range : ranges) {
        uint64_t w{range.second - range.first + 1};
        if (r >= w) r -= w;
        else {
            queue = (int)(range.first + r);
            return comm::RetCode::RET_OK;
        }
    }
    return comm::RetCode::RET_ERR_RANGE_RANK;
}

comm::RetCode TopicConfig::GetQueueByLoopRank(const int queue_info_id, const uint64_t rank, int &queue) const {
    comm::RetCode ret;