AutoReconnect goes into an endless loop

[pr4gmat1q]

Hey. Faced a problem. When a session fails, it often does not work through reconnection. The try_reconnect method goes into an infinite loop and always throws a BrokenPipeError exception: [Errno 32] Broken pipe

client = AMIClient(address=config.ami_host, port=config.ami_port,timeout=2)
AutoReconnect(ami_client=client,delay=1)
future = client.login(username=config.ami_user,secret=config.ami_pass)


client.add_event_listener(
"""
add listeners
"""
)

if future.response.is_error():
 raise Exception(str(future.response))

try:
    while True:
        time.sleep(5)
except (KeyboardInterrupt, SystemExit):
 client.logoff()

[pr4gmat1q]

After about how much to wait for a fix? Connection problem is very important.
Thank.

[pr4gmat1q]

@ettoreleandrotognoli
my Workaround:
client.py
class AutoReconnect

    def try_reconnect(self):
        try:
            f = self._login(*self._login_args[0], **self._login_args[1])
            response = f.response
            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

[pr4gmat1q]

@ettoreleandrotognoli
my Workaround:
client.py
class AutoReconnect

    def try_reconnect(self):
        try:
            f = self._login(*self._login_args[0], **self._login_args[1])
            response = f.response
            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

It working

        except (BrokenPipeError):
            self._ami_client.disconnect()
            self.try_reconnect()

[otahmasebi]

add self.daemon = True after line

python-ami/asterisk/ami/client.py

Line 285 in dea9d37

self.finished = threading.Event()

and self.join() after

python-ami/asterisk/ami/client.py

Line 325 in dea9d37

self.finished.wait(self.delay)

[daverck]

In my case, adding self._ami_client.disconnect() in the run function did the trick:

    def run(self):
        self.finished.wait(self.delay)
        while not self.finished.is_set():
            if not self.ping():
                self._ami_client.disconnect()
                self.try_reconnect()
            self.finished.wait(self.delay)