// 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();
	}