rtpaudiodepacketizerthread.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/audiodesc.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
 
struct RtpAudioDepacketizerContext {
                Queue<RxAudioChunk> *payloadQueue = nullptr;
 
                const Atomic<uint32_t> *resetEpoch = nullptr;
 
                const bool *active = nullptr;
 
                const AudioDesc *readerAudioDesc = nullptr;
 
                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;
 
                Function<void()> noteFrameReceived;
 
                Function<void()> refreshStreamClock;
 
                Function<TimeStamp(const NtpTime &)> ntpToSteady;
};
 
class RtpAudioDepacketizerThread : public RtpDepacketizerThread {
        public:
                RtpAudioDepacketizerThread(RtpAudioDepacketizerContext ctx,
                                           const String &name,
                                           uint32_t clockRateHz);
 
                ~RtpAudioDepacketizerThread() override;
 
                RtpAudioDepacketizerThread(const RtpAudioDepacketizerThread &) = delete;
                RtpAudioDepacketizerThread &operator=(const RtpAudioDepacketizerThread &) = delete;
 
                void handlePacketForTest(const RtpPacket &pkt) { handlePacket(pkt); }
 
        protected:
                void handlePacket(const RtpPacket &pkt) override;
 
        private:
                RtpAudioDepacketizerContext _ctx;
                uint32_t                    _lastEpoch = 0;
};
 
PROMEKI_NAMESPACE_END
 
#endif // PROMEKI_ENABLE_NETWORK