Method Process

phxqueue/test/check_config.cpp:32–65

void CheckConfig::Process() {
    auto global_config = config::GlobalConfig::GetThreadInstance();

    CheckGlobalConfig(global_config);

    std::set<int> topic_ids;
    PHX_ASSERT(phxqueue::comm::as_integer(comm::RetCode::RET_OK), ==, phxqueue::comm::as_integer(global_config->GetAllTopicID(topic_ids)));

    for (auto &&topic_id : topic_ids) {
        QLInfo("topic_id %d checking...", topic_id);

        shared_ptr<const config::TopicConfig> topic_config;
        PHX_ASSERT(phxqueue::comm::as_integer(comm::RetCode::RET_OK), ==, phxqueue::comm::as_integer(global_config->GetTopicConfigByTopicID(topic_id, topic_config)));
        CheckTopicConfig(topic_id, topic_config.get());

        shared_ptr<const config::ConsumerConfig> consumer_config;
        PHX_ASSERT(phxqueue::comm::as_integer(comm::RetCode::RET_OK), ==, phxqueue::comm::as_integer(global_config->GetConsumerConfig(topic_id, consumer_config)));
        CheckConsumerConfig(topic_id, consumer_config.get());

        shared_ptr<const config::StoreConfig> store_config;
        PHX_ASSERT(phxqueue::comm::as_integer(comm::RetCode::RET_OK), ==, phxqueue::comm::as_integer(global_config->GetStoreConfig(topic_id, store_config)));
        CheckStoreConfig(topic_id, store_config.get());

        shared_ptr<const config::SchedulerConfig> scheduler_config;
        PHX_ASSERT(phxqueue::comm::as_integer(comm::RetCode::RET_OK), ==, phxqueue::comm::as_integer(global_config->GetSchedulerConfig(topic_id, scheduler_config)));
        CheckSchedulerConfig(topic_id, scheduler_config.get());

        shared_ptr<const config::LockConfig> lock_config;
        PHX_ASSERT(phxqueue::comm::as_integer(comm::RetCode::RET_OK), ==, phxqueue::comm::as_integer(global_config->GetLockConfig(topic_id, lock_config)));
        CheckLockConfig(topic_id, lock_config.get());

        QLInfo("topic_id %d done", topic_id);
    }
}

void CheckConfig::CheckGlobalConfig(config::GlobalConfig *global_config) {
}