rtpancpacketizerthread.h

Go to the documentation of this file.

 
#pragma once
 
 
#include <promeki/config.h>
#if PROMEKI_ENABLE_NETWORK
#include <cstddef>
#include <cstdint>
#include <promeki/ancpacket.h>
#include <promeki/namespace.h>
#include <promeki/queue.h>
#include <promeki/rtppacketbatch.h>
#include <promeki/rtppacketizerthread.h>
#include <promeki/rtppayloadanc.h>
#include <promeki/string.h>
 
PROMEKI_NAMESPACE_BEGIN
 
class RtpPayloadAnc;
 
struct RtpAncPacketizerContext {
                size_t streamIdx = 0;
 
                uint32_t clockRateHz = 90000;
 
                RtpPayloadAnc *payload = nullptr;
 
                Queue<RtpPacketBatch> *txPacketQueue = nullptr;
 
                RtpPayloadAnc::FieldIndication keepAliveField =
                        RtpPayloadAnc::FieldIndication::Progressive;
};
 
class RtpAncPacketizerThread : public RtpPacketizerThread {
        public:
                RtpAncPacketizerThread(
                        RtpAncPacketizerContext ctx,
                        const String           &name = String("RtpAncPkt"),
                        size_t                  depth = DefaultPayloadQueueDepth);
 
                ~RtpAncPacketizerThread() override;
 
                RtpAncPacketizerThread(const RtpAncPacketizerThread &) = delete;
                RtpAncPacketizerThread &operator=(const RtpAncPacketizerThread &) = delete;
 
                void packetizeForTest(const RtpFrameWork &work) { packetize(work); }
 
                const RtpAncPacketizerContext &context() const { return _ctx; }
 
        protected:
                void packetize(const RtpFrameWork &work) override;
 
        private:
                RtpAncPacketizerContext _ctx;
};
 
PROMEKI_NAMESPACE_END
 
#endif // PROMEKI_ENABLE_NETWORK