| 881 | } |
| 882 | |
| 883 | void Learner :: OnSendCheckpointAck(const CheckpointMsg & oCheckpointMsg) |
| 884 | { |
| 885 | PLGHead("START flag %d", oCheckpointMsg.flag()); |
| 886 | |
| 887 | if (m_poCheckpointSender != nullptr && !m_poCheckpointSender->IsEnd()) |
| 888 | { |
| 889 | if (oCheckpointMsg.flag() == CheckpointSendFileAckFlag_OK) |
| 890 | { |
| 891 | m_poCheckpointSender->Ack(oCheckpointMsg.nodeid(), oCheckpointMsg.uuid(), oCheckpointMsg.sequence()); |
| 892 | } |
| 893 | else |
| 894 | { |
| 895 | m_poCheckpointSender->End(); |
| 896 | } |
| 897 | } |
| 898 | } |
| 899 | |
| 900 | CheckpointSender * Learner :: GetNewCheckpointSender(const nodeid_t iSendNodeID) |
| 901 | { |
nothing calls this directly
no outgoing calls
no test coverage detected