/*
* Copyright (c) 2005-2006 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:  Tests for thread creation & Process priority.
*
*/

#include <stiflogger.h>
#include "epos_comasuplthreadprocesstest.h"
#include "epos_comasuplpostesterlogger.h"

/** Constant used for logging name of test*/
_LIT8(KThreadTest, "---------------Thread and Process Test---------------");

/** Constant used for logging name of test*/
_LIT8(KThreadTestComplete, "Info: Thread and Process Test complete.");

_LIT8(KThreadsNotKilled, "Error: Number of threads not killed: ");

_LIT8(KExtraThreadsKilled, "Error: Number of extra threads killed: ");

_LIT8(KSameThreadCount, "Info: Number of threads created = \
Number of threads killed.");

_LIT8(KPriorityChanged, "Error: Priority of the process is changed.");

_LIT8(KPriorityNotChanged, "Info: Priority of the process is not changed.");	

// ---------------------------------------------------------------------------
// Named constructor
// ---------------------------------------------------------------------------
//
COMASuplThreadProcessTest* COMASuplThreadProcessTest::NewL(
										COMASuplPosTesterCategory* aCallBack )
	{
	COMASuplThreadProcessTest* self = 
							new(ELeave)COMASuplThreadProcessTest(aCallBack);
	CleanupStack::PushL(self);
	self->ConstructL();
	CleanupStack::Pop(self);
	return self;
	}

// ---------------------------------------------------------------------------
// Destructor
// ---------------------------------------------------------------------------
//
COMASuplThreadProcessTest::~COMASuplThreadProcessTest()
	{
	
	}

// ---------------------------------------------------------------------------
// Constructor
// ---------------------------------------------------------------------------
//
COMASuplThreadProcessTest::COMASuplThreadProcessTest(
							COMASuplPosTesterCategory* aCallBack )
							: COMASuplPosTesterCategory( aCallBack )
	{
	
	}

// ---------------------------------------------------------------------------
// Second phase constructor
// ---------------------------------------------------------------------------
//
void COMASuplThreadProcessTest::ConstructL()
	{
	
	}

// ---------------------------------------------------------------------------
// This function is called by test handler. It is entry point of execution
// of a test case.
// ---------------------------------------------------------------------------
//
void COMASuplThreadProcessTest::StartTestingL()
	{
	}

// ---------------------------------------------------------------------------
// Handles an active object's request completion event.
// ---------------------------------------------------------------------------
//
void COMASuplThreadProcessTest::RunL()
	{
	}

// ---------------------------------------------------------------------------
// Implements cancellation of an outstanding request.
// ---------------------------------------------------------------------------
//
void COMASuplThreadProcessTest::DoCancel()
	{
	
	}

// ---------------------------------------------------------------------------
// Handles a leave occurring in the request completion event handler RunL().
// ---------------------------------------------------------------------------
//
TInt COMASuplThreadProcessTest::RunError(TInt /*aError*/)
	{
	return KErrNone;
	}


// ---------------------------------------------------------------------------
// Gets number of threads, name of process and process priority.
// ---------------------------------------------------------------------------
//
void COMASuplThreadProcessTest::ReadStatusL(TInt& aThreadCount
											, TProcessPriority& aPriority
											, TFullName& aProcessName)
	{
	RProcess process;
	CleanupClosePushL(process);
	aProcessName = process.FullName();
	CountThreadsL(aProcessName, aThreadCount);
	aPriority = process.Priority();
	CleanupStack::PopAndDestroy(&process);// removing process
	}

// ---------------------------------------------------------------------------
// Counts number of threads associated with a process.
// ---------------------------------------------------------------------------
//
void COMASuplThreadProcessTest::CountThreadsL(const TFullName& aProcessName
											, TInt& aThreadCount)
	{
	aThreadCount = 0;
	HBufC* searchString = NULL;
	TFullName threadName;
	PrepareSearchStringL(searchString, aProcessName);
	TFindThread findThread(*searchString);
	
	while(KErrNone == findThread.Next(threadName))
		{
		aThreadCount++;
		}
	delete searchString;
	}

// ---------------------------------------------------------------------------
// Prepares a search string from the name of process.
// ---------------------------------------------------------------------------
//
void COMASuplThreadProcessTest::PrepareSearchStringL(HBufC*& aSearchString
								, const TFullName& aProcessName)
	{
	delete aSearchString;
	aSearchString = HBufC::NewL(aProcessName.Length() + 2);
	TPtr stringPtr = aSearchString->Des();
	_LIT(KStar, "*");
	stringPtr.Copy(KStar);
	stringPtr.Append(aProcessName);
	stringPtr.Append(KStar);
	}

// ---------------------------------------------------------------------------
// Reads the number of threads, process priority & name of process 
// before executing tests.
// ---------------------------------------------------------------------------
//
void COMASuplThreadProcessTest::StatusBeforeTestsL()
	{
	ReadStatusL(iThreadCountBeforeTests, iProcessPriorityBeforeTests
				, iProcessNameBeforeTests);
	}
// ---------------------------------------------------------------------------
// Reads the number of threads, process priority & name of process 
// after executing tests.
// ---------------------------------------------------------------------------
//
void COMASuplThreadProcessTest::StatusAfterTestsL()
	{
	ReadStatusL(iThreadCountAfterTests, iProcessPriorityAfterTests
				, iProcessNameAfterTests);
	}

// ---------------------------------------------------------------------------
// Matches the number of threads, process priority & name of process 
// obtained before and after executing tests and logd the info.
// ---------------------------------------------------------------------------
//
TBool COMASuplThreadProcessTest::MatchAndLogStatus()
	{
	iLogger->WriteTestHeader(KThreadTest, iTestNo);
	TBool result = ETrue;
	if(iThreadCountAfterTests > iThreadCountBeforeTests)
		{
		iError++;
		iLogger->WriteStatus(KThreadsNotKilled,
				 iThreadCountAfterTests - iThreadCountBeforeTests
				 								, iTestNo, &KNULL());
		result = EFalse;
		}
	else if(iThreadCountAfterTests < iThreadCountBeforeTests)
		{
		iError++;
		iLogger->WriteStatus(KExtraThreadsKilled,
				 iThreadCountBeforeTests - iThreadCountAfterTests
				 								, iTestNo, &KNULL());
		result = EFalse;
		}
		else
			{
			iInfo++;
			iLogger->WriteLine(KSameThreadCount, iTestNo);
			}
	if(iProcessPriorityBeforeTests != iProcessPriorityAfterTests)
		{
		iError++;
		iLogger->WriteLine(KPriorityChanged, iTestNo);
		result = EFalse;
		}
	else
		{
		iInfo++;
		iLogger->WriteLine(KPriorityNotChanged, iTestNo);
		}
	iInfo++;
	iLogger->WriteLine(KThreadTestComplete, iTestNo);
	return result;
	}