// Copyright (c) 2002-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:
//

#include "t_property.h"

_LIT(KPropSetGetRaceName, "RProperty::Set/Get() Race");
 
CPropSetGetRace::CPropSetGetRace(TUid aCategory, TUint aKey) : 
	  CTestProgram(KPropSetGetRaceName), iCategory(aCategory), iKey(aKey), 
		  iBuf1(RProperty::KMaxPropertySize), iBuf2(RProperty::KMaxPropertySize)
	{
	}

void CPropSetGetRace::Trublemaker(TDes8& aBuf)
	{
	RProperty prop;	
	TInt r = prop.Attach(iCategory, iKey, EOwnerThread);
	TF_ERROR(r, r == KErrNone);
	TBool attached = ETrue;
	for(;;)
		{
		TBuf8<RProperty::KMaxPropertySize> buf;
		if (attached)
			{
			r = prop.Set(aBuf);
			TF_ERROR(r, r == KErrNone);
			r = prop.Get(buf);
			TF_ERROR(r, r == KErrNone);
			}
		else 
			{
			r = prop.Set(iCategory, iKey, aBuf);
			TF_ERROR(r, r == KErrNone);
			r = prop.Get(iCategory, iKey, buf);
			TF_ERROR(r, r == KErrNone);
			}
		TF_ERROR(KErrGeneral, !(buf.Compare(iBuf1) && buf.Compare(iBuf2)));
		User::After(1);
		attached = !attached;
		}
	}

TInt CPropSetGetRace::TrublemakerThreadEntry(TAny* ptr)
	{
	CPropSetGetRace* prog = (CPropSetGetRace*) ptr;
	prog->Trublemaker(prog->iBuf2);
	return KErrNone;
	}

void CPropSetGetRace::Run(TUint aCount)
	{
	RProperty prop;	

	TInt r = prop.Define(iCategory, iKey, RProperty::EByteArray, KPassPolicy, KPassPolicy);
	TF_ERROR(r, r == KErrNone);
	r = prop.Attach(iCategory,iKey);
	TF_ERROR(r, r == KErrNone);

	TUint i;
	for(i = 0; i < RProperty::KMaxPropertySize; ++i)
		{
		iBuf1[i] = '1';
		iBuf2[i] = '2';
		}

	TRequestStatus status;
	RThread thr;
	r = thr.Create(KNullDesC, TrublemakerThreadEntry, 0x2000, NULL, this);
	TF_ERROR(r, r == KErrNone);
	thr.Logon(status);
	thr.SetPriority(EPriorityMore);
	thr.Resume();

	TBool attached = ETrue;
	for (i = 0; i < aCount; ++i)
		{
		TBuf8<RProperty::KMaxPropertySize> buf;
		if (attached)
			{
			r = prop.Set(iBuf1);
			TF_ERROR(r, r == KErrNone);
			r = prop.Get(buf);
			TF_ERROR(r, r == KErrNone);
			}
		else 
			{
			r = prop.Set(iCategory, iKey, iBuf1);
			TF_ERROR(r, r == KErrNone);
			r = prop.Get(iCategory, iKey, buf);
			TF_ERROR(r, r == KErrNone);
			}
		TF_ERROR(KErrGeneral, !(buf.Compare(iBuf1) && buf.Compare(iBuf2)));
		attached = !attached;
		}

	thr.Kill(EExitKill);
	thr.Close();

	User::WaitForRequest(status);
	TF_ERROR(status.Int(), status.Int() == EExitKill);

	prop.Delete(iCategory, iKey);
	prop.Close();
	}


_LIT(KPropCancelRaceName, "RProperty::Cancel() Race");
 
CPropCancelRace::CPropCancelRace(TUid aCategory, TUint aKey) : 
	  CTestProgram(KPropCancelRaceName), iCategory(aCategory), iKey(aKey) 
	{
	}

void CPropCancelRace::Trublemaker()
	{
	for(;;)
		{
		iProp.Cancel();
		User::After(1);
		}
	}

TInt CPropCancelRace::TrublemakerThreadEntry(TAny* ptr)
	{
	CPropCancelRace* prog = (CPropCancelRace*) ptr;
	prog->Trublemaker();
	return KErrNone;
	}

void CPropCancelRace::Run(TUint aCount)
	{
	TInt r = iProp.Define(iCategory, iKey, RProperty::EInt, KPassPolicy, KPassPolicy);
	TF_ERROR(r, r == KErrNone);
	r = iProp.Attach(iCategory,iKey);
	TF_ERROR(r, r == KErrNone);

	TRequestStatus thrStatus;
	RThread thr;
	r = thr.Create(KNullDesC, TrublemakerThreadEntry, 0x2000, NULL, this);
	TF_ERROR(r, r == KErrNone);
	thr.Logon(thrStatus);
	thr.SetPriority(EPriorityMore);
	thr.Resume();

	for (TUint i = 0; i < aCount; ++i)
		{
		TRequestStatus status;
		iProp.Subscribe(status);
		TInt st = status.Int();
		TF_ERROR(st, (st == KRequestPending) || (st == KErrCancel));
		iProp.Set(1);
		User::WaitForRequest(status);
		st = status.Int();
		TF_ERROR(st, (st == KErrNone) || (st == KErrCancel));
		}

	thr.Kill(EExitKill);
	User::WaitForRequest(thrStatus);
	TF_ERROR(thrStatus.Int(), thrStatus.Int() == EExitKill);
	thr.Close();

	iProp.Delete(iCategory, iKey);
	iProp.Close();
	}