/*

* Copyright (c) 2007 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:  Requests handler

*

*/

#include <ecom/ecom.h>

#include <cusbdevicecontrolplugin.h>

#include "cusbdevcon.h"

#include "crequestshandler.h"

#include "debug.h"

// ---------------------------------------------------------------------------

// Two-phase construction

// ---------------------------------------------------------------------------

//

CRequestsHandler* CRequestsHandler::NewL(RDevUsbcClient& aLdd,

                                         RUsbWatcher& aUsbWatcher,

                                         RUsb& aUsbManager)

    {

    FLOG( _L( "[USBDEVCON]\tCRequestsHandler::NewL" ) );

    CRequestsHandler* self = new (ELeave) CRequestsHandler(aLdd, aUsbWatcher, aUsbManager);

    CleanupStack::PushL(self);

    self->ConstructL();

    CleanupStack::Pop(self);

    return self;    

    }

// -------------------------------------Handle--------------------------------------

// Two-phase construction

// ---------------------------------------------------------------------------

//  

void CRequestsHandler::ConstructL()

    {

    FLOG( _L( "[USBDEVCON]\tCRequestsHandler::ConstructL" ) );

    // read, construct and attach handlers

    RImplInfoPtrArray implementations;

    const TEComResolverParams noResolverParams;

    REComSession::ListImplementationsL(KUsbCMHandlerInterface, noResolverParams, KRomOnlyResolverUid, implementations);

    for (TUint i(0); i < implementations.Count(); ++i)

        {

        TUid uid(implementations[i]->ImplementationUid());

        CUsbCMHandler* handler = (reinterpret_cast<CUsbCMHandler*>(REComSession::CreateImplementationL

                                                                                                    (uid, _FOFF(CUsbCMHandler, iPrivateEComUID))));

        iHandlers.Append(handler);

        }

   implementations.Close(); // cleanup

   FTRACE(FPrint(

           _L("[USBDEVCON]\tCRequestsHandler::ConstructL: Amount of handlers attached = %d" ), iHandlers.Count()));

    // initialize handlers, pass them iLdd, iUsbWatcher, iUsbManager

    for(TInt i(0); i < iHandlers.Count(); ++i)

        {

        iHandlers[i]->Initialize(iLdd, iUsbWatcher, iUsbManager);

        }

    }

// ---------------------------------------------------------------------------

// Default construction

// ---------------------------------------------------------------------------

//

CRequestsHandler::CRequestsHandler( RDevUsbcClient& aLdd, 

                                    RUsbWatcher& aUsbWatcher,

                                    RUsb& aUsbManager) : 

                            iLdd (aLdd),

                            iUsbWatcher(aUsbWatcher),

                            iUsbManager(aUsbManager)

    {

    }

// ---------------------------------------------------------------------------

// Destruction

// ---------------------------------------------------------------------------

//

CRequestsHandler::~CRequestsHandler()

    {

    FLOG( _L( "[USBDEVCON]\tCRequestsHandler::~CRequestsHandler()" ) );

    // destroy handlers  

    iHandlers.ResetAndDestroy();

    REComSession::FinalClose(); // plug-ins final cleanup

    }   

// ---------------------------------------------------------------------------

// Search plugin which can handle the request

// ---------------------------------------------------------------------------

//

TInt CRequestsHandler::Handle(const RBuf8& aSetupPacket, RBuf8& aData)

    {

    FLOG( _L( "[USBDEVCON]\tCRequestsHandler::Handle" ) );

    TInt err(KErrNotSupported);

    TUint counter(0); // handlers counter

    // loop through handlers, call handle() while error == KErrNotSupported

    while((err == KErrNotSupported) && (counter < iHandlers.Count()))               

        {

        err = iHandlers[counter]->Handle(aSetupPacket, aData);

        ++counter;

        }

    return err;

    }