OtsDataSaverConsumer_processor.cc

#include "otsdaq/DataProcessorPlugins/OtsDataSaverConsumer.h"
#include "otsdaq/Macros/ProcessorPluginMacros.h"
 
using namespace ots;
 
//==============================================================================
OtsDataSaverConsumer::OtsDataSaverConsumer(
    std::string              supervisorApplicationUID,
    std::string              bufferUID,
    std::string              processorUID,
    const ConfigurationTree& theXDAQContextConfigTree,
    const std::string&       configurationPath)
    : WorkLoop(processorUID)
    , RawDataSaverConsumerBase(supervisorApplicationUID,
                               bufferUID,
                               processorUID,
                               theXDAQContextConfigTree,
                               configurationPath)
{
}
 
//==============================================================================
OtsDataSaverConsumer::~OtsDataSaverConsumer(void) {}
 
//==============================================================================
void OtsDataSaverConsumer::writeHeader(void) {}
 
//==============================================================================
void OtsDataSaverConsumer::writePacketHeader(const std::string& data)
{
    unsigned char quadWordsCount = (data.length() - 2) / 8;
    outFile_.write((char*)&quadWordsCount, 1);
 
    // packetTypes is data[0]
    // seqId is in data[1] position
 
    if(quadWordsCount)
    {
        unsigned char seqId = data[1];
        __CFG_COUT__ << "quadcount: " << quadWordsCount << " packetType: " << data[0]
                     << " sequence id: " << seqId << " last: " << lastSeqId_ << __E__;
        if(!(lastSeqId_ + 1 == seqId || (lastSeqId_ == 255 && seqId == 0)))
        {
            __CFG_COUT__ << "?????? NOOOO Missing Packets: " << (unsigned int)lastSeqId_
                         << " v " << (unsigned int)seqId << __E__;
        }
        lastSeqId_ = seqId;
    }
}
 
DEFINE_OTS_PROCESSOR(OtsDataSaverConsumer)