--- a/rtp/rtpstack/src/rtpmanager.cpp Fri May 28 16:13:10 2010 +0300
+++ b/rtp/rtpstack/src/rtpmanager.cpp Thu Jun 24 14:43:49 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 );
}
}