/*

* 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 CUsbHostMsSession;

class CUsbHostMsDeviceThread : public CActive

    {

public:

    static const TInt KMaxNumMessage = 32;

	static CUsbHostMsDeviceThread* NewL(CUsbHostMsSession& aUsbHostMsSession, TUint aToken);

	~CUsbHostMsDeviceThread();

private:

    CUsbHostMsDeviceThread(CUsbHostMsSession& aUsbHostMsSession, TUint aToken);

public:

	static TInt Entry(TAny* aPtr);

	TInt QueueMsg(const RMessage2& aMsg);

    void Lock();

    void Unlock();

private:

    void Start();

	void RunL();

	void DoCancel();

    TInt RunError(TInt aError);

	void HandleMessage(const RMessage2& aMessage);

	void UnRegisterInterfaceL(const RMessage2& aMessage);

private:

    static void DoStartServerL(TAny* aPtr);

	void RegisterInterfaceL(const RMessage2& aMessage);

	void InitialiseInterfaceL(const RMessage2& aMessage);

	void GetNumLunL(const RMessage2& aMessage);

	void RegisterLogicalUnitL(const RMessage2& aMessage);

	TInt Shutdown();

private:

    CUsbHostMsSession& iUsbHostMsSession;

	CUsbHostMsDevice* iUsbHostMsDevice;

	RMessage2 iRMessage2[KMaxNumMessage];

	RMutex iMutex;

	TInt iQueueIndex;

	TInt iDequeueIndex;

	TBool iQueueFull;

    };

inline void CUsbHostMsDeviceThread::Lock()

	{

	iMutex.Wait();

	}

inline void CUsbHostMsDeviceThread::Unlock()

	{

	iMutex.Signal();

	}

#endif // CUSBMASSSTORAGEDEVICETHREAD_H