// Copyright (c) 1995-2009 Nokia Corporation and/or its subsidiary(-ies).
// All rights reserved.
// This component and the accompanying materials are made available
// under the terms of the License "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:
// e32test\prime\t_mutex.cpp
// Test mutexes
// 
//

#include <e32test.h>
#include "u32std.h"
#include "../misc/prbs.h"

RTest test(_L("T_MUTEX"));

TInt Count1=0;
TInt Count2=0;
TInt TId=-1;
RMutex Mutex;

void BusyWait(TInt aMicroseconds)
	{
	TTime begin;
	begin.HomeTime();
	FOREVER
		{
		TTime now;
		now.HomeTime();
		TTimeIntervalMicroSeconds iv=now.MicroSecondsFrom(begin);
		if (iv.Int64()>=TInt64(aMicroseconds))
			return;
		}
	}

TInt ThreadFunction(TAny* aPtr)
	{
	TInt id=(TInt)aPtr;
	FOREVER
		{
		Mutex.Wait();
		TId=id;
		if (Count1!=Count2)
			{
			RProcess me;
			me.Panic(_L("FAIL!"),0);
			}
		++Count1;
		BusyWait(50000);
		++Count2;
		TId=-1;
		Mutex.Signal();
		}
	}

void CreateThread(RThread& t, TInt aId)
	{
	TInt r=t.Create(KNullDesC,ThreadFunction,0x2000,NULL,(TAny*)aId);
	test(r==KErrNone);
	t.Resume();
	}


GLDEF_C TInt E32Main()
	{
	test.Title();
	test.Start(_L("Create mutex"));
	TInt r=Mutex.CreateLocal();
	test(r==KErrNone);

	test.Next(_L("Create threads"));
	RThread().SetPriority(EPriorityMuchMore);
	RThread t[4];
	TInt i;
	for (i=0; i<4; ++i)
		CreateThread(t[i],i);

	TUint seed[2];
	seed[0]=0xb17217f8;
	seed[1]=0;

	FOREVER
		{
		TUint ms=Random(seed);
		TUint action=(ms>>30);
		i=(ms>>28)&3;
		ms&=63;
		ms+=15;
		User::AfterHighRes(ms*1000);
		switch(action)
			{
			case 0:
				{
				t[i].Suspend();
				break;
				}
			case 1:
				{
				t[i].Resume();
				break;
				}
			case 2:
				{
				TRequestStatus s;
				t[i].Logon(s);
				t[i].Kill(0);
				if (Count1!=Count2)
					{
					if (Count1-Count2!=1)
						{
						RProcess me;
						me.Panic(_L("FAIL!"),1);
						}
					else if (TId==i)
						++Count2;
					}
				User::AfterHighRes(50000);
				User::WaitForRequest(s);
				t[i].Close();
				CreateThread(t[i],i);
				break;
				}
			case 3:
				{
				break;
				}
			}
		}

//	test.End();
	}