mirror of
https://github.com/element-hq/synapse
synced 2024-08-20 08:30:21 +00:00
Rename func
This commit is contained in:
parent
4ac363a168
commit
3670025e64
2 changed files with 2 additions and 2 deletions
|
@ -506,7 +506,7 @@ class ReplicationResource(Resource):
|
||||||
device_lists = request_streams.get("device_lists")
|
device_lists = request_streams.get("device_lists")
|
||||||
|
|
||||||
if device_lists is not None and device_lists != current_position:
|
if device_lists is not None and device_lists != current_position:
|
||||||
changes = yield self.store.get_users_and_hosts_device_list_changes(
|
changes = yield self.store.get_all_device_list_changes_for_remotes(
|
||||||
device_lists,
|
device_lists,
|
||||||
)
|
)
|
||||||
writer.write_header_and_rows("device_lists", changes, (
|
writer.write_header_and_rows("device_lists", changes, (
|
||||||
|
|
|
@ -465,7 +465,7 @@ class DeviceStore(SQLBaseStore):
|
||||||
rows = yield self._execute("get_user_whose_devices_changed", None, sql, from_key)
|
rows = yield self._execute("get_user_whose_devices_changed", None, sql, from_key)
|
||||||
defer.returnValue(set(row["user_id"] for row in rows))
|
defer.returnValue(set(row["user_id"] for row in rows))
|
||||||
|
|
||||||
def get_users_and_hosts_device_list_changes(self, from_key):
|
def get_all_device_list_changes_for_remotes(self, from_key):
|
||||||
"""Return a list of `(stream_id, user_id, destination)` which is the
|
"""Return a list of `(stream_id, user_id, destination)` which is the
|
||||||
combined list of changes to devices, and which destinations need to be
|
combined list of changes to devices, and which destinations need to be
|
||||||
poked. `destination` may be None if no destinations need to be poked.
|
poked. `destination` may be None if no destinations need to be poked.
|
||||||
|
|
Loading…
Reference in a new issue