--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/kerneltest/f32test/smassstorage/src/t_ms_clisvr.cpp	Mon Oct 19 15:55:17 2009 +0100
@@ -0,0 +1,196 @@
+// Copyright (c) 2004-2009 Nokia Corporation and/or its subsidiary(-ies).
+// All rights reserved.
+// This component and the accompanying materials are made available
+// under the terms of the License "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:
+// f32test\msfs\src\t_ms_clisvr.cpp
+// 
+//
+
+#define __T_MS_CLISVR__
+
+#include <f32file.h>
+#include <e32test.h>
+#include <e32std.h>
+#include <e32std_private.h>
+#include <e32svr.h>
+#include <hal.h>
+#include <massstorage.h>
+#include "rusbmassstorage.h"
+#include "t_ms_main.h"
+
+#ifdef __USBMS_NO_PROCESSES__
+#include <e32math.h>
+#endif
+
+GLDEF_D RUsbMassStorage gUsbMs;
+
+// Unit test for MS client API and server API
+GLREF_C void t_ms_clisvr();
+
+// Unit test for MS file server
+GLREF_C void t_ms_fsunit();
+
+
+LOCAL_C TInt StartServer()
+//
+// Start the server process or thread
+//
+	{
+	const TUidType serverUid(KNullUid, KNullUid, KUsbMsSvrUid);
+
+#ifdef __USBMS_NO_PROCESSES__
+	//
+	// In EKA1 WINS the server is a DLL, the exported entrypoint returns a TInt
+	// which represents the real entry-point for the server thread
+	//
+	RLibrary lib;
+	TInt err = lib.Load(KUsbMsImg, serverUid);
+
+	if (err != KErrNone )
+		{
+		return err;
+		}
+	TLibraryFunction ordinal1 = lib.Lookup(1);
+	TThreadFunction serverFunc = reinterpret_cast<TThreadFunction>(ordinal1());
+
+	//
+	// To deal with the unique thread (+semaphore!) naming in EPOC, and that we may
+	// be trying to restart a server that has just exited we attempt to create a
+	// unique thread name for the server.
+	// This uses Math::Random() to generate a 32-bit random number for the name
+	//
+	TName name(KUsbMsServerName);
+	name.AppendNum(Math::Random(),EHex);
+	
+	RThread server;
+	err = server.Create (
+		name,
+		serverFunc,
+		KUsbMsStackSize,
+		NULL,
+		&lib,
+		NULL,
+		KUsbMsMinHeapSize,
+		KUsbMsMaxHeapSize,
+		EOwnerProcess
+	);
+
+	lib.Close();	// if successful, server thread has handle to library now
+#else
+	//
+	// EPOC and EKA2 is easy, we just create a new server process. Simultaneous
+	// launching of two such processes should be detected when the second one
+	// attempts to create the server object, failing with KErrAlreadyExists.
+	//
+	RProcess server;
+	TInt err = server.Create(KUsbMsImg1, KNullDesC, serverUid);
+	if (err == KErrNotFound)
+		{
+		err = server.Create(KUsbMsImg, KNullDesC, serverUid);
+		}
+#endif 
+	
+	if (err != KErrNone)
+		{
+		return err;
+		}
+
+	TRequestStatus stat;
+	server.Rendezvous(stat);
+	
+	if (stat!=KRequestPending)
+		server.Kill(0);		// abort startup
+	else
+		server.Resume();	// logon OK - start the server
+
+	User::WaitForRequest(stat);		// wait for start or death
+
+	// we can't use the 'exit reason' if the server panicked as this
+	// is the panic 'reason' and may be '0' which cannot be distinguished
+	// from KErrNone
+	err = (server.ExitType() == EExitPanic) ? KErrServerTerminated : stat.Int();
+
+	server.Close();
+
+	return err;
+	}
+
+LOCAL_C void DoTestConnect()
+    // 
+    // Connect to the file server
+    // 
+    {
+    test.Printf(_L("DoTestConnect\n"));
+    // Load MS file server
+    TInt r = StartServer();
+    test(KErrNone == r);
+    // Connect to MS file server
+    r = gUsbMs.Connect();
+    test(KErrNone == r);
+    
+    test.Printf(_L("DoTestConnect ====> PASS\n"));
+    }
+    
+LOCAL_C void DoTestStart()
+    //
+    // Start mass storage device
+    //
+    {
+
+    TMassStorageConfig msConfig;
+    msConfig.iVendorId.Copy(t_vendorId);
+    msConfig.iProductId.Copy(t_productId);
+    msConfig.iProductRev.Copy(t_productRev);
+
+    TInt r = gUsbMs.Start(msConfig);
+    test(KErrNone == r);
+    
+    test.Printf(_L("DoTestStart ====> PASS\n"));
+    }
+
+LOCAL_C void DoTestStop()
+    //
+    // Stop USB device
+    //
+    {
+    test.Printf(_L("TestStop\n"));
+    TInt r = gUsbMs.Stop();
+    test(KErrNone == r); 
+    
+    test.Printf(_L("DoTestStop ====> PASS\n"));;
+    }
+
+GLDEF_C void t_ms_clisvr()
+//
+// Do all tests
+//
+	{
+	test.Next( _L("TestConnect") );
+    DoTestConnect();
+   	test.Next(_L("TestStart"));
+    DoTestStart();
+    test.Next(_L("TestStop"));
+    DoTestStop();
+ 	gUsbMs.Shutdown();
+	gUsbMs.Close();
+    
+    }
+
+GLDEF_C void CallTestsL()
+	{
+	test.Start(_L("ClientServer Tests"));
+	t_ms_clisvr();
+	test.End();
+	test.Start(_L("File System Unit Tests"));
+	t_ms_fsunit();
+	test.End();
+	}