fix #50

80b5e3d7 · deepakverma · 02ae9601 · 80b5e3d7
Commit 80b5e3d7 authored Jul 17, 2014 by deepakverma
Hide whitespace changes
Inline Side-by-side

Showing with 17 additions and 10 deletions

PhysicalConnection.cs ...kExchange.Redis/StackExchange/Redis/PhysicalConnection.cs +17 -10

No files found.
--- a/StackExchange.Redis/StackExchange/Redis/PhysicalConnection.cs
+++ b/StackExchange.Redis/StackExchange/Redis/PhysicalConnection.cs
@@ -523,18 +523,25 @@ static void WriteUnified(Stream stream, long value)
        void BeginReading()
        {
            bool keepReading;
-            do
+            try
            {
-                keepReading = false;
+                do
-                int space = EnsureSpaceAndComputeBytesToRead();
-                multiplexer.Trace("Beginning async read...", physicalName);
-                var result = netStream.BeginRead(ioBuffer, ioBufferBytes, space, endRead, this);
-                if (result.CompletedSynchronously)
                {
-                    multiplexer.Trace("Completed synchronously: processing immediately", physicalName);
+                    keepReading = false;
-                    keepReading = EndReading(result);
+                    int space = EnsureSpaceAndComputeBytesToRead();
-                }
+                    multiplexer.Trace("Beginning async read...", physicalName);
-            } while (keepReading);
+                    var result = netStream.BeginRead(ioBuffer, ioBufferBytes, space, endRead, this);
+                    if (result.CompletedSynchronously)
+                    {
+                        multiplexer.Trace("Completed synchronously: processing immediately", physicalName);
+                        keepReading = EndReading(result);
+                    }
+                } while (keepReading);
+            }
+            catch(System.IO.IOException ex)
+            {
+                multiplexer.Trace("Could not connect: " + ex.Message, physicalName);
+            }
        }
        int haveReader;