diff options
Diffstat (limited to 'mcs/class/System/System.Net.Sockets/NetworkStream.cs')
| -rw-r--r-- | mcs/class/System/System.Net.Sockets/NetworkStream.cs | 307 |
1 files changed, 0 insertions, 307 deletions
diff --git a/mcs/class/System/System.Net.Sockets/NetworkStream.cs b/mcs/class/System/System.Net.Sockets/NetworkStream.cs deleted file mode 100644 index d304795eef3..00000000000 --- a/mcs/class/System/System.Net.Sockets/NetworkStream.cs +++ /dev/null @@ -1,307 +0,0 @@ -// -// System.Net.Sockets.NetworkStream.cs -// -// Author: -// Miguel de Icaza (miguel@ximian.com) -// -// (C) 2002 Ximian, Inc. http://www.ximian.com -// - -using System.IO; - -namespace System.Net.Sockets -{ - public class NetworkStream : Stream, IDisposable { - FileAccess access; - Socket socket; - bool owns_socket; - bool readable, writeable; - bool disposed = false; - - public NetworkStream (Socket socket) - : this (socket, FileAccess.ReadWrite, false) - { - } - - public NetworkStream (Socket socket, bool owns_socket) - : this (socket, FileAccess.ReadWrite, owns_socket) - { - } - - public NetworkStream (Socket socket, FileAccess access) - : this (socket, access, false) - { - } - - public NetworkStream (Socket socket, FileAccess access, bool owns_socket) - { - if (socket == null) - throw new ArgumentNullException (); - if (!socket.Connected) - throw new ArgumentException ("Not connected", "socket"); - if (socket.SocketType != SocketType.Stream) - throw new ArgumentException ("Socket is not of type Stream", "socket"); - if (!socket.Blocking) - throw new IOException (); - - this.socket = socket; - this.owns_socket = owns_socket; - this.access = access; - - readable = CanRead; - writeable = CanWrite; - } - - public override bool CanRead { - get { - return access == FileAccess.ReadWrite || access == FileAccess.Read; - } - } - - public override bool CanSeek { - get { - // network sockets cant seek. - return false; - } - } - - public override bool CanWrite { - get { - return access == FileAccess.ReadWrite || access == FileAccess.Write; - } - } - - public virtual bool DataAvailable { - get { - try { - return socket.Available > 0; - } finally { - CheckDisposed (); - } - } - } - - public override long Length { - get { - // Network sockets always throw an exception - throw new NotSupportedException (); - } - } - - public override long Position { - get { - // Network sockets always throw an exception - throw new NotSupportedException (); - } - - set { - // Network sockets always throw an exception - throw new NotSupportedException (); - } - } - - protected bool Readable { - get { - return readable; - } - - set { - readable = value; - } - } - - protected Socket Socket { - get { - return socket; - } - } - - protected bool Writeable { - get { - return writeable; - } - - set { - writeable = value; - } - } - - public override IAsyncResult BeginRead (byte [] buffer, int offset, int size, - AsyncCallback callback, object state) - { - try { - IAsyncResult retval; - - if (buffer == null) - throw new ArgumentNullException (); - int len = buffer.Length; - if (offset >= len || size != len) - throw new ArgumentOutOfRangeException (); - - try { - retval = socket.BeginReceive (buffer, offset, size, 0, callback, state); - } catch { - throw new IOException ("BeginReceive failure"); - } - - return retval; - } finally { - CheckDisposed (); - } - } - - public override IAsyncResult BeginWrite (byte [] buffer, int offset, int size, - AsyncCallback callback, object state) - { - try { - IAsyncResult retval; - - if (buffer == null) - throw new ArgumentNullException (); - - int len = buffer.Length; - if (len < size) - throw new ArgumentException (); - - try { - retval = socket.BeginSend (buffer, offset, size, 0, callback, state); - } catch { - throw new IOException ("BeginWrite failure"); - } - - return retval; - } finally { - CheckDisposed (); - } - } - - ~NetworkStream () - { - Dispose (false); - } - - public override void Close () - { - ((IDisposable) this).Dispose (); - } - - protected virtual void Dispose (bool disposing) - { - if (disposed) - return; - disposed = true; - - if (owns_socket) { - Socket s = socket; - if (s != null) - s.Close (); - } - socket = null; - } - - public override int EndRead (IAsyncResult ar) - { - try { - int res; - - if (ar == null) - throw new ArgumentNullException (); - - try { - res = socket.EndReceive (ar); - } catch { - throw new IOException ("EndRead failure"); - } - return res; - } finally { - CheckDisposed (); - } - } - - public override void EndWrite (IAsyncResult ar) - { - try { - if (ar == null) - throw new ArgumentNullException (); - - try { - socket.EndSend (ar); - } catch { - throw new IOException ("EndWrite failure"); - } - } finally { - CheckDisposed (); - } - } - - public override void Flush () - { - // network streams are non-buffered, this is a no-op - } - - void IDisposable.Dispose () - { - Dispose (true); - GC.SuppressFinalize (this); - } - - public override int Read (byte [] buffer, int offset, int size) - { - try { - int res; - - if (buffer == null) - throw new ArgumentNullException (); - if (buffer.Length < size) - throw new ArgumentException (); - - try { - res = socket.Receive (buffer, offset, size, 0); - } catch { - throw new IOException ("Read failure"); - } - return res; - } finally { - CheckDisposed (); - } - } - - public override long Seek (long offset, SeekOrigin origin) - { - // NetworkStream objects do not support seeking. - - throw new NotSupportedException (); - } - - public override void SetLength (long value) - { - // NetworkStream objects do not support SetLength - - throw new NotSupportedException (); - } - - public override void Write (byte [] buffer, int offset, int size) - { - try { - if (buffer == null) - throw new ArgumentNullException (); - if (buffer.Length < size) - throw new ArgumentException (); - try { - socket.Send (buffer, offset, size, 0); - } catch { - throw new IOException ("Write failure"); - } - } finally { - CheckDisposed (); - } - } - - private void CheckDisposed () - { - if (disposed) - throw new ObjectDisposedException (GetType().FullName); - } - - } -} |