peak_buffer_guard.hpp

Go to the documentation of this file.

 
#pragma once
 
#include <peak_common_c/detail/peak_common_defines.h>
 
#include <peak_common_c/detail/peak_common_defines.h>
#include <peak/buffer/peak_buffer.hpp>
#include <peak/data_stream/peak_data_stream.hpp>
 
#include <memory>
 
 
namespace peak
{
 
namespace core
{

class BufferGuard
{
public:
    explicit BufferGuard(std::shared_ptr<core::Buffer> buffer);

    ~BufferGuard();
 
    BufferGuard(const BufferGuard& other) = delete;
    BufferGuard& operator=(const BufferGuard& other) = delete;
    BufferGuard(BufferGuard&& other) noexcept = default;
    BufferGuard& operator=(BufferGuard&& other) noexcept = default;

    PEAK_COMMON_NO_DISCARD std::shared_ptr<core::Buffer> Buffer() const;

    PEAK_COMMON_NO_DISCARD core::Buffer* operator->() const;
 
private:
    std::shared_ptr<core::Buffer> m_buffer;
};
 
} /* namespace core */
} /* namespace peak */
 
/* Implementation */
namespace peak
{
namespace core
{
 
inline BufferGuard::BufferGuard(std::shared_ptr<core::Buffer> buffer)
    : m_buffer(std::move(buffer))
{
    if (m_buffer == nullptr)
    {
        throw InvalidArgumentException("The given buffer is a nullptr!");
    }
}
 
inline BufferGuard::~BufferGuard()
{
    if (m_buffer)
    {
        try
        {
            m_buffer->ParentDataStream()->QueueBuffer(m_buffer);
        }
        catch (...)
        {}
    }
}
 
inline std::shared_ptr<core::Buffer> BufferGuard::Buffer() const
{
    return m_buffer;
}
 
inline core::Buffer* BufferGuard::operator->() const
{
    return m_buffer.get();
}
 
} /* namespace core */
} /* namespace peak */