| 421 | } |
| 422 | |
| 423 | void Learner :: OnComfirmAskForLearn(const PaxosMsg & oPaxosMsg) |
| 424 | { |
| 425 | BP->GetLearnerBP()->OnComfirmAskForLearn(); |
| 426 | |
| 427 | PLGHead("START Msg.InstanceID %lu Msg.from_nodeid %lu", oPaxosMsg.instanceid(), oPaxosMsg.nodeid()); |
| 428 | |
| 429 | if (!m_oLearnerSender.Comfirm(oPaxosMsg.instanceid(), oPaxosMsg.nodeid())) |
| 430 | { |
| 431 | BP->GetLearnerBP()->OnComfirmAskForLearnGetLockFail(); |
| 432 | |
| 433 | PLGErr("LearnerSender comfirm fail, maybe is lag msg"); |
| 434 | return; |
| 435 | } |
| 436 | |
| 437 | PLGImp("OK, success comfirm"); |
| 438 | } |
| 439 | |
| 440 | int Learner :: SendLearnValue( |
| 441 | const nodeid_t iSendNodeID, |
nothing calls this directly
no test coverage detected