Context Navigation

FileStream.ab@ 552

Last change on this file since 552 was 552, checked in by NoWest, 16 years ago
Handleメソッドを追加
File size: 12.9 KB

Rev	Line
[271]	1	Namespace System
	2	Namespace IO
[256]	3
[260]	4	/* ほんとはmiscに入れるかかファイルを分けたほうがいいかもしれないが一先ず実装 */
[256]	5	Enum FileOptions
[391]	6	None = 0
	7	Asynchronous = FILE_FLAG_OVERLAPPED
	8	DeleteOnClose = FILE_FLAG_DELETE_ON_CLOSE
	9	Encrypted = FILE_ATTRIBUTE_ENCRYPTED
	10	RandomAccess = FILE_FLAG_RANDOM_ACCESS
	11	SequentialScan = FILE_FLAG_SEQUENTIAL_SCAN
	12	WriteThrough = FILE_FLAG_WRITE_THROUGH
[256]	13	End Enum
	14
[105]	15	Class FileStream
[256]	16	Inherits Stream
	17
	18	handle As HANDLE
	19
	20	/*
[260]	21	ファイルハンドルからこれらを取得できれば、これらは入らないが
[256]	22	今のところは不明なので自前で実装するしかない
	23	*/
	24	filePath As String
	25	fileMode As DWord
	26	fileAccess As DWord
	27	fileShare As DWord
	28	fileOptions As DWord
[432]	29	ownsHandle As Boolean
[388]	30
	31	offset As QWord 'オーバーラップドIO用
[256]	32
	33	Public
[260]	34	/* コンストラクタ.NETと同じように実装は難しい、一先ず動くものを実装したが変更が必要だと思う */
[256]	35	Sub FileStream(path As String, mode As FileMode, access As FileAccess, share As FileShare, options As FileOptions)
[435]	36	If ActiveBasic.IsNothing(path) Then
	37	Throw New ArgumentNullException("path")
	38	ElseIf path.Length = 0 Then
	39	Throw New ArgumentException
	40	End If
	41
	42
[432]	43	Dim ac = access As DWord
	44	Dim sh = share As DWord
	45	Dim mo = mode As DWord
	46	Dim op = options As DWord
[426]	47	' If (Environment.OSVersion.Platform As DWord) <> (PlatformID.Win32NT As DWord) Then 'ToDo: なぜかアクセス違反になる
[391]	48	op And= Not FILE_FLAG_OVERLAPPED
[426]	49	' End If
[256]	50
[391]	51	This.handle=CreateFile(ToTCStr(path),ac,sh,ByVal NULL,mo,op,0)
[260]	52	If This.handle=INVALID_HANDLE_VALUE Then
[256]	53	'エラー処理
	54	'Throw ArgumentException
	55	'Throw IOException
	56	'Throw System.IO.FileNotFoundException
[260]	57	This.handle=0
[435]	58	Detail.ThrowWinLastErrorIOException("Failed to open/create file.")
[256]	59	Exit Sub
	60	End If
	61
[336]	62	This.filePath = path
	63	This.fileMode = mo
	64	This.fileAccess = ac
	65	This.fileShare = sh
	66	This.fileOptions = op
[388]	67	This.offset = 0
[432]	68	This.ownsHandle = True
[474]	69
	70	If FileMode.Append = This.fileMode Then
	71	Seek(0, SeekOrigin.End)
	72	End If
[256]	73	End Sub
[260]	74	Sub FileStream(path As String, mode As FileMode, access As FileAccess, share As FileShare)
[336]	75	This.FileStream(path,mode,access,share,FileOptions.None)
[260]	76	End Sub
	77	Sub FileStream(path As String, mode As FileMode, access As FileAccess)
[336]	78	This.FileStream(path,mode,access,FileShare.None,FileOptions.None)
[260]	79	End Sub
[256]	80	Sub FileStream(path As String, mode As FileMode)
[260]	81	Dim access As FileAccess
[256]	82	Select Case mode
	83	Case FileMode.Append
[260]	84	access=FileAccess.Write
[256]	85	Case FileMode.Create
[260]	86	access=FileAccess.ReadWrite
[256]	87	Case FileMode.CreateNew
[260]	88	access=FileAccess.ReadWrite
[256]	89	Case FileMode.Open
[260]	90	access=FileAccess.ReadWrite
[256]	91	Case FileMode.OpenOrCreate
[260]	92	access=FileAccess.ReadWrite
[256]	93	Case FileMode.Truncate
[260]	94	access=FileAccess.Write
[256]	95	End Select
[336]	96	This.FileStream(path,mode,access,FileShare.None,FileOptions.None)
[256]	97	End Sub
[432]	98	/*
	99	@date 2008/02/26
	100	@auther Egtra
	101	'不要になったら削除すること
	102	*/
	103	Sub FileStream(h As HANDLE, access As FileAccess, owns As Boolean)
	104	handle = h
	105	fileAccess = access As DWord
	106	ownsHandle = owns
	107	End Sub
	108
