// Copyright (c) 2008-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
 @internalTechnology
*/

#ifndef CBULKONLYTRANSPORT_H
#define CBULKONLYTRANSPORT_H

class CUsbInterfaceHandler;

/**
The Bulk Only Transport implementation
*/
class CBulkOnlyTransport : public CBase, public MTransport
    {
public:
	static CBulkOnlyTransport* NewL(TUint aInterfaceId);
private:
	CBulkOnlyTransport();
	~CBulkOnlyTransport();
    void ConstructL(TUint aInterfaceId);

public:
    void SetLun(TLun aLun);

    TInt SendDataTxCmdL(const MClientCommandServiceReq* aCommand,
                        TDesC8& aData,
                        TUint aPos,
                        TInt& aLen);

    TInt SendControlCmdL(const MClientCommandServiceReq* aCommand);

    TInt SendControlCmdL(const MClientCommandServiceReq* aReq,
                         MClientCommandServiceResp* aResp);

    TInt SendDataRxCmdL(const MClientCommandServiceReq* aCommand,
                        TDes8& aData,
                        TInt& aLen);

	void Suspend(TRequestStatus &aStatus);
	void Resume();

private:
	TInt Reset();
	void UnInitialiseTransport();
	TInt InitialiseTransport();
	TInt GetEndpointAddress(RUsbInterface& aUsbInterface,
                            TInt aInterfaceSetting,
                            TUint8 aTransferType,
                            TUint8 aDirection,
                            TInt& aEndpointAddress);

	void DoResetRecovery();
	void GetMaxLun(TLun* aReceiveData, const RMessage2& aMessage);
    void SendCbwL(const MClientCommandServiceReq* aReq,
                  TBotCbw::TCbwDirection aDirection,
                  TUint32 aTransferLength);

    void ReceiveCswL();
    TInt ProcessZeroTransferL();
    TInt ProcessInTransferL(TUint32& aDataReceived);
    TInt ProcessOutTransferL(TUint32& aDataReceived);

private:
    static const TInt KCbwPacketSize = 31;
    static const TInt KResponsePacketSize = 1024  * 128;
    // Though the csw valid size is 13, we do try to read 64 in order to validate
    // the device's operation
    static const TInt KCswPacketSize = 64;

private:
    TLun iLun;

	RUsbBulkTransferDescriptor iBulkOutCbwTd;
	RUsbBulkTransferDescriptor iBulkDataTd;
	RUsbBulkTransferDescriptor iBulkInCswTd;
	RUsbPipe iBulkPipeOut;
	RUsbPipe iBulkPipeIn;

	RUsbInterface iInterface;
	TRequestStatus iStatus;
    TBotCbw iCbw;
    TUint32 iCbwTag;
	TBotCsw iCsw;
	CUsbInterfaceHandler* iUsbInterfaceHandler;
    };


#ifdef MASSSTORAGE_PUBLISHER
class TMsPublisher
    {
public:
    static const TInt KMyUid = 0x10285B2E;

    enum TPropertyKeys
        {
        KBotResetProperty = 1,
        KStallProperty = 2
        };


    TMsPublisher(TPropertyKeys aKey);
    };

#endif

#endif // CBULKONLYTRANSPORT_H