719 RTP_DEBUG_DETAIL( "CRtpManager::RegisterRtpObserver, Session not found" ); |
719 RTP_DEBUG_DETAIL( "CRtpManager::RegisterRtpObserver, Session not found" ); |
720 } |
720 } |
721 return result; |
721 return result; |
722 } |
722 } |
723 |
723 |
|
724 |
|
725 // --------------------------------------------------------------------------- |
|
726 // TInt CRtpManager::RegisterRtpPostProcessingObserver() |
|
727 // |
|
728 // --------------------------------------------------------------------------- |
|
729 // |
|
730 TInt CRtpManager::RegisterRtpPostProcessingObserver( TRtpId aSessionId, MRtpPostProcessingObserver& aRtpPacketObserver ) |
|
731 { |
|
732 CRtpSession* session = GetSession( aSessionId ); |
|
733 TInt result( KErrGeneral ); |
|
734 if ( session ) |
|
735 { |
|
736 result = session->RegisterRtpPostProcessingObserver( aRtpPacketObserver ); |
|
737 } |
|
738 else |
|
739 { |
|
740 RTP_DEBUG_DETAIL( "CRtpManager::RegisterRtpPostProcessingObserver, Session not found" ); |
|
741 } |
|
742 return result; |
|
743 } |
|
744 |
|
745 |
|
746 // --------------------------------------------------------------------------- |
|
747 // CRtpManager::UnregisterRtpPostProcessingObserver() |
|
748 // |
|
749 // --------------------------------------------------------------------------- |
|
750 // |
|
751 void CRtpManager::UnregisterRtpPostProcessingObserver( TRtpId aSessionId ) |
|
752 { |
|
753 CRtpSession* session = GetSession( aSessionId ); |
|
754 |
|
755 if ( session ) |
|
756 { |
|
757 session->UnregisterRtpPostProcessingObserver(); |
|
758 } |
|
759 else |
|
760 { |
|
761 RTP_DEBUG_DETAIL( "CRtpManager::UnregisterRtpPostProcessingObserver, Session not found" ); |
|
762 } |
|
763 } |
|
764 |
724 // --------------------------------------------------------------------------- |
765 // --------------------------------------------------------------------------- |
725 // CRtpManager::UnregisterRtpObserver() |
766 // CRtpManager::UnregisterRtpObserver() |
726 // |
767 // |
727 // --------------------------------------------------------------------------- |
768 // --------------------------------------------------------------------------- |
728 // |
769 // |
771 // |
812 // |
772 // --------------------------------------------------------------------------- |
813 // --------------------------------------------------------------------------- |
773 // |
814 // |
774 TInt CRtpManager::SendRtpPacket( TRtpId aTranStreamId, |
815 TInt CRtpManager::SendRtpPacket( TRtpId aTranStreamId, |
775 const TRtpSendHeader& aHeaderInfo, |
816 const TRtpSendHeader& aHeaderInfo, |
776 const TDesC8& aPayloadData ) |
817 const TDesC8& aPayloadData, |
|
818 const TArray<TRtpCSRC> *aCsrcList) |
777 { |
819 { |
778 CRtpSession* rtpSession = GetSession( aTranStreamId ); |
820 CRtpSession* rtpSession = GetSession( aTranStreamId ); |
779 |
821 |
780 if ( rtpSession ) |
822 if ( rtpSession ) |
781 { |
823 { |
784 if (rtpSession->IsSrtp()) |
826 if (rtpSession->IsSrtp()) |
785 { |
827 { |
786 |
828 |
787 return static_cast<CRtpSessionSrtp*> |
829 return static_cast<CRtpSessionSrtp*> |
788 (rtpSession)->SendRtpPacket( aTranStreamId, aHeaderInfo, |
830 (rtpSession)->SendRtpPacket( aTranStreamId, aHeaderInfo, |
789 aPayloadData ); |
831 aPayloadData, aCsrcList ); |
790 |
832 |
791 } |
833 } |
792 else |
834 else |
793 { |
835 { |
794 return rtpSession->SendRtpPacket( aTranStreamId, aHeaderInfo, |
836 return rtpSession->SendRtpPacket( aTranStreamId, aHeaderInfo, |
795 aPayloadData ); |
837 aPayloadData, aCsrcList ); |
796 } |
838 } |
797 } |
839 } |
798 else |
840 else |
799 { |
841 { |
800 return rtpSession->SendRtpPacket( aHeaderInfo, aPayloadData ); |
842 return rtpSession->SendRtpPacket( aHeaderInfo, aPayloadData ); |
813 // --------------------------------------------------------------------------- |
855 // --------------------------------------------------------------------------- |
814 // |
856 // |
815 TInt CRtpManager::SendRtpPacket( TRtpId aTranStreamId, |
857 TInt CRtpManager::SendRtpPacket( TRtpId aTranStreamId, |
816 const TRtpSendHeader& aHeaderInfo, |
858 const TRtpSendHeader& aHeaderInfo, |
817 const TDesC8& aPayloadData, |
859 const TDesC8& aPayloadData, |
818 TRequestStatus& aStatus ) |
860 TRequestStatus& aStatus, |
|
861 const TArray<TRtpCSRC> *aCsrcList) |
819 { |
862 { |
820 CRtpSession* rtpSession = GetSession( aTranStreamId ); |
863 CRtpSession* rtpSession = GetSession( aTranStreamId ); |
821 |
864 |
822 if ( rtpSession ) |
865 if ( rtpSession ) |
823 { |
866 { |
826 if (rtpSession->IsSrtp()) |
869 if (rtpSession->IsSrtp()) |
827 { |
870 { |
828 |
871 |
829 return static_cast<CRtpSessionSrtp*> |
872 return static_cast<CRtpSessionSrtp*> |
830 (rtpSession)->SendRtpPacket( aTranStreamId, aHeaderInfo, |
873 (rtpSession)->SendRtpPacket( aTranStreamId, aHeaderInfo, |
831 aPayloadData, aStatus ); |
874 aPayloadData, aStatus, aCsrcList ); |
832 |
875 |
833 } |
876 } |
834 else |
877 else |
835 { |
878 { |
836 return rtpSession->SendRtpPacket( aTranStreamId, aHeaderInfo, |
879 return rtpSession->SendRtpPacket( aTranStreamId, aHeaderInfo, |
837 aPayloadData, aStatus ); |
880 aPayloadData, aStatus, aCsrcList ); |
838 } |
881 } |
839 |
882 |
840 } |
883 } |
841 else |
884 else |
842 { |
885 { |
858 // |
901 // |
859 TInt CRtpManager::SendRtpPacket( TRtpId aTranStreamId, |
902 TInt CRtpManager::SendRtpPacket( TRtpId aTranStreamId, |
860 TRtpSequence aSequenceNum, |
903 TRtpSequence aSequenceNum, |
861 const TRtpSendHeader& aHeaderInfo, |
904 const TRtpSendHeader& aHeaderInfo, |
862 const TDesC8& aPayloadData, |
905 const TDesC8& aPayloadData, |
863 TRequestStatus& aStatus ) |
906 TRequestStatus& aStatus, |
|
907 const TArray<TRtpCSRC> *aCsrcList ) |
864 { |
908 { |
865 CRtpSession* rtpSession = GetSession( aTranStreamId ); |
909 CRtpSession* rtpSession = GetSession( aTranStreamId ); |
866 TInt result( KErrNone ); |
910 TInt result( KErrNone ); |
867 if ( rtpSession ) |
911 if ( rtpSession ) |
868 { |
912 { |
872 { |
916 { |
873 |
917 |
874 result = static_cast<CRtpSessionSrtp*> |
918 result = static_cast<CRtpSessionSrtp*> |
875 (rtpSession)->SendRtpPacket( aTranStreamId, aSequenceNum, |
919 (rtpSession)->SendRtpPacket( aTranStreamId, aSequenceNum, |
876 aHeaderInfo, aPayloadData, |
920 aHeaderInfo, aPayloadData, |
877 aStatus ); |
921 aStatus, aCsrcList ); |
878 |
922 |
879 } |
923 } |
880 else |
924 else |
881 { |
925 { |
882 result = rtpSession->SendRtpPacket( aTranStreamId, aSequenceNum, |
926 result = rtpSession->SendRtpPacket( aTranStreamId, aSequenceNum, |
883 aHeaderInfo, aPayloadData, |
927 aHeaderInfo, aPayloadData, |
884 aStatus ); |
928 aStatus, aCsrcList ); |
885 } |
929 } |
886 |
930 |
887 } |
931 } |
888 else |
932 else |
889 { |
933 { |