--- /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;
+ }