--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/multimediacommsengine/mmceshared/src/mcecomvideostream.cpp Tue Feb 02 01:04:58 2010 +0200
@@ -0,0 +1,605 @@
+/*
+* Copyright (c) 2005 Nokia Corporation and/or its subsidiary(-ies).
+* All rights reserved.
+* This component and the accompanying materials are made available
+* under the terms of "Eclipse Public License v1.0"
+* which accompanies this distribution, and is available
+* at the URL "http://www.eclipse.org/legal/epl-v10.html".
+*
+* Initial Contributors:
+* Nokia Corporation - initial contribution.
+*
+* Contributors:
+*
+* Description:
+*
+*/
+
+
+
+
+#include "mcevideostream.h"
+#include "mcecomvideostream.h"
+#include "mcecomvideocodec.h"
+#include "mcecommediasource.h"
+#include "mcecommediasink.h"
+#include "mceserial.h"
+#include "mceevents.h"
+#include "cleanupresetanddestroy.h"
+
+
+// ============================ MEMBER FUNCTIONS ===============================
+
+
+// -----------------------------------------------------------------------------
+// CMceComVideoStream::NewL
+// -----------------------------------------------------------------------------
+//
+CMceComVideoStream* CMceComVideoStream::NewL()
+ {
+ CMceComVideoStream* self = NewLC();
+ CleanupStack::Pop( self );
+ return self;
+ }
+
+// -----------------------------------------------------------------------------
+// CMceComVideoStream::NewLC
+// -----------------------------------------------------------------------------
+//
+CMceComVideoStream* CMceComVideoStream::NewLC()
+ {
+ CMceComVideoStream* self = new (ELeave) CMceComVideoStream();
+ CleanupStack::PushL( self );
+ self->ConstructL();
+ return self;
+ }
+
+
+// -----------------------------------------------------------------------------
+// CMceComVideoStream::~CMceComVideoStream
+// -----------------------------------------------------------------------------
+//
+CMceComVideoStream::~CMceComVideoStream()
+ {
+ iCodecs.ResetAndDestroy();
+ }
+
+
+// -----------------------------------------------------------------------------
+// CMceComVideoStream::CMceComVideoStream
+// -----------------------------------------------------------------------------
+//
+CMceComVideoStream::CMceComVideoStream()
+ :CMceComMediaStream( KMceVideo )
+ {
+ }
+
+
+// -----------------------------------------------------------------------------
+// CMceComVideoStream::AddCodecL
+// -----------------------------------------------------------------------------
+//
+void CMceComVideoStream::AddCodecL( CMceComCodec* aCodec )
+ {
+ __ASSERT_ALWAYS( aCodec, User::Leave( KErrArgument ) );
+
+ CMceComVideoCodec* codec = static_cast< CMceComVideoCodec* >( aCodec );
+ iCodecs.AppendL( codec );
+ }
+
+
+// -----------------------------------------------------------------------------
+// CMceComVideoStream::RemoveCodecL
+// -----------------------------------------------------------------------------
+//
+void CMceComVideoStream::RemoveCodecL( CMceComCodec* aCodec )
+ {
+ TInt index = FindCodecFromList( aCodec );
+
+ if ( index >= 0 )
+ {
+ RemoveCodecFromListL( index );
+ }
+
+ delete aCodec;
+ }
+
+
+// -----------------------------------------------------------------------------
+// CMceComVideoStream::CodecL
+// -----------------------------------------------------------------------------
+//
+CMceComVideoCodec* CMceComVideoStream::CodecL( TInt aIndex ) const
+ {
+ __ASSERT_ALWAYS( aIndex >= 0 && aIndex < iCodecs.Count(),
+ User::Leave( KErrArgument ) );
+
+ return iCodecs[aIndex];
+ }
+
+
+// -----------------------------------------------------------------------------
+// CMceComVideoStream::CodecCount
+// -----------------------------------------------------------------------------
+//
+TInt CMceComVideoStream::CodecCount() const
+ {
+ return iCodecs.Count();
+ }
+
+// -----------------------------------------------------------------------------
+// CMceComVideoStream::Codecs
+// -----------------------------------------------------------------------------
+//
+const RPointerArray<CMceComVideoCodec>& CMceComVideoStream::Codecs() const
+ {
+ return iCodecs;
+ }
+
+
+// -----------------------------------------------------------------------------
+// CMceComVideoStream::FindCodecL
+// -----------------------------------------------------------------------------
+//
+CMceComCodec* CMceComVideoStream::FindCodecL( CMceComCodec& aCodec )
+ {
+ CMceComCodec* foundCodec = NULL;
+ CMceComVideoCodec* codec = static_cast< CMceComVideoCodec* >( &aCodec );
+
+ TInt index = FindCodecFromList( codec );
+
+ if ( index == KErrNotFound )
+ {
+ const TInt codecCount = CodecCount();
+
+ for ( TInt i = 0; i < codecCount && !foundCodec; ++i )
+ {
+ // Video codec may be identified also based on fmtp
+ if ( CodecL( i )->Decodes( aCodec.iSdpName, aCodec.FmtpAttr() ) )
+ {
+ foundCodec = CodecL( i );
+ }
+ }
+ }
+ else
+ {
+ foundCodec = CodecL( index );
+ }
+
+ return foundCodec;
+ }
+
+
+// -----------------------------------------------------------------------------
+// CMceComVideoStream::FindCodecFromList
+// -----------------------------------------------------------------------------
+//
+TInt CMceComVideoStream::FindCodecFromList( CMceComCodec* aCodec ) const
+ {
+ CMceComVideoCodec* codec = static_cast< CMceComVideoCodec* >( aCodec );
+ return iCodecs.Find( codec );
+ }
+
+
+// -----------------------------------------------------------------------------
+// CMceComVideoStream::RemoveCodecFromListL
+// -----------------------------------------------------------------------------
+//
+void CMceComVideoStream::RemoveCodecFromListL( TInt aIndex )
+ {
+ __ASSERT_ALWAYS( aIndex >= 0 && aIndex < iCodecs.Count(),
+ User::Leave( KErrArgument ) );
+
+ iCodecs.Remove( aIndex );
+ }
+
+
+// -----------------------------------------------------------------------------
+// CMceComVideoStream::DestroyCodecs
+// -----------------------------------------------------------------------------
+//
+void CMceComVideoStream::DestroyCodecs()
+ {
+ iCodecs.ResetAndDestroy();
+ }
+
+
+// -----------------------------------------------------------------------------
+// CMceComVideoStream::InternalizeFlatL
+// -----------------------------------------------------------------------------
+//
+void CMceComVideoStream::InternalizeFlatL( RReadStream& aReadStream )
+ {
+ CMceComMediaStream::InternalizeFlatL( aReadStream );
+ }
+
+
+// -----------------------------------------------------------------------------
+// CMceComVideoStream::ExternalizeFlatL
+// -----------------------------------------------------------------------------
+//
+void CMceComVideoStream::ExternalizeFlatL( RWriteStream& aWriteStream )
+ {
+ CMceComMediaStream::ExternalizeFlatL( aWriteStream );
+ }
+
+
+// -----------------------------------------------------------------------------
+// CMceComVideoStream::InternalizeL
+// -----------------------------------------------------------------------------
+//
+void CMceComVideoStream::InternalizeL( MMceComSerializationContext& aSerCtx )
+ {
+ CMceComMediaStream::InternalizeL( aSerCtx );
+
+ TMceVideoStreamSerializer<CMceComVideoStream> serial( *this );
+ serial.InternalizeL( aSerCtx );
+
+ }
+
+// -----------------------------------------------------------------------------
+// CMceComVideoStream::ExternalizeL
+// -----------------------------------------------------------------------------
+//
+void CMceComVideoStream::ExternalizeL( MMceComSerializationContext& aSerCtx )
+ {
+
+ CMceComMediaStream::ExternalizeL( aSerCtx );
+
+ TMceVideoStreamSerializer<CMceComVideoStream> serial( *this );
+ serial.ExternalizeL( aSerCtx );
+
+ }
+
+// -----------------------------------------------------------------------------
+// CMceComVideoStream::CloneL
+// -----------------------------------------------------------------------------
+//
+CMceComMediaStream* CMceComVideoStream::CloneL()
+ {
+ CMceComVideoStream* copy = new (ELeave) CMceComVideoStream();
+ CleanupStack::PushL( copy );
+ copy->ConstructL( *this );
+ CleanupStack::Pop( copy );
+ return copy;
+ }
+
+// -----------------------------------------------------------------------------
+// CMceComVideoStream::ConstructL
+// -----------------------------------------------------------------------------
+//
+void CMceComVideoStream::ConstructL()
+ {
+
+ CMceComMediaStream::ConstructL();
+
+ }
+
+
+// -----------------------------------------------------------------------------
+// CMceComVideoStream::ConstructL
+// -----------------------------------------------------------------------------
+//
+void CMceComVideoStream::ConstructL( CMceComVideoStream& aStream )
+ {
+ CMceComMediaStream::ConstructL( aStream );
+
+ const TInt codecCount = aStream.CodecCount();
+
+ for ( TInt i = 0; i < codecCount ; ++i )
+ {
+ CMceComVideoCodec* codec = aStream.CodecL( i )->CloneL();
+ CleanupStack::PushL( codec );
+ AddCodecL( codec );
+ CleanupStack::Pop( codec );
+ }
+
+ }
+
+
+// -----------------------------------------------------------------------------
+// CMceComVideoStream::ConstructL
+// -----------------------------------------------------------------------------
+//
+void CMceComVideoStream::InitializeL( CMceComSession& aParent )
+ {
+ CMceComMediaStream::InitializeL( aParent );
+
+ const TInt codecCount = CodecCount();
+
+ for ( TInt i = 0; i < codecCount ; ++i )
+ {
+ CodecL( i )->InitializeL( *this );
+ }
+ }
+
+
+
+
+// -----------------------------------------------------------------------------
+// CMceComVideoStream::UpdateL
+// -----------------------------------------------------------------------------
+//
+void CMceComVideoStream::UpdateL( CMceComMediaStream& aStream )
+ {
+ CMceComMediaStream::UpdateL( aStream );
+
+ CMceComVideoStream* stream = static_cast< CMceComVideoStream* >( &aStream );
+
+ RPointerArray<CMceComVideoCodec> updated;
+
+ MceCleanupResetAndDestroyPushL( updated );
+
+ for( TInt i = 0; i < stream->CodecCount() ; ++i )
+ {
+ CMceComVideoCodec* update = stream->CodecL( i );
+ TBool isUpdated = EFalse;
+ TInt j = 0;
+
+ while( !isUpdated && j < CodecCount() )
+ {
+ CMceComVideoCodec* codec = CodecL( j );
+
+ if ( codec->Id() == update->Id() )
+ {
+ codec->UpdateL( *update );
+ stream->RemoveCodecFromListL( i );
+ delete update;
+ updated.AppendL( codec );
+ RemoveCodecFromListL( j );
+ i--;
+ isUpdated = ETrue;
+ }
+ j++;
+ }
+ }
+
+ if ( CodecCount() > 0 ) // Codecs have been removed
+ {
+ Session()->IsStructureChanged() = ETrue;
+ }
+
+ DestroyCodecs();
+
+ while( updated.Count() > 0 )
+ {
+ AddCodecL( updated[0] );
+ updated.Remove( 0 );
+ }
+
+ CleanupStack::PopAndDestroy(); // updated
+
+ if ( stream->CodecCount() > 0 ) // Streams have been added
+ {
+ Session()->IsStructureChanged() = ETrue;
+
+ while( stream->CodecCount() > 0 )
+ {
+ CMceComVideoCodec* add = stream->CodecL( 0 );
+ AddCodecL( add );
+ stream->RemoveCodecFromListL( 0 );
+ }
+ }
+
+ }
+
+
+// -----------------------------------------------------------------------------
+// CMceComVideoStream::ReorderCodecs
+// -----------------------------------------------------------------------------
+//
+void CMceComVideoStream::ReorderCodecs()
+ {
+ TLinearOrder<CMceComVideoCodec> order( CMceComVideoCodec::CompareSdpIndex );
+
+ iCodecs.Sort( order );
+ }
+
+
+#ifdef MCE_COMMON_SERVER_SIDE
+
+// -----------------------------------------------------------------------------
+// CMceComVideoStream::SynchronizeL
+// -----------------------------------------------------------------------------
+//
+void CMceComVideoStream::SynchronizeL( TBool aRoleAnswerer )
+ {
+ TInt codecIndex( 0 );
+
+ while ( codecIndex < CodecCount() )
+ {
+ CMceComCodec& codec = *CodecL( codecIndex );
+
+ TBool remove( !codec.iIsNegotiated && aRoleAnswerer );
+
+ if ( BoundStream() )
+ {
+ CMceComCodec* sync = BoundStreamL().FindCodecL( codec );
+
+ if ( remove )
+ {
+ BoundStreamL().RemoveCodecL( sync );
+ }
+ else if ( sync )
+ {
+ sync->SynchronizeL( codec, aRoleAnswerer );
+ }
+ else if ( aRoleAnswerer )
+ {
+ MCE_DEFINE_VIDEO_CODEC( videoCodec, codec );
+ CMceComVideoCodec* copy = videoCodec.CloneL();
+ CleanupStack::PushL( copy );
+ copy->InitializeL( BoundStreamL() );
+ MCE_VIDEO( BoundStreamL() ).AddCodecL( copy );
+ CleanupStack::Pop( copy );
+ copy->SynchronizeL( codec, aRoleAnswerer );
+ }
+ else
+ {
+ //NOP
+ }
+ }
+
+ if ( remove )
+ {
+ RemoveCodecL( &codec );
+ }
+ else
+ {
+ codecIndex++;
+ }
+ }
+ }
+
+// -----------------------------------------------------------------------------
+// CMceComAudioStream::UpdateDefaultCodecL
+// -----------------------------------------------------------------------------
+//
+void CMceComVideoStream::UpdateDefaultCodecL()
+ {
+ CMceComCodec* highestPrioritySendCodec = NULL;
+ CMceComCodec* codec = NULL;
+
+ const RPointerArray< CMceComCodec >& allCodecs =
+ reinterpret_cast< const RPointerArray< CMceComCodec >& >( Codecs() );
+
+ CMceComCodec::TIterator codecs( allCodecs,
+ CMceComCodec::TIterator::EFilterIsNegotiated );
+
+ MCE_ITERATOR_FIND_NEXT( codecs, highestPrioritySendCodec,
+ highestPrioritySendCodec->SendSupported() );
+
+ // If no negotiated send codecs, disable all.
+ // If send codec changed, enable new one and disable other send codecs.
+ if ( !highestPrioritySendCodec ||
+ ( highestPrioritySendCodec &&
+ !highestPrioritySendCodec->iIsEnabled ) )
+ {
+ CMceComCodec* newDefaultCodec = NULL;
+ codecs.Reset();
+ codecs.SetFilter( CMceComCodec::TIterator::EFilterNone );
+ while( codecs.Next( codec ) )
+ {
+ if ( !newDefaultCodec && codec->iIsNegotiated && codec->SendSupported() )
+ {
+ codec->SetEnabled( ETrue );
+ newDefaultCodec = codec;
+ }
+ else
+ {
+ codec->SetEnabled( EFalse );
+ }
+ }
+
+ // Enable also new codecs of associated local streams
+ UpdateDefaultCodecForAssociatedLocalL( newDefaultCodec );
+ }
+ }
+
+// -----------------------------------------------------------------------------
+// CMceComVideoStream::UpdateDefaultCodecForAssociatedLocalL
+// -----------------------------------------------------------------------------
+//
+void CMceComVideoStream::UpdateDefaultCodecForAssociatedLocalL(
+ CMceComCodec* aNewDefaultCodec )
+ {
+ CMceComCodec* codec = NULL;
+ if ( aNewDefaultCodec && Session() )
+ {
+ for ( TInt i = 0; i < Session()->Streams().Count(); i++ )
+ {
+ if ( Session()->Streams()[ i ]->iType == KMceVideo )
+ {
+ CMceComVideoStream* videoStream = static_cast<CMceComVideoStream*>(
+ Session()->Streams()[ i ] );
+ const RPointerArray< CMceComCodec >& allCodecs =
+ reinterpret_cast< const RPointerArray< CMceComCodec >& >(
+ videoStream->Codecs() );
+
+ // Enabling
+ CMceComCodec::TIterator codecs( allCodecs,
+ CMceComCodec::TIterator::EFilterAssociatedLocal, aNewDefaultCodec );
+ while( codecs.Next( codec ) )
+ {
+ codec->SetEnabled( ETrue );
+ }
+
+ // Disabling
+ codecs.Reset();
+ while( codecs.Next( codec, CMceComCodec::TIterator::EOtherSdpName ) )
+ {
+ codec->SetEnabled( EFalse );
+ }
+ }
+ }
+ }
+ }
+
+// -----------------------------------------------------------------------------
+// CMceComVideoStream::PrepareL
+// -----------------------------------------------------------------------------
+//
+void CMceComVideoStream::PrepareL()
+ {
+ __ASSERT_ALWAYS ( CodecCount() > 0, User::Leave( KErrArgument ) );
+
+ if ( BoundStream() )
+ {
+ MCE_DEFINE_VIDEO( boundStream, BoundStreamL() );
+ __ASSERT_ALWAYS ( boundStream.CodecCount() > 0, User::Leave( KErrArgument ) );
+ }
+ }
+
+
+
+// -----------------------------------------------------------------------------
+// CMceComVideoStream::MccStreamType
+// -----------------------------------------------------------------------------
+//
+TInt CMceComVideoStream::MccStreamType() const
+ {
+
+ TInt type = KMccVideoLocalStream;
+
+ if ( iStreamType == EReceiveStream ||
+ iStreamType == EReceiveOnlyStream )
+ {
+ type = KMccVideoDownlinkStream;
+ }
+ else if ( iStreamType == ESendStream ||
+ iStreamType == ESendOnlyStream )
+ {
+ type = KMccVideoUplinkStream;
+ }
+ else
+ {
+ type = KMccVideoLocalStream;
+ }
+
+ return type;
+
+ }
+
+
+// -----------------------------------------------------------------------------
+// CMceComVideoStream::MccStreamType
+// -----------------------------------------------------------------------------
+//
+TInt CMceComVideoStream::MccLinkType() const
+ {
+ TInt type = KMccLinkGeneralVideo;
+
+ if ( iStreamType == ELocalStream )
+ {
+ type = KMccLinkLocal;
+ }
+
+ if (iSession->iClientCryptoSuites.Count()>0)
+ {
+ type =KMccLinkSecureVideo;
+ }
+
+ return type;
+ }
+
+#endif//MCE_COMMON_SERVER_SIDE