From 65c19f07bf630d672184e0f6749141bca17e8a7f Mon Sep 17 00:00:00 2001 From: Alexey Rybalchenko Date: Thu, 9 Feb 2017 09:15:06 +0100 Subject: [PATCH] Fix compatibility with ZeroMQ 4.2.1 --- fairmq/FairMQDevice.cxx | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/fairmq/FairMQDevice.cxx b/fairmq/FairMQDevice.cxx index 7617f58e..5ae23f98 100644 --- a/fairmq/FairMQDevice.cxx +++ b/fairmq/FairMQDevice.cxx @@ -320,8 +320,14 @@ bool FairMQDevice::AttachChannel(FairMQChannel& ch) ch.fSocket->SetOption("rcv-hwm", &(ch.fRcvBufSize), sizeof(ch.fRcvBufSize)); // set kernel transmit size - ch.fSocket->SetOption("snd-size", &(ch.fSndKernelSize), sizeof(ch.fSndKernelSize)); - ch.fSocket->SetOption("rcv-size", &(ch.fRcvKernelSize), sizeof(ch.fRcvKernelSize)); + if (ch.fSndKernelSize != 0) + { + ch.fSocket->SetOption("snd-size", &(ch.fSndKernelSize), sizeof(ch.fSndKernelSize)); + } + if (ch.fRcvKernelSize != 0) + { + ch.fSocket->SetOption("rcv-size", &(ch.fRcvKernelSize), sizeof(ch.fRcvKernelSize)); + } // attach bool bind = (ch.fMethod == "bind");