@@ -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