MpRtpOutputConnection.h

Go to the documentation of this file.

//  
// Copyright (C) 2006-2013 SIPez LLC.  All rights reserved.
//
// Copyright (C) 2004-2007 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 _MpRtpOutputConnection_h_
#define _MpRtpOutputConnection_h_

#include "rtcp/RtcpConfig.h"

// FORWARD DECLARATIONS
class MprDejitter;
class MprFromNet;
class OsSocket;
class SdpCodec;
struct IRTCPSession;
struct IRTCPConnection;

// SYSTEM INCLUDES
// APPLICATION INCLUDES
#include <os/OsMutex.h>
#include <mp/MpResource.h>
#include <mp/MpResourceMsg.h>
#include <mp/MpTypes.h>
#include <mp/MprToNet.h>

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

class MpRtpOutputConnection : public MpResource
{
/* //////////////////////////// PUBLIC //////////////////////////////////// */
public:

   enum {
      NUM_PAYLOAD_TYPES = (2<<7),
      MAX_ACTIVE_PAYLOAD_TYPES = 10
   };

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


   MpRtpOutputConnection(const UtlString& resourceName,
                         MpConnectionID myID, 
                         IRTCPSession *piRTCPSession);

   virtual
   ~MpRtpOutputConnection();


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


   void setSockets(OsSocket& rRtpSocket, OsSocket& rRtcpSocket);
   void releaseSockets();
#ifdef INCLUDE_RTCP /* [ */
   virtual void reassignSSRC(void);
#endif /* INCLUDE_RTCP ] */

   // set the # of microseconds of skew to add to the RTCP SR timestamps
   OsStatus setSRAdjustUSecs(const UtlString& namedResource, OsMsgQ& fgQ, int adjustUSecs);


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


   OsStatus setFlowGraph(MpFlowGraphBase* pFlowGraph);

#ifdef INCLUDE_RTCP /* [ */


   IRTCPConnection *getRTCPConnection(void);
#endif /* INCLUDE_RTCP ] */

   inline RtpSRC getSSRC() const;


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



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

   MprToNet*          mpToNet;         
   UtlBoolean         mOutRtpStarted;  

#ifdef INCLUDE_RTCP /* [ */
   IRTCPConnection *mpiRTCPConnection; 

#endif /* INCLUDE_RTCP ] */

   UtlBoolean processFrame();

   UtlBoolean connectInput(MpResource& rFrom, int fromPortIdx, int toPortIdx);

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

   typedef enum
   {
      MPRM_SET_SR_ADJUST_USECS = MpResourceMsg::MPRM_EXTERNAL_MESSAGE_START,
   } AddlResMsgTypes;

   UtlBoolean handleMessage(MpResourceMsg& message);

   MpRtpOutputConnection();

   MpRtpOutputConnection(const MpRtpOutputConnection& rMpRtpOutputConnection);

   MpRtpOutputConnection& operator=(const MpRtpOutputConnection& rhs);
};

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

RtpSRC MpRtpOutputConnection::getSSRC() const
{
   return mpToNet->getSSRC();
}

#endif  // _MpRtpOutputConnection_h_