From d8a8be7a96d7c6e32af2c1c20cea8863755c2dfe Mon Sep 17 00:00:00 2001 From: jef Date: Tue, 20 Dec 2022 23:56:45 +0100 Subject: [PATCH] umqtt.robust: When reconnecting, close the previous socket. --- micropython/umqtt.robust/umqtt/robust.py | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/micropython/umqtt.robust/umqtt/robust.py b/micropython/umqtt.robust/umqtt/robust.py index d9e4e9e97..77f1c0bb0 100644 --- a/micropython/umqtt.robust/umqtt/robust.py +++ b/micropython/umqtt.robust/umqtt/robust.py @@ -20,6 +20,11 @@ def log(self, in_reconnect, e): def reconnect(self): i = 0 while 1: + try: + if self.sock: + self.sock.close() + except OSError as e: + self.log(True, e) try: return super().connect(False) except OSError as e: