diff -r 000000000000 -r d0791faffa3f mtpfws/mtpfw/dataproviders/proxydp/src/cmtpgetformatcapabilities.cpp --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/mtpfws/mtpfw/dataproviders/proxydp/src/cmtpgetformatcapabilities.cpp Tue Feb 02 01:11:40 2010 +0200 @@ -0,0 +1,251 @@ +// 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 +#include + + +#include "cmtpgetformatcapabilities.h" +#include "mtpproxydppanic.h" +#include "cmtpdataprovidercontroller.h" +#include "cmtpobjectmgr.h" +#include "cmtpdataprovider.h" +#include "cmtpparserrouter.h" + + +// Class constants. +__FLOG_STMT(_LIT8(KComponent,"GetFormatCapabilityList");) + + +/** +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* CMTPGetFormatCapabilities::NewL( MMTPDataProviderFramework& aFramework, MMTPConnection& aConnection ) + { + CMTPGetFormatCapabilities* self = new (ELeave) CMTPGetFormatCapabilities( aFramework, aConnection ); + CleanupStack::PushL(self); + self->ConstructL(); + CleanupStack::Pop(self); + return self; + } + +/** +Destructor +*/ +CMTPGetFormatCapabilities::~CMTPGetFormatCapabilities() + { + __FLOG(_L8("~CMTPGetFormatCapabilities - Entry")); + + iSingletons.Close(); + delete iCapabilityList; + iTargetDps.Close(); + + __FLOG(_L8("~CMTPGetFormatCapabilities - Exit")); + __FLOG_CLOSE; + } + +CMTPGetFormatCapabilities::CMTPGetFormatCapabilities(MMTPDataProviderFramework& aFramework, MMTPConnection& aConnection): +CMTPRequestProcessor( aFramework, aConnection, 0, NULL ) + { + + } + +void CMTPGetFormatCapabilities::ConstructL() + { + __FLOG_OPEN(KMTPSubsystem, KComponent); + __FLOG(_L8("ConstructL - Entry")); + + iSingletons.OpenL(); + + __FLOG(_L8("ConstructL - Exit")); + } + + +void CMTPGetFormatCapabilities::ServiceL() + { + __FLOG(_L8("ServiceL - Entry")); + + delete iCapabilityList; + iCapabilityList = CMTPTypeFormatCapabilityList::NewL(); + iTargetDps.Reset(); + + CMTPParserRouter& router(iSingletons.Router()); + CMTPParserRouter::TRoutingParameters params(*iRequest, iConnection); + router.ParseOperationRequestL(params); + router.RouteOperationRequestL(params, iTargetDps); + iCurrentTarget = 0; + Schedule(KErrNone); + + __FLOG(_L8("ServiceL - Exit")); + } + +void CMTPGetFormatCapabilities::ProxyReceiveDataL(MMTPType& /*aData*/, const TMTPTypeRequest& /*aRequest*/, MMTPConnection& /*aConnection*/, TRequestStatus& /*aStatus*/) + { + __FLOG(_L8("ProxyReceiveDataL - Entry")); + + Panic(EMTPWrongRequestPhase); + + __FLOG(_L8("ProxyReceiveDataL - Exit")); + } + + +#ifdef _DEBUG +void CMTPGetFormatCapabilities::ProxySendDataL(const MMTPType& aData, const TMTPTypeRequest& aRequest, MMTPConnection& aConnection, TRequestStatus& aStatus) +#else +void CMTPGetFormatCapabilities::ProxySendDataL(const MMTPType& aData, const TMTPTypeRequest& /*aRequest*/, MMTPConnection& /*aConnection*/, TRequestStatus& aStatus) +#endif + { + __FLOG(_L8("ProxySendDataL - Entry")); + + __ASSERT_DEBUG(((iRequest == &aRequest) && (&iConnection == &aConnection)), Panic(EMTPNotSameRequestProxy)); + __ASSERT_DEBUG(aData.Type() == EMTPTypeFormatCapabilityListDataset, Panic(EMTPInvalidDataType)); + + + const CMTPTypeFormatCapabilityList& sourceList(static_cast(aData)); + const TInt count(sourceList.NumberOfElements()); + for(TInt i(0); (i < count); i++) + { + CMTPTypeFormatCapability& element(sourceList.ElementL(i)); + CMTPTypeFormatCapability* newElement = CMTPTypeFormatCapability::NewLC(); + MMTPType::CopyL(element, *newElement); + iCapabilityList->AppendL(newElement); + CleanupStack::Pop(newElement); + } + + TRequestStatus* status = &aStatus; + User::RequestComplete(status, KErrNone); + + __FLOG(_L8("ProxySendDataL - Exit")); + } + +/** + Send the corresponding response for the request is routed by Proxy DP + ProxySendResponseL will complete the request of framework's AO, then switch the transaction phase to TranscationComplete + so ProxyTransactionCompleteL will be called later. + @param aResponse The response which is sent by some DP + @param aRequest The corresponding request + @param aConnection The corresponding connection + @param aStatus The status of framework AO + */ +#ifdef _DEBUG +void CMTPGetFormatCapabilities::ProxySendResponseL(const TMTPTypeResponse& aResponse, const TMTPTypeRequest& aRequest, MMTPConnection& aConnection, TRequestStatus& aStatus) +#else +void CMTPGetFormatCapabilities::ProxySendResponseL(const TMTPTypeResponse& aResponse, const TMTPTypeRequest& /*aRequest*/, MMTPConnection& /*aConnection*/, TRequestStatus& aStatus) +#endif + { + __FLOG(_L8("ProxySendResponseL - Entry")); + + __ASSERT_DEBUG(((iRequest == &aRequest) && (&iConnection == &aConnection)), Panic(EMTPNotSameRequestProxy)); + MMTPType::CopyL(aResponse, iResponse); + TRequestStatus* status(&aStatus); + User::RequestComplete(status, KErrNone); + + __FLOG(_L8("ProxySendResponseL - Exit")); + } + + +/** + Complete the transaction phase for the request is routed by Proxy DP + Drive its AO to route other requests or send the response. + @param aRequest The corresponding request + @param aConnection The corresponding connection + */ +#ifdef _DEBUG +void CMTPGetFormatCapabilities::ProxyTransactionCompleteL(const TMTPTypeRequest& aRequest, MMTPConnection& aConnection) +#else +void CMTPGetFormatCapabilities::ProxyTransactionCompleteL(const TMTPTypeRequest& /*aRequest*/, MMTPConnection& /*aConnection*/) +#endif + { + __FLOG(_L8("ProxyTransactionCompleteL - Entry")); + + __ASSERT_DEBUG(((iRequest == &aRequest) && (&iConnection == &aConnection)), Panic(EMTPNotSameRequestProxy)); + TInt err((iResponse.Uint16(TMTPTypeResponse::EResponseCode) == EMTPRespCodeOK) ? KErrNone : KErrGeneral); + if (err == KErrNone) + { + ++iCurrentTarget; + } + Schedule(err); + + __FLOG(_L8("ProxyTransactionCompleteL - Exit")); + } + + +void CMTPGetFormatCapabilities::SendResponseL(TUint16 aCode) + { + __FLOG(_L8("SendResponseL - Entry")); + + 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()); + + __FLOG(_L8("SendResponseL - Exit")); + } + +void CMTPGetFormatCapabilities::RunL() + { + __FLOG(_L8("RunL - Entry")); + + if (iStatus == KErrNone) + { + if (iCurrentTarget < iTargetDps.Count()) + { + TUint id(iTargetDps[iCurrentTarget]); + CMTPDataProvider& dp(iSingletons.DpController().DataProviderL(id)); + dp.ExecuteProxyRequestL(*iRequest, Connection(), *this); + } + else + { + SendDataL(*iCapabilityList); + } + } + else + { + SendResponseL(iResponse.Uint16(TMTPTypeResponse::EResponseCode)); + } + + __FLOG(_L8("RunL - Exit")); + } + +TInt CMTPGetFormatCapabilities::RunError(TInt /*aError*/) + { + __FLOG(_L8("RunError - Entry")); + + TRAP_IGNORE(SendResponseL(EMTPRespCodeGeneralError)); + + __FLOG(_L8("RunError - Exit")); + return KErrNone; + } + +/** +Completes the current asynchronous request with the specified +completion code. +@param aError The asynchronous request completion request. +*/ +void CMTPGetFormatCapabilities::Schedule(TInt aError) + { + __FLOG(_L8("Schedule - Entry")); + + TRequestStatus* status = &iStatus; + User::RequestComplete(status, aError); + SetActive(); + + __FLOG(_L8("Schedule - Exit")); + } +