diff --git a/sjrpc/client/simple.py b/sjrpc/client/simple.py index bacece116eebfed444134e291be9af117f7df4a5..2a541351298bde5d2ad0fcc51b0e62502897b5ef 100644 --- a/sjrpc/client/simple.py +++ b/sjrpc/client/simple.py @@ -82,7 +82,7 @@ class SimpleRpcClient(ConnectionManager): try: self._connection.receive() except socket.error as err: - logging.error('Socket error while receiving from the client ' + logging.debug('Socket error while receiving from the client ' 'fd/%s: %s', fd, err) self.shutdown() @@ -91,12 +91,12 @@ class SimpleRpcClient(ConnectionManager): try: self._connection.send() except socket.error as err: - logging.error('Socket error while sending to the client ' + logging.debug('Socket error while sending to the client ' 'fd/%s: %s', fd, err) self.shutdown() if event & select.EPOLLHUP: - logging.error('Socket HUP fd/%s', fd) + logging.debug('Socket HUP fd/%s', fd) self.shutdown() def all_connections(self): diff --git a/sjrpc/core/rpcconnection.py b/sjrpc/core/rpcconnection.py index b1466560c6750dd4f7545031ce91a767c8485cca..679196eba80f6307d0b4c4b324b2f11de6f675dd 100644 --- a/sjrpc/core/rpcconnection.py +++ b/sjrpc/core/rpcconnection.py @@ -119,7 +119,7 @@ class RpcConnection(object): except socket.error as err: if err.errno == 11: # Errno 11 -> retry again - logging.warning('Non critical error while reading a socket:' + logging.debug('Non critical error while reading a socket:' ' %r', err) return @@ -368,7 +368,7 @@ class RpcConnection(object): # manager while cleanup. else: - logging.warning('Malformed message received: %s', message) + logging.debug('Malformed message received: %s', message) def shutdown(self, callback=None): ''' @@ -384,7 +384,7 @@ class RpcConnection(object): try: self._sock.close() except socket.error as err: - logging.warning('Error while socket close: %s.', err) + logging.debug('Error while socket close: %s.', err) # Release all running calls from this connection: for call in self._calls.values(): @@ -407,7 +407,7 @@ class RpcConnection(object): try: callback(self) except Exception as err: - logging.error('Error while execution of shutdown ' + logging.debug('Error while execution of shutdown ' 'callback: %s', err) def clean_call(self, msg_id): diff --git a/sjrpc/server/simple.py b/sjrpc/server/simple.py index 8f8c1d5d1d90f8c9a22f980f8d88b50bd0f91c67..66649a95192a0d888ae7af69897503605c25c168 100644 --- a/sjrpc/server/simple.py +++ b/sjrpc/server/simple.py @@ -78,11 +78,11 @@ class SimpleRpcServer(ConnectionManager): try: connection.receive() except socket.error as err: - logging.error('Socket error while receiving from client ' + logging.debug('Socket error while receiving from client ' 'fd/%s: %s', fd, err) self.shutdown_client(fd) except Exception as err: - logging.error('Unknown error while receiving from client ' + logging.debug('Unknown error while receiving from client ' 'fd/%s: %s', fd, err) self.shutdown_client(fd) @@ -91,16 +91,16 @@ class SimpleRpcServer(ConnectionManager): try: connection.send() except socket.error as err: - logging.error('Socket error while sending to the client ' + logging.debug('Socket error while sending to the client ' 'fd/%s: %s', fd, err) self.shutdown_client(fd) except Exception as err: - logging.error('Unknown error while sending to the client ' + logging.debug('Unknown error while sending to the client ' 'fd/%s: %s', fd, err) self.shutdown_client(fd) if event & select.EPOLLHUP: - logging.error('Socket HUP fd/%s', fd) + logging.debug('Socket HUP fd/%s', fd) self.shutdown_client(fd) @@ -129,6 +129,6 @@ class SimpleSslRpcServer(SimpleRpcServer): ssl_version=ssl.PROTOCOL_TLSv1, do_handshake_on_connect=True) except ssl.SSLError as err: - logging.error('Error when accepting ssl connection: %s', err) + logging.debug('Error when accepting ssl connection: %s', err) else: return sslsock, address