qrtplib::RTPUDPTransmitter Class Reference

#include <rtpudptransmitter.h>

Inheritance diagram for qrtplib::RTPUDPTransmitter:

Collaboration diagram for qrtplib::RTPUDPTransmitter:

Signals
void	NewDataAvailable ()

Public Member Functions
	RTPUDPTransmitter ()
virtual	~RTPUDPTransmitter ()
virtual int	Init ()
virtual int	Create (std::size_t maxpacksize, const RTPTransmissionParams *transparams)
virtual int	BindSockets ()
void	moveToThread (QThread *thread)
virtual void	Destroy ()
virtual RTPTransmissionInfo *	GetTransmissionInfo ()
virtual void	DeleteTransmissionInfo (RTPTransmissionInfo *inf)
virtual bool	ComesFromThisTransmitter (const RTPAddress &addr)
virtual std::size_t	GetHeaderOverhead ()
virtual int	SendRTPData (const void *data, std::size_t len)
virtual int	SendRTCPData (const void *data, std::size_t len)
virtual int	AddDestination (const RTPAddress &addr)
virtual int	DeleteDestination (const RTPAddress &addr)
virtual void	ClearDestinations ()
virtual bool	SupportsMulticasting ()
virtual int	JoinMulticastGroup (const RTPAddress &addr)
virtual int	LeaveMulticastGroup (const RTPAddress &addr)
virtual int	SetReceiveMode (RTPTransmitter::ReceiveMode m)
virtual int	AddToIgnoreList (const RTPAddress &addr)
virtual int	DeleteFromIgnoreList (const RTPAddress &addr)
virtual void	ClearIgnoreList ()
virtual int	AddToAcceptList (const RTPAddress &addr)
virtual int	DeleteFromAcceptList (const RTPAddress &addr)
virtual void	ClearAcceptList ()
virtual int	SetMaximumPacketSize (std::size_t s)
virtual RTPRawPacket *	GetNextPacket ()
Public Member Functions inherited from qrtplib::RTPTransmitter
virtual	~RTPTransmitter ()

Private Slots
void	readRTPPendingDatagrams ()
void	readRTCPPendingDatagrams ()

Private Member Functions
bool	ShouldAcceptData (const RTPAddress &address)

Private Attributes
bool	m_init
bool	m_created
bool	m_waitingfordata
QUdpSocket *	m_rtpsock
QUdpSocket *	m_rtcpsock
bool	m_deletesocketswhendone
QHostAddress	m_localIP
	from parameters bind IP More...
QNetworkInterface	m_multicastInterface
	from parameters multicast interface More...
uint16_t	m_rtpPort
uint16_t	m_rtcpPort
RTPTransmitter::ReceiveMode	m_receivemode
std::size_t	m_maxpacksize
char	m_rtpBuffer [m_absoluteMaxPackSize]
char	m_rtcpBuffer [m_absoluteMaxPackSize]
std::list< RTPAddress >	m_destinations
std::list< RTPAddress >	m_acceptList
std::list< RTPAddress >	m_ignoreList
QQueue< RTPRawPacket * >	m_rawPacketQueue
QMutex	m_rawPacketQueueLock

Static Private Attributes
static const std::size_t	m_absoluteMaxPackSize = 65535

Additional Inherited Members
Public Types inherited from qrtplib::RTPTransmitter
enum	TransmissionProtocol {   IPv4UDPProto, IPv6UDPProto, TCPProto, ExternalProto,   UserDefinedProto }
enum	ReceiveMode { AcceptAll, AcceptSome, IgnoreSome }
Protected Member Functions inherited from qrtplib::RTPTransmitter
	RTPTransmitter ()

Detailed Description

An UDP transmission component. This class inherits the RTPTransmitter interface and implements a transmission component which uses UDP to send and receive RTP and RTCP data. The component's parameters are described by the class RTPUDPTransmissionParams. The GetTransmissionInfo member function returns an instance of type RTPUDPTransmissionInfo.

Definition at line 301 of file rtpudptransmitter.h.

Constructor & Destructor Documentation

RTPUDPTransmitter()

qrtplib::RTPUDPTransmitter::RTPUDPTransmitter

(

)

Definition at line 44 of file rtpudptransmitter.cpp.

References qrtplib::RTPTransmitter::AcceptAll, m_absoluteMaxPackSize, m_created, m_deletesocketswhendone, m_init, m_maxpacksize, m_receivemode, m_rtcpBuffer, m_rtcpPort, m_rtcpsock, m_rtpBuffer, m_rtpPort, m_rtpsock, and m_waitingfordata.

                                     :
    m_rawPacketQueueLock(QMutex::Recursive)
{
    m_created = false;
    m_init = false;
    m_rtcpsock = 0;
    m_rtpsock = 0;
    m_deletesocketswhendone = false;
    m_waitingfordata = false;
    m_rtcpPort = 0;
    m_rtpPort = 0;
    m_receivemode = RTPTransmitter::AcceptAll;
    m_maxpacksize = 0;
    memset(m_rtpBuffer, 0, m_absoluteMaxPackSize);
    memset(m_rtcpBuffer, 0, m_absoluteMaxPackSize);
}

