Mikaela/Limnoria
1
0
Fork 0
mirror of https://github.com/Mikaela/Limnoria.git synced 2025-02-18 22:51:01 +01:00
Code Issues Projects Releases Wiki Activity

Converted Irc.fastqueue to a fix.queue

Browse Source
This commit is contained in:
Jeremy Fincher 2003-04-02 09:26:16 +00:00
parent 5ef1d3eaaa
commit 818f01e206
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/irclib.py
View File

@ -280,7 +280,7 @@ class Irc(object):
self._nickmods = copy.copy(conf.nickmods) self._nickmods = copy.copy(conf.nickmods)
self.state = IrcState() self.state = IrcState()
self.queue = IrcMsgQueue() self.queue = IrcMsgQueue()
self.fastqueue = [] self.fastqueue = queue()
self.lastping = time.time() self.lastping = time.time()
self.lastTake = 0 self.lastTake = 0
self.driver = None # The driver should set this later. self.driver = None # The driver should set this later.
@ -291,7 +291,7 @@ class Irc(object):
self._nickmods = copy.copy(conf.nickmods) self._nickmods = copy.copy(conf.nickmods)
self.state.reset() self.state.reset()
self.queue.reset() self.queue.reset()
self.fastqueue = [] self.fastqueue = queue()
self.queue.enqueueMsg(ircmsgs.user(self.user, self.ident)) self.queue.enqueueMsg(ircmsgs.user(self.user, self.ident))
self.queue.enqueueMsg(ircmsgs.nick(self.nick)) self.queue.enqueueMsg(ircmsgs.nick(self.nick))
for callback in self.callbacks: for callback in self.callbacks:
@ -316,13 +316,13 @@ class Irc(object):
self.queue.enqueueMsg(msg) self.queue.enqueueMsg(msg)
def sendMsg(self, msg): def sendMsg(self, msg):
self.fastqueue.append(msg) self.fastqueue.enqueue(msg)
def takeMsg(self): def takeMsg(self):
now = time.time() now = time.time()
msg = None msg = None
if self.fastqueue: if self.fastqueue:
msg = self.fastqueue.pop(0) msg = self.fastqueue.dequeue()
elif not self.queue.empty(): elif not self.queue.empty():
if now - self.lastTake <= conf.throttleTime: if now - self.lastTake <= conf.throttleTime:
debug.debugMsg('Irc.takeMsg throttling.', 'verbose') debug.debugMsg('Irc.takeMsg throttling.', 'verbose')