Method Execute

phxqueue/lock/locksm.cpp:150–197

LockSM::~LockSM() {}

bool LockSM::Execute(const int paxos_group_id, const uint64_t instance_id,
                     const string &paxos_value, phxpaxos::SMCtx *sm_ctx) {
    comm::LockSMBP::GetThreadInstance()->
            OnExecute(impl_->lock->GetTopicID(), paxos_group_id,
                      instance_id, paxos_value);
    QLVerb("topic_id %d paxos_group_id %d instance_id %llu",
           impl_->lock->GetTopicID(), paxos_group_id, instance_id);

    proto::LockPaxosArgs args;
    bool succ{args.ParseFromString(paxos_value)};
    if (!succ) {
        QLErr("topic_id %d paxos_group_id %d instance_id %llu ParseFromString err",
              impl_->lock->GetTopicID(), paxos_group_id, instance_id);

        return false;
    }

    int ret{DoExecute(impl_->lock, LockDb::Type::MAP, paxos_group_id,
                      instance_id, args, false, sm_ctx)};

    if (!args.master_addr().ip().empty()) {
        auto opt(impl_->lock->GetLockOption());

        comm::proto::Addr addr;
        addr.set_ip(opt->ip);
        addr.set_port(opt->port);
        addr.set_paxos_port(opt->paxos_port);

        if (!(addr.ip() == args.master_addr().ip() &&
              addr.port() == args.master_addr().port() &&
              addr.paxos_port() == args.master_addr().paxos_port())) {
            QLInfo("topic_id %d paxos_group_id %d DropMaster self_addr %s master_addr %s",
                   impl_->lock->GetTopicID(), paxos_group_id, addr.ip().c_str(),
                   args.master_addr().ip().c_str());
            auto &&node(impl_->lock->GetNode());
            if (node) {
                node->DropMaster(paxos_group_id);
            } else {
                // init should not drop master
                QLInfo("topic_id %d paxos_group_id %d node null self_addr %s master_addr %s",
                       impl_->lock->GetTopicID(), paxos_group_id, addr.ip().c_str(),
                       args.master_addr().ip().c_str());
            }
        }
    }

    return ret;
}

bool LockSM::ExecuteForCheckpoint(const int paxos_group_id, const uint64_t instance_id,
                                  const string &paxos_value) {