summary refs log tree commit diff
path: root/synapse/storage
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2015-05-21 15:38:08 +0100
committerErik Johnston <erik@matrix.org>2015-05-21 15:38:08 +0100
commit6189d8e54d7f7d55cd6cd2e9d7f866e895c6fe44 (patch)
treebbb60f05993ba20419d250be764ed126c20b99fa /synapse/storage
parentCorrectly capture Queue.Empty exception (diff)
downloadsynapse-6189d8e54d7f7d55cd6cd2e9d7f866e895c6fe44.tar.xz
PriorityQueue gives lowest first
Diffstat (limited to 'synapse/storage')
-rw-r--r--synapse/storage/event_federation.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/synapse/storage/event_federation.py b/synapse/storage/event_federation.py
index e171cbcdb4..03942fec7a 100644
--- a/synapse/storage/event_federation.py
+++ b/synapse/storage/event_federation.py
@@ -395,7 +395,7 @@ class EventFederationStore(SQLBaseStore):
             )
 
             for row in txn.fetchall():
-                queue.put(row)
+                queue.put((-row[0], row[1]))
 
         while not queue.empty() and len(event_results) < limit:
             try:
@@ -411,7 +411,7 @@ class EventFederationStore(SQLBaseStore):
             )
 
             for row in txn.fetchall():
-                queue.put(row)
+                queue.put((-row[0], row[1]))
 
         return event_results