MprToNet.h

Go to the documentation of this file.

//  
// Copyright (C) 2006-2018 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.
//
// $$


#ifndef _MprToNet_h_
#define _MprToNet_h_

#include "rtcp/RtcpConfig.h"

// Defining this option includes debug code for introducing sudden changes
// to several fields of the outgoing RTP headers (SSRC, seq#, timestamp).
#define ENABLE_PACKET_HACKING
#undef ENABLE_PACKET_HACKING

// SYSTEM INCLUDES

// APPLICATION INCLUDES
#include "os/OsSocket.h"
#include "mp/NetInTask.h"
#include "mp/MpResourceMsg.h"
#ifdef INCLUDE_RTCP /* [ */
#include "rtcp/ISetSenderStatistics.h"
#endif /* INCLUDE_RTCP ] */

// DEFINES
// MACROS
// EXTERNAL FUNCTIONS
// EXTERNAL VARIABLES
// CONSTANTS
// STRUCTS
// TYPEDEFS
// FORWARD DECLARATIONS
class MprFromNet;
class MpFlowGraphBase;

class MprToNet
{
/* //////////////////////////// PUBLIC //////////////////////////////////// */
public:

   enum { RESERVED_RTP_PACKET_HEADER_BYTES = 76
   };

   enum {
      MPRM_SET_SR_ADJUST_USECS = MpResourceMsg::MPRM_EXTERNAL_MESSAGE_START,
   };

#ifdef ENABLE_PACKET_HACKING /* [ */
   static int sDebug1;
   static int sDebug2;
   static int sDebug3;
   static int sDebug4;
   static int sDebug5;
#endif /* ENABLE_PACKET_HACKING ] */

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


   MprToNet();

   virtual
   ~MprToNet();


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


   OsStatus setSockets(OsSocket& rRtpSocket, OsSocket& rRtcpSocket);
   OsStatus resetSockets();
   OsStatus setRtpPal(MprFromNet* pal);

   virtual int writeRtp(int payloadType, UtlBoolean markerState,
      const unsigned char* payloadData, int payloadOctets, unsigned int timestamp,
      void* csrcList);

    // set the # of microseconds of skew to add to the RTCP SR timestamps
   void setSRAdjustUSecs(int iUSecs);
    // send a message via flowgraph to set the # of microseconds of skew
    // the namedResource will be one of the Connections (e.g. MpRtpOutputConnection).
   static OsStatus setSRAdjustUSecs(const UtlString& namedResource, OsMsgQ& fgQ, int adjustUSecs);


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


   OsStatus setFlowGraph(MpFlowGraphBase* flowgraph);

   void setSSRC(ssrc_t iSSRC);
   inline RtpSRC getSSRC() const;
#ifdef INCLUDE_RTCP /* [ */
   void   setRTPAccumulator(ISetSenderStatistics *piRTPAccumulator);
#endif /* INCLUDE_RTCP ] */


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



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

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

   MprFromNet*  mpFromNetPal;
   MpFlowGraphBase* mpFlowGraph; 
   int          mRtcpPackets;
   int          mRtcpFrameCount;
   int          mRtcpFrameLimit;
#ifdef DEBUG /* [ */
   unsigned int mRtpSampleCounter;
#endif /* DEBUG ] */

   // RTP State
   unsigned int mTimestampDelta;
   unsigned int mSeqNum;
   unsigned int mSSRC;
   OsSocket*    mpRtpSocket;
   OsSocket*    mpRtcpSocket;
   int          mNumRtpWriteErrors;
   int          mNumRtcpWriteErrors;

#ifdef ENABLE_PACKET_HACKING /* [ */
   void adjustRtpPacket(struct RtpHeader* p);
#endif /* ENABLE_PACKET_HACKING ] */

#ifdef INCLUDE_RTCP /* [ */
   ISetSenderStatistics *mpiRTPAccumulator;
#endif /* INCLUDE_RTCP ] */

   int mSRAdjustUSecs;

   MprToNet(const MprToNet& rMprToNet);

   MprToNet& operator=(const MprToNet& rhs);

};

/* ============================ INLINE METHODS ============================ */

RtpSRC MprToNet::getSSRC() const
{
   return mSSRC;
}

#endif  // _MprToNet_h_