diff -r d7640adb246b -r b8a7e07b2677 rtp/rtpstack/src/rtpmanager.cpp --- 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 *aCsrcList) { CRtpSession* rtpSession = GetSession( aTranStreamId ); @@ -786,13 +828,13 @@ return static_cast (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 *aCsrcList) { CRtpSession* rtpSession = GetSession( aTranStreamId ); @@ -828,13 +871,13 @@ return static_cast (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 *aCsrcList ) { CRtpSession* rtpSession = GetSession( aTranStreamId ); TInt result( KErrNone ); @@ -874,14 +918,14 @@ result = static_cast (rtpSession)->SendRtpPacket( aTranStreamId, aSequenceNum, aHeaderInfo, aPayloadData, - aStatus ); + aStatus, aCsrcList ); } else { result = rtpSession->SendRtpPacket( aTranStreamId, aSequenceNum, aHeaderInfo, aPayloadData, - aStatus ); + aStatus, aCsrcList ); } }