~RTPUDPTransmitter()

qrtplib::RTPUDPTransmitter::~RTPUDPTransmitter ( )

virtual

Definition at line 61 of file rtpudptransmitter.cpp.

References Destroy().

{
    Destroy();
}

Here is the call graph for this function:

Member Function Documentation

AddDestination()

int qrtplib::RTPUDPTransmitter::AddDestination ( const RTPAddress &  addr )

virtual

Adds the address specified by addr to the list of destinations.

Implements qrtplib::RTPTransmitter.

Definition at line 291 of file rtpudptransmitter.cpp.

References m_destinations.

{
    m_destinations.push_back(addr);
    return 0;
}

AddToAcceptList()

int qrtplib::RTPUDPTransmitter::AddToAcceptList ( const RTPAddress &  addr )

virtual

Adds addr to the list of addresses to accept.

Implements qrtplib::RTPTransmitter.

Definition at line 410 of file rtpudptransmitter.cpp.

References m_acceptList.

{
    m_acceptList.push_back(addr);
    return 0;
}

AddToIgnoreList()

int qrtplib::RTPUDPTransmitter::AddToIgnoreList ( const RTPAddress &  addr )

virtual

Adds addr to the list of addresses to ignore.

Implements qrtplib::RTPTransmitter.

Definition at line 393 of file rtpudptransmitter.cpp.

References m_ignoreList.

{
    m_ignoreList.push_back(addr);
    return 0;
}

BindSockets()

int qrtplib::RTPUDPTransmitter::BindSockets ( )

virtual

Bind the RTP and RTCP sockets to ports that were set at creation time

Implements qrtplib::RTPTransmitter.

Definition at line 170 of file rtpudptransmitter.cpp.

References ERR_RTP_UDPV4TRANS_CANTBINDRTCPSOCKET, ERR_RTP_UDPV4TRANS_CANTBINDRTPSOCKET, m_localIP, m_rtcpPort, m_rtcpsock, m_rtpPort, m_rtpsock, readRTCPPendingDatagrams(), and readRTPPendingDatagrams().

{
    if (!m_rtpsock->bind(m_localIP, m_rtpPort)) {
        return ERR_RTP_UDPV4TRANS_CANTBINDRTPSOCKET;
    }

    connect(m_rtpsock, SIGNAL(readyRead()), this, SLOT(readRTPPendingDatagrams()));

    if (m_rtpsock != m_rtcpsock)
    {
        if (!m_rtcpsock->bind(m_localIP, m_rtcpPort)) {
            return ERR_RTP_UDPV4TRANS_CANTBINDRTCPSOCKET;
        }

        connect(m_rtcpsock, SIGNAL(readyRead()), this, SLOT(readRTCPPendingDatagrams()));
    }

    return 0;
}

Here is the call graph for this function:

ClearAcceptList()

void qrtplib::RTPUDPTransmitter::ClearAcceptList ( )

virtual

Clears the list of addresses to accept.

Implements qrtplib::RTPTransmitter.

Definition at line 422 of file rtpudptransmitter.cpp.

References m_acceptList.

{
    m_acceptList.clear();
}

ClearDestinations()

void qrtplib::RTPUDPTransmitter::ClearDestinations ( )

virtual

Clears the list of destinations.

Implements qrtplib::RTPTransmitter.

Definition at line 303 of file rtpudptransmitter.cpp.

References m_destinations.

{
    m_destinations.clear();
}

ClearIgnoreList()

void qrtplib::RTPUDPTransmitter::ClearIgnoreList ( )

virtual

Clears the list of addresses to ignore.

Implements qrtplib::RTPTransmitter.

Definition at line 405 of file rtpudptransmitter.cpp.

References m_ignoreList.

{
    m_ignoreList.clear();
}

ComesFromThisTransmitter()

bool qrtplib::RTPUDPTransmitter::ComesFromThisTransmitter ( const RTPAddress &  addr )

virtual

Returns true if the address specified by addr is one of the addresses of the transmitter.

Implements qrtplib::RTPTransmitter.

Definition at line 233 of file rtpudptransmitter.cpp.

References qrtplib::RTPAddress::getAddress(), qrtplib::RTPAddress::getPort(), qrtplib::RTPAddress::getRtcpsendport(), m_localIP, m_rtcpPort, and m_rtpPort.

{
    if (addr.getAddress() != m_localIP) {
        return false;
    }

    return (addr.getPort() == m_rtpPort) && (addr.getRtcpsendport() == m_rtcpPort);
}

Here is the call graph for this function:

Create()

int qrtplib::RTPUDPTransmitter::Create ( std::size_t  maxpacksize, const RTPTransmissionParams *  transparams  )

virtual

Prepares the component to be used. Prepares the component to be used. The parameter maxpacksize specifies the maximum size a packet can have: if the packet is larger it will not be transmitted. The transparams parameter specifies a pointer to an RTPTransmissionParams instance. This is also an abstract class and each actual component will define its own parameters by inheriting a class from RTPTransmissionParams. If transparams is NULL, the default transmission parameters for the component will be used.

