queue_base.hpp

#pragma once
 
#include <cstddef>
#include <cstdint>
 
#include "libxr_def.hpp"
 
namespace LibXR
{
class QueueBase
{
 public:
  QueueBase(uint16_t element_size, size_t length, uint8_t* buffer);
 
  QueueBase(uint16_t element_size, size_t length);
 
  ~QueueBase();
 
  [[nodiscard]] void* operator[](uint32_t index);
 
  ErrorCode PushBytes(const void* data);
 
  ErrorCode PeekBytes(void* data);
 
  ErrorCode PopBytes(void* data = nullptr);
 
  int GetLastElementIndex() const;
 
  int GetFirstElementIndex() const;
 
  ErrorCode PushBatchBytes(const void* data, size_t size);
 
  ErrorCode PopBatchBytes(void* data, size_t size);
 
  ErrorCode PeekBatchBytes(void* data, size_t size);
 
  ErrorCode OverwriteBytes(const void* data);
 
  void Reset();
 
  [[nodiscard]] size_t Size() const;
 
  [[nodiscard]] size_t EmptySize() const;
 
  [[nodiscard]] size_t MaxSize() const { return length_; }
 
 private:
  QueueBase(const QueueBase&);
  QueueBase& operator=(const QueueBase&);
  QueueBase& operator=(QueueBase&);
  QueueBase& operator=(const QueueBase&&);
  QueueBase& operator=(QueueBase&&);
 
 public:
  uint8_t* queue_array_;        
  const uint16_t ELEMENT_SIZE;  
  size_t head_ = 0;  
  size_t tail_ = 0;  
  bool is_full_ = false;  
  size_t length_;         
  bool own_buffer_ =
      false;  
};
}  // namespace LibXR