diff --git a/RTCP/Cobalt/OutputProc/src/OutputThread.cc b/RTCP/Cobalt/OutputProc/src/OutputThread.cc index be82403b4f027b438e9e0771df452f03eb8868f2..6440f6d628784aa32b2f9de64fe2b81491a28675 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) {