/*

* Copyright (c) 2001-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:

* Contains sanity tests for various things.

*

*/

#include <e32base.h>

#include <c32comm.h>

#include <usbman.h>

#include <acminterface.h>

#include <e32test.h>

#ifndef __WINS__

_LIT(KCommDriverName, "EUSBC");

#else

_LIT(KCommPhysDriverName, "ECDRV");

_LIT(KCommPhysDeviceName, "Comm.Wins");

_LIT(KCommDriverName, "ECOMM");

#endif

LOCAL_D RTest gTest(_L("T_CSYACCESS"));

enum TInitReturnValue 

	{

	ENotFinished,

	EFinished

	};

TInitReturnValue C32_FailAcmOpen(TUint aCount);

TInitReturnValue C32_SucceedAcmOpen(TUint aCount);

TInitReturnValue USBMAN_SucceedAcmOpen(TUint aCount);

TUint gInitSafetyTimeout = 100000;

TUint gBetweenTestDelay = 1000000;

TInt _1();

TInt _2();

TInt _3();

TInt _4();

TInt _5();

TInt Oom(TInitReturnValue fn(TUint n));

TInt Regression_DEF23333();

TInt RunOneTest(TInt aKey);

void RunAll();

#define TEST(AAA)	{ if ( !(AAA) ) { return __LINE__; } }

TInt _1()

/**

 * Checks: 

 *	1/ can't open ACM port when USBMAN isn't started.

 *	2/ can open ACM port when USBMAN is started.

 *	3/ then stop USBMAN and check Read and Write complete with error.

 *	4/ then close the port and check that opening ACM port returns error.

 *	5/ then restarts USBMAN and checks the ACM port can be opened then shuts 

 *		it all down.

 *	6/ then start USBMAN, open ACM port, issue a Read request, close USBMAN, 

 *		and check the Read is completed with an error.

 */

	{

	gTest.Printf(_L("\nRunning test 1"));

	CActiveScheduler* sch = new(ELeave) CActiveScheduler;

	CActiveScheduler::Install(sch);

	TName portName(KAcmSerialName);

	portName.AppendFormat(_L("::%d"), KAcmLowUnit);

	// Try to access serial/USB when the registration hasn't been done

	RCommServ sess;

	TEST(sess.Connect() == KErrNone);

	RComm port;

	TEST(sess.LoadCommModule(KAcmCsyName) == KErrNone);

	TInt err = port.Open(sess, portName, ECommExclusive); // should fail

	TEST(err == KErrAccessDenied);

	// Start USB services

	RUsb usb;

	TEST(usb.Connect() == KErrNone);

	TRequestStatus stat;

	usb.Start(stat);

	User::WaitForRequest(stat);

	TEST(stat.Int() == KErrNone);

	// Try to access serial/USB when the registration HAS been done

	TEST(port.Open(sess, portName, ECommExclusive) == KErrNone); // should work

	// Deregister and check further RComm calls

	usb.Stop();

	usb.Close();

	TBuf8<10> buf;

	port.Read(stat, buf);

	User::WaitForRequest(stat);

	TEST(stat.Int() == KErrAccessDenied);

	port.Write(stat, _L8("stuff"));

	User::WaitForRequest(stat);

	TEST(stat.Int() == KErrAccessDenied);

	port.Close();

	err = port.Open(sess, portName, ECommExclusive); // should fail

	TEST(err == KErrAccessDenied);

	// Check can open again after restarting service

	TEST(usb.Connect() == KErrNone);

	usb.Start(stat);

	User::WaitForRequest(stat);

	TEST(stat.Int() == KErrNone);

	err = port.Open(sess, portName, ECommExclusive); // should work

	TEST(err == KErrNone);

	port.Close();

	usb.Stop();

	usb.Close();

	// Check completion of an outstanding RComm request when usbman pulls the 

	// rug out.

	TEST(usb.Connect() == KErrNone);

	usb.Start(stat);

	User::WaitForRequest(stat);

	TEST(stat.Int() == KErrNone);

	err = port.Open(sess, portName, ECommExclusive); // should work

	TEST(err == KErrNone);

	// Hacky pause to wait for device to enumerate.

	User::After(1000000);

	port.Read(stat, buf);

	usb.Stop();

	User::WaitForRequest(stat);

	TEST(stat.Int() == KErrAccessDenied);

	// Clean up

	port.Close(); 

	TEST(sess.UnloadCommModule(KAcmSerialName) == KErrNone);

	sess.Close();

	usb.Close();

	delete sch;

	return KErrNone;

	}

