// Copyright (c) 1999-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\realtime\t_lat2.cpp
// 
//

#include <e32test.h>
#include <e32svr.h>
#include <e32property.h>
#include <e32atomics.h>
#include "runtests.h"
#include "d_latncy.h"

_LIT(KLatencyLddFileName,"D_LATNCY");
_LIT(KThreadName,"LatencyThreadU");

RTest test(_L("Latency"));
RThread Main;
TUint TicksPerMs;

struct SFullLatencyResults : public SLatencyResults
	{
	TUint iKernRetAddr;
	TUint iUserRetAddr;
	TInt64 iCount;
	TInt64 iSumIntTicks;
	TInt64 iSumKernTicks;
	TInt64 iSumUserTicks;
	TUint iIntCpsr;
	TUint iKernCpsr;
	TUint iKernR14;
	TUint iUserCpsr;
	TUint iUserR14;

	void Update(SLatencyResults& aResults);
	};

SFullLatencyResults Latencies;
volatile TUint32 UpdateCount=0;

TUint TimerToMicroseconds(TUint aTimerValue)
	{
	return (aTimerValue*1000+TicksPerMs-1)/TicksPerMs;
	}

void SFullLatencyResults::Update(SLatencyResults& aResults)
	{
	__e32_atomic_add_acq32(&UpdateCount, 1);

	// memory barrier

	if (aResults.iIntTicks>iIntTicks)
		{
		iIntTicks=aResults.iIntTicks;
		iIntRetAddr=aResults.iIntRetAddr;
#ifdef __CAPTURE_EXTRAS
		iIntCpsr=aResults.iIntSpsr;
		iIntR14=aResults.iIntR14;
#endif
		}
	if (aResults.iKernThreadTicks>iKernThreadTicks)
		{
		iKernThreadTicks=aResults.iKernThreadTicks;
		iKernRetAddr=aResults.iIntRetAddr;
#ifdef __CAPTURE_EXTRAS
		iKernCpsr=aResults.iIntSpsr;
		iKernR14=aResults.iIntR14;
#endif
		}
	if (aResults.iUserThreadTicks>iUserThreadTicks)
		{
		iUserThreadTicks=aResults.iUserThreadTicks;
		iUserRetAddr=aResults.iIntRetAddr;
#ifdef __CAPTURE_EXTRAS
		iUserCpsr=aResults.iIntSpsr;
		iUserR14=aResults.iIntR14;
#endif
		}
	iSumIntTicks+=aResults.iIntTicks;
	iSumKernTicks+=aResults.iKernThreadTicks;
	iSumUserTicks+=aResults.iUserThreadTicks;
	++iCount;

	// memory barrier

	__e32_atomic_add_rel32(&UpdateCount, 1);
	}

TInt LatencyThread(TAny* aStatus)
	{
	TRequestStatus* pS=(TRequestStatus*)aStatus;
	RLatency l;
	TInt r=l.Open();
	if (r!=KErrNone)
		return r;
	TicksPerMs=l.TicksPerMs();
	Mem::FillZ(&Latencies,sizeof(Latencies));
	Main.RequestComplete(pS,0);
	SLatencyResults results;

	l.Start();
	FOREVER
		{
		User::WaitForAnyRequest();
		l.GetResults(results);
		Latencies.Update(results);
		}
	return r;
	}

void GetLatencies(SFullLatencyResults& aResults)
	{
	FOREVER
		{
		TUint32 u1 = UpdateCount;
		__e32_memory_barrier();
		aResults=Latencies;
		__e32_memory_barrier();
		TUint32 u2 = UpdateCount;
		if (u1==u2 && !(u1&1))	// no good if it changed partway through or was changing when we started
			break;
		}
	}

