dunedaq::flxlibs Namespace Reference

Namespaces
namespace	felixcardcontroller
namespace	opmon
namespace	parsers
namespace	stats

Classes
class	CardControllerWrapper
class	CardWrapper
class	DefaultParserImpl
class	ElinkConcept
class	ElinkModel

Functions
std::unique_ptr< ElinkConcept >	createElinkModel (const appmodel::DataMoveCallbackConf *conf)

Function Documentation

createElinkModel()

std::unique_ptr< ElinkConcept > dunedaq::flxlibs::createElinkModel

(

const appmodel::DataMoveCallbackConf *

conf

)

Definition at line 36 of file CreateElink.hpp.

{
  auto datatype = conf->get_data_type();
/*
 
  if (raw_dt.find("WIBFrame") != std::string::npos) {
    // WIB1 specific char arrays
    // Create Model
    auto elink_model = std::make_unique<ElinkModel<fdreadoutlibs::types::ProtoWIBSuperChunkTypeAdapter>>();
 
    // Setup sink (acquire pointer from QueueRegistry)
    elink_model->set_sink(conn_uid);
 
    // Get parser and sink
    auto& parser = elink_model->get_parser();
    auto& sink = elink_model->get_sink();
    auto& error_sink = elink_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 elink_model;
 
  } else if (raw_dt.find("WIB2Frame") != std::string::npos) {
    // WIB2 specific char arrays
    auto elink_model = std::make_unique<ElinkModel<fdreadoutlibs::types::DUNEWIBSuperChunkTypeAdapter>>();
    elink_model->set_sink(conn_uid);
    auto& parser = elink_model->get_parser();
    auto& sink = elink_model->get_sink();
    parser.process_chunk_func = parsers::fixsizedChunkInto<fdreadoutlibs::types::DUNEWIBSuperChunkTypeAdapter>(sink);
    return elink_model;
 
  } else*/ 
  if (datatype.find("PDSStreamFrame") != std::string::npos) {
    // PDS specific char arrays
    auto elink_model = std::make_unique<ElinkModel<fdreadoutlibs::types::DAPHNEStreamSuperChunkTypeAdapter>>();
    elink_model->set_sink_config(conf);
    auto& parser = elink_model->get_parser();
    auto& cb = elink_model->m_sink_callback;
    parser.process_chunk_func = parsers::fixsizedChunkInto<fdreadoutlibs::types::DAPHNEStreamSuperChunkTypeAdapter>(cb);
    return elink_model;
 
  } else if (datatype.find("PDSFrame") != std::string::npos) {
    // PDS specific char arrays
    auto elink_model = std::make_unique<ElinkModel<fdreadoutlibs::types::DAPHNESuperChunkTypeAdapter>>();
    elink_model->set_sink_config(conf);
    auto& parser = elink_model->get_parser();
    auto& cb = elink_model->m_sink_callback;
    parser.process_chunk_func = parsers::fixsizedChunkInto<fdreadoutlibs::types::DAPHNESuperChunkTypeAdapter>(cb);
    return elink_model;
 
 
  } else if (datatype.find("varsize") != std::string::npos) {
    // Variable sized user payloads
    auto elink_model = std::make_unique<ElinkModel<fdreadoutlibs::types::VariableSizePayloadTypeAdapter>>();
    elink_model->set_sink_config(conf);
    auto& parser = elink_model->get_parser();
    auto& cb = elink_model->m_sink_callback;
    parser.process_chunk_func = parsers::varsizedChunkIntoWrapper(cb);
    parser.process_shortchunk_func = parsers::varsizedShortchunkIntoWrapper(cb);
    return elink_model;
  }
 
  return nullptr;
}