DataDecoderConsumer_processor.cc

#include "otsdaq/DataProcessorPlugins/DataDecoderConsumer.h"
#include "otsdaq/Macros/CoutMacros.h"
#include "otsdaq/Macros/ProcessorPluginMacros.h"
#include "otsdaq/MessageFacility/MessageFacility.h"
#include "otsdaq/TablePlugins/DataDecoderConsumerTable.h"
 
#include <unistd.h>
#include <cassert>
#include <iostream>
 
using namespace ots;
 
//==============================================================================
DataDecoderConsumer::DataDecoderConsumer(
    std::string              supervisorApplicationUID,
    std::string              bufferUID,
    std::string              processorUID,
    const ConfigurationTree& theXDAQContextConfigTree,
    const std::string&       configurationPath)
    : WorkLoop(processorUID)
    , DataDecoder(supervisorApplicationUID, bufferUID, processorUID)
    , DataConsumer(
          supervisorApplicationUID, bufferUID, processorUID, HighConsumerPriority)
    , Configurable(theXDAQContextConfigTree, configurationPath)
{
}
 
//==============================================================================
DataDecoderConsumer::~DataDecoderConsumer(void) {}
 
//==============================================================================
bool DataDecoderConsumer::workLoopThread(toolbox::task::WorkLoop* workLoop)
{
    // std::cout << __COUT_HDR_FL__ << __PRETTY_FUNCTION__ << processorUID_ << " running!"
    // << std::endl;
    std::string                        buffer;
    std::map<std::string, std::string> header;
    // unsigned long block;
    if(DataConsumer::read(buffer, header) < 0)
        usleep(100000);
    else
    {
        std::cout << __COUT_HDR_FL__ << __PRETTY_FUNCTION__ << processorUID_
                  << " Buffer: " << buffer << std::endl;
    }
    return true;
}
 
DEFINE_OTS_PROCESSOR(DataDecoderConsumer)