Function TestAcquireLock

phxqueue/test/test_lock_main.cpp:54–81

}

void TestAcquireLock(lock::Lock &lock, const int topic_id, const int lock_id,
                     const string &lock_key, const uint64_t version) {
    NLVerb("begin");

    const string client_id{"test_client_123"};
    const uint64_t lease_time_ms{10000};

    comm::proto::AcquireLockRequest req;
    comm::proto::AcquireLockResponse resp;

    req.set_topic_id(topic_id);
    req.set_lock_id(lock_id);

    comm::proto::LockInfo *lock_info{req.mutable_lock_info()};
    lock_info->set_lock_key(lock_key);
    lock_info->set_version(version);
    lock_info->set_client_id(client_id);
    lock_info->set_lease_time_ms(lease_time_ms);

    comm::RetCode ret{lock.AcquireLock(req, resp)};
    if (comm::RetCode::RET_OK != ret) {
        NLErr("lock AcquireLock ret %d", as_integer(ret));

        return;
    }

    NLVerb("succ");
}

void LockRun(const int vpid) {
    comm::RetCode ret;