Method CheckStoreConfig

phxqueue/test/check_config.cpp:226–261

}

void CheckConfig::CheckStoreConfig(const int topic_id, const config::StoreConfig *store_config) {

    std::vector<std::shared_ptr<const config::proto::Store>> stores;
    PHX_ASSERT(phxqueue::comm::as_integer(comm::RetCode::RET_OK), ==, phxqueue::comm::as_integer(store_config->GetAllStore(stores)));

    std::set<int> store_ids;
    PHX_ASSERT(phxqueue::comm::as_integer(comm::RetCode::RET_OK), ==, phxqueue::comm::as_integer(store_config->GetAllStoreID(store_ids)));
    PHX_ASSERT(store_ids.size(), ==, stores.size());

    for (auto &&store : stores) {
        auto store_id = store->store_id();

        PHX_ASSERT(store_ids.end() != store_ids.find(store_id), ==, true);

        {
            std::shared_ptr<const config::proto::Store> tmp_store;
            PHX_ASSERT(phxqueue::comm::as_integer(comm::RetCode::RET_OK), ==, phxqueue::comm::as_integer(store_config->GetStoreByStoreID(store_id, tmp_store)));
            PHX_ASSERT(store_id, ==, tmp_store->store_id());
        }

        for (int i{0}; i < store->addrs_size(); ++i) {
            auto &&addr = store->addrs(i);

            {
                int tmp_store_id;
                PHX_ASSERT(phxqueue::comm::as_integer(comm::RetCode::RET_OK), ==, phxqueue::comm::as_integer(store_config->GetStoreIDByAddr(addr, tmp_store_id)));
                PHX_ASSERT(tmp_store_id, ==, store_id);
            }
            {
                std::shared_ptr<const config::proto::Store> tmp_store;
                PHX_ASSERT(phxqueue::comm::as_integer(comm::RetCode::RET_OK), ==, phxqueue::comm::as_integer(store_config->GetStoreByAddr(addr, tmp_store)));
                PHX_ASSERT(tmp_store->store_id(), ==, store_id);
            }
        }
    }
}


void CheckConfig::CheckSchedulerConfig(const int topic_id, const config::SchedulerConfig *scheduler_config) {