gSROService.h

Go to the documentation of this file.

#pragma once
 
#include "gSROCrate.h"

class GSROService
{
public:
    using ResourceFactory = std::function<GSROCrateResources(GSROCrateId)>;
    using DeliveryCallback = std::function<void(GSROCrateId, GSROEventId, std::uint64_t)>;
 
    GSROService();
    ~GSROService();
    GSROService(const GSROService&) = delete;
    GSROService& operator=(const GSROService&) = delete;
    GSROService(GSROService&&) = delete;
    GSROService& operator=(GSROService&&) = delete;

    void begin_run(ResourceFactory make_resources, GSROCrateLimits limits = {},
                   DeliveryCallback on_delivery = {});

    void begin_run(ResourceFactory make_resources, std::shared_ptr<const GSROTiming> timing,
                   GSROCrateLimits limits = {}, std::size_t max_pending_events = 65536);

    void create_crate_thread_if_needed(GSROCrateId crate_id);

    void dispatch_payload_to_crate(GSROPayload payload);

    void complete_event(GSROEventId event_id);

    void advance_time(GSROTime safe_time);

    void finish_run(GSROEndContext context);
    void cancel_run(std::exception_ptr error);
    void rethrow_if_failed() const;
 
private:
    class Impl;
    std::unique_ptr<Impl> impl;
};