detail_ring_buffer.hpp

#pragma once
 
#include "../../global.hpp"
#include "../../device.hpp"
 
#include "../_decl/decl_stream.hpp"
 
#include "../_decl/decl_ring_buffer.hpp"
#include "../_decl/decl_ring_buffer_image.hpp"
 
namespace Cvb
{
 
  CVB_BEGIN_INLINE_NS
 
  namespace Driver
  {
 
    inline RingBufferImagePtr RingBuffer::At(int bufferIndex) const
    {
      return bufferImages_[static_cast<std::size_t>(bufferIndex)].AtomicGet([&] {
        void *handle = nullptr;
        auto result  = CExports::RBGetBufferImage(parent_->Handle(), bufferIndex, handle);
        if (result < 0)
          std::rethrow_exception(CvbException::FromCvbResult(result, "failed to get ring buffer image"));
 
        return Image::FromHandle<RingBufferImage>(HandleGuard<Image>(handle), bufferIndex, shared_from_this());
      });
    }
 
    inline int RingBuffer::Count() const noexcept
    {
 
      void *dumy             = nullptr;
      CExports::cvbval_t num = 0;
      CExports::RBNumBuffer(parent_->Handle(), CExports::RINGBUFFER_NUMBUFFER_CMD::RINGBUFFER_NUMBUFFER_CMD_GET, num,
                            dumy);
      return static_cast<int>(num);
    }
 
    inline RingBufferLockMode RingBuffer::LockMode() const noexcept
    {
      CExports::RINGBUFFER_LOCKMODE lockMode = CExports::RINGBUFFER_LOCKMODE::RINGBUFFER_LOCKMODE_AUTO;
      CExports::RBLockMode(parent_->Handle(), CExports::RINGBUFFER_LOCKMODE_CMD::RINGBUFFER_LOCKMODE_CMD_GET, lockMode);
 
      return static_cast<RingBufferLockMode>(lockMode);
    }
 
    inline void RingBuffer::SetLockMode(RingBufferLockMode ringBufferLockMode)
    {
 
      if (parent_->StreamCount() > 0 && parent_->Stream()->IsRunning())
        throw std::logic_error("can't change lock mode while grab is active");
 
      auto lockMode = static_cast<CExports::RINGBUFFER_LOCKMODE>(ringBufferLockMode);
      auto result =
          CExports::RBLockMode(parent_->Handle(), CExports::RINGBUFFER_LOCKMODE_CMD::RINGBUFFER_LOCKMODE_CMD_SET, lockMode);
      if (result < 0)
        std::rethrow_exception(CvbException::FromCvbResult(result, "failed to set ring buffer lock mode"));
    }
 
    inline void RingBuffer::ChangeCount(int numBuffers, DeviceUpdateMode mode)
    {
      if (parent_->StreamCount() > 0 && parent_->Stream()->IsRunning())
        throw std::logic_error("can't change number of buffers while grab is active");
 
      std::vector<Internal::AsyncRef<RingBufferImage>> newBufferImages(static_cast<std::size_t>(numBuffers));
 
      CExports::cvbval_t num = static_cast<CExports::cvbval_t>(numBuffers);
      CExports::IMG img      = nullptr;
      auto result            = CExports::RBNumBuffer(parent_->Handle(),
                                                     CExports::RINGBUFFER_NUMBUFFER_CMD::RINGBUFFER_NUMBUFFER_CMD_SET, num, img);
      if (result < 0)
        std::rethrow_exception(CvbException::FromCvbResult(result, "failed to set number of buffers"));
 
      bufferImages_.swap(newBufferImages);
 
      HandleGuard<Device> guard(img);
      parent_->ChangeHandle(std::move(guard), mode);
    }
 
  }  // namespace Driver
 
  CVB_END_INLINE_NS
 
}  // namespace Cvb