OpenCloud
/
MatrixSynapse
mirror of https://github.com/matrix-org/synapse
1
0
Fork 0
Code Issues Releases Wiki Activity

Comments

pull/6664/head
Erik Johnston 2020-01-08 14:27:35 +00:00
parent 187dc6ad02
commit bca3455b38
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
synapse/storage/data_stores/main/room.py
View File

@ -453,6 +453,8 @@ class RoomWorkerStore(SQLBaseStore):
remote_media_mxcs = [] remote_media_mxcs = []
while True: while True:
# The first time round we just want to get the most recent
# events, then we bound by stream ordering
if next_token is None: if next_token is None:
sql = """ sql = """
SELECT stream_ordering, json FROM events SELECT stream_ordering, json FROM events
@ -496,6 +498,7 @@ class RoomWorkerStore(SQLBaseStore):
remote_media_mxcs.append((hostname, media_id)) remote_media_mxcs.append((hostname, media_id))
if next_token is None: if next_token is None:
# We've gone through the whole room, so we're finished.
break break
return local_media_mxcs, remote_media_mxcs return local_media_mxcs, remote_media_mxcs