Implements qrtplib::RTPTransmitter.

Definition at line 76 of file rtpudptransmitter.cpp.

References qrtplib::RTPTransmitter::AcceptAll, ERR_RTP_UDPV4TRANS_ALREADYCREATED, ERR_RTP_UDPV4TRANS_ILLEGALPARAMETERS, ERR_RTP_UDPV4TRANS_NOTINIT, ERR_RTP_UDPV4TRANS_PORTBASENOTEVEN, ERR_RTP_UDPV4TRANS_SPECIFIEDSIZETOOBIG, qrtplib::RTPUDPTransmissionParams::GetAllowOddPortbase(), qrtplib::RTPUDPTransmissionParams::GetBindIP(), qrtplib::RTPUDPTransmissionParams::GetForcedRTCPPort(), qrtplib::RTPUDPTransmissionParams::GetMulticastInterface(), qrtplib::RTPUDPTransmissionParams::GetPortbase(), qrtplib::RTPUDPTransmissionParams::GetRTCPMultiplexing(), qrtplib::RTPUDPTransmissionParams::GetRTCPReceiveBufferSize(), qrtplib::RTPUDPTransmissionParams::GetRTPReceiveBufferSize(), qrtplib::RTPTransmissionParams::GetTransmissionProtocol(), qrtplib::RTPUDPTransmissionParams::GetUseExistingSockets(), qrtplib::RTPTransmitter::IPv4UDPProto, m_absoluteMaxPackSize, m_created, m_deletesocketswhendone, m_init, m_localIP, m_maxpacksize, m_multicastInterface, m_receivemode, m_rtcpPort, m_rtcpsock, m_rtpPort, m_rtpsock, and m_waitingfordata.

Referenced by RTPSink::RTPSink().

{
    const RTPUDPTransmissionParams *params, defaultparams;
    qint64 size;

    if (maximumpacketsize > m_absoluteMaxPackSize) {
        return ERR_RTP_UDPV4TRANS_SPECIFIEDSIZETOOBIG;
    }

    if (!m_init) {
        return ERR_RTP_UDPV4TRANS_NOTINIT;
    }

    if (m_created) {
        return ERR_RTP_UDPV4TRANS_ALREADYCREATED;
    }

    // Obtain transmission parameters

    if (transparams == 0) {
        params = &defaultparams;
    }
    else
    {
        if (transparams->GetTransmissionProtocol() != RTPTransmitter::IPv4UDPProto)
        {
            return ERR_RTP_UDPV4TRANS_ILLEGALPARAMETERS;
        }
        params = (const RTPUDPTransmissionParams *) transparams;
    }

    // Determine the port numbers

    m_localIP = params->GetBindIP();

    if (params->GetAllowOddPortbase())
    {
        m_rtpPort = params->GetPortbase();
        m_rtcpPort = params->GetForcedRTCPPort();
    }
    else
    {
        if (params->GetPortbase() % 2 == 0)
        {
            m_rtpPort = params->GetPortbase();
            m_rtcpPort = m_rtpPort + 1;
        }
        else
        {
            return ERR_RTP_UDPV4TRANS_PORTBASENOTEVEN;
        }
    }

    if (params->GetUseExistingSockets(&m_rtpsock, &m_rtcpsock))
    {
        m_deletesocketswhendone = false;
    }
    else
    {
        m_deletesocketswhendone = true;

        m_rtpsock = new QUdpSocket();

        // If we're multiplexing, we're just going to set the RTCP socket to equal the RTP socket
        if (params->GetRTCPMultiplexing())
        {
            m_rtcpsock = m_rtpsock;
            m_rtcpPort = m_rtpPort;
        } else {
            m_rtcpsock = new QUdpSocket();
        }
    }

    // set socket buffer sizes

    size = params->GetRTPReceiveBufferSize();
    m_rtpsock->setReadBufferSize(size);

    if (m_rtpsock != m_rtcpsock)
    {
        size = params->GetRTCPReceiveBufferSize();
        m_rtcpsock->setReadBufferSize(size);
    }

    m_maxpacksize = maximumpacketsize;
    m_multicastInterface = params->GetMulticastInterface();
    m_receivemode = RTPTransmitter::AcceptAll;

    m_waitingfordata = false;
    m_created = true;

    return 0;
}

Here is the call graph for this function:

Here is the caller graph for this function:

DeleteDestination()

int qrtplib::RTPUDPTransmitter::DeleteDestination ( const RTPAddress &  addr )

virtual

Deletes the address specified by addr from the list of destinations.

Implements qrtplib::RTPTransmitter.

Definition at line 297 of file rtpudptransmitter.cpp.

References m_destinations.

{
    m_destinations.remove(addr);
    return 0;
}

DeleteFromAcceptList()

int qrtplib::RTPUDPTransmitter::DeleteFromAcceptList ( const RTPAddress &  addr )

virtual

Deletes addr from the list of addresses to accept.

Implements qrtplib::RTPTransmitter.

