reverted change in synchronous connection

quantmind · quantmind · commit bcd12dd2bba3 · 2012-09-19T17:45:29.000+01:00
diff --git a/stdnet/lib/redis/connection.py b/stdnet/lib/redis/connection.py
@@ -216,6 +216,7 @@ def execute(self, tried=0):
             try:
                 self.connection.connect(self)
                 self.send()
+                return self.read_response()
             except (socket.timeout, socket.error):
                 if tried < self.retry:
                     self.connection.disconnect(release_connection=False)
@@ -232,11 +233,7 @@ def read_response(self):
         response = NOT_READY
         sock = self.connection.sock
         while response is NOT_READY:
-            try:
-                stream = sock.recv(io.DEFAULT_BUFFER_SIZE)
-            except:
-                self.disconnect()
-                raise
+            stream = sock.recv(io.DEFAULT_BUFFER_SIZE)
             response = self.parse(stream)
         return response
     
