summary refs log tree commit diff
path: root/synapse/storage/deviceinbox.py
diff options
context:
space:
mode:
authorRichard van der Hoff <richard@matrix.org>2017-03-15 12:16:55 +0000
committerRichard van der Hoff <richard@matrix.org>2017-03-15 12:16:55 +0000
commit29ed09e80a8c7ddeebe3f257a336e4c387a06c88 (patch)
tree9fb244c8c00d9d01cd0856f0efc028caf53f4688 /synapse/storage/deviceinbox.py
parentMerge pull request #2008 from matrix-org/erikj/notifier_stats (diff)
downloadsynapse-29ed09e80a8c7ddeebe3f257a336e4c387a06c88.tar.xz
Fix assertion to stop transaction queue getting wedged
... and update some docstrings to correctly reflect the types being used.

get_new_device_msgs_for_remote can return a long under some circumstances,
which was being stored in last_device_list_stream_id_by_dest, and was then
upsetting things on the next loop.
Diffstat (limited to 'synapse/storage/deviceinbox.py')
-rw-r--r--synapse/storage/deviceinbox.py6
1 files changed, 3 insertions, 3 deletions
diff --git a/synapse/storage/deviceinbox.py b/synapse/storage/deviceinbox.py

index 5c7db5e5f6..7925cb5f1b 100644 --- a/synapse/storage/deviceinbox.py +++ b/synapse/storage/deviceinbox.py
@@ -357,12 +357,12 @@ class DeviceInboxStore(BackgroundUpdateStore): """ Args: destination(str): The name of the remote server. - last_stream_id(int): The last position of the device message stream + last_stream_id(int|long): The last position of the device message stream that the server sent up to. - current_stream_id(int): The current position of the device + current_stream_id(int|long): The current position of the device message stream. Returns: - Deferred ([dict], int): List of messages for the device and where + Deferred ([dict], int|long): List of messages for the device and where in the stream the messages got to. """