sl@0: // Copyright (c) 2000-2009 Nokia Corporation and/or its subsidiary(-ies).
sl@0: // All rights reserved.
sl@0: // This component and the accompanying materials are made available
sl@0: // under the terms of the License "Eclipse Public License v1.0"
sl@0: // which accompanies this distribution, and is available
sl@0: // at the URL "http://www.eclipse.org/legal/epl-v10.html".
sl@0: //
sl@0: // Initial Contributors:
sl@0: // Nokia Corporation - initial contribution.
sl@0: //
sl@0: // Contributors:
sl@0: //
sl@0: // Description:
sl@0: // e32test/usb/t_usb_device/src/activecontrol.cpp
sl@0: // USB Test Program T_USB_DEVICE, functional part.
sl@0: // Device-side part, to work against T_USB_HOST running on the host.
sl@0: // 
sl@0: //
sl@0: 
sl@0: 
sl@0: #include "general.h"									
sl@0: #include "usblib.h"											// Helpers
sl@0: #include "config.h"
sl@0: #include "activecontrol.h"
sl@0: #include "apitests.h"
sl@0: #include "activerw.h"
sl@0: 
sl@0: void StartMassStorage(RDEVCLIENT* aPort);
sl@0: void StopMassStorage(RDEVCLIENT* aPort);
sl@0: 
sl@0: enum Ep0Requests
sl@0: 	{
sl@0: 	EStop = 0x1,
sl@0: 	EVersion = 0x10,
sl@0: 	ETestParam = 0x20,
sl@0: 	ETestResult = 0x30,
sl@0: 	ETestFail = 0x40,
sl@0: 	ETestConnect = 0x50,
sl@0: 	ETestDisconnect = 0x60,
sl@0: 	ETestMassStorage = 0x70,
sl@0: 	ETestIdleCounter = 0x80,
sl@0: 	};
sl@0: 
sl@0: extern RTest test;
sl@0: extern TBool gVerbose;
sl@0: extern TBool gSkip;
sl@0: extern TBool gTempTest;
sl@0: extern TBool gStopOnFail;
sl@0: extern TBool gAltSettingOnNotify;
sl@0: extern TInt gSoakCount;
sl@0: extern CActiveRW* gRW[KMaxConcurrentTests];				// the USB read/write active object
sl@0: extern IFConfigPtr gInterfaceConfig [128] [KMaxInterfaceSettings];
sl@0: extern TInt gActiveTestCount;
sl@0: #ifdef USB_SC
sl@0: extern RChunk gChunk;
sl@0: #endif
sl@0: 
sl@0: TInt firstBulkOutEndpoint = -1;
sl@0: 
sl@0: _LIT(KTestIdleCounterChunkName, "TestIdleCounter");
sl@0: _LIT(KTestIdleCounterPanic, "IdleCounter");
sl@0: 
sl@0: enum TTestIdleCounterPanic
sl@0: 	{
sl@0: 	ETestIdleCounterWrongCommand
sl@0: 	};
sl@0: 
sl@0: enum TTestIdleCounterCommand
sl@0: 	{
sl@0: 	ETestIdleCounterDoNothing,
sl@0: 	ETestIdleCounterReset,
sl@0: 	ETestIdleCounterClose
sl@0: 	};
sl@0: 
sl@0: struct TTestIdleCounter
sl@0: 	{
sl@0: 	volatile TInt64 iCounter;
sl@0: 	volatile TTestIdleCounterCommand iCommand;
sl@0: 	};
sl@0: 
sl@0: TInt IdleCounterThread(TAny*)
sl@0: 	{
sl@0: 	TInt r;
sl@0: 	//
sl@0: 	RThread().SetPriority(EPriorityAbsoluteVeryLow);
sl@0: 	//
sl@0: 	RChunk chunk;
sl@0: 	r = chunk.CreateGlobal(KTestIdleCounterChunkName,
sl@0: 			sizeof(struct TTestIdleCounter),
sl@0: 			sizeof(struct TTestIdleCounter) + 1);
sl@0: 	if (r == KErrNone)
sl@0: 		{
sl@0: 		struct TTestIdleCounter* counter = (struct TTestIdleCounter*) chunk.Base();
sl@0: 		counter->iCounter = 0;
sl@0: 		counter->iCommand = ETestIdleCounterDoNothing;
sl@0: 		//
sl@0: 		FOREVER
sl@0: 			{
sl@0: 			TInt command = counter->iCommand;
sl@0: 			if (command == ETestIdleCounterReset)
sl@0: 				{
sl@0: 				counter->iCounter = 0;
sl@0: 				counter->iCommand = ETestIdleCounterDoNothing;
sl@0: 				}
sl@0: 			else if (command == ETestIdleCounterClose)
sl@0: 				{
sl@0: 				break;
sl@0: 				}
sl@0: 			else if (command != ETestIdleCounterDoNothing)
sl@0: 				{
sl@0: 				RThread().Panic(KTestIdleCounterPanic, ETestIdleCounterWrongCommand);
sl@0: 				}
sl@0: 			//
sl@0: 			counter->iCounter++;
sl@0: 			}
sl@0: 		//
sl@0: 		chunk.Close();
sl@0: 		}
sl@0: 	return r;
sl@0: 	}
sl@0: 
sl@0: //
sl@0: // --- class CActiveControl ---------------------------------------------------------
sl@0: //
sl@0: 
sl@0: CActiveControl::CActiveControl(CConsoleBase* aConsole, TDes * aConfigFile, TDes * aScriptFile)
sl@0: 	: CActive(EPriorityNormal),
sl@0: 	  iConsole(aConsole),
sl@0: 	  iSoftwareConnect(EFalse),
sl@0: 	  iHighSpeed(EFalse),
sl@0: 	  iConfigFileName(aConfigFile),
sl@0: 	  iScriptFileName(aScriptFile),
sl@0: 	  iEp0PacketSize(0)
sl@0: 	{}
sl@0: 
sl@0: 
sl@0: CActiveControl* CActiveControl::NewLC(CConsoleBase* aConsole, TDes * aConfigFile, TDes * aScriptFile)
sl@0: 	{
sl@0: 	CActiveControl* self = new (ELeave) CActiveControl(aConsole, aConfigFile, aScriptFile);
sl@0: 	CleanupStack::PushL(self);
sl@0: 	self->ConstructL();
sl@0: 	return self;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: CActiveControl* CActiveControl::NewL(CConsoleBase* aConsole, TDes * aConfigFile, TDes * aScriptFile)
sl@0: 	{
sl@0: 	CActiveControl* self = NewLC(aConsole, aConfigFile, aScriptFile);
sl@0: 	CleanupStack::Pop();
sl@0: 	return self;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void CActiveControl::ConstructL()
sl@0: 	{
sl@0: 	CActiveScheduler::Add(this);
sl@0: 	TInt r;
sl@0: 	
sl@0: 	User::LeaveIfError(iFs.Connect());
sl@0: 
sl@0: 	test.Start (_L("Configuration"));
sl@0: 	
sl@0: 	test_Compare(iConfigFileName->Length(),!=,0);
sl@0: 		
sl@0: 	iTimer.CreateLocal();
sl@0: 	iPending = EPendingNone;
sl@0: 	
sl@0: 	test.Next (_L("Open configuration file"));
sl@0: 	// set the session path to use the ROM if no drive specified
sl@0: 	r=iFs.SetSessionPath(_L("Z:\\test\\"));
sl@0: 	test_KErrNone(r);
sl@0: 
sl@0: 	r = iConfigFile.Open(iFs, * iConfigFileName, EFileShareReadersOnly | EFileStreamText | EFileRead);
sl@0: 	test_KErrNone(r);
sl@0: 	TUSB_VERBOSE_PRINT1("Configuration file %s Opened successfully", iConfigFileName->PtrZ());
sl@0: 
sl@0: 	test.Next (_L("Process configuration file"));
sl@0: 	test(ProcessConfigFile (iConfigFile,iConsole,&iLddPtr));
sl@0: 	
sl@0: 	iConfigFile.Close();
sl@0: 
sl@0: 	test.Next (_L("LDD in configuration file"));
sl@0: 	test_NotNull(iLddPtr);
sl@0: 		
sl@0: 	LDDConfigPtr lddPtr = iLddPtr;
sl@0: 	TInt nextPort = 0;
sl@0: 	while (lddPtr != NULL)
sl@0: 		{
sl@0: 		// Load logical driver (LDD)
sl@0: 		// (There's no physical driver (PDD) with USB: it's a kernel extension DLL which
sl@0: 		//  was already loaded at boot time.)
sl@0: 		test.Next (_L("Loading USB LDD"));
sl@0: 		TUSB_VERBOSE_PRINT1("Loading USB LDD ",lddPtr->iName.PtrZ());
sl@0: 		r = User::LoadLogicalDevice(lddPtr->iName);
sl@0: 		test(r == KErrNone || r == KErrAlreadyExists);
sl@0: 	
sl@0: 		IFConfigPtr ifPtr = lddPtr->iIFPtr;
sl@0: 		
sl@0: 		test.Next (_L("Opening Channels"));
sl@0: 		for (TInt portNumber = nextPort; portNumber < nextPort+lddPtr->iNumChannels; portNumber++)
sl@0: 			{
sl@0: 			test_Compare(lddPtr->iNumChannels,>,0);
sl@0: 
sl@0: 			// Open USB channel
sl@0: 			r = iPort[portNumber].Open(0);
sl@0: 			test_KErrNone(r);
sl@0: 			TUSB_VERBOSE_PRINT("Successfully opened USB port");
sl@0: 
sl@0: 			// Query the USB device/Setup the USB interface
sl@0: 			if (portNumber == nextPort)
sl@0: 				{
sl@0: 				// Change some descriptors to contain suitable values
sl@0: 				SetupDescriptors(lddPtr, &iPort[portNumber]);
sl@0: 				}
sl@0: 				
sl@0: 			if (portNumber == 0)
sl@0: 				{
sl@0: 				QueryUsbClientL(lddPtr, &iPort[portNumber]);
sl@0: 				}
sl@0: 
sl@0: 			test_NotNull(ifPtr);
sl@0: 
sl@0: 			IFConfigPtr defaultIfPtr = ifPtr;
sl@0: 			SetupInterface(&ifPtr,portNumber);
sl@0: 					
sl@0: 			#ifdef USB_SC
sl@0: 			RChunk *tChunk = &gChunk;
sl@0: 			test_KErrNone(iPort[portNumber].FinalizeInterface(tChunk));
sl@0: 			#endif
sl@0: 
sl@0: 			// 	allocate endpoint DMA and double buffering for all endpoints on default interface
sl@0: 			for (TUint8 i = 1; i <= defaultIfPtr->iInfoPtr->iTotalEndpointsUsed; i++)
sl@0: 				{
sl@0: 				defaultIfPtr->iEpDMA[i-1] ? AllocateEndpointDMA(&iPort[portNumber],(TENDPOINTNUMBER)i) : DeAllocateEndpointDMA(&iPort[portNumber],(TENDPOINTNUMBER)i);
sl@0: 				#ifndef USB_SC
sl@0: 				defaultIfPtr->iEpDoubleBuff[i-1] ? AllocateDoubleBuffering(&iPort[portNumber],(TENDPOINTNUMBER)i) : DeAllocateDoubleBuffering(&iPort[portNumber],(TENDPOINTNUMBER)i);
sl@0: 				#endif
sl@0: 				}				
sl@0: 
sl@0: 			}
sl@0: 	
sl@0: 		iTotalChannels += lddPtr->iNumChannels;
sl@0: 		nextPort += lddPtr->iNumChannels;	
sl@0: 		lddPtr = lddPtr->iPtrNext;	
sl@0: 		}
sl@0: 		
sl@0: 	TUSB_VERBOSE_PRINT("All Interfaces and Alternate Settings successfully set up");
sl@0: 	
sl@0: 	test.Next (_L("Start Idle Counter Thread"));
sl@0: 	r = iIdleCounterThread.Create(_L("IdleCounter"), IdleCounterThread, KDefaultStackSize, KMinHeapSize, KMinHeapSize, NULL);
sl@0: 	test_KErrNone(r);
sl@0: 	iIdleCounterThread.Resume();
sl@0: 	// Allow some time for low-priority counter process
sl@0: 	User::After(100000); // 0.1 second
sl@0: 	r = iIdleCounterChunk.OpenGlobal(KTestIdleCounterChunkName, EFalse);
sl@0: 	test_KErrNone(r);
sl@0: 	iIdleCounter = (struct TTestIdleCounter*) iIdleCounterChunk.Base();
sl@0: 	test_NotNull(iIdleCounter);
sl@0: 	// Allow some time for low-priority counter process
sl@0: 	User::After(100000); // 0.1 second
sl@0: 	TInt64 val1 = iIdleCounter->iCounter;
sl@0: 	User::After(1000000); // 1 second
sl@0: 	TInt64 val2 = iIdleCounter->iCounter;
sl@0: 	TUSB_PRINT1("Idle Counter when test inactive: %Ldinc/ms", (val2 - val1) / 1000);
sl@0: 
sl@0: 	test.Next (_L("Enumeration..."));
sl@0: 	r = ReEnumerate();
sl@0: 	test_KErrNone(r);
sl@0: 		
sl@0: 	TUSB_VERBOSE_PRINT("Device successfully re-enumerated\n");
sl@0: 
sl@0: 
sl@0: 	if (iLddPtr->iHighSpeed && !gSkip)
sl@0: 		{
sl@0: 		test.Next (_L("High Speed"));
sl@0: 		test(iHighSpeed);	
sl@0: 		}
sl@0: 			
sl@0: 	test.Next (_L("Create Notifiers"));
sl@0: 	for (TInt portNumber = 0; portNumber < iTotalChannels; portNumber++)
sl@0: 		{
sl@0: 
sl@0: 		// Create device state active object
sl@0: 		iDeviceStateNotifier[portNumber] = CActiveDeviceStateNotifier::NewL(iConsole, &iPort[portNumber], portNumber);
sl@0: 		test_NotNull(iDeviceStateNotifier[portNumber]);
sl@0: 		iDeviceStateNotifier[portNumber]->Activate();
sl@0: 		TUSB_VERBOSE_PRINT("Created device state notifier");
sl@0: 
sl@0: 		// Create endpoint stall status active object
sl@0: 		iStallNotifier[portNumber] = CActiveStallNotifier::NewL(iConsole, &iPort[portNumber]);
sl@0: 		test_NotNull(iStallNotifier[portNumber]);
sl@0: 		iStallNotifier[portNumber]->Activate();
sl@0: 		TUSB_VERBOSE_PRINT("Created stall notifier");
sl@0: 			
sl@0: 		TestInvalidSetInterface (&iPort[portNumber],iNumInterfaceSettings[portNumber]);			
sl@0: 		TestInvalidReleaseInterface (&iPort[portNumber],iNumInterfaceSettings[portNumber]);
sl@0: 			
sl@0: 		}
sl@0: 		
sl@0: 	test.Next (_L("Endpoint Zero Max Packet Sizes"));
sl@0: 	TUint ep0Size = iPort[0].EndpointZeroMaxPacketSizes();
sl@0: 	switch (ep0Size)
sl@0: 		{
sl@0: 		case KUsbEpSize8 :
sl@0: 			iEp0PacketSize = 8;
sl@0: 			break;
sl@0: 					
sl@0: 		case KUsbEpSize16 :
sl@0: 			iEp0PacketSize = 16;
sl@0: 			break;
sl@0: 
sl@0: 		case KUsbEpSize32 :
sl@0: 			iEp0PacketSize = 32;
sl@0: 			break;
sl@0: 
sl@0: 		case KUsbEpSize64 :
sl@0: 			iEp0PacketSize = 64;
sl@0: 			break;
sl@0: 					
sl@0: 		default:
sl@0: 			iEp0PacketSize = 0;
sl@0: 			break;		
sl@0: 		}
sl@0: 	test_Compare(iEp0PacketSize,>,0);
sl@0: 
sl@0: 	test.Next (_L("Set Device Control"));
sl@0: 	r = iPort[0].SetDeviceControl();
sl@0: 	test_KErrNone(r);
sl@0: 
sl@0: 	#ifdef USB_SC
sl@0: 	r = iPort[0].OpenEndpoint(iEp0Buf,0);
sl@0: 	test_KErrNone(r);
sl@0: 	#endif
sl@0: 	
sl@0: 	test.End();
sl@0: 	
sl@0: 	}
sl@0: 
sl@0: void CActiveControl::ReConnect()
sl@0: 	{
sl@0: 	TInt r;
sl@0: 
sl@0: 	test.Start (_L("Reconnecting USB"));
sl@0: 	LDDConfigPtr lddPtr = iLddPtr;
sl@0: 	TInt nextPort = 0;
sl@0: 	while (lddPtr != NULL)
sl@0: 		{
sl@0: 		IFConfigPtr ifPtr = lddPtr->iIFPtr;
sl@0: 		
sl@0: 		test.Next (_L("Opening Channels"));
sl@0: 		for (TInt portNumber = nextPort; portNumber < nextPort+lddPtr->iNumChannels; portNumber++)
sl@0: 			{
sl@0: 			// Open USB channel
sl@0: 			r = iPort[portNumber].Open(0);
sl@0: 			test_KErrNone(r);
sl@0: 			TUSB_VERBOSE_PRINT("Successfully opened USB port");
sl@0: 
sl@0: 			// Query the USB device/Setup the USB interface
sl@0: 			if (portNumber == nextPort)
sl@0: 				{
sl@0: 				// Change some descriptors to contain suitable values
sl@0: 				SetupDescriptors(lddPtr, &iPort[portNumber]);
sl@0: 				}
sl@0: 				
sl@0: 			IFConfigPtr defaultIfPtr = ifPtr;
sl@0: 			SetupInterface(&ifPtr,portNumber);
sl@0: 					
sl@0: 			#ifdef USB_SC
sl@0: 			RChunk *tChunk = &gChunk;
sl@0: 			test_KErrNone(iPort[portNumber].FinalizeInterface(tChunk));
sl@0: 			#endif
sl@0: 
sl@0: 			// 	allocate endpoint DMA and double buffering for all endpoints on default interface
sl@0: 			for (TUint8 i = 1; i <= defaultIfPtr->iInfoPtr->iTotalEndpointsUsed; i++)
sl@0: 				{
sl@0: 				defaultIfPtr->iEpDMA[i-1] ? AllocateEndpointDMA(&iPort[portNumber],(TENDPOINTNUMBER)i) : DeAllocateEndpointDMA(&iPort[portNumber],(TENDPOINTNUMBER)i);
sl@0: 				#ifndef USB_SC
sl@0: 				defaultIfPtr->iEpDoubleBuff[i-1] ? AllocateDoubleBuffering(&iPort[portNumber],(TENDPOINTNUMBER)i) : DeAllocateDoubleBuffering(&iPort[portNumber],(TENDPOINTNUMBER)i);
sl@0: 				#endif
sl@0: 				}				
sl@0: 			}
sl@0: 	
sl@0: 		nextPort += lddPtr->iNumChannels;	
sl@0: 		lddPtr = lddPtr->iPtrNext;	
sl@0: 		}
sl@0: 		
sl@0: 	TUSB_VERBOSE_PRINT("All Interfaces and Alternate Settings successfully set up");
sl@0: 
sl@0: 	test.Next (_L("Enumeration..."));
sl@0: 	r = ReEnumerate();
sl@0: 	test_KErrNone(r);
sl@0: 		
sl@0: 	TUSB_VERBOSE_PRINT("Device successfully re-enumerated\n");
sl@0: 	
sl@0: 	for (TInt portNumber = 0; portNumber < iTotalChannels; portNumber++)
sl@0: 		{
sl@0: 		// Create device state active object
sl@0: 		iDeviceStateNotifier[portNumber] = CActiveDeviceStateNotifier::NewL(iConsole, &iPort[portNumber], portNumber);
sl@0: 		test_NotNull(iDeviceStateNotifier[portNumber]);
sl@0: 		iDeviceStateNotifier[portNumber]->Activate();
sl@0: 		TUSB_VERBOSE_PRINT("Created device state notifier");
sl@0: 
sl@0: 		// Create endpoint stall status active object
sl@0: 		iStallNotifier[portNumber] = CActiveStallNotifier::NewL(iConsole, &iPort[portNumber]);
sl@0: 		test_NotNull(iStallNotifier[portNumber]);
sl@0: 		iStallNotifier[portNumber]->Activate();
sl@0: 		TUSB_VERBOSE_PRINT("Created stall notifier");
sl@0: 
sl@0: 		if (portNumber == 0)
sl@0: 			{
sl@0: 			test.Next (_L("Set Device Control"));
sl@0: 			r = iPort[portNumber].SetDeviceControl();
sl@0: 			test_KErrNone(r);
sl@0: 
sl@0: 			#ifdef USB_SC
sl@0: 			r = iPort[portNumber].OpenEndpoint(iEp0Buf,0);
sl@0: 			test_KErrNone(r);
sl@0: 			#endif
sl@0: 			
sl@0: 			}
sl@0: 		}
sl@0: 	
sl@0: 	test.End();
sl@0: 	}
sl@0: 	
sl@0: void CActiveControl::SetupInterface(IFConfigPtr* aIfPtr, TInt aPortNumber)
sl@0: 	{
sl@0: 	test.Start (_L("Setup Interface"));
sl@0: 	
sl@0: 	// first of all set the default interface	
sl@0: 	TUSB_PRINT2 ("Set Default Interface with %d endpoints bandwidth 0x%x",(*aIfPtr)->iInfoPtr->iTotalEndpointsUsed,(*aIfPtr)->iBandwidthIn | (*aIfPtr)->iBandwidthOut);
sl@0: 	#ifdef USB_SC
sl@0: 	TUsbcScInterfaceInfoBuf ifc = *((*aIfPtr)->iInfoPtr);
sl@0: 	TInt r = iPort[aPortNumber].SetInterface(0, ifc);
sl@0: 	#else
sl@0: 	TUsbcInterfaceInfoBuf ifc = *((*aIfPtr)->iInfoPtr);
sl@0: 	TInt r = iPort[aPortNumber].SetInterface(0, ifc, (*aIfPtr)->iBandwidthIn | (*aIfPtr)->iBandwidthOut);
sl@0: 	#endif
sl@0: 	test_KErrNone(r);
sl@0: 
sl@0: 	TBuf8<KUsbDescSize_Interface> ifDescriptor;
sl@0: 	r = iPort[aPortNumber].GetInterfaceDescriptor(0, ifDescriptor);
sl@0: 	test_KErrNone(r);
sl@0: 
sl@0: 	// Check the interface descriptor
sl@0: 	test(ifDescriptor[KIfcDesc_SettingOffset] == 0 && ifDescriptor[KIfcDesc_NumEndpointsOffset] == (*aIfPtr)->iInfoPtr->iTotalEndpointsUsed &&
sl@0: 	    ifDescriptor[KIfcDesc_ClassOffset] == (*aIfPtr)->iInfoPtr->iClass.iClassNum &&
sl@0: 	    ifDescriptor[KIfcDesc_SubClassOffset] == (*aIfPtr)->iInfoPtr->iClass.iSubClassNum &&
sl@0: 	    ifDescriptor[KIfcDesc_ProtocolOffset] == (*aIfPtr)->iInfoPtr->iClass.iProtocolNum);
sl@0: 
sl@0: 	if ((*aIfPtr)->iNumber != 0 && ifDescriptor[KIfcDesc_NumberOffset] != (*aIfPtr)->iNumber)
sl@0: 		{
sl@0: 		ifDescriptor[KIfcDesc_NumberOffset] = (*aIfPtr)->iNumber;
sl@0: 		r = iPort[aPortNumber].SetInterfaceDescriptor(0, ifDescriptor);	
sl@0: 		test_KErrNone(r);
sl@0: 		}
sl@0: 	else
sl@0: 		{
sl@0: 		(*aIfPtr)->iNumber = ifDescriptor[KIfcDesc_NumberOffset];	
sl@0: 		}
sl@0: 	TUint8 interfaceNumber = (*aIfPtr)->iNumber;
sl@0: 	TUSB_PRINT1 ("Interface Number %d",interfaceNumber);
sl@0: 		
sl@0: 	// Check all endpoint descriptors
sl@0: 	TBuf8<KUsbDescSize_AudioEndpoint> epDescriptor;
sl@0: 	for (TUint i = 0; i < (*aIfPtr)->iInfoPtr->iTotalEndpointsUsed; i++)
sl@0: 		{
sl@0: 		if (!gSkip)
sl@0: 			{
sl@0: 			TestEndpointDescriptor (&iPort[aPortNumber],0,i+1,(*aIfPtr)->iInfoPtr->iEndpointData[i]);	
sl@0: 
sl@0: 			}
sl@0: 
sl@0: 		if (firstBulkOutEndpoint < 0 && ((*aIfPtr)->iInfoPtr->iEndpointData[i].iDir & KUsbEpDirOut) &&
sl@0: 			(*aIfPtr)->iInfoPtr->iEndpointData[i].iType == KUsbEpTypeBulk)
sl@0: 			{
sl@0: 			firstBulkOutEndpoint = i+1;	
sl@0: 			}
sl@0: 		}
sl@0: 
sl@0: 	TUSB_PRINT1 ("Interface number is %d",interfaceNumber);
sl@0: 	(*aIfPtr)->iPortNumber = aPortNumber;
sl@0: 	gInterfaceConfig [interfaceNumber] [0] = *aIfPtr;
sl@0: 
sl@0: 	TInt alternateNumber = 1;
sl@0: 	// check for any alternatate interfaces and set any that are found
sl@0: 	* aIfPtr = (*aIfPtr)->iPtrNext;
sl@0: 	if (* aIfPtr != NULL)
sl@0: 		{
sl@0: 		test(SupportsAlternateInterfaces());
sl@0: 
sl@0: 		IFConfigPtr ifPtr = *aIfPtr;
sl@0: 		while (ifPtr != NULL)
sl@0: 			{
sl@0: 			if (ifPtr->iAlternateSetting)
sl@0: 				{
sl@0: 				ifc = *(ifPtr->iInfoPtr);
sl@0: 				#ifdef USB_SC
sl@0: 				TUSB_PRINT2 ("Set Alternate Interface Setting %d with %d endpoints",alternateNumber,ifPtr->iInfoPtr->iTotalEndpointsUsed);
sl@0: 				r = iPort[aPortNumber].SetInterface(alternateNumber, ifc);
sl@0: 				#else
sl@0: 				TUSB_PRINT3 ("Set Alternate Interface Setting %d with %d endpoints bandwidth 0x%x",alternateNumber,ifPtr->iInfoPtr->iTotalEndpointsUsed,ifPtr->iBandwidthIn | iLddPtr->iIFPtr->iBandwidthOut);
sl@0: 				r = iPort[aPortNumber].SetInterface(alternateNumber, ifc, ifPtr->iBandwidthIn | iLddPtr->iIFPtr->iBandwidthOut);
sl@0: 				#endif
sl@0: 				test_KErrNone(r);
sl@0: 					
sl@0: 				r = iPort[aPortNumber].GetInterfaceDescriptor(alternateNumber, ifDescriptor);
sl@0: 				test_KErrNone(r);
sl@0: 
sl@0: 				// Check the interface descriptor
sl@0: 				test(ifDescriptor[KIfcDesc_SettingOffset] == alternateNumber && ifDescriptor[KIfcDesc_NumEndpointsOffset] == (*aIfPtr)->iInfoPtr->iTotalEndpointsUsed &&
sl@0: 				    ifDescriptor[KIfcDesc_ClassOffset] == (*aIfPtr)->iInfoPtr->iClass.iClassNum &&
sl@0: 				    ifDescriptor[KIfcDesc_SubClassOffset] == (*aIfPtr)->iInfoPtr->iClass.iSubClassNum &&
sl@0: 				    ifDescriptor[KIfcDesc_ProtocolOffset] == (*aIfPtr)->iInfoPtr->iClass.iProtocolNum);
sl@0: 
sl@0: 				// Check all endpoint descriptors
sl@0: 				for (TUint i = 0; i < ifPtr->iInfoPtr->iTotalEndpointsUsed; i++)
sl@0: 					{
sl@0: 					TInt desc_size;
sl@0: 					r = iPort[aPortNumber].GetEndpointDescriptorSize(alternateNumber, i+1, desc_size);
sl@0: 					test_KErrNone(r);
sl@0: 					test_Equal(KUsbDescSize_Endpoint + (*aIfPtr)->iInfoPtr->iEndpointData[i].iExtra,static_cast<TUint>(desc_size));
sl@0: 
sl@0: 					r = iPort[aPortNumber].GetEndpointDescriptor(alternateNumber, i+1, epDescriptor);
sl@0: 					test_KErrNone(r);
sl@0: 					
sl@0: 					test((((*aIfPtr)->iInfoPtr->iEndpointData[i].iDir & KUsbEpDirIn) && (epDescriptor[KEpDesc_AddressOffset] & 0x80) ||
sl@0: 						!((*aIfPtr)->iInfoPtr->iEndpointData[i].iDir & KUsbEpDirIn) && !(epDescriptor[KEpDesc_AddressOffset] & 0x80)) &&
sl@0: 						EpTypeMask2Value((*aIfPtr)->iInfoPtr->iEndpointData[i].iType) == (TUint)(epDescriptor[KEpDesc_AttributesOffset] & 0x03) &&
sl@0: 						(*aIfPtr)->iInfoPtr->iEndpointData[i].iInterval == epDescriptor[KEpDesc_IntervalOffset]);
sl@0: 
sl@0: 
sl@0: 					if (!gSkip && (*aIfPtr)->iInfoPtr->iEndpointData[i].iExtra)
sl@0: 						{
sl@0: 						test.Next(_L("Extended Endpoint Descriptor Manipulation"));
sl@0: 						TUint8 addr = 0x85;										// bogus address
sl@0: 						if (epDescriptor[KEpDesc_SynchAddressOffset] == addr)
sl@0: 							addr++;
sl@0: 						epDescriptor[KEpDesc_SynchAddressOffset] = addr;
sl@0: 						r = iPort[aPortNumber].SetEndpointDescriptor(alternateNumber, i+1, epDescriptor);
sl@0: 						test_KErrNone(r);
sl@0: 
sl@0: 						TBuf8<KUsbDescSize_AudioEndpoint> descriptor2;
sl@0: 						r = iPort[aPortNumber].GetEndpointDescriptor(alternateNumber, i+1, descriptor2);
sl@0: 						test_KErrNone(r);
sl@0: 
sl@0: 						test.Next(_L("Compare endpoint descriptor with value set"));
sl@0: 						r = descriptor2.Compare(epDescriptor);
sl@0: 						test_KErrNone(r);						
sl@0: 						}
sl@0: 					}
sl@0: 				
sl@0: 					
sl@0: 				// if no error move on to the next interface
sl@0: 				ifPtr->iPortNumber = aPortNumber;
sl@0: 				ifPtr->iNumber = interfaceNumber;
sl@0: 				gInterfaceConfig [interfaceNumber] [alternateNumber] = ifPtr;
sl@0: 
sl@0: 				alternateNumber++;
sl@0: 				ifPtr = ifPtr->iPtrNext;
sl@0: 				* aIfPtr = ifPtr;
sl@0: 				}
sl@0: 			else
sl@0: 				{
sl@0: 				ifPtr = NULL;
sl@0: 				}
sl@0: 			}
sl@0: 		}
sl@0: 	iNumInterfaceSettings[aPortNumber] = alternateNumber;
sl@0: 	if (!gSkip)
sl@0: 		{
sl@0: 		TestInvalidSetInterface (&iPort[aPortNumber],iNumInterfaceSettings[aPortNumber]);			
sl@0: 		TestInvalidReleaseInterface (&iPort[aPortNumber],iNumInterfaceSettings[aPortNumber]);
sl@0: 
sl@0: 		TestDescriptorManipulation(iLddPtr->iHighSpeed,&iPort[aPortNumber],alternateNumber);
sl@0: 		TestOtgExtensions(&iPort[aPortNumber]);
sl@0: 		TestEndpoint0MaxPacketSizes(&iPort[aPortNumber]);
sl@0: 		}
sl@0: 		
sl@0: 	test.End();
sl@0: 	}
sl@0: 
sl@0: 
sl@0: CActiveControl::~CActiveControl()
sl@0: 	{
sl@0: 	TUSB_PRINT("CActiveControl::~CActiveControl()");
sl@0: 
sl@0: 	Cancel();
sl@0: 	
sl@0: 	iTimer.Close();
sl@0: 	
sl@0: 	// delete interfaces		
sl@0: 	while (iLddPtr->iIFPtr)
sl@0: 		{
sl@0: 		IFConfigPtr* ifPtrPtr = & iLddPtr->iIFPtr;
sl@0: 		while ((*ifPtrPtr)->iPtrNext)
sl@0: 			{
sl@0: 			ifPtrPtr = &(*ifPtrPtr)->iPtrNext;
sl@0: 			}
sl@0: 		delete (*ifPtrPtr)->iInfoPtr->iString;
sl@0: 		delete (*ifPtrPtr)->iInfoPtr;
sl@0: 		delete (*ifPtrPtr);
sl@0: 		* ifPtrPtr = NULL;
sl@0: 		}
sl@0: 
sl@0: 	while (iLddPtr)
sl@0: 		{
sl@0: 		LDDConfigPtr* lddPtrPtr = &iLddPtr;	
sl@0: 		while ((*lddPtrPtr)->iPtrNext)
sl@0: 			{
sl@0: 			lddPtrPtr = &(*lddPtrPtr)->iPtrNext;
sl@0: 			}
sl@0: 		delete (*lddPtrPtr)->iManufacturer;
sl@0: 		delete (*lddPtrPtr)->iProduct;
sl@0: 		delete (*lddPtrPtr)->iSerialNumber;
sl@0: 		delete (*lddPtrPtr);
sl@0: 		* lddPtrPtr = NULL;
sl@0: 		}
sl@0: 
sl@0: 	iFs.Close();
sl@0: 	}
sl@0: 
sl@0: void CActiveControl::DoCancel()
sl@0: 	{
sl@0: 	TUSB_VERBOSE_PRINT("CActiveControl::DoCancel()");
sl@0: 	iConsole->ReadCancel();
sl@0: 	}
sl@0: 
sl@0: void CActiveControl::SetMSFinished(TBool aState)
sl@0: 	{
sl@0: 	if (aState)
sl@0: 		{
sl@0: 		if (iPending != EPendingEject)
sl@0: 			{
sl@0: 			iPending = EPendingEject;
sl@0: 			iTimer.After(iStatus,KMSFinishedDelay);
sl@0: 			if (!IsActive())
sl@0: 				{
sl@0: 				SetActive();
sl@0: 				}		
sl@0: 			}
sl@0: 		}
sl@0: 	else
sl@0: 		{
sl@0: 		if (iPending == EPendingEject)
sl@0: 			{
sl@0: 			iPending = EPendingCancel;
sl@0: 			iTimer.Cancel();
sl@0: 			}
sl@0: 		}
sl@0: 	}
sl@0: 	
sl@0: void CActiveControl::RequestEp0ControlPacket()
sl@0: 	{
sl@0: 	TUSB_VERBOSE_PRINT("CActiveControl::RequestEp0ControlPacket()");
sl@0: 	// A request is issued to read a packet for endpoint 0
sl@0: 	__ASSERT_ALWAYS(!IsActive(), User::Panic(KActivePanic, 660));
sl@0: 	#ifdef	USB_SC
sl@0: 	TInt r = 0;
sl@0: 	do
sl@0: 		{
sl@0: 		r = iEp0Buf.GetBuffer (iEp0Packet,iEp0Size,iEp0Zlp,iStatus);
sl@0: 		TUSB_VERBOSE_PRINT4("Get Buffer Return code %d Status %d PacketPtr 0x%x Size %d", r, iStatus.Int(),iEp0Packet,iEp0Size);	
sl@0: 		test_Value(r, (r == KErrNone) || (r == KErrCompletion) || (r == TEndpointBuffer::KStateChange) || (r == KErrAlternateSettingChanged));  
sl@0: 		if (r == KErrCompletion)
sl@0: 			{
sl@0: 			// ignore anything except a setup packet
sl@0: 			if ((TInt)iEp0Size == KSetupPacketSize)
sl@0: 				{
sl@0: 				iEp0SetUpPacket.Copy((TUint8 *)iEp0Packet,iEp0Size);
sl@0: 				r = ProcessEp0ControlPacket();
sl@0: 				}
sl@0: 			}
sl@0: 		else
sl@0: 			{
sl@0: 			if (r == KErrNone)
sl@0: 				{
sl@0: 				iPending = EPendingEp0Read;
sl@0: 				SetActive();
sl@0: 				}
sl@0: 			}
sl@0: 		}
sl@0: 	while ((r == KErrCompletion) || (r == TEndpointBuffer::KStateChange) || (r == KErrAlternateSettingChanged));
sl@0: 	#else
sl@0: 	iPort[0].ReadPacket(iStatus,EEndpoint0, iEp0SetUpPacket,KSetupPacketSize);
sl@0: 	iPending = EPendingEp0Read;
sl@0: 	SetActive();
sl@0: 	#endif
sl@0: 	}
sl@0: 
sl@0: void CActiveControl::RunL()
sl@0: 	{
sl@0: 	TInt r = KErrNone;
sl@0: 	
sl@0: 	TUSB_VERBOSE_PRINT("CActiveControl::RunL()");
sl@0: 	
sl@0: 	switch (iPending)
sl@0: 		{
sl@0: 		case EPendingNone :
sl@0: 			break;
sl@0: 			
sl@0: 		case EPendingEp0Read :
sl@0: 			iPending = EPendingNone;
sl@0: 			if (iStatus != KErrNone)
sl@0: 				{
sl@0: 				TUSB_PRINT1("ActiveControl::Error %d in Ep0 Read Packet", iStatus.Int());
sl@0: 				test(EFalse);
sl@0: 				}
sl@0: 			#ifdef USB_SC
sl@0: 			// for shared chunks this means that data is available in the buffer
sl@0: 			// but the data has yet to be transferred to a local buffer
sl@0: 			RequestEp0ControlPacket();
sl@0: 			#else
sl@0: 			if (ProcessEp0ControlPacket() == KErrCompletion)
sl@0: 				RequestEp0ControlPacket();
sl@0: 			#endif		
sl@0: 			break;		
sl@0: 
sl@0: 		case EPendingTimer :
sl@0: 			iPending = EPendingNone;
sl@0: 			if (iStatus != KErrNone)
sl@0: 				{
sl@0: 				TUSB_PRINT1("ActiveControl::Error %d in Connection Timer Delay", iStatus.Int());
sl@0: 				test(EFalse);
sl@0: 				}
sl@0: 			r = iPort[0].DeviceConnectToHost();
sl@0: 			test_KErrNone (r);
sl@0: 		
sl@0: 			test.End();
sl@0: 		
sl@0: 			RequestEp0ControlPacket();
sl@0: 			break;
sl@0: 			
sl@0: 		case EPendingEject :
sl@0: 			iPending = EPendingNone;
sl@0: 			if (iStatus != KErrNone)
sl@0: 				{
sl@0: 				TUSB_PRINT1("ActiveControl::Error %d in Eject Timer Delay", iStatus.Int());
sl@0: 				test(EFalse);
sl@0: 				}
sl@0: 			StopMassStorage(&iPort[0]);
sl@0: 			#ifdef USB_SC
sl@0: 				iEp0Buf.Close();
sl@0: 			#endif
sl@0: 			ReConnect();
sl@0: 							
sl@0: 			RequestEp0ControlPacket();
sl@0: 			break;
sl@0: 					
sl@0: 		case EPendingCancel :
sl@0: 			iPending = EPendingNone;
sl@0: 			if (iStatus != KErrNone && iStatus != KErrCancel)
sl@0: 				{
sl@0: 				TUSB_PRINT1("ActiveControl::Error %d in Eject Timer Delay", iStatus.Int());
sl@0: 				test(EFalse);
sl@0: 				}
sl@0: 		}
sl@0: 	
sl@0: 	}
sl@0: 
sl@0: TInt CActiveControl::ProcessEp0ControlPacket()
sl@0: 	{
sl@0: 	TUint16 value = *reinterpret_cast<TUint16*>(&iEp0SetUpPacket[KUsb_Ep0wValueOffset]);
sl@0: 	TUint16 index = *reinterpret_cast<TUint16*>(&iEp0SetUpPacket[KUsb_Ep0wIndexOffset]);
sl@0: 	TUint16 length= *reinterpret_cast<TUint16*>(&iEp0SetUpPacket[KUsb_Ep0wLengthOffset]);
sl@0: 	TUSB_VERBOSE_PRINT3("ProcessEp0ControlPacket length 0x%x value 0x%x index 0x%x",length,value,index);
sl@0: 	TRequestStatus ep0Status;
sl@0: 	TUint8 host_ver_major;
sl@0: 	TUint8 host_ver_minor;
sl@0: 	TUint8 host_ver_micro;
sl@0: 	TUint8 usbio_ver_major;
sl@0: 	TUint8 usbio_ver_minor;
sl@0: 	#ifndef USB_SC
sl@0: 	TBuf8<KMaxControlPacketSize> ep0DataPacket;
sl@0: 	#endif
sl@0: 	TestParamPtr tpPtr;
sl@0: 	TBool firstSettingThread = (index & KFirstSettingThreadMask) ? ETrue : EFalse;
sl@0: 	TBool lastSettingThread = (index & KLastSettingThreadMask) ? ETrue : EFalse;
sl@0: 	index &= ~(KFirstSettingThreadMask | KLastSettingThreadMask);
sl@0:     CActiveRW* pActiveRW;
sl@0: 	TInt r;
sl@0: 	TBool sendStatus;
sl@0: 
sl@0: 	if (((iEp0SetUpPacket[KUsb_Ep0RequestTypeOffset] & KUsbRequestType_DestMask) == KUsbRequestType_DestDevice) &&
sl@0: 		((iEp0SetUpPacket[KUsb_Ep0RequestTypeOffset] & KUsbRequestType_TypeMask) == KUsbRequestType_TypeClass))
sl@0: 		{
sl@0: 		TUSB_VERBOSE_PRINT("Received Device Directed setup packet");
sl@0: 		if ((iEp0SetUpPacket[KUsb_Ep0RequestTypeOffset] & KUsbRequestType_DirMask) == KUsbRequestType_DirToDev)
sl@0: 			{
sl@0: 			iEp0DataBuffer.SetLength(0);
sl@0: 			while (iEp0DataBuffer.Length() < length)
sl@0: 				{
sl@0: 				TUSB_VERBOSE_PRINT("Reading Ep0 data packet");
sl@0: 				#ifdef USB_SC
sl@0: 				r = iEp0Buf.GetBuffer (iEp0Packet,iEp0Size,iEp0Zlp,ep0Status);
sl@0: 				test_Value(r, r == KErrNone || r == KErrCompletion || (r == KErrAlternateSettingChanged));
sl@0: 				while (r == KErrNone)  
sl@0: 					{
sl@0: 					TUSB_VERBOSE_PRINT("Waiting for Ep0 data packet");
sl@0: 					User::WaitForRequest(ep0Status);
sl@0: 					test_KErrNone(ep0Status.Int());
sl@0: 					r = iEp0Buf.GetBuffer (iEp0Packet,iEp0Size,iEp0Zlp,ep0Status);
sl@0: 					test_Value(r, r == KErrNone || r == KErrCompletion || (r == KErrAlternateSettingChanged));
sl@0: 					}
sl@0: 				TUSB_VERBOSE_PRINT1("Ep0 data packet - size %d",iEp0Size);
sl@0: 				iEp0DataBuffer.Append((TUint8 *)iEp0Packet,iEp0Size);								
sl@0: 				#else
sl@0: 				TUint16 packetLength = Min(length-iEp0DataBuffer.Length(),iEp0PacketSize);
sl@0: 				iPort[0].ReadPacket(ep0Status, EEndpoint0, ep0DataPacket, packetLength);
sl@0: 				User::WaitForRequest(ep0Status);
sl@0: 				if (ep0Status == KErrNone)
sl@0: 					{
sl@0: 					iEp0DataBuffer.Append(ep0DataPacket);				
sl@0: 					}
sl@0: 				else
sl@0: 					{
sl@0: 					TUSB_PRINT1("ActiveControl::Error %d in Ep0 Read Data Packet", ep0Status.Int());
sl@0: 					test(EFalse);
sl@0: 					return KErrNone;						
sl@0: 					}
sl@0: 				#endif
sl@0: 				}
sl@0: 			TUSB_VERBOSE_PRINT4("Setup ToDevice Type %d length %d value %d index %d",iEp0SetUpPacket[KUsb_Ep0RequestOffset],length,value,index);
sl@0: 			sendStatus = ETrue;
sl@0: 			switch (iEp0SetUpPacket[KUsb_Ep0RequestOffset])	
sl@0: 				{
sl@0: 				case EStop :
sl@0: 					// send this now as the port will be disconnected
sl@0: 					sendStatus = EFalse;
sl@0: 					r = iPort[0].SendEp0StatusPacket();					
sl@0: 					test_KErrNone(r);
sl@0: 		
sl@0: 					if (value && firstBulkOutEndpoint > 0)
sl@0: 						{
sl@0: 						PrintHostLog();
sl@0: 						}
sl@0: 						
sl@0: 					for (TInt portNumber = 0; portNumber < iTotalChannels; portNumber++)
sl@0: 						{
sl@0: 						// base class cancel -> calls our DoCancel
sl@0: 						delete iDeviceStateNotifier[portNumber];
sl@0: 						delete iStallNotifier[portNumber];
sl@0: 						if (portNumber == 0)
sl@0: 							{
sl@0: 							r = iPort[portNumber].RemoveStringDescriptor(stridx1);
sl@0: 							if (r != KErrNone)
sl@0: 								{
sl@0: 								TUSB_PRINT1("Error %d on string removal", r);
sl@0: 								}
sl@0: 							r = iPort[portNumber].RemoveStringDescriptor(stridx2);
sl@0: 							if (r != KErrNone)
sl@0: 								{
sl@0: 								TUSB_PRINT1("Error %d on string removal", r);
sl@0: 								}	
sl@0: 							}
sl@0: 						TUSB_VERBOSE_PRINT1 ("Closing USB channel number %d",portNumber);
sl@0: 						iPort[portNumber].Close();											// close USB channel
sl@0: 						}
sl@0: 					TUSB_VERBOSE_PRINT("Closing Idle Counter Thread");
sl@0: 					iIdleCounter->iCommand = ETestIdleCounterClose;
sl@0: 					iIdleCounterChunk.Close();
sl@0: 					// Allow time for low-priority thread to close
sl@0: 					User::After(100000);
sl@0: 					iIdleCounterThread.Close();
sl@0: 					
sl@0: 					CActiveScheduler::Stop();
sl@0: 					break;
sl@0: 					
sl@0: 				case EVersion :
sl@0: 					TUSB_PRINT("Receiving t_usb_host version");
sl@0: 					host_ver_major = iEp0DataBuffer[0];
sl@0: 					host_ver_minor = iEp0DataBuffer[1];
sl@0: 					host_ver_micro = iEp0DataBuffer[2];
sl@0: 					usbio_ver_major = iEp0DataBuffer[3];
sl@0: 					usbio_ver_minor = iEp0DataBuffer[4];
sl@0: 					TUSB_PRINT5("Host-side: t_usb_host v%d.%d.%d  USBIO v%d.%d\n",
sl@0: 						host_ver_major, host_ver_minor, host_ver_micro,
sl@0: 						usbio_ver_major, usbio_ver_minor);
sl@0: 					if (host_ver_major < KHostVersionMajor)
sl@0: 						{
sl@0: 						TUSB_PRINT1("t_usb_host version not sufficient (need at least v%d.x.x)\n",KHostVersionMajor);
sl@0: 						User::Leave(-1);
sl@0: 						return KErrNone;
sl@0: 						}
sl@0: 					// Just using '<' instead of the seemingly absurd '<= && !==' doesn't work without
sl@0: 					// GCC compiler warning because Kxxx can also be zero (in which case there's no '<').
sl@0: 					else if ((host_ver_minor <= KHostVersionMinor) &&
sl@0: 			 				!(host_ver_minor == KHostVersionMinor))
sl@0: 						{
sl@0: 						TUSB_PRINT2("t_usb_host version not sufficient (need at least v%d.%d.x)\n",
sl@0: 							KHostVersionMajor, KHostVersionMinor);
sl@0: 						test(EFalse);
sl@0: 						return KErrNone;
sl@0: 						}
sl@0: 					// Just using '<' instead of the seemingly absurd '<= && !==' doesn't work without
sl@0: 					// GCC compiler warning because Kxxx can also be zero (in which case there's no '<').
sl@0: 					else if ((host_ver_micro <= KHostVersionMicro) &&
sl@0: 			 				!(host_ver_micro == KHostVersionMicro))
sl@0: 						{
sl@0: 						TUSB_PRINT3("USBRFLCT version not sufficient (need at least v%d.%d.%d)\n",
sl@0: 									KHostVersionMajor, KHostVersionMinor, KHostVersionMicro);
sl@0: 						test(EFalse);
sl@0: 						return KErrNone;
sl@0: 						}
sl@0: 					break;
sl@0: 					
sl@0: 				case ETestParam :
sl@0: 					tpPtr = (TestParamPtr)(&iEp0DataBuffer[0]);
sl@0: 					TUSB_VERBOSE_PRINT4("Test Params - interface %d repeat %d settingRepeat %d beforeIndex %d",tpPtr->interfaceNumber,tpPtr->repeat,tpPtr->settingRepeat,tpPtr->beforeIndex);
sl@0: 					if (index >= KMaxConcurrentTests)
sl@0: 						{
sl@0: 						TUSB_PRINT2("Test index %d is greater than maximum allowed (%d) concurrent tests",index,KMaxConcurrentTests);
sl@0: 						test(EFalse);
sl@0: 						return KErrNone;
sl@0: 						}
sl@0: 					// Create Reader/Writer active object
sl@0: 					pActiveRW = CActiveRW::NewL(iConsole, &iPort[gInterfaceConfig[tpPtr->interfaceNumber][tpPtr->alternateSetting]->iPortNumber], iFs, index, lastSettingThread);
sl@0: 					if (!pActiveRW)
sl@0: 						{
sl@0: 						TUSB_PRINT("Failed to create reader/writer");
sl@0: 						test(EFalse);
sl@0: 						return KErrNone;
sl@0: 						}
sl@0: 					TUSB_VERBOSE_PRINT("Created reader/writer");
sl@0: 					pActiveRW->SetTestParams(tpPtr);
sl@0: 					switch (value)
sl@0: 						{
sl@0: 					case 'X' :
sl@0: 						test.Start (_L("Xml"));
sl@0: 						break;
sl@0: 							
sl@0: 					case 'L' :
sl@0: 						test.Start (_L("Loop"));
sl@0: 						pActiveRW->SetTransferMode(ELoop);
sl@0: 						gAltSettingOnNotify = ETrue;
sl@0: 						if (tpPtr->settingRepeat && !firstSettingThread)
sl@0: 							{
sl@0: 							pActiveRW->Suspend(ESuspend);	
sl@0: 							}
sl@0: 						else
sl@0: 							{
sl@0: 							pActiveRW->StartOrSuspend();						
sl@0: 							}
sl@0: 						break;
sl@0: 							
sl@0: 					case 'C' :
sl@0: 						test.Start (_L("Compare"));
sl@0: 						pActiveRW->SetTransferMode(ELoopComp);
sl@0: 						gAltSettingOnNotify = ETrue;
sl@0: 						if (tpPtr->settingRepeat && !firstSettingThread)
sl@0: 							{
sl@0: 							pActiveRW->Suspend(ESuspend);	
sl@0: 							}
sl@0: 						else
sl@0: 							{
sl@0: 							pActiveRW->StartOrSuspend();						
sl@0: 							}
sl@0: 						break;
sl@0: 							
sl@0: 					case 'S' :
sl@0: 						test.Start (_L("Stream"));
sl@0: 						if (tpPtr->outPipe > KMaxEndpointsPerClient)
sl@0: 							{
sl@0: 							pActiveRW->SetTransferMode(ETransmitOnly);						
sl@0: 							gAltSettingOnNotify = ETrue;
sl@0: 							if (tpPtr->settingRepeat && !firstSettingThread)
sl@0: 								{
sl@0: 								pActiveRW->Suspend(ESuspend);	
sl@0: 								}
sl@0: 							else
sl@0: 								{
sl@0: 								pActiveRW->StartOrSuspend();						
sl@0: 								}
sl@0: 							}
sl@0: 						else
sl@0: 							{
sl@0: 							pActiveRW->SetTransferMode(EReceiveOnly);						
sl@0: 							gAltSettingOnNotify = ETrue;
sl@0: 							if (tpPtr->settingRepeat && !firstSettingThread)
sl@0: 								{
sl@0: 								pActiveRW->Suspend(ESuspend);	
sl@0: 								}
sl@0: 							else
sl@0: 								{
sl@0: 								pActiveRW->StartOrSuspend();						
sl@0: 								}
sl@0: 							}					
sl@0: 						break;
sl@0: 							
sl@0: 					case 'F' :
sl@0: 						test.Start (_L("File"));
sl@0: 						// send this now as the file setup takes a long time
sl@0: 						sendStatus = EFalse;
sl@0: 						r = iPort[0].SendEp0StatusPacket();					
sl@0: 						test_KErrNone(r);
sl@0: 						if (tpPtr->outPipe > KMaxEndpointsPerClient)
sl@0: 							{
sl@0: 							pActiveRW->SetTransferMode(ETransmitOnly);
sl@0: 							TInt maxFileSize = tpPtr->maxSize * tpPtr->repeat;						
sl@0: 							pActiveRW->ReadFromDisk((TChar)tpPtr->minSize,maxFileSize);
sl@0: 							gAltSettingOnNotify = ETrue;
sl@0: 							if (tpPtr->settingRepeat && !firstSettingThread)
sl@0: 								{
sl@0: 								pActiveRW->Suspend(ESuspend);	
sl@0: 								}
sl@0: 							else
sl@0: 								{
sl@0: 								pActiveRW->StartOrSuspend();						
sl@0: 								}
sl@0: 							}
sl@0: 						else
sl@0: 							{
sl@0: 							pActiveRW->SetTransferMode(EReceiveOnly);						
sl@0: 							pActiveRW->WriteToDisk((TChar)tpPtr->minSize);
sl@0: 							gAltSettingOnNotify = ETrue;
sl@0: 							if (tpPtr->settingRepeat && !firstSettingThread)
sl@0: 								{
sl@0: 								pActiveRW->Suspend(ESuspend);	
sl@0: 								}
sl@0: 							else
sl@0: 								{
sl@0: 								pActiveRW->StartOrSuspend();						
sl@0: 								}
sl@0: 							}					
sl@0: 						break;
sl@0: 						
sl@0: 					default :
sl@0: 						TUSB_PRINT1("Invalid test value %X",value);
sl@0: 						test(EFalse);
sl@0: 						}
sl@0: 						
sl@0: 					gRW[index] = pActiveRW;
sl@0: 					break;
sl@0: 					
sl@0: 				case ETestResult :
sl@0: 					TUSB_VERBOSE_PRINT2 ("Test index %d complete - value %d",index,value);
sl@0: 					// if failure, send this first to prevent panic corrupting EP0 
sl@0: 					if (!value)
sl@0: 						{
sl@0: 						sendStatus = EFalse;
sl@0: 						r = iPort[0].SendEp0StatusPacket();					
sl@0: 						}
sl@0: 					if (index < KMaxConcurrentTests)
sl@0: 						{
sl@0: 						if (gRW[index] != NULL)
sl@0: 							{
sl@0: 							gRW[index]->TestComplete (value);
sl@0: 							break;
sl@0: 							}
sl@0: 						}
sl@0: 					if (index == KHostErrorIndex)
sl@0: 						{
sl@0: 						if (!value)
sl@0: 							{
sl@0: 							TUSB_PRINT("Host Test Fail");							
sl@0: 							}
sl@0: 						}
sl@0: 					else
sl@0: 						{
sl@0: 						TUSB_PRINT2("Invalid test index %d for result %d",index,value);
sl@0: 						}
sl@0: 					if (!value)
sl@0: 						{
sl@0: 						test(EFalse);
sl@0: 						}
sl@0: 					break;
sl@0: 
sl@0: 				case ETestFail :
sl@0: 					User::Leave(-1);
sl@0: 					break;
sl@0: 
sl@0: 				case ETestConnect :
sl@0: 					test.Start (_L("Connect"));
sl@0: 					sendStatus = EFalse;
sl@0: 					r = iPort[0].SendEp0StatusPacket();					
sl@0: 					if (iSoftwareConnect)
sl@0: 						{
sl@0: 						r = iPort[0].DeviceDisconnectFromHost();
sl@0: 						test_KErrNone (r);
sl@0: 						
sl@0: 						TUint32 waitTime = (TUint32)value * 1000;
sl@0: 						if (waitTime == 0)
sl@0: 							{
sl@0: 							waitTime = 5000;		// default to 5 milliseconds
sl@0: 							}
sl@0: 						iTimer.After(iStatus,waitTime);
sl@0: 						iPending = EPendingTimer;
sl@0: 						
sl@0: 						SetActive();
sl@0: 						}
sl@0: 					else
sl@0: 						{
sl@0: 						iConsole->Printf(_L("This device does not support software\n"));
sl@0: 						iConsole->Printf(_L("disconnect/reconnect\n"));
sl@0: 						iConsole->Printf(_L("Please physically unplug and replug\n"));
sl@0: 						iConsole->Printf(_L("the USB cable NOW... "));
sl@0: 						test.End ();
sl@0: 						}				
sl@0: 					break;
sl@0: 
sl@0: 				case ETestDisconnect :
sl@0: 					test.Start (_L("Disconnect"));
sl@0: 					// send this now as the port will be disconnected
sl@0: 					sendStatus = EFalse;
sl@0: 					r = iPort[0].SendEp0StatusPacket();					
sl@0: 					if (iSoftwareConnect)
sl@0: 						{
sl@0: 						r = iPort[0].DeviceDisconnectFromHost();
sl@0: 						test_KErrNone (r);
sl@0: 						}
sl@0: 					else
sl@0: 						{
sl@0: 						iConsole->Printf(_L("This device does not support software\n"));
sl@0: 						iConsole->Printf(_L("disconnect/reconnect\n"));
sl@0: 						iConsole->Printf(_L("Please physically unplug and replug\n"));
sl@0: 						iConsole->Printf(_L("the USB cable NOW... "));
sl@0: 						}				
sl@0: 
sl@0: 					test.End ();
sl@0: 					break;
sl@0: 
sl@0: 				case ETestMassStorage :
sl@0: 					test.Start (_L("Select Mass Storage"));
sl@0: 				
sl@0: 					// send this now as the port will be disconnected
sl@0: 					sendStatus = EFalse;
sl@0: 					r = iPort[0].SendEp0StatusPacket();					
sl@0: 					test_KErrNone(r);
sl@0: 			
sl@0: 					for (TInt portNumber = 0; portNumber < iTotalChannels; portNumber++)
sl@0: 						{
sl@0: 						delete iDeviceStateNotifier[portNumber];
sl@0: 						delete iStallNotifier[portNumber];
sl@0: 						if (portNumber == 0)
sl@0: 							{
sl@0: 							r = iPort[portNumber].RemoveStringDescriptor(stridx1);
sl@0: 							if (r != KErrNone)
sl@0: 								{
sl@0: 								TUSB_PRINT1("Error %d on string removal", r);
sl@0: 								}
sl@0: 							r = iPort[portNumber].RemoveStringDescriptor(stridx2);
sl@0: 							if (r != KErrNone)
sl@0: 								{
sl@0: 								TUSB_PRINT1("Error %d on string removal", r);
sl@0: 								}	
sl@0: 							}
sl@0: 						TUSB_VERBOSE_PRINT1 ("Closing USB channel number %d",portNumber);
sl@0: 						iPort[portNumber].Close();											// close USB channel
sl@0: 						}
sl@0: 		
sl@0: 					r = iPort[0].Open(0);
sl@0: 					test_KErrNone(r);
sl@0: 					TUSB_VERBOSE_PRINT("Successfully opened USB port");
sl@0: 
sl@0: 					SetupDescriptors(iLddPtr, &iPort[0],value);
sl@0: 					StartMassStorage(&iPort[0]);
sl@0: 		
sl@0: 					test.Next (_L("Enumeration..."));
sl@0: 					r = ReEnumerate();				
sl@0: 					test_KErrNone(r);
sl@0: 
sl@0: 
sl@0: 					test.End ();
sl@0: 					break;
sl@0: 				}
sl@0: 			if (sendStatus)
sl@0: 				{
sl@0: 				r = iPort[0].SendEp0StatusPacket();
sl@0: 				if (r != KErrNone)
sl@0: 					{
sl@0: 					TUSB_PRINT1("ActiveControl::Error %d in Ep0 Send Status Packet", r);
sl@0: 					test(EFalse);
sl@0: 					return KErrNone;						
sl@0: 					}				
sl@0: 				}
sl@0: 			}
sl@0: 		else
sl@0: 			{
sl@0: 			if ((iEp0SetUpPacket[KUsb_Ep0RequestOffset] == EVersion) && length > 0)
sl@0: 				{
sl@0: 				TUSB_PRINT4("Sending t_usb_device version: %d.%d.%d length %d \n", KDeviceVersionMajor, KDeviceVersionMinor, KDeviceVersionMicro, length);
sl@0: 				#ifdef	USB_SC
sl@0: 				TUint8 *ep0Buffer;
sl@0: 				TUint8 *ep0BufPtr;
sl@0: 				TUint ep0Length;
sl@0: 				iEp0Buf.GetInBufferRange(((TAny*&)ep0Buffer),ep0Length);
sl@0: 				
sl@0: 				ep0BufPtr = ep0Buffer;
sl@0: 				*(ep0Buffer++) = KDeviceVersionMajor;
sl@0: 				*(ep0Buffer++) = KDeviceVersionMinor;
sl@0: 				*(ep0Buffer++) = KDeviceVersionMicro;
sl@0: 				TUint8 i=3;
sl@0: 				if (iConfigFileName->Length())
sl@0: 					{
sl@0: 					for(TUint8 j=0; j < iConfigFileName->Length() && i < length; j++)
sl@0: 						{
sl@0: 						i++;
sl@0: 						*(ep0Buffer++) = (*iConfigFileName)[j];
sl@0: 						}
sl@0: 					}
sl@0: 				if (iScriptFileName->Length())
sl@0: 					{
sl@0: 					for(TUint8 j=0; j < iScriptFileName->Length() && i < length; j++)
sl@0: 						{
sl@0: 						i++;
sl@0: 						*(ep0Buffer++) = (*iScriptFileName)[j];
sl@0: 						}
sl@0: 					}
sl@0: 				*(ep0Buffer++) = 0;
sl@0: 				r = iEp0Buf.WriteBuffer(ep0BufPtr,length,FALSE,ep0Status);
sl@0: 				test_KErrNone(r);
sl@0: 				#else				
sl@0: 				iEp0DataBuffer.FillZ(length);
sl@0: 				iEp0DataBuffer[0] = KDeviceVersionMajor;
sl@0: 				iEp0DataBuffer[1] = KDeviceVersionMinor;
sl@0: 				iEp0DataBuffer[2] = KDeviceVersionMicro;
sl@0: 				iEp0DataBuffer.SetLength(3);
sl@0: 				iEp0DataBuffer.Append (*iConfigFileName);
sl@0: 				iEp0DataBuffer.Append (*iScriptFileName);
sl@0: 				iEp0DataBuffer.SetLength(length);				
sl@0: 				iPort[0].Write(ep0Status, EEndpoint0, iEp0DataBuffer, length);
sl@0: 				#endif
sl@0: 				User::WaitForRequest(ep0Status);
sl@0: 				test_KErrNone(ep0Status.Int());
sl@0: 				}
sl@0: 			else if ((iEp0SetUpPacket[KUsb_Ep0RequestOffset] == ETestIdleCounter) && length >= sizeof(TInt64))
sl@0: 				{
sl@0: 				// for a non zero request value if any tests still active send zero otherwise the counter value
sl@0: 				TInt64 val = (value == 0 || gActiveTestCount == 0) ? iIdleCounter->iCounter : 0;
sl@0: 
sl@0: 				TUSB_PRINT1("Sending counter value %Ld\n", val);
sl@0: 				#ifdef	USB_SC
sl@0: 
sl@0: 				TUint8 *ep0Buffer;
sl@0: 				TUint ep0Length;
sl@0: 				iEp0Buf.GetInBufferRange(((TAny*&)ep0Buffer),ep0Length);
sl@0: 				
sl@0: 				*((TInt64*) ep0Buffer) = val;
sl@0: 				
sl@0: 				r = iEp0Buf.WriteBuffer(ep0Buffer,length,FALSE,ep0Status);
sl@0: 				test_KErrNone(r);
sl@0: 				#else				
sl@0: 
sl@0: 				iEp0DataBuffer.FillZ(length);
sl@0: 				*((TInt64*) iEp0DataBuffer.Ptr()) = val;
sl@0: 				iEp0DataBuffer.SetLength(sizeof(TInt64));
sl@0: 				iPort[0].Write(ep0Status, EEndpoint0, iEp0DataBuffer, length);
sl@0: 				#endif
sl@0: 
sl@0: 				User::WaitForRequest(ep0Status);
sl@0: 				test_KErrNone(ep0Status.Int());
sl@0: 				}
sl@0: 			}
sl@0: 		if (iEp0SetUpPacket[KUsb_Ep0RequestOffset] != EStop && iEp0SetUpPacket[KUsb_Ep0RequestOffset] != ETestConnect &&
sl@0: 			iEp0SetUpPacket[KUsb_Ep0RequestOffset] != ETestMassStorage)
sl@0: 			{
sl@0: 			return KErrCompletion;		
sl@0: 			}				
sl@0: 		}
sl@0: 	else
sl@0: 		{
sl@0: 		TUSB_PRINT1("Error : Incorrect SetUp Packet Request Type %X", iEp0SetUpPacket[0]);			
sl@0: 		test(EFalse);
sl@0: 		return KErrNone;
sl@0: 		}
sl@0: 	
sl@0: 	return KErrNone;
sl@0: 	}
sl@0: 	
sl@0: void CActiveControl::PrintHostLog()
sl@0: 	{
sl@0: 	TRequestStatus status = 0;
sl@0: 	wchar_t lineBuf[128];
sl@0: 	TUint j = 0;
sl@0: 	
sl@0: 	TUSB_VERBOSE_PRINT("Reading Host log file\n");
sl@0: 
sl@0: 	#ifdef USB_SC
sl@0: 	TInt r = 0;
sl@0: 	TEndpointBuffer scReadBuf;
sl@0: 	TAny * scReadData;
sl@0: 	TUint8 * scCharPtr;
sl@0: 	TUint readSize;
sl@0: 	TBool readZlp = EFalse;
sl@0: 
sl@0: 	r = iPort->OpenEndpoint(scReadBuf,firstBulkOutEndpoint);
sl@0: 	test_KErrNone(r);
sl@0: 	do
sl@0: 		{
sl@0: 		r = scReadBuf.GetBuffer (scReadData,readSize,readZlp,status);
sl@0: 		// The following line can be reinstated once the shared chunk failure is fixed
sl@0: 		// that prevents the readZlp flag from being set
sl@0: 		// test_Value(r, (r == KErrNone) || (r == KErrCompletion) || (r == KErrEof));
sl@0: 		if (r == KErrCompletion)
sl@0: 			{
sl@0: 			TUSB_VERBOSE_PRINT1("Host log file %d bytes read\n",readSize);
sl@0: 			scCharPtr = (TUint8 *)scReadData;
sl@0: 			// Print the host log file
sl@0: 			for (TUint i = 0; i < readSize; i++)
sl@0: 				{
sl@0: 				if (* scCharPtr == '\r')
sl@0: 					{
sl@0: 					lineBuf[j++] = '\0';
sl@0: 					RDebug::Print (_L("%s"),lineBuf);
sl@0: 					j = 0;	
sl@0: 					}
sl@0: 				else
sl@0: 					{
sl@0: 					if (* scCharPtr != '\n')
sl@0: 						{
sl@0: 						lineBuf[j++] = * scCharPtr;				
sl@0: 						}
sl@0: 					}
sl@0: 				scCharPtr++;
sl@0: 				}
sl@0: 			}
sl@0: 		if (r == KErrNone)
sl@0: 			{
sl@0: 			User::WaitForRequest(status);
sl@0: 			test_KErrNone(status.Int());	
sl@0: 			}
sl@0: 		}
sl@0: 	while (r >= KErrNone && !readZlp);
sl@0: 	#else
sl@0: 	TPtr8 readBuf((TUint8 *)User::Alloc(KHostLogFileSize),KHostLogFileSize,KHostLogFileSize);
sl@0: 	iPort[0].ReadUntilShort(status, (TEndpointNumber)firstBulkOutEndpoint, readBuf);
sl@0: 	User::WaitForRequest(status);
sl@0: 	test_KErrNone(status.Int());
sl@0: 	TUSB_VERBOSE_PRINT1("Host log file %d bytes read\n",readBuf.Length());
sl@0: 	for (TUint i = 0; i < readBuf.Length(); i++)
sl@0: 		{
sl@0: 		if (readBuf[i] == '\r')
sl@0: 			{
sl@0: 			lineBuf[j++] = '\0';
sl@0: 			RDebug::Print (_L("%s"),lineBuf);
sl@0: 			j = 0;	
sl@0: 			}
sl@0: 		else
sl@0: 			{
sl@0: 			if (readBuf[i] != '\n')
sl@0: 				{
sl@0: 				lineBuf[j++] = readBuf[i];				
sl@0: 				}
sl@0: 			}
sl@0: 		}
sl@0: 	User::Free ((TAny *)readBuf.Ptr());
sl@0: 	#endif
sl@0: 	}
sl@0: 	
sl@0: void CActiveControl::QueryUsbClientL(LDDConfigPtr aLddPtr, RDEVCLIENT* aPort)
sl@0: 	{
sl@0: 	// Get device/endpoint capabilities
sl@0: 	//
sl@0: 	// A TPckg, or TPckBuf was not used in the following, because
sl@0: 	//
sl@0: 	//	 TPckgBuf<TUsbcEndpointData[KUsbcMaxEndpoints]> databuf;
sl@0: 	//
sl@0: 	// doesn't work. Also,
sl@0: 	//
sl@0: 	//	 TUsbcEndpointData data[KUsbcMaxEndpoints];
sl@0: 	//	 TPckgBuf<TUsbcEndpointData[KUsbcMaxEndpoints]> databuf(data);
sl@0: 	//
sl@0: 	// doesn't work. Also,
sl@0: 	//
sl@0: 	//	 TUsbcEndpointData data[KUsbcMaxEndpoints];
sl@0: 	//	 TPckgBuf<TUsbcEndpointData[]> databuf(data);
sl@0: 	//
sl@0: 	// doesn't work.
sl@0: 	// So we seem to have to stick to the ugly cast below.
sl@0: 	//
sl@0: 	//	 TUsbcEndpointData data[KUsbcMaxEndpoints];
sl@0: 	//	 TPtr8 databuf(reinterpret_cast<TUint8*>(data), sizeof(data), sizeof(data));
sl@0: 	//
sl@0: 
sl@0: 	// Device
sl@0: 	// === Device Descriptor
sl@0: 	
sl@0: 	test.Start(_L("Query device and Endpoint Capabilities"));
sl@0: 
sl@0: 
sl@0: 	TUsbDeviceCaps d_caps;
sl@0: 	TInt r = aPort->DeviceCaps(d_caps);
sl@0: 	test_KErrNone(r);
sl@0: 
sl@0: 	const TInt n = d_caps().iTotalEndpoints;
sl@0: 
sl@0: 	TUSB_PRINT("###  USB device capabilities:");
sl@0: 	TUSB_PRINT1("Number of endpoints:                %d", n);
sl@0: 	TUSB_PRINT1("Supports Software-Connect:          %s",
sl@0: 				d_caps().iConnect ? _S("yes") : _S("no"));
sl@0: 	TUSB_PRINT1("Device is Self-Powered:             %s",
sl@0: 				d_caps().iSelfPowered ? _S("yes") : _S("no"));
sl@0: 	TUSB_PRINT1("Supports Remote-Wakeup:             %s",
sl@0: 				d_caps().iRemoteWakeup ? _S("yes") : _S("no"));
sl@0: 	TUSB_PRINT1("Supports High-speed:                %s",
sl@0: 				d_caps().iHighSpeed ? _S("yes") : _S("no"));
sl@0: 	TUSB_PRINT1("Supports unpowered cable detection: %s\n",
sl@0: 				(d_caps().iFeatureWord1 & KUsbDevCapsFeatureWord1_CableDetectWithoutPower) ?
sl@0: 				_S("yes") : _S("no"));
sl@0: 	TUSB_PRINT("");
sl@0: 
sl@0: 	iSoftwareConnect = d_caps().iConnect;					// we need to remember this
sl@0: 	test_Equal(aLddPtr->iSoftConnect,iSoftwareConnect);
sl@0: 
sl@0: 	// only check capabilities if set; therefore allowing them to be disabled
sl@0: 	if (aLddPtr->iSelfPower)
sl@0: 		{
sl@0: 		test(d_caps().iSelfPowered);	
sl@0: 		}
sl@0: 	
sl@0: 	// only check capabilities if set; therefore allowing them to be disabled
sl@0: 	if (aLddPtr->iRemoteWakeup)
sl@0: 		{
sl@0: 		test(d_caps().iRemoteWakeup);		
sl@0: 		}
sl@0: 
sl@0: 	test_Equal(d_caps().iFeatureWord1 & KUsbDevCapsFeatureWord1_CableDetectWithoutPower,aLddPtr->iFeatures);
sl@0: 
sl@0: 	// only check capability if set; therefore allowing it to be disabled
sl@0: 	if (aLddPtr->iHighSpeed)
sl@0: 		{
sl@0: 		test(d_caps().iHighSpeed);		
sl@0: 		}
sl@0: 	
sl@0: 	test_Equal(aLddPtr->iNumEndpoints,n);
sl@0: 
sl@0: 	// Endpoints
sl@0: 	TUsbcEndpointData data[KUsbcMaxEndpoints];
sl@0: 	TPtr8 dataptr(reinterpret_cast<TUint8*>(data), sizeof(data), sizeof(data));
sl@0: 	r = aPort->EndpointCaps(dataptr);
sl@0: 	test_KErrNone(r);
sl@0: 
sl@0: 	TUSB_PRINT("### USB device endpoint capabilities:");
sl@0: 	for (TInt i = 0; i < n; i++)
sl@0: 		{
sl@0: 		const TUsbcEndpointCaps* caps = &data[i].iCaps;
sl@0: 		
sl@0: 		
sl@0: 		TBuf<40> sizeStr(_S("unknown"));
sl@0: 		if (caps->iSizes == KUsbEpNotAvailable)
sl@0: 			{
sl@0: 			sizeStr = _S("Not Available");	
sl@0: 			}		
sl@0: 		else
sl@0: 			{
sl@0: 			sizeStr.SetLength(0);
sl@0: 			if (caps->iSizes & KUsbEpSizeCont)
sl@0: 				sizeStr.Append(_S(" Continuous"),11);
sl@0: 			if (caps->iSizes & KUsbEpSize8)
sl@0: 				sizeStr.Append(_S(" 8"),2);
sl@0: 			if (caps->iSizes & KUsbEpSize16)
sl@0: 				sizeStr.Append(_S(" 16"),3);
sl@0: 			if (caps->iSizes & KUsbEpSize32)
sl@0: 				sizeStr.Append(_S(" 32"),3);
sl@0: 			if (caps->iSizes & KUsbEpSize64)
sl@0: 				sizeStr.Append(_S(" 64"),3);
sl@0: 			if (caps->iSizes & KUsbEpSize128)
sl@0: 				sizeStr.Append(_S(" 128"),4);
sl@0: 			if (caps->iSizes & KUsbEpSize256)
sl@0: 				sizeStr.Append(_S(" 256"),4);
sl@0: 			if (caps->iSizes & KUsbEpSize512)
sl@0: 				sizeStr.Append(_S(" 512"),4);
sl@0: 			if (caps->iSizes & KUsbEpSize1023)
sl@0: 				sizeStr.Append(_S(" 1023"),5);
sl@0: 			if (caps->iSizes & KUsbEpSize1024)
sl@0: 				sizeStr.Append(_S(" 1024"),5);
sl@0: 			}
sl@0: 
sl@0: 		TBuf<40> typeStr(_S("unknown"));
sl@0: 		if (caps->iTypesAndDir == KUsbEpNotAvailable)
sl@0: 			typeStr = _S("Not Available");
sl@0: 		if (caps->iTypesAndDir & (KUsbEpTypeControl | KUsbEpTypeBulk | KUsbEpTypeInterrupt | KUsbEpTypeIsochronous))
sl@0: 			{
sl@0: 			typeStr.SetLength(0);
sl@0: 			if (caps->iTypesAndDir & KUsbEpTypeBulk)
sl@0: 				typeStr.Append(_S("Control "),8);
sl@0: 			if (caps->iTypesAndDir & KUsbEpTypeBulk)
sl@0: 				typeStr.Append(_S("Bulk "),5);
sl@0: 			if (caps->iTypesAndDir & KUsbEpTypeInterrupt)
sl@0: 				typeStr.Append(_S("Interrupt "),10);
sl@0: 			if (caps->iTypesAndDir & KUsbEpTypeIsochronous)
sl@0: 				typeStr.Append(_S("Isochronous"),11);			
sl@0: 			}
sl@0: 			
sl@0: 		TBuf<20> directionStr(_S("unknown"));
sl@0: 		
sl@0: 		if (caps->iTypesAndDir & KUsbEpDirIn)
sl@0: 			directionStr = _S("In");
sl@0: 		if (caps->iTypesAndDir & KUsbEpDirOut)
sl@0: 			directionStr = _S("Out");
sl@0: 		if (caps->iTypesAndDir & KUsbEpDirBidirect)
sl@0: 			directionStr = _S("Both");
sl@0: 				
sl@0: 		TUSB_PRINT4("Endpoint:%d Sizes =%s Type = %s - %s",
sl@0: 					i+1,sizeStr.PtrZ(), typeStr.PtrZ(), directionStr.PtrZ());
sl@0: 		}
sl@0: 	TUSB_PRINT("");
sl@0: 
sl@0: 	test.End();
sl@0: 			
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void CActiveControl::AllocateEndpointDMA(RDEVCLIENT* aPort,TENDPOINTNUMBER aEndpoint)
sl@0: 	{
sl@0: 	TBool res = EFalse;
sl@0: 	
sl@0: 	TInt r = aPort->AllocateEndpointResource(aEndpoint, EUsbcEndpointResourceDMA);
sl@0: 	if (r == KErrNone)
sl@0: 		RDebug::Print(_L("DMA allocation on endpoint %d: KErrNone"), aEndpoint);
sl@0: 	else if (r == KErrInUse)
sl@0: 		RDebug::Print(_L("DMA allocation on endpoint %d: KErrInUse"), aEndpoint);
sl@0: 	else if (r == KErrNotSupported)
sl@0: 		RDebug::Print(_L("DMA allocation on endpoint %d: KErrNotSupported"), aEndpoint);
sl@0: 	else
sl@0: 		RDebug::Print(_L("DMA allocation on endpoint %d: unexpected return value %d"),
sl@0: 					  aEndpoint, r);
sl@0: 	#ifdef	USB_SC
sl@0: 	res = aPort->QueryEndpointResourceUse(aEndpoint, EUsbcEndpointResourceDMA);
sl@0: 	#else
sl@0: 	res = aPort->QueryEndpointResourceUse(aEndpoint, EUsbcEndpointResourceDMA);
sl@0: 	#endif
sl@0: 	
sl@0: 	TUSB_PRINT2("DMA on endpoint %d %s\n",
sl@0: 				aEndpoint, res ? _S("allocated") : _S("not allocated"));
sl@0: 
sl@0: 	if ((r == KErrNone) && !res)
sl@0: 		RDebug::Print(_L("(Allocation success but negative query result: contradiction!)\n"));
sl@0: 	else if ((r != KErrNone) && res)
sl@0: 		RDebug::Print(_L("(Allocation failure but positive query result: contradiction!)\n"));
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void CActiveControl::DeAllocateEndpointDMA(RDEVCLIENT* aPort,TENDPOINTNUMBER aEndpoint)
sl@0: 	{
sl@0: 	TBool res = FALSE;	
sl@0: 	TInt r = aPort->DeAllocateEndpointResource(aEndpoint, EUsbcEndpointResourceDMA);
sl@0: 	if (r == KErrNone)
sl@0: 		RDebug::Print(_L("DMA deallocation on endpoint %d: KErrNone"), aEndpoint);
sl@0: 	else if (r == KErrNotSupported)
sl@0: 		RDebug::Print(_L("DMA deallocation on endpoint %d: KErrNotSupported"), aEndpoint);
sl@0: 	else
sl@0: 		RDebug::Print(_L("DMA deallocation on endpoint %d: unexpected return value %d"),
sl@0: 					  aEndpoint, r);
sl@0: 	#ifdef	USB_SC
sl@0: 	res = aPort->QueryEndpointResourceUse(aEndpoint, EUsbcEndpointResourceDMA);
sl@0: 	#else
sl@0: 	res = aPort->QueryEndpointResourceUse(aEndpoint, EUsbcEndpointResourceDMA);
sl@0: 	#endif
sl@0: 	
sl@0: 	TUSB_PRINT2("DMA on endpoint %d %s\n",
sl@0: 				aEndpoint, res ? _S("allocated") : _S("not allocated"));
sl@0: 	}
sl@0: 
sl@0: #ifndef USB_SC
sl@0: void CActiveControl::AllocateDoubleBuffering(RDEVCLIENT* aPort,TENDPOINTNUMBER aEndpoint)
sl@0: 	{
sl@0: 	TBool res = FALSE;
sl@0: 	TInt r = aPort->AllocateEndpointResource(aEndpoint, EUsbcEndpointResourceDoubleBuffering);
sl@0: 	if (r == KErrNone)
sl@0: 		RDebug::Print(_L("Double Buffering allocation on endpoint %d: KErrNone"), aEndpoint);
sl@0: 	else if (r == KErrInUse)
sl@0: 		RDebug::Print(_L("Double Buffering allocation on endpoint %d: KErrInUse"), aEndpoint);
sl@0: 	else if (r == KErrNotSupported)
sl@0: 		RDebug::Print(_L("Double Buffering allocation on endpoint %d: KErrNotSupported"), aEndpoint);
sl@0: 	else
sl@0: 		RDebug::Print(_L("Double Buffering allocation on endpoint %d: unexpected return value %d"),
sl@0: 					  aEndpoint, r);
sl@0: 	res = aPort->QueryEndpointResourceUse(aEndpoint, EUsbcEndpointResourceDoubleBuffering);
sl@0: 	TUSB_PRINT2("Double Buffering on endpoint %d %s\n",
sl@0: 				aEndpoint, res ? _S("allocated") : _S("not allocated"));
sl@0: 
sl@0: 	if ((r == KErrNone) && !res)
sl@0: 		RDebug::Print(_L("(Allocation success but negative query result: contradiction!)\n"));
sl@0: 	else if ((r != KErrNone) && res)
sl@0: 		RDebug::Print(_L("(Allocation failure but positive query result: contradiction!)\n"));
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void CActiveControl::DeAllocateDoubleBuffering(RDEVCLIENT* aPort,TENDPOINTNUMBER aEndpoint)
sl@0: 	{
sl@0: 	TInt r = aPort->DeAllocateEndpointResource(aEndpoint, EUsbcEndpointResourceDoubleBuffering);
sl@0: 	if (r == KErrNone)
sl@0: 		RDebug::Print(_L("Double Buffering deallocation on endpoint %d: KErrNone"), aEndpoint);
sl@0: 	else if (r == KErrNotSupported)
sl@0: 		RDebug::Print(_L("Double Buffering deallocation on endpoint %d: KErrNotSupported"), aEndpoint);
sl@0: 	else
sl@0: 		RDebug::Print(_L("Double Buffering deallocation on endpoint %d: unexpected return value %d"),
sl@0: 					  aEndpoint, r);
sl@0: 	TBool res = aPort->QueryEndpointResourceUse(aEndpoint, EUsbcEndpointResourceDoubleBuffering);
sl@0: 	TUSB_PRINT2("Double Buffering on endpoint %d %s\n",
sl@0: 				aEndpoint, res ? _S("allocated") : _S("not allocated"));
sl@0: 	}
sl@0: 
sl@0: #endif
sl@0: 
sl@0: TInt CActiveControl::ReEnumerate()
sl@0: 	{
sl@0: 	TRequestStatus enum_status;
sl@0: 	iPort[0].ReEnumerate(enum_status);
sl@0: 	if (!iSoftwareConnect)
sl@0: 		{
sl@0: 		iConsole->Printf(_L("This device does not support software\n"));
sl@0: 		iConsole->Printf(_L("disconnect/reconnect\n"));
sl@0: 		iConsole->Printf(_L("Please physically unplug and replug\n"));
sl@0: 		iConsole->Printf(_L("the USB cable NOW... "));
sl@0: 		}
sl@0: 	iConsole->Printf(_L("\n>>> Start the t_usb_win program on the host <<<\n"));
sl@0: 	User::WaitForRequest(enum_status);
sl@0: 	if (enum_status != KErrNone)
sl@0: 		{
sl@0: 		TUSB_PRINT1("Error: Re-enumeration status = %d", enum_status.Int());
sl@0: 		return KErrGeneral;
sl@0: 		}
sl@0: 	TUsbcDeviceState device_state =	EUsbcDeviceStateUndefined;
sl@0: 	TInt r = iPort[0].DeviceStatus(device_state);
sl@0: 	if (r != KErrNone)
sl@0: 		{
sl@0: 		TUSB_PRINT1("Error %d on querying device state", r);
sl@0: 		}
sl@0: 	else
sl@0: 		{
sl@0: 		TUSB_PRINT1("Current device state: %s",
sl@0: 					(device_state == EUsbcDeviceStateUndefined) ? _S("Undefined") :
sl@0: 					((device_state == EUsbcDeviceStateAttached) ? _S("Attached") :
sl@0: 					 ((device_state == EUsbcDeviceStatePowered) ? _S("Powered") :
sl@0: 					  ((device_state == EUsbcDeviceStateDefault) ? _S("Default") :
sl@0: 					   ((device_state == EUsbcDeviceStateAddress) ? _S("Address") :
sl@0: 						((device_state == EUsbcDeviceStateConfigured) ? _S("Configured") :
sl@0: 						 ((device_state == EUsbcDeviceStateSuspended) ? _S("Suspended") :
sl@0: 						  _S("Unknown"))))))));
sl@0: 		}
sl@0: 
sl@0: 	// Check the speed of the established physical USB connection
sl@0: 	iHighSpeed = iPort[0].CurrentlyUsingHighSpeed();
sl@0: 	if (iHighSpeed)
sl@0: 		{
sl@0: 		TUSB_PRINT("---> USB High-speed Testing\n");
sl@0: 		}
sl@0: 	else
sl@0: 		{
sl@0: 		TUSB_PRINT("---> USB Full-speed Testing\n");
sl@0: 		}
sl@0: 
sl@0: 	return KErrNone;
sl@0: 	}
sl@0: 
sl@0: // -eof-