source: trunk/Include/Classes/System/IO/FileStream.ab@ 319

Last change on this file since 319 was 289, checked in by dai, 17 years ago

タイプミスを修正。

File size: 9.6 KB
Line 
1Namespace System
2Namespace IO
3
4
5/* ほんとはmiscに入れるかかファイルを分けたほうがいいかもしれないが一先ず実装 */
6Enum FileOptions
7 Asynchronous
8 DeleteOnClose
9 Encrypted
10 None
11 RandomAccess
12 SequentialScan
13 WriteThrough
14End Enum
15
16Class FileStream
17 Inherits Stream
18
19 handle As HANDLE
20
21 /*
22 ファイルハンドルからこれらを取得できれば、これらは入らないが
23 今のところは不明なので自前で実装するしかない
24 */
25 filePath As String
26 fileMode As DWord
27 fileAccess As DWord
28 fileShare As DWord
29 fileOptions As DWord
30
31 /* 現在は未使用 */
32 /*Overlapped As OVERLAPPED*/
33
34Public
35 /* コンストラクタ.NETと同じように実装は難しい、一先ず動くものを実装したが変更が必要だと思う */
36 Sub FileStream(path As String, mode As FileMode, access As FileAccess, share As FileShare, options As FileOptions)
37 Dim ac As DWord
38 Dim mo As DWord
39 Dim sh As DWord
40 Dim op As DWord
41
42 Select Case access
43 Case FileAccess.Read
44 ac=GENERIC_READ
45 Case FileAccess.ReadWrite
46 ac=GENERIC_READ or GENERIC_WRITE
47 Case FileAccess.Write
48 ac=GENERIC_WRITE
49 End Select
50
51 Select Case share
52 Case FileShare.DeleteFile
53 sh=FILE_SHARE_DELETE
54 Case FileShare.None
55 sh=0
56 Case FileShare.Read
57 sh=FILE_SHARE_READ
58 Case FileShare.ReadWrite
59 sh=FILE_SHARE_READ or FILE_SHARE_WRITE
60 Case FileShare.Write
61 sh=FILE_SHARE_WRITE
62 End Select
63
64 Select Case mode
65 Case FileMode.Append
66 mo=OPEN_ALWAYS
67 Case FileMode.Create
68 mo=CREATE_ALWAYS
69 Case FileMode.CreateNew
70 mo=CREATE_NEW
71 Case FileMode.Open
72 mo=OPEN_EXISTING
73 Case FileMode.OpenOrCreate
74 mo=OPEN_ALWAYS
75 Case FileMode.Truncate
76 mo=TRUNCATE_EXISTING
77 End Select
78
79 Select Case options
80 Case FileOptions.Asynchronous
81 op=FILE_FLAG_OVERLAPPED
82 Case FileOptions.DeleteOnClose
83 op=FILE_FLAG_DELETE_ON_CLOSE
84 Case FileOptions.Encrypted
85 Case FileOptions.None
86 op=0
87 Case FileOptions.RandomAccess
88 op=FILE_FLAG_RANDOM_ACCESS
89 Case FileOptions.SequentialScan
90 op=FILE_FLAG_SEQUENTIAL_SCAN
91 Case FileOptions.WriteThrough
92 op=FILE_FLAG_WRITE_THROUGH
93 End Select
94
95 This.handle=CreateFile(path As PSTR,ac,sh,ByVal NULL,mo,op,0)
96 If This.handle=INVALID_HANDLE_VALUE Then
97 'エラー処理
98 'Throw ArgumentException
99 'Throw IOException
100 'Throw System.IO.FileNotFoundException
101 This.handle=0
102 Exit Sub
103 End If
104
105 filePath = path
106 fileMode = mo
107 fileAccess = ac
108 fileShare = sh
109 fileOptions = op
110 End Sub
111 Sub FileStream(path As String, mode As FileMode, access As FileAccess, share As FileShare)
112 FileStream(path,mode,access,share,FileOptions.None)
113 End Sub
114 Sub FileStream(path As String, mode As FileMode, access As FileAccess)
115 FileStream(path,mode,access,FileShare.None,FileOptions.None)
116 End Sub
117 Sub FileStream(path As String, mode As FileMode)
118 Dim access As FileAccess
119 Select Case mode
120 Case FileMode.Append
121 access=FileAccess.Write
122 Case FileMode.Create
123 access=FileAccess.ReadWrite
124 Case FileMode.CreateNew
125 access=FileAccess.ReadWrite
126 Case FileMode.Open
127 access=FileAccess.ReadWrite
128 Case FileMode.OpenOrCreate
129 access=FileAccess.ReadWrite
130 Case FileMode.Truncate
131 access=FileAccess.Write
132 End Select
133 FileStream(path,mode,access,FileShare.None,FileOptions.None)
134 End Sub
135
136 Sub ~FileStream()
137 This.Flush()
138 This.Close()
139 End Sub
140
141Public
142 Override Function CanRead() As Boolean
143 /* ファイルが読み込みに対応しているかを返す */
144 If fileAccess=GENERIC_READ/*FileAccess.Read*/ or fileAccess=GENERIC_READ or GENERIC_WRITE/*FileAccess.ReadWrite*/ Then
145 Return True
146 Else
147 Return False
148 End If
149 End Function
150
151 Override Function CanSeek() As Boolean
152 /* ファイルがシークに対応しているかを返す */
153 Return True
154 End Function
155
156 Override Function CanTimeout() As Boolean
157 /* ファイルがタイムアウトに対応しているかを返す */
158 Return False /*今のところ対応していないのでFalse*/
159 End Function
160
161 Override Function CanWrite() As Boolean
162 /* ファイルが書き込みに対応しているかを返す */
163 If fileAccess=GENERIC_WRITE/*FileAccess.Write*/ or fileAccess=GENERIC_READ or GENERIC_WRITE/*FileAccess.ReadWrite*/ Then
164 Return True
165 Else
166 Return False
167 End If
168 End Function
169
170 /*Handle*/
171
172 Function IsAsync() As Boolean
173 /* ファイルが非同期操作に対応しているかを返す */
174 If fileOptions=FILE_FLAG_OVERLAPPED/*FileOptions.Asynchronous*/ Then
175 Return True
176 Else
177 Return False
178 End If
179 End Function
180
181 Override Function Length() As Int64
182 /* ファイルのサイズの取得 */
183 Dim s As LARGE_INTEGER
184 s.LowPart=GetFileSize(This.handle,VarPtr(s.HighPart) As *DWord)
185 memcpy(VarPtr(Length),VarPtr(s),SizeOf(LARGE_INTEGER))
186 End Function
187
188 Function Name() As String
189 /* 多分文字列をコピーして返す方がいいのと思うが。。。*/
190 Return filePath
191 End Function
192
193 Override Sub Position(value As Int64)
194 /* ファイルポインタの位置の設定 */
195 Dim o As LARGE_INTEGER
196 memcpy(VarPtr(o),VarPtr(value),SizeOf(LARGE_INTEGER))
197 If o.HighPart=0 And value<0 Then
198 o.LowPart=-Abs(o.LowPart) As Long
199 End If
200 Dim ret As LARGE_INTEGER
201 SetFilePointer(This.handle,o.LowPart,VarPtr(o.HighPart) As *DWord,FILE_CURRENT)
202 End Sub
203 Override Function Position() As Int64
204 /* ファイルポインタの位置の取得 */
205 Dim o As LARGE_INTEGER
206 o.HighPart=0
207 o.LowPart=0
208 o.LowPart=SetFilePointer(This.handle,0,VarPtr(o.HighPart) As *DWord,FILE_CURRENT)
209 memcpy(VarPtr(Position),VarPtr(o),SizeOf(LARGE_INTEGER))
210 End Function
211
212 Override Sub ReadTimeout(value As Long)
213 'TODO
214 End Sub
215 Override Function ReadTimeout() As Long
216 'TODO
217 End Function
218
219 /* Safe~Handle系の実装は要相談!! */
220/* Function SafeFileHandle() As SafeFileHandle
221 End Function*/
222
223 Override Sub WriteTimeout(value As Long)
224 'TODO
225 End Sub
226 Override Function WriteTimeout() As Long
227 'TODO
228 End Function
229
230
231Public
232 Override Function BeginRead(ByRef buffer[] As Byte, offset As Long, count As Long, callback As AsyncCallback, state As Object) As System.IAsyncResult
233 'TODO
234 End Function
235
236 Override Function BeginWrite(ByRef buffer[] As Byte, offset As Long, count As Long, callback As AsyncCallback, state As Object) As System.IAsyncResult
237 'TODO
238 End Function
239
240 Override Sub Close()
241 CloseHandle(This.handle)
242 End Sub
243
244/* CreateObjRef*/
245/* Dispose*/
246
247 Override Sub EndRead(ByRef asyncResult As System.IAsyncResult)
248 'TODO
249 End Sub
250
251 Override Sub EndWrite(ByRef asyncResult As System.IAsyncResult)
252 'TODO
253 End Sub
254
255/* Equals*/
256
257 Override Sub Flush()
258 FlushFileBuffers(This.handle)
259 End Sub
260
261/* Function GetAccessControl() As FileSecurity
262 FileSecurityの実装がまだできてない。
263 End Function*/
264
265 Override Function GetHashCode() As Long
266 Return ObjPtr(This) As Long
267 End Function
268
269/* GetLifetimeService*/
270
271/* Override Function GetType() As TypeInfo
272 Return Super.GetType()
273 End Function*/
274
275/* InitializeLifetimeService*/
276
277 Sub Lock(position As Int64, length As Int64)
278 Dim p As LARGE_INTEGER
279 Dim l As LARGE_INTEGER
280 memcpy(VarPtr(p),VarPtr(position),SizeOf(LARGE_INTEGER))
281 memcpy(VarPtr(l),VarPtr(length),SizeOf(LARGE_INTEGER))
282 LockFile(This.handle,p.LowPart,p.HighPart,l.LowPart,l.HighPart)
283 End Sub
284
285 Override Function Read(ByRef buffer[] As Byte, offset As Long, count As Long) As Long
286 If offset Then
287 SetFilePointer(This.handle,offset,NULL,FILE_CURRENT)
288 End If
289 ReadFile(This.handle,buffer,count,VarPtr(Read) As *DWord,ByVal NULL)
290 End Function
291
292 Override Function ReadByte() As Long
293 Dim b As Byte
294 Dim ret = Read(b, 0, 1)
295 If ret <> 0 Then
296 Return b As Long
297 Else
298 Return -1
299 End If
300 End Function
301/* ReferenceEquals*/
302
303 Override Function Seek(offset As Int64, origin As SeekOrigin) As Long
304 Dim o As LARGE_INTEGER
305 memcpy(VarPtr(o),VarPtr(offset),SizeOf(LARGE_INTEGER))
306 If o.HighPart=0 And offset<0 Then
307 o.LowPart=-o.LowPart
308 End If
309 Select Case origin
310 Case SeekOrigin.Begin
311 SetFilePointer(This.handle,o.LowPart,VarPtr(o.HighPart) As *DWord,FILE_BEGIN)
312 Case SeekOrigin.Current
313 SetFilePointer(This.handle,o.LowPart,VarPtr(o.HighPart) As *DWord,FILE_CURRENT)
314 Case SeekOrigin.End
315 SetFilePointer(This.handle,o.LowPart,VarPtr(o.HighPart) As *DWord,FILE_END)
316 End Select
317 End Function
318
319/* Sub SetAccessControl(fileSecurity As FileSecurity)
320 FileSecurityの実装がまだできてない。
321 End Sub*/
322
323 Override Sub SetLength(value As Int64)
324 Dim o As LARGE_INTEGER
325 memcpy(VarPtr(o),VarPtr(value),SizeOf(LARGE_INTEGER))
326 If o.HighPart=0 And value<0 Then
327 o.LowPart=-o.LowPart
328 End If
329 If Length()=>value Then
330 SetFilePointer(This.handle,o.LowPart,VarPtr(o.HighPart) As *DWord,FILE_BEGIN)
331 SetEndOfFile(This.handle)
332 End If
333 End Sub
334
335/* Synchronized*/
336
337 Override Function ToString() As String
338 Return Name()
339 End Function
340
341 Sub Unlock(position As Int64, length As Int64)
342 Dim p As LARGE_INTEGER
343 Dim l As LARGE_INTEGER
344 memcpy(VarPtr(p),VarPtr(position),SizeOf(LARGE_INTEGER))
345 memcpy(VarPtr(l),VarPtr(length),SizeOf(LARGE_INTEGER))
346 UnlockFile(This.handle,p.LowPart,p.HighPart,l.LowPart,l.HighPart)
347 End Sub
348
349 Override Sub Write(ByRef buffer[] As Byte, offset As Long, count As Long)
350 If offset Then
351 SetFilePointer(This.handle,offset,NULL,FILE_CURRENT)
352 End If
353 Dim ret As DWord
354 WriteFile(This.handle,buffer,count,VarPtr(ret),ByVal NULL)
355 End Sub
356
357 Override Sub WriteByte(b As Byte)
358 Write(b, 0, 1)
359 End Sub
360
361Protected
362 /*非同期ファイル操作に必須だがどうやって実装しようか検討中*/
363 Override Function CreateWaitHandle() As System.Threading.WaitHandle
364' Return Nothing
365 End Function
366
367/* Dispose
368 Finalize
369 MemberwiseClone*/
370End Class
371
372
373End Namespace
374End Namespace
Note: See TracBrowser for help on using the repository browser.