MprRtpDispatcherActiveSsrcs.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 _MprRtpDispatcherActiveSsrcs_h_
#define _MprRtpDispatcherActiveSsrcs_h_

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

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

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

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


   MprRtpDispatcherActiveSsrcs(const UtlString& name, int connectionId,
                               int streamsNum);
   virtual
   ~MprRtpDispatcherActiveSsrcs();


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


   OsStatus pushPacket(MpRtpBufPtr &pRtp);

   void checkRtpStreamsActivity();

   UtlBoolean connectOutput(int outputIdx, MpResource* pushRtpToResource);

   UtlBoolean disconnectOutput(int outputIdx);


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



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



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

   int             mRtpStreamsNum;   
   MpRtpStream    *mpStreamsArray;   
   UtlHashBag      mActiveStreams;   
   UtlSList        mInactiveStreams; 

   int             mNumPushed;       
   int             mNumDropped;      

   MpRtpStream *lookupRtpStream(unsigned int ssrc, const in_addr &fromIp,
                                int fromPort);

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

   MprRtpDispatcherActiveSsrcs(const MprRtpDispatcherActiveSsrcs& rMprRtpDispatcherActiveSsrcs);

   MprRtpDispatcherActiveSsrcs& operator=(const MprRtpDispatcherActiveSsrcs& rhs);

};

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

#endif  // _MprRtpDispatcherActiveSsrcs_h_