diff options
| author | Erik Johnston <erik@matrix.org> | 2015-05-21 15:46:07 +0100 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2015-05-21 15:46:07 +0100 |
| commit | ae3bff349151d8f309bdf29fd258b215cb792e90 (patch) | |
| tree | 373e88ec65ea0531a9a34959554a5cd2f08d54de /synapse | |
| parent | Don't prepopulate event_results (diff) | |
| download | synapse-ae3bff349151d8f309bdf29fd258b215cb792e90.tar.xz | |
Correctly prepopulate queue
Diffstat (limited to 'synapse')
| -rw-r--r-- | synapse/storage/event_federation.py | 12 |
1 files changed, 10 insertions, 2 deletions
diff --git a/synapse/storage/event_federation.py b/synapse/storage/event_federation.py index 26d570cf2d..91d19857b1 100644 --- a/synapse/storage/event_federation.py +++ b/synapse/storage/event_federation.py @@ -394,8 +394,16 @@ class EventFederationStore(SQLBaseStore): (room_id, event_id, limit - len(event_results)) ) - for row in txn.fetchall(): - queue.put((-row[0], row[1])) + depth = self._simple_select_one_onecol_txn( + txn, + table="events", + keyvalues={ + "event_id": event_id, + }, + retcol="depth" + ) + + queue.put((-depth, event_id)) while not queue.empty() and len(event_results) < limit: try: |