// Copyright (c) 2007-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:
// @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()
	{
	LOG_FUNC
	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)
	{
	LOG_FUNC
	RDebug::Printf("Endpoint %d", iEndpoint);
	
	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)
	{
	LOG_FUNC
	RDebug::Printf("Endpoint %d", iEndpoint);
	
	// 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)
	{
	LOG_FUNC
	RDebug::Printf("Endpoint %d", iEndpoint);
	
	// 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)
	{
	LOG_FUNC
	iCompletionAction = EHaltEndpoint;
	ReadL(aByteCount);
	}

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

	iCompletionAction = ERepeatedRead;
	iRepeatedReadTotalNumBytes = aTotalNumBytes;
	iRepeatedReadNumBytesPerRead = aNumBytesPerRead;
	iNumBytesReadSoFar = 0;
	iDataPatternLength = aDataPattern.Length();
	iIsValid = ETrue; //until proven guilty!
	RDebug::Printf("Total Bytes To Read: %d, Bytes Per Individual Read: %d", iRepeatedReadTotalNumBytes, iRepeatedReadNumBytesPerRead);
	//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()
	{
	LOG_FUNC
	TInt err(iClientDriver.SendEp0StatusPacket());
	if(err != KErrNone)
		{
		RDebug::Printf("<Error %d> Sending acknowledge packet",err);
		}
	return err;
	}
			
			
void CEndpointReader::DoCancel()
	{
	LOG_FUNC
	
	// Cancel reading from the endpoint
	
	iClientDriver.ReadCancel(iEndpoint);
	}
	
	
void CEndpointReader::RunL()
	{
	LOG_FUNC
	RDebug::Printf("Endpoint %d", iEndpoint);
	RDebug::Printf("Completion Action %d", iCompletionAction);
	TCompletionAction completionAction = iCompletionAction;
	iCompletionAction = ENone; //reset here in case of 'early' returns
	
	// The operation completion code
	TInt completionCode(iStatus.Int());
	
	if(completionCode != KErrNone)
		{
		RDebug::Printf("<Error> void CEndpointReader::RunL()completed with ERROR %d", completionCode);
		
		// Nak the packet received
		iClientDriver.HaltEndpoint(iEndpoint);
		
		if(iHandler)
			{
			iHandler->EndpointReadError(iEndpoint,completionCode);
			}
		else
			{
			RDebug::Printf("No handler set");
			}
		}
	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)
			{
			RDebug::Printf("byte %d %02x %c",i,(*iDataBuffer)[i],(*iDataBuffer)[i]);
			}

		if(iHandler)
			{
			iHandler->DataReceivedFromEndpointL(iEndpoint,*iDataBuffer);
			}
		else
			{
			RDebug::Printf("No handler set");
			}
		
		if(completionAction==EHaltEndpoint)
			{
			RDebug::Printf("Halting Endpoint");
			iClientDriver.HaltEndpoint(iEndpoint);
			}

		if(completionAction==ERepeatedRead)
			{
			RDebug::Printf("Repeated Read");
			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();
			RDebug::Printf("Bytes read so far %d, Total bytes to read %d", iNumBytesReadSoFar, iRepeatedReadTotalNumBytes);

			if(err!=0)
				{
				RDebug::Printf("Validation Result %d, Validation String Length %d, Bytes Actually Read %d", err, valDesc.Length(), iDataPtr.Length());
				RDebug::Printf("Expected string, followed by read string");
				RDebug::RawPrint(valDesc);
				RDebug::Printf("\n");
				RDebug::RawPrint(iDataPtr);
				RDebug::Printf("\n");
				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)
	{
	LOG_FUNC
	
	RDebug::Printf("<Leaving Error> void CEndpointReader::RunError()called with ERROR %d", aError);

	// Nak the packet received
	iClientDriver.HaltEndpoint(iEndpoint);

	aError = KErrNone;	
	return aError;
	}
	
	}