MprRtpDispatcherIpAffinity.h

Go to the documentation of this file.

//  
// Copyright (C) 2007-2011 SIPez LLC.  All rights reserved.
// Licensed to SIPfoundry under a Contributor Agreement. 
//
// Copyright (C) 2007-2008 SIPfoundry Inc.
// Licensed by SIPfoundry under the LGPL license.
//
// $$

// Author: Alexander Chemeris <Alexander DOT Chemeris AT SIPez DOT com>

#ifndef _MprRtpDispatcherIpAffinity_h_
#define _MprRtpDispatcherIpAffinity_h_

// SYSTEM INCLUDES
// APPLICATION INCLUDES
#include <mp/MprRtpDispatcher.h>

// DEFINES
// MACROS
// EXTERNAL FUNCTIONS
// EXTERNAL VARIABLES
// CONSTANTS
// STRUCTS
// TYPEDEFS
// FORWARD DECLARATIONS
class MpRtpStream;
class MprDejitter;

class MprRtpDispatcherIpAffinity : public MprRtpDispatcher
{
/* //////////////////////////// PUBLIC //////////////////////////////////// */
public:

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


   MprRtpDispatcherIpAffinity(const UtlString& rName, int connectionId);
   virtual
   ~MprRtpDispatcherIpAffinity();


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


   OsStatus pushPacket(MpRtpBufPtr &pRtp);

   void checkRtpStreamsActivity();

   UtlBoolean connectOutput(int outputIdx, MpResource* pushRtpToResource);

   UtlBoolean disconnectOutput(int outputIdx);

   void setPreferredIp(unsigned long address, int port);


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



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



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

   MpRtpStream     mRtpStream;     
   MprDejitter    *mpDejitter;     

   UtlBoolean      mPrefSsrcValid; 
   unsigned long   mRtpDestIp;     
   int             mRtpDestPort;   

   int             mNumPushed;              
   int             mNumDropped;             
   int             mTotalWarnings;          
   int             mNumWarnings;            
   int             mNumNonPrefPackets;      
   int             mRtpDestMatchIpOnlySsrc; 
   UtlBoolean      mRtpDestMatchIpOnlySsrcValid;
   int             mRtpOtherSsrc;           
   UtlBoolean      mRtpOtherSsrcValid;

   static const int SSRC_SWITCH_MISMATCH_COUNT;

   int setPrefSsrc(unsigned int newSsrc);
   RtpSRC getPrefSsrc(void);

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

   MprRtpDispatcherIpAffinity(const MprRtpDispatcherIpAffinity& rMprRtpDispatcherIpAffinity);

   MprRtpDispatcherIpAffinity& operator=(const MprRtpDispatcherIpAffinity& rhs);

};

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

#endif  // _MprRtpDispatcherIpAffinity_h_