[256]	109	Public
[391]	110	/*!
	111	@brief ファイルが読み込みに対応しているかを返す
	112	*/
[256]	113	Override Function CanRead() As Boolean
[336]	114	If This.fileAccess And GENERIC_READ Then
[256]	115	Return True
	116	Else
	117	Return False
	118	End If
	119	End Function
	120
[391]	121	/*!
	122	@brief ファイルがシークに対応しているかを返す
	123	*/
[256]	124	Override Function CanSeek() As Boolean
[336]	125	If GetFileType(This.handle)=FILE_TYPE_DISK Then
	126	Return True
	127	Else
	128	Return False
	129	End If
[256]	130	End Function
	131
[336]	132	' Override Function CanTimeout() As Boolean
	133	' /* ファイルがタイムアウトに対応しているかを返す */
	134	' Return False /今のところ対応していないのでFalse/
	135	' End Function*/
[256]	136
[391]	137	/*!
	138	@brief ファイルが書き込みに対応しているかを返す
	139	*/
[256]	140	Override Function CanWrite() As Boolean
[336]	141	If This.fileAccess And GENERIC_WRITE Then
[256]	142	Return True
	143	Else
	144	Return False
	145	End If
	146	End Function
	147
[552]	148	Function Handle() As HANDLE
	149	Return handle
	150	End Function
[256]	151
[391]	152	/*!
	153	@brief ファイルが非同期操作に対応しているかを返す
	154	*/
[256]	155	Function IsAsync() As Boolean
[388]	156	If This.fileOptions And FILE_FLAG_OVERLAPPED /FileOptions.Asynchronous/ Then
[256]	157	Return True
	158	Else
	159	Return False
	160	End If
	161	End Function
	162
	163	Override Function Length() As Int64
[391]	164	disposedCheck()
[336]	165	If This.CanSeek() Then
[391]	166	Dim length = VarPtr(Length) As *ULARGE_INTEGER
	167	length->LowPart = GetFileSize(This.handle, VarPtr(length->HighPart))
	168	If LODWORD(Length) = INVALID_FILE_SIZE Then
	169	Dim error = GetLastError()
	170	If error <> NO_ERROR Then
	171	' Detail.ThrowWinIOException("FileStream.Read: Failed to read.", error)
	172	End If
	173	End If
	174
	175	If Length < 0 Then
	176	Debug 'Throw OverflowException
	177	End If
[336]	178	End If
[256]	179	End Function
	180
	181	Function Name() As String
[388]	182	Return This.filePath
[256]	183	End Function
	184
	185	Override Sub Position(value As Int64)
[391]	186	disposedCheck()
[336]	187	If This.CanSeek() Then
	188	If This.IsAsync() Then
[388]	189	offset = value As QWord
[336]	190	Else
	191	Dim position As LARGE_INTEGER
	192	position.LowPart=LODWORD(value)
	193	position.HighPart=HIDWORD(value)
	194	SetFilePointer(This.handle,position.LowPart,VarPtr(position.HighPart) As *DWord,FILE_BEGIN)
	195	End If
[256]	196	End If
	197	End Sub
	198	Override Function Position() As Int64
[391]	199	disposedCheck()
[336]	200	If This.CanSeek() Then
	201	If This.IsAsync() Then
[388]	202	Return offset As Int64
[336]	203	Else
	204	Dim position As LARGE_INTEGER
	205	ZeroMemory(VarPtr(position),SizeOf(LARGE_INTEGER))
	206	position.LowPart=SetFilePointer(This.handle,position.LowPart,VarPtr(position.HighPart) As *DWord,FILE_CURRENT)
[388]	207	Return MAKEQWORD(position.LowPart,position.HighPart) As Int64
[336]	208	End If
	209	End If
[256]	210	End Function
	211
[336]	212	/* Override Sub ReadTimeout(value As Long)
[256]	213	'TODO
	214	End Sub
	215	Override Function ReadTimeout() As Long
	216	'TODO
[336]	217	End Function*/
[256]	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
	231	Public
[348]	232	Override Function BeginRead(buffer As *Byte, offset As Long, count As Long, callback As AsyncCallback, state As Object) As System.IAsyncResult
[336]	233	If This.IsAsync() Then
	234	Else
	235	Read(buffer,offset,count)
	236	End If
[256]	237	End Function
	238
[348]	239	Override Function BeginWrite(buffer As *Byte, offset As Long, count As Long, callback As AsyncCallback, state As Object) As System.IAsyncResult
[336]	240	If This.IsAsync() Then
	241	Else
	242	Write(buffer,offset,count)
	243	End If
