--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/phonebookengines/contactsmodel/tsrc/ThreadBase.cpp	Tue Feb 02 10:12:17 2010 +0200
@@ -0,0 +1,181 @@
+// 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();
+	}