rtpseqreorderbuffer.h

Go to the documentation of this file.

 
#pragma once
 
 
#include <promeki/config.h>
#if PROMEKI_ENABLE_NETWORK
#include <cstdint>
#include <promeki/duration.h>
#include <promeki/error.h>
#include <promeki/map.h>
#include <promeki/mutex.h>
#include <promeki/namespace.h>
#include <promeki/rtppacket.h>
#include <promeki/timestamp.h>
 
PROMEKI_NAMESPACE_BEGIN
 
class RtpSeqReorderBuffer {
        public:
                struct Config {
                                size_t maxWindow = 64;
 
                                Duration playoutDelay = Duration::fromMilliseconds(0);
                };
 
                struct Stats {
                                uint64_t inserted = 0;
                                uint64_t emittedInOrder = 0;
                                uint64_t emittedOnDeadline = 0;
                                uint64_t droppedOnOverflow = 0;
                                uint64_t droppedAsDuplicate = 0;
                };
 
                RtpSeqReorderBuffer() = default;
                explicit RtpSeqReorderBuffer(const Config &c);
 
                void insert(RtpPacket pkt, uint32_t extendedSeq,
                            const TimeStamp &arrivalSteady, RtpPacket::Queue &out);
 
                void flush(RtpPacket::Queue &out);
 
                void clear();
 
                Stats snapshot() const;
 
                Config config() const;
 
                size_t size() const;
 
        private:
                struct Entry {
                                RtpPacket pkt;
                                TimeStamp arrival;
                };
 
                using EntryMap = Map<uint32_t, Entry>;
 
                // Drains any in-order tail starting at the next-
                // expected seq.  Caller must hold @c _mutex.
                void drainInOrderLocked(RtpPacket::Queue &out);
 
                // Emits the head entry as a deadline-fill case.
                // Caller must hold @c _mutex.
                void emitHeadLocked(RtpPacket::Queue &out, bool deadline);
 
                mutable Mutex                _mutex;
                Config                       _config;
                EntryMap                     _buf;
                bool                         _haveExpected = false;
                uint32_t                     _expectedSeq = 0;
                Stats                        _stats;
};
 
PROMEKI_NAMESPACE_END
 
#endif // PROMEKI_ENABLE_NETWORK