--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/mtpfws/mtpfw/dataproviders/proxydp/src/cmtpgetobjectproplist.cpp	Tue Feb 02 01:11:40 2010 +0200
@@ -0,0 +1,305 @@
+// Copyright (c) 2006-2009 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 <mtp/tmtptyperequest.h>
+#include <mtp/mmtpdataproviderframework.h>
+#include <mtp/mtpprotocolconstants.h>
+#include <mtp/cmtptypeobjectinfo.h>
+#include <mtp/cmtptypeobjectproplist.h>
+#include <mtp/cmtpdataproviderplugin.h>
+#include <mtp/cmtptypearray.h>
+
+#include "rmtpframework.h"
+#include "cmtpdataprovidercontroller.h"
+#include "cmtpparserrouter.h"
+#include "cmtpdataprovider.h"
+#include "cmtpgetobjectproplist.h"
+#include "mtpproxydppanic.h"
+#include "cmtpobjectbrowser.h"
+#include "mtpdppanic.h"
+#include "cmtpobjectmgr.h"
+
+__FLOG_STMT( _LIT8( KComponent,"PrxyGetObjPrpLst" ); )
+const TUint KInvalidDpId = 0xFF;
+/**
+Factory method.
+@param aFramework	The data provider framework
+@param aConnection	The connection from which the request comes
+@return a pointer to the created request processor object.
+*/ 
+MMTPRequestProcessor* CMTPGetObjectPropList::NewL(MMTPDataProviderFramework& aFramework, MMTPConnection& aConnection)
+	{
+	CMTPGetObjectPropList* self = new (ELeave) CMTPGetObjectPropList(aFramework, aConnection);
+    CleanupStack::PushL(self);
+    self->ConstructL();
+    CleanupStack::Pop(self);
+	return self;
+	}
+
+/**
+Destructor.
+*/	
+CMTPGetObjectPropList::~CMTPGetObjectPropList()
+	{
+	delete iObjectPropList;
+	iSingletons.Close();
+	iTargetDps.Close();
+    iHandles.Close();
+    delete iObjBrowser;
+    __FLOG( _L8("+/-Dtor") );
+    __FLOG_CLOSE;
+	}
+
+/**
+GetObjectPropList request handler. Builds a list of all the data providers
+that support the request, then starts an active object to send it to them all.
+*/	
+void CMTPGetObjectPropList::ServiceL()
+    {
+    iTargetDps.Reset();
+    CMTPParserRouter& router(iSingletons.Router());
+    CMTPParserRouter::TRoutingParameters params(Request(), iConnection);
+    router.ParseOperationRequestL(params);
+    router.RouteOperationRequestL(params, iTargetDps);
+    
+    GetObjectHandlesL();
+    }
+
+void CMTPGetObjectPropList::ProxyReceiveDataL(MMTPType& /*aData*/, const TMTPTypeRequest& /*aRequest*/, MMTPConnection& /*aConnection*/, TRequestStatus& /*aStatus*/)
+	{	
+	Panic(EMTPWrongRequestPhase);
+	}
+
+#ifdef _DEBUG	
+void CMTPGetObjectPropList::ProxySendDataL(const MMTPType& aData, const TMTPTypeRequest& aRequest, MMTPConnection& aConnection, TRequestStatus& aStatus)
+#else
+void CMTPGetObjectPropList::ProxySendDataL(const MMTPType& aData, const TMTPTypeRequest& /*aRequest*/, MMTPConnection& /*aConnection*/, TRequestStatus& aStatus)
+#endif
+	{
+	__ASSERT_DEBUG((( (iRequest == &aRequest) || ( &iCurrentRequest == &aRequest ) ) && (&iConnection == &aConnection)), Panic(EMTPNotSameRequestProxy));
+	__ASSERT_DEBUG(aData.Type() == EMTPTypeObjectPropListDataset, Panic(EMTPInvalidDataType));
+	
+	const CMTPTypeObjectPropList& sourceObjectPropList(static_cast<const CMTPTypeObjectPropList&>(aData));
+
+	iObjectPropList->AppendObjectPropListL(sourceObjectPropList);
+	
+    TRequestStatus* status(&aStatus);
+	User::RequestComplete(status, KErrNone);	
+	}
+
+#ifdef _DEBUG	
+void CMTPGetObjectPropList::ProxySendResponseL(const TMTPTypeResponse& aResponse, const TMTPTypeRequest& aRequest, MMTPConnection& aConnection, TRequestStatus& aStatus)
+#else
+void CMTPGetObjectPropList::ProxySendResponseL(const TMTPTypeResponse& aResponse, const TMTPTypeRequest& /*aRequest*/, MMTPConnection& /*aConnection*/, TRequestStatus& aStatus)
+#endif
+	{
+    __FLOG( _L8("+ProxySendResponseL") );
+    
+	__ASSERT_DEBUG((( (iRequest == &aRequest) || ( &iCurrentRequest == &aRequest ) ) && (&iConnection == &aConnection)), Panic(EMTPNotSameRequestProxy));
+	MMTPType::CopyL(aResponse, iResponse);
+	TRequestStatus* status(&aStatus);
+	User::RequestComplete(status, KErrNone);
+	
+    __FLOG( _L8("-ProxySendResponseL") );
+	}
+
+#ifdef _DEBUG		
+void CMTPGetObjectPropList::ProxyTransactionCompleteL(const TMTPTypeRequest& aRequest, MMTPConnection& aConnection)
+#else
+void CMTPGetObjectPropList::ProxyTransactionCompleteL(const TMTPTypeRequest& /*aRequest*/, MMTPConnection& /*aConnection*/)
+#endif
+	{
+    __FLOG( _L8("+ProxyTransactionCompleteL") );
+    __FLOG_1( _L8("Response code is 0x%08X,"), iResponse.Uint16(TMTPTypeResponse::EResponseCode) );
+    
+	__ASSERT_DEBUG((( (iRequest == &aRequest) || ( &iCurrentRequest == &aRequest ) ) && (&iConnection == &aConnection)), Panic(EMTPNotSameRequestProxy));
+	TUint16 response = iResponse.Uint16(TMTPTypeResponse::EResponseCode);
+	if(( EMTPRespCodeGroupNotSupported == response) || (EMTPRespCodeSpecificationByGroupUnsupported == response))
+		{
+		response = EMTPRespCodeOK;
+		iResponse.SetUint16(TMTPTypeResponse::EResponseCode, response);
+		}
+	
+    TInt err((EMTPRespCodeOK == response) ? KErrNone : KErrGeneral);      
+    if (err == KErrNone)
+        {
+        ++iCurrentHandle;
+        Schedule(err);
+        }
+    else
+        {
+        SendResponseL( response );    
+        }
+    
+    
+    __FLOG( _L8("-ProxyTransactionCompleteL") );
+	}	
+
+/**
+Sends the request to all the data providers that expressed an interest,
+one each iteration of the active object.
+*/
+void CMTPGetObjectPropList::RunL()
+    {
+    __FLOG( _L8("+RunL") );
+    
+    // We cannot use assertion here, because it might be completed with KErrGeneral. See ProxyTransactionCompleteL()
+    
+    if ( iStatus == KErrNone )
+        {
+        GetNextObjectPropL();
+        if ( iOwnerDp != KInvalidDpId )
+            {
+            CMTPDataProvider& dp = iSingletons.DpController().DataProviderL( iOwnerDp );
+            dp.ExecuteProxyRequestL( iCurrentRequest, Connection(), *this );
+            }
+        }
+    else
+        {
+        SendResponseL( iResponse.Uint16( TMTPTypeResponse::EResponseCode ) );
+        }
+    
+    __FLOG( _L8("-RunL") );
+    }
+
+/**
+Constructor.
+*/	
+CMTPGetObjectPropList::CMTPGetObjectPropList(MMTPDataProviderFramework& aFramework, MMTPConnection& aConnection) :
+    CMTPRequestProcessor(aFramework, aConnection, 0, NULL)
+    {
+    __FLOG_OPEN( KMTPSubsystem, KComponent );
+    __FLOG( _L8("+/-Ctor") );
+    }
+
+/**
+Second phase constructor.
+*/
+void CMTPGetObjectPropList::ConstructL()
+    {
+    __FLOG( _L8("+ConstructL") );
+    iSingletons.OpenL();
+    iOwnerDp = KInvalidDpId;
+    __FLOG( _L8("-ConstructL") );
+    }
+
+/**
+Completes the current asynchronous request with the specified 
+completion code.
+@param aError The asynchronous request completion request.
+*/
+void CMTPGetObjectPropList::Schedule(TInt aError)
+	{
+	TRequestStatus* status(&iStatus);
+	User::RequestComplete(status, aError);
+	SetActive();
+	}
+
+/**
+Sends a response to the initiator.
+@param aCode MTP response code
+*/
+void CMTPGetObjectPropList::SendResponseL(TUint16 aCode)
+    {
+    const TMTPTypeRequest& req(Request());
+    iResponse.SetUint16(TMTPTypeResponse::EResponseCode, aCode);
+    iResponse.SetUint32(TMTPTypeResponse::EResponseSessionID, req.Uint32(TMTPTypeRequest::ERequestSessionID));
+    iResponse.SetUint32(TMTPTypeResponse::EResponseTransactionID, req.Uint32(TMTPTypeRequest::ERequestTransactionID));
+    iFramework.SendResponseL(iResponse, req, Connection());
+    }
+
+void CMTPGetObjectPropList::GetObjectHandlesL()
+    {
+    __FLOG( _L8("+GetObjectHandlesL") );
+    
+    delete iObjBrowser;
+    iObjBrowser = NULL;
+    iObjBrowser = CMTPObjectBrowser::NewL( iFramework );
+    
+    iHandles.Reset();
+    
+    delete iObjectPropList;
+    iObjectPropList = NULL;
+    iObjectPropList = CMTPTypeObjectPropList::NewL();
+    
+    iCurrentHandle = 0;
+    MMTPType::CopyL( Request(), iCurrentRequest );
+    // Set depth to be zero to avoid the other DPs enumerating objects repeatedly.
+    iCurrentRequest.SetUint32( TMTPTypeRequest::ERequestParameter5, 0 );
+    
+    CMTPObjectBrowser::TBrowseCallback callback = { CMTPGetObjectPropList::OnBrowseObjectL, this };
+    TUint32 handle = Request().Uint32( TMTPTypeRequest::ERequestParameter1 );
+    TUint32 fmtCode = Request().Uint32( TMTPTypeRequest::ERequestParameter2 );
+    TUint32 depth = Request().Uint32( TMTPTypeRequest::ERequestParameter5 );
+    iObjBrowser->GoL( fmtCode, handle, depth, callback );
+    __FLOG_1( _L8("The total of object handles is %d"), iHandles.Count() );
+    
+    if ( 0 == iHandles.Count() )
+        {
+        if ( handle==KMTPHandleNone && depth==0 )
+            {
+            SendDataL( *iObjectPropList );
+            }
+        else if ( fmtCode != KMTPFormatsAll )
+            {
+            SendResponseL(EMTPRespCodeSpecificationByFormatUnsupported);
+            }
+        else if ( handle != KMTPHandleAll )
+            {
+            SendResponseL(EMTPRespCodeInvalidObjectHandle);
+            }
+        }
+    else
+        {
+        Schedule( KErrNone );
+        }
+    
+    __FLOG( _L8("-GetObjectHandlesL") );
+    }
+
+void CMTPGetObjectPropList::GetNextObjectPropL()
+    {
+    __FLOG( _L8("+GetNextObjectPropL") );
+
+    iOwnerDp = KInvalidDpId;
+    if ( iCurrentHandle < iHandles.Count() )
+        {
+        TUint32 handle = iHandles[iCurrentHandle];
+        iOwnerDp = iSingletons.ObjectMgr().ObjectOwnerId( handle );
+        if ( iOwnerDp == KInvalidDpId )
+            {
+            SendResponseL(EMTPRespCodeInvalidObjectHandle);
+            }
+        else
+            {
+            iCurrentRequest.SetUint32( TMTPTypeRequest::ERequestParameter1, handle );
+            }
+        }
+    else
+        {
+        SendDataL( *iObjectPropList );
+        }
+    
+    __FLOG( _L8("-GetNextObjectPropL") );
+    }
+
+void CMTPGetObjectPropList::OnBrowseObjectL( TAny* aSelf, TUint aHandle, TUint32 /*aCurDepth*/ )
+    {
+    CMTPGetObjectPropList* self = reinterpret_cast< CMTPGetObjectPropList* >( aSelf );
+    if ( self->iTargetDps.Find(self->iSingletons.ObjectMgr().ObjectOwnerId(aHandle)) != KErrNotFound )
+        {
+        self->iHandles.AppendL( aHandle );
+        }
+    }