diff --git a/RTCP/Cobalt/InputProc/src/Station/PacketReader.cc b/RTCP/Cobalt/InputProc/src/Station/PacketReader.cc index 84d5975274b1e3a4a11cb2e19514ad894b0e6eae..4eec3bb3ea01590993d254641beffc3d5f49da2e 100644 --- a/RTCP/Cobalt/InputProc/src/Station/PacketReader.cc +++ b/RTCP/Cobalt/InputProc/src/Station/PacketReader.cc @@ -203,20 +203,22 @@ namespace LOFAR const double interval = now - lastLogTime; - // Emit log line - LOG_INFO_STR( logPrefix << (nrReceived / interval) << " pps: received " << - nrReceived << " packets: " << nrBadTime << " bad timestamps, " << - nrBadMode << " bad clock/bitmode, " << nrBadData << " payload errors, " << - nrBadOther << " otherwise bad packets" ); - - // Emit data points for monitoring (PVSS) - // Reproduce PN_CSI_STREAM0_BLOCKS_IN or PN_CSI_STREAM0_REJECTED, but with the right nr. - string streamStr = str(boost::format("stream%u") % boardNr); - mdLogger.log(mdKeyPrefix + streamStr + ".blocksIn", - (int)round(nrReceived / interval)); - size_t nrBad = nrBadTime + nrBadMode + nrBadData + nrBadOther; - mdLogger.log(mdKeyPrefix + streamStr + ".rejected", - (int)round(nrBad / interval)); + // Emit log line, but only once we are producing increments + if (lastLogTime > 0.0) { + LOG_INFO_STR( logPrefix << (nrReceived / interval) << " pps: received " << + nrReceived << " packets: " << nrBadTime << " bad timestamps, " << + nrBadMode << " bad clock/bitmode, " << nrBadData << " payload errors, " << + nrBadOther << " otherwise bad packets" ); + + // Emit data points for monitoring (PVSS) + // Reproduce PN_CSI_STREAM0_BLOCKS_IN or PN_CSI_STREAM0_REJECTED, but with the right nr. + string streamStr = str(boost::format("stream%u") % boardNr); + mdLogger.log(mdKeyPrefix + streamStr + ".blocksIn", + (int)round(nrReceived / interval)); + size_t nrBad = nrBadTime + nrBadMode + nrBadData + nrBadOther; + mdLogger.log(mdKeyPrefix + streamStr + ".rejected", + (int)round(nrBad / interval)); + } // Update totals totalNrReceived += nrReceived;