Skip to content

Commit 924206e

Browse files
authored
Add TPC CMV Readout workflows (#698)
* Add workflow including CMC * Add dataspec * Change of config_key_values * Remove ARGS_ALL * change * change * Put dataspec in quotation marks * change * Change also c-side workflow * Change names from cmc to cmv * Rename cmc to cmv * remove --write-debug-on-error * Add 4 lanes for o2-tpc-cmv-flp * correct output dataspec * Add n-TFs-buffer for cmv * increase nTF by factor 3 * Add cmv only workflow
1 parent 8d44744 commit 924206e

6 files changed

Lines changed: 51 additions & 0 deletions

File tree

jit/tpc-cmv

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
CRU_IDS=$(consul kv get o2/cache/flpToCruId/{{ it }}) && o2-dpl-raw-proxy -b --session default --dataspec 'x:TPC/RAWDATA;dd:FLP/DISTSUBTIMEFRAME/0' --inject-missing-data --readout-proxy '--channel-config "name=readout-proxy,type=pull,method=connect,address=ipc://tmp/stf-builder-dpl-pipe-0,transport=shmem,rateLogging=1"' | o2-tpc-cmv-to-vector --input-spec "A:TPC/RAWDATA" --crus "${CRU_IDS}" --configKeyValues 'NameConf.mCCDBServer=http://127.0.0.1:8084;;keyval.output_dir=/dev/null' | o2-tpc-cmv-flp --crus "${CRU_IDS}" --n-TFs-buffer $(( 300 * 128 / {{ pdp_n_hbf_per_tf }} )) --configKeyValues 'NameConf.mCCDBServer=http://127.0.0.1:8084;;keyval.output_dir=/dev/null' --lanes 4 | o2-dpl-output-proxy -b --session default --labels tpcidc:ecs-preserve-raw-channels --proxy-name tpcidc --proxy-channel-name tpcidc --fairmq-rate-logging 10 --tpcidc '--channel-config "name=tpcidc,method=bind,address=tcp://*:{{ merger_port }},type=push,transport=zeromq,rateLogging=1" ' --dataspec "cmvgroup:TPC/CMVGROUP;cmvorbit:TPC/CMVORBITINFO" --sporadic-inputs --infologger-severity info --severity info | o2-dpl-output-proxy -b --session default --dpl-output-proxy '--channel-config "name=downstream,type=push,method=bind,address=ipc:///tmp/stf-pipe-0,rateLogging=10,transport=shmem"' --dataspec 'xout:TPC/RAWDATA;ddout:FLP/DISTSUBTIMEFRAME/0' --environment DPL_OUTPUT_PROXY_ORDERED=1

jit/tpc-idc-cmv-a

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
CRU_IDS=$(consul kv get o2/cache/flpToCruId/{{ it }}) && o2-dpl-raw-proxy -b --session default --dataspec 'x:TPC/RAWDATA;dd:FLP/DISTSUBTIMEFRAME/0' --inject-missing-data --readout-proxy '--channel-config "name=readout-proxy,type=pull,method=connect,address=ipc://tmp/stf-builder-dpl-pipe-0,transport=shmem,rateLogging=1"' | o2-tpc-idc-to-vector -b --session default --crus "${CRU_IDS}" --severity error --infologger-severity error --configKeyValues 'NameConf.mCCDBServer=http://127.0.0.1:8084;;keyval.output_dir=/dev/null' --pedestal-url ccdb-default@{{ tpc_idc_pedestal_timestamp }} | o2-tpc-idc-flp -b --session default --n-TFs-buffer $(( 1000 * 128 / {{ pdp_n_hbf_per_tf }} )) --crus "${CRU_IDS}" --severity warning --infologger-severity warning --configKeyValues 'NameConf.mCCDBServer=http://127.0.0.1:8084;;keyval.output_dir=/dev/null' --lanes 1 --disableIDC0CCDB true | o2-tpc-cmv-to-vector --input-spec "A:TPC/RAWDATA" --crus "${CRU_IDS}" --configKeyValues 'NameConf.mCCDBServer=http://127.0.0.1:8084;;keyval.output_dir=/dev/null' | o2-tpc-cmv-flp --crus "${CRU_IDS}" --n-TFs-buffer $(( 300 * 128 / {{ pdp_n_hbf_per_tf }} )) --configKeyValues 'NameConf.mCCDBServer=http://127.0.0.1:8084;;keyval.output_dir=/dev/null' --lanes 4 | o2-dpl-output-proxy -b --session default --labels tpcidc:ecs-preserve-raw-channels --proxy-name tpcidc --proxy-channel-name tpcidc --fairmq-rate-logging 10 --tpcidc '--channel-config "name=tpcidc,method=bind,address=tcp://*:{{ merger_port }},type=push,transport=zeromq,rateLogging=1" ' --dataspec "idc2:TPC/IDCGROUPA;cmvgroup:TPC/CMVGROUP;cmvorbit:TPC/CMVORBITINFO" --sporadic-inputs --infologger-severity info --severity info | o2-dpl-output-proxy -b --session default --dpl-output-proxy '--channel-config "name=downstream,type=push,method=bind,address=ipc:///tmp/stf-pipe-0,rateLogging=10,transport=shmem"' --dataspec 'xout:TPC/RAWDATA;ddout:FLP/DISTSUBTIMEFRAME/0' --environment DPL_OUTPUT_PROXY_ORDERED=1

jit/tpc-idc-cmv-c

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
CRU_IDS=$(consul kv get o2/cache/flpToCruId/{{ it }}) && o2-dpl-raw-proxy -b --session default --dataspec 'x:TPC/RAWDATA;dd:FLP/DISTSUBTIMEFRAME/0' --inject-missing-data --readout-proxy '--channel-config "name=readout-proxy,type=pull,method=connect,address=ipc://tmp/stf-builder-dpl-pipe-0,transport=shmem,rateLogging=1"' | o2-tpc-idc-to-vector -b --session default --crus "${CRU_IDS}" --severity error --infologger-severity error --configKeyValues 'NameConf.mCCDBServer=http://127.0.0.1:8084;;keyval.output_dir=/dev/null' --pedestal-url ccdb-default@{{ tpc_idc_pedestal_timestamp }} | o2-tpc-idc-flp -b --session default --n-TFs-buffer $(( 100 * 128 / {{ pdp_n_hbf_per_tf }} )) --crus "${CRU_IDS}" --severity warning --infologger-severity warning --configKeyValues 'NameConf.mCCDBServer=http://127.0.0.1:8084;;keyval.output_dir=/dev/null' --lanes 1 --disableIDC0CCDB true | o2-tpc-cmv-to-vector $ARGS_ALL --input-spec "A:TPC/RAWDATA" --crus "${CRU_IDS}" --configKeyValues 'NameConf.mCCDBServer=http://127.0.0.1:8084;;keyval.output_dir=/dev/null' | o2-tpc-cmv-flp $ARGS_ALL --crus "${CRU_IDS}" --n-TFs-buffer $(( 300 * 128 / {{ pdp_n_hbf_per_tf }} )) --configKeyValues 'NameConf.mCCDBServer=http://127.0.0.1:8084;;keyval.output_dir=/dev/null' --lanes 4 | o2-dpl-output-proxy -b --session default --labels tpcidc:ecs-preserve-raw-channels --proxy-name tpcidc --proxy-channel-name tpcidc --fairmq-rate-logging 10 --tpcidc '--channel-config "name=tpcidc,method=bind,address=tcp://*:{{ merger_port }},type=push,transport=zeromq,rateLogging=1" ' --dataspec "idc2:TPC/IDCGROUPC;cmvgroup:TPC/CMVGROUP;cmvorbit:TPC/CMVORBITINFO" --sporadic-inputs --infologger-severity info --severity info | o2-dpl-output-proxy -b --session default --dpl-output-proxy '--channel-config "name=downstream,type=push,method=bind,address=ipc:///tmp/stf-pipe-0,rateLogging=10,transport=shmem"' --dataspec 'xout:TPC/RAWDATA;ddout:FLP/DISTSUBTIMEFRAME/0' --environment DPL_OUTPUT_PROXY_ORDERED=1

workflows/readout-dataflow.yaml

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -658,6 +658,8 @@ defaults:
658658
- qc-daq
659659
- qcmn-daq-local
660660
- tpc-idc-sac-full-split
661+
- tpc-idc-sac-cmv-full-split
662+
- tpc-sac-cmv-full-split
661663
tpc_qc_remote_workflow: !public
662664
value: "none"
663665
type: string
Lines changed: 23 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,23 @@
1+
name: tpc-idc-sac-full-split
2+
defaults:
3+
ccdb_path: "http://o2-ccdb.internal"
4+
tpc_sac_try_realign: 0
5+
tpc_sac_threads : 1
6+
tpc_idc_pedestal_timestamp : 1715236056769
7+
bookkept: "false"
8+
roles:
9+
- name: tpc-idc-a
10+
defaults:
11+
merger_port: 29950
12+
enabled: "{{ util.SuffixInRange(it, 'alio2-cr1-flp', '001', '072') }}"
13+
include: "{{ dpl.GenerateFromUri('tpc-idc-cmv-a') }}"
14+
- name: tpc-idc-c
15+
defaults:
16+
merger_port: 29950
17+
enabled: "{{ util.SuffixInRange(it, 'alio2-cr1-flp', '073', '144') }}"
18+
include: "{{ dpl.GenerateFromUri('tpc-idc-cmv-c') }}"
19+
- name: tpc-sac
20+
defaults:
21+
merger_port: 29951
22+
enabled: "{{ it == 'alio2-cr1-flp145' }}"
23+
include: "{{ dpl.GenerateFromUri('tpc-sac') }}"
Lines changed: 23 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,23 @@
1+
name: tpc-idc-sac-full-split
2+
defaults:
3+
ccdb_path: "http://o2-ccdb.internal"
4+
tpc_sac_try_realign: 0
5+
tpc_sac_threads : 1
6+
tpc_idc_pedestal_timestamp : 1715236056769
7+
bookkept: "false"
8+
roles:
9+
- name: tpc-idc-a
10+
defaults:
11+
merger_port: 29950
12+
enabled: "{{ util.SuffixInRange(it, 'alio2-cr1-flp', '001', '072') }}"
13+
include: "{{ dpl.GenerateFromUri('tpc-cmv') }}"
14+
- name: tpc-idc-c
15+
defaults:
16+
merger_port: 29950
17+
enabled: "{{ util.SuffixInRange(it, 'alio2-cr1-flp', '073', '144') }}"
18+
include: "{{ dpl.GenerateFromUri('tpc-cmv') }}"
19+
- name: tpc-sac
20+
defaults:
21+
merger_port: 29951
22+
enabled: "{{ it == 'alio2-cr1-flp145' }}"
23+
include: "{{ dpl.GenerateFromUri('tpc-sac') }}"

0 commit comments

Comments
 (0)