pep/slixmpp
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

xmlstream: make connect_loop_wait private

Browse source
This commit is contained in:
mathieui 2021-02-04 18:32:41 +01:00
parent 782dbdea65
commit d3063a0368
1 changed files with 9 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
slixmpp/xmlstream/xmlstream.py
View file

@ -88,7 +88,9 @@ class XMLStream(asyncio.BaseProtocol):
# The socket that is used internally by the transport object # The socket that is used internally by the transport object
self.socket = None self.socket = None
self.connect_loop_wait = 0 # The backoff of the connect routine (increases exponentially
# after each failure)
self._connect_loop_wait = 0
self.parser = None self.parser = None
self.xml_depth = 0 self.xml_depth = 0
@ -284,7 +286,7 @@ class XMLStream(asyncio.BaseProtocol):
self.disconnect_reason = None self.disconnect_reason = None
self.cancel_connection_attempt() self.cancel_connection_attempt()
self.connect_loop_wait = 0 self._connect_loop_wait = 0
if host and port: if host and port:
self.address = (host, int(port)) self.address = (host, int(port))
try: try:
@ -309,9 +311,9 @@ class XMLStream(asyncio.BaseProtocol):
async def _connect_routine(self): async def _connect_routine(self):
self.event_when_connected = "connected" self.event_when_connected = "connected"
if self.connect_loop_wait > 0: if self._connect_loop_wait > 0:
self.event('reconnect_delay', self.connect_loop_wait) self.event('reconnect_delay', self._connect_loop_wait)
await asyncio.sleep(self.connect_loop_wait, loop=self.loop) await asyncio.sleep(self._connect_loop_wait, loop=self.loop)
record = await self.pick_dns_answer(self.default_domain) record = await self.pick_dns_answer(self.default_domain)
if record is not None: if record is not None:
@ -337,7 +339,7 @@ class XMLStream(asyncio.BaseProtocol):
self.address[1], self.address[1],
ssl=ssl_context, ssl=ssl_context,
server_hostname=self.default_domain if self.use_ssl else None) server_hostname=self.default_domain if self.use_ssl else None)
self.connect_loop_wait = 0 self._connect_loop_wait = 0
except Socket.gaierror as e: except Socket.gaierror as e:
self.event('connection_failed', self.event('connection_failed',
'No DNS record available for %s' % self.default_domain) 'No DNS record available for %s' % self.default_domain)
@ -346,7 +348,7 @@ class XMLStream(asyncio.BaseProtocol):
self.event("connection_failed", e) self.event("connection_failed", e)
if self._current_connection_attempt is None: if self._current_connection_attempt is None:
return return
self.connect_loop_wait = self.connect_loop_wait * 2 + 1 self._connect_loop_wait = self._connect_loop_wait * 2 + 1
self._current_connection_attempt = asyncio.ensure_future( self._current_connection_attempt = asyncio.ensure_future(
self._connect_routine(), self._connect_routine(),
loop=self.loop, loop=self.loop,