gRunHeader.h

Go to the documentation of this file.

#pragma once
 
// gemc
#include "gbase.h"
 
// C++
#include <string>
 
constexpr const char* GDATARUNHEADER_LOGGER = "run_header";
 
namespace grun_header {
 
inline auto defineOptions() -> GOptions {
    auto goptions = GOptions(GDATARUNHEADER_LOGGER);
    return goptions;
}
 
} // namespace grun_header
 
class GRunHeader : public GBase<GRunHeader>
{
public:
    GRunHeader(const std::shared_ptr<GOptions>& gopts, int rid, int tid = -1)
        : GBase(gopts, GDATARUNHEADER_LOGGER), runID(rid) {
        log->debug(CONSTRUCTOR, "GRunHeader");
        if (tid != -1) {
            log->info(1, "\n",
                      TPOINTITEM, " Run ID:  ", rid, "\n",
                      TPOINTITEM, " Number of events processed:  ", events_processed, "\n",
                      TPOINTITEM, " Number of events with payload:  ", events_with_payload, "\n",
                      TPOINTITEM, " Thread ID:  ", tid);
        }
        else {
            log->info(1, "\n",
                      TPOINTITEM, " Run ID:  ", rid, "\n",
                      TPOINTITEM, " Number of events processed:  ", events_processed, "\n",
                      TPOINTITEM, " Number of events with payload:  ", events_with_payload);
        }
    }
 
    [[nodiscard]] auto getRunID() const -> int { return runID; }
 
    [[nodiscard]] auto get_events_processed() const -> int { return events_processed; }
 
    [[nodiscard]] auto get_events_with_payload() const -> int { return events_with_payload; }
 
    void increment_events_processed() { events_processed++; }
 
    void increment_events_with_payload() { events_with_payload++; }
 
    void add_events_processed(int count) { events_processed += count; }
 
    void add_events_with_payload(int count) { events_with_payload += count; }
 
private:
    int events_processed{0};
 
    int events_with_payload{0};
 
    int runID;
};