eventDispenser.h

Go to the documentation of this file.

#pragma once
 
#include <gemc/gbase/gbase.h>
#include <gemc/gdynamicDigitization/gdynamicdigitization.h>
 
#include <chrono>
#include <map>
#include <memory>
#include <optional>
#include <vector>
 
class EventDispenser : public GBase<EventDispenser>
{
public:
    EventDispenser(const std::shared_ptr<GOptions>&                                 gopt,
                   const std::shared_ptr<const gdynamicdigitization::dRoutinesMap>& gdynamicDigitizationMap);
 
private:
    int neventsToProcess;
 
    int userRunno;
 
    bool offscreen_screenshots = false;
 
    int currentRunno = -1;
 
    std::map<int, double> runWeights;
 
    std::map<int, int> runEvents;
 
    std::vector<int> listOfRuns;
 
    int currentRunIndex{};
 
    std::optional<std::chrono::steady_clock::time_point> beamOnTime;
 
    void distributeEvents(int nevents_to_process);
 
    void setNextRun() { currentRunIndex++; }
 
    std::shared_ptr<const gdynamicdigitization::dRoutinesMap> gDigitizationMap;
 
public:
    std::map<int, int> getRunEvents() { return runEvents; }
 
    [[nodiscard]] int getCurrentRun() const { return listOfRuns[currentRunIndex]; }
 
    [[nodiscard]] int getTotalNumberOfEvents() const;
 
    int processEvents();
 
    [[nodiscard]] bool beamOnIssued() const { return beamOnTime.has_value(); }
 
    [[nodiscard]] std::chrono::steady_clock::time_point beamOnStartTime() const { return beamOnTime.value(); }
 
    void setNumberOfEvents(int nevts);
 
    void resetRunContext();
};