Fix BrokenPipeError in reconnect method ettoreleandrotognoli#31 ettor…

…eleandrotognoli#32
bouhao01 · Apr 26, 2020 · 60a9775 · 60a9775
1 parent 31309d8
commit 60a9775
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/asterisk/ami/client.py b/asterisk/ami/client.py
@@ -313,6 +313,11 @@ def try_reconnect(self):
             if response is not None and not response.is_error():
                 self.on_reconnect(self._ami_client, response)
                 return True
+        except (BrokenPipeError):
+            self._ami_client._socket.close()
+            self._ami_client._socket = None
+            self._ami_client.connect()
+            self.try_reconnect()
         except:
             pass
         return False