Definition at line 416 of file rtpudptransmitter.cpp.

References m_acceptList.

{
    m_acceptList.remove(addr);
    return 0;
}

DeleteFromIgnoreList()

int qrtplib::RTPUDPTransmitter::DeleteFromIgnoreList ( const RTPAddress &  addr )

virtual

Deletes addr from the list of addresses to accept.

Implements qrtplib::RTPTransmitter.

Definition at line 399 of file rtpudptransmitter.cpp.

References m_ignoreList.

{
    m_ignoreList.remove(addr);
    return 0;
}

DeleteTransmissionInfo()

void qrtplib::RTPUDPTransmitter::DeleteTransmissionInfo ( RTPTransmissionInfo *  inf )

virtual

Deallocates the information returned by RTPTransmitter::GetTransmissionInfo . Deallocates the information returned by RTPTransmitter::GetTransmissionInfo .

Implements qrtplib::RTPTransmitter.

Definition at line 224 of file rtpudptransmitter.cpp.

References m_init.

{
    if (!m_init) {
        return;
    }

    delete inf;
}

Destroy()

void qrtplib::RTPUDPTransmitter::Destroy ( )

virtual

By calling this function, buffers are cleared and the component cannot be used anymore. By calling this function, buffers are cleared and the component cannot be used anymore. Only when the Create function is called again can the component be used again.

Implements qrtplib::RTPTransmitter.

Definition at line 190 of file rtpudptransmitter.cpp.

References m_created, m_deletesocketswhendone, m_init, m_rtcpsock, and m_rtpsock.

Referenced by ~RTPUDPTransmitter().

{
    if (!m_init) {
        return;
    }

    if (!m_created)
    {
        return;
    }

    if (m_deletesocketswhendone)
    {
        if (m_rtpsock != m_rtcpsock) {
            delete m_rtcpsock;
        }

        delete m_rtpsock;
    }

    m_created = false;
}

Here is the caller graph for this function:

GetHeaderOverhead()

virtual std::size_t qrtplib::RTPUDPTransmitter::GetHeaderOverhead ( )

inlinevirtual

Returns the amount of bytes that will be added to the RTP packet by the underlying layers (excluding the link layer).

Implements qrtplib::RTPTransmitter.

Definition at line 317 of file rtpudptransmitter.h.

References RTPUDPTRANS_HEADERSIZE.

    {
        return RTPUDPTRANS_HEADERSIZE;
    }

GetNextPacket()

RTPRawPacket * qrtplib::RTPUDPTransmitter::GetNextPacket ( )

virtual

Returns the raw data of a received RTP packet in an RTPRawPacket instance.

Implements qrtplib::RTPTransmitter.

Definition at line 445 of file rtpudptransmitter.cpp.

References m_rawPacketQueue, and m_rawPacketQueueLock.

{
    QMutexLocker locker(&m_rawPacketQueueLock);

    if (m_rawPacketQueue.isEmpty()) {
        return 0;
    } else {
        return m_rawPacketQueue.takeFirst();
    }
}

GetTransmissionInfo()

RTPTransmissionInfo * qrtplib::RTPUDPTransmitter::GetTransmissionInfo ( )

virtual

Returns additional information about the transmitter. This function returns an instance of a subclass of RTPTransmissionInfo which will give some additional information about the transmitter (a list of local IP addresses for example). Currently, either an instance of RTPUDPv4TransmissionInfo or RTPUDPv6TransmissionInfo is returned, depending on the type of the transmitter. The user has to deallocate the returned instance when it is no longer needed, which can be done using RTPTransmitter::DeleteTransmissionInfo.

Implements qrtplib::RTPTransmitter.

Definition at line 213 of file rtpudptransmitter.cpp.

References m_init, m_localIP, m_rtcpPort, m_rtcpsock, m_rtpPort, and m_rtpsock.

{
    if (!m_init) {
        return 0;
    }

    RTPTransmissionInfo *tinf = new RTPUDPTransmissionInfo(m_localIP, m_rtpsock, m_rtcpsock, m_rtpPort, m_rtcpPort);

    return tinf;
}

Init()

int qrtplib::RTPUDPTransmitter::Init ( )

virtual

This function must be called before the transmission component can be used.

Implements qrtplib::RTPTransmitter.

Definition at line 66 of file rtpudptransmitter.cpp.

References ERR_RTP_UDPV4TRANS_ALREADYINIT, and m_init.

Referenced by RTPSink::RTPSink().

{
    if (m_init) {
        return ERR_RTP_UDPV4TRANS_ALREADYINIT;
    }

    m_init = true;
    return 0;
}

Here is the caller graph for this function:

JoinMulticastGroup()

int qrtplib::RTPUDPTransmitter::JoinMulticastGroup ( const RTPAddress &  addr )

virtual

Joins the multicast group specified by addr.

Implements qrtplib::RTPTransmitter.

Definition at line 321 of file rtpudptransmitter.cpp.

