rtpancdepacketizerthread.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/ancdesc.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/rtpstreamclock.h>
#include <promeki/rxpayloadbundle.h>
#include <promeki/string.h>
#include <promeki/timestamp.h>
 
PROMEKI_NAMESPACE_BEGIN
 
class RtpPayloadAnc;
 
struct RtpAncDepacketizerContext {
                Queue<RxAncFrame> *payloadQueue = nullptr;
 
                const Atomic<uint32_t> *resetEpoch = nullptr;
 
                const bool *active = nullptr;
 
                RtpPayloadAnc *payload = nullptr;
 
                AncDesc desc;
 
                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 RtpAncDepacketizerThread : public RtpDepacketizerThread {
        public:
                RtpAncDepacketizerThread(RtpAncDepacketizerContext ctx,
                                         const String              &name,
                                         uint32_t                   clockRateHz);
 
                ~RtpAncDepacketizerThread() override;
 
                RtpAncDepacketizerThread(const RtpAncDepacketizerThread &) = delete;
                RtpAncDepacketizerThread &operator=(const RtpAncDepacketizerThread &) = delete;
 
                void handlePacketForTest(const RtpPacket &pkt) { handlePacket(pkt); }
 
                void flushForTest() { emitFrame(); }
 
        protected:
                void handlePacket(const RtpPacket &pkt) override;
                void onStop() override;
 
        private:
                void emitFrame();
 
                RtpAncDepacketizerContext _ctx;
                RtpPacket::List           _reasmPackets;
                uint32_t                  _reasmTimestamp = 0;
                bool                      _reasmHasTimestamp = false;
                uint32_t                  _lastEpoch = 0;
};
 
PROMEKI_NAMESPACE_END
 
#endif // PROMEKI_ENABLE_NETWORK