adding calib-workflow

DATA/common/setenv.sh

@@ -225,3 +225,22 @@ add_comma_separated()
     fi
   done
 }
+
+add_semicolon_separated()
+{
+  if (( $# < 2 )); then
+    echo "$# parameters received"
+    echo "Function name: ${FUNCNAME} expects at least 2 parameters:"
+    echo "it concatenates the string in 1st parameter by the following"
+    echo "ones, forming semi-colon-separated string. $# parameters received"
+    exit 1
+  fi
+
+  for ((i = 2; i <= $#; i++ )); do
+    if [[ -z ${!1} ]]; then
+      eval $1+="${!i}"
+    else
+      eval $1+="\;${!i}"
+    fi
+  done
+}

DATA/common/setenv_calib.sh

@@ -0,0 +1,130 @@
+#!/bin/bash
+
+# ---------------------------------------------------------------------------------------------------------------------
+
+# Check that the requirements to enable the calibrations are met, and
+# enabled them by default if they are not yet enabled or
+# if they are not explicitly disabled.
+# Then, configure data spec according to enabled calibrations
+
+source $O2DPG_ROOT/DATA/common/setenv.sh
+
+if [[ $BEAMTYPE != "cosmic" ]] && [[ $FORCECALIBRATIONS != 1 ]] ; then
+
+    # calibrations for primary vertex
+    if has_detector_calib ITS && has_detectors_reco ITS && has_detector_matching PRIMVTX && [[ ! -z "$VERTEXING_SOURCES" ]]; then
+	if [[ -z ${CALIB_PRIMVTX_MEANVTX+x} ]]; then CALIB_PRIMVTX_MEANVTX=1; fi
+    else
+	CALIB_PRIMVTX_MEANVTX=0
+    fi
+
+    # calibrations for TOF
+    if has_detector_calib TOF && has_detector_reco TOF; then
+	if has_detector_matching ITSTPCTOF || has_detector_matching ITSTPCTRDTOF; then
+	    if [[ -z ${CALIB_TOF_LHCPHASE+x} ]]; then CALIB_TOF_LHCPHASE=1; fi
+	    if [[ -z ${CALIB_TOF_CHANNELOFFSETS+x} ]]; then CALIB_TOF_CHANNELOFFSETS=1; fi
+	else
+	    CALIB_TOF_LHCPHASE=0
+	    CALIB_TOF_CHANNELOFFSETS=0
+	fi
+	if [[ -z ${CALIB_TOF_DIAGNOSTICS+x} ]]; then CALIB_TOF_DIAGNOSTICS=1; fi
+    else
+	CALIB_TOF_DIAGNOSTICS=0
+    fi
+
+    # calibrations for TPC
+    if has_detector_calib TPC && has_detectors ITS TPC TOF TRD; then
+	if has_detectors TPC ITS TRD TOF && has_detector_matching ITSTPCTRDTOF; then
+	    if [[ -z ${CALIB_TPC_SCDCALIB+x} ]]; then CALIB_TPC_SCDCALIB=1; fi
+	else
+	    CALIB_TPC_SCDCALIB=0
+	fi
+    fi
+
+    # calibrations for EMC
+    if has_detector_calib EMC && has_detector_reco EMC; then
+	if [[ -z ${CALIB_EMC_CHANNELCALIB+x} ]]; then CALIB_EMC_CHANNELCALIB=1; fi
+    else
+	CALIB_EMC_CHANNELCALIB=0
+    fi
+
+    # calibrations for PHS
+    if has_detector_calib PHS && has_detector_reco PHS; then
+	if [[ -z ${CALIB_PHS_ENERGYCALIB+x} ]]; then CALIB_PHS_ENERGYCALIB=1; fi
+	if [[ -z ${CALIB_PHS_BADMAPCALIB+x} ]]; then CALIB_PHS_BADMAPCALIB=1; fi
+	if [[ -z ${CALIB_PHS_TURNONCALIB+x} ]]; then CALIB_PHS_TURNONCALIB=1; fi
+	if [[ -z ${CALIB_PHS_RUNBYRUNCALIB+x} ]]; then CALIB_PHS_RUNBYRUNCALIB=1; fi
+    else
+	CALIB_PHS_ENERGYCALIB=0
+	CALIB_PHS_BADMAPCALIB=0
+	CALIB_PHS_TURNONCALIB=0
+	CALIB_PHS_RUNBYRUNCALIB=0
+    fi
+
+fi
+
+# prim vtx
+if [[ $CALIB_PRIMVTX_MEANVTX == 1 ]] ; then add_semicolon_separated CALIBDATASPEC_BARREL "pvtx:GLO/PVTX/0"; fi
+
+# TOF
+if [[ $CALIB_TOF_LHCPHASE == 1 ]] || [[ $CALIB_TOF_CHANNELOFFSETS == 1 ]]; then add_semicolon_separated CALIBDATASPEC_BARREL "calibTOF:TOF/CALIBDATA/0"; fi
+if [[ $CALIB_TOF_DIAGNOSTICS == 1 ]]; then add_semicolon_separated CALIBDATASPEC_BARREL "diagWords:TOF/DIAFREQ/0"; fi
+
+# EMC
+if [[ $CALIB_EMC_CHANNELCALIB == 1 ]]; then
+    add_semicolon_separated CALIBDATASPEC_CALO "cellsEMC:EMC/CELLS/0"
+    add_semicolon_separated CALIBDATASPEC_CALO "cellsTrgREMC:EMC/CELLSTRGR/0"
+fi
+
+# PHS
+if [[ $CALIB_PHS_ENERGYCALIB == 1 ]] || [[ $CALIB_PHS_TURNONCALIB == 1 ]] || [[ $CALIB_PHS_RUNBYRUNCALIB == 1 ]]; then
+    add_semicolon_separated CALIBDATASPEC_CALO "clsPHS:PHS/CLUSTERS/0;"
+    add_semicolon_separated CALIBDATASPEC_CALO "clTRPHS:PHS/CLUSTERTRIGREC/0;"
+fi
+if [[ $CALIB_PHS_ENERGYCALIB == 1 ]]; then add_semicolon_separated CALIBDATASPEC_CALO "cluelementsPHS:PHS/CLUELEMENTS/0;"; fi
+if [[ $CALIB_PHS_BADMAPCALIB == 1 ]] || [[ $CALIB_PHS_TURNONCALIB == 1 ]]; then add_semicolon_separated CALIBDATASPEC_CALO "cellsPHS:PHS/CELLS/0;"; fi
+if [[ $CALIB_PHS_TURNONCALIB == 1 ]]; then add_semicolon_separated CALIBDATASPEC_CALO "cellsTRPHS:PHS/CELLTRIGREC/0;"; fi
+
+# printing for debug
+echo CALIBDATASPEC_BARREL = $CALIBDATASPEC_BARREL 1>&2
+echo CALIBDATASPEC_CALO = $CALIBDATASPEC_CALO 1>&2
+
+# proxies properties
+PORT_BARREL=30453
+PORT_CALO=30454
+get_proxy_connection()
+{
+  if (( $# < 2 )); then
+    echo "$# parameters received"
+    echo "Function name: ${FUNCNAME} expects at least 3 parameters:"
+    echo "first parameter is the string id of the proxy"
+    echo "second parameter is the type of connection (input/output)"
+    exit 1
+  fi
+
+  # setting the port
+  if [[ $1 == "barrel" ]]; then
+      local PORT=$PORT_BARREL
+  elif [[ $1 == "calo" ]]; then
+      local PORT=$PORT_CALO
+  else
+      echo "parameter 1 should be either 'barrel' or 'calo'"
+      exit 3
+  fi
+
+  # setting the type of connection
+  if [[ $2 == "input" ]]; then
+      local CONNECTION="method=bind,type=pull"
+  elif [[ $2 == "output" ]]; then
+      local CONNECTION="method=connect,type=push"
+  else
+      echo "parameter 2 should be either 'input' or 'output'"
+      exit 2
+  fi
+
+  local PROXY_CONN="--proxy-channel-name aggregator-proxy-$1 --channel-config \"name=aggregator-proxy-$1,$CONNECTION,rateLogging=1,transport=zeromq,address=tcp://localhost:$PORT\""
+
+  echo PROXY_CONN = $PROXY_CONN 1>&2
+  echo $PROXY_CONN
+
+}