TDECrateApplication.cpp

Go to the documentation of this file.

 
#include "conffwk/Configuration.hpp"
#include "oks/kernel.hpp"
#include "logging/Logging.hpp"
 
#include "appmodel/NWDetDataReceiver.hpp"
#include "confmodel/NetworkInterface.hpp"
#include "confmodel/DetectorStream.hpp"
#include "confmodel/GeoId.hpp"
#include "confmodel/DetectorToDaqConnection.hpp"
 
#include "appmodel/appmodelIssues.hpp"
#include "ConfigObjectFactory.hpp"
#include "appmodel/TDECrateApplication.hpp"
#include "appmodel/TdeAmcDetDataSender.hpp"
#include "appmodel/TDEAMCModule.hpp"
#include "appmodel/TDEAMCModuleConf.hpp"
 
#include <string>
#include <vector>
#include <iostream>
#include <fmt/core.h>
 
namespace dunedaq {
namespace appmodel {
 
std::vector<const confmodel::Resource*>
TDECrateApplication::contained_resources() const {
  return to_resources(get_detector_connections());
}
 
std::vector<const confmodel::DaqModule*> 
TDECrateApplication::generate_modules(const confmodel::Session* session) const
{
  ConfigObjectFactory obj_fac(this);
 
  std::vector<const confmodel::DaqModule*> modules;
 
  std::map<std::string, std::vector<const appmodel::TdeAmcDetDataSender*>> ctrlhost_sender_map;
 
  for (auto d2d_conn : get_detector_connections()) {
        // Are we sure?
    if (d2d_conn->is_disabled(*session)) {
      TLOG_DEBUG(7) << "Ignoring disabled DetectorToDaqConnection " << d2d_conn->UID();
      continue;
    }
 
    TLOG_DEBUG(6) << "Processing DetectorToDaqConnection " << d2d_conn->UID();
    // get the readout groups and the interfaces and streams therein; 1 reaout group corresponds to 1 data reader module
 
    auto det_senders = d2d_conn->senders();
    // Should not be necessary, schema doesn't allow 0 senders
    if (det_senders.empty()) {
      throw(BadConf(ERS_HERE, "DetectorToDaqConnection does not contain senders"));
    }
 
    // Loop over senders
    for (const auto* sender : det_senders) {
 
      if ( sender->is_disabled(*session) ) {
        TLOG() << "Skipping disabled sender: " << sender->UID();
        continue;
      }
      
      // Check the sender type, must me a TdeAmcDetDataSender
      const auto* tde_sender = sender->cast<appmodel::TdeAmcDetDataSender>();
      if (!tde_sender ) {
        throw(BadConf(ERS_HERE, fmt::format("DataSender {} is not a appmodel::TdeAmcDetDataSender", sender->UID())));
      }
 
      ctrlhost_sender_map[tde_sender->get_control_host()].push_back(tde_sender);
    }
  }
 
  for( const auto& [ctrlhost, senders] : ctrlhost_sender_map ) {
 
    // std::cout << "this->UID()='" << this->UID() << "' ctrlhost='" << ctrlhost << "'" << std::endl;
    if ( this->get_tde_amc_module_conf() ) {
      conffwk::ConfigObject tde_obj = obj_fac.create( "TDEAMCModule", fmt::format("tde-ctrl-{}-{}", this->UID(), ctrlhost));
      // std::string tde_uid = fmt::format("tde-ctrl-{}-{}", this->UID(), ctrlhost);
      // config->create(dbfile, "TDEAMCModule", tde_uid, tde_obj);
      tde_obj.set_obj("amc", &(senders[0]->config_object()) ); // for now just allow one AMC per module
      modules.push_back(obj_fac.get_dal<appmodel::TDEAMCModule>(tde_obj));
    }
  }
  return modules;
}
 
} // namespace appmodel  
} // namespace dunedaq