// Copyright (c) 1997-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\personality\example\t_expers.cpp

// 

//

#include <e32base.h>

#include <e32base_private.h>

#include <e32test.h>

#include "ifcldd.h"

#include "../../misc/prbs.h"

RTest test(_L("EXAMPLE PERSONALITY"));

_LIT(KIfcLddName,"expers.ldd");

class CRxData : public CActive

	{

public:

	CRxData();

	static void New(RRtosIfc aIfc);

	void Start();

	void RunL();

	void DoCancel();

public:

	RRtosIfc iIfc;

	TUint8 iBuf[512];

	};

void CRxData::New(RRtosIfc aIfc)

	{

	CRxData* p = new CRxData;

	test(p!=NULL);

	p->iIfc = aIfc;

	CActiveScheduler::Add(p);

	p->Start();

	}

CRxData::CRxData()

	:	CActive(0)

	{

	}

void CRxData::DoCancel()

	{

	iIfc.Cancel(RRtosIfc::ECancelReceive);

	}

void CRxData::Start()

	{

	iIfc.Receive(iStatus, *(SRxData*)iBuf);

	SetActive();

	}

void CRxData::RunL()

	{

	SRxData& rxd = *(SRxData*)iBuf;

	TInt l = rxd.iLength;

	TUint cs = 0;

	TInt i;

	for (i=0; i<l; ++i)

		cs += rxd.iData[i];

	test( (cs & 0xff) == rxd.iChecksum);

	test.Printf(_L("RXD: l=%02x cs=%02x\n"), l, rxd.iChecksum);

	Start();

	}

class CReport : public CActive

	{

public:

	CReport();

	static void New(RRtosIfc aIfc);

	void Start();

	void RunL();

	void DoCancel();

	void SendData();

public:

	RRtosIfc iIfc;

	TUint iSeed[2];

	SReport iRpt;

	};

void CReport::New(RRtosIfc aIfc)

	{

	CReport* p = new CReport;

	test(p!=NULL);

	p->iIfc = aIfc;

	CActiveScheduler::Add(p);

	p->Start();

	}

CReport::CReport()

	:	CActive(0)

	{

	iSeed[0] = 0xb504f333;

	}

void CReport::DoCancel()

	{

	iIfc.Cancel(RRtosIfc::ECancelReport);

	}

void CReport::Start()

	{

	iIfc.Report(iStatus, iRpt);

	SetActive();

	}

void CReport::RunL()

	{

	switch (iRpt.iType)

		{

		case SReport::ESem:

			test.Printf(_L("SEM: C:%10d OK:%10d BAD:%10d\n"), iRpt.iCount, iRpt.iOkCount, iRpt.iBadCount);

			if (iRpt.iOkCount>1000000)

				CActiveScheduler::Stop();

			break;

		case SReport::ERcv:

			test.Printf(_L("RCV: C:%10d OK:%10d BAD:%10d\n"), iRpt.iCount, iRpt.iOkCount, iRpt.iBadCount);

			break;

		case SReport::ETm:

			test.Printf(_L("TM: C:%10d\n"), iRpt.iCount);

#ifndef __EPOC32__

			if (iRpt.iCount > 100000)

				CActiveScheduler::Stop();

#endif

			TUint x = Random(iSeed) & 3;

			if (x==3)

				SendData();

			if (x)

				SendData();

			else

				iIfc.FlushData();

			break;

		}

	Start();

	}

void CReport::SendData()

	{

	TInt l = (Random(iSeed)&127)+128;

	TUint buf[64];

	TInt i;

	for (i=0; i<64; ++i)

		buf[i] = Random(iSeed);

	TPtrC8 ptr((const TUint8*)buf, l);

	TInt r = iIfc.SendData(ptr);

	test(r==KErrNone);

	}

GLDEF_C TInt E32Main()

	{

	test.Title();

	test.Start(_L("Load interface LDD"));

	TInt r = User::LoadLogicalDevice(KIfcLddName);

	test(r==KErrNone || r==KErrAlreadyExists);

	test.Next(_L("Open channel"));

	RRtosIfc ifc;

	RThread().SetPriority(EPriorityAbsoluteHigh);

	r = ifc.Open();

	test(r==KErrNone);

	test.Next(_L("Start personality tests"));

	ifc.Init();

	TRequestStatus s;

	ifc.WaitInitialTests(s);

	User::WaitForRequest(s);

	test(s==KErrNone);

	CActiveScheduler* as = new CActiveScheduler;

	test(as!=NULL);

	CActiveScheduler::Install(as);

	CRxData::New(ifc);

	CReport::New(ifc);

	CActiveScheduler::Start();

	ifc.Finish();

	ifc.Close();

	test.End();

	return 0;

	}