NetworkDetectorToDaqConnection.cpp

Go to the documentation of this file.

 
#include "appmodel/NetworkDetectorToDaqConnection.hpp"
#include "appmodel/NWDetDataReceiver.hpp"
#include "appmodel/NWDetDataSender.hpp"
#include "confmodel/DetDataReceiver.hpp"
#include "confmodel/DetDataSender.hpp"
 
namespace dunedaq::appmodel {
 
std::vector<const dunedaq::confmodel::DetDataSender*>
NetworkDetectorToDaqConnection::senders() const
{
  std::vector<const dunedaq::confmodel::DetDataSender*> senders;
  if (m_net_senders.empty()) {
    std::lock_guard scoped_lock(m_mutex);
    check_init();
  }
  for (auto sender : m_net_senders) {
    senders.push_back(dynamic_cast<const dunedaq::confmodel::DetDataSender*>(sender));
  }
  TLOG_DEBUG(6) << "Found " << senders.size() << " senders\n";
  return senders;
}
 
const confmodel::DetDataReceiver*
NetworkDetectorToDaqConnection::receiver() const
{
  if (m_net_senders.empty()) {
    std::lock_guard scoped_lock(m_mutex);
    check_init();
  }
  return (m_net_receiver);
}
 
} // namespace dunedaq::appmodel