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

// @internalComponent

// 

//

#include "endpointreader.h"

#include "controltransferrequests.h"

#include "testdebug.h"

namespace NUnitTesting_USBDI

	{

const TUint8 KNumPatternRepeatsNeededForValidation = 4;

CEndpointReader::CEndpointReader(RDevUsbcClient& aClientDriver,TEndpointNumber aEndpoint)

:	CActive(EPriorityStandard),

	iClientDriver(aClientDriver),

	iEndpoint(aEndpoint),

	iDataPtr(NULL,0),

	iValidationPatternPtr(NULL,0)

	{

	CActiveScheduler::Add(this);

	}

CEndpointReader::~CEndpointReader()

	{

	Cancel();

	delete iDataBuffer;

	iDataBuffer = NULL;

	delete iValidationPatternBuffer;

	iValidationPatternBuffer = NULL;

	}

TPtr8 CEndpointReader::Buffer()

	{

	return iDataPtr;

	}

TBool CEndpointReader::IsValid()

	{

	return iIsValid;

	}

TUint CEndpointReader::NumBytesReadSoFar()

	{

	return iNumBytesReadSoFar;

	}

void CEndpointReader::ReadPacketL(MEndpointDataHandler* aHandler)

	{

	iHandler = aHandler;

	// Allocate buffer for reading a data packet

	if(iDataBuffer)

		{

		delete iDataBuffer;

		iDataBuffer = NULL;

		}

	iDataBuffer = HBufC8::NewL(KFullSpeedPacketSize); 

	iDataPtr.Set(iDataBuffer->Des());

	// Read from the endpoint

	// Read from the endpoint

	iClientDriver.ReadPacket(iStatus,iEndpoint,iDataPtr,KFullSpeedPacketSize);

	SetActive();

	}

void CEndpointReader::ReadL(TInt aByteCount)

	{

	// Allocate buffer for reading a data packet

	if(iDataBuffer)

		{

		delete iDataBuffer;

		iDataBuffer = NULL;

		}

	iDataBuffer = HBufC8::NewL(aByteCount);

	iDataPtr.Set(iDataBuffer->Des());

	// Read from the endpoint

	iClientDriver.Read(iStatus,iEndpoint,iDataPtr,aByteCount);

	SetActive();

	}

void CEndpointReader::ReadUntilShortL(TInt aByteCount)

	{

	// Allocate buffer for reading a data packet

	if(iDataBuffer)

		{

		delete iDataBuffer;

		iDataBuffer = NULL;

		}

	iDataBuffer = HBufC8::NewL(aByteCount);

	iDataPtr.Set(iDataBuffer->Des());

	// Read from the endpoint

	iClientDriver.ReadUntilShort(iStatus,iEndpoint,iDataPtr,aByteCount);

	SetActive();

	}

void CEndpointReader::ReadAndHaltL(TInt aByteCount)

	{

	iCompletionAction = EHaltEndpoint;

	ReadL(aByteCount);

	}

void CEndpointReader::RepeatedReadAndValidateL(const TDesC8& aDataPattern, TUint aNumBytesPerRead, TUint aTotalNumBytes)

	{

	iCompletionAction = ERepeatedRead;

	iRepeatedReadTotalNumBytes = aTotalNumBytes;

	iRepeatedReadNumBytesPerRead = aNumBytesPerRead;

	iNumBytesReadSoFar = 0;

	iDataPatternLength = aDataPattern.Length();

	iIsValid = ETrue; //until proven guilty!

	//Create buffer to contain two lots of the payload pattern

	//..so that we may grab cyclic chunks of said payload pattern

	delete iValidationPatternBuffer;

	iValidationPatternBuffer = NULL;

	iValidationPatternBuffer = HBufC8::New(KNumPatternRepeatsNeededForValidation*aDataPattern.Length()); 

	iValidationPatternPtr.Set(iValidationPatternBuffer->Des());

	iValidationPatternPtr.Zero();

	for(TUint i=0;i<KNumPatternRepeatsNeededForValidation;i++)

		{

		iValidationPatternPtr.Append(aDataPattern);

		}

	ReadUntilShortL(iRepeatedReadNumBytesPerRead);

	}

TInt CEndpointReader::Acknowledge()

	{

	TInt err(iClientDriver.SendEp0StatusPacket());

	if(err != KErrNone)

		{

		}

	return err;

	}

void CEndpointReader::DoCancel()

	{

	// Cancel reading from the endpoint

	iClientDriver.ReadCancel(iEndpoint);

	}

void CEndpointReader::RunL()

	{

	TCompletionAction completionAction = iCompletionAction;

	iCompletionAction = ENone; //reset here in case of 'early' returns

	// The operation completion code

	TInt completionCode(iStatus.Int());

	if(completionCode != KErrNone)

		{

		// Nak the packet received

		iClientDriver.HaltEndpoint(iEndpoint);

		if(iHandler)

			{

			iHandler->EndpointReadError(iEndpoint,completionCode);

			}

		else

			{

			}

		}

	else

		{

		// Some data has arrived but 

		TInt ent = iDataBuffer->Length()/16;

		ent = ent==0?1:ent;

		for(TInt i=0; i<iDataBuffer->Length(); i+=ent)

			{

			}

		if(iHandler)

			{

			iHandler->DataReceivedFromEndpointL(iEndpoint,*iDataBuffer);

			}

		else

			{

			}

		if(completionAction==EHaltEndpoint)

			{

			iClientDriver.HaltEndpoint(iEndpoint);

			}

		if(completionAction==ERepeatedRead)

			{

			iCompletionAction = ERepeatedRead;

			//Prepare to validate

			TInt previousBytesToRead = iRepeatedReadTotalNumBytes - iNumBytesReadSoFar; //PRIOR TO THIS READ

			TUint expectedNumJustReadBytes = previousBytesToRead < iRepeatedReadNumBytesPerRead ? previousBytesToRead : iRepeatedReadNumBytesPerRead;

			TPtrC8 valDesc = iValidationPatternPtr.Mid(iNumBytesReadSoFar%iDataPatternLength, expectedNumJustReadBytes);

			TInt err = iDataPtr.Compare(valDesc);

			iNumBytesReadSoFar += iDataPtr.Length();

			if(err!=0)

				{

				iIsValid = EFalse; //record validation error

				}

			if(iNumBytesReadSoFar < iRepeatedReadTotalNumBytes)

				{

				ReadUntilShortL(iRepeatedReadNumBytesPerRead);

				}

			else

				{

				//reset

				iRepeatedReadTotalNumBytes = 0;

				iRepeatedReadNumBytesPerRead = 0;

				iNumBytesReadSoFar = 0;

				iDataPatternLength = 0;

				//do not reset iIsValid - this is required later

				}

			}

		}

	}

TInt CEndpointReader::RunError(TInt aError)

	{

	// Nak the packet received

	iClientDriver.HaltEndpoint(iEndpoint);

	aError = KErrNone;	

	return aError;

	}

	}