decl_stream_base.hpp

#pragma once
 
#include "../../global.hpp"
 
#include "../../image.hpp"
 
#include "../chunk_image_buffer_description.hpp"
#include "../gevserver.hpp"
 
namespace Cvb
{
  CVB_BEGIN_INLINE_NS
  namespace GevServer
  {

    class StreamBase
    {
    protected:
      explicit StreamBase(const ServerBasePtr &parent)
          : parent_(parent)
      {
        if (!parent_)
          throw std::runtime_error("Server for stream creation must not be null");
      }
 
    public:
      virtual ~StreamBase() {}
      StreamBase(const StreamBase &other) noexcept       = delete;
      StreamBase(StreamBase &&) noexcept                 = delete;
      StreamBase &operator=(StreamBase &&) noexcept      = delete;
      StreamBase &operator=(const StreamBase &) noexcept = delete;

      virtual bool IsRunning() const;

      virtual std::int64_t ResendBuffersCount() const;

      virtual void SetResendBuffersCount(const std::int64_t &numBuffers);
 
    protected:
      static void __stdcall SendDispatcher(void *pPrivate)
      {
        // Call thread context of Send function
        if (auto pFunction = reinterpret_cast<std::function<void(void)> *>(pPrivate))
        {
          try
          {
            (*pFunction)();
          }
          catch (...)
          {
          }
          delete pFunction;
        }
      }
 
      ServerBasePtr parent_;
    };
  }  // namespace GevServer
  CVB_END_INLINE_NS
}  // namespace Cvb