Receiver.cpp

Go to the documentation of this file.

 
#include "ipm/Receiver.hpp"
#include "ipm/opmon/ipm.pb.h"
 
#include <utility>
 
dunedaq::ipm::Receiver::Response
dunedaq::ipm::Receiver::receive(const duration_t& timeout, message_size_t bytes, bool no_tmoexcept_mode)
{
  if (!can_receive()) {
    throw KnownStateForbidsReceive(ERS_HERE);
  }
  auto message = receive_(timeout, no_tmoexcept_mode);
 
  if (bytes != s_any_size) {
    auto received_size = static_cast<message_size_t>(message.data.size());
    if (received_size != bytes) {
      throw UnexpectedNumberOfBytes(ERS_HERE, m_connection_info.connection_name, received_size, bytes);
    }
  }
 
  // 18-May-2026, KAB: only increment the opmon counters if a non-empty message was received
  if (message.data.size() > 0) {
    m_bytes += message.data.size();
    ++m_messages;
  }
 
  return message;
}
 
void
dunedaq::ipm::Receiver::generate_opmon_data()
{
 
  opmon::ReceiverInfo i;
 
  i.set_bytes(m_bytes.exchange(0));
  i.set_messages(m_messages.exchange(0));
 
  publish(std::move(i));
}