diff -r 000000000000 -r bde4ae8d615e os/kernelhwsrv/kerneltest/e32test/device/t_usb.h --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/os/kernelhwsrv/kerneltest/e32test/device/t_usb.h Fri Jun 15 03:10:57 2012 +0200 @@ -0,0 +1,293 @@ +// Copyright (c) 1997-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: +// e32test\device\t_usb.h +// +// + +#ifndef __T_USB_H__ +#define __T_USB_H__ + +#include +#include +#include +#include + +#include +#include + + +static const TInt KMaxBufSize = 1024 * 1024; // max data buffer size: 1MB +static const TInt KPreambleLength = 8; // length of preamble data (bytes) + + +enum TXferMode + { + ENone, + ELoop, + ELoopComp, + EReceiveOnly, + ETransmitOnly + }; + + +class CActiveRW; +class CActiveStallNotifier; +class CActiveDeviceStateNotifier; + +class CActiveConsole : public CActive + { +public: + static CActiveConsole* NewLC(CConsoleBase* aConsole, TBool aVerboseOutput); + static CActiveConsole* NewL(CConsoleBase* aConsole, TBool aVerboseOutput); + void ConstructL(); + ~CActiveConsole(); + TInt SetupInterface(); + void RequestCharacter(); + +private: + CActiveConsole(CConsoleBase* aConsole, TBool aVerboseOutput); + // Defined as pure virtual by CActive; + // implementation provided by this class. + virtual void DoCancel(); + // Defined as pure virtual by CActive; + // implementation provided by this class, + virtual void RunL(); + void ProcessKeyPressL(TChar aChar); + TInt QueryUsbClientL(); + void AllocateEndpointDMA(TEndpointNumber aEndpoint); + void AllocateDoubleBuffering(TEndpointNumber aEndpoint); + void DeAllocateEndpointDMA(TEndpointNumber aEndpoint); + void DeAllocateDoubleBuffering(TEndpointNumber aEndpoint); + void QueryEndpointState(TEndpointNumber aEndpoint); +#ifdef WITH_DUMP_OPTION + void QueryRxBuffer(); +#endif + TInt SetupDescriptors(); + TInt ReEnumerate(); + +private: + CConsoleBase* iConsole; // a console to read from + CActiveRW* iRW; // the USB read/write active object + CActiveStallNotifier* iStallNotifier; + CActiveDeviceStateNotifier* iDeviceStateNotifier; + RDevUsbcClient iPort; + RUsbOtgDriver iOtgPort; + TBool iBufferSizeChosen; + TBool iBandwidthPriorityChosen; + TBool iDMAChosen; + TBool iDoubleBufferingChosen; + TUint32 iBandwidthPriority; + TBool iSoftwareConnect; + TBool iHighSpeed; + TBool iOtg; + TBool iVerbose; + }; + + +class CActiveTimer; + +class CActiveRW : public CActive + { +public: + enum TXferType + { + ENone, + EPreamble, + EReadXfer, + EWriteXfer + }; + static CActiveRW* NewL(CConsoleBase* aConsole, RDevUsbcClient* aPort, TBool aVerboseOutput); + ~CActiveRW(); + TInt ExchangeVersions(); + void SendPreamble(); + void SendData(); + void ReadData(); + void Stop(); + void SetMaxBufSize(TInt aBufSz); + void SetMaxPacketSize(TInt aPktSz); + TInt MaxBufSize() const; + void SetTransferMode(TXferMode aMode); + TInt WriteToDisk(TBool aEnable); + TInt ReadFromDisk(TBool aEnable); + +private: + CActiveRW(CConsoleBase* aConsole, RDevUsbcClient* aPort, TBool aVerboseOutput); + void ConstructL(); + virtual void RunL(); + virtual void DoCancel(); + TInt SendVersion(); + TInt ReceiveVersion(); + TBool CompareBuffers(TInt aLen); + TInt SelectDrive(); + void WriteBufferToDisk(TDes8& aBuffer, TInt aLen); + void ReadBufferFromDisk(TDes8& aBuffer, TInt aLen); + +private: + TBuf8 iPreambleBuf; // 2 bytes transfer length + stuffing + TBuf8 iWriteBuf; + TBuf8 iReadBuf; + CConsoleBase* iConsole; + RDevUsbcClient* iPort; + CActiveTimer* iTimeoutTimer; + TInt iBufSz; + TInt iMaxBufSz; + TInt iMaxPktSz; + TXferType iCurrentXfer; + TXferMode iXferMode; + TBool iDoStop; + TUint32 iPktNum; + TBool iVerbose; + TBool iDiskAccessEnabled; + RFs iFs; + RFile iFile; + TFileName iFileName; + TInt iFileOffset; + }; + + +class CActiveStallNotifier : public CActive + { +public: + static CActiveStallNotifier* NewL(CConsoleBase* aConsole, RDevUsbcClient* aPort, TBool aVerboseOutput); + ~CActiveStallNotifier(); + void Activate(); + +private: + CActiveStallNotifier(CConsoleBase* aConsole, RDevUsbcClient* aPort, TBool aVerboseOutput); + void ConstructL(); + virtual void DoCancel(); + virtual void RunL(); + +private: + CConsoleBase* iConsole; + RDevUsbcClient* iPort; + TUint iEndpointState; + TBool iVerbose; + }; + + +class CActiveDeviceStateNotifier : public CActive + { +public: + static CActiveDeviceStateNotifier* NewL(CConsoleBase* aConsole, RDevUsbcClient* aPort, TBool aVerboseOutput); + ~CActiveDeviceStateNotifier(); + void Activate(); + +private: + CActiveDeviceStateNotifier(CConsoleBase* aConsole, RDevUsbcClient* aPort, TBool aVerboseOutput); + void ConstructL(); + virtual void DoCancel(); + virtual void RunL(); + +private: + CConsoleBase* iConsole; + RDevUsbcClient* iPort; + TUint iDeviceState; + TBool iVerbose; + }; + + +class CActiveTimer : public CActive + { +public: + static CActiveTimer* NewL(CConsoleBase* aConsole, RDevUsbcClient* aPort, TBool aVerboseOutput); + ~CActiveTimer(); + void Activate(TTimeIntervalMicroSeconds32 aDelay); + +private: + CActiveTimer(CConsoleBase* aConsole, RDevUsbcClient* aPort, TBool aVerboseOutput); + void ConstructL(); + virtual void DoCancel(); + virtual void RunL(); + +private: + CConsoleBase* iConsole; + RDevUsbcClient* iPort; + RTimer iTimer; + TBool iVerbose; + }; + + +// +// Helpful Defines +// + +#define TUSB_PRINT(string) \ + do { \ + iConsole->Printf(_L(string)); \ + iConsole->Printf(_L("\n")); \ + RDebug::Print(_L(string)); \ + } while (0) + +#define TUSB_PRINT1(string, a) \ + do { \ + iConsole->Printf(_L(string), (a)); \ + iConsole->Printf(_L("\n")); \ + RDebug::Print(_L(string), (a)); \ + } while (0) + +#define TUSB_PRINT2(string, a, b) \ + do { \ + iConsole->Printf(_L(string), (a), (b)); \ + iConsole->Printf(_L("\n")); \ + RDebug::Print(_L(string), (a), (b)); \ + } while (0) + +#define TUSB_PRINT3(string, a, b, c) \ + do { \ + iConsole->Printf(_L(string), (a), (b), (c)); \ + iConsole->Printf(_L("\n")); \ + RDebug::Print(_L(string), (a), (b), (c)); \ + } while (0) + +#define TUSB_PRINT5(string, a, b, c, d, e) \ + do { \ + iConsole->Printf(_L(string), (a), (b), (c), (d), (e)); \ + iConsole->Printf(_L("\n")); \ + RDebug::Print(_L(string), (a), (b), (c), (d), (e)); \ + } while (0) + +#define TUSB_PRINT6(string, a, b, c, d, e, f) \ + do { \ + iConsole->Printf(_L(string), (a), (b), (c), (d), (e), (f)); \ + iConsole->Printf(_L("\n")); \ + RDebug::Print(_L(string), (a), (b), (c), (d), (e), (f)); \ + } while (0) + +#define TUSB_VERBOSE_PRINT(string) \ + do { \ + if (iVerbose) \ + { \ + TUSB_PRINT(string); \ + } \ + } while (0) + +#define TUSB_VERBOSE_PRINT1(string, a) \ + do { \ + if (iVerbose) \ + { \ + TUSB_PRINT1(string, a); \ + } \ + } while (0) + +#define TUSB_VERBOSE_PRINT2(string, a, b) \ + do { \ + if (iVerbose) \ + { \ + TUSB_PRINT2(string, a, b); \ + } \ + } while (0) + + +#endif // __T_USB_H__