Commit fd485daa authored by Antoine Millet's avatar Antoine Millet
Browse files

Fixed bug in RpcConnection writer 

Non blocking errors was not handled in the writer callback.
parent 12d8b798

sjrpc/core/rpcconnection.py

+6 −0
Original line number Diff line number Diff line
@@ -294,6 +294,12 @@ class RpcConnection(object): 
                else:

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

            except socket.error as err:

                if (isinstance(err, socket.error) and err.errno

                    in RpcConnection.NONBLOCKING_ERRORS):

                    return

                elif (isinstance(err, ssl.SSLError) and err.errno

                    in RpcConnection.NONBLOCKING_SSL_ERRORS):

                    return

                errmsg = 'Fatal error while sending through socket: %s' % err

                self.logger.error(errmsg)

                raise SocketError(errmsg)