rtpsession.h

Go to the documentation of this file.

 
#pragma once
 
#include <cstdint>
#include <promeki/core/objectbase.h>
#include <promeki/core/error.h>
#include <promeki/core/buffer.h>
#include <promeki/network/socketaddress.h>
#include <promeki/network/rtppacket.h>
 
PROMEKI_NAMESPACE_BEGIN
 
class UdpSocket;
 
class RtpSession : public ObjectBase {
        PROMEKI_OBJECT(RtpSession, ObjectBase)
        public:
                RtpSession(ObjectBase *parent = nullptr);
 
                ~RtpSession() override;
 
                Error start(const SocketAddress &localAddr);
 
                void stop();
 
                bool isRunning() const { return _running; }
 
                Error sendPacket(const Buffer &payload, uint32_t timestamp,
                                 uint8_t payloadType, const SocketAddress &dest,
                                 bool marker = false);
 
                Error sendPackets(RtpPacket::List &packets, uint32_t timestamp,
                                  const SocketAddress &dest, bool markerOnLast = true);
 
                uint32_t ssrc() const { return _ssrc; }
 
                void setSsrc(uint32_t ssrc) { _ssrc = ssrc; }
 
                uint16_t sequenceNumber() const { return _sequenceNumber; }
 
                void setPayloadType(uint8_t pt) { _payloadType = pt; }
 
                uint8_t payloadType() const { return _payloadType; }
 
                void setClockRate(uint32_t hz) { _clockRate = hz; }
 
                uint32_t clockRate() const { return _clockRate; }
 
                UdpSocket *socket() const { return _socket; }
 
                PROMEKI_SIGNAL(packetReceived, Buffer, uint32_t, uint8_t, bool);
 
                PROMEKI_SIGNAL(ssrcCollision, uint32_t);
 
        private:
                void fillHeader(RtpPacket &pkt, uint8_t pt, bool marker,
                                uint32_t timestamp);
                void generateSsrc();
 
                UdpSocket      *_socket = nullptr;
                bool            _running = false;
                uint32_t        _ssrc = 0;
                uint16_t        _sequenceNumber = 0;
                uint8_t         _payloadType = 96;
                uint32_t        _clockRate = 90000;
};
 
PROMEKI_NAMESPACE_END