summaryrefslogtreecommitdiffstats
path: root/src/InputZeroMQReader.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/InputZeroMQReader.cpp')
-rw-r--r--src/InputZeroMQReader.cpp17
1 files changed, 0 insertions, 17 deletions
diff --git a/src/InputZeroMQReader.cpp b/src/InputZeroMQReader.cpp
index e95644a..36d4e4b 100644
--- a/src/InputZeroMQReader.cpp
+++ b/src/InputZeroMQReader.cpp
@@ -41,7 +41,6 @@
#include "porting.h"
#include "InputReader.h"
#include "PcDebug.h"
-#include "Utils.h"
#define NUM_FRAMES_PER_ZMQ_MESSAGE 4
/* A concatenation of four ETI frames,
@@ -88,9 +87,6 @@ int InputZeroMQReader::GetNextFrame(void* buffer)
boost::shared_ptr<std::vector<uint8_t> > incoming;
- struct timespec time_before;
- int time_before_ret = clock_gettime(CLOCK_MONOTONIC, &time_before);
-
/* Do some prebuffering because reads will happen in bursts
* (4 ETI frames in TM1) and we should make sure that
* we can serve the data required for a full transmission frame.
@@ -103,19 +99,6 @@ int InputZeroMQReader::GetNextFrame(void* buffer)
in_messages_.wait_and_pop(incoming);
}
- struct timespec time_after;
- int time_after_ret = clock_gettime(CLOCK_MONOTONIC, &time_after);
-
- if (time_before_ret == 0 and time_after_ret == 0) {
- etiLog.level(debug) << "ZMQ Time delta : " <<
- timespecdiff_us(time_before, time_after) << " us, queue " <<
- in_messages_.size();
- }
- else {
- etiLog.level(error) << "ZMQ Time delta failed " <<
- time_before_ret << " " << time_after_ret;
- }
-
if (! workerdata_.running) {
throw zmq_input_overflow();
}