From 05d3b4244d35e8a8d8511d9dd624d0b646a5eb09 Mon Sep 17 00:00:00 2001 From: TheKysek Date: Wed, 23 Aug 2017 18:29:07 +0200 Subject: [PATCH] Retry connections to SAM bridge Remove unnecessary debug logging --- minode/i2p/controller.py | 8 +++++++- minode/i2p/dialer.py | 4 ++-- 2 files changed, 9 insertions(+), 3 deletions(-) diff --git a/minode/i2p/controller.py b/minode/i2p/controller.py index d76c267..6f5f675 100644 --- a/minode/i2p/controller.py +++ b/minode/i2p/controller.py @@ -18,7 +18,13 @@ class I2PController(threading.Thread): self.port = port self.nick = b'MiNode_' + base64.b16encode(os.urandom(4)).lower() - self.s = socket.create_connection((self.host, self.port)) + while True: + try: + self.s = socket.create_connection((self.host, self.port)) + break + except ConnectionRefusedError: + logging.error("Error while connecting to I2P SAM bridge. Retrying.") + time.sleep(10) self.version_reply = [] diff --git a/minode/i2p/dialer.py b/minode/i2p/dialer.py index d8bf755..609cacb 100644 --- a/minode/i2p/dialer.py +++ b/minode/i2p/dialer.py @@ -33,11 +33,11 @@ class I2PDialer(threading.Thread): def _receive_line(self): line = receive_line(self.s) - logging.debug('I2PDialer <- ' + str(line)) + # logging.debug('I2PDialer <- ' + str(line)) return line def _send(self, command): - logging.debug('I2PDialer -> ' + str(command)) + # logging.debug('I2PDialer -> ' + str(command)) self.s.sendall(command) def _connect(self):