Method TestLockConfig

phxqueue/test/test_config.cpp:342–388

void TestConfig::TestLockConfig(const config::LockConfig *lock_config) {
    const int expected_lock_id{1};
    comm::proto::Addr expected_addr;
    expected_addr.set_ip("127.0.0.1");
    expected_addr.set_port(7100);
    expected_addr.set_paxos_port(7101);

    // GetAllLock
    {
        vector<shared_ptr<const config::proto::Lock> > locks;
        const int expected_nr_lock{1};

        assert(comm::RetCode::RET_OK == lock_config->GetAllLock(locks));
        assert(expected_nr_lock == locks.size());
    }

    // GetAllLockID
    {
        set<int> lock_ids;
        const int expected_nr_lock{1};

        assert(comm::RetCode::RET_OK == lock_config->GetAllLockID(lock_ids));
        assert(expected_nr_lock == lock_ids.size());
    }

    // GetLockByLockID
    {

        shared_ptr<const config::proto::Lock> lock;
        assert(comm::RetCode::RET_OK == lock_config->GetLockByLockID(expected_lock_id, lock));
        assert(lock);
    }

    // GetLockIDByAddr
    {
        int lock_id;
        assert(comm::RetCode::RET_OK == lock_config->GetLockIDByAddr(expected_addr, lock_id));
        assert(expected_lock_id == lock_id);
    }

    // GetLockByAddr
    {
        shared_ptr<const config::proto::Lock> lock;
        assert(comm::RetCode::RET_OK == lock_config->GetLockByAddr(expected_addr, lock));
        assert(lock);
    }
}


}  // namespace test