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;
}