fifobuffer.h

Go to the documentation of this file.

#pragma once

#include "fifo_buffer_base.h"

BEGIN_NAMESPACE_MEMORY

template <typename T>
struct FifoBufferStatus
{
    T* bufferPtr;
    size_t capacity;
    size_t readPos;
    size_t writePos;
    size_t size;
};

template <typename T>
class FifoBuffer : public FifoBufferBase<T>
{
public:
    explicit FifoBuffer(size_t aCapacity = 0);

    void setCapacity(size_t aCapacity) override;

    FifoBufferStatus<T> getStatus();

    T* getData() const override;

    std::size_t getSize() const;

protected:
    std::unique_ptr<T[]> buffer;
};


template <typename T>
FifoBuffer<T>::FifoBuffer(size_t aCapacity)
{
    FifoBuffer<T>::setCapacity(aCapacity);
}

template <typename T>
void FifoBuffer<T>::setCapacity(size_t aCapacity)
{
    std::lock_guard<std::recursive_mutex> guard(this->getLock());
    FifoBufferBase<T>::setCapacity(aCapacity);
    buffer.reset(new T[this->getCapacity()]);
}

template <typename T>
FifoBufferStatus<T> FifoBuffer<T>::getStatus()
{
    std::lock_guard<std::recursive_mutex> guard(this->getLock());
    return {buffer.get(), this->capacity, this->readPos, this->writePos, this->size};
}

template <typename T>
T* FifoBuffer<T>::getData() const
{
    return buffer.get();
}

template <typename T>
std::size_t FifoBuffer<T>::getSize() const
{
    std::lock_guard<std::recursive_mutex> guard(FifoBufferBase<T>::lock);
    return FifoBufferBase<T>::size;
}

END_NAMESPACE_MEMORY