Method PaxosAcquireLock

phxqueue/lock/lock.cpp:441–507

ret: RET_OK if acquired, others if not acquired

// ret: RET_OK if acquired, others if not acquired
comm::RetCode Lock::PaxosAcquireLock(const comm::proto::AcquireLockRequest &req,
                                     comm::proto::AcquireLockResponse &resp) {
    comm::LockBP::GetThreadInstance()->OnPaxosAcquireLock(req);

    auto &&lock_info(req.lock_info());
    uint32_t paxos_group_id{HashUi32(lock_info.lock_key()) % impl_->opt.nr_group};

    // paxos
    proto::LockPaxosArgs args;

    // 1. make args
    *args.mutable_acquire_lock_req() = req;

    // 2. serialize args to paxos value
    string buf;
    args.SerializeToString(&buf);

    // 3. send to paxos
    comm::LockBP::GetThreadInstance()->OnPropose(req);

    LockContext lc;
    phxpaxos::SMCtx sm_ctx(LockSM::ID, &lc);
    uint64_t instance_id{0};

    uint64_t t1{comm::utils::Time::GetSteadyClockMS()};
    int paxos_ret{impl_->node->Propose(paxos_group_id, buf, instance_id, &sm_ctx)};
    uint64_t t2{comm::utils::Time::GetSteadyClockMS()};
    uint64_t used_time_ms{t2 - t1};

    if (phxpaxos::PaxosTryCommitRet_OK != paxos_ret) {
        comm::LockBP::GetThreadInstance()->OnProposeErr(req, used_time_ms);
        QLErr("paxos_group %d lock \"%s\" Propose err %d buf.size %zu req.client_id \"%s\"",
              paxos_group_id, lock_info.lock_key().c_str(),
              paxos_ret, buf.size(), lock_info.client_id().c_str());
        switch (paxos_ret) {
            case phxpaxos::PaxosTryCommitRet_Timeout:
                comm::LockBP::GetThreadInstance()->OnProposeErrTimeout(req);
                return comm::RetCode::RET_ERR_PROPOSE_TIMEOUT;
            case phxpaxos::PaxosTryCommitRet_TooManyThreadWaiting_Reject:
                comm::LockBP::GetThreadInstance()->OnProposeErrTooManyThreadWaitingReject(req);
                return comm::RetCode::RET_ERR_PROPOSE_FAST_REJECT;
            case phxpaxos::PaxosTryCommitRet_Value_Size_TooLarge:
                comm::LockBP::GetThreadInstance()->OnProposeErrValueSizeTooLarge(req);
                return comm::RetCode::RET_ERR_SIZE_TOO_LARGE;
            default:
                comm::LockBP::GetThreadInstance()->OnProposeErrOther(req);
                return comm::RetCode::RET_ERR_PROPOSE;
        };
    }

    if (comm::RetCode::RET_OK != lc.result) {
        QLErr("paxos_group %d lock \"%s\" Propose err %d instance_id %" PRIu64
              " buf.size %zu req.client_id \"%s\"", paxos_group_id,
              lock_info.lock_key().c_str(), lc.result, instance_id, buf.size(),
              lock_info.client_id().c_str());
        comm::LockBP::GetThreadInstance()->OnProposeErrResult(req, instance_id, used_time_ms);

        return lc.result;