Mikaela/Limnoria
1
0
Fork 0
mirror of https://github.com/Mikaela/Limnoria.git synced 2025-01-11 12:42:34 +01:00
Code Issues Projects Releases Wiki Activity

Changed the way Irc handles unresponded-to PINGs.

Browse Source
This commit is contained in:
Jeremy Fincher 2003-04-04 08:30:16 +00:00
parent 29effdf8cc
commit a46ce6b109
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/irclib.py
View File

@ -282,7 +282,7 @@ class Irc(object):
self.queue = IrcMsgQueue()
self.fastqueue = queue()
self.lastping = time.time()
self.lastpong = time.time()+60
self.outstandingPongs = set()
self.lastTake = 0
self.driver = None # The driver should set this later.
self.queue.enqueue(ircmsgs.user(self.user, self.ident))
@ -330,8 +330,8 @@ class Irc(object):
else:
self.lastTake = now
msg = self.queue.dequeue()
elif self.lastping - self.lastpong > 180:
# Our ping hasn't be responded to.
elif len(self.outstandingPongs) > 2:
# Our pings hasn't be responded to.
if hasattr(self.driver, 'scheduleReconnect'):
self.driver.scheduleReconnect()
self.driver.die()
@ -340,6 +340,8 @@ class Irc(object):
debug.msg('Irc.takeMsg throttling.', 'verbose')
else:
self.lastping = now
now = str(int(now))
self.outstandingPongs.add(now)
msg = ircmsgs.ping(str(int(now)))
if msg:
for callback in self.callbacks:
@ -399,7 +401,7 @@ class Irc(object):
ircdb.users.setUser(self.nick, u)
atexit.register(lambda: catch(ircdb.users.delUser(self.nick)))
elif msg.command == 'PONG':
self.lastpong = time.time()
self.outstandingPongs.remove(msg.args[1])
elif msg.command == 'ERROR':
if msg.args[0].startswith('Closing Link'):
if hasattr(self.driver, 'scheduleReconnect'):