NvSourceInterface.hpp

#ifndef ZAO_ENDPOINT_VIDEO_NV_SOURCE_INTERFACE_HPP_
#define ZAO_ENDPOINT_VIDEO_NV_SOURCE_INTERFACE_HPP_
 
#include <future>
#include <memory>
#include <vector>
 
#include "../EventSourceInterface.hpp"
#include "../SourceStreamInterface.hpp"
#include "../StreamInterface.hpp"
#include "../TimestampInterface.hpp"
#include "NvBufferInterface.hpp"
#include "NvSourceBufferDequeueResult.hpp"
#include "NvSourceBufferEnqueueResult.hpp"
#include "VideoFormat.hpp"
 
// 前方宣言
struct v4l2_buffer;
class NvBuffer;
namespace v4l2 {
struct VideoFormat;
}
 
namespace zao {
namespace endpoint {
namespace video {
 
class NvSourceCallbackInterface;
 
class NvSourceInterface
    : public StreamInterface,
      public SourceStreamInterface,
      public EventSourceInterface<NvSourceCallbackInterface> {
 public:
  [[deprecated("Please use SetSourceFormats function")]]
  void SetAcceptableFormats(const std::vector<VideoFormat>& formats) {
    return SetSourceFormats(formats);
  }
  virtual void SetSourceFormats(const std::vector<VideoFormat>& formats) = 0;
 
  [[deprecated("Please use GetDeterminedFormat function")]]
  bool GetDecidedFormat(VideoFormat& format) const {
    return GetDeterminedFormat(format);
  }
 
  virtual bool GetDeterminedFormat(VideoFormat& format) const = 0;
 
  [[deprecated("Please use GetDeterminedFormatAsync function")]]
  std::shared_future<VideoFormat> GetFormatDecisionStatus() const {
    return GetDeterminedFormatAsync();
  }
 
  virtual std::shared_future<VideoFormat> GetDeterminedFormatAsync() const = 0;
 
  virtual NvSourceBufferDequeueResult DequeueSourceBuffer() = 0;
 
  [[deprecated("Please use DequeueSourceBuffer.")]]
  std::unique_ptr<NvBufferInterface> DequeueBuffer() {
    return DequeueSourceBuffer().TakeBuffer();
  }
 
  virtual NvSourceBufferEnqueueResult EnqueueSourceBuffer(
      std::unique_ptr<NvBufferInterface> buffer) = 0;
 
  [[deprecated("Please use EnqueueSourceBuffer.")]]
  bool QueueBuffer(std::unique_ptr<NvBufferInterface> buffer) {
    return !EnqueueSourceBuffer(std::move(buffer)).HasError();
  }
 
  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 endpoint
}  // namespace zao
 
#endif  // ZAO_ENDPOINT_VIDEO_NV_SOURCE_INTERFACE_HPP_