BufferAccumulator.hpp

Go to the documentation of this file.

#pragma once
#include <Pothos/Config.hpp>
#include <Pothos/Framework/BufferPool.hpp>
#include <Pothos/Framework/BufferChunk.hpp>
#include <Pothos/Util/RingDeque.hpp>
#include <cassert>

namespace Pothos {

class POTHOS_API BufferAccumulator
{
public:

    BufferAccumulator(void);

    void clear(void);

    bool empty(void) const;

    void push(BufferChunk &&buffer);

    const BufferChunk &front(void) const;

    void pop(const size_t numBytes);

    size_t getTotalBytesAvailable(void) const;

    void require(const size_t numBytes);

    size_t getUniqueManagedBufferCount(void) const;

private:
    Util::RingDeque<BufferChunk> _queue;
    size_t _bytesAvailable;
    bool _inPoolBuffer;
    BufferPool _pool;
};

} //namespace Pothos

inline bool Pothos::BufferAccumulator::empty(void) const
{
    return _bytesAvailable == 0;
}

inline const Pothos::BufferChunk &Pothos::BufferAccumulator::front(void) const
{
    assert(not _queue.empty());
    return _queue.front();
}

inline size_t Pothos::BufferAccumulator::getTotalBytesAvailable(void) const
{
    return _bytesAvailable;
}