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 |
|
765 // --------------------------------------------------------------------------- |
724 // --------------------------------------------------------------------------- |
766 // CRtpManager::UnregisterRtpObserver() |
725 // CRtpManager::UnregisterRtpObserver() |
767 // |
726 // |
768 // --------------------------------------------------------------------------- |
727 // --------------------------------------------------------------------------- |
769 // |
728 // |
812 // |
771 // |
813 // --------------------------------------------------------------------------- |
772 // --------------------------------------------------------------------------- |
814 // |
773 // |
815 TInt CRtpManager::SendRtpPacket( TRtpId aTranStreamId, |
774 TInt CRtpManager::SendRtpPacket( TRtpId aTranStreamId, |
816 const TRtpSendHeader& aHeaderInfo, |
775 const TRtpSendHeader& aHeaderInfo, |
817 const TDesC8& aPayloadData, |
776 const TDesC8& aPayloadData ) |
818 const TArray<TRtpCSRC> *aCsrcList) |
|
819 { |
777 { |
820 CRtpSession* rtpSession = GetSession( aTranStreamId ); |
778 CRtpSession* rtpSession = GetSession( aTranStreamId ); |
821 |
779 |
822 if ( rtpSession ) |
780 if ( rtpSession ) |
823 { |
781 { |
826 if (rtpSession->IsSrtp()) |
784 if (rtpSession->IsSrtp()) |
827 { |
785 { |
828 |
786 |
829 return static_cast<CRtpSessionSrtp*> |
787 return static_cast<CRtpSessionSrtp*> |
830 (rtpSession)->SendRtpPacket( aTranStreamId, aHeaderInfo, |
788 (rtpSession)->SendRtpPacket( aTranStreamId, aHeaderInfo, |
831 aPayloadData, aCsrcList ); |
789 aPayloadData ); |
832 |
790 |
833 } |
791 } |
834 else |
792 else |
835 { |
793 { |
836 return rtpSession->SendRtpPacket( aTranStreamId, aHeaderInfo, |
794 return rtpSession->SendRtpPacket( aTranStreamId, aHeaderInfo, |
837 aPayloadData, aCsrcList ); |
795 aPayloadData ); |
838 } |
796 } |
839 } |
797 } |
840 else |
798 else |
841 { |
799 { |
842 return rtpSession->SendRtpPacket( aHeaderInfo, aPayloadData ); |
800 return rtpSession->SendRtpPacket( aHeaderInfo, aPayloadData ); |
855 // --------------------------------------------------------------------------- |
813 // --------------------------------------------------------------------------- |
856 // |
814 // |
857 TInt CRtpManager::SendRtpPacket( TRtpId aTranStreamId, |
815 TInt CRtpManager::SendRtpPacket( TRtpId aTranStreamId, |
858 const TRtpSendHeader& aHeaderInfo, |
816 const TRtpSendHeader& aHeaderInfo, |
859 const TDesC8& aPayloadData, |
817 const TDesC8& aPayloadData, |
860 TRequestStatus& aStatus, |
818 TRequestStatus& aStatus ) |
861 const TArray<TRtpCSRC> *aCsrcList) |
|
862 { |
819 { |
863 CRtpSession* rtpSession = GetSession( aTranStreamId ); |
820 CRtpSession* rtpSession = GetSession( aTranStreamId ); |
864 |
821 |
865 if ( rtpSession ) |
822 if ( rtpSession ) |
866 { |
823 { |
869 if (rtpSession->IsSrtp()) |
826 if (rtpSession->IsSrtp()) |
870 { |
827 { |
871 |
828 |
872 return static_cast<CRtpSessionSrtp*> |
829 return static_cast<CRtpSessionSrtp*> |
873 (rtpSession)->SendRtpPacket( aTranStreamId, aHeaderInfo, |
830 (rtpSession)->SendRtpPacket( aTranStreamId, aHeaderInfo, |
874 aPayloadData, aStatus, aCsrcList ); |
831 aPayloadData, aStatus ); |
875 |
832 |
876 } |
833 } |
877 else |
834 else |
878 { |
835 { |
879 return rtpSession->SendRtpPacket( aTranStreamId, aHeaderInfo, |
836 return rtpSession->SendRtpPacket( aTranStreamId, aHeaderInfo, |
880 aPayloadData, aStatus, aCsrcList ); |
837 aPayloadData, aStatus ); |
881 } |
838 } |
882 |
839 |
883 } |
840 } |
884 else |
841 else |
885 { |
842 { |
901 // |
858 // |
902 TInt CRtpManager::SendRtpPacket( TRtpId aTranStreamId, |
859 TInt CRtpManager::SendRtpPacket( TRtpId aTranStreamId, |
903 TRtpSequence aSequenceNum, |
860 TRtpSequence aSequenceNum, |
904 const TRtpSendHeader& aHeaderInfo, |
861 const TRtpSendHeader& aHeaderInfo, |
905 const TDesC8& aPayloadData, |
862 const TDesC8& aPayloadData, |
906 TRequestStatus& aStatus, |
863 TRequestStatus& aStatus ) |
907 const TArray<TRtpCSRC> *aCsrcList ) |
|
908 { |
864 { |
909 CRtpSession* rtpSession = GetSession( aTranStreamId ); |
865 CRtpSession* rtpSession = GetSession( aTranStreamId ); |
910 TInt result( KErrNone ); |
866 TInt result( KErrNone ); |
911 if ( rtpSession ) |
867 if ( rtpSession ) |
912 { |
868 { |
916 { |
872 { |
917 |
873 |
918 result = static_cast<CRtpSessionSrtp*> |
874 result = static_cast<CRtpSessionSrtp*> |
919 (rtpSession)->SendRtpPacket( aTranStreamId, aSequenceNum, |
875 (rtpSession)->SendRtpPacket( aTranStreamId, aSequenceNum, |
920 aHeaderInfo, aPayloadData, |
876 aHeaderInfo, aPayloadData, |
921 aStatus, aCsrcList ); |
877 aStatus ); |
922 |
878 |
923 } |
879 } |
924 else |
880 else |
925 { |
881 { |
926 result = rtpSession->SendRtpPacket( aTranStreamId, aSequenceNum, |
882 result = rtpSession->SendRtpPacket( aTranStreamId, aSequenceNum, |
927 aHeaderInfo, aPayloadData, |
883 aHeaderInfo, aPayloadData, |
928 aStatus, aCsrcList ); |
884 aStatus ); |
929 } |
885 } |
930 |
886 |
931 } |
887 } |
932 else |
888 else |
933 { |
889 { |