References ERR_RTP_UDPV4TRANS_COULDNTJOINMULTICASTGROUP, ERR_RTP_UDPV4TRANS_NOTCREATED, ERR_RTP_UDPV4TRANS_NOTINIT, ERR_RTP_UDPV6TRANS_NOMULTICASTSUPPORT, qrtplib::RTPAddress::getAddress(), m_created, m_init, m_multicastInterface, m_rtcpsock, m_rtpsock, and SupportsMulticasting().

{
    if (!m_init) {
        return ERR_RTP_UDPV4TRANS_NOTINIT;
    }

    if (!m_created) {
        return ERR_RTP_UDPV4TRANS_NOTCREATED;
    }

    if (!SupportsMulticasting()) {
        return ERR_RTP_UDPV6TRANS_NOMULTICASTSUPPORT;
    }

    if (m_rtpsock->joinMulticastGroup(addr.getAddress(), m_multicastInterface))
    {
        if (m_rtpsock != m_rtcpsock)
        {
            if (!m_rtcpsock->joinMulticastGroup(addr.getAddress(), m_multicastInterface)) {
                return ERR_RTP_UDPV4TRANS_COULDNTJOINMULTICASTGROUP;
            }
        }
    }
    else
    {
        return ERR_RTP_UDPV4TRANS_COULDNTJOINMULTICASTGROUP;
    }

    return 0;
}

Here is the call graph for this function:

LeaveMulticastGroup()

int qrtplib::RTPUDPTransmitter::LeaveMulticastGroup ( const RTPAddress &  addr )

virtual

Leaves the multicast group specified by addr.

Implements qrtplib::RTPTransmitter.

Definition at line 352 of file rtpudptransmitter.cpp.

References ERR_RTP_UDPV4TRANS_NOTCREATED, ERR_RTP_UDPV4TRANS_NOTINIT, ERR_RTP_UDPV6TRANS_NOMULTICASTSUPPORT, qrtplib::RTPAddress::getAddress(), m_created, m_init, m_rtcpsock, m_rtpsock, and SupportsMulticasting().

{
    if (!m_init) {
        return ERR_RTP_UDPV4TRANS_NOTINIT;
    }

    if (!m_created) {
        return ERR_RTP_UDPV4TRANS_NOTCREATED;
    }

    if (!SupportsMulticasting()) {
        return ERR_RTP_UDPV6TRANS_NOMULTICASTSUPPORT;
    }

    m_rtpsock->leaveMulticastGroup(addr.getAddress());

    if (m_rtpsock != m_rtcpsock)
    {
        m_rtcpsock->leaveMulticastGroup(addr.getAddress());
    }

    return 0;
}

Here is the call graph for this function:

moveToThread()

void qrtplib::RTPUDPTransmitter::moveToThread

(

QThread *

thread

)

NewDataAvailable

void qrtplib::RTPUDPTransmitter::NewDataAvailable ( )

signal

Referenced by readRTCPPendingDatagrams(), and readRTPPendingDatagrams().

Here is the caller graph for this function:

readRTCPPendingDatagrams

void qrtplib::RTPUDPTransmitter::readRTCPPendingDatagrams ( )

privateslot

Definition at line 502 of file rtpudptransmitter.cpp.

References qrtplib::RTPTime::CurrentTime(), m_rawPacketQueue, m_rawPacketQueueLock, m_rtcpBuffer, m_rtcpsock, NewDataAvailable(), qrtplib::RTPAddress::setAddress(), qrtplib::RTPAddress::setPort(), and ShouldAcceptData().

Referenced by BindSockets().

{
    while (m_rtcpsock->hasPendingDatagrams())
    {
        RTPTime curtime = RTPTime::CurrentTime();
        QHostAddress remoteAddress;
        quint16 remotePort;
        qint64 pendingDataSize = m_rtcpsock->pendingDatagramSize();
        qint64 bytesRead = m_rtcpsock->readDatagram(m_rtcpBuffer, pendingDataSize, &remoteAddress, &remotePort);
        qDebug("RTPUDPTransmitter::readRTCPPendingDatagrams: %lld bytes read from %s:%d",
                bytesRead,
                qPrintable(remoteAddress.toString()),
                remotePort);

        RTPAddress rtpAddress;
        rtpAddress.setAddress(remoteAddress);
        rtpAddress.setPort(remotePort);

        if (ShouldAcceptData(rtpAddress))
        {
            RTPRawPacket *pack = new RTPRawPacket((uint8_t *) m_rtcpBuffer, bytesRead, rtpAddress, curtime, false);

            m_rawPacketQueueLock.lock();
            m_rawPacketQueue.append(pack);
            m_rawPacketQueueLock.unlock();

            emit NewDataAvailable();
        }
    }
}

Here is the call graph for this function:

Here is the caller graph for this function:

readRTPPendingDatagrams

void qrtplib::RTPUDPTransmitter::readRTPPendingDatagrams ( )

privateslot

Definition at line 456 of file rtpudptransmitter.cpp.

References qrtplib::RTPTime::CurrentTime(), m_rawPacketQueue, m_rawPacketQueueLock, m_rtcpsock, m_rtpBuffer, m_rtpsock, NewDataAvailable(), qrtplib::RTCPCommonHeader::packettype, qrtplib::RTPAddress::setAddress(), qrtplib::RTPAddress::setPort(), and ShouldAcceptData().

