// 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\device\t_sirco2.cpp

// 

//

#include "t_slowir.h"

#include <e32svr.h> 

#include <e32std.h>

#include <e32std_private.h> 

#include <e32hal.h>

#include <hal.h>

#if defined(__VC32__) && _MSC_VER==1100

// Disable MSVC++ 5.0 aggressive warnings about non-expansion of inline functions. 

#pragma warning(disable : 4710)	// function '...' not expanded

#endif

#if defined (__WINS__)

#define PDD_NAME _L("ECDRV.PDD")

#define LDD_NAME _L("ECOMM.LDD")

#else

#define PDD_NAME _L("EUART")

#define LDD_NAME _L("ECOMM")

#endif

#define PDD2_NAME _L("EUART")

#ifdef __WINS__

	#include <es_sock.h>

	RSocketServ ss;

#endif

#define FIND_NAME _L("Comm.*")

const TInt KUnit1=1;

const TInt KUnit2=2;

//LOCAL_D RTest test(_L("T_SlowIR"));

TBuf8<2060> WriteBuf;

TBuf8<2060> ReadBuf;

TInt iTimeDelay=1000000;

TInt iBufSz=2000;

TBool iRWToWrite=EFalse;

void ResetReadBuffer()

	{

	TInt i=0;

	ReadBuf.SetLength(2060);

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

		ReadBuf[i] ='R';

	}

void ResetWriteBuffer()

//

// Mark a buffer with repeating byte pattern

//

	{

	TUint startChar='A';

	TUint endChar='z';

	WriteBuf.SetLength(2060);

	TUint character=startChar;

	for (TInt i=0;i<WriteBuf.Length();i++)

		{

		WriteBuf[i]=(TText8)character;

		if(++character>endChar)

			character=startChar;

		}

	}

TInt CActiveRW::ErrorStats()

	{ // Computes error %ge

		if(iRxCount != 0)

			return (iRxErrCount*200+iRxCount)/(2*iRxCount);

		else

			return 0;

	}

TBool CActiveRW::CompareBuffers(TInt aLen)

	{

	TInt i=0;

	if(aLen !=ReadBuf.Length() || aLen !=WriteBuf.Length())

		return EFalse;

	while(i<aLen)

		{

		if(ReadBuf[i]!=WriteBuf[i]){

			return EFalse;}

		i++;

		}

	return ETrue;

	}

void SetUpBuffers()

	{

	ResetReadBuffer();

	ResetWriteBuffer();

	}

CActiveConsole::CActiveConsole(CConsoleBase* aConsole) 

	: CActive(EPriorityNormal)

	{

	iConsole=aConsole;

	iInit1  =EFalse;

	iInit2  =EFalse;

	}

CActiveConsole* CActiveConsole::NewLC(CConsoleBase* aConsole)

	{

	CActiveConsole* self = new (ELeave) CActiveConsole(aConsole);

	self->ConstructL();

	return self;

	}

