diff -r 000000000000 -r d0791faffa3f mtpfws/mtpfw/daemon/server/src/cmtpserversession.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/mtpfws/mtpfw/daemon/server/src/cmtpserversession.cpp	Tue Feb 02 01:11:40 2010 +0200
@@ -0,0 +1,219 @@
+// Copyright (c) 2006-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
+ @internalTechnology
+*/
+
+#include "cmtpconnectionmgr.h"
+#include "cmtpserversession.h"
+#include "rmtpframework.h"
+#include "cmtpframeworkconfig.h"
+#include "cmtpdataprovidercontroller.h"
+#include "cmtpparserrouter.h"
+#include "e32def.h"
+__FLOG_STMT(_LIT8(KComponent,"ServerSession");)
+
+
+/**
+Constructor.
+*/
+CMTPServerSession::CMTPServerSession()
+    {
+    __FLOG_OPEN(KMTPSubsystem, KComponent);
+    __FLOG(_L8("CMTPServerSession - Entry"));
+    __FLOG(_L8("CMTPServerSession - Exit"));
+    }
+    
+/**
+Destructor.
+*/
+CMTPServerSession::~CMTPServerSession()
+    {
+    __FLOG(_L8("~CMTPServerSession - Entry"));
+    static_cast<CMTPServer*>(const_cast<CServer2*>(CSession2::Server()))->DropSession();
+    iSingletons.Close();
+    __FLOG(_L8("~CMTPServerSession - Exit"));
+    __FLOG_CLOSE;
+    }
+    
+void CMTPServerSession::CreateL()
+    {
+    __FLOG(_L8("CreateL - Entry"));
+    iSingletons.OpenL();
+    static_cast<CMTPServer*>(const_cast<CServer2*>(CSession2::Server()))->AddSession();
+    __FLOG(_L8("CreateL - Exit"));
+    }
+
+void CMTPServerSession::ServiceL(const RMessage2& aMessage)
+    {
+    __FLOG(_L8("ServiceL - Entry"));
+    switch (aMessage.Function())
+        {
+    case EMTPClientStartTransport:
+        __FLOG(_L8("StartTransport message received"));        
+        DoStartTransportL(aMessage);
+        break;
+    case EMTPClientStopTransport:
+        __FLOG(_L8("StopTransport message received"));
+        DoStopTransport(aMessage);
+        break;
+     case EMTPClientIsAvailable :
+        __FLOG(_L8("IsAvailable message received"));
+        DoIsAvailableL(aMessage);
+     
+        break;
+    default:
+        __FLOG(_L8("Unrecognised message received"));
+        break;        
+        }
+    __FLOG(_L8("ServiceL - Exit"));
+    }
+TBool CMTPServerSession::CheckIsAvailableL(TUid aNewUID,TUid aCurUID)
+{
+
+	    TInt SwitchEnabled;
+	    iSingletons.FrameworkConfig().GetValueL(CMTPFrameworkConfig::ETransportSwitchEnabled, SwitchEnabled);	    
+	    if(!SwitchEnabled )
+		    {		    
+		    return EFalse;
+		    }
+       TBuf<30> value;
+       iSingletons.FrameworkConfig().GetValueL(CMTPFrameworkConfig::ETransportHighPriorityUID,value);	    	    
+	   TUint HighUID;	    
+	   TLex lex(value);	    
+	   TInt conErr = lex.Val(HighUID,EHex);
+	   if(aCurUID.iUid == HighUID)
+		    {
+		    return EFalse;	
+
+		    }
+	   else if(aNewUID.iUid ==HighUID)
+		    {
+	    	return ETrue;
+		    }
+	   return EFalse;	
+}
+/**
+Starts up the specified MTP transport protocol.
+@param aTransport The implementation UID of the transport protocol implemetation.
+@leave One of the system wide error codes, if a processing error occurs.
+*/
+void CMTPServerSession::DoStartTransportL(const RMessage2& aMessage)
+    {
+    __FLOG(_L8("DoStartTransportL - Entry"));
+    TUid newUID = TUid::Uid(aMessage.Int0()); 
+    TUid curUID = iSingletons.ConnectionMgr().TransportUid();
+    if(curUID !=(KNullUid))  // Another Transport is already running
+		{
+    	if(!CheckIsAvailableL(newUID,curUID))
+    		{
+    		aMessage.Complete(KErrServerBusy);
+    		iSingletons.ConnectionMgr().QueueTransportL( newUID, NULL );
+    		return;
+    		}
+	    iSingletons.ConnectionMgr().StopTransport(curUID);
+    	}
+    
+    TUid secureid=aMessage.SecureId();    
+    iSingletons.ConnectionMgr().SetClientSId(secureid);
+    
+    TInt length = aMessage.GetDesLength( 1 );
+    
+    if((!CheckIsBlueToothTransport(newUID) || (length!=0)) && (iSingletons.DpController().Count()==0))
+    	{
+    	iSingletons.DpController().LoadDataProvidersL();
+    	iSingletons.Router().ConfigureL();
+    	}
+   
+    if (length > 0)
+    	{
+    	HBufC8* paramHbuf = HBufC8::NewLC(length);
+    	TPtr8 bufptr = paramHbuf->Des();
+    	aMessage.ReadL( 1, bufptr, 0);
+    	TRAPD(err, iSingletons.ConnectionMgr().StartTransportL( newUID, static_cast<TAny*>(paramHbuf) ));
+    	if ( KErrArgument == err )
+    		{
+    		PanicClient( aMessage, EPanicErrArgument );
+    		}
+    	else if ( KErrNone == err )
+    		{
+    		aMessage.Complete(KErrNone);
+    		}
+    	else 
+    		{
+    		User::LeaveIfError( err );
+    		}
+    	CleanupStack::PopAndDestroy(paramHbuf);
+    	}
+    else
+    	{
+    	iSingletons.ConnectionMgr().StartTransportL(newUID, NULL);
+    	aMessage.Complete(KErrNone);
+    	}
+    
+    
+    __FLOG(_L8("DoStartTransportL - Exit"));
+    }  
+
+
+/**
+Shuts down the specified MTP transport protocol.
+@param aTransport The implementation UID of the transport protocol implemetation.
+*/  
+void CMTPServerSession::DoStopTransport(const RMessage2& aMessage)
+    {
+    __FLOG(_L8("DoStopTransport - Entry"));
+   iSingletons.ConnectionMgr().StopTransport( TUid::Uid( aMessage.Int0() ), ETrue );
+    aMessage.Complete(KErrNone);
+    __FLOG(_L8("DoStopTransport - Exit"));
+    }
+
+/**
+Checks whether MTP Framework shall allow the StartTransport Command for given transport.
+@param aTransport The implementation UID of the transport protocol implementation.
+@leave One of the system wide error codes, if a processing error occurs.
+*/  
+void CMTPServerSession::DoIsAvailableL(const RMessage2& aMessage)
+    {
+    __FLOG(_L8("DoStopTransport - Entry"));
+   
+   TUid newUID = TUid::Uid(aMessage.Int0()); 
+   TUid curUID = iSingletons.ConnectionMgr().TransportUid();
+   
+   if(curUID !=(KNullUid))  // Another Transport is already running
+		{
+		if(curUID== newUID)
+			{
+    		aMessage.Complete(KErrAlreadyExists); 	
+    		return;				
+			}
+    	else if(!CheckIsAvailableL(newUID,curUID))
+    		{
+    		aMessage.Complete(KErrServerBusy); 	
+    		return;
+    		}	    
+    	}
+
+    aMessage.Complete(KErrNone);
+    __FLOG(_L8("DoStopTransport - Exit"));
+    }
+
+TBool CMTPServerSession::CheckIsBlueToothTransport(TUid aNewUid)
+	{
+	TInt32 bluetoothUid = 0x10286FCB;
+	return aNewUid.iUid == bluetoothUid;
+	}