Skip to content

GlobalTimeSorter

Guillaume Baulieu requested to merge timesorter into preprod

Addition of a GlobalTimeSorter actor (producer). It uses a GlobalTimeSorter.json configuration file :

{
"ActualClass":"GlobalTimeSorter",
"InputFifos":["trigger:psa:10A","trigger:psa:10B","trigger:psa:10C","trigger:psa:12A","trigger:psa:12B","trigger:psa:12C","trigger:psa:14A","trigger:psa:14B","trigger:psa:14C"],
"NbThreads":9
}

Data are read from the central memory, one input fifo per crystal. The list of input fifos is given by the InputFifos parameter. Several threads (number defined by the NbThreads parameter) are getting the data from the CentralMemory.

For N input lines, 4 mergers (each in its own thread) are sorting N/4 lines. A finale merger (5th thread) will merge the 4 previous lines into a final one. Timestamp correction is not yet implemented.

A sqm2adf.json configuration file is also added to the SQM2ADF filter :

{
  "uname": "/AGATA/SQM2ADF/03A",
  "nb_threads": 6,
  "processing_level": 2
}

Merge request reports