Method IsValidQueue

phxqueue/config/topicconfig.cpp:337–374

bool TopicConfig::IsValidQueue(const int queue_id, const int pub_id, const int sub_id) const {
    auto &&f = [&](const int arg_pub_id)->bool {
        if (-1 != sub_id) {
            auto &&it = impl_->pub_id2sub_ids.find(arg_pub_id);
            if (impl_->pub_id2sub_ids.end() == it) return false;
            auto &&sub_ids = it->second;
            auto &&it1 = sub_ids.find(sub_id);
            if (sub_ids.end() == it1) return false;
        }

        {
            auto &&it = impl_->pub_id2queue_info_ids.find(arg_pub_id);
            if (impl_->pub_id2queue_info_ids.end() == it) return false;
            auto &&queue_info_ids = it->second;
            for (auto &&queue_info_id : queue_info_ids) {
                auto &&it1 = impl_->queue_info_id2ranges.find(queue_info_id);
                if (impl_->queue_info_id2ranges.end() == it1) return false;
                auto &&ranges = it1->second;
                for (auto &&range : ranges) {
                    if (range.first <= queue_id && queue_id <= range.second) {
                        return true;
                    }
                }
            }
        }
        return false;
    };

    if (-1 != pub_id) {
        return f(pub_id);
    } else {
        for (auto &&kv : impl_->pub_id2pub) {
            if (f(kv.first)) return true;
        }
    }

    return false;
}

comm::RetCode TopicConfig::GetQueuesByQueueInfoID(const int queue_info_id, set<int> &queues) const {
    queues.clear();