mirror of
https://github.com/Mikaela/Limnoria.git
synced 2024-11-23 19:19:32 +01:00
Minor changes, added some (commented-out) debug.printfs.
This commit is contained in:
parent
0fe7b81874
commit
e6bfc72b77
@ -74,6 +74,7 @@ class AsyncoreDriver(asynchat.async_chat, object):
|
|||||||
self.close()
|
self.close()
|
||||||
|
|
||||||
def scheduleReconnect(self):
|
def scheduleReconnect(self):
|
||||||
|
#debug.methodNamePrintf(self, 'scheduleReconnect')
|
||||||
when = time.time() + 60
|
when = time.time() + 60
|
||||||
whenS = time.strftime(conf.logTimestampFormat, time.localtime(when))
|
whenS = time.strftime(conf.logTimestampFormat, time.localtime(when))
|
||||||
debug.msg('Scheduling reconnect at %s' % whenS, 'normal')
|
debug.msg('Scheduling reconnect at %s' % whenS, 'normal')
|
||||||
@ -94,9 +95,8 @@ class AsyncoreDriver(asynchat.async_chat, object):
|
|||||||
return asynchat.async_chat.writable(self)
|
return asynchat.async_chat.writable(self)
|
||||||
|
|
||||||
def handle_error(self):
|
def handle_error(self):
|
||||||
debug.recoverableException()
|
#debug.recoverableException()
|
||||||
self.scheduleReconnect()
|
self.handle_close()
|
||||||
self.close()
|
|
||||||
|
|
||||||
def collect_incoming_data(self, s):
|
def collect_incoming_data(self, s):
|
||||||
#debug.methodNamePrintf(self, 'collect_incoming_data')
|
#debug.methodNamePrintf(self, 'collect_incoming_data')
|
||||||
@ -121,9 +121,11 @@ class AsyncoreDriver(asynchat.async_chat, object):
|
|||||||
reconnect = handle_close
|
reconnect = handle_close
|
||||||
|
|
||||||
def handle_connect(self):
|
def handle_connect(self):
|
||||||
|
#debug.methodNamePrintf(self, 'handle_connect')
|
||||||
pass
|
pass
|
||||||
|
|
||||||
def die(self):
|
def die(self):
|
||||||
|
#debug.methodNamePrintf(self, 'die')
|
||||||
self.close()
|
self.close()
|
||||||
|
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user