Method CheckLockConfig

phxqueue/test/check_config.cpp:268–303

void CheckConfig::CheckLockConfig(const int topic_id, const config::LockConfig *lock_config) {

    std::vector<std::shared_ptr<const config::proto::Lock> > locks;
    PHX_ASSERT(phxqueue::comm::as_integer(comm::RetCode::RET_OK), ==, phxqueue::comm::as_integer(lock_config->GetAllLock(locks)));

    std::set<int> lock_ids;
    PHX_ASSERT(phxqueue::comm::as_integer(comm::RetCode::RET_OK), ==, phxqueue::comm::as_integer(lock_config->GetAllLockID(lock_ids)));
    PHX_ASSERT(locks.size(), ==, lock_ids.size());

    for (auto &&lock : locks) {
        auto lock_id = lock->lock_id();

        PHX_ASSERT(lock_ids.end() != lock_ids.find(lock_id), ==, true);

        {
            std::shared_ptr<const config::proto::Lock> tmp_lock;
            PHX_ASSERT(phxqueue::comm::as_integer(comm::RetCode::RET_OK), ==, phxqueue::comm::as_integer(lock_config->GetLockByLockID(lock_id, tmp_lock)));
            PHX_ASSERT(lock_id, ==, tmp_lock->lock_id());
        }

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

            {
                int tmp_lock_id;
                PHX_ASSERT(phxqueue::comm::as_integer(comm::RetCode::RET_OK), ==, phxqueue::comm::as_integer(lock_config->GetLockIDByAddr(addr, tmp_lock_id)));
                PHX_ASSERT(tmp_lock_id, ==, lock_id);
            }
            {
                std::shared_ptr<const config::proto::Lock> tmp_lock;
                PHX_ASSERT(phxqueue::comm::as_integer(comm::RetCode::RET_OK), ==, phxqueue::comm::as_integer(lock_config->GetLockByAddr(addr, tmp_lock)));
                PHX_ASSERT(tmp_lock->lock_id(), ==, lock_id);
            }
        }
    }
}


}  // namespace test