Method GetLockInfo

phxqueue/lock/lock.cpp:253–310

}

comm::RetCode Lock::GetLockInfo(const comm::proto::GetLockInfoRequest &req,
                                comm::proto::GetLockInfoResponse &resp) {
    comm::LockBP::GetThreadInstance()->OnGetLockInfo(req);

    if (0 >= req.lock_key().size()) {
        comm::LockBP::GetThreadInstance()->OnGetLockInfoRequestInvalid(req);
        QLErr("lock \"%s\" invalid", req.lock_key().c_str());

        return comm::RetCode::RET_ERR_KEY;
    }

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

    comm::RetCode ret{CheckMaster(paxos_group_id, *resp.mutable_redirect_addr())};
    if (comm::RetCode::RET_OK != ret) {
        QLErr("paxos_group %d lock \"%s\" CheckMaster err %d",
              paxos_group_id, req.lock_key().c_str(), ret);
        // TODO:
        //OssAttrInc(impl_->opt.oss_attr_id, 23u, 1u);

        return ret;
    }
    comm::LockBP::GetThreadInstance()->OnGetLockInfoCheckMasterPass(req);
    QLVerb("paxos_group %d lock \"%s\" node %" PRIu64 " master 1",
           paxos_group_id, req.lock_key().c_str(), impl_->node->GetMyNodeID());

    proto::LocalLockInfo local_lock_info;

    // begin mutex
    {

        // prevent paxos from writing
        comm::utils::MutexGuard guard(impl_->lock_mgr->map(paxos_group_id).mutex());
        ret = impl_->lock_mgr->map(paxos_group_id).Get(req.lock_key(), local_lock_info);

    }
    // end mutex

    if (comm::RetCode::RET_ERR_KEY_NOT_EXIST == ret) {
        QLVerb("paxos_group %d lock \"%s\" Get not exist", paxos_group_id, req.lock_key().c_str());
        // TODO:
        //OssAttrInc(impl_->opt.oss_attr_id, 25u, 1u);

        return ret;
    } else if (comm::RetCode::RET_OK != ret) {
        QLErr("paxos_group %d lock \"%s\" Get err %d", paxos_group_id, req.lock_key().c_str(), ret);
        // TODO:
        //OssAttrInc(impl_->opt.oss_attr_id, 24u, 1u);

        return ret;
    }

    LocalLockInfo2LockInfo(local_lock_info, *resp.mutable_lock_info());
    QLInfo("paxos_group %d lock \"%s\" Get ok map.ver %llu map.client_id \"%s\"", paxos_group_id,
           req.lock_key().c_str(), resp.lock_info().version(), resp.lock_info().client_id().c_str());

    return ret;
}