MpRtpBuf.h

Go to the documentation of this file.

//  
// Copyright (C) 2006-2012 SIPez LLC.  All rights reserved.
//  
//  
// $$ 

#ifndef _INCLUDED_MPRTPBUF_H /* [ */
#define _INCLUDED_MPRTPBUF_H

// SYSTEM INCLUDES
#ifdef __pingtel_on_posix__ // [
#  include <netinet/in.h>
#endif // __pigntel_on_posix__ ]

#ifdef WIN32
#   include <winsock2.h>
#endif

// APPLICATION INCLUDES
#include <sdp/SdpCodec.h>
#include <mp/MpUdpBuf.h>
//#include <mp/MpTypes.h>
#include <mp/RtpHeader.h>
#include <mp/MpMisc.h>

// MACROS
// EXTERNAL FUNCTIONS
// EXTERNAL VARIABLES
// CONSTANTS
// STRUCTS
// TYPEDEFS
// DEFINES


struct MpRtpBuf : public MpUdpBuf
{
    friend class MpRtpBufPtr;

/* //////////////////////////// PUBLIC //////////////////////////////////// */
public:

    static MpBufPool *smpDefaultPool;

/* ============================ CREATORS ================================== */




/* ============================ MANIPULATORS ============================== */



    bool setPayloadSize(int payloadSize)
    {
        if(!mpData.isValid())
        {
            MpMisc.RtpPool->profileFlowgraphPoolUsage();
        }
        return mpData->setDataSize(payloadSize);
    }


    void setRtpVersion(uint8_t version)
    { mRtpHeader.vpxcc = ( (version<<RTP_V_SHIFT)&RTP_V_MASK)
                         | (mRtpHeader.vpxcc&(~RTP_V_MASK));}


    void enableRtpPadding()
    { mRtpHeader.vpxcc |= 1<<RTP_P_SHIFT;}


    void disableRtpPadding()
    { mRtpHeader.vpxcc &= ~RTP_P_MASK;}


    void enableRtpExtension()
    { mRtpHeader.vpxcc |= 1<<RTP_X_SHIFT;}


    void disableRtpExtension()
    { mRtpHeader.vpxcc &= ~RTP_X_MASK;}


    void setRtpCSRCCount(uint8_t csrcCount)
    { mRtpHeader.vpxcc = ( (csrcCount<<RTP_CC_SHIFT)&RTP_CC_MASK)
                         | (mRtpHeader.vpxcc&(~RTP_CC_MASK));}


    void enableRtpMarker()
    { mRtpHeader.mpt |= 1<<RTP_M_SHIFT;}



    void disableRtpMarker()
    { mRtpHeader.mpt &= ~RTP_M_MASK;}


    void setRtpPayloadType(uint8_t type)
    { mRtpHeader.mpt = ( (type<<RTP_PT_SHIFT)&RTP_PT_MASK)
                       | (mRtpHeader.mpt&(~RTP_PT_MASK));}


    void setRtpSequenceNumber(RtpSeq sequenceNumber)
    { mRtpHeader.seq = htons(sequenceNumber);}


    void setRtpTimestamp(RtpTimestamp timestamp)
    { mRtpHeader.timestamp = htonl(timestamp);}


    void setRtpSSRC(RtpSRC ssrc)
    { mRtpHeader.ssrc = htonl(ssrc);}


/* ============================ ACCESSORS ================================= */


    unsigned getPayloadSize() const {return mpData->getDataSize();}

    RtpHeader &getRtpHeader() {return mRtpHeader;}

    const RtpHeader &getRtpHeader() const {return mRtpHeader;}

    RtpSRC *getRtpCSRCs() {return mRtpCSRCs;}

    const RtpSRC *getRtpCSRCs() const {return mRtpCSRCs;}


    uint8_t getRtpVersion() const
    {return (mRtpHeader.vpxcc&RTP_V_MASK) >> RTP_V_SHIFT;}


    uint8_t getRtpCSRCCount() const {return mRtpHeader.vpxcc & RTP_CC_MASK;}


    uint8_t getRtpPayloadType() const
    {return (mRtpHeader.mpt&RTP_PT_MASK) >> RTP_PT_SHIFT;}

    SdpCodec::SdpCodecTypes getCodecId() const { return(mInternalCodecId); };
    /*
     * Note this must be set by the RTP Input connection as the bufer maintains no
     * codec mapping capablity.
     */

    void setCodecId(SdpCodec::SdpCodecTypes codecId) { mInternalCodecId = codecId; };


    RtpSeq getRtpSequenceNumber() const {return ntohs(mRtpHeader.seq);}


    RtpTimestamp getRtpTimestamp() const {return ntohl(mRtpHeader.timestamp);}


    RtpSRC getRtpSSRC() const {return ntohl(mRtpHeader.ssrc);}


/* ============================ INQUIRY =================================== */



    bool isRtpPadding() const
    {return (mRtpHeader.vpxcc&RTP_P_MASK) == (1<<RTP_P_SHIFT);}


    bool isRtpExtension() const
    {return (mRtpHeader.vpxcc&RTP_X_MASK) == (1<<RTP_X_SHIFT);}


    bool isRtpMarker() const
    {return (mRtpHeader.mpt&RTP_M_MASK) == (1<<RTP_M_SHIFT);}


/* //////////////////////////// PROTECTED ///////////////////////////////// */
protected:

    RtpHeader  mRtpHeader;   

    SdpCodec::SdpCodecTypes mInternalCodecId; 

    RtpSRC mRtpCSRCs[RTP_MAX_CSRCS]; 

    void init();

/* //////////////////////////// PRIVATE /////////////////////////////////// */
private:

    MpRtpBuf(const MpBuf &);
    MpRtpBuf &operator=(const MpBuf &);
};


class MpRtpBufPtr : public MpUdpBufPtr {

/* //////////////////////////// PUBLIC //////////////////////////////////// */
public:

/* ============================ CREATORS ================================== */


    MPBUF_DEFAULT_CONSTRUCTOR(MpRtpBuf)

    
    MPBUFDATA_FROM_BASE_CONSTRUCTOR(MpRtpBuf, MP_BUF_RTP, MpUdpBuf)

    
    MPBUF_TYPECHECKED_COPY(MpRtpBuf, MP_BUF_RTP, MpUdpBuf)



/* ============================ MANIPULATORS ============================== */





/* ============================ ACCESSORS ================================= */


    MPBUF_MEMBER_ACCESS_OPERATOR(MpRtpBuf)

    
    MPBUF_CONST_MEMBER_ACCESS_OPERATOR(MpRtpBuf)



/* ============================ INQUIRY =================================== */





/* //////////////////////////// PROTECTED ///////////////////////////////// */
protected:


/* //////////////////////////// PRIVATE /////////////////////////////////// */
private:

};

#endif /* ] _INCLUDED_MPRTPBUF_H */