diff -r 000000000000 -r d0791faffa3f mtptransports/mtpcontroller/src/cmtpoperator.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/mtptransports/mtpcontroller/src/cmtpoperator.cpp	Tue Feb 02 01:11:40 2010 +0200
@@ -0,0 +1,138 @@
+// 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 );
+        }
+    __FLOG_1( _L8("+/-AppendOperation returns %d"), err );
+    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() );
+            err = iMTPClient.StopTransport( aOperation.iTransport );
+            iNotifier.HandleStopTrasnportCompleteL( err );
+            break;
+        }
+    __FLOG( _L8("-HandleOperationL") );
+    }
+