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

Method Ack

src/algorithm/learner_sender.cpp:188–206  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

186}
187
188void LearnerSender :: Ack(const uint64_t llAckInstanceID, const nodeid_t iFromNodeID)
189{
190 m_oLock.Lock();
191
192 if (IsIMSending() && m_bIsComfirmed)
193 {
194 if (m_iSendToNodeID == iFromNodeID)
195 {
196 if (llAckInstanceID > m_llAckInstanceID)
197 {
198 m_llAckInstanceID = llAckInstanceID;
199 m_llAbsLastAckTime = Time::GetSteadyClockMS();
200 m_oLock.Interupt();
201 }
202 }
203 }
204
205 m_oLock.UnLock();
206}
207
208///////////////////////////////////////////////
209

Callers

nothing calls this directly

Calls 1

GetSteadyClockMSFunction · 0.50

Tested by

no test coverage detected