rtpaudiopacketizerthread.h

Go to the documentation of this file.

 
#pragma once
 
 
#include <promeki/config.h>
#if PROMEKI_ENABLE_NETWORK
#include <cstddef>
#include <cstdint>
#include <promeki/audiobuffer.h>
#include <promeki/audiodesc.h>
#include <promeki/buffer.h>
#include <promeki/list.h>
#include <promeki/namespace.h>
#include <promeki/queue.h>
#include <promeki/rtppacketizerthread.h>
#include <promeki/string.h>
 
PROMEKI_NAMESPACE_BEGIN
 
struct RtpAudioPacketizerContext {
                AudioDesc storageDesc;
 
                size_t packetSamples = 0;
 
                size_t packetBytes = 0;
 
                size_t prerollSamples = 0;
 
                size_t streamIdx = 0;
 
                Queue<Buffer> *txPacketQueue = nullptr;
};
 
class RtpAudioPacketizerThread : public RtpPacketizerThread {
        public:
                RtpAudioPacketizerThread(
                        RtpAudioPacketizerContext ctx,
                        const String              &name = String("RtpAudPkt"),
                        size_t                     depth = DefaultPayloadQueueDepth);
 
                ~RtpAudioPacketizerThread() override;
 
                RtpAudioPacketizerThread(const RtpAudioPacketizerThread &) = delete;
                RtpAudioPacketizerThread &operator=(const RtpAudioPacketizerThread &) = delete;
 
                void packetizeForTest(const RtpFrameWork &work) { packetize(work); }
 
                void openForTest() { onStart(); }
 
                const AudioBuffer &fifo() const { return _fifo; }
 
                bool isPrerollDone() const { return _prerollDone; }
 
        protected:
                void onStart() override;
                void packetize(const RtpFrameWork &work) override;
 
        private:
                RtpAudioPacketizerContext _ctx;
                AudioBuffer               _fifo;
                List<uint8_t>             _drained;
                bool                      _prerollDone = false;
};
 
PROMEKI_NAMESPACE_END
 
#endif // PROMEKI_ENABLE_NETWORK