From 253604344f5e351bc963b425f6c95133a5ad95e2 Mon Sep 17 00:00:00 2001
From: Alexey Rybalchenko <alexryba@gmail.com>
Date: Fri, 27 May 2016 10:14:15 +0200
Subject: [PATCH] nanomsg: reset maximum receive msg size

---
 fairmq/CMakeLists.txt                                        | 2 +-
 fairmq/nanomsg/FairMQSocketNN.cxx                            | 5 +++++
 .../{startFairMQBenchmark.sh.in => startMQBenchmark.sh.in}   | 0
 3 files changed, 6 insertions(+), 1 deletion(-)
 rename fairmq/run/{startFairMQBenchmark.sh.in => startMQBenchmark.sh.in} (100%)

diff --git a/fairmq/CMakeLists.txt b/fairmq/CMakeLists.txt
index 8c5ba744..1b497a0f 100644
--- a/fairmq/CMakeLists.txt
+++ b/fairmq/CMakeLists.txt
@@ -6,7 +6,7 @@
  #                  copied verbatim in the file "LICENSE"                       #
  ################################################################################
 
-configure_file(${CMAKE_SOURCE_DIR}/fairmq/run/startFairMQBenchmark.sh.in ${CMAKE_BINARY_DIR}/bin/startFairMQBenchmark.sh)
+configure_file(${CMAKE_SOURCE_DIR}/fairmq/run/startMQBenchmark.sh.in ${CMAKE_BINARY_DIR}/bin/startMQBenchmark.sh)
 configure_file(${CMAKE_SOURCE_DIR}/fairmq/run/benchmark.json ${CMAKE_BINARY_DIR}/bin/config/benchmark.json)
 
 add_subdirectory(logger)
diff --git a/fairmq/nanomsg/FairMQSocketNN.cxx b/fairmq/nanomsg/FairMQSocketNN.cxx
index 1fcb6c23..77957cd6 100644
--- a/fairmq/nanomsg/FairMQSocketNN.cxx
+++ b/fairmq/nanomsg/FairMQSocketNN.cxx
@@ -71,6 +71,11 @@ FairMQSocketNN::FairMQSocketNN(const string& type, const string& name, const int
         }
     }
 
+#ifdef NN_RCVMAXSIZE
+    int rcvSize = -1;
+    nn_setsockopt(fSocket, NN_SOL_SOCKET, NN_RCVMAXSIZE, &rcvSize, sizeof(rcvSize));
+#endif
+
     // LOG(INFO) << "created socket " << fId;
 }
 
diff --git a/fairmq/run/startFairMQBenchmark.sh.in b/fairmq/run/startMQBenchmark.sh.in
similarity index 100%
rename from fairmq/run/startFairMQBenchmark.sh.in
rename to fairmq/run/startMQBenchmark.sh.in