summary refs log tree commit diff
path: root/synapse/federation/transaction_queue.py
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2017-04-12 10:11:43 +0100
committerErik Johnston <erik@matrix.org>2017-04-12 10:16:26 +0100
commitc7ddb5ef7ac3dc7370010ee6685497ee73f46fa2 (patch)
treecb0b7ea77f9709eebd95b34aa7f56bac3d300a52 /synapse/federation/transaction_queue.py
parentMove get_presence_list_* to SlaveStore (diff)
downloadsynapse-c7ddb5ef7ac3dc7370010ee6685497ee73f46fa2.tar.xz
Reuse get_interested_parties
Diffstat (limited to 'synapse/federation/transaction_queue.py')
-rw-r--r--synapse/federation/transaction_queue.py6
1 files changed, 3 insertions, 3 deletions
diff --git a/synapse/federation/transaction_queue.py b/synapse/federation/transaction_queue.py
index 260a472255..feb1605019 100644
--- a/synapse/federation/transaction_queue.py
+++ b/synapse/federation/transaction_queue.py
@@ -269,13 +269,13 @@ class TransactionQueue(object):
         self._processing_pending_presence = True
         try:
             while True:
-                states = self.pending_presence
+                states_map = self.pending_presence
                 self.pending_presence = {}
 
-                if not states:
+                if not states_map:
                     break
 
-                yield self._process_presence_inner(states)
+                yield self._process_presence_inner(states_map.values())
         finally:
             self._processing_pending_presence = False