packet_buffer.h

#ifndef PACKET_BUFFER_H
#define PACKET_BUFFER_H
 
#include <atomic>
#include <mutex>
#include <queue>
#include <vector>
 
namespace ObdEmulator
{
    class PacketBuffer
    {
    private:
        std::mutex mMutex;
        std::queue<std::vector<uint8_t>> mQueue;
        std::atomic_size_t mSize;
 
    public:
        PacketBuffer();
 
        ~PacketBuffer() = default;
 
        inline bool Empty() const noexcept
        {
            return mSize == 0;
        }
 
        bool TryEnqueue(std::vector<uint8_t> &&packet);
 
        bool TryDequeue(std::vector<uint8_t> &packet);
 
        bool TryClear();
    };
}
 
#endif