diff options
author | Hubert Chathi <hubert@uhoreg.ca> | 2019-10-30 14:57:34 -0400 |
---|---|---|
committer | Hubert Chathi <hubert@uhoreg.ca> | 2019-10-30 14:57:34 -0400 |
commit | bb6cec27a5ac6d5d6d5f67df21610a63745ac0a9 (patch) | |
tree | 20fe45ccc7c8371e10ab8dc7eca9fcadd8da63bc /synapse/storage/data_stores | |
parent | Merge branch 'develop' into cross-signing_federation (diff) | |
download | synapse-bb6cec27a5ac6d5d6d5f67df21610a63745ac0a9.tar.xz |
rename get_devices_by_remote to get_device_updates_by_remote
Diffstat (limited to 'synapse/storage/data_stores')
-rw-r--r-- | synapse/storage/data_stores/main/devices.py | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/synapse/storage/data_stores/main/devices.py b/synapse/storage/data_stores/main/devices.py index 0b12bc58c4..717eab4159 100644 --- a/synapse/storage/data_stores/main/devices.py +++ b/synapse/storage/data_stores/main/devices.py @@ -91,7 +91,7 @@ class DeviceWorkerStore(SQLBaseStore): @trace @defer.inlineCallbacks - def get_devices_by_remote(self, destination, from_stream_id, limit): + def get_device_updates_by_remote(self, destination, from_stream_id, limit): """Get a stream of device updates to send to the given remote server. Args: @@ -123,8 +123,8 @@ class DeviceWorkerStore(SQLBaseStore): # stream_id; the rationale being that such a large device list update # is likely an error. updates = yield self.runInteraction( - "get_devices_by_remote", - self._get_devices_by_remote_txn, + "get_device_updates_by_remote", + self._get_device_updates_by_remote_txn, destination, from_stream_id, now_stream_id, @@ -241,7 +241,7 @@ class DeviceWorkerStore(SQLBaseStore): return now_stream_id, results - def _get_devices_by_remote_txn( + def _get_device_updates_by_remote_txn( self, txn, destination, from_stream_id, now_stream_id, limit ): """Return device update information for a given remote destination |