NvSourceInterface.hpp

#ifndef ZEP_VIDEO_NV_SOURCE_INTERFACE_HPP_
#define ZEP_VIDEO_NV_SOURCE_INTERFACE_HPP_

#include <future>
#include <memory>
#include <vector>

#include "../SourceStreamInterface.hpp"
#include "../StreamInterface.hpp"
#include "../TimestampInterface.hpp"
#include "NvBufferInterface.hpp"
#include "VideoFormat.hpp"

// 前方宣言
struct v4l2_buffer;
class NvBuffer;
namespace v4l2 {
struct VideoFormat;
}

namespace zep {
namespace video {

class NvSourceCallbackInterface;

class NvSourceInterface : public StreamInterface, public SourceStreamInterface {
 public:
  virtual void SetAcceptableFormats(
      const std::vector<VideoFormat>& formats) = 0;

  virtual bool GetDecidedFormat(VideoFormat& format) const noexcept = 0;

  virtual std::shared_future<VideoFormat> GetFormatDecisionStatus()
      const noexcept = 0;

  virtual std::unique_ptr<NvBufferInterface> DequeueBuffer() = 0;
  virtual bool QueueBuffer(std::unique_ptr<NvBufferInterface> buffer) = 0;

  virtual void SendStatistics(/*TODO*/) = 0;

  virtual void RegisterCallback(
      const std::shared_ptr<NvSourceCallbackInterface>& listener,
      bool use_weak_ptr = false) = 0;

  virtual void RegisterCallback(
      std::unique_ptr<NvSourceCallbackInterface>&& listener) = 0;

  virtual ~NvSourceInterface() noexcept = default;
};

class NvSourceCallbackInterface : public StreamCallbackInterface,
                                  public SourceStreamCallbackInterface {
 public:
  enum class EventType {
    kUnknown = 0,

    kDisconnected,

    kUnlinked,

    kFailedFormatNegotiation,
  };

  virtual bool OnRequestSourceFormat(const VideoFormat& format) = 0;

  virtual void OnNotifySourceEvent(EventType type, const std::string& message) {
  }

  virtual ~NvSourceCallbackInterface() noexcept = default;
};

}  // namespace video
}  // namespace zep

#endif  // ZEP_VIDEO_NV_SOURCE_INTERFACE_HPP_