From c7fde18f34104478e7d77ee6c13f27b128b98c51 Mon Sep 17 00:00:00 2001
From: Jan David Mol <mol@astron.nl>
Date: Wed, 22 May 2013 14:54:12 +0000
Subject: [PATCH] Task #4396: Initial implementation
---
.../CEPCU/src/CEPlogProcessor/CEPlogProcessor.cc | 14 ++++++++++++++
1 file changed, 14 insertions(+)
diff --git a/MAC/APL/CEPCU/src/CEPlogProcessor/CEPlogProcessor.cc b/MAC/APL/CEPCU/src/CEPlogProcessor/CEPlogProcessor.cc
index d37393f2aba..a83d3f233d6 100644
--- a/MAC/APL/CEPCU/src/CEPlogProcessor/CEPlogProcessor.cc
+++ b/MAC/APL/CEPCU/src/CEPlogProcessor/CEPlogProcessor.cc
@@ -850,6 +850,20 @@ void CEPlogProcessor::_processIONProcLine(const struct logline &logline)
RTDBPropertySet *inputBuffer = itsInputBuffers[processNr];
+ if (logline.obsID >= 0) {
+ // will be flushed once other relevant meta data is found and flushed
+ inputBuffer->setValue("observationName", GCFPVString(str(format("%i") % logline.obsID).c_str()), logline.timestamp, false);
+ }
+
+ if ((result = strstr(logline.target, "station "))) {
+ char stationName[6];
+ strncpy(stationName, result + 8, 5);
+ stationName[5] = '\0';
+
+ // will be flushed once other relevant meta data is found and flushed
+ inputBuffer->setValue("process.logMsg", GCFPVString(stationName), logline.timestamp, false);
+ }
+
if (_recordLogMsg(logline)) {
inputBuffer->setValue("process.logMsg", GCFPVString(logline.fullmsg), logline.timestamp, true);
}
--
GitLab