detail_stream_gev3.hpp

#pragma once
 
#include "../_decl/decl_stream_gev3.hpp"
 
 
inline Cvb::GevServer::SendStatus Cvb::GevServer::StreamGev3::SendFlowSet(size_t index, std::vector<size_t> actualSendSizes,
                                                              std::function<void(size_t)> onSendComplete)
{
  auto parentServerGev3 = std::dynamic_pointer_cast<ServerGev3>(parent_);
  if (!parentServerGev3)
    throw std::runtime_error("parent server pointer is not valid or not a ServerGev3 ptr");
 
  if (index >= parentServerGev3->GetRegisteredFlowSetPoolSize())
    throw std::out_of_range("FlowSet index out of range");
  
  if (actualSendSizes.size() != parentServerGev3->GetRegisteredFlowSetInfo().size())
    throw std::length_error("Actual send sizes must match flow infos size");
  auto pPrivate =
      new std::function<void(void)>([onSendComplete, index]() mutable  // NOLINT(cppcoreguidelines-owning-memory)
                                { 
                                  try
                                  {
                                    onSendComplete(index);
                                  }
                                  catch (...)
                                  {
                                   
                                  }
                                });
  CExports::CVGSSendStatus status = CExports::CVGSSendStatus::GVGSSS_Timeout;
  try
  {
    CVB_CALL_CAPI_CHECKED(CVGSServerSendFlowSet(parentServerGev3->Handle(), index, actualSendSizes.data(),
                                                actualSendSizes.size(), &SendDispatcher, pPrivate, status));
  }
  catch (const std::exception &)
  {
    delete pPrivate;
    throw;
  }
  return static_cast<SendStatus>(status);
}