| 186 | } |
| 187 | |
| 188 | void 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 |
nothing calls this directly
no test coverage detected