decl_server.hpp

#pragma once
 
#include <atomic>
#include <iostream>
#include <mutex>
#include <thread>
 
#include "../../exception.hpp"
#include "../../global.hpp"
#include "../../size_2d.hpp"
#include "../../utilities/system_info.hpp"
#include "../logical_network_interface.hpp"
 
#include "../../driver/driver.hpp"
#include "../_decl/decl_server_base.hpp"
 
#include "../_detail/detail_server_base.hpp"
 
#include "../gevserver.hpp"
#include "../../pfnc_format.hpp"
 
namespace Cvb
{
  CVB_BEGIN_INLINE_NS
 
  template <>
  inline HandleGuard<GevServer::Server>::HandleGuard(void *handle) noexcept
      : HandleGuard<GevServer::Server>(handle, [](void *handle) { CVB_CALL_CAPI(ReleaseObject(handle)); })
  {
  }
  namespace GevServer
  {
    class Server : public ServerBase
    {
    public:
      using GuardType = HandleGuard<Server>;

      static ServerPtr CreateNonStreaming();

      static ServerPtr CreateWithConstSize(Size2D<int> size, PfncFormat pixelFormat,
                                           GevServer::DriverType driverType = GevServer::DriverType::Auto);

      static ServerPtr CreateWithConstSize(Size2D<int> size, ColorModel colorModel, DataType dataType,
                                           GevServer::DriverType driverType = GevServer::DriverType::Auto);

      static ServerPtr CreateWithVariableSize(Size2D<int> maxSize, ColorModel colorModel, DataType dataType,
                                              GevServer::DriverType driverType = GevServer::DriverType::Auto);

      static ServerPtr CreateWithVariableSize(Size2D<int> maxSize, PfncFormat pixelFormat,
                                              GevServer::DriverType driverType = GevServer::DriverType::Auto);
 
      Server(HandleGuard<Server> &&guard, bool hasStream, ProtectedTag)
          : handle_(std::move(guard))
          , ServerBase(hasStream)
      {
        RegisterEvents();
      }
 
      void *Handle() const noexcept override
      {
        return handle_.Handle();
      }
 
      StreamPtr Stream() const;
 
    private:
      mutable Internal::AsyncRef<GevServer::Stream> gsStream_;
      HandleGuard<Server> handle_;
    };
  }  // namespace GevServer
  CVB_END_INLINE_NS
}  // namespace Cvb