[256]	244	End Function
	245
	246	/* CreateObjRef*/
[348]	247
[388]	248	Override Function EndRead(asyncResult As System.IAsyncResult) As Long
[256]	249	'TODO
[339]	250	End Function
[256]	251
[388]	252	Override Sub EndWrite(asyncResult As System.IAsyncResult)
[256]	253	'TODO
[349]	254	End Sub
[256]	255
	256	/* Equals*/
	257
	258	Override Sub Flush()
[391]	259	disposedCheck()
	260	Dim ret = FlushFileBuffers(This.handle)
	261	If ret = FALSE Then
	262	' Detail.ThrowWinLastErrorIOException("FileStream.Read: Failed to read.")
	263	End If
[256]	264	End Sub
	265
	266	/* Function GetAccessControl() As FileSecurity
	267	FileSecurityの実装がまだできてない。
	268	End Function*/
	269
	270	/* GetLifetimeService*/
	271
	272	/* Override Function GetType() As TypeInfo
	273	Return Super.GetType()
	274	End Function*/
	275
	276	/* InitializeLifetimeService*/
	277
	278	Sub Lock(position As Int64, length As Int64)
[391]	279	disposedCheck()
[388]	280	If position < 0 Then
	281	Throw New ArgumentOutOfRangeException("FileStream.Lock: An argument is negative value.", New System.Int64(position), "position")
	282	ElseIf length < 0 Then
	283	Throw New ArgumentOutOfRangeException("FileStream.Lock: An argument is negative value.", New System.Int64(length), "length")
	284	End If
	285	LockFile(handle, LODWORD(position As QWord), HIDWORD(position As QWord),
	286	LODWORD(length As QWord), HIDWORD(length As QWord))
[256]	287	End Sub
	288
[426]	289	Override Function Read(buffer As *Byte, offset As Long, count As Long) As Long
[391]	290	disposedCheck()
	291	If buffer = 0 Then
[426]	292	Throw New ArgumentNullException("FileStream.Read: An argument is null value.", "buffer")
[391]	293	ElseIf Not This.CanRead() Then
[426]	294	Throw New NotSupportedException("FileStream.Read: This stream is not readable.")
[391]	295	End If
	296
	297	Dim ret As BOOL
	298	Dim readBytes As DWord
	299	If This.IsAsync() Then
	300	Dim overlapped As OVERLAPPED
	301	SetQWord(VarPtr(overlapped.Offset), offset)
	302	overlapped.hEvent = CreateEvent(0, TRUE, FALSE, 0)
	303	If overlapped.hEvent = 0 Then
[426]	304	Throw New OutOfMemoryException("FileStream.Read: Failed to create an event object.")
[391]	305	End If
	306	Try
	307	ret = ReadFile(This.handle, VarPtr(buffer[offset]), count, 0, overlapped)
[388]	308	If ret = FALSE Then
[391]	309	Dim error = GetLastError()
	310	If error <> ERROR_IO_PENDING Then
[426]	311	Detail.ThrowWinIOException("FileStream.Read: Failed to read.", error)
[388]	312	End If
	313	End If
[391]	314	ret = GetOverlappedResult(This.handle, overlapped, readBytes, TRUE)
	315	If ret = FALSE Then
[426]	316	Detail.ThrowWinLastErrorIOException("FileStream.Read: Failed to read.")
[391]	317	End If
[388]	318	offset += Read
[391]	319	Finally
	320	CloseHandle(overlapped.hEvent)
	321	End Try
	322	Else
	323	ret = ReadFile(This.handle,VarPtr(buffer[offset]),count,VarPtr(readBytes),ByVal NULL)
	324	If ret = FALSE Then
[426]	325	Detail.ThrowWinLastErrorIOException("FileStream.Read: Failed to read.")
[336]	326	End If
[256]	327	End If
[391]	328	Read = readBytes As Long
[256]	329	End Function
	330
[391]	331	/*!
	332	@brief ストリームの現在位置を移動させる。
	333	@param[in] offset originからの移動量
	334	@param[in] origin 移動の基準位置
	335	@return 移動後の新しい現在位置
	336	@exception DisposedException 既にストリームが閉じられている場合
	337	@exception ArgumentException 移動後の位置が負の位置（ファイル先頭より手前）になる場合
	338	@exception IOException その他エラーが発生した場合
	339	*/
	340	Override Function Seek(offset As Int64, origin As SeekOrigin) As Int64
	341	disposedCheck()
[336]	342	If This.CanSeek() Then
	343	If This.IsAsync() Then
	344	Select Case origin
	345	Case SeekOrigin.Begin
