rtpdatadepacketizerthread.h

Go to the documentation of this file.

 
#pragma once
 
 
#include <promeki/config.h>
#if PROMEKI_ENABLE_NETWORK
#include <cstdint>
#include <functional>
#include <promeki/function.h>
#include <promeki/atomic.h>
#include <promeki/clockdomain.h>
#include <promeki/namespace.h>
#include <promeki/queue.h>
#include <promeki/rtpdepacketizerthread.h>
#include <promeki/rtppacket.h>
#include <promeki/rtppayload.h>
#include <promeki/rtpstreamclock.h>
#include <promeki/rxpayloadbundle.h>
#include <promeki/string.h>
#include <promeki/timestamp.h>
 
PROMEKI_NAMESPACE_BEGIN
 
struct RtpDataDepacketizerContext {
                Queue<RxDataMessage> *payloadQueue = nullptr;
 
                const Atomic<uint32_t> *resetEpoch = nullptr;
 
                const bool *active = nullptr;
 
                RtpPayload *payload = nullptr;
 
                ClockDomain clockDomain;
 
                const bool *hasSr = nullptr;
 
                const RtpStreamClock *streamClock = nullptr;
 
                Atomic<int64_t> *packetsReceived = nullptr;
                Atomic<int64_t> *bytesReceived = nullptr;
                Atomic<int64_t> *lastPacketArrivalNs = nullptr;
                Atomic<int64_t> *framesReassembled = nullptr;
                Atomic<int64_t> *framesDroppedSsrcReset = nullptr;
 
                Function<void()> noteFrameReceived;
 
                Function<void()> refreshStreamClock;
 
                Function<TimeStamp(const NtpTime &)> ntpToSteady;
};
 
class RtpDataDepacketizerThread : public RtpDepacketizerThread {
        public:
                RtpDataDepacketizerThread(RtpDataDepacketizerContext ctx,
                                          const String &name,
                                          uint32_t clockRateHz,
                                          size_t queueDepth = DefaultInputQueueDepth);
 
                ~RtpDataDepacketizerThread() override;
 
                RtpDataDepacketizerThread(const RtpDataDepacketizerThread &) = delete;
                RtpDataDepacketizerThread &operator=(const RtpDataDepacketizerThread &) = delete;
 
                void handlePacketForTest(const RtpPacket &pkt) { handlePacket(pkt); }
 
                void flushForTest() { emitMessage(); }
 
        protected:
                void handlePacket(const RtpPacket &pkt) override;
                void onStop() override;
 
        private:
                void emitMessage();
 
                RtpDataDepacketizerContext _ctx;
                RtpPacket::List            _reasmPackets;
                uint32_t                   _reasmTimestamp = 0;
                bool                       _reasmHasTimestamp = false;
                uint32_t                   _lastEpoch = 0;
};
 
PROMEKI_NAMESPACE_END
 
#endif // PROMEKI_ENABLE_NETWORK