sl@0: // Copyright (c) 2003-2009 Nokia Corporation and/or its subsidiary(-ies).
sl@0: // All rights reserved.
sl@0: // This component and the accompanying materials are made available
sl@0: // under the terms of "Eclipse Public License v1.0"
sl@0: // which accompanies this distribution, and is available
sl@0: // at the URL "http://www.eclipse.org/legal/epl-v10.html".
sl@0: //
sl@0: // Initial Contributors:
sl@0: // Nokia Corporation - initial contribution.
sl@0: //
sl@0: // Contributors:
sl@0: //
sl@0: // Description:
sl@0: //
sl@0: 
sl@0: #include <fbs.h>
sl@0: #include "TestFrameworkRecog.h"
sl@0: #include "TestFrameworkMain.h"
sl@0: 
sl@0: #ifdef __WINS__
sl@0: #include <windows.h>	// for ExitProcess
sl@0: #endif // __WINS__
sl@0: 
sl@0: GLREF_C void StartupL();
sl@0: const TInt KThreadStackSize=0x2000;			//  8KB
sl@0: const TInt KThreadInitHeapSize=0x1000;		//  4KB
sl@0: const TInt KThreadMaxHeapSize=0x1000000;	// 16MB
sl@0: const TInt KThreadStartupDelay=30000000;	// 30 seconds
sl@0: const TInt KMaxLineLength=256;				// max length of config file line
sl@0: _LIT(KLitConfigFileName, "C:\\MM\\AutorunTests.cfg");
sl@0: 
sl@0: //
sl@0: 
sl@0: CTestFrameworkRecognizer::CTestFrameworkRecognizer()
sl@0: 	: CApaDataRecognizerType(KUidTestFrameworkRecognizer, CApaDataRecognizerType::ENormal)
sl@0: 	{
sl@0: 	}
sl@0: 
sl@0: CTestFrameworkRecognizer::~CTestFrameworkRecognizer()
sl@0: 	{
sl@0: 	delete iTestActive;
sl@0: 	}
sl@0: 
sl@0: //
sl@0: // CApaDataRecognizerType stuff...
sl@0: TUint CTestFrameworkRecognizer::PreferredBufSize()
sl@0: 	{
sl@0: 	return 0;
sl@0: 	}
sl@0: 
sl@0: TDataType CTestFrameworkRecognizer::SupportedDataTypeL(TInt /*aIndex*/) const
sl@0: 	{
sl@0: 	return TDataType();
sl@0: 	}
sl@0: 
sl@0: void CTestFrameworkRecognizer::DoRecognizeL(const TDesC& /*aName*/, const TDesC8& /*aBuffer*/)
sl@0: 	{
sl@0: 	}
sl@0: 
sl@0: //
sl@0: // Entry point of recognizer
sl@0: EXPORT_C CApaDataRecognizerType* CreateRecognizer()
sl@0: 	{
sl@0: 	CTestFrameworkRecognizer* self = new CTestFrameworkRecognizer();
sl@0: 	TRAPD(err, self->DoCreateL());
sl@0: 	return self;
sl@0: 	}
sl@0: 
sl@0: void CTestFrameworkRecognizer::DoCreateL()
sl@0: 	{
sl@0: 	// Open the config file
sl@0: 	LoadConfigFileL(KLitConfigFileName);
sl@0: 
sl@0: 	// If the RUN_SCRIPT command is present in the config file, run each test in a separate thread
sl@0: 	if (iRunScript)
sl@0: 		{
sl@0: 		// Create active object waiting on thread death
sl@0: 		iTestActive = new(ELeave) CTestFrameworkRecogActive(iTestScriptArray);	// Takes ownership of iTestScriptArray
sl@0: 
sl@0: 		// Create the first test thread
sl@0: 		iTestActive->CreateNextTestThread();
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: void CTestFrameworkRecognizer::LoadConfigFileL(const TDesC& aFileName)
sl@0: 	{
sl@0: 	RFs fs;
sl@0: 	User::LeaveIfError(fs.Connect());
sl@0: 	CleanupClosePushL(fs);
sl@0: 
sl@0: 	TEntry entry;
sl@0: 	User::LeaveIfError(fs.Entry(aFileName, entry));
sl@0: 
sl@0: 	RFile file;
sl@0: 	User::LeaveIfError(file.Open(fs, aFileName, EFileRead));
sl@0: 	CleanupClosePushL(file);
sl@0: 
sl@0: 	TInt size;
sl@0: 	User::LeaveIfError(file.Size(size));
sl@0: 	TUint8* fileData = (TUint8*)User::AllocLC(size);
sl@0: 	TPtr8 ptr(fileData, 0, size);
sl@0: 	User::LeaveIfError(file.Read(ptr));
sl@0: 
sl@0: 	iTestScriptArray = new(ELeave) CTestScriptArray(4);
sl@0: 
sl@0: 	// Process the config file
sl@0: 	TLex8 lex(ptr);
sl@0: 	while (!lex.Eos())
sl@0: 		{
sl@0: 		// skip any spaces
sl@0: 		while (lex.Peek() == ' ')
sl@0: 			lex.Inc();
sl@0: 		// mark the start of the line
sl@0: 		lex.Mark();
sl@0: 		// move to the next
sl@0: 		while (!lex.Eos() && lex.Peek() != '\n')
sl@0: 			lex.Inc();
sl@0: 		// step over \n
sl@0: 		if (lex.Peek() == '\n' )
sl@0: 			lex.Inc();
sl@0: 
sl@0: 		// Process line
sl@0: 		TPtrC8 linePtr = lex.MarkedToken();
sl@0: 		ProcessLineL(linePtr);
sl@0: 		}
sl@0: 	CleanupStack::PopAndDestroy(fileData);
sl@0: 	CleanupStack::PopAndDestroy(2);	// file, fs
sl@0: 	}
sl@0: 
sl@0: void CTestFrameworkRecognizer::ProcessLineL(const TDesC8& aLine)
sl@0: 	{
sl@0: 	ASSERT(aLine.Length() <= KMaxLineLength);
sl@0: 	TBuf<KMaxLineLength> buf;
sl@0: 	buf.Copy(aLine);
sl@0: 	if (buf.Find(_L("//"))==0)
sl@0: 		{
sl@0: 		// ignore comments
sl@0: 		}
sl@0: 	else
sl@0: 		{
sl@0: 		// Get the script path and startup delay
sl@0: 		TLex lex(buf);
sl@0: 		if (!iRunScript)
sl@0: 			{
sl@0: 			if (lex.NextToken().Compare(_L("RUN_SCRIPT")) == 0)
sl@0: 				iRunScript = ETrue;
sl@0: 			}
sl@0: 		else
sl@0: 			{
sl@0: 			// Parse the parameters
sl@0: 			TTestScriptInfo info;
sl@0: 			info.iScriptPath = lex.NextToken();
sl@0: 			info.iThreadStartupDelay = 0;
sl@0: 
sl@0: 			TPtrC token(lex.NextToken());
sl@0: 			while (token.Length())
sl@0: 				{
sl@0: 				if (token[0] == '-')
sl@0: 					{
sl@0: 					info.iParams.Append(token);
sl@0: 					info.iParams.Append(' ');
sl@0: 					}
sl@0: 				else
sl@0: 					{
sl@0: 					// Assume this to be the startup delay
sl@0: 					TLex tokenLex(token);
sl@0: 					User::LeaveIfError(tokenLex.Val(info.iThreadStartupDelay));
sl@0: 					if (info.iThreadStartupDelay < 0)
sl@0: 						info.iThreadStartupDelay = 0;
sl@0: 					}
sl@0: 				token.Set(lex.NextToken());
sl@0: 				}
sl@0: 
sl@0: 			// Add the script info
sl@0: 			if (info.iScriptPath.Length())
sl@0: 				iTestScriptArray->AppendL(info);
sl@0: 			}
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: //
sl@0: // CTestFrameworkRecogActive
sl@0: CTestFrameworkRecogActive::CTestFrameworkRecogActive(CTestScriptArray* aTestScriptArray)
sl@0: 	: CActive(EPriorityStandard), iTestScriptArray(aTestScriptArray)
sl@0: 	{
sl@0: 	CActiveScheduler::Add(this);
sl@0: 	iCurrentScript = -1;
sl@0: 	}
sl@0: 
sl@0: CTestFrameworkRecogActive::~CTestFrameworkRecogActive()
sl@0: 	{
sl@0: 	delete iTestScriptArray;
sl@0: 	}
sl@0: 
sl@0: TInt CTestFrameworkRecogActive::CreateNextTestThread()
sl@0: 	{
sl@0: 	// Create the next test in a separate thread
sl@0: 	iCurrentScript++;
sl@0: 	RThread thread;
sl@0: 	TBuf<16> threadName;
sl@0: 	threadName.Format(_L("TFR_THREAD_%d"), iCurrentScript);
sl@0: 
sl@0: 	TInt err = thread.Create(threadName, &StartTestThreadFn, KThreadStackSize,
sl@0: 							 &User::Heap(), this);
sl@0: 
sl@0: 	if (err == KErrNone)
sl@0: 		{
sl@0: 		thread.Logon(iStatus);
sl@0: 		thread.Resume();
sl@0: 		SetActive();
sl@0: 		}
sl@0: 	return err;
sl@0: 	}
sl@0: 
sl@0: void CTestFrameworkRecogActive::DoCancel()
sl@0: 	{
sl@0: 	}
sl@0: 
sl@0: void CTestFrameworkRecogActive::RunL()
sl@0: 	{
sl@0: 	// This will run when the thread created in CreateNextTestThreadL dies
sl@0: 	//
sl@0: 	TInt err = KErrNone;
sl@0: 	if (iCurrentScript < (iTestScriptArray->Count() - 1))
sl@0: 		{
sl@0: 		err = CreateNextTestThread();
sl@0: 		}
sl@0: 	else
sl@0: 		{
sl@0: 		// Tests finished
sl@0: 		delete iTestScriptArray;
sl@0: 		iTestScriptArray = NULL;
sl@0: #ifdef __WINS__
sl@0: 		// Cause the emulator to exit
sl@0: 		ExitProcess(0);
sl@0: #endif // __WINS__
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: TInt CTestFrameworkRecogActive::StartTestThreadFn(TAny* aPtr)
sl@0: 	{
sl@0: 	CTestFrameworkRecogActive* self = static_cast<CTestFrameworkRecogActive*>(aPtr);
sl@0: 	TRAPD(err, self->DoStartTestThreadL());
sl@0: 	return err;
sl@0: 	}
sl@0: 
sl@0: void CTestFrameworkRecogActive::DoStartTestThreadL()
sl@0: 	{
sl@0: 	// Create the thread and wait until it's finished
sl@0: 	RThread thread;
sl@0: 	TBuf<16> threadName;
sl@0: 	threadName.Format(_L("TESTFRMRECOG_%d"), iCurrentScript);
sl@0: 
sl@0: 	TInt err = thread.Create(threadName, &ThreadFunc, KThreadStackSize,
sl@0: 							 &User::Heap(), this);
sl@0: 
sl@0: 	if (err == KErrNone)
sl@0: 		{
sl@0: 		RSemaphore sem;
sl@0: 		err = sem.CreateGlobal(KRecogSemaphoreName, 0);
sl@0: 		if (err == KErrAlreadyExists)
sl@0: 			err = sem.OpenGlobal(KRecogSemaphoreName);
sl@0: 		if (err == KErrNone)
sl@0: 			{
sl@0: 			// Start the thread and wait for it to signal us that it's finished
sl@0: 			thread.Resume();
sl@0: 			sem.Wait();
sl@0: 			}
sl@0: 		}
sl@0: 	User::LeaveIfError(err);
sl@0: 	}
sl@0: 
sl@0: 
sl@0: TInt CTestFrameworkRecogActive::ThreadFunc(TAny* aPtr)
sl@0: 	{
sl@0: 	CTrapCleanup* cleanup = CTrapCleanup::New(); // get clean-up stack
sl@0: 	CTestFrameworkRecogActive* self = static_cast<CTestFrameworkRecogActive*>(aPtr);
sl@0: 	TRAPD(err, self->DoThreadFuncL());
sl@0: 	delete cleanup; // destroy clean-up stack
sl@0: 	return err;
sl@0: 	}
sl@0: 
sl@0: void CTestFrameworkRecogActive::DoThreadFuncL()
sl@0: 	{
sl@0: 	// Run the test script, using filename held in iScriptPath
sl@0: 	CActiveScheduler* scheduler=new(ELeave) CActiveScheduler;
sl@0: 	CleanupStack::PushL(scheduler);
sl@0: 	CActiveScheduler::Install(scheduler);
sl@0: 
sl@0: // Hurricane emulator only - start all services which we require to run tests.
sl@0: // Future enhancement :- add these startups to TestUtils
sl@0: #if defined(__WINS__)
sl@0: 	#ifndef EXCLUDE_FOR_UNITTEST
sl@0: 	FbsStartup();
sl@0: 	#endif // EXCLUDE_FOR_UNITTEST
sl@0: #endif
sl@0: 
sl@0: 	// Get the current script
sl@0: 	const TTestScriptInfo& script = iTestScriptArray->At(iCurrentScript);
sl@0: 
sl@0: 	// Delay for several seconds to allow vital bits of the emulator to start up (window server bits)
sl@0: 	User::After(script.iThreadStartupDelay);
sl@0: 
sl@0: 	// Format the parameter to be passed to the test framework
sl@0: 	TFileName args;
sl@0: 	if (script.iParams.Length())
sl@0: 		{
sl@0: 		// Add the params
sl@0: 		args.Append(script.iParams);
sl@0: 		args.Append(' ');
sl@0: 		}
sl@0: 	args.Append(script.iScriptPath);
sl@0: 
sl@0: 	// Run the script
sl@0: 	CTestFrameworkMain* tester = CTestFrameworkMain::NewLC();
sl@0: 	tester->StartTestingL(args);
sl@0: 
sl@0: 	CleanupStack::PopAndDestroy(2, scheduler);	// tester, scheduler
sl@0: 	}
sl@0: 
sl@0: