diff -r 000000000000 -r a41df078684a kerneltest/e32test/usbho/t_usbdi/src/hostbulktransfers.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/kerneltest/e32test/usbho/t_usbdi/src/hostbulktransfers.cpp	Mon Oct 19 15:55:17 2009 +0100
@@ -0,0 +1,161 @@
+// 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();
+	}
+
+	}