Changeset 256 for Include/Classes/System/IO/FileStream.ab

Timestamp:

May 18, 2007, 4:57:00 PM (17 years ago)

Author:

NoWest

Message:

同期的なファイル読み込み、書き込みは何とか動くようになってきたが、まだ完成度は4割くらいだと思う。
コンストラクタも改善の余地あり。

File:

• Include/Classes/System/IO/FileStream.ab (modified) (1 diff)

Include/Classes/System/IO/FileStream.ab

@@ +1 @@
+
+/* ほんとはmiscかファイルを分けたほうがいいかもしれないが一先ず実装 */
+Enum FileOptions
+    Asynchronous
+    DeleteOnClose
+    Encrypted
+    None
+    RandomAccess
+    SequentialScan
+    WriteThrough 
+End Enum
+
 Class FileStream
-    ' TODO: 実装
+    Inherits Stream
+
+    handle As HANDLE
+
+    /*
+    ファイルハンドルからこれらを取得できれば入らないが
+    今のところは不明なので自前で実装するしかない
+    */
+    filePath As String
+    fileMode As DWord
+    fileAccess As DWord
+    fileShare As DWord
+    fileOptions As DWord
+
+    /* 現在は未使用 */
+    /*Overlapped As OVERLAPPED*/
+
+Public
+    /* コンストラクタ.NETと同じように実装は難しい、一先ず動くものを実装したが要変更だと思う */
+    Sub FileStream(path As String, mode As FileMode, access As FileAccess, share As FileShare, options As FileOptions)
+        Dim acc As DWord
+        Dim mod As DWord
+        Dim sha As DWord
+        Dim opt As DWord
+
+        Select Case access
+            Case FileAccess.Read
+                acc=GENERIC_READ
+            Case FileAccess.ReadWrite
+                acc=GENERIC_READ or GENERIC_WRITE
+            Case FileAccess.Write
+                acc=GENERIC_WRITE
+        End Select
+
+        Select Case share
+            Case FileShare.DeleteFile
+                sha=FILE_SHARE_DELETE
+            Case FileShare.None
+                sha=0
+            Case FileShare.Read
+                sha=FILE_SHARE_READ
+            Case FileShare.ReadWrite
+                sha=FILE_SHARE_READ or FILE_SHARE_WRITE
+            Case Write
+                sha=FILE_SHARE_WRITE
+        End Select
+
+        Select Case mode
+            Case FileMode.Append
+                mo=OPEN_ALWAYS
+            Case FileMode.Create
+                mo=CREATE_ALWAYS
+            Case FileMode.CreateNew
+                mo=CREATE_NEW
+            Case FileMode.Open
+                mo=OPEN_EXISTING
+            Case FileMode.OpenOrCreate
+                mo=OPEN_ALWAYS
+            Case FileMode.Truncate
+                mo=TRUNCATE_EXISTING
+        End Select
+
+        Select Case options
+            Case FileOption.Asynchronous
+                opt=FILE_FLAG_OVERLAPPED
+            Case FileOptions.DeleteOnClose
+                opt=FILE_FLAG_DELETE_ON_CLOSE
+            Case FileOptions.Encrypted
+            Case FileOptions.None
+                opt=0
+            Case FileOptions.RandomAccess
+                opt=FILE_FLAG_RANDOM_ACCESS
+            Case FileOptions.SequentialScan
+                opt=FILE_FLAG_SEQUENTIAL_SCAN
+            Case FileOptions.WriteThrough
+                opt=FILE_FLAG_WRITE_THROUGH
+        End Select
+
+        This.handle=CreateFile(path.Chars As PSTR,acc,sha,ByVal NULL,mo,opt,0)
+        If This.handle=HANDLE_INVALIDATE Then
+        'エラー処理
+        'Throw ArgumentException
+        'Throw IOException
+        'Throw System.IO.FileNotFoundException 
+            Exit Sub
+        End If
+
+        fileMode = mod
+        fileAccess = acc
+        fileShare = sha
+        fileOptions = opt
+    End Sub
+    Sub FileStream(path As String, mode As FileMode)
+        Dim acc As DWord
+        Dim mo As DWord
+        Select Case mode
+            Case FileMode.Append
+                acc=GENERIC_WRITE
+                mo=OPEN_ALWAYS
+'               OutputDebugString(Ex"append\n")
+            Case FileMode.Create
+                acc=GENERIC_READ or GENERIC_WRITE
+                mo=CREATE_ALWAYS
+'               OutputDebugString(Ex"create\n")
+            Case FileMode.CreateNew
+                acc=GENERIC_READ or GENERIC_WRITE
+                mo=CREATE_NEW
+'               OutputDebugString(Ex"create new\n")
+            Case FileMode.Open
+                acc=GENERIC_READ or GENERIC_WRITE
+                mo=OPEN_EXISTING
+'               OutputDebugString(Ex"open\n")
+            Case FileMode.OpenOrCreate
+                acc=GENERIC_READ or GENERIC_WRITE
+                mo=OPEN_ALWAYS
+'               OutputDebugString(Ex"open or create\n")
+            Case FileMode.Truncate
+                acc=GENERIC_WRITE
+                mo=TRUNCATE_EXISTING
+'               OutputDebugString(Ex"truncate\n")
+        End Select
+
+        'ファイルを作成または開く
+        This.handle=CreateFile(path.Chars As PSTR,acc,0,ByVal NULL,mo,0,0)
+
+        'エラー処理
+        'Throw ArgumentException
+        'Throw IOException
+        'Throw System.IO.FileNotFoundException 
+
+
+        'ファイルを作成または開いた後の処理
+        If mode=FileMode.Append Then
+            SetFilePointer(This.handle,0,NULL,FILE_END)
+        End If
+    End Sub
+
+    Sub ~FileStream()
+        This.Flush()
+        This.Close()
+    End Sub
+
+Public
+    Override Function CanRead() As Boolean
+        /* ファイルが読み込みに対応しているかを返す */
+        If fileAccess=GENERIC_READ/*FileAccess.Read*/ or fileAccess=GENERIC_READ or GENERIC_WRITE/*FileAccess.ReadWrite*/ Then
+            Return True
+        Else
+            Return False
+        End If
+    End Function
+
+    Override Function CanSeek() As Boolean
+        /* ファイルがシークに対応しているかを返す */
+        Return True
+    End Function
+
+    Override Function CanTimeout() As Boolean
+        /* ファイルがタイムアウトに対応しているかを返す */
+        Return False /*今のところ対応していないのでFalse*/
+    End Function
+
+    Override Function CanWrite() As Boolean
+        /* ファイルが書き込みに対応しているかを返す */
+        If fileAccess=GENERIC_WRITE/*FileAccess.Write*/ or fileAccess=GENERIC_READ or GENERIC_WRITE/*FileAccess.ReadWrite*/ Then
+            Return True
+        Else
+            Return False
+        End If
+    End Function
+
+    /*Handle*/
+
+    Function IsAsync() As Boolean
+        /* ファイルが非同期操作に対応しているかを返す */
+        If fileOptions=FILE_FLAG_OVERLAPPED/*FileOptions.Asynchronous*/ Then
+            Return True
+        Else
+            Return False
+        End If
+    End Function
+
+    Override Function Length() As Int64
+        /* ファイルのサイズの取得 */
+        Dim s As LARGE_INTEGER
+        s.LowPart=GetFileSize(This.handle,VarPtr(s.HighPart) As *DWord)
+        memcpy(VarPtr(Length),VarPtr(s),SizeOf(LARGE_INTEGER))
+    End Function
+
+    Function Name() As String
+        /* 多分文字列をコピーして返す方がいいのと思うが。。。*/
+        Return filePath
+    End Function
+    
+    Override Sub Position(value As Int64)
+        /* ファイルポインタの位置の設定 */
+        Dim o As LARGE_INTEGER
+        memcpy(VarPtr(o),VarPtr(value),SizeOf(LARGE_INTEGER))
+        If o.HighPart=0 And value<0 Then
+            o.LowPart=-Abs(o.LowPart) As Long
+        End If
+        Dim ret As LARGE_INTEGER
+        SetFilePointer(This.handle,o.LowPart,VarPtr(o.HighPart) As *DWord,FILE_CURRENT)
+    End Sub
+    Override Function Position() As Int64
+        /* ファイルポインタの位置の取得 */
+        Dim o As LARGE_INTEGER
+        o.HighPart=0
+        o.LowPart=0
+        o.LowPart=SetFilePointer(This.handle,0,VarPtr(o.HighPart) As *DWord,FILE_CURRENT)
+        memcpy(VarPtr(Position),VarPtr(o),SizeOf(LARGE_INTEGER))
+    End Function
+
+    Override Sub ReadTimeout(value As Long)
+        'TODO
+    End Sub
+    Override Function ReadTimeout() As Long
+        'TODO
+    End Function
+
+    /* Safe～Handle系の実装は要相談！！ */
+/*  Function SafeFileHandle() As SafeFileHandle
+    End Function*/
+
+    Override Sub WriteTimeout(value As Long)
+        'TODO
+    End Sub
+    Override Function WriteTimeout() As Long
+        'TODO
+    End Function
+    
+
+Public
+    Override Function BeginRead(ByRef buffer[] As Byte, offset As Long, count As Long, callback As AsyncCallback, state As Object) As IAsyncResult
+        'TODO
+    End Function
+
+    Override Function BeginWrite(ByRef buffer[] As Byte, offset As Long, count As Long, callback As AsyncCallback, state As Object) As IAsyncResult
+        'TODO
+    End Function
+
+    Override Sub Close()
+        CloseHandle(This.handle)
+    End Sub
+
+/*  CreateObjRef*/
+/*  Dispose*/
+
+    Override Sub EndRead(ByRef asyncResult As IAsyncResult)
+        'TODO
+    End Sub
+
+    Override Sub EndWrite(ByRef asyncResult As IAsyncResult)
+        'TODO
+    End Sub
+
+/*  Equals*/
+
+    Override Sub Flush()
+        FlushFileBuffers(This.handle)
+    End Sub
+
+/*  Function GetAccessControl() As FileSecurity
+    FileSecurityの実装がまだできてない。
+    End Function*/
+
+    Override Function GetHashCode() As Long
+        Return ObjPtr(This) As Long
+    End Function
+
+/*  GetLifetimeService*/
+
+/*  Override Function GetType() As TypeInfo
+        Return Super.GetType()
+    End Function*/
+
+/*  InitializeLifetimeService*/
+
+    Sub Lock(position As Int64, length As Int64)
+        Dim p As LARGE_INTEGER
+        Dim l As LARGE_INTEGER
+        memcpy(VarPtr(p),VarPtr(position),SizeOf(LARGE_INTEGER))
+        memcpy(VarPtr(l),VarPtr(length),SizeOf(LARGE_INTEGER))
+        LockFile(This.handle,p.LowPart,p.HighPart,l.LowPart,l.HighPart)
+    End Sub
+
+    Override Function Read(ByRef buffer[] As Byte, offset As Long, count As Long) As Long
+        If offset Then
+            SetFilePointer(This.handle,offset,NULL,FILE_CURRENT)
+        End If
+        ReadFile(This.handle,buffer,count,VarPtr(Read) As *DWord,ByVal NULL)
+    End Function
+
+    Override Function ReadByte() As Long
+        Dim b As Byte
+        Dim ret = Read(b, 0, 1)
+        If ret <> 0 Then
+            Return b As Long
+        Else
+            Return -1
+        End If
+    End Function
+/*  ReferenceEquals*/
+
+    Override Function Seek(offset As Int64, origin As SeekOrigin) As Long
+        Dim o As LARGE_INTEGER
+        memcpy(VarPtr(o),VarPtr(offset),SizeOf(LARGE_INTEGER))
+        If o.HighPart=0 And offset<0 Then
+            o.LowPart=-o.LowPart
+        End If
+        Select Case origin
+            Case SeekOrigin.Begin
+                SetFilePointer(This.handle,o.LowPart,VarPtr(o.HighPart) As *DWord,FILE_BEGIN)
+            Case SeekOrigin.Current
+                SetFilePointer(This.handle,o.LowPart,VarPtr(o.HighPart) As *DWord,FILE_CURRENT)
+            Case SeekOrigin.End
+                SetFilePointer(This.handle,o.LowPart,VarPtr(o.HighPart) As *DWord,FILE_END)
+        End Select
+    End Function
+
+/*  Sub SetAccessControl(fileSecurity As FileSecurity)
+    FileSecurityの実装がまだできてない。
+    End Sub*/
+
+    Override Sub SetLength(value As Int64)
+        Dim o As LARGE_INTEGER
+        memcpy(VarPtr(o),VarPtr(value),SizeOf(LARGE_INTEGER))
+        If o.HighPart=0 And value<0 Then
+            o.LowPart=-o.LowPart
+        End If
+        If Length()=>value Then
+            SetFilePointer(This.handle,o.LowPart,VarPtr(o.HighPart) As *DWord,FILE_BEGIN)
+            SetEndOfFile(This.handle)
+        End If
+    End Sub
+
+/*  Synchronized*/
+
+    Override Function ToString() As String
+        Return Name()
+    End Function
+
+    Sub Unlock(position As Int64, length As Int64)
+        Dim p As LARGE_INTEGER
+        Dim l As LARGE_INTEGER
+        memcpy(VarPtr(p),VarPtr(position),SizeOf(LARGE_INTEGER))
+        memcpy(VarPtr(l),VarPtr(length),SizeOf(LARGE_INTEGER))
+        UnlockFile(This.handle,p.LowPart,p.HighPart,l.LowPart,l.HighPart)
+    End Sub
+
+    Override Sub Write(ByRef buffer[] As Byte, offset As Long, count As Long)
+        If offset Then
+            SetFilePointer(This.handle,offset,NULL,FILE_CURRENT)
+        End If
+        Dim ret As DWord
+        WriteFile(This.handle,buffer,count,VarPtr(ret),ByVal NULL)
+    End Sub
+
+    Override Sub WriteByte(b As Byte)
+        Write(b, 0, 1)
+    End Sub
+
+Protected
+    /*非同期ファイル操作に必須だがどうやって実装しようか検討中*/
+    Override Function CreateWaitHandle() As WaitHandle
+'       Return Nothing
+    End Function
+
+/*  Dispose
+    Finalize
+    MemberwiseClone*/
 End Class