--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/multimediacommsengine/tsrc/MMCTestDriver/MCETester/src/TCmdAddVideoStream.cpp	Tue Feb 02 01:04:58 2010 +0200
@@ -0,0 +1,238 @@
+/*
+* 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:    Implementation
+*
+*/
+
+
+
+#include "MCEConstants.h"
+#include "TCmdAddVideoStream.h"
+#include "CTcMCEContext.h"
+
+#include <badesca.h>
+#include <MceInSession.h>
+#include <MCEVideoStream.h>
+#include <mcecamerasource.h>
+#include <MceRtpSink.h>
+#include <MceRtpSource.h>
+#include <mcedisplaysink.h>
+#include <MCEVideoCodec.h>
+#include <mceh263codec.h>
+#include <mcefilesource.h>
+
+void TCmdAddVideoStream::ExecuteL()
+	{	
+
+	// ---------- Setup --------------------------------------------------------
+
+	// Get session
+	CMceSession* session = reinterpret_cast<CMceSession*>
+		(GetObjectForIdL(KSessionId, ETrue));	
+
+	// Get existing stream
+	CMceMediaStream* mainStream = reinterpret_cast<CMceMediaStream*>
+		(GetObjectForIdL(KStreamId, EFalse));	
+
+	//source path for audiofile
+	TPtrC8 pathAudioFile = ExtractTextL( KParamAudioFileSource, EFalse );
+	
+	//get path for media file sink
+	TPtrC8 mediaFileSink = ExtractTextL( KParamMediaFileSink, EFalse );
+	// ---------- Execution ----------------------------------------------------
+
+	CMceVideoStream* videoStream = CMceVideoStream::NewLC();
+	
+	
+	// Add source
+	TPtrC8 source = ExtractTextL( KParamSource, EFalse );
+	if (source == KValueSourceRTP )
+		{
+		CMceRtpSource* rtpSource = CMceRtpSource::NewLC();
+		videoStream->SetSourceL(rtpSource);
+		CleanupStack::Pop(rtpSource);			
+		}
+	else if (source == KValueSourceCamera )
+		{
+		CMceCameraSource* camera = CMceCameraSource::NewLC( iContext.MCEManager() );
+		videoStream->SetSourceL(camera);	
+		CleanupStack::Pop(camera);
+		}
+	else if (pathAudioFile.Compare( KNullDesC8 ) != 0)
+		{
+
+		// If source path was defined use the file audio specified in path
+		iSessionHelper.SetMediaFileSourceL( iContext.MCEManager(), *videoStream, pathAudioFile );		
+		}
+    else
+	    {
+	    if( mediaFileSink.Compare( KNullDesC8 ) == 0 )
+	    	User::Leave( KErrNotSupported );
+	    }	
+
+		
+	// Add sinks
+	CDesC8Array* sinks = ExtractArrayL( KParamSinks, EFalse );
+
+	if ( sinks )
+		{	
+		CleanupStack::PushL( sinks );
+		for ( TInt i = 0; i < sinks->Count(); i++ )
+			{
+			if ( (*sinks)[i] == KValueSinkRTP )
+				{
+				//CMceRtpSink* rtpSink = CMceRtpSink::NewLC();
+				//enable all RtpSink with RTCP
+				CMceRtpSink* rtpSink = CMceRtpSink::NewL(EFalse);
+				CleanupStack::PushL(rtpSink);
+				videoStream->AddSinkL(rtpSink);
+				CleanupStack::Pop(rtpSink);
+				}
+			else if ( (*sinks)[i] == KValueSinkSpeaker )
+				{
+				CMceDisplaySink* display = CMceDisplaySink::NewLC( iContext.MCEManager() );	
+				videoStream->AddSinkL(display);
+				CleanupStack::Pop(display);				
+				}
+			else if ( (*sinks)[i] == KValueSinkFile )
+				{				
+				const RPointerArray<CMceMediaStream>& streams = session->Streams();				
+				for ( TInt i = 0; i < streams.Count(); ++i )
+			        {        
+			        CMceMediaStream* tmpStream;
+			        tmpStream = streams[i];        
+					if ( tmpStream->Type() == KMceVideo )
+						{
+						//use the same source which was used for outgoing video stream	
+						if( tmpStream->Source()->Type() != KMceRTPSource )
+							{
+							videoStream->SetSourceL( tmpStream->Source() );
+							}
+						else
+							{
+							if( tmpStream->BoundStream() )
+								if( tmpStream->BoundStreamL().Source()->Type() != KMceRTPSource )
+									videoStream->SetSourceL(tmpStream->BoundStreamL().Source());
+							}			
+						break;	//only one file sink can be added for testing
+						}			        	
+			        }
+				if( mediaFileSink.Compare( KNullDesC8 ) != 0 )
+					{
+					iSessionHelper.SetMediaFileSinkL(*videoStream, mediaFileSink);
+					}
+				else
+					{
+					iSessionHelper.SetMediaFileSinkL(*videoStream, TPtrC8( KTestAudioFileName ));
+					}
+				session->AddStreamL(videoStream);
+				}
+	        else
+	            {
+	            User::Leave( KErrNotSupported );
+	            }
+			}
+		CleanupStack::PopAndDestroy( sinks );
+		}
+
+		
+	// Modify codecs
+	CDesC8Array* codecs = ExtractArrayL( KParamCodecs, EFalse );
+	
+	if ( codecs )
+		{
+		CleanupStack::PushL( codecs );
+		if ( codecs->Count() > 0)
+			{
+			const RPointerArray<CMceVideoCodec>& streamCodecs = 
+			    videoStream->Codecs();
+			
+			if ( (*codecs)[0] == KValueCodecNone )
+				{
+			    // Remove all codecs from stream
+                for (TInt i = 0; i < streamCodecs.Count(); i++ )
+                    {
+                    // No implementation yet in MMCE
+                    videoStream->RemoveCodecL( *(streamCodecs[i]) );
+                    }
+				}
+				
+			if ( (*codecs)[0] != KValueCodecNone &&
+	 		   	 (*codecs)[0] != KValueCodecAll )
+				{	
+				for (TInt i = 0; i < codecs->Count(); i++ )
+					{
+					videoStream->AddCodecL( 
+					    GetVideoCodecCloneL( (*codecs)[i] ) );
+					}
+				
+				}
+			}
+		CleanupStack::PopAndDestroy( codecs );
+		}
+	
+	// Add streams
+	if (mainStream)
+		{
+		mainStream->BindL( videoStream );
+		//if there are no codecs in the stream already, all the codecs will be
+		//added to stream by mce.
+		//Note: streams needs to be bound before adding stream to session
+		session->AddStreamL( mainStream );
+		}
+	else
+		{
+		//NOOP	
+		}
+	
+	CleanupStack::Pop( videoStream );
+	
+	// ---------- Response creation --------------------------------------------
+ 
+	AddIdResponseL(KSessionId, session); // uses CleanupStack internally
+	AddIdResponseL(KStreamId, *videoStream); 
+	
+	}
+	
+TBool TCmdAddVideoStream::Match( const TTcIdentifier& aId )
+	{
+	return TTcMceCommandBase::Match( aId, _L8("AddVideoStream") );
+	}
+
+TTcCommandBase* TCmdAddVideoStream::CreateL( MTcTestContext& aContext )
+	{
+	return new( ELeave ) TCmdAddVideoStream( aContext );
+	}
+	
+	
+CMceVideoCodec* TCmdAddVideoStream::GetVideoCodecCloneL( const TDesC8& aParamCodecName )
+    {
+    
+    const RPointerArray<const CMceVideoCodec>& managerVideoCodecs =
+        iContext.MCEManager().SupportedVideoCodecs();
+    for ( TInt i = 0; i < managerVideoCodecs.Count(); i++ )
+        {
+        const CMceVideoCodec* managerVideoCodec = managerVideoCodecs[i];
+        
+        if ( managerVideoCodec->SdpName() == aParamCodecName )
+            {
+            return managerVideoCodec->CloneL();
+            }
+        
+        }
+    
+    // If the requested codec is not supported
+    User::Leave( KErrNotSupported );
+    return NULL; // To keep compiler happy
+    }