From 38eb9d22e4abe1c3c918aa457c1ac7abfeac5762 Mon Sep 17 00:00:00 2001 From: Alexey Rybalchenko Date: Thu, 19 Mar 2020 09:36:38 +0100 Subject: [PATCH] Shmem: more detailed errors on meta data mismatch --- fairmq/shmem/Socket.cxx | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/fairmq/shmem/Socket.cxx b/fairmq/shmem/Socket.cxx index ee118081..b58df26c 100644 --- a/fairmq/shmem/Socket.cxx +++ b/fairmq/shmem/Socket.cxx @@ -184,7 +184,10 @@ int Socket::Receive(MessagePtr& msg, const int timeout) if (nbytes > 0) { // check for number of received messages. must be 1 if (nbytes != sizeof(MetaHeader)) { - throw SocketError("Received message is not a valid FairMQ shared memory message. Possibly due to a misconfigured transport on the sender side."); + throw SocketError( + tools::ToString("Received message is not a valid FairMQ shared memory message. ", + "Possibly due to a misconfigured transport on the sender side. ", + "Expected size of ", sizeof(MetaHeader), " bytes, received ", nbytes)); } MetaHeader* hdr = static_cast(zmqMsg.Data()); @@ -302,7 +305,10 @@ int64_t Socket::Receive(vector& msgVec, const int timeout) assert(hdrVecSize > 0); if (hdrVecSize % sizeof(MetaHeader) != 0) { - throw SocketError("Received message is not a valid FairMQ shared memory message. Possibly due to a misconfigured transport on the sender side."); + throw SocketError( + tools::ToString("Received message is not a valid FairMQ shared memory message. ", + "Possibly due to a misconfigured transport on the sender side. ", + "Expected size of ", sizeof(MetaHeader), " bytes, received ", nbytes)); } const auto numMessages = hdrVecSize / sizeof(MetaHeader);