[System]: WebRequest.GetSystemProxy(): Return custom proxy for monodroid.

[mono.git] / mcs / class / System / System.Net / FtpDataStream.cs

diff --git a/mcs/class/System/System.Net/FtpDataStream.cs b/mcs/class/System/System.Net/FtpDataStream.cs
index 9f448bf7538ef6bc871613cdb671f4e0aaf228c4..7bb47468c3aa899d5875cce7eaa0323b854d1f57 100644 (file)
--- a/mcs/class/System/System.Net/FtpDataStream.cs
+++ b/mcs/class/System/System.Net/FtpDataStream.cs
@@ -12,37 +12,26 @@ using System.IO;
 using System.Net.Sockets;
 using System.Runtime.Remoting.Messaging;
 using System.Threading;
-
-#if NET_2_0
+using System.Net;
 
 namespace System.Net
 {
        class FtpDataStream : Stream, IDisposable
        {
                FtpWebRequest request;
-               NetworkStream networkStream;
+               Stream networkStream;
                bool disposed;
                bool isRead;
                int totalRead;
-               int contentLength;
-
-               ManualResetEvent closewh;
 
-               internal FtpDataStream (FtpWebRequest request, Socket socket, bool isRead)
+               internal FtpDataStream (FtpWebRequest request, Stream stream, bool isRead)
                {
                        if (request == null)
                                throw new ArgumentNullException ("request");
-                       if (socket == null)
-                               throw new ArgumentNullException ("socket");
-                       if (!socket.Connected)
-                               throw new ArgumentException ("socket");
 
                        this.request = request;
-                       this.contentLength = socket.Available;
-                       this.networkStream = new NetworkStream (socket, true);
+                       this.networkStream = stream;
                        this.isRead = isRead;
-
-                       closewh = new ManualResetEvent (false);
                }
 
                public override bool CanRead {
@@ -78,7 +67,7 @@ namespace System.Net
                        }
                }
 
-               internal NetworkStream NetworkStream {
+               internal Stream NetworkStream {
                        get {
                                CheckDisposed ();
                                return networkStream;
@@ -87,7 +76,7 @@ namespace System.Net
 
                public override void Close ()
                {
-                       ((IDisposable) this).Dispose ();
+                       Dispose (true);
                }
 
                public override void Flush ()
@@ -107,20 +96,23 @@ namespace System.Net
 
                int ReadInternal (byte [] buffer, int offset, int size)
                {
-                       int nbytes;
+                       int nbytes = 0;
+                       request.CheckIfAborted ();
+
                        try {
                                // Probably it would be better to have the socket here
                                nbytes = networkStream.Read (buffer, offset, size);
-                       } catch (IOException exc) {
+                       } catch (IOException) {
                                throw new ProtocolViolationException ("Server commited a protocol violation");
                        }
 
                        totalRead += nbytes;
-                       if (nbytes == 0)
-                               contentLength = totalRead;
-                       if (totalRead >= contentLength)
+                       if (nbytes == 0) {
+                               networkStream = null;
+                               request.CloseDataConnection ();
                                request.SetTransferCompleted ();
-                       
+                       }
+
                        return nbytes;
                }
 
@@ -159,10 +151,10 @@ namespace System.Net
 
                public override int Read (byte [] buffer, int offset, int size)
                {
+                       request.CheckIfAborted ();
                        IAsyncResult ar = BeginRead (buffer, offset, size, null, null);
                        if (!ar.IsCompleted && !ar.AsyncWaitHandle.WaitOne (request.ReadWriteTimeout, false))
                                throw new WebException ("Read timed out.", WebExceptionStatus.Timeout);
-
                        return EndRead (ar);
                }
 
@@ -171,9 +163,11 @@ namespace System.Net
                
                void WriteInternal (byte [] buffer, int offset, int size)
                {
+                       request.CheckIfAborted ();
+                       
                        try {
                                networkStream.Write (buffer, offset, size);
-                       } catch (IOException exc) {
+                       } catch (IOException) {
                                throw new ProtocolViolationException ();
                        }
                }
@@ -212,6 +206,7 @@ namespace System.Net
 
                public override void Write (byte [] buffer, int offset, int size)
                {
+                       request.CheckIfAborted ();
                        IAsyncResult ar = BeginWrite (buffer, offset, size, null, null);
                        if (!ar.IsCompleted && !ar.AsyncWaitHandle.WaitOne (request.ReadWriteTimeout, false))
                                throw new WebException ("Read timed out.", WebExceptionStatus.Timeout);
@@ -236,11 +231,12 @@ namespace System.Net
                                return;
 
                        disposed = true;
-
-                       networkStream.Close ();
-                       networkStream = null;
-
-                       closewh.Set ();
+                       if (networkStream != null)  {
+                               request.CloseDataConnection ();
+                               request.SetTransferCompleted ();
+                               request = null;
+                               networkStream = null;
+                       }
                }
 
                void CheckDisposed ()
@@ -250,15 +246,7 @@ namespace System.Net
                }
 
                delegate int ReadDelegate (byte [] buffer, int offset, int size);
-
-               // We need to know whether the stream has been closed
-               internal ManualResetEvent CloseWaitHandle {
-                       get {
-                               return closewh;
-                       }
-               }
        }
 }
 
-#endif