diff --git a/RTCP/Cobalt/OutputProc/src/GPUProcIO.cc b/RTCP/Cobalt/OutputProc/src/GPUProcIO.cc index 68c9b7b91f30aaa9dad1670ab802d9700dc0423a..3e93b865c8171f86a3c1854aa06718f64675c7a8 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);