From f833337eb0b14a0399145cc3ae3d9d85c9640b97 Mon Sep 17 00:00:00 2001
From: Jan David Mol <mol@astron.nl>
Date: Tue, 14 Feb 2017 13:29:06 +0000
Subject: [PATCH] Task #10118: Increase BF output buffers from 10 blocks to 60
blocks
---
RTCP/Cobalt/OutputProc/src/GPUProcIO.cc | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git a/RTCP/Cobalt/OutputProc/src/GPUProcIO.cc b/RTCP/Cobalt/OutputProc/src/GPUProcIO.cc
index 68c9b7b91f3..3e93b865c81 100644
--- a/RTCP/Cobalt/OutputProc/src/GPUProcIO.cc
+++ b/RTCP/Cobalt/OutputProc/src/GPUProcIO.cc
@@ -209,7 +209,8 @@ bool process(Stream &controlStream)
const size_t nrSamples = stokes.nrSamples;
const size_t alignment = TABTranspose::BeamformedData::alignment;
- const size_t poolSize = 10;
+ // poolSize is the buffer size (in #blocks) for the queue to disk
+ const size_t poolSize = 60;
arenas[fileIdx] = new MallocedArena(poolSize * (MultiDimArray<float,3>::nrElements(boost::extents[nrSamples][nrSubbands][nrChannels]) * sizeof(float) + alignment), alignment);
allocators[fileIdx] = new SparseSetAllocator(*arenas[fileIdx]);
@@ -225,6 +226,8 @@ bool process(Stream &controlStream)
}
// Create a collector for this fileIdx
+ // #blocks here is the number of blocks that can be constructed in parallel on
+ // the input side (what the correlator sends)
collectors[fileIdx] = new TABTranspose::BlockCollector(
*outputPools[fileIdx], fileIdx, nrSubbands, nrChannels, nrSamples, parset.settings.nrBlocks(), parset.settings.realTime ? 5 : 0);
--
GitLab