Collect ICMP packet loss information

src/link_prober/LinkProber.cpp

@@ -319,10 +319,12 @@ void LinkProber::handleRecv(
                 // echo reply for an echo request generated by this/active ToR
                 mRxSelfSeqNo = mTxSeqNo;
                 mLinkProberStateMachine.postLinkProberStateEvent(LinkProberStateMachine::getIcmpSelfEvent());
+                mContinuousIcmpUnknownEventCount = 0;
             } else {
                 // echo reply for an echo request generated by peer ToR
                 mRxPeerSeqNo = mTxSeqNo;
                 mLinkProberStateMachine.postLinkProberStateEvent(LinkProberStateMachine::getIcmpPeerEvent());
+                mContinuousIcmpUnknownEventCount = 0;
                 if (ntohl(icmpPayload->command) == static_cast<uint32_t> (Command::COMMAND_SWITCH_ACTIVE)) {
                     boost::asio::io_service::strand &strand = mLinkProberStateMachine.getStrand();
                     boost::asio::io_service &ioService = strand.context();
@@ -394,6 +396,14 @@ void LinkProber::handleTimeout(boost::system::error_code errorCode)
     if (mTxSeqNo != mRxSelfSeqNo && mTxSeqNo != mRxPeerSeqNo) {
         // post unknown event
         mLinkProberStateMachine.postLinkProberStateEvent(LinkProberStateMachine::getIcmpUnknownEvent());
+        mContinuousIcmpUnknownEventCount++; 
+        mIcmpUnknownEventCount++;
+
+        MUXLOGINFO(boost::format("%s: continusous ICMP Unknown event count: %d, pck loss rate since initialization: %.2f %%") %
+            mMuxPortConfig.getPortName() %
+            mContinuousIcmpUnknownEventCount %
+            (static_cast<double_t>(mIcmpUnknownEventCount) / mIcmpPacketCount * 100) 
+        );
     }
 
     // start another cycle of send/recv
@@ -433,6 +443,8 @@ void LinkProber::startRecv()
 {
     MUXLOGTRACE(mMuxPortConfig.getPortName());
 
+    mIcmpPacketCount++;
+
     mStream.async_read_some(
         boost::asio::buffer(mRxBuffer, MUX_MAX_ICMP_BUFFER_SIZE),
         mStrand.wrap(boost::bind(

src/link_prober/LinkProber.h

@@ -373,6 +373,10 @@ class LinkProber
     std::array<uint8_t, MUX_MAX_ICMP_BUFFER_SIZE> mRxBuffer;
 
     bool mSuspendTx = false;
+
+    uint32_t mContinuousIcmpUnknownEventCount = 0;
+    uint64_t mIcmpUnknownEventCount = 0;
+    uint64_t mIcmpPacketCount = 0;
 };
 
 } /* namespace link_prober */