Welcome to mirror list, hosted at ThFree Co, Russian Federation.

github.com/mono/mono.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
Diffstat (limited to 'mcs/class/corlib/System.IO/FileStream.cs')
-rw-r--r--mcs/class/corlib/System.IO/FileStream.cs339
1 files changed, 0 insertions, 339 deletions
diff --git a/mcs/class/corlib/System.IO/FileStream.cs b/mcs/class/corlib/System.IO/FileStream.cs
deleted file mode 100644
index 7180992ca84..00000000000
--- a/mcs/class/corlib/System.IO/FileStream.cs
+++ /dev/null
@@ -1,339 +0,0 @@
-//
-// System.IO/FileStream.cs
-//
-// Authors:
-// Dietmar Maurer (dietmar@ximian.com)
-// Dan Lewis (dihlewis@yahoo.co.uk)
-//
-// (C) 2001 Ximian, Inc. http://www.ximian.com
-//
-
-using System;
-using System.Runtime.CompilerServices;
-
-// FIXME: emit the correct exceptions everywhere. add error handling.
-
-namespace System.IO
-{
-
- public class FileStream : Stream
- {
- // construct from handle
-
- public FileStream (IntPtr handle, FileAccess access)
- : this (handle, access, true, DefaultBufferSize, false) {}
-
- public FileStream (IntPtr handle, FileAccess access, bool ownsHandle)
- : this (handle, access, ownsHandle, DefaultBufferSize, false) {}
-
- public FileStream (IntPtr handle, FileAccess access, bool ownsHandle, int bufferSize)
- : this (handle, access, ownsHandle, bufferSize, false) {}
-
- public FileStream (IntPtr handle, FileAccess access, bool ownsHandle, int bufferSize, bool isAsync)
- {
- this.handle = handle;
- this.access = access;
- this.owner = ownsHandle;
- this.async = isAsync;
-
- InitBuffer (bufferSize);
- }
-
- // construct from filename
-
- public FileStream (string name, FileMode mode)
- : this (name, mode, FileAccess.ReadWrite, FileShare.ReadWrite, DefaultBufferSize, false) { }
-
- public FileStream (string name, FileMode mode, FileAccess access)
- : this (name, mode, access, FileShare.ReadWrite, DefaultBufferSize, false) { }
-
- public FileStream (string name, FileMode mode, FileAccess access, FileShare share)
- : this (name, mode, access, share, DefaultBufferSize, false) { }
-
- public FileStream (string name, FileMode mode, FileAccess access, FileShare share, int bufferSize)
- : this (name, mode, access, share, bufferSize, false) { }
-
- public FileStream (string name, FileMode mode, FileAccess access, FileShare share, int bufferSize, bool isAsync)
- {
- if (name == null)
- throw new ArgumentNullException ();
- if (name == "" || name.IndexOfAny (Path.InvalidPathChars) != -1)
- throw new ArgumentException ();
-
- // TODO: demand permissions
-
- this.handle = MonoIO.Open (name, mode, access, share);
- if (handle == MonoIO.InvalidHandle)
- throw MonoIO.GetException ();
-
- this.access = access;
- this.owner = true;
- this.async = isAsync;
-
- InitBuffer (bufferSize);
- }
-
- // properties
-
- public override bool CanRead {
- get {
- return access == FileAccess.Read ||
- access == FileAccess.ReadWrite;
- }
- }
-
- public override bool CanWrite {
- get {
- return access == FileAccess.Write ||
- access == FileAccess.ReadWrite;
- }
- }
-
- public override bool CanSeek {
- get {
- return true; // FIXME: false for pipes & streams
- }
- }
-
- public override long Length {
- get { return MonoIO.GetLength (handle); }
- }
-
- public override long Position {
- get { return buf_start + buf_offset; }
- set { Seek (value, SeekOrigin.Begin); }
- }
-
- public virtual IntPtr Handle {
- get { return handle; }
- }
-
- // methods
-
- public override int ReadByte ()
- {
- if (buf_offset >= buf_length) {
- RefillBuffer ();
-
- if (buf_length == 0)
- return -1;
- }
-
- return buf [buf_offset ++];
- }
-
- public override void WriteByte (byte value)
- {
- if (buf_offset == buf_size)
- FlushBuffer ();
-
- buf [buf_offset ++] = value;
- if (buf_offset > buf_length)
- buf_length = buf_offset;
-
- buf_dirty = true;
- }
-
- public override int Read (byte[] dest, int dest_offset, int count)
- {
- int copied = 0;
- while (count > 0) {
- int n = ReadSegment (dest, dest_offset + copied, count);
- copied += n;
- count -= n;
-
- if (count == 0)
- break;
-
- if (count > buf_size) { // shortcut for long reads
- FlushBuffer ();
-
- MonoIO.Seek (handle, buf_start, SeekOrigin.Begin);
- n = MonoIO.Read (handle, dest, dest_offset + copied, count);
-
- copied += n;
- buf_start += n;
- break;
- }
-
- RefillBuffer ();
- if (buf_length == 0)
- break;
- }
-
- return copied;
- }
-
- public override void Write (byte[] src, int src_offset, int count)
- {
- int copied = 0;
- while (count > 0) {
- int n = WriteSegment (src, src_offset + copied, count);
- copied += n;
- count -= n;
-
- if (count == 0)
- break;
-
- FlushBuffer ();
-
- if (count > buf_size) { // shortcut for long writes
- MonoIO.Write (handle, src, src_offset + copied, count);
- buf_start += count;
- break;
- }
- }
- }
-
- public override long Seek (long offset, SeekOrigin origin)
- {
- long pos;
-
- // make absolute
-
- switch (origin) {
- case SeekOrigin.End:
- pos = Length - offset;
- break;
-
- case SeekOrigin.Current:
- pos = Position + offset;
- break;
-
- case SeekOrigin.Begin: default:
- pos = offset;
- break;
- }
-
- if (pos >= buf_start && pos <= buf_start + buf_length) {
- buf_offset = (int) (pos - buf_start);
- return pos;
- }
-
- FlushBuffer ();
- buf_start = MonoIO.Seek (handle, pos, SeekOrigin.Begin);
-
- return buf_start;
- }
-
- public override void SetLength (long length)
- {
- Flush ();
- MonoIO.SetLength (handle, length);
- }
-
- public override void Flush ()
- {
- FlushBuffer ();
- MonoIO.Flush (handle);
- }
-
- public override void Close ()
- {
- Dispose (true);
- GC.SuppressFinalize (this); // remove from finalize queue
- }
-
- // protected
-
- ~FileStream ()
- {
- Dispose (false);
- }
-
- protected virtual void Dispose (bool disposing) {
- if (handle != MonoIO.InvalidHandle) {
- Flush ();
- MonoIO.Close (handle);
-
- handle = MonoIO.InvalidHandle;
- }
-
- if (disposing)
- buf = null;
- }
-
- // private
-
- private int ReadSegment (byte [] dest, int dest_offset, int count)
- {
- if (count > buf_length - buf_offset)
- count = buf_length - buf_offset;
-
- if (count > 0) {
- Buffer.BlockCopy (buf, buf_offset, dest, dest_offset, count);
- buf_offset += count;
- }
-
- return count;
- }
-
- private int WriteSegment (byte [] src, int src_offset, int count)
- {
- if (count > buf_size - buf_offset)
- count = buf_size - buf_offset;
-
- if (count > 0) {
- Buffer.BlockCopy (src, src_offset, buf, buf_offset, count);
- buf_offset += count;
- if (buf_offset > buf_length)
- buf_length = buf_offset;
-
- buf_dirty = true;
- }
-
- return count;
- }
-
- private void FlushBuffer ()
- {
- if (buf_dirty) {
- MonoIO.Seek (handle, buf_start, SeekOrigin.Begin);
- MonoIO.Write (handle, buf, 0, buf_length);
- }
-
- buf_start += buf_length;
- buf_offset = buf_length = 0;
- buf_dirty = false;
- }
-
- private void RefillBuffer ()
- {
- FlushBuffer ();
-
- MonoIO.Seek (handle, buf_start, SeekOrigin.Begin);
- buf_length = MonoIO.Read (handle, buf, 0, buf_size);
- }
-
- private void InitBuffer (int size)
- {
- if (size < 0)
- throw new ArgumentOutOfRangeException ("Buffer size cannot be negative.");
- if (size < 8)
- size = 8;
-
- buf = new byte [size];
- buf_size = size;
- buf_start = 0;
- buf_offset = buf_length = 0;
- buf_dirty = false;
- }
-
- // fields
-
- private static int DefaultBufferSize = 8192;
-
- private FileAccess access;
- private bool owner;
- private bool async;
-
- private byte [] buf; // the buffer
- private int buf_size; // capacity in bytes
- private int buf_length; // number of valid bytes in buffer
- private int buf_offset; // position of next byte
- private bool buf_dirty; // true if buffer has been written to
- private long buf_start; // location of buffer in file
-
- IntPtr handle; // handle to underlying file
- }
-}