TInt _2()

/**

 * Checks: 

 *	simple open/close of registration port

 */

	{

	gTest.Printf(_L("\nRunning test 2"));

	CActiveScheduler* sch = new(ELeave) CActiveScheduler;

	CActiveScheduler::Install(sch);

	TName portName(KAcmSerialName);

	portName.AppendFormat(_L("::%d"), 666);

	RCommServ sess;

	TEST(sess.Connect() == KErrNone);

	RComm port;

	TEST(sess.LoadCommModule(KAcmCsyName) == KErrNone);

	TEST(port.Open(sess, portName, ECommExclusive) == KErrNone); 

	port.Close();

	TEST(sess.UnloadCommModule(KAcmSerialName) == KErrNone);

	sess.Close();

	delete sch;

	return KErrNone;

	}

TInt _3()

/**

 * Checks: 

 *	simple open/close of registration port with open/close of ACM port inside 

 *	that.

 */

	{

	gTest.Printf(_L("\nRunning test 3"));

	CActiveScheduler* sch = new(ELeave) CActiveScheduler;

	CActiveScheduler::Install(sch);

	TName portName(KAcmSerialName);

	portName.AppendFormat(_L("::%d"), 666);

	RCommServ sess;

	TEST(sess.Connect() == KErrNone);

	RComm port;

	TEST(sess.LoadCommModule(KAcmCsyName) == KErrNone);

	TEST(port.Open(sess, portName, ECommExclusive) == KErrNone); 

	TName acmPortName(KAcmSerialName);

	acmPortName.AppendFormat(_L("::%d"), KAcmLowUnit);

	RComm acmPort;

	TEST(acmPort.Open(sess, acmPortName, ECommExclusive) == KErrNone); 

	acmPort.Close();

	port.Close();

	TEST(sess.UnloadCommModule(KAcmSerialName) == KErrNone);

	sess.Close();

	delete sch;

	return KErrNone;

	}

TInt _4()

/**

 * Checks: 

 *	opens registration port (NB actually starts USB- just opening reg port 

 *		doesn't instantiate the LDD, which we need to get the Read test to 

 *		work. Otherwise the read comes back immediately with KErrGeneral.)

 *	opens ACM port

 *	check ACM APIs active

 *	closes registration port (NB stop & close USB)

 *	checks ACM APIs inactive

 *	closes ACM port.

 */

	{

	gTest.Printf(_L("\nRunning test 4"));

	CActiveScheduler* sch = new(ELeave) CActiveScheduler;

	CActiveScheduler::Install(sch);

	// Start USB services

	RUsb usb;

	TEST(usb.Connect() == KErrNone);

	TRequestStatus stat;

	usb.Start(stat);

	User::WaitForRequest(stat);

	TEST(stat.Int() == KErrNone);	  

	RCommServ sess;

	TEST(sess.Connect() == KErrNone);

	TName acmPortName(KAcmSerialName);

	acmPortName.AppendFormat(_L("::%d"), KAcmLowUnit); 

	RComm acmPort;

	TEST(acmPort.Open(sess, acmPortName, ECommExclusive) == KErrNone); 

	// Hacky pause to wait for device to enumerate.

	User::After(1000000);

	TRequestStatus readStat;

	TRequestStatus timerStat;

	TBuf8<10> buf;

	acmPort.Read(readStat, buf);

	RTimer timer;

	TEST(timer.CreateLocal() == KErrNone);

	timer.After(timerStat, 1000000); 

	User::WaitForRequest(readStat, timerStat);

	TEST(readStat == KRequestPending);

	TEST(timerStat == KErrNone);

	acmPort.ReadCancel();

	User::WaitForRequest(readStat);

	TEST(readStat == KErrCancel);

	timer.Close();

	usb.Stop();

	usb.Close();

	acmPort.Read(readStat, buf);

	User::WaitForRequest(readStat);

	TEST(readStat == KErrAccessDenied);

	acmPort.Close();

	sess.Close();

	delete sch;

	return KErrNone;

	}

