libs/common/RingBuffer.h

Go to the documentation of this file.

#ifndef QRK_RING_BUFFER_H
#define QRK_RING_BUFFER_H

#include <deque>


namespace qrk
{
    template <class T>
    class RingBuffer
    {
    public:
        explicit RingBuffer(void)
        {
        }


        size_t size(void)
        {
            return ring_buffer_.size();
        }


        bool empty(void)
        {
            return ring_buffer_.empty();
        }


        void put(const T* data, size_t size)
        {
            const T* last_p = data + size;
            ring_buffer_.insert(ring_buffer_.end(), data, last_p);
        }


        size_t get(T* data, size_t size)
        {
            size_t n = std::min(size, ring_buffer_.size());
            std::copy(ring_buffer_.begin(), ring_buffer_.begin() + n, data);
            ring_buffer_.erase(ring_buffer_.begin(), ring_buffer_.begin() + n);
            return n;
        }


        void ungetc(const T ch)
        {
            ring_buffer_.push_front(ch);
        }


        void clear(void)
        {
            ring_buffer_.clear();
        }


    private:
        RingBuffer(const RingBuffer& rhs);
        RingBuffer& operator = (const RingBuffer& rhs);

        std::deque<T> ring_buffer_;
    };
}

#endif /* !QRK_RING_BUFFER_H */