Merge pull request #113 from kt81/fix-header-error

Prevent 'Expected magic value...' exception at failover

Author: cnblogs-dudu

Enyim.Caching/Memcached/PooledSocket.cs

@@ -292,8 +292,10 @@ public async Task ReadAsync(byte[] buffer, int offset, int count)
                 try
                 {
                     int currentRead = await _inputStream.ReadAsync(buffer, offset, shouldRead);
-                    if (currentRead == count || currentRead < 1)
+                    if (currentRead == count)
                         break;
+                    if (currentRead < 1)
+                        throw new IOException("The socket seems to be disconnected");
 
                     read += currentRead;
                     offset += currentRead;
@@ -330,8 +332,10 @@ public void Read(byte[] buffer, int offset, int count)
                 try
                 {
                     int currentRead = _inputStream.Read(buffer, offset, shouldRead);
-                    if (currentRead == count || currentRead < 1)
+                    if (currentRead == count)
                         break;
+                    if (currentRead < 1)
+                        throw new IOException("The socket seems to be disconnected");
 
                     read += currentRead;
                     offset += currentRead;
@@ -437,4 +441,4 @@ public async Task WriteAsync(IList<ArraySegment<byte>> buffers)
  *    
  * ************************************************************/
 
-#endregion
+#endregion