lastinbuffer.h

Go to the documentation of this file.

 
#ifndef SEMF_UTILS_CORE_BUFFER_LASTINBUFFER_H_
#define SEMF_UTILS_CORE_BUFFER_LASTINBUFFER_H_
 
#include <semf/utils/core/buffer/buffer.h>
 
namespace semf
{
template <typename T>
class LastInBuffer : public Buffer<T>
{
public:
    using Buffer<T>::Buffer;
    virtual ~LastInBuffer() = default;
 
    virtual void put(T data);
    void fill(T data);
    virtual T& operator[](size_t pos) const;
    void setPos(size_t pos);
    size_t pos() const;
 
private:
    size_t m_pos = 0;
};
 
template <typename T>
void LastInBuffer<T>::put(T data)
{
    CriticalSection::enter();
    this->data()[m_pos++] = data;
    m_pos %= this->size();
    CriticalSection::exit();
}
 
template <typename T>
void LastInBuffer<T>::fill(T data)
{
    for (size_t i = 0; i < this->size(); i++)
    {
        CriticalSection::enter();
        this->data()[i] = data;
        CriticalSection::exit();
    }
}
 
template <typename T>
T& LastInBuffer<T>::operator[](size_t pos) const
{
    pos %= this->size();
 
    CriticalSection::enter();
    T& data = m_pos >= pos + 1 ? this->data()[m_pos - (pos + 1)] : this->data()[(this->size() + m_pos) - (pos + 1)];
    CriticalSection::exit();
    return data;
}
 
template <typename T>
void LastInBuffer<T>::setPos(size_t pos)
{
    m_pos = pos % this->size();
}
 
template <typename T>
size_t LastInBuffer<T>::pos() const
{
    return m_pos;
}
} /* namespace semf */
#endif /* SEMF_UTILS_CORE_BUFFER_LASTINBUFFER_H_ */