Skip to content

Commit 8d2aec9

Browse files
committed
TPC IDC aggregator workflow: use 1 proxy for IDCs and SACs
1 parent 17a0ce9 commit 8d2aec9

1 file changed

Lines changed: 9 additions & 7 deletions

File tree

prodtests/full-system-test/aggregator-workflow.sh

Lines changed: 9 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -116,26 +116,28 @@ if workflow_has_parameter CALIB_PROXIES; then
116116
add_W o2-dpl-raw-proxy "--dataspec \"$CALIBDATASPEC_BARREL_SPORADIC\" $(get_proxy_connection barrel_sp input sporadic)" "" 0
117117
fi
118118
elif [[ $AGGREGATOR_TASKS == TPC_IDCBOTH_SAC ]]; then
119+
if [[ $EPNSYNCMODE != 1 ]]; then
120+
echo "ERROR: You cannot run the TPC IDCs if you are not in EPNSYNCMODE" 1>&2
121+
exit 2
122+
fi
123+
CHANNELS_LIST=
119124
if [[ ! -z $CALIBDATASPEC_TPCIDC_A ]] || [[ ! -z $CALIBDATASPEC_TPCIDC_C ]]; then
120-
if [[ $EPNSYNCMODE != 1 ]]; then
121-
echo "ERROR: You cannot run the TPC IDCs if you are not in EPNSYNCMODE" 1>&2
122-
exit 2
123-
fi
124125
# define port for FLP; should be in 47900 - 47999; if nobody defined it, we use 47900
125126
[[ -z $TPC_IDC_FLP_PORT ]] && TPC_IDC_FLP_PORT=47900
126127
# expand FLPs; TPC uses from 001 to 145, but 145 is reserved for SAC
127128
for flp in $(seq -f "%03g" 1 144); do
128129
FLP_ADDRESS="tcp://alio2-cr1-flp${flp}-ib:${TPC_IDC_FLP_PORT}"
129130
CHANNELS_LIST+="type=pull,name=tpcidc_flp${flp},transport=zeromq,address=$FLP_ADDRESS,method=connect,rateLogging=10;"
130131
done
131-
add_W o2-dpl-raw-proxy "--proxy-name tpcidc --io-threads 2 --dataspec \"$CALIBDATASPEC_TPCIDC_A;$CALIBDATASPEC_TPCIDC_C\" --channel-config \"$CHANNELS_LIST\" --timeframes-shm-limit $TIMEFRAME_SHM_LIMIT" "" 0
132132
fi
133133
if [[ ! -z $CALIBDATASPEC_TPCSAC ]]; then
134134
# define port for FLP; should be in 47900 - 47999; if nobody defined it, we use 47901
135135
[[ -z $TPC_SAC_FLP_PORT ]] && TPC_SAC_FLP_PORT=47901
136136
FLP_ADDRESS_SAC="tcp://alio2-cr1-flp145-ib:${TPC_SAC_FLP_PORT}"
137-
CHANNEL_SAC="type=pull,name=tpcsac,transport=zeromq,address=$FLP_ADDRESS_SAC,method=connect,rateLogging=10;"
138-
add_W o2-dpl-raw-proxy "--proxy-name tpcsac --dataspec \"$CALIBDATASPEC_TPCSAC\" --channel-config \"$CHANNEL_SAC\" --timeframes-shm-limit $TIMEFRAME_SHM_LIMIT" "" 0
137+
CHANNELS_LIST+="type=pull,name=tpcidc_sac,transport=zeromq,address=$FLP_ADDRESS_SAC,method=connect,rateLogging=10;"
138+
fi
139+
if [[ ! -z $CHANNELS_LIST ]]; then
140+
add_W o2-dpl-raw-proxy "--proxy-name tpcidc --io-threads 2 --dataspec \"$CALIBDATASPEC_TPCIDC_A;$CALIBDATASPEC_TPCIDC_C;$CALIBDATASPEC_TPCSAC\" --channel-config \"$CHANNELS_LIST\" --timeframes-shm-limit $TIMEFRAME_SHM_LIMIT" "" 0
139141
fi
140142
elif [[ $AGGREGATOR_TASKS == CALO_TF ]]; then
141143
if [[ ! -z $CALIBDATASPEC_CALO_TF ]]; then

0 commit comments

Comments
 (0)