DataProcessor.cc

#include "otsdaq/DataManager/DataProcessor.h"

using namespace ots;

#undef __MF_SUBJECT__
#define __MF_SUBJECT__ "Processor"
#define mfSubject_ (std::string("Processor:") + DataProcessor::processorUID_)

//==============================================================================
DataProcessor::DataProcessor(std::string supervisorApplicationUID, std::string bufferUID, std::string processorUID)
    : supervisorApplicationUID_(supervisorApplicationUID), bufferUID_(bufferUID), processorUID_(processorUID), theCircularBuffer_(nullptr)
{
    __GEN_COUT__ << "Constructor." << __E__;
    __GEN_COUTV__(supervisorApplicationUID_);
    __GEN_COUTV__(bufferUID_);
    __GEN_COUTV__(processorUID_);

    __GEN_COUT__ << "Constructed." << __E__;
}

//==============================================================================
DataProcessor::~DataProcessor(void) { __GEN_COUT__ << "Destructed." << __E__; }

//==============================================================================
void DataProcessor::setCircularBuffer(CircularBufferBase* circularBuffer) { theCircularBuffer_ = circularBuffer; }