Referenced by BindSockets().

{
    while (m_rtpsock->hasPendingDatagrams())
    {
        RTPTime curtime = RTPTime::CurrentTime();
        QHostAddress remoteAddress;
        quint16 remotePort;
        qint64 pendingDataSize = m_rtpsock->pendingDatagramSize();
        qint64 bytesRead = m_rtpsock->readDatagram(m_rtpBuffer, pendingDataSize, &remoteAddress, &remotePort);
        qDebug("RTPUDPTransmitter::readRTPPendingDatagrams: %lld bytes read from %s:%d",
                bytesRead,
                qPrintable(remoteAddress.toString()),
                remotePort);

        RTPAddress rtpAddress;
        rtpAddress.setAddress(remoteAddress);
        rtpAddress.setPort(remotePort);

        if (ShouldAcceptData(rtpAddress))
        {
            bool isrtp = true;

            if (m_rtpsock == m_rtcpsock) // check payload type when multiplexing
            {
                if ((std::size_t) bytesRead > sizeof(RTCPCommonHeader))
                {
                    RTCPCommonHeader *rtcpheader = (RTCPCommonHeader *) m_rtpBuffer;
                    uint8_t packettype = rtcpheader->packettype;

                    if (packettype >= 200 && packettype <= 204) {
                        isrtp = false;
                    }
                }
            }

            RTPRawPacket *pack = new RTPRawPacket((uint8_t *) m_rtpBuffer, bytesRead, rtpAddress, curtime, isrtp);

            m_rawPacketQueueLock.lock();
            m_rawPacketQueue.append(pack);
            m_rawPacketQueueLock.unlock();

            emit NewDataAvailable();
        }
    }
}

Here is the call graph for this function:

Here is the caller graph for this function:

SendRTCPData()

int qrtplib::RTPUDPTransmitter::SendRTCPData ( const void *  data, std::size_t  len  )

virtual

Send a packet with length len containing data to all RTCP addresses of the current destination list.

Implements qrtplib::RTPTransmitter.

Definition at line 267 of file rtpudptransmitter.cpp.

References ERR_RTP_UDPV4TRANS_NOTCREATED, ERR_RTP_UDPV4TRANS_NOTINIT, ERR_RTP_UDPV4TRANS_SPECIFIEDSIZETOOBIG, m_created, m_destinations, m_init, m_maxpacksize, and m_rtcpsock.

{
    if (!m_init) {
        return ERR_RTP_UDPV4TRANS_NOTINIT;
    }

    if (!m_created) {
        return ERR_RTP_UDPV4TRANS_NOTCREATED;
    }

    if (len > m_maxpacksize) {
        return ERR_RTP_UDPV4TRANS_SPECIFIEDSIZETOOBIG;
    }

    std::list<RTPAddress>::const_iterator it = m_destinations.begin();

    for (; it != m_destinations.end(); ++it)
    {
        m_rtcpsock->writeDatagram((const char*) data, (qint64) len, it->getAddress(), it->getRtcpsendport());
    }

    return 0;
}

SendRTPData()

int qrtplib::RTPUDPTransmitter::SendRTPData ( const void *  data, std::size_t  len  )

virtual

Send a packet with length len containing data to all RTP addresses of the current destination list.

Implements qrtplib::RTPTransmitter.

Definition at line 242 of file rtpudptransmitter.cpp.

References ERR_RTP_UDPV4TRANS_NOTCREATED, ERR_RTP_UDPV4TRANS_NOTINIT, ERR_RTP_UDPV4TRANS_SPECIFIEDSIZETOOBIG, m_created, m_destinations, m_init, m_maxpacksize, and m_rtpsock.

{
    if (!m_init) {
        return ERR_RTP_UDPV4TRANS_NOTINIT;
    }

    if (!m_created) {
        return ERR_RTP_UDPV4TRANS_NOTCREATED;
    }

    if (len > m_maxpacksize)
    {
        return ERR_RTP_UDPV4TRANS_SPECIFIEDSIZETOOBIG;
    }

    std::list<RTPAddress>::const_iterator it = m_destinations.begin();

    for (; it != m_destinations.end(); ++it)
    {
        m_rtpsock->writeDatagram((const char*) data, (qint64) len, it->getAddress(), it->getPort());
    }

    return 0;
}

SetMaximumPacketSize()

int qrtplib::RTPUDPTransmitter::SetMaximumPacketSize ( std::size_t  s )

virtual

Sets the maximum packet size which the transmitter should allow to s.

Implements qrtplib::RTPTransmitter.

Definition at line 427 of file rtpudptransmitter.cpp.

References ERR_RTP_UDPV4TRANS_NOTCREATED, ERR_RTP_UDPV4TRANS_NOTINIT, ERR_RTP_UDPV4TRANS_SPECIFIEDSIZETOOBIG, m_absoluteMaxPackSize, m_created, m_init, and m_maxpacksize.

