dunedaq::asiolibs Namespace Reference

Namespaces
namespace	opmon

Classes
class	GenericReceiverConcept
class	GenericReceiverModel
class	SourceConcept
class	SourceModel

Functions
std::shared_ptr< GenericReceiverConcept >	createGenericReceiver (const std::string &receiver_connection_name)
std::shared_ptr< SourceConcept >	createSourceModel (const appmodel::DataMoveCallbackConf *conf)

Function Documentation

createGenericReceiver()

std::shared_ptr< GenericReceiverConcept > dunedaq::asiolibs::createGenericReceiver

(

const std::string &

receiver_connection_name

)

Definition at line 28 of file CreateGenericReceiver.hpp.

{
  const auto datatypes = dunedaq::iomanager::IOManager::get()->get_datatypes(receiver_connection_name);
  if (datatypes.size() != 1) {
    ers::error(datahandlinglibs::GenericConfigurationError(ERS_HERE,
      "Multiple input data types specified! Expected only a single type!"));
  }
  const std::string dt = *datatypes.begin();
  TLOG() << "Choosing specializations for GenericReceiverConcept for input connection "
         << " [uid:" << receiver_connection_name << " , data_type:" << dt << ']';
 
  if (dt.find("CRTBernFrame") != std::string::npos) {
    return std::make_shared<GenericReceiverModel<fddetdataformats::CRTBernFrame>>(receiver_connection_name);
  } else if (dt.find("CRTGrenobleFrame") != std::string::npos) {
    return std::make_shared<GenericReceiverModel<fddetdataformats::CRTGrenobleFrame>>(receiver_connection_name);
  }
 
  return nullptr;
}

createSourceModel()

std::shared_ptr< SourceConcept > dunedaq::asiolibs::createSourceModel

(

const appmodel::DataMoveCallbackConf *

conf

)

Definition at line 31 of file CreateSource.hpp.

{
  auto datatype = conf->get_data_type();
  TLOG() << "Choosing specializations for SourceModel for output connection "
         << " [uid:" << conf->UID() << " , data_type:" << datatype << ']';
 
  if (datatype.find("WIBEthFrame") != std::string::npos) {
    // Create Model
    auto source_model = std::make_shared<SourceModel<fdreadoutlibs::types::DUNEWIBEthTypeAdapter>>();
 
    // For callback acquisition later (lazy)
    source_model->set_sink_config(conf);
 
    // Get parser and sink
    //auto& parser = source_model->get_parser();
    //auto& sink = source_model->get_sink();
    //auto& error_sink = source_model->get_error_sink();
 
    // Modify parser as needed...
    //parser.process_chunk_func = parsers::fixsizedChunkInto<fdreadoutlibs::types::ProtoWIBSuperChunkTypeAdapter>(sink);
    //if (error_sink != nullptr) {
    //  parser.process_chunk_with_error_func = parsers::errorChunkIntoSink(error_sink);
    //}
    // parser.process_block_func = ...
 
    // Return with setup model
    return source_model;
 
  } else if (datatype.find("CRTBernFrame") != std::string::npos) {
    auto source_model = std::make_shared<SourceModel<fdreadoutlibs::types::CRTBernTypeAdapter>>();
    source_model->set_sink_config(conf);
    return source_model;
  } else if (datatype.find("CRTGrenobleFrame") != std::string::npos) {
    auto source_model = std::make_shared<SourceModel<fdreadoutlibs::types::CRTGrenobleTypeAdapter>>();
    source_model->set_sink_config(conf);
    return source_model;
  }
 
  return nullptr;
}