Collapse all Symbian^3 Product Developer Library

 

examples/RemoteConn/MtpDataProviderExample/src/mtpdataproviderpluginexample.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 <bautils.h>
#include <mtp/mmtpconnection.h>
#include <mtp/mtpprotocolconstants.h>
#include <mtp/mmtpdataproviderframework.h>
#include <mtp/mmtpstoragemgr.h>
#include <mtp/cmtpobjectmetadata.h>
#include <mtp/mmtpobjectmgr.h>

#include "mtpdataproviderpluginexample.h"

#include "mtpexamplerequestprocessor.h"
#include "cmtpexampledprequestprocessor.h"

#include "cmtpexampledpconst.h"


// Class constants.
static const TInt KMTPExampleDpSessionGranualrity = 3;


TAny* CMTPExampleDataProvider::NewL(TAny* aParams)
        {
        CMTPExampleDataProvider* self = new (ELeave) CMTPExampleDataProvider(aParams);
        CleanupStack::PushL(self);
        self->ConstructL();
        CleanupStack::Pop(self);
        return self;
        }
        
CMTPExampleDataProvider::CMTPExampleDataProvider(TAny* aParams)
        :CMTPDataProviderPlugin(aParams),
        iActiveProcessors(KMTPExampleDpSessionGranualrity),
    iActiveProcessor(-1)
        {
        
        }

CMTPExampleDataProvider::~CMTPExampleDataProvider()
        {
    TUint count(iActiveProcessors.Count());
    while (count--)
        {
        iActiveProcessors[count]->Release();
        }
    iActiveProcessors.Close();
        }
        

void CMTPExampleDataProvider::Cancel()
        {
        }

void CMTPExampleDataProvider::Supported(TMTPSupportCategory aCategory, RArray<TUint>& aArray) const
    {
    switch (aCategory) 
        {        
        case EEvents:
            break;
        case EObjectPlaybackFormats:
        case EObjectCaptureFormats:
            break;
        case EObjectProperties:
            break; 
    
        case EOperations:
            {
            TInt count(sizeof(KMTPExampleDpSupportedOperations) / sizeof(KMTPExampleDpSupportedOperations[0]));
            for (TInt i(0); (i < count); i++)
                {
                aArray.Append(KMTPExampleDpSupportedOperations[i]);
                }   
            }
            break;  
   
        default:   
            break;
        }
    }
void CMTPExampleDataProvider::SupportedL(TMTPSupportCategory aCategory, CDesCArray& /*aStrings*/) const
        {
        switch (aCategory) 
        {
        case EFolderExclusionSets:
            break;
        case EFormatExtensionSets:
            break;
        default:
            break;
        }
        }

void CMTPExampleDataProvider::StartObjectEnumerationL(TUint32 aStorageId)
    {
    Framework().ObjectEnumerationCompleteL(aStorageId);

    }
    
void CMTPExampleDataProvider::StartStorageEnumerationL()
    {
    Framework().StorageEnumerationCompleteL();
    }

void CMTPExampleDataProvider::ProcessEventL(const TMTPTypeEvent& aEvent, MMTPConnection& aConnection)   
        {
    TInt idx = LocateRequestProcessorL(aEvent, aConnection);

    if (idx != KErrNotFound)
        {
        iActiveProcessors[idx]->HandleEventL(aEvent);
        }
        }

void CMTPExampleDataProvider::ProcessNotificationL(TMTPNotification aNotification, const TAny* aParams)
    {
    switch (aNotification)
        {
    case EMTPSessionClosed:
        SessionClosedL(*reinterpret_cast<const TMTPNotificationParamsSessionChange*>(aParams));
        break;
        
    case EMTPSessionOpened:
        SessionOpenedL(*reinterpret_cast<const TMTPNotificationParamsSessionChange*>(aParams));
        break;
        
    default:
        // Ignore all other notifications.
        break;
        }
    }
    
void CMTPExampleDataProvider::ProcessRequestPhaseL(TMTPTransactionPhase aPhase, const TMTPTypeRequest& aRequest, MMTPConnection& aConnection)
        {
    //Check if the request is handled.
    TInt idx(LocateRequestProcessorL(aRequest, aConnection));
    MMTPExampleDpRequestProcessor* processor(iActiveProcessors[idx]);
    //Handle the request
    TBool result(processor->HandleRequestL(aRequest, aPhase));
    if (result)    //destroy the processor
        {
        processor->Release();
        iActiveProcessors.Remove(idx);
        }
        }

void CMTPExampleDataProvider::SessionClosedL(const TMTPNotificationParamsSessionChange& aSession)       
        {
    TInt count = iActiveProcessors.Count();
    while(count--)
        {
        MMTPExampleDpRequestProcessor* processor = iActiveProcessors[count];
        TUint32 sessionId = processor->SessionId();
        if((sessionId == aSession.iMTPId) && (processor->Connection().ConnectionId() == aSession.iConnection.ConnectionId()))
            {
            iActiveProcessors.Remove(count);
            if (count == iActiveProcessor)
                {
                iActiveProcessorRemoved = ETrue;
                }
            else
                {
                processor->Release();
                }
            }
        } 
        }

void CMTPExampleDataProvider::SessionOpenedL(const TMTPNotificationParamsSessionChange& /*aSession*/)   
        {
        }
        
TAny* CMTPExampleDataProvider::GetExtendedInterface(TUid /*aInterfaceUid*/)     
        {
        return NULL;
        }

void CMTPExampleDataProvider::ConstructL()      
        {

      
        }

TInt CMTPExampleDataProvider::LocateRequestProcessorL(const TMTPTypeRequest& aRequest, MMTPConnection& aConnection)
        {
    TInt idx(KErrNotFound);
    //Get the Count of the request supported.
    TInt count(iActiveProcessors.Count());
    //Not found create and then append to the array.
    if (idx == KErrNotFound)
        {
        MMTPExampleDpRequestProcessor* processor = MTPExampleDpProcessor::CreateL
                                                 (Framework(), aRequest, aConnection);
        CleanupReleasePushL(*processor);
        iActiveProcessors.AppendL(processor);
        CleanupStack::Pop(processor);
        idx = count;
        }
    return idx;
        }

TInt CMTPExampleDataProvider::LocateRequestProcessorL(const TMTPTypeEvent& aEvent, MMTPConnection& aConnection)
        {
    TInt idx(KErrNotFound);
    TInt count(iActiveProcessors.Count());
    for (TInt i(0); (i < count); i++)
        {
        if (iActiveProcessors[i]->Match(aEvent, aConnection))
            {
            idx = i;
            break;
            }
        }    
    return idx;   
        }
        
        

---

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.