// 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:

//

/**

 @file

 @internalComponent

*/

#include "cmtpoperator.h"

__FLOG_STMT( _LIT8( KComponent, "mtpoperator" ); )

CMTPOperator* CMTPOperator::NewL( MMTPOperatorNotifier& aNotifier )

    {

    CMTPOperator* self = new( ELeave ) CMTPOperator( aNotifier );

    self->ConstructL();

    return self;

    }

CMTPOperator::~CMTPOperator()

    {

    Cancel();

    iPendingOperations.Reset();

    iPendingOperations.Close();

    iMTPClient.Close();

    __FLOG( _L8("+/-Dtor") );

    __FLOG_CLOSE;

    }

void CMTPOperator::StartTransport( TUid aTransport )

    {

    __FLOG_1( _L8("+/-StartTransport( 0x%08X )"), aTransport.iUid );

    TInt err = AppendOperation( EStartTransport, aTransport );

    if ( KErrNone != err )

        {

        iNotifier.HandleStartTrasnportCompleteL( err );

        }

    }

void CMTPOperator::StopTransport( TUid aTransport )

    {

    __FLOG_1( _L8("+/-StopTransport( 0x%08X )"), aTransport.iUid );

    TInt err = AppendOperation( EStopTransport, aTransport );

    if ( KErrNone != err )

        {

        iNotifier.HandleStartTrasnportCompleteL( err );

        }

    }

void CMTPOperator::DoCancel()

    {

    __FLOG( _L8("+/-DoCancel") );

    }

void CMTPOperator::RunL()

    {

    __FLOG( _L8("+RunL") );

    TInt count = iPendingOperations.Count();

    if ( count > 0 )

        {

        TOperation& operation = iPendingOperations[0];

        TRAP_IGNORE( HandleOperationL( operation ) );

        iPendingOperations.Remove( 0 );

        }

    __FLOG( _L8("-RunL") );

    }

CMTPOperator::CMTPOperator( MMTPOperatorNotifier& aNotifier ):

    CActive( EPriorityStandard ),

    iNotifier( aNotifier )

    {

    __FLOG_OPEN( KMTPSubsystem, KComponent );

    __FLOG( _L8("+/-Ctor") );

    }

void CMTPOperator::ConstructL()

    {

    __FLOG( _L8("+ConstructL") );

    CActiveScheduler::Add( this );

    User::LeaveIfError( iMTPClient.Connect() );

    __FLOG( _L8("-ConstructL") );

    }

TInt CMTPOperator::AppendOperation( TOperationType aType, TUid aTransport )

    {

    TOperation operation = { aType, aTransport };

    TInt err = iPendingOperations.Append( operation );

    if ( ( KErrNone == err ) && !IsActive() )

        {

        Schedule( KErrNone );

        }

    return err;

    }

void CMTPOperator::Schedule( TInt aError )

    {

    __FLOG_1( _L8("+/-Schedule( %d )"), aError );

    TRequestStatus* status = &iStatus;

    User::RequestComplete( status, aError );

    SetActive();

    }

void CMTPOperator::HandleOperationL( const TOperation& aOperation )

    {

    __FLOG_2( _L8("+HandleOperationL( 0x%08X, 0x%08X )"), aOperation.iTransport.iUid, aOperation.iType );

    TInt err = KErrNone;

    switch ( aOperation.iType )

        {

        case EStartTransport:

            err = iMTPClient.StartTransport( aOperation.iTransport );

            iNotifier.HandleStartTrasnportCompleteL( err );

            break;

        default:

            __ASSERT_DEBUG( ( EStopTransport == aOperation.iType ), User::Invariant() );

            iNotifier.HandleStopTrasnportCompleteL( err );

            break;

        }

    __FLOG( _L8("-HandleOperationL") );

    }