TInt _5()

/**

 * Checks: 

 *	opens registration port

 *	opens ACM port

 *	check ACM APIs active

 *	closes registration port

 *	checks ACM APIs inactive

 *	opens registration port

 *	checks ACM APIs active

 *	closes ACM port

 *	closes registration port

 */

	{

	gTest.Printf(_L("\nRunning test 5"));

	CActiveScheduler* sch = new(ELeave) CActiveScheduler;

	CActiveScheduler::Install(sch);

	// Start USB services

	RUsb usb;

	TEST(usb.Connect() == KErrNone);

	TRequestStatus stat;

	usb.Start(stat);

	User::WaitForRequest(stat);

	TEST(stat.Int() == KErrNone);	  

	RCommServ sess;

	TEST(sess.Connect() == KErrNone);

	TName acmPortName(KAcmSerialName);

	acmPortName.AppendFormat(_L("::%d"), KAcmLowUnit);

	RComm acmPort;

	TEST(acmPort.Open(sess, acmPortName, ECommExclusive) == KErrNone); 

	// Hacky pause to wait for device to enumerate.

	User::After(1000000);  

	TRequestStatus readStat;

	TRequestStatus timerStat;

	TBuf8<10> buf;

	acmPort.Read(readStat, buf);

	RTimer timer;

	TEST(timer.CreateLocal() == KErrNone);

	timer.After(timerStat, 1000000); 

	User::WaitForRequest(readStat, timerStat);

	TEST(readStat == KRequestPending);

	TEST(timerStat == KErrNone);

	acmPort.ReadCancel();

	User::WaitForRequest(readStat);

	TEST(readStat == KErrCancel);

	timer.Close();

	usb.Stop();

	acmPort.Read(readStat, buf);

	User::WaitForRequest(readStat);

	TEST(readStat == KErrAccessDenied);

	usb.Start(stat);

	User::WaitForRequest(stat);

	TEST(stat.Int() == KErrNone);	  

	// Hacky pause to wait for device to enumerate.

	User::After(1000000);

	acmPort.Read(readStat, buf);

	TEST(timer.CreateLocal() == KErrNone);

	timer.After(timerStat, 1000000);

	User::WaitForRequest(readStat, timerStat);

	TEST(readStat == KRequestPending);

	TEST(timerStat == KErrNone);

	acmPort.ReadCancel();

	User::WaitForRequest(readStat);

	TEST(readStat == KErrCancel);

	timer.Close();

	acmPort.Close();

	usb.Stop();

	usb.Close();

	sess.Close();

	delete sch;

	return KErrNone;

	}

TInitReturnValue C32_FailAcmOpen(TUint aCount)

