From 1ef78e8041e3d02f56fa1121b60f7f12b9a1758f Mon Sep 17 00:00:00 2001 From: Piotr Konopka Date: Mon, 26 Jun 2023 08:39:40 +0200 Subject: [PATCH] [O2-2818] Disable FairMQ's autoBind in the proxies --- Framework/src/InfrastructureGenerator.cxx | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/Framework/src/InfrastructureGenerator.cxx b/Framework/src/InfrastructureGenerator.cxx index f9ceff37a6..3ff42adf29 100644 --- a/Framework/src/InfrastructureGenerator.cxx +++ b/Framework/src/InfrastructureGenerator.cxx @@ -374,7 +374,7 @@ void InfrastructureGenerator::generateDataSamplingPolicyLocalProxyBind(framework std::string proxyName = policyName + "-proxy"; std::string channelName = policyName + "-" + localMachine; std::string channelConfig = "name=" + channelName + ",type=pub,method=bind,address=tcp://*:" + localPort + - ",rateLogging=60,transport=zeromq,sndBufSize=4"; + ",rateLogging=60,transport=zeromq,sndBufSize=4,autoBind=false"; auto channelSelector = [channelName](InputSpec const&, const std::unordered_map>&) { return channelName; }; @@ -445,7 +445,7 @@ void InfrastructureGenerator::generateDataSamplingPolicyRemoteProxyBind(framewor const std::string& channelName = policyName; const std::string& proxyName = channelName; // channel name has to match proxy name - std::string channelConfig = "name=" + channelName + ",type=sub,method=bind,address=tcp://*:" + remotePort + ",rateLogging=60,transport=zeromq,rcvBufSize=1"; + std::string channelConfig = "name=" + channelName + ",type=sub,method=bind,address=tcp://*:" + remotePort + ",rateLogging=60,transport=zeromq,rcvBufSize=1,autoBind=false"; auto proxy = specifyExternalFairMQDeviceProxy( proxyName.c_str(), @@ -491,7 +491,7 @@ void InfrastructureGenerator::generateLocalTaskRemoteProxy(framework::WorkflowSp } std::string channelConfig = "name=" + channelName + ",type=sub,method=bind,address=tcp://*:" + remotePort + - ",rateLogging=60,transport=zeromq,rcvBufSize=1"; + ",rateLogging=60,transport=zeromq,rcvBufSize=1,autoBind=false"; auto proxy = specifyExternalFairMQDeviceProxy( proxyName.c_str(),