diff options
| author | Erik Johnston <erik@matrix.org> | 2020-10-02 12:22:19 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-10-02 12:22:19 +0100 |
| commit | 695240d34a9dd1c34379ded1fbbbe42a1850549e (patch) | |
| tree | b8ab12b922cf6217e91baf279db02607f267cdfa /synapse/storage/util | |
| parent | Convert additional templates to Jinja (#8444) (diff) | |
| download | synapse-695240d34a9dd1c34379ded1fbbbe42a1850549e.tar.xz | |
Fix DB query on startup for negative streams. (#8447)
For negative streams we have to negate the internal stream ID before querying the DB. The effect of this bug was to query far too many rows, slowing start up time, but we would correctly filter the results afterwards so there was no ill effect.
Diffstat (limited to 'synapse/storage/util')
| -rw-r--r-- | synapse/storage/util/id_generators.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/synapse/storage/util/id_generators.py b/synapse/storage/util/id_generators.py index 02fbb656e8..48efbb5067 100644 --- a/synapse/storage/util/id_generators.py +++ b/synapse/storage/util/id_generators.py @@ -341,7 +341,7 @@ class MultiWriterIdGenerator: "cmp": "<=" if self._positive else ">=", } sql = self._db.engine.convert_param_style(sql) - cur.execute(sql, (min_stream_id,)) + cur.execute(sql, (min_stream_id * self._return_factor,)) self._persisted_upto_position = min_stream_id |