DaphneV3Interface.hxx

Go to the documentation of this file.

 
template<class T>
T dunedaq::daphnemodules::DaphneV3Interface::send( std::string && message, daphne::MessageTypeV2 sent_type, daphne::MessageTypeV2 received_type ) {
 
  std::unique_lock<std::mutex> lock(m_access_mutex);
 
  _send(std::move(message), sent_type);
 
  auto ret = _receive();
 
  lock.unlock();
 
  const auto ty = ret.type();
  T out;
  if ( ty != received_type ) {
    throw FailedDecoding(ERS_HERE, out.GetTypeName(), ret.payload(),
             TypeMismatch(ERS_HERE, MessageTypeV2_Name(ty), MessageTypeV2_Name(received_type)) );
  }
 
  if (!out.ParseFromString(ret.payload())) {
    throw FailedDecoding(ERS_HERE, out.GetTypeName(), ret.payload());
  }
 
  return out;
}