rtpaudiosinknode.h

Go to the documentation of this file.

 
#pragma once
 
#include <promeki/core/namespace.h>
#include <promeki/core/variant.h>
#include <promeki/core/map.h>
#include <promeki/core/buffer.h>
#include <promeki/proav/medianode.h>
#include <promeki/proav/audiodesc.h>
 
#ifdef PROMEKI_HAVE_NETWORK
#include <promeki/network/socketaddress.h>
#include <promeki/network/rtpsession.h>
#include <promeki/network/rtppayload.h>
#endif
 
PROMEKI_NAMESPACE_BEGIN
 
class RtpAudioSinkNode : public MediaNode {
        PROMEKI_OBJECT(RtpAudioSinkNode, MediaNode)
        public:
                RtpAudioSinkNode(ObjectBase *parent = nullptr);
 
                ~RtpAudioSinkNode() override;
 
#ifdef PROMEKI_HAVE_NETWORK
                void setDestination(const SocketAddress &addr) { _destination = addr; return; }
 
                const SocketAddress &destination() const { return _destination; }
 
                void setRtpPayload(RtpPayload *handler) { _payload = handler; return; }
 
                RtpPayload *rtpPayload() const { return _payload; }
#endif
 
                void setPayloadType(uint8_t pt) { _payloadType = pt; return; }
 
                uint8_t payloadType() const { return _payloadType; }
 
                void setClockRate(uint32_t hz) { _clockRate = hz; return; }
 
                uint32_t clockRate() const { return _clockRate; }
 
                void setPacketTime(double ptime) { _packetTime = ptime; return; }
 
                double packetTime() const { return _packetTime; }
 
                void setOutputFormat(AudioDesc::DataType fmt) { _outputFormat = fmt; return; }
 
                AudioDesc::DataType outputFormat() const { return _outputFormat; }
 
                void setDscp(uint8_t dscp) { _dscp = dscp; return; }
 
                uint8_t dscp() const { return _dscp; }
 
                // ---- Lifecycle overrides ----
 
                Error configure() override;
 
                Error start() override;
 
                void stop() override;
 
                void process() override;
 
                void starvation() override;
 
                Map<String, Variant> extendedStats() const override;
 
        private:
                void sendAccumulatedPackets();
                void flushRemaining();
 
                uint8_t         _payloadType = 97;
                uint32_t        _clockRate = 48000;
                double          _packetTime = 1.0;
                uint8_t         _dscp = 46;
                AudioDesc::DataType _outputFormat = AudioDesc::Invalid;
                uint32_t        _rtpTimestamp = 0;
                size_t          _samplesPerPacket = 0;
                size_t          _bytesPerSampleFrame = 0;
                size_t          _packetBytes = 0;
                uint64_t        _packetsSent = 0;
                uint64_t        _samplesSent = 0;
                uint64_t        _underrunCount = 0;
 
                Buffer::Ptr     _accumBuffer;
                size_t          _accumOffset = 0;
 
#ifdef PROMEKI_HAVE_NETWORK
                SocketAddress   _destination;
                RtpPayload      *_payload = nullptr;
                RtpSession      *_session = nullptr;
#endif
};
 
PROMEKI_NAMESPACE_END