TunnelInterface.hpp

#ifndef ZAO_ENDPOINT_IP_TUNNEL_INTERFACE_HPP_
#define ZAO_ENDPOINT_IP_TUNNEL_INTERFACE_HPP_
 
#include <cstdint>
#include <memory>
#include <string>
 
#include "../EventSourceInterface.hpp"
#include "../StreamInterface.hpp"
#include "../TimestampInterface.hpp"
#include "FrameSinkBufferDequeueResult.hpp"
#include "FrameSinkBufferEnqueueResult.hpp"
#include "FrameSinkBufferInterface.hpp"
#include "FrameSourceBufferDequeueResult.hpp"
#include "FrameSourceBufferEnqueueResult.hpp"
#include "FrameSourceBufferInterface.hpp"
 
namespace zao {
namespace endpoint {
namespace ip {
 
class TunnelCallbackInterface;
 
class TunnelInterface : public StreamInterface,
                        public EventSourceInterface<TunnelCallbackInterface> {
 public:
  virtual void ConfigureQueue(std::size_t bytes_per_buffer,
                              std::size_t num_of_buffers) = 0;
 
  virtual FrameSourceBufferDequeueResult DequeueSourceBuffer() = 0;
 
  virtual FrameSourceBufferEnqueueResult EnqueueSourceBuffer(
      std::unique_ptr<FrameSourceBufferInterface> buffer) = 0;
 
  virtual FrameSinkBufferDequeueResult DequeueSinkBuffer() = 0;
 
  virtual FrameSinkBufferEnqueueResult EnqueueSinkBuffer(
      std::unique_ptr<FrameSinkBufferInterface> buffer) = 0;
 
  virtual void FlushQueue() = 0;
 
  virtual ~TunnelInterface() noexcept = default;
};
 
class TunnelCallbackInterface {
 public:
  enum class EventType {
    kUnknown = 0,
 
    kDisconnected,
 
    kUnlinked,
 
    kDepacketizeError,
 
    kDeactivated,
 
    kActivated,
  };
 
  virtual void OnNotifyTunnelEvent(EventType type, const std::string& message) {
  }
 
  virtual ~TunnelCallbackInterface() noexcept = default;
};
 
}  // namespace ip
}  // namespace endpoint
}  // namespace zao
 
#endif  // ZAO_ENDPOINT_IP_TUNNEL_INTERFACE_HPP_