rtpseqtracker.h

Go to the documentation of this file.

 
#pragma once
 
 
#include <promeki/config.h>
#if PROMEKI_ENABLE_NETWORK
#include <cstdint>
#include <promeki/mutex.h>
#include <promeki/namespace.h>
#include <promeki/timestamp.h>
 
PROMEKI_NAMESPACE_BEGIN
 
class RtpSeqTracker {
        public:
                static constexpr unsigned int MinSequential = 2;
 
                static constexpr uint32_t MaxDropout = 32768;
 
                static constexpr uint32_t MaxMisorder = 1000;
 
                static constexpr uint32_t SeqMod = 1u << 16;
 
                struct ObserveResult {
                                bool probation = false;
 
                                bool duplicate = false;
 
                                bool ssrcInit = false;
 
                                uint32_t extendedSeq = 0;
 
                                uint32_t jitterRtpTsUnits = 0;
                };
 
                struct Stats {
                                uint32_t extendedHighestSeq = 0;
 
                                uint32_t cycles = 0;
 
                                int32_t cumulativeLost = 0;
 
                                uint8_t fractionLost = 0;
 
                                uint32_t expectedPackets = 0;
 
                                uint32_t receivedPackets = 0;
 
                                uint32_t duplicatePackets = 0;
 
                                uint32_t reorderedPackets = 0;
 
                                uint32_t interarrivalJitter = 0;
                };
 
                RtpSeqTracker() = default;
 
                void initSource(uint16_t seq, uint32_t clockRateHz);
 
                ObserveResult observe(uint16_t seq, uint32_t rtpTs, const TimeStamp &arrivalSteady);
 
                Stats snapshot() const;
 
                void commitRrInterval();
 
                void reset();
 
                uint32_t clockRateHz() const;
 
                void setClockRateHz(uint32_t rate);
 
        private:
                void initSourceLocked(uint16_t seq);
                void updateJitterLocked(uint32_t rtpTs, const TimeStamp &arrivalSteady);
 
                mutable Mutex _mutex;
                bool          _initialised = false;
                unsigned int  _probation = MinSequential;
                uint16_t      _baseSeq = 0;
                uint16_t      _maxSeq = 0;
                uint32_t      _badSeq = SeqMod + 1;
                uint32_t      _cycles = 0;
                uint32_t      _received = 0;
                uint32_t      _expectedPrior = 0;
                uint32_t      _receivedPrior = 0;
                uint32_t      _duplicates = 0;
                uint32_t      _reordered = 0;
                uint8_t       _fractionLost = 0;
                uint32_t      _clockRateHz = 0;
                uint32_t      _jitter = 0;
                bool          _haveJitterPrev = false;
                uint32_t      _prevTransit = 0;
};
 
PROMEKI_NAMESPACE_END
 
#endif // PROMEKI_ENABLE_NETWORK