gSROImplementation.h

Go to the documentation of this file.

#pragma once
 
#include "gSROCrate.h"
 
#include <gemc/gbase/gbase.h>
#include <gemc/gfactory/gdl.h>

struct GSRORunContext {
    int run_id;
    GSROEventId event_count;
    std::string output_basename;
};
 
struct GSROConfiguration {
    std::shared_ptr<const GSROTiming> timing;
    GSROCrateLimits crate_limits;
    std::size_t max_pending_events = 65536;
};

class GSROImplementation : public GBase<GSROImplementation> {
public:
    explicit GSROImplementation(const std::shared_ptr<GOptions>& opts)
        : GBase(opts, "gstreamer"), options(opts) {}
    ~GSROImplementation() override = default;

    void set_loggers(const std::shared_ptr<GOptions>& opts) {
        options = opts;
        log = std::make_shared<GLogger>(opts, "GSROImplementation", "gstreamer");
    }
 
    virtual GSROConfiguration configure_run(const GSRORunContext& run) = 0;
    virtual GSROCrateResources create_crate(GSROCrateId crate, const GSRORunContext& run) const = 0;
 
    static GSROImplementation* instantiate(dlhandle handle, const std::shared_ptr<GOptions>& opts) {
        using Factory = GSROImplementation* (*)(const std::shared_ptr<GOptions>&);
        auto factory = reinterpret_cast<Factory>(dlsym(handle, "GSROImplementationFactory"));
        if (!factory) { throw std::runtime_error("SRO plugin is missing GSROImplementationFactory"); }
        return factory(opts);
    }
 
protected:
    std::shared_ptr<GOptions> options;
};