From daba1771fadaa0b777f5a157e79a75f91578430e Mon Sep 17 00:00:00 2001
From: Alexey Rybalchenko <alexryba@gmail.com>
Date: Tue, 3 Nov 2015 13:16:07 +0100
Subject: [PATCH] Fix return values of nanomsg send/receive calls

---
 fairmq/nanomsg/FairMQSocketNN.cxx | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/fairmq/nanomsg/FairMQSocketNN.cxx b/fairmq/nanomsg/FairMQSocketNN.cxx
index 98011144..582a3bbb 100644
--- a/fairmq/nanomsg/FairMQSocketNN.cxx
+++ b/fairmq/nanomsg/FairMQSocketNN.cxx
@@ -103,6 +103,7 @@ int FairMQSocketNN::Send(FairMQMessage* msg, const string& flag)
         fBytesTx += nbytes;
         ++fMessagesTx;
         static_cast<FairMQMessageNN*>(msg)->fReceiving = false;
+        return nbytes;
     }
     if (nn_errno() == EAGAIN)
     {
@@ -126,6 +127,7 @@ int FairMQSocketNN::Send(FairMQMessage* msg, const int flags)
         fBytesTx += nbytes;
         ++fMessagesTx;
         static_cast<FairMQMessageNN*>(msg)->fReceiving = false;
+        return nbytes;
     }
     if (nn_errno() == EAGAIN)
     {
@@ -151,6 +153,7 @@ int FairMQSocketNN::Receive(FairMQMessage* msg, const string& flag)
         msg->Rebuild();
         msg->SetMessage(ptr, nbytes);
         static_cast<FairMQMessageNN*>(msg)->fReceiving = true;
+        return nbytes;
     }
     if (nn_errno() == EAGAIN)
     {
@@ -175,6 +178,7 @@ int FairMQSocketNN::Receive(FairMQMessage* msg, const int flags)
         ++fMessagesRx;
         msg->SetMessage(ptr, nbytes);
         static_cast<FairMQMessageNN*>(msg)->fReceiving = true;
+        return nbytes;
     }
     if (nn_errno() == EAGAIN)
     {