diff -r dec420019252 -r cf5481c2bc0b videocollection/mpxmyvideoscollection/src/vcxmyvideosmdscmdqueue.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/videocollection/mpxmyvideoscollection/src/vcxmyvideosmdscmdqueue.cpp	Fri Apr 16 14:59:52 2010 +0300
@@ -0,0 +1,231 @@
+/*
+* Copyright (c) 2007 Nokia Corporation and/or its subsidiary(-ies).
+* All rights reserved.
+* This component and the accompanying materials are made available
+* under the terms of the License "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:  Queues commands to MDS.
+*
+*/
+
+
+// INCLUDE FILES
+#include <e32base.h>
+#include <mpxlog.h>
+#include "vcxmyvideosmdscmdqueue.h"
+#include "vcxmyvideosmdsdb.h"
+#include "vcxmyvideosmdsalbums.h"
+
+
+// ============================ MEMBER FUNCTIONS =============================
+
+// ---------------------------------------------------------------------------
+// Constructor
+// ---------------------------------------------------------------------------
+//
+CVcxMyVideosMdsCmdQueue::CVcxMyVideosMdsCmdQueue( CVcxMyVideosMdsDb& aMdsDb )
+: iMdsDb( aMdsDb )
+    {
+    }
+
+// ---------------------------------------------------------------------------
+// 2nd-phase constructor
+// ---------------------------------------------------------------------------
+//
+void CVcxMyVideosMdsCmdQueue::ConstructL()
+    {
+    iQueue.Reset();    
+    }
+
+// ---------------------------------------------------------------------------
+// Two-Phase Constructor
+// ---------------------------------------------------------------------------
+//
+CVcxMyVideosMdsCmdQueue* CVcxMyVideosMdsCmdQueue::NewL( CVcxMyVideosMdsDb& aMdsDb )
+    {
+    CVcxMyVideosMdsCmdQueue* self = new(ELeave) CVcxMyVideosMdsCmdQueue( aMdsDb );
+    CleanupStack::PushL( self );
+    self->ConstructL();
+    CleanupStack::Pop( self );
+    return self;
+    }
+
+// ---------------------------------------------------------------------------
+// Destructor
+// ---------------------------------------------------------------------------
+//
+CVcxMyVideosMdsCmdQueue::~CVcxMyVideosMdsCmdQueue()
+    {
+    for ( TInt i = 0; i < iQueue.Count(); i++ )
+        {
+        delete iQueue[i];
+        }
+    iQueue.Close();
+    }
+
+// ---------------------------------------------------------------------------
+// CVcxMyVideosMdsCmdQueue::Cancel
+// ---------------------------------------------------------------------------
+//
+void CVcxMyVideosMdsCmdQueue::Cancel( CVcxMyVideosMdsDb::TRequestType aType )
+    {
+    TInt count = iQueue.Count()-1;
+    for ( TInt i = count; i >= 0; i-- )
+        {
+        if ( iQueue[i]->iCmdType == aType || aType == CVcxMyVideosMdsDb::EAll )
+            {
+            delete iQueue[i];
+            iQueue[i] = NULL;
+            iQueue.Remove( i );
+            }
+        }    
+    iQueue.Compress();
+    }
+
+// ---------------------------------------------------------------------------
+// CVcxMyVideosMdsCmdQueue::ExecuteCmdL
+// ---------------------------------------------------------------------------
+//
+void CVcxMyVideosMdsCmdQueue::ExecuteCmdL( CVcxMyVideosMdsCmd* aCmd )
+    {    
+    if ( iQueue.Count() == 0 && !iCmdInProgress )
+        {
+        DoExecuteCmdL( aCmd ); //ownership does not move
+        delete aCmd;
+        }
+    else
+        {
+        iQueue.AppendL( aCmd );
+        }    
+    }
+    
+// ---------------------------------------------------------------------------
+// CVcxMyVideosMdsCmdQueue::CmdFinished
+// ---------------------------------------------------------------------------
+//
+void CVcxMyVideosMdsCmdQueue::CmdFinished()
+    {
+    iCmdInProgress = EFalse;
+
+    TInt err( KErrGeneral );
+    while ( err != KErrNone )
+        {
+        if ( iQueue.Count() == 0 )
+            {
+            break;
+            }
+                            
+        TInt cmdIndexToExecute;
+        // Let other commads bypass EGetVideoList
+        if ( iQueue.Count() > 1 && iQueue[0]->iCmdType == CVcxMyVideosMdsDb::EGetVideoList )
+            {
+            cmdIndexToExecute = 1;
+            }
+        else
+            {
+            cmdIndexToExecute = 0;
+            }
+        TRAP( err, DoExecuteCmdL( iQueue[cmdIndexToExecute] ) ); //ownership does not move
+        delete iQueue[cmdIndexToExecute];
+        iQueue[cmdIndexToExecute] = NULL;
+        iQueue.Remove( cmdIndexToExecute );
+        iQueue.Compress();
+        
+#ifdef _DEBUG
+        if ( err != KErrNone )
+            {
+            MPX_DEBUG2("CVcxMyVideosMdsCmdQueue:: MDS cmd failed: %d", err);
+            }
+#endif
+        }
+    }
+
+// ---------------------------------------------------------------------------
+// CVcxMyVideosMdsCmdQueue::DoExecuteCmdL
+// ---------------------------------------------------------------------------
+//
+void CVcxMyVideosMdsCmdQueue::DoExecuteCmdL( CVcxMyVideosMdsCmd* aCmd )
+    {    
+    switch ( aCmd->iCmdType )
+        {
+        case CVcxMyVideosMdsDb::EGetVideoList:
+            {
+            CVcxMyVideosMdsCmdGetVideoList* cmd =
+                    static_cast<CVcxMyVideosMdsCmdGetVideoList*>( aCmd );
+            iMdsDb.DoCreateVideoListL( cmd->iSortingOrder,
+                    cmd->iAscending,
+                    cmd->iFullDetails,
+                    *cmd->iVideoList );
+            iCmdInProgress = ETrue;
+            }
+            break;
+        
+        case CVcxMyVideosMdsDb::EGetAlbums:
+            {
+            CVcxMyVideosMdsCmdGetAlbums* cmd = static_cast<CVcxMyVideosMdsCmdGetAlbums*>( aCmd );
+            iMdsDb.iAlbums->DoGetAlbumsL( cmd->iAlbumList, *cmd->iClient );
+            iCmdInProgress = ETrue;
+            }
+            break;
+
+        case CVcxMyVideosMdsDb::EGetAlbumContentIds:
+            {
+            CVcxMyVideosMdsCmdGetAlbumContentIds* cmd =
+                    static_cast<CVcxMyVideosMdsCmdGetAlbumContentIds*>( aCmd );
+            iMdsDb.iAlbums->DoGetAlbumContentIdsL( cmd->iAlbumId, *cmd->iAlbumContent,
+                    *cmd->iClient );
+            iCmdInProgress = ETrue;
+            }
+            break;
+
+        case CVcxMyVideosMdsDb::EGetAlbumContentVideos:
+            {
+            CVcxMyVideosMdsCmdGetAlbumContentVideos* cmd =
+                    static_cast<CVcxMyVideosMdsCmdGetAlbumContentVideos*>( aCmd );
+            iMdsDb.iAlbums->DoGetAlbumContentVideosL( cmd->iAlbumId, *cmd->iAlbumContentVideos,
+                    *cmd->iClient );
+            iCmdInProgress = ETrue;
+            }
+            break;
+            
+        case CVcxMyVideosMdsDb::EAddVideosToAlbum:
+            {
+            CVcxMyVideosMdsCmdAddVideosToAlbum* cmd =
+                    static_cast<CVcxMyVideosMdsCmdAddVideosToAlbum*>( aCmd );
+            iMdsDb.iAlbums->DoAddVideosToAlbumL( cmd->iMpxCmd,
+                    *cmd->iClient );
+            iCmdInProgress = ETrue;
+            }
+            break;
+
+        case CVcxMyVideosMdsDb::ERemoveRelations:
+            {
+            CVcxMyVideosMdsCmdRemoveRelations* cmd =
+                    static_cast<CVcxMyVideosMdsCmdRemoveRelations*>( aCmd );
+            iMdsDb.iAlbums->DoRemoveRelationsL( *cmd->iRelationIds, *cmd->iResults,
+                    *cmd->iClient );
+            iCmdInProgress = ETrue;
+            }
+            break;
+            
+        case CVcxMyVideosMdsDb::ERemoveAlbums:
+            {
+            CVcxMyVideosMdsCmdRemoveAlbums* cmd =
+                    static_cast<CVcxMyVideosMdsCmdRemoveAlbums*>( aCmd );
+            iMdsDb.iAlbums->DoRemoveAlbumsL( cmd->iMpxCmd, *cmd->iClient );
+            iCmdInProgress = ETrue;
+            }
+            break;
+
+        default:
+            break;
+        }    
+    }    
+// END OF FILE