MCPcopy Create free account
hub / github.com/Tencent/phxpaxos / OnSendCheckpoint_Begin

Method OnSendCheckpoint_Begin

src/algorithm/learner.cpp:745–763  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

743}
744
745int Learner :: OnSendCheckpoint_Begin(const CheckpointMsg & oCheckpointMsg)
746{
747 int ret = m_oCheckpointReceiver.NewReceiver(oCheckpointMsg.nodeid(), oCheckpointMsg.uuid());
748 if (ret == 0)
749 {
750 PLGImp("NewReceiver ok");
751
752 ret = m_poCheckpointMgr->SetMinChosenInstanceID(oCheckpointMsg.checkpointinstanceid());
753 if (ret != 0)
754 {
755 PLGErr("SetMinChosenInstanceID fail, ret %d CheckpointInstanceID %lu",
756 ret, oCheckpointMsg.checkpointinstanceid());
757
758 return ret;
759 }
760 }
761
762 return ret;
763}
764
765int Learner :: OnSendCheckpoint_Ing(const CheckpointMsg & oCheckpointMsg)
766{

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected