time_extension_reader.h

Go to the documentation of this file.

 
#pragma once
#include <adtf_file/reader.h>
 
namespace adtfdat_processing
{

class TimeExtensionReader : public adtf_file::SeekableReader,
                            public adtf_file::ExplicitReader
{
public:
    TimeExtensionReader();
 
    std::string getReaderIdentifier() const override;
    void open(const std::string& file_name,
              std::shared_ptr<adtf_file::SampleFactory> sample_factory,
              std::shared_ptr<adtf_file::StreamTypeFactory> stream_type_factory) override;
 
    uint32_t getFileVersion() const override;
    std::string getDescription() const override;
    std::vector<adtf_file::Stream> getStreams() const override;
    std::vector<adtf_file::Extension> getExtensions() const override;
    adtf_file::FileItem getNextItem() override;
    std::optional<uint64_t> getItemCount() const override;
    std::optional<double> getProgress() const override;
 
    uint64_t getItemIndexForTimeStamp(std::chrono::nanoseconds time_stamp) override;
    uint64_t getItemIndexForStreamItemIndex(uint16_t stream_id, uint64_t stream_item_index) override;
    std::shared_ptr<const adtf_file::StreamType> getStreamTypeBefore(uint64_t item_index, uint16_t stream_id) override;
    void seekTo(uint64_t item_index) override;
 
private:
    std::shared_ptr<adtf_file::SampleFactory> _sample_factory;
    std::shared_ptr<adtf_file::StreamTypeFactory> _stream_type_factory;
    std::shared_ptr<Reader> _reader;
    std::vector<adtf_file::Stream> _streams;
    uint16_t _time_extension_stream_id;
    std::chrono::nanoseconds _time_extension;
    std::chrono::nanoseconds _remaining_time_extension;
    std::chrono::nanoseconds _time_extension_interval;
    std::chrono::nanoseconds _time_extension_last;
    bool _next_item_is_sample = true;
};

using TimeExtensionReaderFactory = adtf_file::ReaderFactoryImplementation<TimeExtensionReader>;
 
}