// 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_ampv.cpp

// Approval tests for the Pc Card Adapter.

// 

//

#include <e32std.h>

#include <e32std_private.h>

#include <e32cons.h>

#include <e32svr.h>

#include <e32hal.h>

#include <e32uid.h>

#include <d32comm.h>

const TInt KRxBufSize=20;

const TInt KAmpVTimeout=2000000;

const TInt KUnit0=0;

#if defined (__WINS__)

#define PDD_NAME _L("ECDRV.PDD")

#define LDD_NAME _L("ECOMM.LDD")

#else

#define PDD_NAME _L("EUART1.PDD")

#define LDD_NAME _L("ECOMM.LDD")

#endif

class RComm : public RBusDevComm

	{

public:

	TInt WriteS(const TDesC8& aDes);

	};

GLDEF_D CConsoleBase *theConsole;

GLDEF_D RComm *theSerialPort;

TInt RComm::WriteS(const TDesC8& aDes)

//

// Syncronous write

//

	{

	TRequestStatus s;

	Write(s,aDes,aDes.Length());

	User::WaitForRequest(s);

	return(s.Int());

	}

LOCAL_C void AmpVTest()

//

// Perform the test

//

	{

    TInt errCount=0;

    TInt okStatus=0;

	TRequestStatus tStat,sStat,kStat;

	TUint8 rxBuf[KRxBufSize];

	TPtr8 rxDes(&rxBuf[0],KRxBufSize,KRxBufSize);

	theSerialPort->Read(sStat,rxDes,0);	// Raise DTR and wake up the PCA

	User::WaitForRequest(sStat);

	User::After(4000000);				// 4Secs while PC card starts up

	theSerialPort->WriteS(_L8("AT\r"));

	theSerialPort->WriteS(_L8("AT&f\r"));

	User::After(500000);		// 0.5S

	theSerialPort->ResetBuffers();

	theConsole->Printf(_L("Sending AT&V\n\r"));

	theSerialPort->WriteS(_L8("AT&V\r"));

	RTimer tim;

	tim.CreateLocal();

	tim.After(tStat,KAmpVTimeout);

	theConsole->Read(kStat);

	theSerialPort->Read(sStat,rxDes,1);

    FOREVER

        {

		User::WaitForAnyRequest();

		if (sStat!=KRequestPending)

			{

            // got another character

            if (sStat!=KErrNone)

                {

                // Bad character - initiate another try. 

                errCount++;

				tim.Cancel();

				User::WaitForRequest(tStat);

				User::After(200000);	

				theSerialPort->ResetBuffers();

				theConsole->Printf(_L("Errors:%d (Bad char-%d)\r\n"),errCount,sStat.Int());

				theConsole->Printf(_L("Sending AT&V\n\r"));

				theSerialPort->WriteS(_L8("AT&V\r"));

				tim.After(tStat,KAmpVTimeout);

                okStatus=0;

                }

            else

                {

                // Check if its CR/LF/OK/CR/LF

                switch(okStatus)

                    {

                    case 0:

                        okStatus=(rxBuf[0]=='\x0D')?(okStatus+1):0;

                        break;

                    case 1:

                        if (rxBuf[0]=='\x0A')

                            okStatus++;

                        else

                            okStatus=(rxBuf[0]=='\x0D')?1:0;

                        break;

                    case 2:

                        if (rxBuf[0]=='O')

                            okStatus++;

                        else

                            okStatus=(rxBuf[0]=='\x0D')?1:0;

                        break;

                    case 3:

                        if (rxBuf[0]=='K')

                            okStatus++;

                        else

                            okStatus=(rxBuf[0]=='\x0D')?1:0;

                        break;

                    case 4:

                        if (rxBuf[0]=='\x0D')

                            okStatus++;

                        else

                            okStatus=(rxBuf[0]=='\x0D')?1:0;

                        break;

                    case 5:

                        if (rxBuf[0]=='\x0A')

                            {

                            // Success - initiate another try. 

							tim.Cancel();

							User::WaitForRequest(tStat);

							User::After(200000);	

							theSerialPort->ResetBuffers(); 

							theConsole->Printf(_L("Errors:%d\r\n"),errCount);

							theConsole->Printf(_L("Sending AT&V\n\r"));

							theSerialPort->WriteS(_L8("AT&V\r"));

							tim.After(tStat,KAmpVTimeout);

                			okStatus=0;

                            }

                        else

                            okStatus=(rxBuf[0]=='\x0D')?1:0;

                        break;

                    default:

                        okStatus=0;

                    }

                }

            // Queue another serial read

			theSerialPort->Read(sStat,rxDes,1);

			}

		else if (tStat!=KRequestPending)

			{

            // Error - didn't get OK

			theSerialPort->ReadCancel();

			User::WaitForRequest(sStat);

            errCount++;

            // Initiate another try

			User::After(200000);	

			theSerialPort->ResetBuffers();

			theConsole->Printf(_L("Errors:%d (Timeout)\r\n"),errCount);

			theConsole->Printf(_L("Sending AT&V\n\r"));

			theSerialPort->WriteS(_L8("AT&V\r"));

			tim.After(tStat,KAmpVTimeout);

			theSerialPort->Read(sStat,rxDes,1);

            okStatus=0;

			}

        else if (kStat!=KRequestPending)

            {

			theSerialPort->ReadCancel();

			User::WaitForRequest(sStat);

			tim.Cancel();

			User::WaitForRequest(tStat);

            return;

            }

		else

			{

			theConsole->Printf(_L("ERROR - stray signal\r\n"));

			theConsole->ReadCancel();

			User::WaitForRequest(kStat);

			theSerialPort->ReadCancel();

			User::WaitForRequest(sStat);

			tim.Cancel();

			User::WaitForRequest(tStat);

			theConsole->Getch();

            return;

			}

        }

	}

GLDEF_C TInt E32Main()

	{

	TCommConfig cBuf;

	TCommConfigV01 &c=cBuf();

	// Create console

	theConsole=Console::NewL(_L("T_AMPV"),TSize(KDefaultConsWidth,KDefaultConsHeight));

	// Load Device Drivers

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

	TInt r;

	r=User::LoadPhysicalDevice(PDD_NAME);

	if (r!=KErrNone&&r!=KErrAlreadyExists)

		goto AmpvEnd;

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

	r=User::LoadLogicalDevice(LDD_NAME);

	if (r!=KErrNone&&r!=KErrAlreadyExists)

		goto AmpvEnd;

	// Create RComm object

	theConsole->Printf(_L("Create RComm object\n\r"));

	theSerialPort=new RComm;

	if (theSerialPort==NULL)

		goto AmpvEnd;

	// Open Serial Port

	theConsole->Printf(_L("Open Serial Port\n\r"));

	r=theSerialPort->Open(KUnit0);

	if (r!=KErrNone)

		goto AmpvEnd;

	// Setup serial port

	theConsole->Printf(_L("Setup serial port\n\r"));

	theSerialPort->Config(cBuf);

	c.iRate=EBps57600;

	c.iDataBits=EData8;

	c.iStopBits=EStop1;

	c.iParity=EParityNone;

//	c.iHandshake=KConfigObeyCTS;

	c.iHandshake=0;

	r=theSerialPort->SetConfig(cBuf);

	if (r!=KErrNone)

		goto AmpvEnd;

	AmpVTest();

AmpvEnd:

	if (theSerialPort)

		theSerialPort->Close();

	delete theSerialPort;

	delete theConsole;

	return(KErrNone);

	}