Skip to content
Snippets Groups Projects
  • Pierre-Alain Loizeau's avatar
    baa426cd
    [MQ] Improve FairMQ channels usage in unpack-buil-sink chain · baa426cd
    Pierre-Alain Loizeau authored and Pierre-Alain Loizeau's avatar Pierre-Alain Loizeau committed
    - 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
    baa426cd
    History
    [MQ] Improve FairMQ channels usage in unpack-buil-sink chain
    Pierre-Alain Loizeau authored and Pierre-Alain Loizeau's avatar Pierre-Alain Loizeau committed
    - 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