void CActiveConsole::ConstructL ()

	{ 

	TCommCaps aCapsBuf;

	TCommCapsV01& aCaps=aCapsBuf();

	TCommConfig aConfigBuf;

	TCommConfigV01& aConfig=aConfigBuf();

	iConsole->Printf(_L("\r\n"));

	CActiveScheduler::Add(this);			// Add to active scheduler

    TBuf<10> pddName=PDD_NAME;

#if defined (__MARM__)

	const TInt KMaxPdds=10;

	iConsole->Printf(_L("Load MARM PDDs\n\r"));

	RDebug::Print(_L("Load MARM PDDs\n\r"));	

#else

	const TInt KMaxPdds=0;

	iConsole->Printf(_L("Load WINS PDD\n\r"));

	iConsole->Printf(PDD_NAME);

#endif

//		iConsole->Read(iStatus); 

	TInt i;

	TInt r;

	for (i=-1; i<KMaxPdds; ++i)

		{

		if (i==0)

			pddName.Append(TChar('0'));

		else if (i>0)

			pddName[pddName.Length()-1] = (TText)('0'+i);

		r=User::LoadPhysicalDevice(pddName);

		if (r==KErrNone || r==KErrAlreadyExists)

			{

			iConsole->Printf(_L("PDD %S loaded\n"),&pddName);

			RDebug::Print(_L("PDD %S loaded\n"),&pddName);	

			}

		}

	RDebug::Print(_L("Load MARM LDD\n\r"));	

	RDebug::Print(LDD_NAME);	

	iConsole->Printf(_L("Load LDD\n\r"));

	iConsole->Printf(LDD_NAME);

	r=User::LoadLogicalDevice(LDD_NAME);

	RDebug::Print(_L("\n\rReturn %d\n\r"),r);	

	iConsole->Printf(_L("\n\rReturn %d\n\r"),r);

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

	RDebug::Print(_L("\n\rFind PDDs\n\r"));	

	iConsole->Printf(_L("Find PDDs\n"));

	TFindPhysicalDevice findPDD(FIND_NAME);

	TFullName findResult;

	TInt res=findPDD.Next(findResult);

	while (res==KErrNone)

		{

		RDebug::Print(_L("Found Driver: %S\n\r"),&findResult);	

		iConsole->Printf(_L("Found Driver: %S\n\r"),&findResult);

		res=findPDD.Next(findResult);

		}

	iConsole->Printf(_L("Found drivers\n\r"));

	iPort=new RCommDev;

//	test(iPort!=NULL);

	SetUpBuffers();

	TInt muid=0;

	TInt ret=HAL::Get(HAL::EMachineUid, muid);

	if (ret!=KErrNone)

		iConsole->Printf(_L("Error %d reading MachineUid\r\n"),ret);

	if(muid==HAL::EMachineUid_Integrator)

		iConsole->Printf(_L("Platform is Integrator\r\n"));

	if(muid==HAL::EMachineUid_Integrator) ret=iPort->Open(KUnit2); // unit =2 for Integrator

	else ret=iPort->Open(KUnit1); // unit == 1 for brutus

	if (ret!=KErrNone)

		iConsole->Printf(_L("Error %d on opening Slow ir port\r\n"),ret);

	else

		iConsole->Printf(_L("Successfully opened Slow ir port\r\n"));

	iPort->Caps(aCapsBuf);

	if (ret!=KErrNone)

		iConsole->Printf(_L("Error %d on getting caps\r\n"),ret);

	else

		iConsole->Printf(_L("Sir Caps: %d\r\n"),aCaps.iRate);

	iPort->Config(aConfigBuf);

	if (ret!=KErrNone)

		iConsole->Printf(_L("Error %d getting config\r\n"),ret);

	else

		iConsole->Printf(_L("IR port config read\r\n"));

    iConsole->Printf(_L("****Choose Rate*****\r\n"));

    iConsole->Printf(_L("press '1' for   9600\r\n"));

    iConsole->Printf(_L("press '2' for  19200\r\n"));

    iConsole->Printf(_L("press '3' for  38400\r\n"));

    iConsole->Printf(_L("press '4' for  57600\r\n"));

    iConsole->Printf(_L("press '5' for 115200\r\n"));

    TRequestStatus key;

    iConsole->Read(key);

    User::WaitForRequest(key);

    TChar pressedkey = TChar(iConsole->KeyCode());

    switch(pressedkey)

        {

    case '1':

        aConfig.iRate=EBps9600;

        break;

    case '2':

        aConfig.iRate=EBps19200;

        break;

    case '3':

        aConfig.iRate=EBps38400;

        break;

    case '4':

        aConfig.iRate=EBps57600;

        break;

    case '5':

        aConfig.iRate=EBps115200;

        break;

    default:

        aConfig.iRate=EBps115200;

        break;

        }

	aConfig.iHandshake=0;

	aConfig.iSIREnable=ESIREnable;

	aConfig.iParity=EParityNone;

	aConfig.iDataBits=EData8;

	aConfig.iStopBits=EStop1;

	ret=iPort->SetConfig(aConfigBuf);

	if (ret!=KErrNone)

		iConsole->Printf(_L("Error %d setting config\r\n"),ret);

	else

		iConsole->Printf(_L("Have configured port\n"));

	iRW=CActiveRW::NewL(iConsole,iPort);

	if(iRW)

		iConsole->Printf(_L("Have created writer\r\n"));

	else

		iConsole->Printf(_L("Failed to create writer\r\n"));

	}

