gRunHeader.h

Go to the documentation of this file.

#pragma once
 
// gemc
#include <gemc/gbase/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%1 Run ID:  %2\n%3 Number of events processed:  %4\n%5 Number of events with payload:  "
                "%6\n%7 Thread ID:  %8", guts::TPOINTITEM, rid, guts::TPOINTITEM, events_processed,
                guts::TPOINTITEM, events_with_payload, guts::TPOINTITEM, tid);
        }
        else {
            log->info(
                1,
                "\n%1 Run ID:  %2\n%3 Number of events processed:  %4\n%5 Number of events with payload:  %6",
                guts::TPOINTITEM, rid, guts::TPOINTITEM, events_processed, guts::TPOINTITEM,
                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;
};