DataProducer.cc

#include "otsdaq/DataManager/DataProducer.h"
#include "otsdaq/ConfigurationInterface/ConfigurationManager.h"
#include "otsdaq/DataManager/DataManager.h"
#include "otsdaq/DataManager/DataManagerSingleton.h"
 
#include <iostream>
#include <memory>
using namespace ots;
 
#undef __MF_SUBJECT__
#define __MF_SUBJECT__ "Producer"
#define mfSubject_ (std::string("Producer-") + bufferUID_ + "-" + processorUID_)
 
//==============================================================================
DataProducer::DataProducer(std::string  supervisorApplicationUID,
                           std::string  bufferUID,
                           std::string  processorUID,
                           unsigned int bufferSize)
    : WorkLoop(processorUID)
    , DataProducerBase(supervisorApplicationUID, bufferUID, processorUID, bufferSize)
{
    __GEN_COUT__ << "Constructed." << __E__;
}
 
//==============================================================================
DataProducer::~DataProducer(void) { __GEN_COUT__ << "Destructed." << __E__; }
 
//==============================================================================
void DataProducer::startProcessingData(std::string /*runNumber*/)
{
    __GEN_COUT__ << "startWorkLoop..." << std::endl;
    WorkLoop::startWorkLoop();
}
 
//==============================================================================
void DataProducer::stopProcessingData(void)
{
    __GEN_COUT__ << "stopWorkLoop..." << std::endl;
    WorkLoop::stopWorkLoop();
}