DataProducerBase.cc

#include "otsdaq/DataManager/DataProducerBase.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("ProducerBase:") + DataProcessor::processorUID_)
 
//==============================================================================
DataProducerBase::DataProducerBase(const std::string& supervisorApplicationUID,
                                   const std::string& bufferUID,
                                   const std::string& processorUID,
                                   unsigned int       bufferSize)
    : DataProcessor(supervisorApplicationUID, bufferUID, processorUID)
    , bufferSize_(bufferSize)
{
    __GEN_COUT__ << "Constructor." << __E__;
    registerToBuffer();
    __GEN_COUT__ << "Constructed." << __E__;
}  // end constructor()
 
//==============================================================================
DataProducerBase::~DataProducerBase(void)
{
    __GEN_COUT__ << "Destructed." << __E__;
}  // end destructor()
 
//==============================================================================
void DataProducerBase::registerToBuffer(void)
{
    __GEN_COUT__ << "Producer '" << DataProcessor::processorUID_
                 << "' is registering to DataManager Supervisor Buffer '"
                 << DataProcessor::supervisorApplicationUID_ << ":"
                 << DataProcessor::bufferUID_ << ".'" << std::endl;
 
    DataManager* dataManager =
        (DataManagerSingleton::getInstance(supervisorApplicationUID_));
 
    dataManager->registerProducer(bufferUID_, this);
 
    {
        __GEN_SS__;
        dataManager->dumpStatus(&ss);
        std::cout << ss.str() << __E__;
    }
 
    __GEN_COUT__ << "Producer '" << DataProcessor::processorUID_ << "' Registered."
                 << __E__;
}  // end registerToBuffer()
 
//{
//  __GEN_COUT__ << "Producer '" << DataProcessor::processorUID_ <<
//          "' is unregistering to DataManager Supervisor Buffer '" <<
//          DataProcessor::supervisorApplicationUID_ << ":" <<
//          DataProcessor::bufferUID_ << ".'" << std::endl;
//
//  DataManager* dataManager =
//      (DataManagerSingleton::getInstance(
//              supervisorApplicationUID_));
//
//  dataManager->unregisterProducer(
//                      bufferUID_,DataProcessor::processorUID_);
//
//  {
//      __GEN_SS__;
//      dataManager->dumpStatus(&ss);
//      std::cout << ss.str() << __E__;
//  }
//
//  __GEN_COUT__ << "Producer '" << DataProcessor::processorUID_ <<
//          "' Unregistered." << __E__;
//} //end unregisterFromBuffer()