Method CheckTopicConfig

phxqueue/test/check_config.cpp:70–211

}

void CheckConfig::CheckTopicConfig(const int topic_id, const config::TopicConfig *topic_config) {

    auto &&topic = topic_config->GetProto().topic();
    PHX_ASSERT(topic_id, ==, topic.topic_id());
    for (int i{0}; i < topic.handle_ids_size(); ++i) {
        auto handle_id = topic.handle_ids(i);
        int rank;
        PHX_ASSERT(phxqueue::comm::as_integer(comm::RetCode::RET_OK), ==, phxqueue::comm::as_integer(topic_config->GetHandleIDRank(handle_id, rank)));
        PHX_ASSERT(rank, ==, i);
    }

    // pub
    std::vector<std::shared_ptr<const config::proto::Pub>> pubs;
    PHX_ASSERT(phxqueue::comm::as_integer(comm::RetCode::RET_OK), ==, phxqueue::comm::as_integer(topic_config->GetAllPub(pubs)));

    std::set<int> pub_ids;
    PHX_ASSERT(phxqueue::comm::as_integer(comm::RetCode::RET_OK), ==, phxqueue::comm::as_integer(topic_config->GetAllPubID(pub_ids)));
    PHX_ASSERT(pubs.size(), ==, pub_ids.size());
    for (auto &&pub : pubs) {
        auto pub_id = pub->pub_id();
        PHX_ASSERT(pub_ids.end() != pub_ids.find(pub_id), ==, true);
        PHX_ASSERT(topic_config->IsValidPubID(pub_id), ==, true);

        {
            std::shared_ptr<const config::proto::Pub> tmp_pub;
            PHX_ASSERT(phxqueue::comm::as_integer(comm::RetCode::RET_OK), ==, phxqueue::comm::as_integer(topic_config->GetPubByPubID(pub_id, tmp_pub)));
            PHX_ASSERT(tmp_pub->pub_id(), ==, pub_id);
        }

        {
            std::set<int> sub_ids;
            PHX_ASSERT(phxqueue::comm::as_integer(comm::RetCode::RET_OK), ==, phxqueue::comm::as_integer(topic_config->GetSubIDsByPubID(pub_id, sub_ids)));
            PHX_ASSERT(pub->sub_ids_size(), ==, sub_ids.size());
            for (int i{0}; i < pub->sub_ids_size(); ++i) {
                auto sub_id = pub->sub_ids(i);
                PHX_ASSERT(sub_ids.end() != sub_ids.find(sub_id), ==, true);
            }
        }
    }

    // sub
    std::vector<std::shared_ptr<const config::proto::Sub>> subs;
    PHX_ASSERT(phxqueue::comm::as_integer(comm::RetCode::RET_OK), ==, phxqueue::comm::as_integer(topic_config->GetAllSub(subs)));

    std::set<int> sub_ids;
    PHX_ASSERT(phxqueue::comm::as_integer(comm::RetCode::RET_OK), ==, phxqueue::comm::as_integer(topic_config->GetAllSubID(sub_ids)));
    PHX_ASSERT(subs.size(), ==, sub_ids.size());
    for (auto &&sub : subs) {
        auto sub_id = sub->sub_id();
        PHX_ASSERT(sub_ids.end() != sub_ids.find(sub_id), ==, true);
        PHX_ASSERT(topic_config->IsValidSubID(sub_id), ==, true);

        {
            std::shared_ptr<const config::proto::Sub> tmp_sub;
            PHX_ASSERT(phxqueue::comm::as_integer(comm::RetCode::RET_OK), ==, phxqueue::comm::as_integer(topic_config->GetSubBySubID(sub_id, tmp_sub)));
            PHX_ASSERT(tmp_sub->sub_id(), ==, sub_id);
        }
    }