From a94bc32b50f9af0dd7d703f63776fc2e176675c7 Mon Sep 17 00:00:00 2001
From: Jan David Mol <mol@astron.nl>
Date: Thu, 24 Oct 2013 09:05:21 +0000
Subject: [PATCH] Task #4820: Removed superfluous write semaphore
---
RTCP/Cobalt/OutputProc/src/OutputThread.cc | 14 --------------
1 file changed, 14 deletions(-)
diff --git a/RTCP/Cobalt/OutputProc/src/OutputThread.cc b/RTCP/Cobalt/OutputProc/src/OutputThread.cc
index be82403b4f0..6440f6d6287 100644
--- a/RTCP/Cobalt/OutputProc/src/OutputThread.cc
+++ b/RTCP/Cobalt/OutputProc/src/OutputThread.cc
@@ -197,32 +197,18 @@ namespace LOFAR
}
- static Semaphore writeSemaphore(300);
-
-
void OutputThread::doWork()
{
time_t prevlog = 0;
for (SmartPtr<StreamableData> data; (data = itsReceiveQueue.remove()) != 0; itsFreeQueue.append(data.release())) {
- //NSTimer writeTimer("write data", false, false);
-
- //writeTimer.start();
- writeSemaphore.down();
-
try {
itsWriter->write(data);
checkForDroppedData(data);
} catch (SystemCallException &ex) {
LOG_WARN_STR(itsLogPrefix << "OutputThread caught non-fatal exception: " << ex.what());
- } catch (...) {
- writeSemaphore.up();
- throw;
}
- writeSemaphore.up();
- //writeTimer.stop();
-
time_t now = time(0L);
if (now > prevlog + 5) {
--
GitLab