/*

* Copyright (c) 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:

*

*/

/**

 Implements a thread per device functionality

 */

/** @file

@internalTechnology

*/

#ifndef CUSBMASSSTORAGEDEVICETHREAD_H

#define CUSBMASSSTORAGEDEVICETHREAD_H

class TDeviceHandler

    {

public:

    TDeviceHandler(CUsbHostMsDevice& aDevice);

	void HandleMessageL(const RMessage2& aMessage);

private:

    CUsbHostMsDevice& iDevice;

    };

class TLogicalUnitHandler

    {

public:

    TLogicalUnitHandler(CUsbHostMsLogicalUnit& aLu);

	void HandleMessageL(const RMessage2& aMessage);

private:

	CUsbHostMsLogicalUnit& iLu;

    };

class CUsbHostMsDeviceThread : public CActive

    {

public:

    static const TInt KMaxNumMessage = 32;

	static TInt Entry(TAny* aPtr);

	void RunL();

	inline void DoCancel()	{	};

	void Lock();

	void Unlock();

	TInt QueueMsg(const RMessage2& aMsg);

	void HandleMessage(const RMessage2& aMessage);

	static CUsbHostMsDeviceThread* NewL(TUint aToken);

	void UnRegisterInterfaceL(const RMessage2& aMessage);

	~CUsbHostMsDeviceThread();

private:

    static void DoStartServerL(TAny* aPtr);

	CUsbHostMsDeviceThread(TUint);

	void RegisterInterfaceL(const RMessage2& aMessage);

	void InitialiseInterfaceL(const RMessage2& aMessage);

	void GetNumLunL(const RMessage2& aMessage);

	void RegisterLogicalUnitL(const RMessage2& aMessage);

	TInt Shutdown();

public:

	TBool iIsSignalled;

private:

	CUsbHostMsDevice* iUsbHostMsDevice;

	RMessage2 iRMessage2[KMaxNumMessage];

	RMutex iMutex;

	TInt iQueueIndex;

	TInt iDequeueIndex;

	TBool iQueueFull;

    };

#endif // CUSBMASSSTORAGEDEVICETHREAD_H