[MQ] Improve FairMQ channels usage in unpack-buil-sink chain
- Switch Sampler-Unpackers connection from Push-Pull to Rep-Req! lower sample memory usage and better load-balancing performances (first ready first served)! - Use single channel for all histograms exchanges (objects but also configs)... to be cross-checked as some warnings - In CbmMQTsSamplerRepReq, fix logic for emission of missing TS list when first missing is index 1 - In CbmMQTsSamplerRepReq, add case of missing TS 0 to same logic (starting processing after beginning of a run) - In CbmMQTsSamplerRepReq, fix the stop execution when reaching max TS nb condition
Showing
- MQ/mcbm/CbmDeviceBuildDigiEvents.cxx 104 additions, 58 deletionsMQ/mcbm/CbmDeviceBuildDigiEvents.cxx
- MQ/mcbm/CbmDeviceBuildDigiEvents.h 8 additions, 6 deletionsMQ/mcbm/CbmDeviceBuildDigiEvents.h
- MQ/mcbm/CbmDeviceDigiEventSink.cxx 125 additions, 79 deletionsMQ/mcbm/CbmDeviceDigiEventSink.cxx
- MQ/mcbm/CbmDeviceDigiEventSink.h 8 additions, 7 deletionsMQ/mcbm/CbmDeviceDigiEventSink.h
- MQ/mcbm/CbmDeviceUnpack.cxx 178 additions, 55 deletionsMQ/mcbm/CbmDeviceUnpack.cxx
- MQ/mcbm/CbmDeviceUnpack.h 28 additions, 12 deletionsMQ/mcbm/CbmDeviceUnpack.h
- MQ/mcbm/UnpBuildSink_missing_features.txt 0 additions, 1 deletionMQ/mcbm/UnpBuildSink_missing_features.txt
- MQ/mcbm/runDigiEventSink.cxx 3 additions, 6 deletionsMQ/mcbm/runDigiEventSink.cxx
- MQ/mcbm/runUnpack.cxx 9 additions, 1 deletionMQ/mcbm/runUnpack.cxx
- MQ/mcbm/startBuildRawEvents2021.sh.in 15 additions, 24 deletionsMQ/mcbm/startBuildRawEvents2021.sh.in
- MQ/source/CbmMQTsSamplerRepReq.cxx 25 additions, 4 deletionsMQ/source/CbmMQTsSamplerRepReq.cxx
Loading
Please register or sign in to comment