diff options
author | Erik Johnston <erik@matrix.org> | 2017-05-02 10:36:35 +0100 |
---|---|---|
committer | Erik Johnston <erik@matrix.org> | 2017-05-02 10:36:35 +0100 |
commit | 7166854f4169999fee0cd40a5ed389cc684b6dc8 (patch) | |
tree | 7443dd5e6dc7ef0d83a1a1109d3ff57ff8379acd /synapse/federation | |
parent | Merge pull request #2080 from matrix-org/erikj/filter_speed (diff) | |
download | synapse-7166854f4169999fee0cd40a5ed389cc684b6dc8.tar.xz |
Add cache for get_current_hosts_in_room
Diffstat (limited to 'synapse/federation')
-rw-r--r-- | synapse/federation/transaction_queue.py | 6 |
1 files changed, 1 insertions, 5 deletions
diff --git a/synapse/federation/transaction_queue.py b/synapse/federation/transaction_queue.py index dee387eb7f..695f1a7375 100644 --- a/synapse/federation/transaction_queue.py +++ b/synapse/federation/transaction_queue.py @@ -24,7 +24,6 @@ from synapse.util.async import run_on_reactor from synapse.util.logcontext import preserve_context_over_fn, preserve_fn from synapse.util.retryutils import NotRetryingDestination, get_retry_limiter from synapse.util.metrics import measure_func -from synapse.types import get_domain_from_id from synapse.handlers.presence import format_user_presence_state, get_interested_remotes import synapse.metrics @@ -183,15 +182,12 @@ class TransactionQueue(object): # Otherwise if the last member on a server in a room is # banned then it won't receive the event because it won't # be in the room after the ban. - users_in_room = yield self.state.get_current_user_in_room( + destinations = yield self.state.get_current_hosts_in_room( event.room_id, latest_event_ids=[ prev_id for prev_id, _ in event.prev_events ], ) - destinations = set( - get_domain_from_id(user_id) for user_id in users_in_room - ) if send_on_behalf_of is not None: # If we are sending the event on behalf of another server # then it already has the event and there is no reason to |