rtpvideosinknode.h

Go to the documentation of this file.

 
#pragma once
 
#include <chrono>
#include <promeki/core/string.h>
#include <promeki/core/namespace.h>
#include <promeki/core/variant.h>
#include <promeki/core/map.h>
#include <promeki/core/framerate.h>
#include <promeki/proav/medianode.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 RtpVideoSinkNode : public MediaNode {
        PROMEKI_OBJECT(RtpVideoSinkNode, MediaNode)
        public:
                RtpVideoSinkNode(ObjectBase *parent = nullptr);
 
                ~RtpVideoSinkNode() override;
 
#ifdef PROMEKI_HAVE_NETWORK
                void setDestination(const SocketAddress &addr) { _destination = addr; return; }
 
                const SocketAddress &destination() const { return _destination; }
 
                void setMulticast(const SocketAddress &group) { _multicast = group; return; }
 
                const SocketAddress &multicast() const { return _multicast; }
#endif
 
                void setFrameRate(const FrameRate &fps) { _frameRate = fps; return; }
 
                const FrameRate &frameRate() const { return _frameRate; }
 
#ifdef PROMEKI_HAVE_NETWORK
                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 setDumpPath(const String &path) { _dumpPath = path; return; }
 
                const String &dumpPath() const { return _dumpPath; }
 
                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:
                FrameRate       _frameRate;
                uint8_t         _payloadType = 96;
                uint32_t        _clockRate = 90000;
                uint8_t         _dscp = 34;
                uint32_t        _rtpTimestamp = 0;
                uint32_t        _timestampIncrement = 0;
                uint64_t        _packetsSent = 0;
                uint64_t        _bytesSent = 0;
                uint64_t        _underrunCount = 0;
 
                std::chrono::nanoseconds                        _frameInterval{0};
                std::chrono::steady_clock::time_point           _nextFrameTime;
                bool                                            _firstFrame = true;
                String                                          _dumpPath;
 
#ifdef PROMEKI_HAVE_NETWORK
                SocketAddress   _destination;
                SocketAddress   _multicast;
                RtpPayload      *_payload = nullptr;
                RtpSession      *_session = nullptr;
#endif
};
 
PROMEKI_NAMESPACE_END