os/kernelhwsrv/userlibandfileserver/fileserver/shostmassstorage/server/controller/include/cusbhostmsdevicethread.h
author sl@SLION-WIN7.fritz.box
Fri, 15 Jun 2012 03:10:57 +0200
changeset 0 bde4ae8d615e
permissions -rw-r--r--
First public contribution.
sl@0
     1
/*
sl@0
     2
* Copyright (c) 2009 Nokia Corporation and/or its subsidiary(-ies).
sl@0
     3
* All rights reserved.
sl@0
     4
* This component and the accompanying materials are made available
sl@0
     5
* under the terms of the License "Eclipse Public License v1.0"
sl@0
     6
* which accompanies this distribution, and is available
sl@0
     7
* at the URL "http://www.eclipse.org/legal/epl-v10.html".
sl@0
     8
*
sl@0
     9
* Initial Contributors:
sl@0
    10
* Nokia Corporation - initial contribution.
sl@0
    11
*
sl@0
    12
* Contributors:
sl@0
    13
*
sl@0
    14
* Description:
sl@0
    15
*
sl@0
    16
*/
sl@0
    17
/**
sl@0
    18
 Implements a thread per device functionality
sl@0
    19
 */
sl@0
    20
sl@0
    21
/** @file
sl@0
    22
@internalTechnology
sl@0
    23
*/
sl@0
    24
sl@0
    25
#ifndef CUSBMASSSTORAGEDEVICETHREAD_H
sl@0
    26
#define CUSBMASSSTORAGEDEVICETHREAD_H
sl@0
    27
sl@0
    28
sl@0
    29
class TDeviceHandler
sl@0
    30
    {
sl@0
    31
public:
sl@0
    32
    TDeviceHandler(CUsbHostMsDevice& aDevice);
sl@0
    33
	void HandleMessageL(const RMessage2& aMessage);
sl@0
    34
sl@0
    35
private:
sl@0
    36
    CUsbHostMsDevice& iDevice;
sl@0
    37
    };
sl@0
    38
sl@0
    39
sl@0
    40
class TLogicalUnitHandler
sl@0
    41
    {
sl@0
    42
public:
sl@0
    43
    TLogicalUnitHandler(CUsbHostMsLogicalUnit& aLu);
sl@0
    44
	void HandleMessageL(const RMessage2& aMessage);
sl@0
    45
sl@0
    46
private:
sl@0
    47
	CUsbHostMsLogicalUnit& iLu;
sl@0
    48
    };
sl@0
    49
sl@0
    50
class CUsbHostMsSession;
sl@0
    51
sl@0
    52
class CUsbHostMsDeviceThread : public CActive
sl@0
    53
    {
sl@0
    54
public:
sl@0
    55
    static const TInt KMaxNumMessage = 32;
sl@0
    56
sl@0
    57
	static CUsbHostMsDeviceThread* NewL(CUsbHostMsSession& aUsbHostMsSession, TUint aToken);
sl@0
    58
	~CUsbHostMsDeviceThread();
sl@0
    59
sl@0
    60
private:
sl@0
    61
    CUsbHostMsDeviceThread(CUsbHostMsSession& aUsbHostMsSession, TUint aToken);
sl@0
    62
sl@0
    63
public:
sl@0
    64
	static TInt Entry(TAny* aPtr);
sl@0
    65
	TInt QueueMsg(const RMessage2& aMsg);
sl@0
    66
    void Lock();
sl@0
    67
    void Unlock();
sl@0
    68
sl@0
    69
sl@0
    70
private:
sl@0
    71
    void Start();
sl@0
    72
sl@0
    73
	void RunL();
sl@0
    74
	void DoCancel();
sl@0
    75
    TInt RunError(TInt aError);
sl@0
    76
sl@0
    77
	void HandleMessage(const RMessage2& aMessage);
sl@0
    78
sl@0
    79
	void UnRegisterInterfaceL(const RMessage2& aMessage);
sl@0
    80
sl@0
    81
private:
sl@0
    82
    static void DoStartServerL(TAny* aPtr);
sl@0
    83
sl@0
    84
	void RegisterInterfaceL(const RMessage2& aMessage);
sl@0
    85
	void InitialiseInterfaceL(const RMessage2& aMessage);
sl@0
    86
	void GetNumLunL(const RMessage2& aMessage);
sl@0
    87
	void RegisterLogicalUnitL(const RMessage2& aMessage);
sl@0
    88
	TInt Shutdown();
sl@0
    89
sl@0
    90
private:
sl@0
    91
    CUsbHostMsSession& iUsbHostMsSession;
sl@0
    92
sl@0
    93
	CUsbHostMsDevice* iUsbHostMsDevice;
sl@0
    94
sl@0
    95
	RMessage2 iRMessage2[KMaxNumMessage];
sl@0
    96
	RMutex iMutex;
sl@0
    97
sl@0
    98
	TInt iQueueIndex;
sl@0
    99
	TInt iDequeueIndex;
sl@0
   100
	TBool iQueueFull;
sl@0
   101
    };
sl@0
   102
sl@0
   103
sl@0
   104
inline void CUsbHostMsDeviceThread::Lock()
sl@0
   105
	{
sl@0
   106
	iMutex.Wait();
sl@0
   107
	}
sl@0
   108
sl@0
   109
sl@0
   110
inline void CUsbHostMsDeviceThread::Unlock()
sl@0
   111
	{
sl@0
   112
	iMutex.Signal();
sl@0
   113
	}
sl@0
   114
sl@0
   115
sl@0
   116
#endif // CUSBMASSSTORAGEDEVICETHREAD_H