// 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:

// @file PBASE-T_USBDI-0484.cpp

// @internalComponent

// 

//

#include "PBASE-T_USBDI-0484.h"

#include "testpolicy.h"

#include "modelleddevices.h"

namespace NUnitTesting_USBDI

	{	

_LIT8(KDataPayload1,"opqrstuvwxyzabcdefghijklmnopqrstuvwxyz12345abcdefghijklmnopqrstuvwxyz");

_LIT8(KDataPayload2,"12345opqrstuvwxyzabcdefghijklmnopqrstuvwxyzabcdefghijklmnopqrstuvwxyz");

_LIT8(KDataPayload3,"abcdefghijklmnopqrstuvwxyzopqrstuvwxyzabcdefghijklmnopqrstuvwxyz"); // 64bytes

const TInt KBulkTransferId1 = 0x01;

const TInt KBulkTransferId2 = 0x02;

const TInt KBulkTransferId3 = 0x03;

_LIT(KTestCaseId,"PBASE-T_USBDI-0484");

const TFunctorTestCase<CUT_PBASE_T_USBDI_0484,TBool> CUT_PBASE_T_USBDI_0484::iFunctor(KTestCaseId);	

CUT_PBASE_T_USBDI_0484* CUT_PBASE_T_USBDI_0484::NewL(TBool aHostRole)

	{

	CUT_PBASE_T_USBDI_0484* self = new (ELeave) CUT_PBASE_T_USBDI_0484(aHostRole);

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop(self);

	return self;

	}

CUT_PBASE_T_USBDI_0484::CUT_PBASE_T_USBDI_0484(TBool aHostRole)

:	CBaseBulkTestCase(KTestCaseId,aHostRole),

	iCaseStep(EInProgress)

	{

	} 

void CUT_PBASE_T_USBDI_0484::ConstructL()

	{

	BaseBulkConstructL();

	}

CUT_PBASE_T_USBDI_0484::~CUT_PBASE_T_USBDI_0484()

	{

	}

void CUT_PBASE_T_USBDI_0484::Ep0TransferCompleteL(TInt aCompletionCode)

	{

	Cancel();	

	if(aCompletionCode != KErrNone)

		{	

		TBuf<256> msg;

		msg.Format(_L("<Error %d> Transfer to control endpoint 0 was not successful"),aCompletionCode);

		}

	if(iCaseStep == EPassed)

		{	

		if(aCompletionCode == KErrNone)

			{

			return TestPassed();

			}

		// else error

	    iCaseStep = EFailed;

		}

	if(iCaseStep == EFailed)

		{

		return TestFailed(KErrCompletion);

		}

	}

void CUT_PBASE_T_USBDI_0484::TransferCompleteL(TInt aTransferId,TInt aCompletionCode)

	{

	Cancel();

	TInt err(KErrNone);

	if(aTransferId == KBulkTransferId1)

		{

		if(iCaseStep == EStalled)

			{						

			if(aCompletionCode != KErrUsbStalled)

				{

				TBuf<256> msg;

				msg.Format(_L("<Error %d> The transfer completed with no errors but should have stalled"),aCompletionCode);

				TTestCaseFailed request(KErrCorrupt,msg);

				return iControlEp0->SendRequest(request,this);

				}

			else 

				{

				// Acknowledge the stall and clear				

				err = iTestPipeInterface1BulkIn.ClearRemoteStall();

				if(err != KErrNone)

					{

					TBuf<256> msg;

					msg.Format(_L("<Error %d> The remote stall cannot be cleared"),err);

					iCaseStep = EFailed;

					TTestCaseFailed request(err,msg);

					return iControlEp0->SendRequest(request,this);

					}

				// try to get data now, after EP has been stalled

				iInTransfer[0]->TransferIn(KDataPayload1().Length());

				iInTransfer[1]->TransferIn(KDataPayload2().Length());

				iInTransfer[2]->TransferIn(KDataPayload3().Length());

				iCaseStep = ETransferAfterStall;

				TEndpointWriteRequest request(1,1,KDataPayload1);// EP1 because 1st writter EP

				iControlEp0->SendRequest(request,this);	

				return;		

				}

			}

		if(iCaseStep == ETransferAfterStall)

			{

			if(aCompletionCode != KErrNone)

				{

				TBuf<256> msg;

				msg.Format(_L("<Error %d> No data got after EP2 being stalled"),aCompletionCode);

				iCaseStep = EFailed;

				TTestCaseFailed request(err,msg);

				return iControlEp0->SendRequest(request,this);

				}	

			// else ok, compare data rcvd now

			TPtrC8 data(iInTransfer[0]->DataPolled());		

			// Compare the data to what is expected		

			if(data.Compare(KDataPayload1) != 0)

				{

				TBuf<256> msg;

				msg.Format(_L("<Error %d> Interrupt data received does not match data sent"),KErrCompletion);

				iCaseStep = EFailed;

				TTestCaseFailed request(KErrCompletion,msg);

				return iControlEp0->SendRequest(request,this);

				}			 

			// Comparison is a match, wait for next transfer

			User::After(500000);

			TEndpointWriteRequest request(1,1,KDataPayload2);// EP1 because 1st writter EP

			iControlEp0->SendRequest(request,this);						

			}

		}

	else if(aTransferId == KBulkTransferId2)

		{

		if(aCompletionCode != KErrNone)

			{

			TBuf<256> msg;

			msg.Format(_L("<Error %d> No data got after EP2 being stalled"),aCompletionCode);

			iCaseStep = EFailed;

			TTestCaseFailed request(err,msg);

			return iControlEp0->SendRequest(request,this);

			}	

		// else ok, compare data rcvd now

		TPtrC8 data(iInTransfer[1]->DataPolled());		

		// Compare the data to what is expected		

		if(data.Compare(KDataPayload2) != 0)

			{

			TBuf<256> msg;

			msg.Format(_L("<Error %d> Interrupt data received does not match data sent"),KErrCompletion);

			iCaseStep = EFailed;

			TTestCaseFailed request(KErrCompletion,msg);

			return iControlEp0->SendRequest(request,this);

			}			 

		// Comparison is a match, wait for next transfer

		User::After(500000);

		TEndpointWriteRequest request(1,1,KDataPayload3);// EP1 because 1st writter EP

		iControlEp0->SendRequest(request,this);					

		}

	else if(aTransferId == KBulkTransferId3)

		{		

		if(aCompletionCode != KErrNone)

			{

			TBuf<256> msg;

			msg.Format(_L("<Error %d> No data got after EP2 being stalled"),aCompletionCode);

			iCaseStep = EFailed;

			TTestCaseFailed request(err,msg);

			return iControlEp0->SendRequest(request,this);

			}			

		// else ok, compare data rcvd now

		TPtrC8 data(iInTransfer[2]->DataPolled());		

		// Compare the data to what is expected		

		if(data.Compare(KDataPayload3) != 0)

			{

			TBuf<256> msg;

			msg.Format(_L("<Error %d> Interrupt data received does not match data sent"),KErrCompletion);

			iCaseStep = EFailed;

			TTestCaseFailed request(KErrCompletion,msg);

			return iControlEp0->SendRequest(request,this);

			}			 

		// Comparison is a match, test passes

		iCaseStep = EPassed;

		TTestCasePassed request;

		return iControlEp0->SendRequest(request,this);

		}

	else

		{

		return TestFailed(KErrCorrupt);

		}	

	}

void CUT_PBASE_T_USBDI_0484::DeviceInsertedL(TUint aDeviceHandle)

	{

	Cancel();

	TBuf<256> msg;

	TInt err = KErrNone;

	if(BaseBulkDeviceInsertedL(aDeviceHandle, EFalse) == EDeviceConfigurationError)

		// Prepare for response from control transfer to client

		{

		err = KErrGeneral;

		msg.Format(_L("Base class DeviceInsertedL failed"));

		}

	else

		{

		// Create the bulk transfers	

		iInTransfer[0] = new (ELeave) CBulkTransfer(iTestPipeInterface1BulkIn,iUsbInterface1,256,*this,KBulkTransferId1);	

		iInTransfer[1] = new (ELeave) CBulkTransfer(iTestPipeInterface1BulkIn,iUsbInterface1,256,*this,KBulkTransferId2);	

		iInTransfer[2] = new (ELeave) CBulkTransfer(iTestPipeInterface1BulkIn,iUsbInterface1,256,*this,KBulkTransferId3);	

		// Initialise the descriptors for transfer		

		err = iUsbInterface1.InitialiseTransferDescriptors();

		if(err != KErrNone)

			{

			_LIT(lit, "<Error %d> Unable to initialise transfer descriptors");

			msg.Format(lit,err);

			}

		}

	if(err != KErrNone)

		{

		iCaseStep = EFailed;

		TTestCaseFailed request(err,msg);

		iControlEp0->SendRequest(request,this);

		}

	else

		{

		iCaseStep = EStalled;	

		iInTransfer[0]->TransferIn(KDataPayload1().Length());

		TStallEndpointRequest r2(2,1); // Stall endpoint 2 interface 1

		iControlEp0->SendRequest(r2,this);		

		}

	}

	}