Method ProposeMaster

phxqueue/lock/keepmasterthread.cpp:404–433

//}

comm::RetCode KeepMasterThread::ProposeMaster(const int paxos_group_id,
                                              const comm::proto::Addr addr) {
    QLInfo("paxos_group_id %d try be master", paxos_group_id);

    // 1. serialize paxos value
    proto::LockPaxosArgs args;
    args.mutable_master_addr()->CopyFrom(addr);

    string buf;
    args.SerializeToString(&buf);

    // 2. send to paxos
    LockContext lc;
    phxpaxos::SMCtx sm_ctx(LockSM::ID, &lc);
    uint64_t instance_id{0};
    int paxos_ret{impl_->lock->GetNode()->Propose(paxos_group_id, buf, instance_id, &sm_ctx)};
    const int topic_id{impl_->lock->GetTopicID()};
    if (phxpaxos::PaxosTryCommitRet_OK != paxos_ret) {
        QLErr("paxos_group_id %d Propose err %d buf.size %zu", paxos_group_id, paxos_ret, buf.size());
        comm::LockKeepMasterThreadBP::GetThreadInstance()->
                OnProposeMasterSucc(topic_id, paxos_group_id);
    } else {
        QLInfo("paxos_group_id %d Propose ok instance_id %" PRIu64 " buf.size %zu",
               paxos_group_id, instance_id, buf.size());
        comm::LockKeepMasterThreadBP::GetThreadInstance()->
                OnProposeMasterErr(topic_id, paxos_group_id);
    }

    return comm::RetCode::RET_OK;
}

comm::RetCode KeepMasterThread::UpdatePaxosArgs() {
    const int topic_id{impl_->lock->GetTopicID()};