Replace ReadInt with ReadLong

Author: mythz

src/ServiceStack.Redis/Pipeline/RedisPipelineCommand.cs

@@ -24,7 +24,7 @@ public List<long> ReadAllAsInts()
             var results = new List<long>();
             while (cmdCount-- > 0)
             {
-                results.Add(client.ReadInt());
+                results.Add(client.ReadLong());
             }
 
             return results;

src/ServiceStack.Redis/RedisNativeClient_Utils.cs

@@ -415,6 +415,7 @@ public bool FlushSendBuffer()
                         }
                     }
                 }
+
                 ResetSendBuffer();
             }
             catch (IOException ex)  // several stream commands wrap SocketException in IOException
@@ -481,12 +482,12 @@ protected long SendExpectLong(params byte[][] cmdWithBinaryArgs)
 
             if (Pipeline != null)
             {
-                Pipeline.CompleteLongQueuedCommand(ReadInt);
+                Pipeline.CompleteLongQueuedCommand(ReadLong);
                 return default(long);
             }
             return ReadLong();
         }
-		        
+
         protected byte[] SendExpectData(params byte[][] cmdWithBinaryArgs)
         {
             if (!SendCommand(cmdWithBinaryArgs))
@@ -682,29 +683,6 @@ internal void ExpectQueued()
             ExpectWord(QUEUED);
         }
 
-		public long ReadInt()
-        {
-            int c = SafeReadByte();
-            if (c == -1)
-                throw CreateResponseError("No more data");
-
-            var s = ReadLine();
-
-            if (log.IsDebugEnabled)
-                Log("R: {0}", s);
-
-            if (c == '-')
-                throw CreateResponseError(s.StartsWith("ERR") ? s.Substring(4) : s);
-
-            if (c == ':' || c == '$')//really strange why ZRANK needs the '$' here
-            {
-                int i;
-                if (int.TryParse(s, out i))
-                    return i;
-            }
-            throw CreateResponseError("Unknown reply on integer response: " + c + s);
-        }
-
         public long ReadLong()
         {
             int c = SafeReadByte();