decl_server_gev3.hpp

#pragma once
 
#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 "../../driver/flow_set_pool.hpp"
#include "../../driver/gendc_descriptor.hpp"
#include "../_decl/decl_server_base.hpp"
#include "../gevserver.hpp"
#include "../../pfnc_format.hpp"
 
namespace Cvb
{
  CVB_BEGIN_INLINE_NS
 
  template <>
  inline HandleGuard<GevServer::ServerGev3>::HandleGuard(void *handle) noexcept
      : HandleGuard<GevServer::ServerGev3>(handle, [](void *handle) { CVB_CALL_CAPI(ReleaseObject(handle)); })
  {
  }
 
  namespace GevServer
  {
    class ServerGev3 : public ServerBase
    {
    public:
      using GuardType = HandleGuard<ServerGev3>;
      static ServerGev3Ptr Create(GevServer::DriverType driverType);

      template <class T>
      static ServerGev3Ptr FromHandle(HandleGuard<ServerGev3> &&guard)
      {
        if (!guard.Handle())
          throw std::runtime_error("handle must not be null");
        return std::make_shared<ServerGev3>(std::move(guard), ProtectedTag{});
      }
 
      void *Handle() const noexcept override
      {
        return handle_.Handle();
      }
 
      ServerGev3(HandleGuard<ServerGev3> &&guard, ProtectedTag)
          : ServerBase(true)
          , handle_(std::move(guard))
          , registeredPoolSize_{0}
          , registeredFlowSetInfo_{}
 
      {
        RegisterEvents();
      }

      void RegisterFlowSetPool(const GenDcDescriptor &descriptor, FlowSetPoolPtr flowSetPool,
                               std::function<void()> onFlowSetRelease);

      size_t GetRegisteredFlowSetPoolSize() const noexcept;

      std::vector<FlowInfo> GetRegisteredFlowSetInfo() const noexcept;

      StreamGev3Ptr Stream() const;
 
    private:
      mutable Internal::AsyncRef<GevServer::StreamGev3> gsStream_;
      std::vector<FlowInfo> registeredFlowSetInfo_;
      size_t registeredPoolSize_;
      HandleGuard<ServerGev3> handle_;
    };
  }  // namespace GevServer
  CVB_END_INLINE_NS
}  // namespace Cvb