From ff9618765f2369894324a5a432a87a3b52458d93 Mon Sep 17 00:00:00 2001 From: Dennis Klein Date: Sun, 22 Apr 2018 19:53:39 +0200 Subject: [PATCH] Always build multipart support in nanomsg transport --- fairmq/nanomsg/FairMQSocketNN.cxx | 12 ------------ 1 file changed, 12 deletions(-) diff --git a/fairmq/nanomsg/FairMQSocketNN.cxx b/fairmq/nanomsg/FairMQSocketNN.cxx index c50c02d0..3cdf4bd4 100644 --- a/fairmq/nanomsg/FairMQSocketNN.cxx +++ b/fairmq/nanomsg/FairMQSocketNN.cxx @@ -24,9 +24,7 @@ #include #include -#ifdef MSGPACK_FOUND #include -#endif /*MSGPACK_FOUND*/ using namespace std; @@ -259,7 +257,6 @@ int FairMQSocketNN::ReceiveImpl(FairMQMessagePtr& msg, const int flags, const in int64_t FairMQSocketNN::SendImpl(vector& msgVec, const int flags, const int timeout) { const unsigned int vecSize = msgVec.size(); -#ifdef MSGPACK_FOUND int elapsed = 0; // create msgpack simple buffer @@ -331,15 +328,10 @@ int64_t FairMQSocketNN::SendImpl(vector& msgVec, const int fla return nbytes; } } -#else /*MSGPACK_FOUND*/ - LOG(error) << "Cannot send message from vector of size " << vecSize << " and flags " << flags << " with nanomsg multipart because MessagePack is not available."; - exit(EXIT_FAILURE); -#endif /*MSGPACK_FOUND*/ } int64_t FairMQSocketNN::ReceiveImpl(vector& msgVec, const int flags, const int timeout) { -#ifdef MSGPACK_FOUND // Warn if the vector is filled before Receive() and empty it. // if (msgVec.size() > 0) // { @@ -423,10 +415,6 @@ int64_t FairMQSocketNN::ReceiveImpl(vector& msgVec, const int return nbytes; } } -#else /*MSGPACK_FOUND*/ - LOG(error) << "Cannot receive message into vector of size " << msgVec.size() << " and flags " << flags << " with nanomsg multipart because MessagePack is not available."; - exit(EXIT_FAILURE); -#endif /*MSGPACK_FOUND*/ } void FairMQSocketNN::Close()