// 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);

 	}