{
    if (!m_init) {
        return ERR_RTP_UDPV4TRANS_NOTINIT;
    }

    if (!m_created) {
        return ERR_RTP_UDPV4TRANS_NOTCREATED;
    }

    if (s > m_absoluteMaxPackSize) {
        return ERR_RTP_UDPV4TRANS_SPECIFIEDSIZETOOBIG;
    }

    m_maxpacksize = s;
    return 0;
}

SetReceiveMode()

int qrtplib::RTPUDPTransmitter::SetReceiveMode ( RTPTransmitter::ReceiveMode  m )

virtual

Sets the receive mode. Sets the receive mode to m, which is one of the following: RTPTransmitter::AcceptAll, RTPTransmitter::AcceptSome or RTPTransmitter::IgnoreSome. Note that if the receive mode is changed, all information about the addresses to ignore to accept is lost.

Implements qrtplib::RTPTransmitter.

Definition at line 376 of file rtpudptransmitter.cpp.

References ERR_RTP_UDPV4TRANS_NOTCREATED, ERR_RTP_UDPV4TRANS_NOTINIT, m_created, m_init, and m_receivemode.

{
    if (!m_init) {
        return ERR_RTP_UDPV4TRANS_NOTINIT;
    }

    if (!m_created) {
        return ERR_RTP_UDPV4TRANS_NOTCREATED;
    }

    if (m != m_receivemode) {
        m_receivemode = m;
    }

    return 0;
}

ShouldAcceptData()

bool qrtplib::RTPUDPTransmitter::ShouldAcceptData ( const RTPAddress &  address )

private

Definition at line 533 of file rtpudptransmitter.cpp.

References qrtplib::RTPTransmitter::AcceptAll, qrtplib::RTPTransmitter::AcceptSome, m_acceptList, m_ignoreList, and m_receivemode.

Referenced by readRTCPPendingDatagrams(), and readRTPPendingDatagrams().

{
    if (m_receivemode == RTPTransmitter::AcceptAll)
    {
        return true;
    }
    else if (m_receivemode == RTPTransmitter::AcceptSome)
    {
        std::list<RTPAddress>::iterator findIt = std::find(m_acceptList.begin(), m_acceptList.end(), rtpAddress);
        return findIt != m_acceptList.end();
    }
    else // this is RTPTransmitter::IgnoreSome
    {
        std::list<RTPAddress>::iterator findIt = std::find(m_ignoreList.begin(), m_ignoreList.end(), rtpAddress);
        return findIt == m_ignoreList.end();
    }
}

Here is the caller graph for this function:

SupportsMulticasting()

bool qrtplib::RTPUDPTransmitter::SupportsMulticasting ( )

virtual

Returns true if the transmission component supports multicasting.

Implements qrtplib::RTPTransmitter.

Definition at line 308 of file rtpudptransmitter.cpp.

References m_multicastInterface, m_rtcpsock, and m_rtpsock.

Referenced by JoinMulticastGroup(), and LeaveMulticastGroup().

{
    QNetworkInterface::InterfaceFlags flags = m_multicastInterface.flags();
    QAbstractSocket::SocketState rtpSocketState = m_rtpsock->state();
    QAbstractSocket::SocketState rtcpSocketState = m_rtcpsock->state();
    return m_multicastInterface.isValid()
            && (rtpSocketState & QAbstractSocket::BoundState)
            && (rtcpSocketState & QAbstractSocket::BoundState)
            && (flags & QNetworkInterface::CanMulticast)
            && (flags & QNetworkInterface::IsRunning)
            && !(flags & QNetworkInterface::IsLoopBack);
}

Here is the caller graph for this function:

Member Data Documentation

m_absoluteMaxPackSize

const std::size_t qrtplib::RTPUDPTransmitter::m_absoluteMaxPackSize = 65535

staticprivate

Definition at line 357 of file rtpudptransmitter.h.

Referenced by Create(), RTPUDPTransmitter(), and SetMaximumPacketSize().

m_acceptList

std::list<RTPAddress> qrtplib::RTPUDPTransmitter::m_acceptList

private

Definition at line 362 of file rtpudptransmitter.h.

Referenced by AddToAcceptList(), ClearAcceptList(), DeleteFromAcceptList(), and ShouldAcceptData().

m_created

bool qrtplib::RTPUDPTransmitter::m_created

private

Definition at line 347 of file rtpudptransmitter.h.

Referenced by Create(), Destroy(), JoinMulticastGroup(), LeaveMulticastGroup(), RTPUDPTransmitter(), SendRTCPData(), SendRTPData(), SetMaximumPacketSize(), and SetReceiveMode().

m_deletesocketswhendone

bool qrtplib::RTPUDPTransmitter::m_deletesocketswhendone

private

Definition at line 350 of file rtpudptransmitter.h.

Referenced by Create(), Destroy(), and RTPUDPTransmitter().

m_destinations

std::list<RTPAddress> qrtplib::RTPUDPTransmitter::m_destinations

private

Definition at line 361 of file rtpudptransmitter.h.

