Skip to content
Snippets Groups Projects
Commit 1b9286d5 authored by Alexander van Amesfoort's avatar Alexander van Amesfoort
Browse files

Task #5833 (in branch of Task #5830): move writing of dropped PVSS data point...

Task #5833 (in branch of Task #5830): move writing of dropped PVSS data point to a less frequently executed place
parent ef764bc6
No related branches found
No related tags found
No related merge requests found
...@@ -142,6 +142,9 @@ namespace LOFAR ...@@ -142,6 +142,9 @@ namespace LOFAR
itsBlocksDropped += droppedBlocks; itsBlocksDropped += droppedBlocks;
LOG_WARN_STR(itsLogPrefix << "Just dropped " << droppedBlocks << " blocks. Dropped " << itsBlocksDropped << " blocks and written " << itsBlocksWritten << " blocks so far."); 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; itsNextSequenceNumber = data->sequenceNumber() + 1;
...@@ -151,8 +154,6 @@ namespace LOFAR ...@@ -151,8 +154,6 @@ namespace LOFAR
droppedBlocks > 0 ? "1" : "0"); // logged too late? droppedBlocks > 0 ? "1" : "0"); // logged too late?
itsMdLogger.log(itsMdKeyPrefix + PN_COP_WRITTEN + '[' + lexical_cast<string>(itsStreamNr) + ']', itsMdLogger.log(itsMdKeyPrefix + PN_COP_WRITTEN + '[' + lexical_cast<string>(itsStreamNr) + ']',
itsBlocksWritten * static_cast<float>(itsParset.settings.blockDuration())); itsBlocksWritten * static_cast<float>(itsParset.settings.blockDuration()));
itsMdLogger.log(itsMdKeyPrefix + PN_COP_DROPPED + '[' + lexical_cast<string>(itsStreamNr) + ']',
itsBlocksDropped * static_cast<float>(itsParset.settings.blockDuration()));
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment