| 271 | } |
| 272 | |
| 273 | int LearnerSender :: SendOne(const uint64_t llSendInstanceID, const nodeid_t iSendToNodeID, uint32_t & iLastChecksum) |
| 274 | { |
| 275 | BP->GetLearnerBP()->SenderSendOnePaxosLog(); |
| 276 | |
| 277 | AcceptorStateData oState; |
| 278 | int ret = m_poPaxosLog->ReadState(m_poConfig->GetMyGroupIdx(), llSendInstanceID, oState); |
| 279 | if (ret != 0) |
| 280 | { |
| 281 | return ret; |
| 282 | } |
| 283 | |
| 284 | BallotNumber oBallot(oState.acceptedid(), oState.acceptednodeid()); |
| 285 | |
| 286 | ret = m_poLearner->SendLearnValue(iSendToNodeID, llSendInstanceID, oBallot, oState.acceptedvalue(), iLastChecksum); |
| 287 | |
| 288 | iLastChecksum = oState.checksum(); |
| 289 | |
| 290 | return ret; |
| 291 | } |
| 292 | |
| 293 | void LearnerSender :: SendDone() |
| 294 | { |
nothing calls this directly
no test coverage detected