Skip to content
Snippets Groups Projects
Commit f48cd794 authored by Jan David Mol's avatar Jan David Mol
Browse files

COB-4: Reduce log spam

parent 270d2374
No related branches found
No related tags found
1 merge request!6Import cobalt2 into lofar4
...@@ -41,17 +41,9 @@ namespace LOFAR ...@@ -41,17 +41,9 @@ namespace LOFAR
itsInputThread(parset, RSP_RAW_DATA, streamNr, itsOutputPool, logPrefix), itsInputThread(parset, RSP_RAW_DATA, streamNr, itsOutputPool, logPrefix),
itsOutputThread(parset, streamNr, itsOutputPool, mdLogger, mdKeyPrefix, logPrefix) itsOutputThread(parset, streamNr, itsOutputPool, mdLogger, mdKeyPrefix, logPrefix)
{ {
NSTimer timer(str(format("preallocator %u") % itsStreamNr), true, true);
for (unsigned i = 0; i < preAllocateReceiveQueue; i++) { 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(); RSPRawData *data = new RSPRawData();
LOG_DEBUG_STR(str(format("[stream %u] Appending element %u") % itsStreamNr % i));
itsOutputPool.free.append(data); itsOutputPool.free.append(data);
timer.stop();
} }
} }
......
...@@ -57,17 +57,9 @@ namespace LOFAR ...@@ -57,17 +57,9 @@ namespace LOFAR
itsAllocator = new SparseSetAllocator(*itsArena); itsAllocator = new SparseSetAllocator(*itsArena);
NSTimer timer(str(format("preallocator %u") % itsStreamNr), true, true);
for (unsigned i = 0; i < preAllocateReceiveQueue; i++) { 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); 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); itsOutputPool.free.append(data);
timer.stop();
} }
} }
...@@ -79,17 +71,10 @@ namespace LOFAR ...@@ -79,17 +71,10 @@ namespace LOFAR
# pragma omp section # pragma omp section
{ {
OMPThread::ScopedName sn(str(format("allocator %u") % itsStreamNr)); OMPThread::ScopedName sn(str(format("allocator %u") % itsStreamNr));
NSTimer timer(str(format("allocator %u") % itsStreamNr), true, true);
for (unsigned i = preAllocateReceiveQueue; i < maxReceiveQueueSize; i++) { 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); 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); itsOutputPool.free.append(data);
timer.stop();
} }
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment