/*

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

*

*/

#include "threadbase.h"

_LIT(KSemaphoreNameOne, "SemaphoneNameOne");

_LIT(KSemaphoreNameTwo, "SemaphoneNameTwo");

const TInt KMaxHeapSize=0x400; // 1024 

///////////////////////////////////////////////////////////////////////////////

/* CThreadBase - Implementation                                              */

CThreadBase::CThreadBase()

	{

	}

CThreadBase::~CThreadBase()

	{

	iThread.Close();

	CloseSemaphore();

	}

void CThreadBase::Go()

	{

	iThread.Create( ThreadName(), CThreadBase::ThreadFunction, KDefaultStackSize, 0x2000, 0x20000, this );

	iThread.Logon( iThreadStatus );

	iThread.Resume();

	}

void CThreadBase::WaitForCompetion()

	{

	User::WaitForRequest( iThreadStatus );

	}

void CThreadBase::SetUpTestL( const TDesC& aThreadName )

	{

	// Set's up extra resources.

	CConsoleBase* console = NULL;

	TSize size;

	// Create and name an RTest

	iTest = new(ELeave) RTest(aThreadName);

	iTest->Start(_L("Starting test"));

	// Position our console window

	size = iTest->Console()->ScreenSize();

	size.iWidth = size.iWidth - 4;

	size.iHeight = (size.iHeight / 2) - 3;

	console = Console::NewL(aThreadName, size);

	delete const_cast<RTest*>(iTest)->Console();

	iTest->SetConsole(console);

	console->ClearScreen();

	}

void CThreadBase::TakeDownTest()

	{

	iTest->Close();

	delete iTest;

	iTest = NULL;

	}

void CThreadBase::OpenSemaphore()

	{

	TInt success = KErrNone;

	success = iSemaphoreSignal.OpenGlobal( KSemaphoreNameOne );

	if ( success == KErrNotFound )

		{

		iSemaphoreSignal.CreateGlobal( KSemaphoreNameOne, 0 );

		success = KErrNone;

		}

	success = iSemaphoreWait.OpenGlobal( KSemaphoreNameTwo );

	if ( success == KErrNotFound )

		{

		iSemaphoreWait.CreateGlobal( KSemaphoreNameTwo, 0 );

		}

	iSemaphoreOpen = ETrue;

	}

void CThreadBase::CloseSemaphore()

	{

	if (iSemaphoreOpen)

		{

		iSemaphoreSignal.Close();

		iSemaphoreWait.Close();

		}

	iSemaphoreOpen = EFalse;

	}

void CThreadBase::SyncronizeSignal()

	{

	iSemaphoreSignal.Signal();

	iSemaphoreWait.Wait();

	iSemaphoreSignal.Signal();

	}

void CThreadBase::SyncronizeWait()

	{

	iSemaphoreSignal.Wait();

	iSemaphoreWait.Signal();

	iSemaphoreSignal.Wait();

	}

void CThreadBase::RandomDelay(TInt aMax, TInt aMin) const 

	{

	TInt delay;

	TTime timeNow;

	TInt64 seed;

	TReal randomNumber;

	timeNow.UniversalTime();

	seed = timeNow.Int64();

	randomNumber = Math::FRand( seed );

	delay = static_cast<TInt>( (randomNumber * static_cast<TReal>(aMax)) + aMin ) ;

	delay = delay % aMax;

	User::After( delay );

	}

void CThreadBase::DoRunThreadL()

	{

	CActiveScheduler*  scheduler = NULL;

	scheduler = new (ELeave) CActiveScheduler;

	CleanupStack::PushL(scheduler);

	CActiveScheduler::Install(scheduler);

	OpenSemaphore();

	SetUpTestL( ThreadName() );

	ThreadL();

	TakeDownTest();

	CloseSemaphore();

	CleanupStack::PopAndDestroy(scheduler);

	}

TInt CThreadBase::RunThread()

	{

	TInt retval = KErrNone;

    iCleanup = CTrapCleanup::New();

	if	(iCleanup)

		{	

		TRAP(retval, DoRunThreadL());

		}

	else

		{

		retval = KErrNoMemory;

		}

    delete iCleanup;

    iCleanup = NULL;

	return retval;	

	}

TInt CThreadBase::ThreadFunction(TAny* aMe)

	{

	CThreadBase* me = static_cast<CThreadBase*>(aMe);

	return me->RunThread();

	}