mirror of
https://github.com/Mikaela/Limnoria.git
synced 2024-11-02 17:29:22 +01:00
Changed the uses of queue to a smallqueue.
This commit is contained in:
parent
ae61e178ec
commit
657db2c1f7
@ -30,7 +30,7 @@
|
|||||||
###
|
###
|
||||||
|
|
||||||
import fix
|
import fix
|
||||||
from structures import queue, RingBuffer
|
from structures import queue, smallqueue, RingBuffer
|
||||||
|
|
||||||
import copy
|
import copy
|
||||||
import sets
|
import sets
|
||||||
@ -137,9 +137,9 @@ class IrcMsgQueue(object):
|
|||||||
|
|
||||||
def reset(self):
|
def reset(self):
|
||||||
"""Clears the queue."""
|
"""Clears the queue."""
|
||||||
self.highpriority = queue()
|
self.highpriority = smallqueue()
|
||||||
self.normal = queue()
|
self.normal = smallqueue()
|
||||||
self.lowpriority = queue()
|
self.lowpriority = smallqueue()
|
||||||
self.msgs = sets.Set()
|
self.msgs = sets.Set()
|
||||||
|
|
||||||
def enqueue(self, msg):
|
def enqueue(self, msg):
|
||||||
@ -400,7 +400,7 @@ class Irc(object):
|
|||||||
self.queue = IrcMsgQueue()
|
self.queue = IrcMsgQueue()
|
||||||
self._nickmods = copy.copy(conf.nickmods)
|
self._nickmods = copy.copy(conf.nickmods)
|
||||||
self.lastTake = 0
|
self.lastTake = 0
|
||||||
self.fastqueue = queue()
|
self.fastqueue = smallqueue()
|
||||||
self.lastping = time.time()
|
self.lastping = time.time()
|
||||||
self.outstandingPing = False
|
self.outstandingPing = False
|
||||||
self.driver = None # The driver should set this later.
|
self.driver = None # The driver should set this later.
|
||||||
|
Loading…
Reference in New Issue
Block a user