Fix StreamIdGenerator not handling unpersisted IDs

Spotted by @erikjohnston. Closes #14456.
matrix-org · Nov 16, 2022 · f0601a2 · f0601a2
1 parent 8d3fd3a
commit f0601a2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/synapse/storage/util/id_generators.py b/synapse/storage/util/id_generators.py
@@ -253,7 +253,7 @@ def manager() -> Generator[Sequence[int], None, None]:
         return _AsyncCtxManagerWrapper(manager())
 
     def get_current_token(self) -> int:
-        if self._is_writer:
+        if not self._is_writer:
             return self._current
 
         with self._lock: