From bab9d654f028a214e6f3abe8ade1c1da002d25ff Mon Sep 17 00:00:00 2001
From: "Matthias P. Braendli" <matthias.braendli@mpb.li>
Date: Fri, 17 Jun 2016 11:19:29 +0200
Subject: Add TRACE support for timing analysis

---
 src/InputZeroMQReader.cpp | 4 ++++
 1 file changed, 4 insertions(+)

(limited to 'src/InputZeroMQReader.cpp')

diff --git a/src/InputZeroMQReader.cpp b/src/InputZeroMQReader.cpp
index 69e1ffd..96e3223 100644
--- a/src/InputZeroMQReader.cpp
+++ b/src/InputZeroMQReader.cpp
@@ -96,11 +96,14 @@ int InputZeroMQReader::GetNextFrame(void* buffer)
      */
     if (in_messages_.size() < 4) {
         const size_t prebuffering = 10;
+        etiLog.log(trace, "ZMQ,wait1");
         in_messages_.wait_and_pop(incoming, prebuffering);
     }
     else {
+        etiLog.log(trace, "ZMQ,wait2");
         in_messages_.wait_and_pop(incoming);
     }
+    etiLog.log(trace, "ZMQ,pop");
 
     if (not worker_.is_running()) {
         throw zmq_input_overflow();
@@ -183,6 +186,7 @@ void InputZeroMQWorker::RecvProcess(struct InputZeroMQThreadData* workerdata)
                         offset += framesize;
 
                         queue_size = workerdata->in_messages->push(buf);
+                        etiLog.log(trace, "ZMQ,push %zu", queue_size);
                     }
                 }
             }
-- 
cgit v1.2.3