// Copyright (c) 1998-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_dtenot.cpp

// 

//

#include <e32base.h>

#include <e32base_private.h>

#include <e32test.h>

#include <e32cons.h>

#include <e32svr.h>

#include <e32hal.h>

#include <d32comm.h>

#include <e32uid.h>

#include <hal.h>

const TInt KUnit0=0;

const TInt KUnit1=1;

const TInt KUnit2=2;

const TInt KUnit3=3;

#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 CHECK(r,v)	{if ((r)!=(v)) {test.Printf(_L("Line %d Expected %08x Got %08x\n"),__LINE__,(v),(r)); test(0);}}

//	Our own comms object with synchronous writes

class RComm : public RBusDevComm

	{

public:

	TInt WriteS(const TDesC8& aDes);

	TInt WriteS(const TDesC8& aDes,TInt aLength);

	};

LOCAL_D RTest test(_L("T_DTENOT"));

RComm* theSerialPort;

TCommCaps2 theCapsBuf;

TCommCapsV02& theCaps=theCapsBuf();

TInt RComm::WriteS(const TDesC8& aDes)

//	Syncronous write

	{

	return(WriteS(aDes,aDes.Length()));

	}

TInt RComm::WriteS(const TDesC8& aDes,TInt aLength)

//	Syncronous write

	{

	TRequestStatus s;

	Write(s,aDes,aLength);

	User::WaitForRequest(s);

	return(s.Int());

	}

enum TSetClearOutSignal {ESetOutSignal,EClearOutSignal};

enum TOutcomeExpected {EExpectNotify,EExpectTimeout};

enum TSigChngNotifyType {ENotifyOnInSigOnly,ENotifyOnAnyChange};

LOCAL_C void TestNotifySignalChange(TUint anOutSig,TSetClearOutSignal aSetClr,TUint anInSig,TOutcomeExpected anExpect,TSigChngNotifyType aType)

//

// Change the state of the specified output signal and wait up to 2 seconds for

// this to trigger a change notification.

//

	{

	RTimer tim;

	tim.CreateLocal();

	TRequestStatus notifStatus;

	TRequestStatus timeStatus;

	TUint signals=0;

	if (aType==ENotifyOnAnyChange)

		theSerialPort->NotifySignalChange(notifStatus,signals);

	else

	    theSerialPort->NotifySignalChange(notifStatus,signals,anInSig);

//	CHECK(notifStatus.Int(),KRequestPending);

	const TUint KTimeOut=2000000;

	tim.After(timeStatus,KTimeOut);

	CHECK(timeStatus.Int(),KRequestPending);

	if (aSetClr==ESetOutSignal)

		theSerialPort->SetSignals(anOutSig,0); // Set Out signal

	else

		theSerialPort->SetSignals(0,anOutSig); // Clear Out signal

	User::WaitForRequest(notifStatus,timeStatus);

	if (notifStatus!=KRequestPending)

		{

		test.Printf(_L("notifStatus=%08x\n"),notifStatus.Int());

		tim.Cancel();

		User::WaitForRequest(timeStatus);

		if (anExpect==EExpectNotify)

			{

			// Got a notification as expected - but was it the correct notification?

			TUint sigmask=(anInSig*KSignalChanged);

			if (aSetClr==ESetOutSignal)

				sigmask|=anInSig;

			if (aType==ENotifyOnAnyChange)

				{CHECK((signals&sigmask),sigmask);}

			else

				{CHECK(signals,sigmask);}

			}

		else

			{

			test.Printf(_L("Spurious notify %d %08x\n"),notifStatus.Int(),signals);

			test(FALSE); // Unexpectedly got notification

			}

		}

	else

		{

		test.Printf(_L("timeStatus=%08x\n"),timeStatus.Int());

		theSerialPort->NotifySignalChangeCancel();

		User::WaitForRequest(notifStatus);

		if (anExpect==EExpectNotify)

			{

			test.Printf(_L("Timed Out!\n\r"));

			test(FALSE);

			}

		else

		    test(timeStatus==KErrNone); // Success

		}

	}

GLDEF_C TInt E32Main()

//

// Test DTE serial driver change notification

