rtp/rtpstack/src/rtpmanager.cpp
changeset 33 b8a7e07b2677
parent 30 d7640adb246b
--- a/rtp/rtpstack/src/rtpmanager.cpp	Mon Jun 28 19:10:29 2010 +0300
+++ b/rtp/rtpstack/src/rtpmanager.cpp	Fri Jul 09 13:15:39 2010 +0300
@@ -721,6 +721,47 @@
     return result;
     }
 
+
+// ---------------------------------------------------------------------------
+// TInt CRtpManager::RegisterRtpPostProcessingObserver()
+//
+// ---------------------------------------------------------------------------
+//
+TInt CRtpManager::RegisterRtpPostProcessingObserver( TRtpId aSessionId, MRtpPostProcessingObserver& aRtpPacketObserver )
+    {
+    CRtpSession* session = GetSession( aSessionId ); 
+    TInt result( KErrGeneral );
+    if ( session )
+        {
+        result = session->RegisterRtpPostProcessingObserver( aRtpPacketObserver );
+        }
+    else
+        {
+        RTP_DEBUG_DETAIL( "CRtpManager::RegisterRtpPostProcessingObserver, Session not found" );
+        }
+    return result;
+    }
+
+
+// ---------------------------------------------------------------------------
+// CRtpManager::UnregisterRtpPostProcessingObserver()
+//
+// ---------------------------------------------------------------------------
+//
+void CRtpManager::UnregisterRtpPostProcessingObserver( TRtpId aSessionId )
+    {
+    CRtpSession* session = GetSession( aSessionId ); 
+
+    if ( session )
+        {
+        session->UnregisterRtpPostProcessingObserver();
+        }
+    else
+        {
+        RTP_DEBUG_DETAIL( "CRtpManager::UnregisterRtpPostProcessingObserver, Session not found" );
+        }
+    }
+    
 // ---------------------------------------------------------------------------
 // CRtpManager::UnregisterRtpObserver()
 //
@@ -773,7 +814,8 @@
 //
 TInt CRtpManager::SendRtpPacket( TRtpId aTranStreamId,
                                  const TRtpSendHeader& aHeaderInfo, 
-                                 const TDesC8& aPayloadData )
+                                 const TDesC8& aPayloadData,
+                                 const TArray<TRtpCSRC> *aCsrcList)
     {
     CRtpSession* rtpSession = GetSession( aTranStreamId );
 
@@ -786,13 +828,13 @@
             	
  		        return static_cast<CRtpSessionSrtp*>
  		        	(rtpSession)->SendRtpPacket( aTranStreamId, aHeaderInfo,
-                                             	 aPayloadData );
+                                             	 aPayloadData, aCsrcList );
  	
             	}
             else
             	{
             	return rtpSession->SendRtpPacket( aTranStreamId, aHeaderInfo,
-             		                                 aPayloadData );
+             		                                 aPayloadData, aCsrcList );
             	}
             }
         else
@@ -815,7 +857,8 @@
 TInt CRtpManager::SendRtpPacket( TRtpId aTranStreamId,
                                  const TRtpSendHeader& aHeaderInfo,
                                  const TDesC8& aPayloadData,
-                                 TRequestStatus& aStatus )
+                                 TRequestStatus& aStatus,
+                                 const TArray<TRtpCSRC> *aCsrcList)
     {
     CRtpSession* rtpSession = GetSession( aTranStreamId ); 
 
@@ -828,13 +871,13 @@
             	
  		        return static_cast<CRtpSessionSrtp*>
  		        	(rtpSession)->SendRtpPacket( aTranStreamId, aHeaderInfo,
-                                              aPayloadData, aStatus );
+                                              aPayloadData, aStatus, aCsrcList );
  	
             	}
             else
             	{
             	return rtpSession->SendRtpPacket( aTranStreamId, aHeaderInfo,
-                                              aPayloadData, aStatus );
+                                              aPayloadData, aStatus, aCsrcList );
             	}
            
             }
@@ -860,7 +903,8 @@
                                  TRtpSequence aSequenceNum,
                                  const TRtpSendHeader& aHeaderInfo,
                                  const TDesC8& aPayloadData,
-                                 TRequestStatus& aStatus )
+                                 TRequestStatus& aStatus,
+                                 const TArray<TRtpCSRC> *aCsrcList )
     {
     CRtpSession* rtpSession = GetSession( aTranStreamId ); 
     TInt result( KErrNone );
@@ -874,14 +918,14 @@
 	 		        result = static_cast<CRtpSessionSrtp*>
 	 		        	(rtpSession)->SendRtpPacket( aTranStreamId, aSequenceNum,
 	                                              aHeaderInfo, aPayloadData,
-	                                              aStatus );
+	                                              aStatus, aCsrcList );
 	 	
 	            	}
 	            else
 	            	{
 	            	result =  rtpSession->SendRtpPacket( aTranStreamId, aSequenceNum,
 	                                              aHeaderInfo, aPayloadData,
-	                                              aStatus );
+	                                              aStatus, aCsrcList );
 	            	}	            
 	            
 	            }