summaryrefslogtreecommitdiffstats
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/InputZeroMQReader.cpp17
-rw-r--r--src/OutputUHD.cpp16
2 files changed, 0 insertions, 33 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();
}
diff --git a/src/OutputUHD.cpp b/src/OutputUHD.cpp
index acc4271..6ad7dfd 100644
--- a/src/OutputUHD.cpp
+++ b/src/OutputUHD.cpp
@@ -31,7 +31,6 @@
#include "PcDebug.h"
#include "Log.h"
#include "RemoteControl.h"
-#include "Utils.h"
#include <boost/thread/future.hpp>
@@ -351,23 +350,8 @@ int OutputUHD::process(Buffer* dataIn, Buffer* dataOut)
throw std::runtime_error("Non-constant input length!");
}
- struct timespec time_before;
- int time_before_ret = clock_gettime(CLOCK_MONOTONIC, &time_before);
-
mySyncBarrier.get()->wait();
- 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) << "Time delta : " <<
- timespecdiff_us(time_before, time_after) << " us";
- }
- else {
- etiLog.level(error) << "Time delta failed " <<
- time_before_ret << " " << time_after_ret;
- }
-
if (!uwd.running) {
worker.stop();
first_run = true;