rtpaudiotxthread.h

Go to the documentation of this file.

 
#pragma once
 
 
#include <promeki/config.h>
#if PROMEKI_ENABLE_NETWORK
#include <cstddef>
#include <cstdint>
#include <promeki/atomic.h>
#include <promeki/audiodesc.h>
#include <promeki/buffer.h>
#include <promeki/cadence.h>
#include <promeki/namespace.h>
#include <promeki/pcmsilencefiller.h>
#include <promeki/queue.h>
#include <promeki/rtppayload.h>
#include <promeki/rtpsession.h>
#include <promeki/rtptxthread.h>
#include <promeki/string.h>
 
PROMEKI_NAMESPACE_BEGIN
 
struct RtpAudioTxContext {
                AudioDesc storageDesc;
 
                size_t packetSamples = 0;
 
                size_t packetBytes = 0;
 
                int packetTimeUs = 0;
 
                RtpSession *session = nullptr;
 
                RtpPayload *payload = nullptr;
 
                uint32_t clockRate = 0;
 
                Atomic<int64_t> *packetsSent = nullptr;
 
                Atomic<int64_t> *bytesSent = nullptr;
 
                Atomic<int64_t> *senderOctets = nullptr;
 
                Atomic<int64_t> *silencePacketsEmitted = nullptr;
 
                Atomic<int64_t> *silenceSamplesEmitted = nullptr;
 
                uint32_t initialRtpTs = 0;
};
 
class RtpAudioTxThread : public RtpTxThread {
        public:
                static constexpr int64_t HeadroomUs = 1'000'000;
 
                static constexpr size_t MinDepth = 8;
 
                static constexpr int64_t StallReanchorMultiplier = 16;
 
                explicit RtpAudioTxThread(RtpAudioTxContext ctx,
                                          const String       &name = String("RtpAudTx"));
 
                ~RtpAudioTxThread() override;
 
                RtpAudioTxThread(const RtpAudioTxThread &) = delete;
                RtpAudioTxThread &operator=(const RtpAudioTxThread &) = delete;
 
                Queue<Buffer> &packetQueue() { return _packetQueue; }
 
                const Queue<Buffer> &packetQueue() const { return _packetQueue; }
 
                uint32_t rtpTsCursor() const { return _rtpTs; }
 
                bool runOnceForTest();
 
        protected:
                void onShutdown() override { _packetQueue.cancelWaiters(); }
                void run() override;
 
        private:
                bool emitOne(const Buffer &silenceBuf);
 
                Buffer silenceBuffer();
 
                RtpAudioTxContext _ctx;
                Queue<Buffer>     _packetQueue;
                uint32_t          _rtpTs = 0;
                Buffer            _silenceBuf;
                bool              _silenceBuilt = false;
};
 
PROMEKI_NAMESPACE_END
 
#endif // PROMEKI_ENABLE_NETWORK