Collapse all Symbian^3 Product Developer Library

 

examples/RemoteConn/MtpDataProviderExample/src/cmtpexampledprequestprocessor.cpp

// Copyright (c) 2010 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/mtpprotocolconstants.h>
#include <mtp/tmtptyperequest.h>
#include <mtp/mmtpdataproviderframework.h>
#include <mtp/tmtptypeevent.h>
#include <mtp/mmtpconnection.h>
#include <mtp/mmtpobjectmgr.h>
 
#include "cmtpexampledprequestprocessor.h"


CMTPExampleDpRequestProcessor::CMTPExampleDpRequestProcessor(
                                                                                        MMTPDataProviderFramework& aFramework,                                                                                  
                                                                                        MMTPConnection& aConnection,
                                                                                        TInt aElementCount,
                                                                                        const TMTPRequestElementInfo* aElements)
        :iFramework(aFramework),
        iConnection(aConnection),
        iElementCount(aElementCount),
        iElements(aElements)
        {
        
        }

CMTPExampleDpRequestProcessor::~CMTPExampleDpRequestProcessor()
        {
        }
 void CMTPExampleDpRequestProcessor::Release()
     {
     delete this;
    }


void CMTPExampleDpRequestProcessor::SendResponseL(TMTPResponseCode aResponseCode, TInt aParameterCount, TUint32* aParams)
        {   
        iResponse.SetUint16(TMTPTypeResponse::EResponseCode, aResponseCode);
                    
    iResponse.SetUint32(TMTPTypeResponse::EResponseSessionID, iSessionId);
        
        iResponse.SetUint32(TMTPTypeResponse::EResponseTransactionID, iTransactionCode);
   
    TInt i = 0; 
        for(i = 0; i < aParameterCount; i++)
                {
                iResponse.SetUint32(TMTPTypeResponse::EResponseParameter1 + i, aParams[i]);
                }

        i += TMTPTypeResponse::EResponseParameter1;
        while(i <= TMTPTypeResponse::EResponseParameter5)
            {
            iResponse.SetUint32(i, KMTPNotSpecified32);
            i++;
            }
        iFramework.SendResponseL(iResponse, *iRequest, iConnection);
        }
 const TMTPTypeRequest& CMTPExampleDpRequestProcessor::Request() const
     { 
     return *iRequest;
     }
     


void CMTPExampleDpRequestProcessor::CompleteRequestL()
    {
        iFramework.TransactionCompleteL(*iRequest, iConnection);
        }


TBool CMTPExampleDpRequestProcessor::HandleRequestL(const TMTPTypeRequest& aRequest, TMTPTransactionPhase aPhase)
        {
        iRequest = &aRequest;
        TBool result = EFalse;
        switch(aPhase)
                {
                case ERequestPhase:             
                    ExtractSessionTransactionId();
                    ServiceL(); 
                        break;

                case EResponsePhase:
                        result = DoHandleResponsePhaseL();      
                        break;
                        
                case ECompletingPhase:
                        result = DoHandleCompletingPhaseL();
                        break;
                }
        return result;  
        }


MMTPConnection& CMTPExampleDpRequestProcessor::Connection() const
     {
     return iConnection;
     }

TUint32 CMTPExampleDpRequestProcessor::SessionId()
    {
    return iSessionId;
    }
        
TBool CMTPExampleDpRequestProcessor::DoHandleResponsePhaseL()
        {
        TMTPResponseCode responseCode = (iCancelled ? EMTPRespCodeIncompleteTransfer : EMTPRespCodeOK);
        SendResponseL(responseCode);
        return EFalse;
        }

TBool CMTPExampleDpRequestProcessor::DoHandleCompletingPhaseL()
        {
        CompleteRequestL();
        return ETrue;   
        }

void CMTPExampleDpRequestProcessor::ExtractSessionTransactionId()
        {    
        iSessionId = iRequest->Uint32(TMTPTypeRequest::ERequestSessionID);    
        iTransactionCode = iRequest->Uint32(TMTPTypeRequest::ERequestTransactionID);            
        }


TBool CMTPExampleDpRequestProcessor::Match(const TMTPTypeEvent& aEvent, MMTPConnection& aConnection) const
    {

    TUint32 eventSessionId = aEvent.Uint32(TMTPTypeEvent::EEventSessionID);
    TUint32 eventTransactionCode = aEvent.Uint32(TMTPTypeEvent::EEventTransactionID);
    
    TBool result = EFalse;
    if(iSessionId == eventSessionId && 
        iTransactionCode == eventTransactionCode &&
        &iConnection == &aConnection)
        {
        result = ETrue;
        }
    return result;  
    }
 
TBool CMTPExampleDpRequestProcessor::Match(const TMTPTypeRequest& aRequest, MMTPConnection& aConnection) const
    {
    TBool result = ((&aRequest == iRequest) && (&iConnection == &aConnection));
    return result;      
    }
 
void CMTPExampleDpRequestProcessor::HandleEventL(const TMTPTypeEvent& aEvent)
      {
      TUint16 eventCode = aEvent.Uint16(TMTPTypeEvent::EEventCode);
      iCancelled = (eventCode == EMTPEventCodeCancelTransaction);
      }

---

Copyright ©2010 Nokia Corporation and/or its subsidiary(-ies).
All rights reserved. Unless otherwise stated, these materials are provided under the terms of the Eclipse Public License v1.0.