From 1b9286d58c68ccac17d33c634d01fbeb52b522d9 Mon Sep 17 00:00:00 2001
From: Alexander van Amesfoort <amesfoort@astron.nl>
Date: Tue, 10 Jun 2014 16:48:52 +0000
Subject: [PATCH] Task #5833 (in branch of Task #5830): move writing of dropped
PVSS data point to a less frequently executed place
---
RTCP/Cobalt/OutputProc/src/OutputThread.cc | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git a/RTCP/Cobalt/OutputProc/src/OutputThread.cc b/RTCP/Cobalt/OutputProc/src/OutputThread.cc
index 17435d754cc..cd9fc03871e 100644
--- a/RTCP/Cobalt/OutputProc/src/OutputThread.cc
+++ b/RTCP/Cobalt/OutputProc/src/OutputThread.cc
@@ -142,6 +142,9 @@ namespace LOFAR
itsBlocksDropped += droppedBlocks;
LOG_WARN_STR(itsLogPrefix << "Just dropped " << droppedBlocks << " blocks. Dropped " << itsBlocksDropped << " blocks and written " << itsBlocksWritten << " blocks so far.");
+
+ itsMdLogger.log(itsMdKeyPrefix + PN_COP_DROPPED + '[' + lexical_cast<string>(itsStreamNr) + ']',
+ itsBlocksDropped * static_cast<float>(itsParset.settings.blockDuration()));
}
itsNextSequenceNumber = data->sequenceNumber() + 1;
@@ -151,8 +154,6 @@ namespace LOFAR
droppedBlocks > 0 ? "1" : "0"); // logged too late?
itsMdLogger.log(itsMdKeyPrefix + PN_COP_WRITTEN + '[' + lexical_cast<string>(itsStreamNr) + ']',
itsBlocksWritten * static_cast<float>(itsParset.settings.blockDuration()));
- itsMdLogger.log(itsMdKeyPrefix + PN_COP_DROPPED + '[' + lexical_cast<string>(itsStreamNr) + ']',
- itsBlocksDropped * static_cast<float>(itsParset.settings.blockDuration()));
}
--
GitLab