_LIT(KPrefixRuntests, "RUNTESTS: RT");
void DisplayMaxValues(const TDesC& aPrefix)
	{
	SFullLatencyResults v;
	GetLatencies(v);
	TUint i=TimerToMicroseconds(v.iIntTicks);
	TUint k=TimerToMicroseconds(v.iKernThreadTicks);
	TUint u=TimerToMicroseconds(v.iUserThreadTicks);
	TUint ia=v.iIntRetAddr;
	TUint ka=v.iKernRetAddr;
	TUint ua=v.iUserRetAddr;
	test.Printf(_L("%SMAX: Int %4d %08x Kern %4d %08x User %4d %08x\n"),&aPrefix,i,ia,k,ka,u,ua);
	}

void DisplayAvgValues(const TDesC& aPrefix)
	{
	SFullLatencyResults v;
	GetLatencies(v);
	TUint i=TimerToMicroseconds(I64LOW(v.iSumIntTicks/v.iCount));
	TUint k=TimerToMicroseconds(I64LOW(v.iSumKernTicks/v.iCount));
	TUint u=TimerToMicroseconds(I64LOW(v.iSumUserTicks/v.iCount));
	test.Printf(_L("%SAVG: Int %4d Kern %4d User %4d Count %Ld\n"),&aPrefix,i,k,u,v.iCount);
	}

#ifdef __CAPTURE_EXTRAS
void DisplayExtras(const TDesC& aPrefix)
	{
	SFullLatencyResults v;
	GetLatencies(v);
	test.Printf(_L("%SInt : Cpsr %08x R14 %08x\n"),&aPrefix,v.iIntCpsr,v.iIntR14);
	test.Printf(_L("%SKern: Cpsr %08x R14 %08x\n"),&aPrefix,v.iKernCpsr,v.iKernR14);
	test.Printf(_L("%SUser: Cpsr %08x R14 %08x\n"),&aPrefix,v.iUserCpsr,v.iUserR14);
	}
#endif

void ClearMaxValues()
	{
	Mem::FillZ(&Latencies,6*sizeof(TUint));
	}

void ClearAvgValues()
	{
	Mem::FillZ(&Latencies.iCount,4*sizeof(TInt64));
	}

_LIT_SECURITY_POLICY_PASS(KPersistencePropReadPolicy);
_LIT_SECURITY_POLICY_PASS(KPersistencePropWritePolicy);
void AnnouncePersistence()
	{
	TInt r = RProperty::Define(KRuntestsIntentionalPersistenceKey, RProperty::EInt, KPersistencePropReadPolicy, KPersistencePropWritePolicy);
	test(r==KErrNone || r==KErrAlreadyExists);
	r = RProperty::Set(RProcess().SecureId(), KRuntestsIntentionalPersistenceKey, KRuntestsIntentionalPersistenceValue);
	test(r==KErrNone);
	}

class CConsoleReader : public CActive
	{
public:
	CConsoleReader();
	static void New();
	void Start();
	virtual void RunL();
	virtual void DoCancel();
public:
	CConsoleBase* iConsole;
	};

CConsoleReader::CConsoleReader()
	:	CActive(0)
	{
	}

void CConsoleReader::RunL()
	{
	TKeyCode k = iConsole->KeyCode();
	switch(k)
		{
		case '1':
			test.Printf(_L("Clearing Maximum Values\n"));
			ClearMaxValues();
			break;
		case '2':
			DisplayMaxValues(KNullDesC);
			break;
		case '3':
			test.Printf(_L("Clearing Average Values\n"));
			ClearAvgValues();
			break;
		case '4':
			DisplayAvgValues(KNullDesC);
			break;
#ifdef __CAPTURE_EXTRAS
		case '5':
			DisplayExtras(KNullDesC);
			break;
#endif
		case 'x':
		case 'X':
			CActiveScheduler::Stop();
			return;
		default:
			break;
		}
	Start();
	}

void CConsoleReader::DoCancel()
	{
	iConsole->ReadCancel();
	}

