VideoDecoder.hpp

#pragma once
#include <Media/Libav.hpp>
#if SCORE_HAS_LIBAV
#include <Video/FrameQueue.hpp>
#include <Video/Rescale.hpp>
#include <Video/VideoInterface.hpp>
extern "C" {
#include <libavformat/avformat.h>
#include <libswscale/swscale.h>
}
 
#include <ossia/detail/lockfree_queue.hpp>
 
#include <score_plugin_media_export.h>
 
#include <atomic>
#include <condition_variable>
#include <mutex>
#include <string>
#include <thread>
#include <vector>
 
namespace Video
{
class SCORE_PLUGIN_MEDIA_EXPORT VideoDecoder final
    : public VideoInterface
    , public LibAVDecoder
{
public:
  explicit VideoDecoder(DecoderConfiguration) noexcept;
  ~VideoDecoder() noexcept;
 
  bool open(const std::string& inputFile) noexcept;
  bool load(const std::string& inputFile) noexcept;
 
  const std::string& file() const noexcept { return m_inputFile; }
 
  int64_t duration() const noexcept;
 
  void seek(int64_t flicks);
 
  AVFrame* dequeue_frame() noexcept override;
  void release_frame(AVFrame*) noexcept override;
 
private:
  void buffer_thread() noexcept;
  void close_file() noexcept;
  bool seek_impl(int64_t dts) noexcept;
  AVFrame* read_frame_impl() noexcept;
  bool open_stream() noexcept;
  void close_video() noexcept;
 
  static const constexpr int frames_to_buffer = 16;
 
  std::string m_inputFile;
 
  std::thread m_thread;
  std::mutex m_condMut;
  std::condition_variable m_condVar;
 
  int64_t m_duration{}; // in flicks
 
  std::atomic_int64_t m_seekTo = -1;
  std::atomic_int64_t m_last_dequeued_dts = 0;
  std::atomic_int64_t m_dequeued = 0;
 
  std::atomic_bool m_running{};
};
 
}
#endif