SupervisorDescriptorInfoBase.cc

#include "otsdaq/SupervisorInfo/SupervisorDescriptorInfoBase.h"
 
#include <xdaq/ContextDescriptor.h>
#include "otsdaq/MessageFacility/MessageFacility.h"
 
#include <cassert>
 
using namespace ots;
 
//==============================================================================
SupervisorDescriptorInfoBase::SupervisorDescriptorInfoBase(void) {}
 
//==============================================================================
SupervisorDescriptorInfoBase::SupervisorDescriptorInfoBase(
    xdaq::ApplicationContext* applicationContext)
{
    init(applicationContext);
}
 
//==============================================================================
SupervisorDescriptorInfoBase::~SupervisorDescriptorInfoBase() {}
 
//==============================================================================
void SupervisorDescriptorInfoBase::destroy() { allSupervisors_.clear(); }
 
//==============================================================================
void SupervisorDescriptorInfoBase::init(xdaq::ApplicationContext* applicationContext)
{
    if(applicationContext->getDefaultZone()->getApplicationGroup("daq") == 0)
    {
        __SS__ << "Could not find xdaq application group \"daq\" (Must not be present in "
                  "the xdaq context configuration)"
               << __E__;
        __SS_THROW__;
    }
 
    __COUT__ << "Init" << __E__;
 
    //  //There is only one and only Supervisor! (Or Config Wizard!!)
    //  theSupervisor_ =
    //*(applicationContext->getDefaultZone()->getApplicationGroup("daq")->getApplicationDescriptors("ots::Supervisor").begin());
    //  if(0)//theSupervisor_ == 0)
    //      __COUT__ << "Note: Could not find xdaq application descriptor
    //\"ots::Supervisor\" (Must not be present in the xdaq context configuration)" <<
    //__E__;
    //
    //  theWizard_ =
    //*(applicationContext->getDefaultZone()->getApplicationGroup("daq")->getApplicationDescriptors("ots::OtsConfigurationWizardSupervisor").begin());
    //  if(0)//theWizard_ == 0)
    //      __COUT__ << "Note: Could not find xdaq application descriptor
    //\"ots::OtsConfigurationWizardSupervisor\" (Must not be present in the xdaq context
    // configuration)" << __E__;
    //
    //  if(theWizard_ == 0 && theSupervisor_ == 0)
    //  {
    //      __SS__ << "Must have THE ots::Supervisor (or THE
    // ots::OtsConfigurationWizardSupervisor) as part of the context configuration!" <<
    //__E__;
    //      __COUT_ERR__ << "\n" << ss.str();
    //      __SS_THROW__;
    //  }
 
    std::set<XDAQ_CONST_CALL xdaq::ApplicationDescriptor*> appDescriptors;
 
    // get allSupervisors_
 
    // allFETypeSupervisors_.clear();
    allSupervisors_.clear();
    appDescriptors = applicationContext->getDefaultZone()
                         ->getApplicationGroup("daq")
                         ->getApplicationDescriptors();
    for(auto& it : appDescriptors)
    {
        auto /*<it,bool*/ retPair = allSupervisors_.emplace(
            std::pair<xdata::UnsignedIntegerT,
                      XDAQ_CONST_CALL xdaq::ApplicationDescriptor*>(it->getLocalId(),
                                                                    it));
        if(!retPair.second)
        {
            __SS__ << "Error! Duplicate Application IDs are not allowed. ID ="
                   << it->getLocalId() << __E__;
            __SS_THROW__;
        }
    }
}
 
//==============================================================================
const SupervisorDescriptors& SupervisorDescriptorInfoBase::getAllDescriptors(void) const
{
    return allSupervisors_;
}