| 655 | } |
| 656 | |
| 657 | void Learner :: OnAskforCheckpoint(const PaxosMsg & oPaxosMsg) |
| 658 | { |
| 659 | CheckpointSender * poCheckpointSender = GetNewCheckpointSender(oPaxosMsg.nodeid()); |
| 660 | if (poCheckpointSender != nullptr) |
| 661 | { |
| 662 | poCheckpointSender->start(); |
| 663 | PLGHead("new checkpoint sender started, send to nodeid %lu", oPaxosMsg.nodeid()); |
| 664 | } |
| 665 | else |
| 666 | { |
| 667 | PLGErr("Checkpoint Sender is running"); |
| 668 | } |
| 669 | } |
| 670 | |
| 671 | int Learner :: SendCheckpointBegin( |
| 672 | const nodeid_t iSendNodeID, |