Skip to content

O2sim: Aggregating mode for mctracks proxy#11608

Merged
ktf merged 6 commits into
AliceO2Group:devfrom
aalkin:aggregating-mctracks-proxy
Jul 7, 2023
Merged

O2sim: Aggregating mode for mctracks proxy#11608
ktf merged 6 commits into
AliceO2Group:devfrom
aalkin:aggregating-mctracks-proxy

Conversation

@aalkin
Copy link
Copy Markdown
Member

@aalkin aalkin commented Jul 4, 2023

  • FairMQDeviceProxy: send TF counter metrics if Monitoring service is available
  • FairMQDeviceProxy: message aggregation function added
  • mctracks-proxy: added --aggregate-timeframe <number> option to combine <number> of incoming events into a single multipart message and require a Monitoring service so that TF counter can be sent and TF-based rate limiting works
  • mctracks-to-aod: updated to handle the aggregated messages
  • mctracks-to-aod: removed the redundant spawner task (analysis workflows add aod-spawner automatically)
  • example script: updated to use --aggregate-timeframe

@sawenzel @mconcas

@aalkin aalkin requested review from a team as code owners July 4, 2023 10:24
sawenzel
sawenzel previously approved these changes Jul 4, 2023
Copy link
Copy Markdown
Collaborator

@sawenzel sawenzel left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Thanks for this development. Looks good to me. Maybe @DanielSamitz can also take a look?


DataProcessingHeader tdph{*TFcounter, 0};
ConcreteDataMatcher tracksMatcher = DataSpecUtils::asConcreteDataMatcher(specs[1]);
tracksDH.dataOrigin = tracksMatcher.origin;
Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

nitpick: I would use the

DataHeader tracksDH {
 .dataOrigin = ...,
 .dataDescription = ...
};

syntax.

@DanielSamitz
Copy link
Copy Markdown
Contributor

Thank you, this is great. In principle we are missing something similar in the o2sim-kine-publisher, but I'd say that there it is not so important, because there it is not necessary to do the conversion McTracks --> McParticles on the fly.

@aalkin
Copy link
Copy Markdown
Member Author

aalkin commented Jul 4, 2023

@DanielSamitz there is AODMcProducer that is more useful for creating AOD from kine files.

I can update the kine-publisher as well, in a separate PR, if it is actually used.

@alibuild
Copy link
Copy Markdown
Collaborator

alibuild commented Jul 4, 2023

Error while checking build/O2/fullCI for b5b80bf at 2023-07-04 18:28:

## sw/BUILD/GEANT4_VMC-latest/log
CMake Error at /sw/slc8_x86-64/CMake/v3.23.1-13/share/cmake-3.23/Modules/FindPackageHandleStandardArgs.cmake:230 (message):

Full log here.

@alibuild
Copy link
Copy Markdown
Collaborator

alibuild commented Jul 5, 2023

Error while checking build/O2/fullCI for b1ec1f1 at 2023-07-05 10:26:

## sw/BUILD/GEANT4_VMC-latest/log
CMake Error at /sw/slc8_x86-64/CMake/v3.23.1-13/share/cmake-3.23/Modules/FindPackageHandleStandardArgs.cmake:230 (message):

Full log here.

Comment thread Framework/Core/src/ExternalFairMQDeviceProxy.cxx Outdated
@ktf ktf merged commit 73e6cf8 into AliceO2Group:dev Jul 7, 2023
mwinn2 pushed a commit to mwinn2/AliceO2 that referenced this pull request Aug 24, 2023
@aalkin aalkin deleted the aggregating-mctracks-proxy branch January 16, 2024 09:53
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Development

Successfully merging this pull request may close these issues.

5 participants