--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/userlibandfileserver/fileserver/shostmassstorage/server/controller/include/cusbhostmsdevicethread.h	Mon Oct 19 15:55:17 2009 +0100
@@ -0,0 +1,89 @@
+/*
+* 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