Skip to content

Commit 8fc9f69

Browse files
authored
[O2-2818] Disable FairMQ's autoBind in the proxies (#1852)
1 parent 2673c48 commit 8fc9f69

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

Framework/src/InfrastructureGenerator.cxx

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -374,7 +374,7 @@ void InfrastructureGenerator::generateDataSamplingPolicyLocalProxyBind(framework
374374
std::string proxyName = policyName + "-proxy";
375375
std::string channelName = policyName + "-" + localMachine;
376376
std::string channelConfig = "name=" + channelName + ",type=pub,method=bind,address=tcp://*:" + localPort +
377-
",rateLogging=60,transport=zeromq,sndBufSize=4";
377+
",rateLogging=60,transport=zeromq,sndBufSize=4,autoBind=false";
378378
auto channelSelector = [channelName](InputSpec const&, const std::unordered_map<std::string, std::vector<fair::mq::Channel>>&) {
379379
return channelName;
380380
};
@@ -445,7 +445,7 @@ void InfrastructureGenerator::generateDataSamplingPolicyRemoteProxyBind(framewor
445445
const std::string& channelName = policyName;
446446
const std::string& proxyName = channelName; // channel name has to match proxy name
447447

448-
std::string channelConfig = "name=" + channelName + ",type=sub,method=bind,address=tcp://*:" + remotePort + ",rateLogging=60,transport=zeromq,rcvBufSize=1";
448+
std::string channelConfig = "name=" + channelName + ",type=sub,method=bind,address=tcp://*:" + remotePort + ",rateLogging=60,transport=zeromq,rcvBufSize=1,autoBind=false";
449449

450450
auto proxy = specifyExternalFairMQDeviceProxy(
451451
proxyName.c_str(),
@@ -491,7 +491,7 @@ void InfrastructureGenerator::generateLocalTaskRemoteProxy(framework::WorkflowSp
491491
}
492492

493493
std::string channelConfig = "name=" + channelName + ",type=sub,method=bind,address=tcp://*:" + remotePort +
494-
",rateLogging=60,transport=zeromq,rcvBufSize=1";
494+
",rateLogging=60,transport=zeromq,rcvBufSize=1,autoBind=false";
495495

496496
auto proxy = specifyExternalFairMQDeviceProxy(
497497
proxyName.c_str(),

0 commit comments

Comments
 (0)