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:
    using GStreamer::GStreamer;
 
private:
    bool openConnection() override;

    bool closeConnectionImpl() override;

    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;

    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"; }
};