Method GetNQueue

phxqueue/config/topicconfig.cpp:404–414

}

comm::RetCode TopicConfig::GetNQueue(const int queue_info_id, int &nqueue) 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;

    nqueue = 0;
    for (auto &&range : ranges) {
        nqueue += range.second - range.first + 1;
    }
    return comm::RetCode::RET_OK;
}

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);