From 101bc4c9e7166226ed308481ede22306c01efd60 Mon Sep 17 00:00:00 2001 From: Alexey Rybalchenko Date: Tue, 21 Oct 2014 17:20:29 +0200 Subject: [PATCH] add flag for non-blocking operations --- fairmq/nanomsg/FairMQSocketNN.cxx | 2 ++ fairmq/zeromq/FairMQSocketZMQ.cxx | 2 ++ 2 files changed, 4 insertions(+) diff --git a/fairmq/nanomsg/FairMQSocketNN.cxx b/fairmq/nanomsg/FairMQSocketNN.cxx index cb2d6291..f3d76810 100644 --- a/fairmq/nanomsg/FairMQSocketNN.cxx +++ b/fairmq/nanomsg/FairMQSocketNN.cxx @@ -219,6 +219,8 @@ int FairMQSocketNN::GetConstant(const string& constant) if (constant == "linger") return NN_LINGER; + if (constant == "no-block") + return NN_DONTWAIT; return -1; } diff --git a/fairmq/zeromq/FairMQSocketZMQ.cxx b/fairmq/zeromq/FairMQSocketZMQ.cxx index d146a2ef..efdff2c9 100644 --- a/fairmq/zeromq/FairMQSocketZMQ.cxx +++ b/fairmq/zeromq/FairMQSocketZMQ.cxx @@ -246,6 +246,8 @@ int FairMQSocketZMQ::GetConstant(const string& constant) if (constant == "linger") return ZMQ_LINGER; + if (constant == "no-block") + return ZMQ_DONTWAIT; return -1; }