CActiveConsole::~CActiveConsole()

	{

	// Make sure we're cancelled

	Cancel();

	if(iRW)

		delete iRW;

	iPort->Close();

	}

void  CActiveConsole::DoCancel()

	{

	iConsole->ReadCancel();

	}

void  CActiveConsole::RunL()

	{

	ProcessKeyPressL(TChar(iConsole->KeyCode()));

//	iConsole->Printf(_L("CActiveConsole - Completed with code %d\r\n\r\n"), iStatus.Int ());

	}

void CActiveConsole::RequestCharacter()

	{

	if(!iInit1)

		{

		Options1();

		return;

		}

	if(!iInit2)

		{

		Options2();

		return;

		}

	  // A request is issued to the CConsoleBase to accept a

	  // character from the keyboard.

	iConsole->Printf(_L("*********************************\r\n"));

	iConsole->Printf(_L("press Escape to quit\r\n"));

	iConsole->Printf(_L("press 'r' to start as reader\r\n"));

	iConsole->Printf(_L("press 'w' to start as writer\r\n"));

	iConsole->Printf(_L("press 's' stop \r\n"));

	iConsole->Read(iStatus); 

	SetActive();

	}

void CActiveConsole::Options1()

	{

	iConsole->Printf(_L("*****Choose Delay*****\r\n"));

	iConsole->Printf(_L("press '1' 1.00 sec delay\r\n"));

	iConsole->Printf(_L("press '2' 0.10 sec delay\r\n"));

	iConsole->Printf(_L("press '3' 0.01 sec delay\r\n"));

	iConsole->Printf(_L("press '4' 0.00 sec delay\r\n"));

	iConsole->Read(iStatus); 

	SetActive();	

	}

void CActiveConsole::Options2()

	{

	iConsole->Printf(_L("****Choose Buf Sz*****\r\n"));

	iConsole->Printf(_L("press '1' 1    byte \r\n"));

	iConsole->Printf(_L("press '2' 4    bytes\r\n"));

	iConsole->Printf(_L("press '3' 2000 bytes\r\n"));

	iConsole->Printf(_L("press '4' 2051 bytes\r\n"));

	iConsole->Read(iStatus); 

	SetActive();	

	}

void CActiveConsole::ProcessKeyPressL(TChar aChar)

	{

	if (aChar == EKeyEscape)

		{

		CActiveScheduler::Stop();

		return;

		}

	if(!iInit1)

		{

		switch(aChar)

			{

		case '1'://1 sec

			iTimeDelay=1000000;

			break;

		case '2'://0.1 sec

			iTimeDelay=100000;

			break;

		case '3'://0.01 sec

			iTimeDelay=10000;

			break;

		case '4'://0 sec

			iTimeDelay=0;

			break;

		default:

			iTimeDelay=1000000;

			break;

			}

		iConsole->Printf(_L("Time Delay: %d\r\n"),iTimeDelay);

		iInit1=ETrue;

		RequestCharacter();

		return;

		}

	if(!iInit2)

		{

		switch(aChar)

			{

		case '1':

			iBufSz=1;

			break;

		case '2':

			iBufSz=4;

			break;

		case '3':

			iBufSz=2000;

			break;

		case '4':

			iBufSz=2051;

			break;

		default:

			iBufSz=2000;

			break;

			}

		// check that we have enough space

		if(iBufSz>iPort->ReceiveBufferLength())

			iPort->SetReceiveBufferLength(iBufSz);

		// if it won't do it, then settle for what it is by default

		if(iBufSz>iPort->ReceiveBufferLength())

			iBufSz=iPort->ReceiveBufferLength();

		iConsole->Printf(_L("Buffer size: %d\r\n"),iBufSz);

		iInit2=ETrue;

		RequestCharacter();

		return;

		}

	switch (aChar)

		{

	case 'r'://start reader

	case 'R'://start reader

		iRW->Start(EFalse);

		break;

	case 'w'://start writer

	case 'W'://start writer

		iRW->Start(ETrue);

		break;

	case 's'://stop reader

	case 'S'://stop reader

		iRW->Stop();

		break;

	default:

		iConsole->Printf(_L("\r\nUnknown Command\r\n\r\n"));

		break;

		}

	RequestCharacter ();

	return;

	}

