| 669 | } |
| 670 | |
| 671 | int Learner :: SendCheckpointBegin( |
| 672 | const nodeid_t iSendNodeID, |
| 673 | const uint64_t llUUID, |
| 674 | const uint64_t llSequence, |
| 675 | const uint64_t llCheckpointInstanceID) |
| 676 | { |
| 677 | CheckpointMsg oCheckpointMsg; |
| 678 | |
| 679 | oCheckpointMsg.set_msgtype(CheckpointMsgType_SendFile); |
| 680 | oCheckpointMsg.set_nodeid(m_poConfig->GetMyNodeID()); |
| 681 | oCheckpointMsg.set_flag(CheckpointSendFileFlag_BEGIN); |
| 682 | oCheckpointMsg.set_uuid(llUUID); |
| 683 | oCheckpointMsg.set_sequence(llSequence); |
| 684 | oCheckpointMsg.set_checkpointinstanceid(llCheckpointInstanceID); |
| 685 | |
| 686 | PLGImp("END, SendNodeID %lu uuid %lu sequence %lu cpi %lu", |
| 687 | iSendNodeID, llUUID, llSequence, llCheckpointInstanceID); |
| 688 | |
| 689 | return SendMessage(iSendNodeID, oCheckpointMsg, Message_SendType_TCP); |
| 690 | } |
| 691 | |
| 692 | int Learner :: SendCheckpointEnd( |
| 693 | const nodeid_t iSendNodeID, |
nothing calls this directly
no outgoing calls
no test coverage detected