[388]	346	This.offset = offset
[336]	347	Case SeekOrigin.Current
[388]	348	This.offset += offset
[336]	349	Case SeekOrigin.End
[388]	350	This.offset = This.Length + offset
[336]	351	End Select
[391]	352	Seek = This.offset As Int64
	353	If Seek < 0 Then
	354	' Throw ArgumentException("FileStream.Seek: Cannot seek to negative offset.")
	355	End If
[336]	356	Else
[391]	357	Dim seek = VarPtr(offset) As *ULARGE_INTEGER
	358	Dim ret = SetFilePointer(This.handle, seek->LowPart, VarPtr(seek->HighPart), origin As DWord)
	359	If ret = INVALID_SET_FILE_POINTER Then
	360	Dim error = GetLastError()
	361	If error = ERROR_NEGATIVE_SEEK Then
	362	' Throw ArgumentException("FileStream.Seek: Cannot seek to negative offset.")
	363	ElseIf error <> NO_ERROR Then
	364	' Throw Detail.ThrowWinIOException("FileStream.Seek: Failed to seek.", error)
	365	End If
	366	End If
	367	seek->LowPart = ret
	368	Seek = offset
[336]	369	End If
[256]	370	End If
	371	End Function
	372
	373	/* Sub SetAccessControl(fileSecurity As FileSecurity)
	374	FileSecurityの実装がまだできてない。
	375	End Sub*/
	376
	377	Override Sub SetLength(value As Int64)
[391]	378	disposedCheck()
[336]	379	If This.CanWrite() and This.CanSeek() Then
	380	If This.IsAsync() Then
	381	Else
	382	Dim current = This.Position()
	383	This.Position(value)
[391]	384	Dim ret = SetEndOfFile(This.handle)
	385	If ret = FALSE Then
	386	Detail.ThrowWinLastErrorIOException("FileStream.Read: Failed to read.")
	387	End If
	388	Position = current
[336]	389	End If
[256]	390	End If
	391	End Sub
	392
	393	/* Synchronized*/
	394
	395	Override Function ToString() As String
[336]	396	Return This.Name()
[256]	397	End Function
	398
	399	Sub Unlock(position As Int64, length As Int64)
[391]	400	disposedCheck()
[388]	401	If position < 0 Then
	402	Throw New ArgumentOutOfRangeException("FileStream.Lock: An argument is negative value.", New System.Int64(position), "position")
	403	ElseIf length < 0 Then
	404	Throw New ArgumentOutOfRangeException("FileStream.Lock: An argument is negative value.", New System.Int64(length), "length")
	405	End If
[391]	406	Dim ret = UnlockFile(handle, LODWORD(position As QWord), HIDWORD(position As QWord),
[388]	407	LODWORD(length As QWord), HIDWORD(length As QWord))
[391]	408	If ret = FALSE Then
	409	Detail.ThrowWinLastErrorIOException("FileStream.Read: Failed to read.")
	410	End If
[256]	411	End Sub
	412
[337]	413	Override Sub Write(buffer As *Byte, offset As Long, count As Long)
[391]	414	disposedCheck()
[336]	415	If This.CanWrite() Then
[388]	416	Dim writeBytes As DWord
[336]	417	If This.IsAsync() Then
[388]	418	Dim overlapped As OVERLAPPED
	419	SetQWord(VarPtr(overlapped.Offset), offset)
[391]	420	overlapped.hEvent = CreateEvent(0, TRUE, FALSE, 0)
[388]	421	Dim ret = WriteFile(This.handle, VarPtr(buffer[offset]), count, 0, overlapped)
[391]	422	If ret <> FALSE Or GetLastError() = ERROR_IO_PENDING Then
	423	GetOverlappedResult(This.handle, overlapped, writeBytes, TRUE)
[388]	424	End If
	425	offset += writeBytes
[391]	426	CloseHandle(overlapped.hEvent)
[336]	427	Else
[388]	428	WriteFile(This.handle, VarPtr(buffer[offset]), count, VarPtr(writeBytes), ByVal NULL)
[336]	429	End If
[256]	430	End If
	431	End Sub
	432
	433	Protected
[432]	434	Override Sub Dispose(disposing As Boolean)
	435	If handle <> 0 Then
	436	Flush()
[439]	437	CloseHandle(InterlockedExchangePointer(ByVal VarPtr(handle), NULL))
[432]	438	End If
	439	End Sub
	440
[262]	441	Override Function CreateWaitHandle() As System.Threading.WaitHandle
[437]	442	Return New System.Threading.AutoResetEvent(False)
[256]	443	End Function
	444
[336]	445	Private
[391]	446	Sub disposedCheck()
	447	If handle = 0 Then
	448	' Throw ObjectDisposedException("FileStream: This stream has closed.")
	449	End If
	450	End Sub
	451
[105]	452	End Class
[271]	453
	454
	455	End Namespace
	456	End Namespace

Note: See TracBrowser for help on using the repository browser.

Download in other formats:

Original Format