diff --git a/MAC/APL/CEPCU/src/CEPlogProcessor/CEPlogProcessor.cc b/MAC/APL/CEPCU/src/CEPlogProcessor/CEPlogProcessor.cc index d37393f2aba7f7eb803ae1cd66f13e9e75753b5d..a83d3f233d6d6058982cd460016c8e531ed87153 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); }