diff --git a/RTCP/Cobalt/OutputProc/src/RSPRawWriter.cc b/RTCP/Cobalt/OutputProc/src/RSPRawWriter.cc index 4d6d467bf13168e5ef481e9e0e80e771fb47f615..09b8246ea7bc90814065ab9e9c2573dd92a37d45 100644 --- a/RTCP/Cobalt/OutputProc/src/RSPRawWriter.cc +++ b/RTCP/Cobalt/OutputProc/src/RSPRawWriter.cc @@ -41,17 +41,9 @@ namespace LOFAR itsInputThread(parset, RSP_RAW_DATA, streamNr, itsOutputPool, logPrefix), itsOutputThread(parset, streamNr, itsOutputPool, mdLogger, mdKeyPrefix, logPrefix) { - NSTimer timer(str(format("preallocator %u") % itsStreamNr), true, true); - for (unsigned i = 0; i < preAllocateReceiveQueue; i++) { - timer.start(); - - LOG_DEBUG_STR(str(format("[stream %u] Allocating element %u") % itsStreamNr % i)); RSPRawData *data = new RSPRawData(); - LOG_DEBUG_STR(str(format("[stream %u] Appending element %u") % itsStreamNr % i)); itsOutputPool.free.append(data); - - timer.stop(); } } diff --git a/RTCP/Cobalt/OutputProc/src/SubbandWriter.cc b/RTCP/Cobalt/OutputProc/src/SubbandWriter.cc index 10e2041003301595cf30e973c84b5cc0431d9728..7f679c482a9ee43d73584b87b8e0735b546c8409 100644 --- a/RTCP/Cobalt/OutputProc/src/SubbandWriter.cc +++ b/RTCP/Cobalt/OutputProc/src/SubbandWriter.cc @@ -57,17 +57,9 @@ namespace LOFAR itsAllocator = new SparseSetAllocator(*itsArena); - NSTimer timer(str(format("preallocator %u") % itsStreamNr), true, true); - for (unsigned i = 0; i < preAllocateReceiveQueue; i++) { - timer.start(); - - LOG_DEBUG_STR(str(format("[stream %u] Allocating element %u") % itsStreamNr % i)); CorrelatedData *data = new CorrelatedData(itsNrStations, itsNrChannels, itsNrSamples, *itsAllocator, itsAlignment); - LOG_DEBUG_STR(str(format("[stream %u] Appending element %u") % itsStreamNr % i)); itsOutputPool.free.append(data); - - timer.stop(); } } @@ -79,17 +71,10 @@ namespace LOFAR # pragma omp section { OMPThread::ScopedName sn(str(format("allocator %u") % itsStreamNr)); - NSTimer timer(str(format("allocator %u") % itsStreamNr), true, true); for (unsigned i = preAllocateReceiveQueue; i < maxReceiveQueueSize; i++) { - timer.start(); - - LOG_DEBUG_STR(str(format("[stream %u] Allocating element %u") % itsStreamNr % i)); CorrelatedData *data = new CorrelatedData(itsNrStations, itsNrChannels, itsNrSamples, *itsAllocator, itsAlignment); - LOG_DEBUG_STR(str(format("[stream %u] Appending element %u") % itsStreamNr % i)); itsOutputPool.free.append(data); - - timer.stop(); } }