/**

 * One iteration of loading ECACM.CSY and trying to open the ACM port. Will 

 * fail due to the access control (USB isn't started). Heap failures in C32's 

 * heap.

 */

	{

	RCommServ serv;

	TInt err = serv.Connect();

	if ( !err )

		{

		gTest.Printf(_L("\tconnected to server\n"));

		serv.__DbgMarkHeap();

		serv.__DbgFailNext(aCount);

		err = serv.LoadCommModule(KAcmCsyName);

		if ( !err )

			{

			gTest.Printf(_L("\tloaded comm module\n"));

			RComm comm;

			TName name(KAcmSerialName);

			name.AppendFormat(_L("::%d"), KAcmLowUnit); 

			err = comm.Open(serv, name, ECommExclusive);

			if ( err == KErrAccessDenied ) 

				{

				gTest.Printf(_L("\tsuccessful result from RComm::Open\n"));

				err = KErrNone;

				}

			}

		serv.UnloadCommModule(KAcmSerialName);

		User::After(gInitSafetyTimeout);

		serv.__DbgMarkEnd(0);

		serv.Close();

		User::After(gInitSafetyTimeout);

		if ( !err )

			{

			// Test for if the test has finished. If aCount has become so big 

			// as to skip over all the allocs in the above use case, the next 

			// API call which causes alloc will fail with KErrNoMemory. 

			if ( serv.Connect() == KErrNoMemory )

				{

				serv.Close();

				User::After(gInitSafetyTimeout);

				return EFinished;

				}

			}

		}

	serv.Close();

	User::After(gInitSafetyTimeout);

	return ENotFinished;

	}

TInitReturnValue C32_SucceedAcmOpen(TUint aCount)

/**

 * One iteration of starting USB, loading ECACM.CSY, trying to open the ACM 

 * port and changing the ACM port's buffer sizes. Heap failures in C32's heap.

 */

	{

	RUsb usb;

	TInt err = usb.Connect();

	gTest.Printf(_L("\tRUsb::Connect = %d\n"), err);

	if ( !err )

		{

		RCommServ serv;

		err = serv.Connect();

		gTest.Printf(_L("\tRCommServ::Connect = %d\n"), err);

		if ( !err )

			{

			serv.__DbgMarkHeap();

			serv.__DbgFailNext(aCount);

			TRequestStatus stat;

			usb.Start(stat);

			User::WaitForRequest(stat);

			err = stat.Int();

			gTest.Printf(_L("\tRUsb::Start = %d\n"), err);

			if ( !err )

				{

				err = serv.LoadCommModule(KAcmCsyName);

				gTest.Printf(_L("\tRCommServ::LoadCommModule = %d\n"), err);

				if ( !err )

					{

					RComm comm;

					TName name(KAcmSerialName);

					name.AppendFormat(_L("::%d"), KAcmLowUnit);

					err = comm.Open(serv, name, ECommExclusive);

					gTest.Printf(_L("\tRComm::Open = %d\n"), err);

					if ( !err ) 

						{

						gTest.Printf(_L("\tsuccessful result from RComm::Open\n"));

						comm.Close();			

						}

					}

				serv.UnloadCommModule(KAcmSerialName);

				usb.Stop();

				User::After(gInitSafetyTimeout);

				serv.__DbgMarkEnd(0);

				}

			serv.Close();

			User::After(gInitSafetyTimeout);

			}

		usb.Close();

		User::After(gInitSafetyTimeout);

		if ( !err )

			{

			// Test for if the test has finished. If aCount has become so big 

			// as to skip over all the allocs in the above use case, the next 

			// API call which causes alloc will fail with KErrNoMemory. 

			if ( serv.Connect() == KErrNoMemory )

				{

				serv.Close();

				User::After(gInitSafetyTimeout);

				return EFinished;

				}

			}

		}

	return ENotFinished;

	}

TInitReturnValue USBMAN_SucceedAcmOpen(TUint aCount)

/**

 * One iteration of doing RUsb::Start/Stop. Heap failures in USBMAN's heap.

 */

	{

	RUsb usb;

	TInt err = usb.Connect();

	if ( !err )

		{

		gTest.Printf(_L("\tconnected to USBMAN\n"));

		err = usb.__DbgMarkHeap();

		if ( !err )

			{

			err = usb.__DbgFailNext(aCount);

			if ( !err )

				{

				TRequestStatus stat;

				usb.Start(stat);

				User::WaitForRequest(stat);

				err = stat.Int();

				gTest.Printf(_L("\tRUsb::Start completed with %d\n"), err);

				if ( !err )

					{

					usb.Stop(stat);

					User::WaitForRequest(stat);

					err = stat.Int();