RTCPSource.h

Go to the documentation of this file.

//
// Copyright (C) 2006-2013 SIPez LLC.  All rights reserved.
//
// Copyright (C) 2004-2006 SIPfoundry Inc.
// Licensed by SIPfoundry under the LGPL license.
//
// Copyright (C) 2004-2006 Pingtel Corp.  All rights reserved.
// Licensed to SIPfoundry under a Contributor Agreement.
//
// $$


//  Border Guard
#ifndef _RTCPSource_h
#define _RTCPSource_h

#include "rtcp/RtcpConfig.h"

//  Includes
#include "TLinkedList.h"
#include "RTCPHeader.h"
#include "ByeReport.h"
#include "SenderReport.h"
#include "ReceiverReport.h"
#include "SourceDescription.h"
#include "IRTCPStatistics.h"
#include "INetDispatch.h"
#include "IRTCPNotify.h"

#ifdef __pingtel_on_posix__
#include <netinet/in.h>
#endif

class CRTCPSource:
         public CBaseClass,        // Inherits CBaseClass implementation
         public INetDispatch,      // RTCP Report Input Interface
         public IRTCPStatistics    // RTCP Statistics Retrieval Interface
 {

//  Public Methods
public:

    CRTCPSource(ssrc_t ulSSRC, IRTCPNotify *piRTCPNotify,
                ISetReceiverStatistics *piSetStatistics);


    virtual ~CRTCPSource(void);

    void ProcessPacket(unsigned char *puchDataBuffer,
                       unsigned long ulBufferLength, int verbose=0);

DECLARE_IBASE_M

private:        // Private Methods


    void SendRTCPEvent(unsigned long ulEventType,
                       void  *pvInterface,
                       unsigned long ulChangeMask=0);

    unsigned long ProcessSenderReport(unsigned char *puchRTCPReport);


    unsigned long ProcessReceiverReport(unsigned char *puchRTCPReport,
                                        unsigned long ulReportCount = 0);


    unsigned long ProcessSDESReport(unsigned char *puchRTCPReport);

    unsigned long ProcessByeReport(unsigned char *puchRTCPReport);


    unsigned long ProcessAppReport(unsigned char *puchRTCPReport);


    void GetStatistics(IGetSrcDescription     **piGetSrcDescription,
                       IGetSenderStatistics   **piSenderStatistics,
                       IGetReceiverStatistics **piReceiverStatistics,
                       IGetByeInfo            **piGetByeInfo);

    RTCP_REPORTS_ET GetPayloadType(unsigned char *puchRTCPBuffer);


    ssrc_t GetSenderSSRC(bool bHeader, unsigned char *puchRTCPBuffer);


    ssrc_t GetReceiverSSRC(bool bRTCPHeader,
                                  unsigned char *puchRTCPBuffer);

    unsigned long GetReportCount(unsigned char *puchRTCPBuffer);


    unsigned long GetReportLength(unsigned char *puchRTCPBuffer);


private:        // Private Data Members

      ssrc_t m_ulSSRC;


      IRTCPNotify * m_piRTCPNotify;


      ISetReceiverStatistics *m_piSetReceiverStatistics;

      CTLinkedList<CSourceDescription *> m_tSrcDescriptorList;


      CTLinkedList<CReceiverReport *> m_tReceiverReportList;

      CSenderReport *m_poSenderReport;

      CByeReport *m_poByeReport;

};


inline RTCP_REPORTS_ET
            CRTCPSource::GetPayloadType(unsigned char *puchRTCPBuffer)
{

//  Snoop into the packet header and return the payload type
    return((RTCP_REPORTS_ET)*(puchRTCPBuffer + PAYLOAD_OFFSET));

}


inline ssrc_t CRTCPSource::GetSenderSSRC(bool bRTCPHeader, unsigned char *puchRTCPBuffer)
{

//  Advance over RTCP Header if one exists
    if(bRTCPHeader)
        puchRTCPBuffer += SSRC_OFFSET;

//  Return Sender SSRC
    return(ntohl(*((ssrc_t *)puchRTCPBuffer)));

}


inline ssrc_t CRTCPSource::GetReceiverSSRC(bool bRTCPHeader,
                                 unsigned char *puchRTCPBuffer)
{

//  Advance over RTCP Header if one exists
    if(bRTCPHeader)
        puchRTCPBuffer += HEADER_LENGTH;

//  Return Receiver SSRC
    return(ntohl(*((ssrc_t *)puchRTCPBuffer)));

}

inline unsigned long CRTCPSource::GetReportCount(unsigned char *puchRTCPBuffer)
{

//  Extract Report Count
    return(*puchRTCPBuffer & COUNT_MASK);

}

inline unsigned long CRTCPSource::GetReportLength(unsigned char *puchRTCPBuffer)
{

//  Extract Report Length
    unsigned long ulReportLength =
               ntohs(*((unsigned short *)(puchRTCPBuffer + LENGTH_OFFSET))) + 1;

    return(ulReportLength * sizeof(uint32_t));

}
#endif