TDECrateApplication.cpp

Go to the documentation of this file.

#include "conffwk/Configuration.hpp"
#include "logging/Logging.hpp"
#include "oks/kernel.hpp"
 
#include "appmodel/NWDetDataReceiver.hpp"
#include "confmodel/DetectorStream.hpp"
#include "confmodel/DetectorToDaqConnection.hpp"
#include "confmodel/GeoId.hpp"
#include "confmodel/NetworkInterface.hpp"
 
#include "ConfigObjectFactory.hpp"
#include "appmodel/TDEAMCModule.hpp"
#include "appmodel/TDEAMCModuleConf.hpp"
#include "appmodel/TDECrateApplication.hpp"
#include "appmodel/TdeAmcDetDataSender.hpp"
#include "appmodel/appmodelIssues.hpp"
 
#include <fmt/core.h>
#include <iostream>
#include <string>
#include <vector>
 
namespace dunedaq {
namespace appmodel {
 
std::vector<const confmodel::ExcludableEntity*>
TDECrateApplication::contained_excludable_entities() const
{
  return to_resources(get_detector_connections());
}
 
void
TDECrateApplication::generate_modules(std::shared_ptr<appmodel::ConfigurationHelper> helper) 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 (helper->is_excluded(d2d_conn)) {
      TLOG_DEBUG(7) << "Ignoring excluded 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 (helper->is_excluded(sender)) {
        TLOG() << "Skipping excluded 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));
    }
  }
  obj_fac.update_modules(modules);
}
 
} // namespace appmodel
} // namespace dunedaq