/*
* 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