//

// class CActiveRW

//

CActiveRW::CActiveRW(CConsoleBase* aConsole,RCommDev* aPort)

	: CActive (EPriorityNormal)

	{

	iConsole=aConsole;

	iPort=aPort;

	iLength=0;

	iUnrecovered=0;

	iRxCount=0;

	iRxErrCount=0;

	}

CActiveRW* CActiveRW::NewL(CConsoleBase* aConsole,RCommDev* aPort)

	{

	CActiveRW* self = new (ELeave) CActiveRW(aConsole,aPort);

	CleanupStack::PushL (self);

	self->ConstructL();

	CActiveScheduler::Add (self);

	CleanupStack::Pop ();

	return (self);

	}

void CActiveRW::ConstructL()

	{

	}

CActiveRW::~CActiveRW()

	{

	Cancel();

	}

void CActiveRW::RunL ()

	{

	TInt i=0;

	if(iNextXfer==EWriteXfer)

		iRxCount++;

	if (iStatus != KErrNone)

	{

		if(iNextXfer==EWriteXfer)

			{

			iRxErrCount++;

			iConsole->Printf(_L("Error %d on reading, error = %d%%\r\n"),iStatus.Int(),ErrorStats());

			iPort->ResetBuffers();

			iNextXfer=EDiscardXfer;

			}

		else

			{

			iConsole->Printf(_L("Error %d on writing\r\n"),iStatus.Int());

			iConsole->Printf(_L("Received %d characters\r\n"),iPort->QueryReceiveBuffer());

			}

	}

	//return;

	if(iTimeDelay)

		User::After(iTimeDelay);

	if(iNextXfer==EReadXfer)

		{

//		iPort->ResetBuffers();

		ResetReadBuffer();

		ReadBuf.SetLength(iBufSz);

		iConsole->Printf(_L("Reading(%d)"),ReadBuf.Length());

		iPort->Read(iStatus, ReadBuf, ReadBuf.Length());

		iNextXfer=EWriteXfer;

		}

	else // EWriteXfer || EDiagXfer || EDiscardXfer

		{

		if(iNextXfer==EWriteXfer)

			{

			if(!CompareBuffers(iBufSz))

				{

				iConsole->Printf(_L("\n***** Buffers don't match *****\n"));

				for (i=0;i<ReadBuf.Length();i++)

					{

					iConsole->Printf(_L("WriteBuf[%d] = %02x, ReadBuf[%d] = %02x\n"),i,WriteBuf[i],i,ReadBuf[i]);

					}

				iUnrecovered=iPort->QueryReceiveBuffer();

				iConsole->Printf(_L("Unrecovered %d characters\r\n"),iUnrecovered);

				if(iUnrecovered)

					{

					ReadBuf.SetLength(Max(iBufSz,iUnrecovered));

					iNextXfer=EDiagXfer;

					iConsole->Printf(_L("\n***** Doing Diagnostic read *****\n"));

					iPort->Read(iStatus, ReadBuf, iUnrecovered);

					SetActive();

					return;