diff -r 000000000000 -r bde4ae8d615e os/kernelhwsrv/userlibandfileserver/fileserver/shostmassstorage/server/controller/include/cusbhostmsdevicethread.h
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/os/kernelhwsrv/userlibandfileserver/fileserver/shostmassstorage/server/controller/include/cusbhostmsdevicethread.h	Fri Jun 15 03:10:57 2012 +0200
@@ -0,0 +1,116 @@
+/*
+* 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