OutboundQueue.hpp

Go to the documentation of this file.

 
#pragma once
 
#include <SDL3/SDL_stdinc.h>
 
#include <SDL3_net/SDL_net.h>
#include <cstdint>
#include <deque>
#include <memory>
#include <mutex>
#include <vector>

struct OutboundEntry
{
    uint8_t replaceKey = 0;

    Uint64 enqueuedNs = 0;

    std::shared_ptr<const std::vector<uint8_t>> framedBytes;
};

class OutboundQueue
{
public:
    void enqueue(uint8_t replaceKey, std::shared_ptr<const std::vector<uint8_t>> framedBytes);

    void enqueue(uint8_t replaceKey, std::vector<uint8_t>&& framedBytes);

    bool flushTo(NET_StreamSocket* socket, Uint32 maxAgeMs);

    [[nodiscard]] size_t depth() const noexcept
    {
        std::lock_guard<std::mutex> lock(mutex_);
        return entries_.size();
    }

    [[nodiscard]] size_t totalBytes() const noexcept;

    void clear() noexcept
    {
        std::lock_guard<std::mutex> lock(mutex_);
        entries_.clear();
    }
 
private:
    mutable std::mutex mutex_; 
    std::deque<OutboundEntry> entries_;
};