--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/mtpfws/mtpfw/dataproviders/proxydp/src/cmtpmoveobject.cpp Tue Feb 02 01:11:40 2010 +0200
@@ -0,0 +1,475 @@
+// Copyright (c) 2007-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 <bautils.h>
+#include <f32file.h>
+#include <mtp/cmtptypearray.h>
+#include <mtp/cmtpobjectmetadata.h>
+
+#include "cmtpdataprovider.h"
+#include "cmtpmoveobject.h"
+#include "cmtpobjectmgr.h"
+#include "cmtpparserrouter.h"
+#include "cmtpstoragemgr.h"
+#include "mtpproxydppanic.h"
+#include "cmtpobjectbrowser.h"
+#include "mtpdppanic.h"
+
+__FLOG_STMT(_LIT8(KComponent,"PrxyMoveObj");)
+const TUint KInvalidDpId = 0xFF;
+/**
+Verification data for the MoveObject request
+*/
+const TMTPRequestElementInfo CMTPMoveObject::KMTPMoveObjectPolicy[] =
+ {
+ {TMTPTypeRequest::ERequestParameter1, EMTPElementTypeObjectHandle, EMTPElementAttrFileOrDir | EMTPElementAttrWrite, 0, 0, 0},
+ {TMTPTypeRequest::ERequestParameter2, EMTPElementTypeStorageId, EMTPElementAttrWrite, 0, 0, 0},
+ {TMTPTypeRequest::ERequestParameter3, EMTPElementTypeObjectHandle, EMTPElementAttrDir | EMTPElementAttrWrite, 1, 0, 0}
+ };
+
+/**
+Two-phase construction 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* CMTPMoveObject::NewL(MMTPDataProviderFramework& aFramework, MMTPConnection& aConnection)
+ {
+ CMTPMoveObject* self = new (ELeave) CMTPMoveObject(aFramework, aConnection);
+ CleanupStack::PushL(self);
+ self->ConstructL();
+ CleanupStack::Pop(self);
+ return self;
+ }
+
+/**
+Destructor
+*/
+CMTPMoveObject::~CMTPMoveObject()
+ {
+ iSingletons.Close();
+ iNewParent.Close();
+ delete iPathToCreate;
+
+ delete iFileMan;
+ iFolderToRemove.Close();
+ delete iObjInfoCache;
+ iNewHandleParentStack.Close();
+ iHandleDepths.Close();
+ iHandles.Close();
+ delete iObjBrowser;
+ iTargetDps.Close();
+ __FLOG(_L8("+/-Dtor"));
+ __FLOG_CLOSE;
+ }
+
+/**
+Constructor
+*/
+CMTPMoveObject::CMTPMoveObject(MMTPDataProviderFramework& aFramework, MMTPConnection& aConnection) :
+ CMTPRequestProcessor(aFramework, aConnection, sizeof(KMTPMoveObjectPolicy)/sizeof(TMTPRequestElementInfo), KMTPMoveObjectPolicy)
+ {
+ __FLOG_OPEN( KMTPSubsystem, KComponent );
+ __FLOG( _L8("+/-Ctor") );
+ }
+
+/**
+Second phase constructor.
+*/
+void CMTPMoveObject::ConstructL()
+ {
+ __FLOG( _L8("+ConstructL") );
+ iNewParent.CreateL(KMaxFileName);
+ iSingletons.OpenL();
+ iFolderToRemove.CreateL( KMaxFileName );
+ iOwnerDp = KInvalidDpId;
+ __FLOG( _L8("-ConstructL") );
+ }
+
+/**
+MoveObject request handler
+*/
+void CMTPMoveObject::ServiceL()
+ {
+ __FLOG( _L8("+ServiceL") );
+ iTargetDps.Reset();
+ CMTPParserRouter& router(iSingletons.Router());
+ CMTPParserRouter::TRoutingParameters params(Request(), iConnection);
+ router.ParseOperationRequestL(params);
+ router.RouteOperationRequestL(params, iTargetDps);
+
+ BrowseHandlesL();
+ __FLOG( _L8("-ServiceL") );
+ }
+
+void CMTPMoveObject::ProxyReceiveDataL(MMTPType& /*aData*/, const TMTPTypeRequest& /*aRequest*/, MMTPConnection& /*aConnection*/, TRequestStatus& /*aStatus*/)
+ {
+ Panic(EMTPWrongRequestPhase);
+ }
+
+void CMTPMoveObject::ProxySendDataL(const MMTPType& /*aData*/, const TMTPTypeRequest& /*aRequest*/, MMTPConnection& /*aConnection*/, TRequestStatus& /*aStatus*/)
+ {
+ Panic(EMTPWrongRequestPhase);
+ }
+
+#ifdef _DEBUG
+void CMTPMoveObject::ProxySendResponseL(const TMTPTypeResponse& aResponse, const TMTPTypeRequest& aRequest, MMTPConnection& aConnection, TRequestStatus& aStatus)
+#else
+void CMTPMoveObject::ProxySendResponseL(const TMTPTypeResponse& aResponse, const TMTPTypeRequest& /*aRequest*/, MMTPConnection& /*aConnection*/, TRequestStatus& aStatus)
+#endif
+ {
+ __FLOG( _L8("+ProxySendResponseL") );
+ __ASSERT_DEBUG(((&iCurrentRequest == &aRequest) && (&iConnection == &aConnection)), Panic(EMTPNotSameRequestProxy));
+ MMTPType::CopyL(aResponse, iResponse);
+ TRequestStatus* status = &aStatus;
+ User::RequestComplete(status, KErrNone);
+ __FLOG( _L8("-ProxySendResponseL") );
+ }
+
+#ifdef _DEBUG
+void CMTPMoveObject::ProxyTransactionCompleteL(const TMTPTypeRequest& aRequest, MMTPConnection& aConnection)
+#else
+void CMTPMoveObject::ProxyTransactionCompleteL(const TMTPTypeRequest& /*aRequest*/, MMTPConnection& /*aConnection*/)
+#endif
+ {
+ __FLOG( _L8("+ProxyTransactionCompleteL") );
+ __ASSERT_DEBUG(((&iCurrentRequest == &aRequest) && (&iConnection == &aConnection)), Panic(EMTPNotSameRequestProxy));
+ TInt err((iResponse.Uint16(TMTPTypeResponse::EResponseCode) == EMTPRespCodeOK) ? KErrNone : KErrGeneral);
+ if (err == KErrNone)
+ {
+ iCurrentHandle--;
+ Schedule(err);
+ }
+ else
+ {
+ SendResponseL( iResponse.Uint16( TMTPTypeResponse::EResponseCode ) );
+ }
+
+ __FLOG( _L8("-ProxyTransactionCompleteL") );
+ }
+
+/**
+Retrive the parameters of the request
+*/
+void CMTPMoveObject::GetParametersL()
+ {
+ __FLOG( _L8("+GetParametersL") );
+
+ TUint32 objectHandle = iCurrentRequest.Uint32( TMTPTypeRequest::ERequestParameter1 );
+ TUint32 newParentHandle = iCurrentRequest.Uint32( TMTPTypeRequest::ERequestParameter3 );
+
+ if(newParentHandle == 0)
+ {
+ GetDefaultParentObjectL( iNewParent );
+ }
+ else
+ {
+ iFramework.ObjectMgr().ObjectL( TMTPTypeUint32( newParentHandle ), *iObjInfoCache );
+ iNewParent = iObjInfoCache->DesC(CMTPObjectMetaData::ESuid);
+ }
+
+ iFramework.ObjectMgr().ObjectL( TMTPTypeUint32( objectHandle ), *iObjInfoCache );
+ __FLOG( _L8("-GetParametersL") );
+ }
+
+/**
+Get a default parent object, when the current request does not specify a parent object
+*/
+void CMTPMoveObject::GetDefaultParentObjectL( TDes& aObjectName )
+ {
+ __FLOG( _L8("+GetDefaultParentObjectL") );
+ const CMTPStorageMetaData& storageMetaData( iFramework.StorageMgr().StorageL(iStorageId) );
+ aObjectName = storageMetaData.DesC(CMTPStorageMetaData::EStorageSuid);
+ __FLOG( _L8("-GetDefaultParentObjectL") );
+
+ }
+
+/**
+Check if we can move the file to the new location
+*/
+TMTPResponseCode CMTPMoveObject::CanMoveObjectL(const TDesC& aOldName, const TDesC& aNewName) const
+ {
+ __FLOG(_L8("+CanMoveObjectL"));
+ TMTPResponseCode result = EMTPRespCodeOK;
+
+ TEntry fileEntry;
+ User::LeaveIfError(iFramework.Fs().Entry(aOldName, fileEntry));
+ TInt drive(iFramework.StorageMgr().DriveNumber(iStorageId));
+ User::LeaveIfError(drive);
+ TVolumeInfo volumeInfo;
+ User::LeaveIfError(iFramework.Fs().Volume(volumeInfo, drive));
+
+ if (BaflUtils::FileExists(iFramework.Fs(), aNewName))
+ {
+ result = EMTPRespCodeInvalidParentObject;
+ }
+ __FLOG_VA((_L8("-CanMoveObjectL (Exit with response code 0x%04X)"), result));
+ return result;
+ }
+
+void CMTPMoveObject::GetSuidFromHandleL(TUint aHandle, TDes& aSuid) const
+ {
+ CMTPObjectMetaData* meta(CMTPObjectMetaData::NewLC());
+ iFramework.ObjectMgr().ObjectL(aHandle, *meta);
+ __ASSERT_DEBUG(meta, Panic(EMTPDpObjectNull));
+ aSuid = meta->DesC(CMTPObjectMetaData::ESuid);
+ CleanupStack::PopAndDestroy(meta);
+ }
+
+void CMTPMoveObject::RunL()
+ {
+ __FLOG( _L8("+RunL") );
+ if ( iStatus==KErrNone )
+ {
+ switch ( iState )
+ {
+ case ERemoveSourceFolderTree:
+ SendResponseL(iResponse.Uint16(TMTPTypeResponse::EResponseCode));
+ break;
+ default:
+ NextObjectHandleL();
+ if ( iOwnerDp != KInvalidDpId )
+ {
+ CMTPDataProvider& dp = iSingletons.DpController().DataProviderL( iOwnerDp );
+ dp.ExecuteProxyRequestL( iCurrentRequest, Connection(), *this );
+ }
+ break;
+ }
+ }
+ else
+ {
+ SendResponseL( iResponse.Uint16( TMTPTypeResponse::EResponseCode ) );
+ }
+
+ __FLOG( _L8("-RunL") );
+ }
+
+TInt CMTPMoveObject::RunError(TInt /*aError*/)
+ {
+ TRAP_IGNORE(SendResponseL(EMTPRespCodeGeneralError));
+ return KErrNone;
+ }
+
+/**
+Completes the current asynchronous request with the specified
+completion code.
+@param aError The asynchronous request completion request.
+*/
+void CMTPMoveObject::Schedule(TInt aError)
+ {
+ TRequestStatus* status = &iStatus;
+ User::RequestComplete(status, aError);
+ SetActive();
+ }
+
+/**
+Sends a response to the initiator.
+@param aCode MTP response code
+*/
+void CMTPMoveObject::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());
+ }
+
+TMTPResponseCode CMTPMoveObject::CreateFolderL()
+ {
+ __FLOG( _L8("+CreateFolderL") );
+ TMTPResponseCode ret = EMTPRespCodeOK;
+
+ GetParametersL();
+ __FLOG_1( _L("New folder parent: %S"), &iNewParent );
+ const TDesC& oldPath = iObjInfoCache->DesC( CMTPObjectMetaData::ESuid );
+ if ( iFolderToRemove.Length() == 0 )
+ {
+ iFolderToRemove = oldPath;
+ }
+
+ TFileName fileNamePart;
+ User::LeaveIfError( BaflUtils::MostSignificantPartOfFullName( oldPath, fileNamePart ) );
+ __FLOG_1( _L("Folder name: %S"), &fileNamePart );
+
+ if ( ( iNewParent.Length() + fileNamePart.Length() + 1 ) <= iNewParent.MaxLength() )
+ {
+ iNewParent.Append( fileNamePart );
+ iNewParent.Append( KPathDelimiter );
+ }
+ else
+ {
+ ret = EMTPRespCodeInvalidParentObject;
+ }
+ if ( EMTPRespCodeOK == ret )
+ {
+ __FLOG_VA( ( _L("Try to move %S to %S"), &oldPath, &iNewParent ) );
+ ret = CanMoveObjectL( oldPath, iNewParent );
+
+ if ( EMTPRespCodeOK == ret )
+ {
+ TInt err = iFramework.Fs().MkDir( iNewParent );
+ User::LeaveIfError( err );
+ iNewHandleParentStack.AppendL( iObjInfoCache->Uint( CMTPObjectMetaData::EHandle ) );
+ }
+ }
+
+ __FLOG( _L8("-CreateFolderL") );
+ return ret;
+ }
+
+void CMTPMoveObject::RemoveSourceFolderTreeL()
+ {
+ __FLOG( _L8("+RemoveSourceFolderTreeL") );
+
+ if ( iFolderToRemove.Length() > 0 )
+ {
+ __FLOG_1( _L("Removing %S"), &iFolderToRemove );
+ delete iFileMan;
+ iFileMan = NULL;
+ iFileMan = CFileMan::NewL( iFramework.Fs() );
+
+ iState = ERemoveSourceFolderTree;
+ User::LeaveIfError( iFileMan->RmDir( iFolderToRemove, iStatus ) );
+ SetActive();
+ }
+ else
+ {
+ SendResponseL( iResponse.Uint16( TMTPTypeResponse::EResponseCode ) );
+ }
+
+ __FLOG( _L8("-RemoveSourceFolderTreeL") );
+ }
+
+void CMTPMoveObject::BrowseHandlesL()
+ {
+ __FLOG( _L8("+BrowseHandlesL") );
+
+ iFolderToRemove.SetLength( 0 );
+ iState = EInit;
+
+ delete iObjBrowser;
+ iObjBrowser = NULL;
+ iObjBrowser = CMTPObjectBrowser::NewL( iFramework );
+
+ iHandles.Reset();
+ iHandleDepths.Reset();
+
+ delete iObjInfoCache;
+ iObjInfoCache = NULL;
+ iObjInfoCache = CMTPObjectMetaData::NewL();
+
+ iNewHandleParentStack.Reset();
+
+ MMTPType::CopyL( Request(), iCurrentRequest );
+ iStorageId = Request().Uint32( TMTPTypeRequest::ERequestParameter2 );
+
+ CMTPObjectBrowser::TBrowseCallback callback = { CMTPMoveObject::OnBrowseObjectL, this };
+ TUint32 handle = Request().Uint32( TMTPTypeRequest::ERequestParameter1 );
+ TUint32 newHandleParent = Request().Uint32( TMTPTypeRequest::ERequestParameter3 );
+ iNewHandleParentStack.AppendL( newHandleParent );
+ iObjBrowser->GoL( KMTPFormatsAll, handle, KMaxTUint32, callback );
+ __FLOG_1( _L8("iHandles.Count() = %d"), iHandles.Count() );
+
+ if ( iHandles.Count() > 0 )
+ {
+ iCurrentHandle = iHandles.Count() - 1;
+ Schedule( KErrNone );
+ }
+ else
+ {
+ SendResponseL( EMTPRespCodeInvalidObjectHandle );
+ }
+
+ __FLOG( _L8("-BrowseHandlesL") );
+ }
+
+void CMTPMoveObject::NextObjectHandleL()
+ {
+ __FLOG( _L8("+NextObjectHandleL") );
+ __ASSERT_DEBUG( ( iNewHandleParentStack.Count() > 0 ), User::Invariant() );
+ iOwnerDp = KInvalidDpId;
+ if ( iCurrentHandle >=0 )
+ {
+ __FLOG_1( _L8("iCurrentHandle = %d"), iCurrentHandle );
+ TUint32 handle = iHandles[iCurrentHandle];
+ TUint32 depth = iHandleDepths[iCurrentHandle];
+ __FLOG_1( _L8("depth = %d"), depth );
+ if ( iCurrentHandle != ( iHandles.Count() - 1 ) )
+ {
+ TUint32 previousDepth = iHandleDepths[iCurrentHandle + 1];
+ __FLOG_1( _L8("previousDepth = %d"), previousDepth );
+ if ( depth < previousDepth )
+ {
+ // Completed copying folder and all its sub-folder and files, pop all copied folders' handle which are not shallower than the current one.
+
+ // Step 1: pop the previous handle itself if it is am empty folder
+ if ( iIsMovingFolder )
+ {
+ iNewHandleParentStack.Remove( iNewHandleParentStack.Count() - 1 );
+ }
+ // Step 2: pop the other folders' handle which are not shallower than the current one
+ TUint loopCount = previousDepth - depth;
+ for ( TUint i = 0; i < loopCount; i++ )
+ {
+ iNewHandleParentStack.Remove( iNewHandleParentStack.Count() - 1 );
+ }
+ }
+ else if ( ( depth == previousDepth ) && iIsMovingFolder )
+ {
+ // Completed moving empty folder, pop its handle
+ iNewHandleParentStack.Remove( iNewHandleParentStack.Count() - 1 );
+ }
+ }
+ iIsMovingFolder = EFalse;
+ iOwnerDp = iSingletons.ObjectMgr().ObjectOwnerId( handle );
+ if ( iOwnerDp == KInvalidDpId )
+ {
+ SendResponseL( EMTPRespCodeInvalidObjectHandle );
+ }
+ else
+ {
+ iCurrentRequest.SetUint32( TMTPTypeRequest::ERequestParameter1, handle );
+ iCurrentRequest.SetUint32( TMTPTypeRequest::ERequestParameter3, iNewHandleParentStack[iNewHandleParentStack.Count()-1] );
+ }
+ if ( iOwnerDp==iSingletons.DpController().DeviceDpId() )
+ {
+ iIsMovingFolder = ETrue;
+ if ( EMTPRespCodeOK != CreateFolderL() )
+ {
+ iOwnerDp = KInvalidDpId;
+ iIsMovingFolder = EFalse;
+ SendResponseL( EMTPRespCodeInvalidParentObject );
+ }
+ }
+ }
+ else
+ {
+ RemoveSourceFolderTreeL();
+ }
+
+ __FLOG( _L8("-NextObjectHandleL") );
+ }
+
+void CMTPMoveObject::OnBrowseObjectL( TAny* aSelf, TUint aHandle, TUint32 aCurDepth )
+ {
+ CMTPMoveObject* self = reinterpret_cast< CMTPMoveObject* >( aSelf );
+ if ( self->iTargetDps.Find(self->iSingletons.ObjectMgr().ObjectOwnerId(aHandle)) != KErrNotFound )
+ {
+ self->iHandles.AppendL( aHandle );
+ self->iHandleDepths.AppendL( aCurDepth );
+ }
+ }
+