Commit 9a62bad2 authored by Antoine Millet's avatar Antoine Millet
Browse files

Reduced write size on socket

parent d4ca67c4

sjrpc/core/rpcconnection.py

+1 −1
Original line number Diff line number Diff line
@@ -297,7 +297,7 @@ class RpcConnection(object): 
                    sent = self._sock.send(self._outbound_buffer[:4096])

                else:

                    if self._writer_last_try_buf is None:

                        self._writer_last_try_buf = self._outbound_buffer[:1024 * 128]

                        self._writer_last_try_buf = self._outbound_buffer[:1024 * 64]

                    sent = self._sock.send(self._writer_last_try_buf)

            except socket.error as err:

                if (isinstance(err, socket.error) and err.errno in RpcConnection.NONBLOCKING_ERRORS):