//

    {

	test.SetLogged(EFalse); 	// Turn off serial port debugging!

	test.Title();

	test.Start(_L("Check loopback connector"));

	TBuf <0x100> cmd;

	User::CommandLine(cmd);

	TInt port=0;

	if ((cmd.Length()>0) && (cmd[0]>='0' && cmd[0]<='9'))

		port=(TInt)(cmd[0]-'0');

	// Read machine name to determine handshake options required

	TInt mid;

	TInt r=HAL::Get(HAL::EMachineUid,mid);

	test(r==KErrNone);

	TUint handshake=(KConfigFreeRTS|KConfigFreeDTR); // So we can control them ourselves

	if (mid==HAL::EMachineUid_Brutus && port<3)

		handshake=0;	// Brutus can't support these option on ports 0-2

	test.Printf(_L("\r\nThis test requires a loopback conector.\r\n"));

	test.Printf(_L("<<Hit a key to continue>>\r\n"));

	test.Getch();

	TInt muid=0;

	test(HAL::Get(HAL::EMachineUid, muid)==KErrNone);

	TBool isAssabet=(muid==HAL::EMachineUid_Assabet);

	// Load Device Drivers

    TBuf<10> pddName=PDD_NAME;

	test.Next(_L("Load PDDs"));

#ifdef __WINS__

	const TInt KMaxPdds=0;

#else

	const TInt KMaxPdds=10;

#endif

	TInt i;

	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)

			test.Printf(_L("PDD %S loaded\n"),&pddName);

		}

	test.Next(_L("Load LDD"));

	r=User::LoadLogicalDevice(LDD_NAME);

	test.Printf(_L("Load LDD Return %d\n\r"),r);

	test.Next(_L("Create RComm object"));

	theSerialPort=new RComm;

	test(theSerialPort!=NULL);

