kerneltest/e32test/device/t_ampv.cpp
changeset 0 a41df078684a
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/kerneltest/e32test/device/t_ampv.cpp	Mon Oct 19 15:55:17 2009 +0100
@@ -0,0 +1,259 @@
+// 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);
+	}
+
+