From 2a606ee8de86c9945669467e156f525c4cb63629 Mon Sep 17 00:00:00 2001 From: Dennis Klein Date: Fri, 23 Mar 2018 15:17:19 +0100 Subject: [PATCH] FairMQ: Fix issues from rebase --- fairmq/shmem/FairMQSocketSHM.cxx | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/fairmq/shmem/FairMQSocketSHM.cxx b/fairmq/shmem/FairMQSocketSHM.cxx index 93b2d17a..58d6cdaa 100644 --- a/fairmq/shmem/FairMQSocketSHM.cxx +++ b/fairmq/shmem/FairMQSocketSHM.cxx @@ -170,6 +170,7 @@ int FairMQSocketSHM::SendImpl(FairMQMessagePtr& msg, const int flags, const int int FairMQSocketSHM::ReceiveImpl(FairMQMessagePtr& msg, const int flags, const int timeout) { int nbytes = -1; + int elapsed = 0; zmq_msg_t* msgPtr = static_cast(msg.get())->GetMessage(); while (true) @@ -317,7 +318,7 @@ int64_t FairMQSocketSHM::SendImpl(vector& msgVec, const int fl } -int64_t FairMQSocketSHM::Receive(vector& msgVec, const int flags) +int64_t FairMQSocketSHM::ReceiveImpl(vector& msgVec, const int flags, const int timeout) { int64_t totalSize = 0;