summary refs log tree commit diff
path: root/synapse/storage/deviceinbox.py
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2019-06-11 00:23:54 +0100
committerErik Johnston <erik@matrix.org>2019-06-11 00:23:54 +0100
commit8f1711da0e1182fabe468f32a8b9f3254aad4dc4 (patch)
tree44b33cff83015c79734f9971d78c88f65b53b1e7 /synapse/storage/deviceinbox.py
parentMerge branch 'release-v1.0.0' of github.com:matrix-org/synapse into matrix-or... (diff)
parent1.0.0rc3 (diff)
downloadsynapse-8f1711da0e1182fabe468f32a8b9f3254aad4dc4.tar.xz
Merge branch 'release-v1.0.0' of github.com:matrix-org/synapse into matrix-org-hotfixes
Diffstat (limited to 'synapse/storage/deviceinbox.py')
-rw-r--r--synapse/storage/deviceinbox.py4
1 files changed, 4 insertions, 0 deletions
diff --git a/synapse/storage/deviceinbox.py b/synapse/storage/deviceinbox.py

index 9b0a99cb49..4ea0deea4f 100644 --- a/synapse/storage/deviceinbox.py +++ b/synapse/storage/deviceinbox.py
@@ -138,6 +138,10 @@ class DeviceInboxWorkerStore(SQLBaseStore): if not has_changed or last_stream_id == current_stream_id: return defer.succeed(([], current_stream_id)) + if limit <= 0: + # This can happen if we run out of room for EDUs in the transaction. + return defer.succeed(([], last_stream_id)) + def get_new_messages_for_remote_destination_txn(txn): sql = ( "SELECT stream_id, messages_json FROM device_federation_outbox"