Alternative solution to fix #345.

pika · May 27, 2013 · 3a19d65 · vitaly-krugl · Jan 7, 2014 · 3a19d65
1 parent ec94b1f
commit 3a19d65
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pika/adapters/base_connection.py b/pika/adapters/base_connection.py
@@ -332,12 +332,12 @@ def _handle_write(self):
         if self.outbound_buffer:
             frame = self.outbound_buffer.popleft()
             try:
-                self.socket.sendall(frame)
+                while total_written < len(frame):
+                    total_written += self.socket.send(frame)
             except socket.timeout:
                 raise
             except socket.error, error:
                 return self._handle_error(error)
-            total_written += len(frame)
         return total_written
 
     def _init_connection_state(self):