//

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

	r=theSerialPort->Open(port);

	test.Printf(_L("Open(%d)=%d\n\r"),port,r);

	test(r==KErrNone);

	test.Next(_L("Get caps and configure port"));

	theSerialPort->Caps(theCapsBuf);

	CHECK(r,KErrNone);

	test.Printf(_L("Signals(DTR-RTS-RI-DCD-DSR-CTS) %x\n\r"),theCaps.iSignals);

	test.Printf(_L("Notifications %x\n\r"),theCaps.iNotificationCaps);

	TCommConfig cBuf;

	TCommConfigV01& c=cBuf();

	theSerialPort->Config(cBuf);

	c.iHandshake=handshake;

	c.iDataBits=EData8;

	c.iStopBits=EStop1;

	c.iParity=EParityNone;

	c.iRate=EBps9600;

	r=theSerialPort->SetConfig(cBuf);

	CHECK(r,KErrNone);

	RTimer tim;

	tim.CreateLocal();

	TRequestStatus notifStatus;

	TRequestStatus timeStatus;

	test.Next(_L("Testing NotifySignalChange()"));

	if (!(theCaps.iNotificationCaps & KNotifySignalsChangeSupported))

        test.Printf(_L("WARNING - Signal change notification not supported on this platform\r\n"));

    else

        {

		if ((theCaps.iSignals&(KCapsSignalCTSSupported|KCapsSignalRTSSupported))!=(KCapsSignalCTSSupported|KCapsSignalRTSSupported))

        	test.Printf(_L("WARNING - RTS/CTS not supported on this platform\r\n"));

		else

			{

#ifndef __WINS__

			TUint signals=0xffffffff;

	    	theSerialPort->SetSignals(0,KSignalRTS); // Clear RTS

	    	User::After(100000);

			test.Next(_L("Initial notifier"));

			theSerialPort->NotifySignalChange(notifStatus,signals);

			User::WaitForRequest(notifStatus);

			test(notifStatus==KErrNone);	// goes off immediately the first time

			test.Printf(_L("Signals %08x\n"),signals);

			test((signals&(KSignalRTS|KSignalCTS))==0);

#endif

			// Test with no signal mask set

			isAssabet=0;

			if (isAssabet)

				{

//			test.Next(_L("   CTS(set) notify without mask set"));

//			TestNotifySignalChange(KSignalRTS,ESetOutSignal,KSignalCTS,EExpectNotify,ENotifyOnAnyChange);

//	(CF)	Note: This test presents some problems: we specify notification on any signal but the test only   

//				  passes if the input signal specified (CTS) has changed. The test code makes a request for

//				  notification on any signal (iSignalMask=0x3f) and THEN changes an output signal (RTS) that's 

//				  wired to the input signal specified (CTS). But changing an output signal launches the DFC

//				  to complete the notification request reporting a change on the output signal NOT the input

//				  signal. The only reason most platforms pass this test is because, on them, input signal changes 

//				  trigger interrupts: due to the loopback between output and input signals, when the output

//				  signal changes so does the input signal and that triggers an interrupt which also launches 

//				  a DFC to complete the notification request reporting a change on the input signal.

//				  The interrupt is serviced before the output signal notification DFC is scheduled and

//				  the notification request is completed with the input signal change.

//				  On Assabet Modem control signals are polled instead of generating interrupts (Intel's design

//				  flaw) and therefore the output signal change will complete the notification (in error) before

//				  the input signal change is notified.

//

				test.Next(_L("   RTS(set) notify without mask set"));

				TestNotifySignalChange(KSignalRTS,ESetOutSignal,KSignalRTS,EExpectNotify,ENotifyOnAnyChange);

				test.Next(_L("   RTS(clear) notify without mask set"));

				TestNotifySignalChange(KSignalRTS,EClearOutSignal,KSignalRTS,EExpectNotify,ENotifyOnAnyChange);

				}

			else

				{

				test.Next(_L("   CTS(set) notify without mask set"));

				TestNotifySignalChange(KSignalRTS,ESetOutSignal,KSignalCTS,EExpectNotify,ENotifyOnAnyChange);

				test.Next(_L("   CTS(clear) notify without mask set"));

				TestNotifySignalChange(KSignalRTS,EClearOutSignal,KSignalCTS,EExpectNotify,ENotifyOnAnyChange);

				}

        	// Test notification doesn't happen with signal mask set to some other signal

			test.Next(_L("   No CTS(set) notify with mask set to other signal"));

			TestNotifySignalChange(KSignalRTS,ESetOutSignal,KSignalDSR,EExpectTimeout,ENotifyOnInSigOnly);

			TestNotifySignalChange(KSignalRTS,ESetOutSignal,KSignalCTS,EExpectNotify,ENotifyOnInSigOnly);

        	// Test notification happens with mask set to this signal

			test.Next(_L("   CTS(clear) notify with mask set"));

			TestNotifySignalChange(KSignalRTS,EClearOutSignal,KSignalCTS,EExpectNotify,ENotifyOnInSigOnly);

			test.Next(_L("   CTS(set) notify with mask set"));

			TestNotifySignalChange(KSignalRTS,ESetOutSignal,KSignalCTS,EExpectNotify,ENotifyOnInSigOnly);

			}

		if ((theCaps.iSignals&(KCapsSignalDSRSupported|KCapsSignalDTRSupported))!=(KCapsSignalDSRSupported|KCapsSignalDTRSupported))

        	test.Printf(_L("WARNING - DTR/DSR not supported on this platform\r\n"));

		else

			{

	    	theSerialPort->SetSignals(0,KSignalDTR); // Clear DTR

	    	User::After(100000);

        	// Test with no signal mask set

			if (isAssabet)

				{

// (CF) See note above

				test.Next(_L("   DTR(set) notify without mask set"));

				TestNotifySignalChange(KSignalDTR,ESetOutSignal,KSignalDTR,EExpectNotify,ENotifyOnAnyChange);

				test.Next(_L("   DTR(clear) notify without mask set"));

				TestNotifySignalChange(KSignalDTR,EClearOutSignal,KSignalDTR,EExpectNotify,ENotifyOnAnyChange);

				}

			else

				{

				test.Next(_L("   DSR(set) notify without mask set"));

				TestNotifySignalChange(KSignalDTR,ESetOutSignal,KSignalDSR,EExpectNotify,ENotifyOnAnyChange);

				test.Next(_L("   DSR(clear) notify without mask set"));

				TestNotifySignalChange(KSignalDTR,EClearOutSignal,KSignalDSR,EExpectNotify,ENotifyOnAnyChange);

				}

        	// Test notification happens with mask set to this signal

			test.Next(_L("   DSR(set) notify with mask set"));

			TestNotifySignalChange(KSignalDTR,ESetOutSignal,KSignalDSR,EExpectNotify,ENotifyOnInSigOnly);

			test.Next(_L("   DSR(clear) notify with mask set"));

			TestNotifySignalChange(KSignalDTR,EClearOutSignal,KSignalDSR,EExpectNotify,ENotifyOnInSigOnly);

			}

		if (mid==HAL::EMachineUid_Series5mx ||

			(theCaps.iSignals&(KCapsSignalDCDSupported|KCapsSignalDTRSupported))!=(KCapsSignalDCDSupported|KCapsSignalDTRSupported))

        	test.Printf(_L("WARNING - DTR/DCD not supported on this platform\r\n"));

		else

			{

        	// Test with no signal mask set

			if (isAssabet)

				{

// (CF) See note above

				test.Next(_L("   DTR(set) notify without mask set"));

				TestNotifySignalChange(KSignalDTR,ESetOutSignal,KSignalDTR,EExpectNotify,ENotifyOnAnyChange);			

				test.Next(_L("   DTR(clear) notify without mask set"));

				TestNotifySignalChange(KSignalDTR,EClearOutSignal,KSignalDTR,EExpectNotify,ENotifyOnAnyChange);

				}

			else

				{

				test.Next(_L("   DCD(set) notify without mask set"));

				TestNotifySignalChange(KSignalDTR,ESetOutSignal,KSignalDCD,EExpectNotify,ENotifyOnAnyChange);

				test.Next(_L("   DCD(clear) notify without mask set"));

				TestNotifySignalChange(KSignalDTR,EClearOutSignal,KSignalDCD,EExpectNotify,ENotifyOnAnyChange);

				}

        	// Test notification happens with mask set to this signal

			test.Next(_L("   DCD(set) notify with mask set"));

			TestNotifySignalChange(KSignalDTR,ESetOutSignal,KSignalDCD,EExpectNotify,ENotifyOnInSigOnly);

			test.Next(_L("   DCD(clear) notify with mask set"));

			TestNotifySignalChange(KSignalDTR,EClearOutSignal,KSignalDCD,EExpectNotify,ENotifyOnInSigOnly);

			}

        }

	test.Next(_L("Testing NotifyReceiveDataAvailable()"));

	if (!(theCaps.iNotificationCaps & KNotifyDataAvailableSupported))

        test.Printf(_L("Data available notification not supported on this platform\r\n"));

    else

        {

	    TBuf8<0x10> buf1(0x10), buf2(0x10);

        for (TInt i=0;i<0x10;i++) buf1[i]=(TUint8)i;

        theSerialPort->ResetBuffers();

	    theSerialPort->NotifyReceiveDataAvailable(notifStatus);

	    CHECK(notifStatus.Int(),KRequestPending);

	    const TUint KTimeOut=2000000;

	    tim.After(timeStatus,KTimeOut);

	    CHECK(timeStatus.Int(),KRequestPending);

	    theSerialPort->WriteS(buf1);

	    User::WaitForRequest(notifStatus,timeStatus);

	    if (notifStatus==KErrNone)

		    {

		    tim.Cancel();

		    CHECK(notifStatus.Int(),KErrNone);

		    }

	    else

		    {

		    test.Printf(_L("Timed Out!\n\r"));

	        theSerialPort->NotifyReceiveDataAvailableCancel();

		    test(FALSE);

		    }

		User::After(500000);

		CHECK(theSerialPort->QueryReceiveBuffer(),0x10);

	    buf2.FillZ();

	    theSerialPort->Read(notifStatus,buf2,0x10);

		User::WaitForRequest(notifStatus);

		test(buf1.Compare(buf2)==0);

        }

	theSerialPort->Close();

	test.Printf(_L("<<Hit a key to end>>\r\n"));

	test.Getch();

	test.End();

	return(KErrNone);

	}