MpRtpInputConnection.h

Go to the documentation of this file.

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

#include "rtcp/RtcpConfig.h"

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

// DEFINES
// MACROS
// EXTERNAL FUNCTIONS
// EXTERNAL VARIABLES
// CONSTANTS
// STRUCTS
// TYPEDEFS
// FORWARD DECLARATIONS
class MprFromNet;
class MprRtpDispatcher;
class OsSocket;
struct IRTCPSession;
struct IRTCPConnection;

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

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


   MpRtpInputConnection(const UtlString& resourceName,
                        MpConnectionID myID,
                        IRTCPSession *piRTCPSession = NULL,
                        int maxRtpStreams = 1,
                        MprRtpDispatcher::RtpStreamAffinity rtpStreamAffinity = MprRtpDispatcher::ADDRESS_AND_PORT);
   virtual
   ~MpRtpInputConnection();


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


   UtlBoolean processFrame();

   void setSockets(OsSocket& rRtpSocket, OsSocket& rRtcpSocket);
   void releaseSockets();
   void setConnectionId(MpConnectionID connectionId);

   static OsStatus setRtpInactivityTimeout(const UtlString& namedResource,
                                           OsMsgQ& fgQ,
                                           int timeoutMs);

   static OsStatus enableSsrcDiscard(const UtlString& namedResource,
                                     OsMsgQ& fgQ,
                                     UtlBoolean enable, RtpSRC ssrc);


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


#ifdef INCLUDE_RTCP /* [ */


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


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



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

   enum
   {
      MPRM_SET_INACTIVITY_TIMEOUT = MpResourceMsg::MPRM_EXTERNAL_MESSAGE_START,
      MPRM_ENABLE_SSRC_DISCARD,
      MPRM_DISABLE_SSRC_DISCARD
   };

   MprFromNet*        mpFromNet;       
   MprRtpDispatcher*  mpRtpDispatcher; 
   int                mMaxRtpStreams;  
   MprRtpDispatcher::RtpStreamAffinity  mRtpStreamAffinity; 
   UtlBoolean         mIsRtpStarted;   

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

   UtlBoolean connectOutput(MpResource& rTo, int toPortIdx, int fromPortIdx);

   UtlBoolean disconnectOutput(int outPortIdx);

   OsStatus setFlowGraph(MpFlowGraphBase* pFlowGraph);

   virtual UtlBoolean handleMessage(MpResourceMsg& rMsg);

   void handleSetInactivityTimeout(const OsTime &timeout);

   void handleEnableSsrcDiscard(UtlBoolean enable, RtpSRC ssrc);

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

   MpRtpInputConnection(const MpRtpInputConnection& rMpRtpInputConnection);

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

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

#endif  // _MpRtpInputConnection_h_