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",
                      guts::TPOINTITEM, " Run ID:  ", rid, "\n",
                      guts::TPOINTITEM, " Number of events processed:  ", events_processed, "\n",
                      guts::TPOINTITEM, " Number of events with payload:  ", events_with_payload, "\n",
                      guts::TPOINTITEM, " Thread ID:  ", tid);
        }
        else {
            log->info(1, "\n",
                      guts::TPOINTITEM, " Run ID:  ", rid, "\n",
                      guts::TPOINTITEM, " Number of events processed:  ", events_processed, "\n",
                      guts::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;
};