GitHub/PyLink
3
0
Fork 0
mirror of https://github.com/jlu5/PyLink.git synced 2024-11-01 01:09:22 +01:00
Code Issues Projects Releases Wiki Activity

Fix duplicate calls to _run_autoconnect

Browse Source
This commit is contained in:
James Lu 2018-03-22 17:42:28 -07:00
parent f10f5bee52
commit b522967760
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
classes.py
View File

@ -1301,6 +1301,7 @@ class IRCNetwork(PyLinkNetworkCoreWithUtils):
self._socket = None self._socket = None
self._selector_key = None self._selector_key = None
self._buffer = b'' self._buffer = b''
self._reconnect_thread = None
def _init_vars(self, *args, **kwargs): def _init_vars(self, *args, **kwargs):
super()._init_vars(*args, **kwargs) super()._init_vars(*args, **kwargs)
@ -1471,9 +1472,6 @@ class IRCNetwork(PyLinkNetworkCoreWithUtils):
if not self._aborted.is_set(): if not self._aborted.is_set():
self.disconnect() self.disconnect()
if not self._run_autoconnect():
return
def disconnect(self): def disconnect(self):
"""Handle disconnects from the remote server.""" """Handle disconnects from the remote server."""
self._pre_disconnect() self._pre_disconnect()
@ -1510,8 +1508,10 @@ class IRCNetwork(PyLinkNetworkCoreWithUtils):
# block whatever is calling disconnect() though.) # block whatever is calling disconnect() though.)
if self._run_autoconnect(): if self._run_autoconnect():
self.connect() self.connect()
t = threading.Thread(target=_reconnect, name="Reconnecting network %s" % self.name)
t.start() if self._reconnect_thread is None or not self._reconnect_thread.is_alive():
self._reconnect_thread = threading.Thread(target=_reconnect, name="Reconnecting network %s" % self.name)
self._reconnect_thread.start()
def handle_events(self, line): def handle_events(self, line):
raise NotImplementedError raise NotImplementedError