diff -r 000000000000 -r 1e05558e2206 usbclasses/usbphoneasmodem/classimplementation/mscfileserver/src/mscfileserver.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/usbclasses/usbphoneasmodem/classimplementation/mscfileserver/src/mscfileserver.cpp	Thu Dec 17 09:14:30 2009 +0200
@@ -0,0 +1,196 @@
+// Copyright (c) 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
+ Implements a Symbian OS server that exposes the RUsbMassStorage API
+ */
+
+#include <e32svr.h>
+#include "usbmscfileshared.h"
+#include "mscfileserver.h"
+#include "mscfilesession.h"
+#include "mscfileserversecuritypolicy.h"
+#include "mscfilecontroller.h"
+#include "debug.h"
+
+/**
+ Constructs a USB mass storage Server
+ 
+ @return  a pointer to CMscFileServer object
+ */
+CMscFileServer* CMscFileServer::NewLC()
+	{
+	CMscFileServer* r = new (ELeave) CMscFileServer();
+	CleanupStack::PushL(r);
+	r->ConstructL();
+	return r;
+	}
+
+/**
+ Destructor
+ */
+CMscFileServer::~CMscFileServer()
+	{
+	TRACE_FUNC
+
+    delete iController;
+	}
+
+/**
+ Constructor
+
+ @param aController a USB mass storage controller reference
+ */
+CMscFileServer::CMscFileServer()
+     : CPolicyServer(EPriorityHigh, KMscFileServerPolicy)
+	{
+	}
+
+void CMscFileServer::ConstructL()
+    {
+    TRACE_FUNC
+
+    StartL( KMscFileServerName );
+
+    iController = CMscFileController::NewL();
+    }
+/**
+ Create a new session on this server
+ 
+ @param	&aVersion	Version of client
+ @return	A pointer to a session object to be used for the client
+ */
+CSession2* CMscFileServer::NewSessionL(const TVersion &aVersion, const RMessage2& /*aMessage*/) const
+	{
+	TRACE_FUNC
+	TVersion v( KUsbMsSrvMajorVersionNumber,
+	            KUsbMsSrvMinorVersionNumber,
+	            KUsbMsSrvBuildVersionNumber );
+
+	if ( !User::QueryVersionSupported( v, aVersion ) )
+	    {
+        User::Leave( KErrNotSupported );
+	    }
+
+	CMscFileServer* ncThis = const_cast<CMscFileServer*>(this);
+	CMscFileSession* sess = CMscFileSession::NewL(*ncThis);
+	return sess;
+	}
+
+
+/**
+ Inform the client there has been an error.
+ 
+ @param	aError	The error that has occurred
+ */
+void CMscFileServer::Error(TInt aError)
+	{
+	TRACE_STATE(( _L("!! CMscFileServer::Error( %d )"), aError ))
+
+	Message().Complete(aError);
+	ReStart();
+	}
+
+/**
+ Increment the open session count (iSessionCount) by one.
+ 
+ @post	the number of open sessions is incremented by one
+ */
+void CMscFileServer::IncrementSessionCount()
+	{
+	TRACE_STATE(( _L(">< CMscFileServer::IncrementSessionCount( %d )"), iSessionCount ))
+	__ASSERT_DEBUG(iSessionCount >= 0, User::Panic(KUsbMsSvrPncCat, EUsbMsPanicIllegalIPC));
+	
+	++iSessionCount;
+	}
+
+/**
+ Decrement the open session count (iSessionCount) by one.
+ 
+ @post		the number of open sessions is decremented by one
+ */
+void CMscFileServer::DecrementSessionCount()
+	{
+	TRACE_STATE(( _L(">< CMscFileServer::DecrementSessionCount( %d )"), iSessionCount ))
+	__ASSERT_DEBUG(iSessionCount > 0, User::Panic(KUsbMsSvrPncCat, EUsbMsPanicIllegalIPC));
+
+	--iSessionCount;
+	}
+
+void CMscFileServer::ThreadFunctionL()
+    {
+    TRACE_FUNC_ENTRY
+
+    // Naming the server thread after the server helps to debug panics
+    User::LeaveIfError( User::RenameThread( KMscFileServerName ) );
+    
+    // Construct active scheduler
+    CActiveScheduler* activeScheduler = new ( ELeave ) CActiveScheduler;
+    CleanupStack::PushL( activeScheduler ) ;
+
+    // Install active scheduler
+    // We don't need to check whether an active scheduler is already installed
+    // as this is a new thread, so there won't be one
+    CActiveScheduler::Install( activeScheduler );
+
+    // Construct our server
+    CMscFileServer::NewLC(); // Anonymous
+
+    RProcess::Rendezvous( KErrNone );
+
+    // Start handling requests
+    CActiveScheduler::Start();
+
+    //===== thread stopped =====
+    TRACE_INFO(( _L( "   MscFileServer thread stopped" ) ))
+    CleanupStack::PopAndDestroy( 2, activeScheduler ); // Anonymous CMscFileServer
+    
+    TRACE_FUNC_EXIT
+    }
+
+
+TInt CMscFileServer::ThreadFunction( TAny* /*aNone*/ )
+    {
+    TRACE_FUNC_ENTRY
+    CTrapCleanup* cleanupStack = CTrapCleanup::New();
+    if ( !cleanupStack )
+        {
+        RThread::Rendezvous( KErrNoMemory );
+        }
+
+    TRAPD( err, ThreadFunctionL() )
+    if ( err != KErrNone )
+        {
+        TRACE_ERROR(( _L( "*** Error! Thread leaves w/ %d ***" ), err ))
+        RThread::Rendezvous( KErrNoMemory );        
+        }
+
+    delete cleanupStack;
+    cleanupStack = NULL;
+
+    TRACE_FUNC_EXIT
+    return KErrNone;
+    }
+
+
+TInt E32Main()
+    {
+    return CMscFileServer::ThreadFunction( NULL );
+    }
+
+