MirrorHub/synapse
0
0
Fork 1
mirror of https://mau.dev/maunium/synapse.git synced 2024-12-16 22:53:52 +01:00
Code Issues Projects Releases Wiki Activity

WheelTimer: Don't scan list, use index.

Browse source
This commit is contained in:
Erik Johnston 2016-02-18 16:33:07 +00:00
parent 48b652bcbe
commit b8cdec92c7
1 changed files with 8 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
synapse/util/wheel_timer.py
View file

@ -46,11 +46,14 @@ class WheelTimer(object):
then (int): When to return the object strictly after.
"""
then_key = int(then / self.bucket_size) + 1
for entry in self.entries:
# Add to first bucket we find. This should gracefully handle inserts
# for times in the past.
if entry.end_key >= then_key:
entry.queue.append(obj)
if self.entries:
min_key = self.entries[0].end_key
max_key = self.entries[-1].end_key
if then_key <= max_key:
# The max here is to protect against inserts for times in the past
self.entries[max(min_key, then_key) - min_key].queue.append(obj)
return
next_key = int(now / self.bucket_size) + 1