--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/multimediacommsengine/mmcecli/src/mcestreambundle.cpp	Tue Feb 02 01:04:58 2010 +0200
@@ -0,0 +1,260 @@
+/*
+* 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 "mcestreambundle.h"
+#include "mcesession.h"
+#include "mcecomstreambundle.h"
+#include "mcefactory.h"
+#include "mceserial.h"
+#include "mceendpointproxy.h"
+
+#define _FLAT_DATA static_cast<CMceComStreamBundle*>( iFlatData )
+#define FLAT_DATA( data ) _FLAT_DATA->data
+
+// ============================ MEMBER FUNCTIONS ===============================
+
+// -----------------------------------------------------------------------------
+// CMceStreamBundle::NewL
+// -----------------------------------------------------------------------------
+//
+EXPORT_C CMceStreamBundle* CMceStreamBundle::NewL( TMceStreamBundleType aType )
+    {
+    CMceStreamBundle* self = NewLC( aType );
+    CleanupStack::Pop( self );
+    return self;   
+    
+    }
+
+// -----------------------------------------------------------------------------
+// CMceStreamBundle::NewLC
+// -----------------------------------------------------------------------------
+//
+EXPORT_C CMceStreamBundle* CMceStreamBundle::NewLC( TMceStreamBundleType aType )
+    {
+    CMceStreamBundle* self = new (ELeave) CMceStreamBundle();
+    CleanupStack::PushL( self );
+    self->ConstructL( aType );
+    return self;
+    }
+     
+// -----------------------------------------------------------------------------
+// CMceStreamBundle::~CMceStreamBundle
+// -----------------------------------------------------------------------------
+//
+EXPORT_C CMceStreamBundle::~CMceStreamBundle()
+    {
+    delete iFlatData;
+    iStreams.Close();
+    iTempStreams.Close();
+    }
+
+// -----------------------------------------------------------------------------
+// CMceStreamBundle::Type
+// -----------------------------------------------------------------------------
+//
+EXPORT_C CMceStreamBundle::TMceStreamBundleType CMceStreamBundle::Type() const
+    {
+    return FLAT_DATA( Type() );
+    }
+    
+// -----------------------------------------------------------------------------
+// CMceStreamBundle::AddStreamL
+// -----------------------------------------------------------------------------
+//
+EXPORT_C void CMceStreamBundle::AddStreamL( CMceMediaStream& aStream )
+    {
+    iStreams.AppendL( &aStream );
+    }
+        
+// -----------------------------------------------------------------------------
+// CMceStreamBundle::RemoveStreamL
+// -----------------------------------------------------------------------------
+//
+EXPORT_C void CMceStreamBundle::RemoveStreamL( CMceMediaStream& aStream )
+    {
+    TInt index = iStreams.Find( &aStream );
+    User::LeaveIfError( index );
+    iStreams.Remove( index );
+    }
+        
+// -----------------------------------------------------------------------------
+// CMceStreamBundle::Streams
+// -----------------------------------------------------------------------------
+//
+EXPORT_C const RPointerArray< CMceMediaStream >& CMceStreamBundle::Streams()
+    {
+    return iStreams;
+    }
+     
+// -----------------------------------------------------------------------------
+// CMceStreamBundle::SerializationId
+// -----------------------------------------------------------------------------
+//
+TUint64 CMceStreamBundle::SerializationId() const
+    {
+    return FLAT_DATA( SerializationId() );
+    }
+     
+// -----------------------------------------------------------------------------
+// CMceStreamBundle::InternalizeFlatL
+// -----------------------------------------------------------------------------
+//
+void CMceStreamBundle::InternalizeFlatL( RReadStream& aReadStream )
+    {
+    __ASSERT_ALWAYS( iFlatData , User::Leave( KErrNotReady ) );
+    _FLAT_DATA->InternalizeFlatL( aReadStream );
+    
+    }
+
+// -----------------------------------------------------------------------------
+// CMceStreamBundle::ExternalizeFlatL
+// -----------------------------------------------------------------------------
+//
+void CMceStreamBundle::ExternalizeFlatL( RWriteStream& aWriteStream )
+    {
+    __ASSERT_ALWAYS( iFlatData , User::Leave( KErrNotReady ) );
+    _FLAT_DATA->ExternalizeFlatL( aWriteStream );
+    }
+     
+
+// -----------------------------------------------------------------------------
+// CMceStreamBundle::InternalizeL
+// -----------------------------------------------------------------------------
+//
+void CMceStreamBundle::InternalizeL( MMceComSerializationContext& aSerCtx )
+    {
+    __ASSERT_ALWAYS( iSession, User::Leave( KErrArgument ) );
+    
+    RReadStream& readStream = aSerCtx.ReadStream();
+
+    InternalizeFlatL( readStream );
+
+    TUint32 i = 0;
+    TInt j = 0;
+    TMceMediaId streamId;
+
+    TUint32 streamCount = readStream.ReadUint32L();
+    for( i = 0; i<streamCount; i++)
+        {
+        MceSerial::DecodeL( streamId, readStream );
+        for( j = 0; j < iSession->Streams().Count();j++ )
+            {
+            CMceMediaStream* stream = iSession->Streams()[ j ];
+            if ( stream->Id() == streamId )
+                {
+                AddStreamL( *stream );
+                }
+            }
+        }
+
+    }
+
+// -----------------------------------------------------------------------------
+// CMceStreamBundle::ExternalizeL
+// -----------------------------------------------------------------------------
+//
+void CMceStreamBundle::ExternalizeL( MMceComSerializationContext& aSerCtx )
+    {
+    RWriteStream& writeStream = aSerCtx.WriteStream();
+    
+    ExternalizeFlatL( writeStream );
+    
+	writeStream.WriteUint32L( iStreams.Count() );
+	for( TInt i = 0;i<iStreams.Count();i++)
+	    {
+        MceSerial::EncodeL( iStreams[ i ]->Id(), writeStream );
+    	}
+
+    }
+        
+
+// -----------------------------------------------------------------------------
+// CMceStreamBundle::AddedL
+// -----------------------------------------------------------------------------
+//
+void CMceStreamBundle::AddedL()
+    {
+    MMceEndPointProxy* proxy = NULL;
+    CMceMediaSink* endpoint = NULL;
+    TInt i = 0;
+
+    //sinks
+    for( i = 0; i< iStreams.Count(); i++ )
+        {
+        
+        CMceMediaStream* stream = iStreams[ i ];
+        AddedSinkL( *stream, endpoint, proxy );
+        if ( stream->BoundStream() )
+            {
+            AddedSinkL( stream->BoundStreamL(), endpoint, proxy );
+            }
+        }
+
+    }
+
+
+// -----------------------------------------------------------------------------
+// CMceStreamBundle::AddedSinkL
+// -----------------------------------------------------------------------------
+//
+void CMceStreamBundle::AddedSinkL( CMceMediaStream& aStream,
+                                   CMceMediaSink*& aCurrentSink,
+                                   MMceEndPointProxy*& aProxy )
+
+    {
+    
+    for( TInt j=0; j < aStream.Sinks().Count(); j++ )
+        {
+        aProxy = aCurrentSink ? aCurrentSink->EndpointProxy() : aProxy;
+        aCurrentSink = aStream.Sinks()[ j ];
+        aCurrentSink->SetupEndpointProxyL( aProxy );
+        }
+    }
+
+ 
+ 
+// -----------------------------------------------------------------------------
+// CMceStreamBundle::InitializeL
+// -----------------------------------------------------------------------------
+//
+void CMceStreamBundle::InitializeL( CMceSession& aParent )
+    {
+    iSession = &aParent;
+    }
+    
+// -----------------------------------------------------------------------------
+// CMceStreamBundle::CMceStreamBundle
+// -----------------------------------------------------------------------------
+//
+CMceStreamBundle::CMceStreamBundle()
+    {
+    }
+
+// -----------------------------------------------------------------------------
+// CMceStreamBundle::ConstructL
+// -----------------------------------------------------------------------------
+//
+void CMceStreamBundle::ConstructL( CMceStreamBundle::TMceStreamBundleType aType )
+    {
+    
+    iFlatData = CMceComStreamBundle::NewL( aType );
+    
+    }
+