MCPcopy Create free account
hub / github.com/Tencent/phxpaxos / run

Method run

src/algorithm/learner_sender.cpp:50–68  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

48}
49
50void LearnerSender :: run()
51{
52 m_bIsStart = true;
53
54 while (true)
55 {
56 WaitToSend();
57
58 if (m_bIsEnd)
59 {
60 PLGHead("Learner.Sender [END]");
61 return;
62 }
63
64 SendLearnedValue(m_llBeginInstanceID, m_iSendToNodeID);
65
66 SendDone();
67 }
68}
69
70////////////////////////////////////////
71

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected