--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/kerneltest/e32test/usbho/t_usbdi/src/hostisochronoustransfers.cpp Mon Oct 19 15:55:17 2009 +0100
@@ -0,0 +1,173 @@
+// 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 hostisochronoustransfers.cpp
+// @internalComponent
+//
+//
+
+#include "hosttransfers.h"
+#include <e32debug.h>
+#include <e32test.h>
+
+extern RTest gtest;
+
+namespace NUnitTesting_USBDI
+ {
+
+CIsochTransfer::CIsochTransfer(RUsbPipe& aPipe,RUsbInterface& aInterface,TUint16 aMaxPacketSize,
+ TInt aMaxNumPackets,MTransferObserver& aObserver,TInt aTransferId)
+: CBaseTransfer(aPipe,aInterface,aObserver,aTransferId),
+ iTransferDescriptor(aMaxPacketSize,aMaxNumPackets),
+ iMaxPacketSize(aMaxPacketSize)
+ {
+ RDebug::Printf("aMaxPacketSize = %d, aMaxNumPackets = %d",aMaxPacketSize, aMaxNumPackets);
+ }
+
+CIsochTransfer::~CIsochTransfer()
+ {
+ LOG_FUNC
+
+ // Cancel the transfer
+
+ Cancel();
+ }
+
+TBool CIsochTransfer::DataPolled(TUint aPacketsToBeRead, RBuf8& aDataPolled)
+ {
+ LOG_FUNC
+ TInt numOfPacketsReturned = 0;
+
+ TInt firstPacketIndex = 0;
+ TInt totalPacketsRead = 0;
+ TInt packetsToBeRead = aPacketsToBeRead;
+
+ TUint dataPolledBufSize = iMaxPacketSize*aPacketsToBeRead;
+ aDataPolled.CreateL(dataPolledBufSize);
+
+ do {
+ TPtrC8 ptrRet = iTransferDescriptor.Packets(firstPacketIndex, packetsToBeRead, numOfPacketsReturned);
+ RDebug::Printf("numOfPacketsReturned = %d", numOfPacketsReturned);
+ RDebug::Printf("ptrRet.Length() = %d", ptrRet.Length());
+ firstPacketIndex = numOfPacketsReturned;
+ totalPacketsRead += numOfPacketsReturned;
+ packetsToBeRead = packetsToBeRead - numOfPacketsReturned;
+ RDebug::Printf("totalPacketsRead = %d", totalPacketsRead);
+ RDebug::Printf("packetsToBeRead = %d", packetsToBeRead);
+ aDataPolled.Append(ptrRet);
+ } while(totalPacketsRead != aPacketsToBeRead);
+
+ return ETrue;
+ }
+
+
+TInt CIsochTransfer::TransferInL(TInt aPacketsExpected)
+ {
+ LOG_FUNC
+
+ // Activate the asynchronous transfer
+ RDebug::Printf("Activating isoch. in transfer");
+
+ iTransferDescriptor.Reset();
+ TPacketLengths fullLengths = iTransferDescriptor.Lengths();
+
+ for(TInt packet = 0; packet < fullLengths.MaxNumPackets(); packet++)
+ {
+ fullLengths[packet] = iMaxPacketSize;
+ }
+
+ RDebug::Printf("fullLengths.MaxNumPackets() == %d",fullLengths.MaxNumPackets());
+ iTransferDescriptor.ReceivePackets(aPacketsExpected);
+
+ Pipe().Transfer(iTransferDescriptor,iStatus);
+ SetActive();
+ return KErrNone;
+ }
+
+TInt CIsochTransfer::RegisterTransferDescriptor()
+ {
+ LOG_FUNC
+
+ // 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);
+ }
+ return err;
+ }
+
+TInt CIsochTransfer::PrepareTransfer(const TDesC8& aIsochData)
+ {
+ LOG_FUNC
+
+ //
+ iTransferDescriptor.Reset();
+ TPacketLengths fullLengths = iTransferDescriptor.Lengths();
+
+ RDebug::Printf("fullLengths.MaxNumPackets() == %d",fullLengths.MaxNumPackets());
+
+ //
+ TInt bytesRemaining(aIsochData.Size());
+ TInt maxAvailablePacketSlots;
+ TInt startOffset(0);
+ TInt startPacket(0);
+
+ RDebug::Printf("Audio data is %d bytes",bytesRemaining);
+
+ // Keep saving the isoch data to transfer in each packet buffer supplied
+ // by the transfer descriptor
+
+ while(bytesRemaining)
+ {
+ // Request a modifiable buffer to write the isoch data to
+ TPtr8 packetBuffer = iTransferDescriptor.WritablePackets(bytesRemaining/iMaxPacketSize,maxAvailablePacketSlots);
+ TInt dataToWrite = Min(bytesRemaining,packetBuffer.MaxSize());
+
+ if(dataToWrite == 0)
+ {
+ RDebug::Printf("<Warning> dropping the rest of the isoch data");
+ break;
+ }
+
+ // Validate entire buffer as it is going to be filled
+
+ packetBuffer.SetMax();
+ // Calculate the number of packets to write in this buffer
+ TInt maxPacket = dataToWrite / iMaxPacketSize;
+
+ for(TInt packet = 0; packet < maxPacket; packet++)
+ {
+ fullLengths[startPacket + packet] = iMaxPacketSize;
+ }
+
+ packetBuffer.Copy(aIsochData.Mid(startOffset, maxPacket * iMaxPacketSize));
+ iTransferDescriptor.SaveMultiple(maxPacket);
+ bytesRemaining -= maxPacket * iMaxPacketSize;
+ startOffset += maxPacket * iMaxPacketSize;
+ startPacket += maxPacket;
+ }
+ return KErrNone;
+ }
+
+TInt CIsochTransfer::TransferOut()
+ {
+ // Transfer the iscohronous data
+ RDebug::Printf("Activating isochronous out transfer");
+ Pipe().Transfer(iTransferDescriptor,iStatus);
+ SetActive();
+ return KErrNone;
+ }
+
+
+ }