diff --git a/RTCP/Cobalt/GPUProc/src/Station/StationInput.cc b/RTCP/Cobalt/GPUProc/src/Station/StationInput.cc index a459da0af621d9f4de2c6d9352b6d4373d86b4af..3200cf3aa7d68fcce71443291889c7491abb6062 100644 --- a/RTCP/Cobalt/GPUProc/src/Station/StationInput.cc +++ b/RTCP/Cobalt/GPUProc/src/Station/StationInput.cc @@ -555,12 +555,16 @@ namespace LOFAR { if (ps.settings.realTime) { #pragma omp parallel for num_threads(nrBoards) for(size_t board = 0; board < nrBoards; board++) { - OMPThreadSet::ScopedRun sr(packetReaderThreads); - OMPThread::ScopedName sn(str(format("%s rd %u") % ps.settings.antennaFields.at(stationIdx).name % board)); + try { + OMPThreadSet::ScopedRun sr(packetReaderThreads); + OMPThread::ScopedName sn(str(format("%s rd %u") % ps.settings.antennaFields.at(stationIdx).name % board)); - Thread::ScopedPriority sp(SCHED_FIFO, 10); + Thread::ScopedPriority sp(SCHED_FIFO, 10); - readRSPRealTime(board, mdLogger, mdKeyPrefix); + readRSPRealTime(board, mdLogger, mdKeyPrefix); + } catch(OMPThreadSet::CannotStartException &ex) { + LOG_INFO_STR( logPrefix << "Stopped"); + } } } else { readRSPNonRealTime(mdLogger, mdKeyPrefix);