Skip to content

Commit a96c7f0

Browse files
fix connect retry bug; add reconnect event
1 parent 167cd6d commit a96c7f0

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

steam/core/cm.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -71,7 +71,7 @@ def emit(self, event, *args):
7171
self._LOG.debug("Emit event: %s" % repr(event))
7272
super(CMClient, self).emit(event, *args)
7373

74-
def connect(self, retry=None, delay=0):
74+
def connect(self, retry=0, delay=0):
7575
"""Initiate connection to CM. Blocks until connected unless ``retry`` is specified.
7676
7777
:param retry: number of retries before returning. Unlimited when set to ``None``
@@ -91,12 +91,13 @@ def connect(self, retry=None, delay=0):
9191

9292
if delay:
9393
self._LOG.debug("Delayed connect: %d seconds" % delay)
94+
self.emit('reconnect', delay)
9495
gevent.sleep(delay)
9596

9697
self._LOG.debug("Connect initiated.")
9798

9899
for i, server_addr in enumerate(self.servers):
99-
if retry is not None and i > retry:
100+
if retry and i > retry:
100101
return False
101102

102103
start = time()

0 commit comments

Comments
 (0)