// 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 hostcontroltransfers.cpp
// @internalComponent
// 
//

#include "hosttransfers.h"
#include <e32debug.h>

namespace NUnitTesting_USBDI
	{
	
	
CBulkTransfer::CBulkTransfer(RUsbPipe& aPipe,RUsbInterface& aInterface,TInt aMaxTransferSize,MTransferObserver& aObserver,TInt aTransferId)
:	CBaseTransfer(aPipe,aInterface,aObserver,aTransferId),
	iTransferDescriptor(aMaxTransferSize) // Allocate the buffer for bulk transfers
	{

	// Register the transfer descriptor with the interface
	
	TInt err(Interface().RegisterTransferDescriptor(iTransferDescriptor));
	if(err != KErrNone)
		{
		RDebug::Printf("<Error %d> Unable to register transfer descriptor",err);
		}
	}
	
	
CBulkTransfer::~CBulkTransfer()
	{
	LOG_FUNC
	
	// Cancel the transfer

	Cancel();
	}
	
	
TPtrC8 CBulkTransfer::DataPolled()
	{
	return iTransferDescriptor.Buffer();
	}


void CBulkTransfer::TransferIn(TInt aExpectedDataSize)
	{
	LOG_FUNC
	
	// Activate the asynchronous transfer 
	
	RDebug::Printf("Activating bulk in transfer");
	iTransferDescriptor.SaveData(aExpectedDataSize);
	Pipe().Transfer(iTransferDescriptor,iStatus);
	SetActive();
	}

void CBulkTransfer::TransferOut(const TDesC8& aBulkData, TBool aUseZLPIfRequired)
	{
	LOG_FUNC

	// Copy the data across
	if(aBulkData.Length() > iTransferDescriptor.iMaxSize)
		{
		RDebug::Printf("Too much data in bulk transfer. This test suite will now PANIC!");
		RDebug::Printf("Bytes requested %d, Max allowed %d", aBulkData.Length(), iTransferDescriptor.iMaxSize);
		ASSERT(EFalse);
		}
		
	TPtr8 buffer = iTransferDescriptor.WritableBuffer();
	buffer.Copy(aBulkData);
	RDebug::Printf("Transfer buffer now has %d bytes to write",buffer.Length());
	iTransferDescriptor.SaveData(buffer.Length());
	if(aUseZLPIfRequired)
		{
		iTransferDescriptor.SetZlpStatus(RUsbTransferDescriptor::ESendZlpIfRequired); 
		}
	else
		{
		iTransferDescriptor.SetZlpStatus(RUsbTransferDescriptor::ESuppressZlp);
		}
	
	// Activate the asynchronous transfer 
	
	RDebug::Printf("Activating bulk out transfer");
	Pipe().Transfer(iTransferDescriptor,iStatus);
	SetActive();
	}

void CBulkTransfer::TransferOut(const TDesC8& aBulkDataPattern, TUint aNumBytes, TBool aUseZLPIfRequired)
	{
	LOG_FUNC
	
	TransferOut(aBulkDataPattern, 0, aNumBytes, aUseZLPIfRequired);
	}


void CBulkTransfer::TransferOut(const TDesC8& aBulkDataPattern, TUint aStartPoint, TUint aNumBytes, TBool aUseZLPIfRequired)
	{
	LOG_FUNC

	// Copy the data across
	if(aNumBytes > iTransferDescriptor.iMaxSize)
		{
		RDebug::Printf("Too much data in bulk transfer. This test suite will now PANIC!");
		RDebug::Printf("Bytes requested %d, Max allowed %d", aNumBytes, iTransferDescriptor.iMaxSize);
		ASSERT(EFalse);
		}
	if(aBulkDataPattern.Length()<=0)
		{
		RDebug::Printf("ZERO LENGTH data pattern used in TransferOut. This test suite will now PANIC!");
		ASSERT(EFalse);
		}
	TUint startPoint = aStartPoint%aBulkDataPattern.Length();
	TUint numStartBytes = (aBulkDataPattern.Length() - startPoint)%aBulkDataPattern.Length();
	TUint fullRepeats = (aNumBytes-numStartBytes)/aBulkDataPattern.Length();
	TUint numEndBytes = aNumBytes - fullRepeats*aBulkDataPattern.Length() - numStartBytes;
	TPtr8 buffer = iTransferDescriptor.WritableBuffer();
	buffer.Zero(); //set length to zero
	if(numStartBytes)
		{
		buffer.Append(aBulkDataPattern.Right(numStartBytes));
		}
	for(TUint i = 0; i<fullRepeats; i++)
		{
		buffer.Append(aBulkDataPattern);
		}
	if(numEndBytes)
		{
		buffer.Append(aBulkDataPattern.Left(numEndBytes));
		}
	RDebug::Printf("Transfer buffer now has %d bytes to write",buffer.Length());
	iTransferDescriptor.SaveData(buffer.Length());	
	if(aUseZLPIfRequired)
		{
		iTransferDescriptor.SetZlpStatus(RUsbTransferDescriptor::ESendZlpIfRequired); 
		}
	else
		{
		iTransferDescriptor.SetZlpStatus(RUsbTransferDescriptor::ESuppressZlp);
		}
	
	// Activate the asynchronous transfer 
	
	RDebug::Printf("Activating bulk out transfer");
	Pipe().Transfer(iTransferDescriptor,iStatus);
	SetActive();
	}

	}