Added logging of maximum processing time in cPoller().

msearch.c

@@ -92,3 +92,8 @@ void cSatipMsearch::Process(void)
          }
      }
 }
+
+cString cSatipMsearch::ToString(void) const
+{
+  return "MSearch";
+}

msearch.h

@@ -32,6 +32,7 @@ public:
 public:
   virtual int GetFd(void);
   virtual void Process(void);
+  virtual cString ToString(void) const;
 };
 
 #endif /* __SATIP_MSEARCH_H_ */

poller.c

@@ -69,6 +69,7 @@ void cSatipPoller::Action(void)
 {
   debug("cSatipPoller::%s(): entering", __FUNCTION__);
   struct epoll_event events[eMaxFileDescriptors];
+  int maxElapsed = 0;
   // Increase priority
   SetPriority(-1);
   // Do the thread loop
@@ -77,8 +78,16 @@ void cSatipPoller::Action(void)
         ERROR_IF_FUNC((nfds == -1), "epoll_wait() failed", break, ;);
         for (int i = 0; i < nfds; ++i) {
             cSatipPollerIf* poll = reinterpret_cast<cSatipPollerIf *>(events[i].data.ptr);
-            if (poll)
+            if (poll) {
+               int elapsed;
+               cTimeMs processing(0);
                poll->Process();
+               elapsed = processing.Elapsed();
+               if (elapsed > maxElapsed) {
+                  maxElapsed = elapsed;
+                  debug("cSatipPoller::%s(): Processing %s took %d ms", __FUNCTION__, *(poll->ToString()), maxElapsed);
+                  }
+               }
            }
         }
   debug("cSatipPoller::%s(): exiting", __FUNCTION__);

pollerif.h

@@ -14,6 +14,7 @@ public:
   virtual ~cSatipPollerIf() {}
   virtual int GetFd(void) = 0;
   virtual void Process(void) = 0;
+  virtual cString ToString(void) const = 0;
 
 private:
   cSatipPollerIf(const cSatipPollerIf&);

rtcp.c

@@ -91,3 +91,8 @@ void cSatipRtcp::Process(void)
          error("Error %d reading from RTCP socket [device %d]", errno, tunerM.GetId());
      }
 }
+
+cString cSatipRtcp::ToString(void) const
+{
+  return cString::sprintf("RTCP [device %d]", tunerM.GetId());
+}

rtcp.h

@@ -27,6 +27,7 @@ public:
 public:
   virtual int GetFd(void);
   virtual void Process(void);
+  virtual cString ToString(void) const;
 };
 
 #endif /* __SATIP_RTCP_H_ */

rtp.c

@@ -121,3 +121,8 @@ void cSatipRtp::Process(void)
         error("Error %d reading from RTP socket [device %d]", errno, tunerM.GetId());
      }
 }
+
+cString cSatipRtp::ToString(void) const
+{
+  return cString::sprintf("RTP [device %d]", tunerM.GetId());
+}

rtp.h

@@ -34,6 +34,7 @@ public:
 public:
   virtual int GetFd(void);
   virtual void Process(void);
+  virtual cString ToString(void) const;
 };
 
 #endif /* __SATIP_RTP_H_ */