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):