mirror of
https://github.com/Mikaela/Limnoria.git
synced 2025-11-09 20:27:26 +01:00
Bugfix for darelf's IRC server.
This commit is contained in:
parent
25efb6fc74
commit
b099b66272
@ -103,7 +103,8 @@ class AsyncoreDriver(asynchat.async_chat, drivers.ServersMixin):
|
|||||||
start = time.time()
|
start = time.time()
|
||||||
msg = drivers.parseMsg(self.buffer)
|
msg = drivers.parseMsg(self.buffer)
|
||||||
self.buffer = ''
|
self.buffer = ''
|
||||||
self.irc.feedMsg(msg)
|
if msg is not None:
|
||||||
|
self.irc.feedMsg(msg)
|
||||||
|
|
||||||
def handle_close(self):
|
def handle_close(self):
|
||||||
self._scheduleReconnect()
|
self._scheduleReconnect()
|
||||||
|
|||||||
@ -200,8 +200,12 @@ def newDriver(irc, moduleName=None):
|
|||||||
|
|
||||||
def parseMsg(s):
|
def parseMsg(s):
|
||||||
start = time.time()
|
start = time.time()
|
||||||
msg = ircmsgs.IrcMsg(s)
|
s = s.strip()
|
||||||
log.stat('Time to parse IrcMsg: %s', time.time()-start)
|
if s:
|
||||||
return msg
|
msg = ircmsgs.IrcMsg(s)
|
||||||
|
log.stat('Time to parse IrcMsg: %s', time.time()-start)
|
||||||
|
return msg
|
||||||
|
else:
|
||||||
|
return None
|
||||||
|
|
||||||
# vim:set shiftwidth=4 tabstop=8 expandtab textwidth=78:
|
# vim:set shiftwidth=4 tabstop=8 expandtab textwidth=78:
|
||||||
|
|||||||
@ -109,7 +109,8 @@ class SocketDriver(drivers.IrcDriver, drivers.ServersMixin):
|
|||||||
self.inbuffer = lines.pop()
|
self.inbuffer = lines.pop()
|
||||||
for line in lines:
|
for line in lines:
|
||||||
msg = drivers.parseMsg(line)
|
msg = drivers.parseMsg(line)
|
||||||
self.irc.feedMsg(msg)
|
if msg is not None:
|
||||||
|
self.irc.feedMsg(msg)
|
||||||
except socket.timeout:
|
except socket.timeout:
|
||||||
pass
|
pass
|
||||||
except socket.error, e:
|
except socket.error, e:
|
||||||
|
|||||||
@ -61,7 +61,8 @@ class SupyIrcProtocol(LineReceiver):
|
|||||||
def lineReceived(self, line):
|
def lineReceived(self, line):
|
||||||
start = time.time()
|
start = time.time()
|
||||||
msg = drivers.parseMsg(line)
|
msg = drivers.parseMsg(line)
|
||||||
self.irc.feedMsg(msg)
|
if msg is not None:
|
||||||
|
self.irc.feedMsg(msg)
|
||||||
|
|
||||||
def checkIrcForMsgs(self):
|
def checkIrcForMsgs(self):
|
||||||
if self.connected:
|
if self.connected:
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user