Skip to content

Commit fa571e3

Browse files
committed
SHM transport does not support pub/sub, thus we use push/pull for the local aggregator, which should actually be ok since we don't have 230 EPNs pushing
1 parent b62ec79 commit fa571e3

File tree

1 file changed

+12
-2
lines changed

1 file changed

+12
-2
lines changed

DATA/common/setenv_calib.sh

Lines changed: 12 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -140,13 +140,23 @@ get_proxy_connection()
140140

141141
# setting the type of connection
142142
if [[ $2 == "input" ]]; then
143-
local CONNECTION="method=bind,type=sub"
143+
local CONNECTION="method=bind"
144144
local NAMEPROXY="--proxy-name aggregator-proxy-$1"
145145
local NAMEPROXYCHANNEL=
146+
if workflow_has_parameter CALIB_LOCAL_AGGREGATOR; then
147+
CONNECTION+=",type=pull"
148+
else
149+
CONNECTION+=",type=sub"
150+
fi
146151
elif [[ $2 == "output" ]]; then
147-
local CONNECTION="method=connect,type=pub"
152+
local CONNECTION="method=connect"
148153
local NAMEPROXY="--proxy-name calib-output-proxy-$1"
149154
local NAMEPROXYCHANNEL="--proxy-channel-name aggregator-proxy-$1"
155+
if workflow_has_parameter CALIB_LOCAL_AGGREGATOR; then
156+
CONNECTION+=",type=push"
157+
else
158+
CONNECTION+=",type=pub"
159+
fi
150160
else
151161
echo "parameter 2 should be either 'input' or 'output'"
152162
exit 2

0 commit comments

Comments
 (0)