Mikaela/Limnoria
1
0
Fork 0
mirror of https://github.com/Mikaela/Limnoria.git synced 2024-11-02 17:29:22 +01:00
Code Issues Projects Releases Wiki Activity

Unschedule ourselves after a reconnect and fixed a bugz0r in reconnecting.

Browse Source
This commit is contained in:
Jeremy Fincher 2004-08-31 16:14:05 +00:00
parent 53c951cc04
commit faa340913d
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/asyncoreDrivers.py
View File

@ -63,6 +63,7 @@ class AsyncoreDriver(asynchat.async_chat, drivers.ServersMixin):
asynchat.async_chat.__init__(self) asynchat.async_chat.__init__(self)
drivers.ServersMixin.__init__(self, irc, servers=servers) drivers.ServersMixin.__init__(self, irc, servers=servers)
self.irc = irc self.irc = irc
self.irc.driver = self # Necessary because of the way we reconnect.
self.buffer = '' self.buffer = ''
self.set_terminator('\n') self.set_terminator('\n')
try: try:
@ -81,8 +82,9 @@ class AsyncoreDriver(asynchat.async_chat, drivers.ServersMixin):
drivers.log.reconnect(self.irc.network, when) drivers.log.reconnect(self.irc.network, when)
def makeNewDriver(): def makeNewDriver():
self.irc.reset() self.irc.reset()
self.scheduled = None
driver = self.__class__(self.irc, servers=self.servers) driver = self.__class__(self.irc, servers=self.servers)
schedule.addEvent(makeNewDriver, when) self.scheduled = schedule.addEvent(makeNewDriver, when)
def writable(self): def writable(self):
while self.connected: while self.connected:
@ -119,6 +121,8 @@ class AsyncoreDriver(asynchat.async_chat, drivers.ServersMixin):
pass pass
def die(self): def die(self):
if self.scheduled:
schedule.removeEvent(self.scheduled)
drivers.log.die(self.irc) drivers.log.die(self.irc)
self.reconnect() self.reconnect()