Referenced by AddDestination(), ClearDestinations(), DeleteDestination(), SendRTCPData(), and SendRTPData().

m_ignoreList

std::list<RTPAddress> qrtplib::RTPUDPTransmitter::m_ignoreList

private

Definition at line 363 of file rtpudptransmitter.h.

Referenced by AddToIgnoreList(), ClearIgnoreList(), DeleteFromIgnoreList(), and ShouldAcceptData().

m_init

bool qrtplib::RTPUDPTransmitter::m_init

private

Definition at line 346 of file rtpudptransmitter.h.

Referenced by Create(), DeleteTransmissionInfo(), Destroy(), GetTransmissionInfo(), Init(), JoinMulticastGroup(), LeaveMulticastGroup(), RTPUDPTransmitter(), SendRTCPData(), SendRTPData(), SetMaximumPacketSize(), and SetReceiveMode().

m_localIP

QHostAddress qrtplib::RTPUDPTransmitter::m_localIP

private

from parameters bind IP

Definition at line 351 of file rtpudptransmitter.h.

Referenced by BindSockets(), ComesFromThisTransmitter(), Create(), and GetTransmissionInfo().

m_maxpacksize

std::size_t qrtplib::RTPUDPTransmitter::m_maxpacksize

private

Definition at line 356 of file rtpudptransmitter.h.

Referenced by Create(), RTPUDPTransmitter(), SendRTCPData(), SendRTPData(), and SetMaximumPacketSize().

m_multicastInterface

QNetworkInterface qrtplib::RTPUDPTransmitter::m_multicastInterface

private

from parameters multicast interface

Definition at line 352 of file rtpudptransmitter.h.

Referenced by Create(), JoinMulticastGroup(), and SupportsMulticasting().

m_rawPacketQueue

QQueue<RTPRawPacket*> qrtplib::RTPUDPTransmitter::m_rawPacketQueue

private

Definition at line 364 of file rtpudptransmitter.h.

Referenced by GetNextPacket(), readRTCPPendingDatagrams(), and readRTPPendingDatagrams().

m_rawPacketQueueLock

QMutex qrtplib::RTPUDPTransmitter::m_rawPacketQueueLock

private

Definition at line 365 of file rtpudptransmitter.h.

Referenced by GetNextPacket(), readRTCPPendingDatagrams(), and readRTPPendingDatagrams().

m_receivemode

RTPTransmitter::ReceiveMode qrtplib::RTPUDPTransmitter::m_receivemode

private

Definition at line 354 of file rtpudptransmitter.h.

Referenced by Create(), RTPUDPTransmitter(), SetReceiveMode(), and ShouldAcceptData().

m_rtcpBuffer

char qrtplib::RTPUDPTransmitter::m_rtcpBuffer[m_absoluteMaxPackSize]

private

Definition at line 359 of file rtpudptransmitter.h.

Referenced by readRTCPPendingDatagrams(), and RTPUDPTransmitter().

m_rtcpPort

uint16_t qrtplib::RTPUDPTransmitter::m_rtcpPort

private

Definition at line 353 of file rtpudptransmitter.h.

Referenced by BindSockets(), ComesFromThisTransmitter(), Create(), GetTransmissionInfo(), and RTPUDPTransmitter().

m_rtcpsock

QUdpSocket * qrtplib::RTPUDPTransmitter::m_rtcpsock

private

Definition at line 349 of file rtpudptransmitter.h.

Referenced by BindSockets(), Create(), Destroy(), GetTransmissionInfo(), JoinMulticastGroup(), LeaveMulticastGroup(), readRTCPPendingDatagrams(), readRTPPendingDatagrams(), RTPUDPTransmitter(), SendRTCPData(), and SupportsMulticasting().

m_rtpBuffer

char qrtplib::RTPUDPTransmitter::m_rtpBuffer[m_absoluteMaxPackSize]

private

Definition at line 358 of file rtpudptransmitter.h.

Referenced by readRTPPendingDatagrams(), and RTPUDPTransmitter().

m_rtpPort

uint16_t qrtplib::RTPUDPTransmitter::m_rtpPort

private

Definition at line 353 of file rtpudptransmitter.h.

Referenced by BindSockets(), ComesFromThisTransmitter(), Create(), GetTransmissionInfo(), and RTPUDPTransmitter().

m_rtpsock

QUdpSocket* qrtplib::RTPUDPTransmitter::m_rtpsock

private

Definition at line 349 of file rtpudptransmitter.h.

Referenced by BindSockets(), Create(), Destroy(), GetTransmissionInfo(), JoinMulticastGroup(), LeaveMulticastGroup(), readRTPPendingDatagrams(), RTPUDPTransmitter(), SendRTPData(), and SupportsMulticasting().

m_waitingfordata

bool qrtplib::RTPUDPTransmitter::m_waitingfordata

private

Definition at line 348 of file rtpudptransmitter.h.

Referenced by Create(), and RTPUDPTransmitter().

---

The documentation for this class was generated from the following files:

• qrtplib/rtpudptransmitter.h
• qrtplib/rtpudptransmitter.cpp