gstreamerJLABSROFactory.h

Go to the documentation of this file.

#pragma once
 
// gstreamer
#include "gstreamer.h"
#include "gstreamerConventions.h"
 
// c++
#include <fstream>
 
#pragma pack(push, 1)
struct DataFrameHeader
{
    uint32_t source_id;
    uint32_t total_length;
    uint32_t payload_length;
    uint32_t compressed_length;
    uint32_t magic;
    uint32_t format_version;
    uint32_t flags;
    uint64_t record_counter;
    uint64_t ts_sec;
    uint64_t ts_nsec;
};
#pragma pack(pop)
 
class GstreamerJSROFactory : public GStreamer
{
public:
    //  GstreamerJSROFactory() = default;
 
    // inherit the base (const std::shared_ptr<GOptions>&) ctor
    using GStreamer::GStreamer;
 
private:
    // open and close the output media
    bool openConnection() override;
    bool closeConnectionImpl() override;
 
    // frame streams
    bool startStreamImpl(const GFrameDataCollection* frameRunData) override;
    bool endStreamImpl(const GFrameDataCollection* frameRunData) override;
    bool publishFrameHeaderImpl(const GFrameHeader* gframeHeader) override;
    bool publishPayloadImpl(const std::vector<GIntegralPayload*>* payload) override;
 
    // JLAB specific
    static inline std::uint64_t llswap(unsigned long long val) { return (val >> 32) | (val << 32); }
 
private:
    std::ofstream* ofile = nullptr;
 
    std::vector<unsigned int> frame_data{};
 
    std::string filename() const override { return gstreamer_definitions.rootname + ".ev"; }
};