| 564 | } |
| 565 | |
| 566 | void Learner :: ProposerSendSuccess( |
| 567 | const uint64_t llLearnInstanceID, |
| 568 | const uint64_t llProposalID) |
| 569 | { |
| 570 | BP->GetLearnerBP()->ProposerSendSuccess(); |
| 571 | |
| 572 | PaxosMsg oPaxosMsg; |
| 573 | |
| 574 | oPaxosMsg.set_msgtype(MsgType_PaxosLearner_ProposerSendSuccess); |
| 575 | oPaxosMsg.set_instanceid(llLearnInstanceID); |
| 576 | oPaxosMsg.set_nodeid(m_poConfig->GetMyNodeID()); |
| 577 | oPaxosMsg.set_proposalid(llProposalID); |
| 578 | oPaxosMsg.set_lastchecksum(GetLastChecksum()); |
| 579 | |
| 580 | //run self first |
| 581 | BroadcastMessage(oPaxosMsg, BroadcastMessage_Type_RunSelf_First); |
| 582 | } |
| 583 | |
| 584 | void Learner :: OnProposerSendSuccess(const PaxosMsg & oPaxosMsg) |
| 585 | { |
nothing calls this directly
no test coverage detected