gSROFactory.h

Go to the documentation of this file.

#pragma once
 
#include <gemc/gstreamer/sro/gSROImplementation.h>
#include <gemc/gstreamer/sro/gSROService.h>
 
#include <atomic>

class GSROFactory {
public:
    static std::shared_ptr<GSROFactory> from_options(const std::shared_ptr<GOptions>& options);
 
    GSROFactory(std::shared_ptr<GSROImplementation> implementation, std::string output_basename);
    void begin_run(int run_id, GSROEventId event_count);
    void create_crate_thread_if_needed(GSROCrateId crate);
    void dispatch_payload_to_crate(GSROPayload payload);
    void complete_event(GSROEventId event);
    void interrupt_run() { interrupted = true; }
    void cancel_run(std::exception_ptr error);
    void finish_run(bool all_events_processed);
    void rethrow_if_failed() const;
    GSROEventContext event_context(GSROEventId event) const { return {run_context.run_id, event}; }
 
private:
    // Declaration order keeps implementation code loaded until service/timing/data destruction finishes.
    std::shared_ptr<GSROImplementation> implementation;
    GSRORunContext run_context;
    std::atomic<bool> interrupted{false};
    GSROService service;
};