rtppacketizerthread.h

Go to the documentation of this file.

 
#pragma once
 
 
#include <promeki/config.h>
#if PROMEKI_ENABLE_NETWORK
#include <promeki/atomic.h>
#include <promeki/error.h>
#include <promeki/frame.h>
#include <promeki/framenumber.h>
#include <promeki/namespace.h>
#include <promeki/queue.h>
#include <promeki/string.h>
#include <promeki/thread.h>
 
PROMEKI_NAMESPACE_BEGIN
 
struct RtpFrameWork {
                Frame       frame;
                FrameNumber frameIndex;
};
 
class RtpPacketizerThread : public Thread {
        public:
                static constexpr size_t DefaultPayloadQueueDepth = 2;
 
                RtpPacketizerThread(const String &name,
                                    size_t        depth = DefaultPayloadQueueDepth);
 
                ~RtpPacketizerThread() override;
 
                RtpPacketizerThread(const RtpPacketizerThread &) = delete;
                RtpPacketizerThread &operator=(const RtpPacketizerThread &) = delete;
 
                Error pushWork(const RtpFrameWork &work, unsigned int timeoutMs = 0);
 
                void requestStop();
 
                bool isStopRequested() const { return _stopRequested.value(); }
 
                Queue<RtpFrameWork> &payloadQueue() { return _payloadQueue; }
 
                const Queue<RtpFrameWork> &payloadQueue() const { return _payloadQueue; }
 
        protected:
                virtual void packetize(const RtpFrameWork &work) = 0;
 
                virtual void onStart() {}
 
                virtual void onStop() {}
 
                void run() override;
 
        private:
                Atomic<bool>        _stopRequested;
                Queue<RtpFrameWork> _payloadQueue;
};
 
PROMEKI_NAMESPACE_END
 
#endif // PROMEKI_ENABLE_NETWORK