time_extension_reader.h

Go to the documentation of this file.

 
#pragma once
#include <adtf_file/reader.h>
#include <unordered_map>
 
namespace adtfdat_processing
{
 
class TimeExtensionReader : public adtf_file::Reader,
                            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;
 
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 _time_extension_interval;
    std::chrono::nanoseconds _time_extension_last;
    bool _next_item_is_sample = true;
};
 
using TimeExtensionReaderFactory = adtf_file::ReaderFactoryImplementation<TimeExtensionReader>;
 
}