diff options
author | Kokokokoka <vasiliy.boytsov@gmail.com> | 2021-09-24 12:19:51 +0300 |
---|---|---|
committer | GitHub <noreply@github.com> | 2021-09-24 09:19:51 +0000 |
commit | e704cc2a48c6adc5d3da79a49ed02961edfc3b4a (patch) | |
tree | 0f4f88c0932dba6c186c199a498ec2cf29a01963 /synapse/storage | |
parent | Allow `.` and `~` chars in registration tokens (#10887) (diff) | |
download | synapse-e704cc2a48c6adc5d3da79a49ed02961edfc3b4a.tar.xz |
In `_purge_history_txn`, ensure that txn.fetchall has elements before accessing rows (#10690)
This change adds a check for row existence before accessing row element, this should fix issue #10669 Signed-off-by: Vasya Boytsov vasiliy.boytsov@phystech.edu
Diffstat (limited to 'synapse/storage')
-rw-r--r-- | synapse/storage/databases/main/purge_events.py | 22 |
1 files changed, 13 insertions, 9 deletions
diff --git a/synapse/storage/databases/main/purge_events.py b/synapse/storage/databases/main/purge_events.py index bccff5e5b9..3eb30944bf 100644 --- a/synapse/storage/databases/main/purge_events.py +++ b/synapse/storage/databases/main/purge_events.py @@ -102,15 +102,19 @@ class PurgeEventsStore(StateGroupWorkerStore, CacheInvalidationWorkerStore): (room_id,), ) rows = txn.fetchall() - max_depth = max(row[1] for row in rows) - - if max_depth < token.topological: - # We need to ensure we don't delete all the events from the database - # otherwise we wouldn't be able to send any events (due to not - # having any backwards extremities) - raise SynapseError( - 400, "topological_ordering is greater than forward extremeties" - ) + # if we already have no forwards extremities (for example because they were + # cleared out by the `delete_old_current_state_events` background database + # update), then we may as well carry on. + if rows: + max_depth = max(row[1] for row in rows) + + if max_depth < token.topological: + # We need to ensure we don't delete all the events from the database + # otherwise we wouldn't be able to send any events (due to not + # having any backwards extremities) + raise SynapseError( + 400, "topological_ordering is greater than forward extremities" + ) logger.info("[purge] looking for events to delete") |