summary refs log tree commit diff
path: root/synapse/storage/event_federation.py
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2015-02-23 14:35:23 +0000
committerErik Johnston <erik@matrix.org>2015-02-23 14:35:23 +0000
commit42b972bccd0cf7d903befb498f9c1bbd5c4e6583 (patch)
treee137939fc941e87448f243f41baf677dcb336737 /synapse/storage/event_federation.py
parentImplement and use new batched get missing pdu (diff)
downloadsynapse-42b972bccd0cf7d903befb498f9c1bbd5c4e6583.tar.xz
Revert get_auth_chain changes
Diffstat (limited to 'synapse/storage/event_federation.py')
-rw-r--r--synapse/storage/event_federation.py12
1 files changed, 5 insertions, 7 deletions
diff --git a/synapse/storage/event_federation.py b/synapse/storage/event_federation.py
index 22bf7ad832..2deda8ac50 100644
--- a/synapse/storage/event_federation.py
+++ b/synapse/storage/event_federation.py
@@ -32,15 +32,15 @@ class EventFederationStore(SQLBaseStore):
     and backfilling from another server respectively.
     """
 
-    def get_auth_chain(self, event_ids, have_ids=set()):
+    def get_auth_chain(self, event_ids):
         return self.runInteraction(
             "get_auth_chain",
             self._get_auth_chain_txn,
-            event_ids, have_ids
+            event_ids
         )
 
-    def _get_auth_chain_txn(self, txn, event_ids, have_ids):
-        results = self._get_auth_chain_ids_txn(txn, event_ids, have_ids)
+    def _get_auth_chain_txn(self, txn, event_ids):
+        results = self._get_auth_chain_ids_txn(txn, event_ids)
 
         return self._get_events_txn(txn, results)
 
@@ -51,9 +51,8 @@ class EventFederationStore(SQLBaseStore):
             event_ids
         )
 
-    def _get_auth_chain_ids_txn(self, txn, event_ids, have_ids):
+    def _get_auth_chain_ids_txn(self, txn, event_ids):
         results = set()
-        have_ids = set(have_ids)
 
         base_sql = (
             "SELECT auth_id FROM event_auth WHERE event_id = ?"
@@ -67,7 +66,6 @@ class EventFederationStore(SQLBaseStore):
                 new_front.update([r[0] for r in txn.fetchall()])
 
             new_front -= results
-            new_front -= have_ids
 
             front = new_front
             results.update(front)