/*

 * 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