void CConsoleReader::New()
	{
	CConsoleReader* crdr = new CConsoleReader;
	test(crdr != NULL);
	crdr->iConsole = test.Console();
	CActiveScheduler::Add(crdr);
	crdr->Start();
	}

void CConsoleReader::Start()
	{
	iConsole->Read(iStatus);
	SetActive();
	}

class CPubSubWatcher : public CActive
	{
public:
	CPubSubWatcher();
	static void New();
	void Start();
	virtual ~CPubSubWatcher();
	virtual void RunL();
	virtual void DoCancel();
public:
	RProperty iProperty;
	};

CPubSubWatcher::CPubSubWatcher()
	:	CActive(0)
	{
	}

void CPubSubWatcher::RunL()
	{
	Start();
	DisplayMaxValues(KPrefixRuntests);
	DisplayAvgValues(KPrefixRuntests);
	}

void CPubSubWatcher::DoCancel()
	{
	iProperty.Cancel();
	}

void CPubSubWatcher::New()
	{
	CPubSubWatcher* psw = new CPubSubWatcher;
	test(psw != NULL);
	TInt r = psw->iProperty.Attach(KRuntestsCategory, KRuntestsCurrentTestKey, EOwnerThread);
	test(r==KErrNone);
	CActiveScheduler::Add(psw);
	psw->Start();
	}

void CPubSubWatcher::Start()
	{
	iProperty.Subscribe(iStatus);
	SetActive();
	}

CPubSubWatcher::~CPubSubWatcher()
	{
	iProperty.Close();
	}

GLDEF_C TInt E32Main()
	{
#ifdef _DEBUG
	// Don't run automatically on debug builds
	TUint32 creator_sid = User::CreatorSecureId();
	if (creator_sid == TUint32(KRuntestsCategoryValue))
		return KErrNone;
#endif
	// disable anything which will interfere, e.g. plat sec diagnostics
	User::SetDebugMask(UserSvr::DebugMask(2)|4, 2);

	test.Title();
	
	test.Printf(_L("*** Please note ***\n"));
	test.Printf(_L("\n"));
	test.Printf(_L("t_lat2 runs in the backgroud to measure latency while other tests are\n"));
	test.Printf(_L("running.  It should not be run as a standalone test, only as part of a\n"));
	test.Printf(_L("test run coordinated by runtests.  If run on its owm, it will simply wait\n"));
	test.Printf(_L("forever.\n"));
	test.Printf(_L("\n"));
	
	test.Start(_L("Load LDD"));
	TInt r=User::LoadLogicalDevice(KLatencyLddFileName);
	test(r==KErrNone || r==KErrAlreadyExists);

	test.Next(_L("Duplicate handle"));
	r=Main.Duplicate(RThread());
	test(r==KErrNone);

	test.Next(_L("Create thread"));
	RThread t;
	TRequestStatus sx;
	TRequestStatus sc;
	r=t.Create(KThreadName,LatencyThread,0x1000,NULL,&sc);
	test(r==KErrNone);
	t.Logon(sx);
	t.Resume();
	User::WaitForRequest(sx,sc);
	if (sx!=KRequestPending)
		{
		if (t.ExitType()==EExitKill && t.ExitReason()==KErrAlreadyExists)
			{
			test.Printf(_L("T_LAT2 already running.\n"));
			test.End();
			return 0;
			}
		test.Printf(_L("Initialisation failed, error %d\n"),sx.Int());
		test(0);
		}
	test(sc==KErrNone);

	CTrapCleanup* tcln = CTrapCleanup::New();
	test(tcln != NULL);
	CActiveScheduler* as = new CActiveScheduler;
	test(as != NULL);
	CActiveScheduler::Install(as);
	CConsoleReader::New();
	CPubSubWatcher::New();
	AnnouncePersistence();
	RProcess::Rendezvous(KErrNone);

	CActiveScheduler::Start();

	// latency test over
	User::SetDebugMask(UserSvr::DebugMask(2)&~4, 2);

	test.End();
	return 0;
	}