|
300
|
1 |
// Copyright (c) 2008-2010 Nokia Corporation and/or its subsidiary(-ies).
|
|
0
|
2 |
// All rights reserved.
|
|
|
3 |
// This component and the accompanying materials are made available
|
|
|
4 |
// under the terms of the License "Eclipse Public License v1.0"
|
|
|
5 |
// which accompanies this distribution, and is available
|
|
|
6 |
// at the URL "http://www.eclipse.org/legal/epl-v10.html".
|
|
|
7 |
//
|
|
|
8 |
// Initial Contributors:
|
|
|
9 |
// Nokia Corporation - initial contribution.
|
|
|
10 |
//
|
|
|
11 |
// Contributors:
|
|
|
12 |
//
|
|
|
13 |
// Description:
|
|
|
14 |
//
|
|
|
15 |
|
|
|
16 |
/**
|
|
|
17 |
@file
|
|
|
18 |
@internalTechnology
|
|
|
19 |
*/
|
|
|
20 |
|
|
|
21 |
#include <e32base.h>
|
|
|
22 |
|
|
|
23 |
#include "shared.h"
|
|
|
24 |
#include "msgservice.h"
|
|
|
25 |
#include "msctypes.h"
|
|
|
26 |
|
|
|
27 |
#include "mprotocol.h"
|
|
|
28 |
#include "mblocktransferprotocol.h"
|
|
|
29 |
#include "tspcclientinterface.h"
|
|
|
30 |
#include "cscsiprotocol.h"
|
|
|
31 |
|
|
|
32 |
#include "cusbhostmslogicalunit.h"
|
|
|
33 |
#include "usbmshostpanic.h"
|
|
|
34 |
|
|
300
|
35 |
#include "OstTraceDefinitions.h"
|
|
|
36 |
#ifdef OST_TRACE_COMPILER_IN_USE
|
|
|
37 |
#include "cusbhostmslogicalunitTraces.h"
|
|
|
38 |
#endif
|
|
0
|
39 |
|
|
|
40 |
CUsbHostMsLogicalUnit* CUsbHostMsLogicalUnit::NewL(TLun aLun)
|
|
|
41 |
{
|
|
300
|
42 |
CUsbHostMsLogicalUnit* r = new (ELeave) CUsbHostMsLogicalUnit(aLun);
|
|
|
43 |
CleanupStack::PushL(r);
|
|
|
44 |
r->ConstructL();
|
|
|
45 |
CleanupStack::Pop();
|
|
|
46 |
return r;
|
|
|
47 |
}
|
|
0
|
48 |
|
|
|
49 |
|
|
|
50 |
void CUsbHostMsLogicalUnit::ConstructL()
|
|
|
51 |
{
|
|
|
52 |
const TInt KInitialDataBufSize = 0x200;
|
|
300
|
53 |
iDataBuf.CreateL(KInitialDataBufSize);
|
|
0
|
54 |
}
|
|
|
55 |
|
|
|
56 |
|
|
|
57 |
CUsbHostMsLogicalUnit::CUsbHostMsLogicalUnit(TLun aLun)
|
|
|
58 |
: iProtocol(NULL),
|
|
|
59 |
iLun(aLun),
|
|
300
|
60 |
iSuspendRequest(EFalse)
|
|
0
|
61 |
{
|
|
300
|
62 |
}
|
|
0
|
63 |
|
|
|
64 |
CUsbHostMsLogicalUnit::~CUsbHostMsLogicalUnit()
|
|
|
65 |
{
|
|
|
66 |
iDataBuf.Close();
|
|
300
|
67 |
delete iProtocol;
|
|
|
68 |
}
|
|
0
|
69 |
|
|
|
70 |
|
|
|
71 |
void CUsbHostMsLogicalUnit::InitL()
|
|
|
72 |
{
|
|
300
|
73 |
iProtocol->InitialiseUnitL();
|
|
0
|
74 |
}
|
|
|
75 |
|
|
|
76 |
void CUsbHostMsLogicalUnit::UnInitL()
|
|
|
77 |
{
|
|
300
|
78 |
iProtocol->UninitialiseUnitL();
|
|
0
|
79 |
}
|
|
|
80 |
|
|
|
81 |
void CUsbHostMsLogicalUnit::ReadL(const RMessage2& aMessage)
|
|
|
82 |
{
|
|
300
|
83 |
TReadWrite p;
|
|
|
84 |
TPtr8 pReadWrite((TUint8*)&p,sizeof(TReadWrite));
|
|
|
85 |
aMessage.ReadL(0, pReadWrite);
|
|
|
86 |
OstTraceExt3(TRACE_SHOSTMASSSTORAGE_HOST, CUSBHOSTMSLOGICALUNIT_10,
|
|
|
87 |
"pos = 0x%x %x len = %08x", I64HIGH(p.iPos), I64LOW(p.iPos), p.iLen);
|
|
0
|
88 |
|
|
|
89 |
User::LeaveIfError(CheckPosition(p));
|
|
|
90 |
|
|
300
|
91 |
// check if buffer can hold requested data and resize if not
|
|
|
92 |
if (iDataBuf.MaxLength() < p.iLen)
|
|
0
|
93 |
iDataBuf.ReAllocL(p.iLen);
|
|
|
94 |
|
|
|
95 |
iProtocol->ReadL(p.iPos, iDataBuf, p.iLen);
|
|
|
96 |
aMessage.WriteL(1, iDataBuf);
|
|
|
97 |
}
|
|
|
98 |
|
|
|
99 |
|
|
|
100 |
void CUsbHostMsLogicalUnit::WriteL(const RMessage2& aMessage)
|
|
|
101 |
{
|
|
300
|
102 |
TReadWrite p;
|
|
|
103 |
TPtr8 pReadWrite((TUint8*)&p,sizeof(TReadWrite));
|
|
|
104 |
aMessage.ReadL(1, pReadWrite);
|
|
|
105 |
OstTraceExt3(TRACE_SHOSTMASSSTORAGE_HOST, CUSBHOSTMSLOGICALUNIT_11,
|
|
|
106 |
"pos = 0x%x %x len = %08x", I64HIGH(p.iPos), I64LOW(p.iPos), p.iLen);
|
|
0
|
107 |
|
|
|
108 |
User::LeaveIfError(CheckPosition(p));
|
|
|
109 |
|
|
|
110 |
// check if buffer can hold requested data and resize if not
|
|
|
111 |
if (iDataBuf.MaxLength() < p.iLen)
|
|
|
112 |
iDataBuf.ReAllocL(p.iLen);
|
|
|
113 |
|
|
300
|
114 |
aMessage.ReadL(0, iDataBuf);
|
|
|
115 |
iProtocol->WriteL(p.iPos, iDataBuf, p.iLen);
|
|
0
|
116 |
}
|
|
|
117 |
|
|
|
118 |
|
|
|
119 |
void CUsbHostMsLogicalUnit::EraseL(const RMessage2& aMessage)
|
|
|
120 |
{
|
|
300
|
121 |
TReadWrite p;
|
|
|
122 |
TPtr8 pReadWrite((TUint8*)&p,sizeof(TReadWrite));
|
|
|
123 |
aMessage.ReadL(0, pReadWrite);
|
|
|
124 |
OstTraceExt3(TRACE_SHOSTMASSSTORAGE_HOST, CUSBHOSTMSLOGICALUNIT_12,
|
|
|
125 |
"pos = 0x%x %x len = %08x", I64HIGH(p.iPos), I64LOW(p.iPos), p.iLen);
|
|
0
|
126 |
|
|
|
127 |
User::LeaveIfError(CheckPosition(p));
|
|
|
128 |
|
|
|
129 |
// check if buffer can hold requested data and resize if not
|
|
|
130 |
if (iDataBuf.MaxLength() < p.iLen)
|
|
|
131 |
iDataBuf.ReAllocL(p.iLen);
|
|
|
132 |
|
|
|
133 |
iDataBuf.FillZ(p.iLen);
|
|
300
|
134 |
iProtocol->WriteL(p.iPos, iDataBuf, p.iLen);
|
|
0
|
135 |
}
|
|
|
136 |
|
|
|
137 |
|
|
|
138 |
void CUsbHostMsLogicalUnit::CapsL(const RMessage2& aMessage)
|
|
|
139 |
{
|
|
|
140 |
TCapsInfo capsInfo;
|
|
|
141 |
TPckg<TCapsInfo> pckg(capsInfo);
|
|
300
|
142 |
iProtocol->GetCapacityL(capsInfo);
|
|
0
|
143 |
iSize = static_cast<TInt64>(capsInfo.iNumberOfBlocks) * capsInfo.iBlockLength;
|
|
300
|
144 |
aMessage.WriteL(0, pckg);
|
|
0
|
145 |
}
|
|
|
146 |
|
|
|
147 |
void CUsbHostMsLogicalUnit::NotifyChange(const RMessage2& aMessage)
|
|
|
148 |
{
|
|
300
|
149 |
iProtocol->NotifyChange(aMessage);
|
|
0
|
150 |
}
|
|
|
151 |
|
|
|
152 |
|
|
|
153 |
void CUsbHostMsLogicalUnit::ForceCompleteNotifyChangeL()
|
|
|
154 |
{
|
|
300
|
155 |
iProtocol->ForceCompleteNotifyChangeL();
|
|
0
|
156 |
}
|
|
|
157 |
|
|
|
158 |
void CUsbHostMsLogicalUnit::CancelChangeNotifierL()
|
|
|
159 |
{
|
|
300
|
160 |
iProtocol->CancelChangeNotifierL();
|
|
0
|
161 |
}
|
|
|
162 |
|
|
|
163 |
TBool CUsbHostMsLogicalUnit::IsConnected()
|
|
300
|
164 |
{
|
|
|
165 |
return iProtocol->IsConnected() ? ETrue : EFalse;
|
|
|
166 |
}
|
|
0
|
167 |
|
|
|
168 |
TBool CUsbHostMsLogicalUnit::IsReadyToSuspend()
|
|
|
169 |
{
|
|
300
|
170 |
return iSuspendRequest ? ETrue : EFalse;
|
|
|
171 |
}
|
|
0
|
172 |
|
|
|
173 |
void CUsbHostMsLogicalUnit::ReadyToSuspend()
|
|
|
174 |
{
|
|
300
|
175 |
iSuspendRequest = ETrue;
|
|
0
|
176 |
}
|
|
|
177 |
|
|
|
178 |
void CUsbHostMsLogicalUnit::CancelReadyToSuspend()
|
|
|
179 |
{
|
|
300
|
180 |
iSuspendRequest = EFalse;
|
|
0
|
181 |
}
|
|
|
182 |
|
|
|
183 |
void CUsbHostMsLogicalUnit::SuspendL()
|
|
|
184 |
{
|
|
300
|
185 |
iProtocol->SuspendL();
|
|
0
|
186 |
}
|
|
|
187 |
|
|
|
188 |
void CUsbHostMsLogicalUnit::ResumeL()
|
|
300
|
189 |
{
|
|
|
190 |
// We do not cancel iSuspendRequest here
|
|
|
191 |
iProtocol->ResumeL();
|
|
|
192 |
}
|
|
0
|
193 |
|
|
|
194 |
void CUsbHostMsLogicalUnit::DoLunReadyCheckL()
|
|
|
195 |
{
|
|
300
|
196 |
iProtocol->DoScsiReadyCheckEventL();
|
|
0
|
197 |
}
|
|
|
198 |
|
|
|
199 |
TInt CUsbHostMsLogicalUnit::InitialiseProtocolL(TLun aLun,
|
|
|
200 |
THostMassStorageConfig& aConfig,
|
|
|
201 |
MTransport& aTransport)
|
|
|
202 |
{
|
|
|
203 |
__ASSERT_DEBUG(iProtocol == NULL, User::Panic(KUsbMsHostPanicCat, EProtocolNotFree));
|
|
300
|
204 |
switch(aConfig.iProtocolId)
|
|
0
|
205 |
{
|
|
300
|
206 |
case ScsiProtocol:
|
|
|
207 |
iProtocol = CScsiProtocol::NewL(aLun, aTransport);
|
|
|
208 |
break;
|
|
|
209 |
default:
|
|
|
210 |
OstTrace0(TRACE_SHOSTMASSSTORAGE_HOST, CUSBHOSTMSLOGICALUNIT_13,
|
|
|
211 |
"Unsupported Transport class requested");
|
|
|
212 |
iProtocol = NULL;
|
|
|
213 |
return KErrNotSupported;
|
|
0
|
214 |
}
|
|
300
|
215 |
return KErrNone;
|
|
0
|
216 |
}
|
|
|
217 |
|
|
|
218 |
TInt CUsbHostMsLogicalUnit::CheckPosition(const TReadWrite& aReadWrite)
|
|
|
219 |
{
|
|
|
220 |
if (aReadWrite.iLen == 0)
|
|
|
221 |
{
|
|
|
222 |
if (aReadWrite.iPos == iSize)
|
|
|
223 |
return KErrEof;
|
|
|
224 |
else
|
|
|
225 |
return KErrArgument;
|
|
|
226 |
}
|
|
|
227 |
|
|
300
|
228 |
// detect drive not present
|
|
|
229 |
if (iSize == 0)
|
|
|
230 |
return KErrNotReady;
|
|
0
|
231 |
|
|
|
232 |
if (aReadWrite.iPos >= iSize)
|
|
|
233 |
return KErrArgument;
|
|
|
234 |
return KErrNone;
|
|
|
235 |
}
|