--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/menufw/hierarchynavigator/hnmetadatamodel/src/hnqueryresultcollector.cpp	Thu Dec 17 08:40:49 2009 +0200
@@ -0,0 +1,234 @@
+/*
+* Copyright (c) 2007-2008 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 <liwservicehandler.h>
+
+#include "hnqueryresultcollector.h"
+#include "hnmdquery.h"
+#include "hnmdqueries.h"
+#include "hnconvutils.h"
+#include "hnservicehandler.h"
+#include "hnmdservice.h"
+#include "hnmdservicecommand.h"
+
+using namespace LIW;
+
+// ---------------------------------------------------------------------------
+//
+// ---------------------------------------------------------------------------
+//
+CHnQueryResultCollector* CHnQueryResultCollector::NewL(
+		const CHnMdQueries& aQueries , const CLiwGenericParamList& aParams )
+	{
+	CHnQueryResultCollector* self = NewLC( aQueries , aParams );
+	CleanupStack::Pop( self );
+	return self;
+	}
+// ---------------------------------------------------------------------------
+//
+// ---------------------------------------------------------------------------
+//
+CHnQueryResultCollector* CHnQueryResultCollector::NewLC(
+		const CHnMdQueries& aQueries , const CLiwGenericParamList& aParams )
+	{
+	CHnQueryResultCollector* self =
+	new ( ELeave ) CHnQueryResultCollector( aQueries , aParams );
+	CleanupStack::PushL( self );
+	self->ConstructL();
+	return self;
+	}
+// ---------------------------------------------------------------------------
+//
+// ---------------------------------------------------------------------------
+//
+CHnQueryResultCollector::CHnQueryResultCollector(
+		const CHnMdQueries& aQueries ,
+		const CLiwGenericParamList& aParams) : CActive ( EPriorityStandard ),
+                                        	   iQueries( aQueries ),
+                                        	   iParams( aParams )
+	{
+	}
+
+// ---------------------------------------------------------------------------
+//
+// ---------------------------------------------------------------------------
+//
+CHnQueryResultCollector::~CHnQueryResultCollector()
+	{
+	Cancel();
+	delete iResults;
+	delete iCurrentQueryResults;
+	delete iSh;
+	}
+
+// ---------------------------------------------------------------------------
+//
+// ---------------------------------------------------------------------------
+//
+void CHnQueryResultCollector::ConstructL()
+	{
+	iResults = CLiwGenericParamList::NewL();
+	iCurrentQueryResults = CLiwGenericParamList::NewL();
+	CActiveScheduler::Add( this );
+	}
+
+// ---------------------------------------------------------------------------
+//
+// ---------------------------------------------------------------------------
+//
+void CHnQueryResultCollector::StartAsynchL(
+        MHnQueryResultCollectorNotification* aNotification )
+    {
+    __ASSERT_DEBUG( aNotification , User::Panic( KMatrixPanic , 0) );
+    iNotification = aNotification;
+    ResetL();
+    if( iQueryIterator < iQueries.Count())
+        {
+        ExecQueryAsynchL();
+        }
+    else
+        {
+        iNotification->ResultsCollectedL( iResults );
+        }
+    }
+
+// ---------------------------------------------------------------------------
+//
+// ---------------------------------------------------------------------------
+//
+void CHnQueryResultCollector::ResetL()
+    {
+    iQueryIterator = 0;
+    iCurrentQueryResults->Reset();
+    }
+
+// ---------------------------------------------------------------------------
+//
+// ---------------------------------------------------------------------------
+//
+void CHnQueryResultCollector::DoCancel()
+    {
+    iCurrentQueryResults->Reset();
+    delete iSh;
+    iSh = NULL;
+    }
+// ---------------------------------------------------------------------------
+//
+// ---------------------------------------------------------------------------
+//
+TBool CHnQueryResultCollector::NextQuery()
+    {
+    iQueryIterator++;
+    return iQueryIterator < iQueries.Count();
+    }
+
+// ---------------------------------------------------------------------------
+//
+// ---------------------------------------------------------------------------
+//
+void CHnQueryResultCollector::HandleQueryResultsL()
+    {
+    HBufC8* name8 = HnConvUtils::StrToStr8FastLC(
+            iQueries.Query( iQueryIterator ).NameSpace() );
+    CLiwDefaultMap* map = CLiwDefaultMap::NewL();
+    map->PushL();
+
+    TLiwGenericParam param;
+    param.PushL();
+    for (TInt i = 0; i < iCurrentQueryResults->Count(); i++)
+        {
+        iCurrentQueryResults->AtL(i, param);
+        map->InsertL( param.Name(), param.Value() );
+        param.Reset();
+        }
+
+    param.SetNameAndValueL( *name8, TLiwVariant( map) );
+    iResults->AppendL(param);
+
+    CleanupStack::PopAndDestroy( &param);
+    CleanupStack::PopAndDestroy( map);
+    CleanupStack::PopAndDestroy(name8);
+    }
+
+// ---------------------------------------------------------------------------
+//
+// ---------------------------------------------------------------------------
+//
+void CHnQueryResultCollector::RunL()
+    {
+    if ( !iStatus.Int() )
+        {
+        HandleQueryResultsL();
+        }
+
+    if( NextQuery() )
+        {
+        ExecQueryAsynchL();
+        }
+    else
+        {
+        iNotification->ResultsCollectedL( iResults );
+        }
+    }
+
+// ---------------------------------------------------------------------------
+//
+// ---------------------------------------------------------------------------
+//
+void CHnQueryResultCollector::ExecQueryAsynchL()
+    {
+    __ASSERT_DEBUG( iQueryIterator < iQueries.Count() ,
+                    User::Panic( KMatrixPanic , 0) );
+    //cancel any running evaulations
+    Cancel();
+    ExecQueryL( iQueries.Query( iQueryIterator ) );
+    SetActive();
+    }
+
+// ---------------------------------------------------------------------------
+//
+// ---------------------------------------------------------------------------
+//
+void CHnQueryResultCollector::ExecQueryL( CHnMdQuery& aQuery )
+    {
+    CLiwGenericParamList* constructor
+        = aQuery.GetService().EvaluateConstructorL( iParams );
+    CleanupStack::PushL( constructor );
+    CLiwGenericParamList* command
+        = aQuery.GetService().EvaluateCommandL( iParams );
+    CleanupStack::PushL( command );
+
+    delete iSh;
+    iSh = NULL;
+    iSh = CHnServiceHandler::NewL(
+            aQuery.GetService().GetServiceName(),
+            aQuery.GetService().GetInterfaceName(),
+            aQuery.GetService().GetCommand().GetCommandName(),
+            aQuery.GetService().GetCommand().GetCommandMode(),
+            constructor,
+            command );
+
+    CleanupStack::Pop( command );
+    CleanupStack::Pop( constructor );
+
+    iSh->ExecuteL( *iCurrentQueryResults, iStatus );
+    }
+
+
+
+// End of file