diff options
| author | Erik Johnston <erik@matrix.org> | 2020-05-22 14:21:54 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-05-22 14:21:54 +0100 |
| commit | 1531b214fc57714c14046a8f66c7b5fe5ec5dcdd (patch) | |
| tree | fd150f21a14dcc6f5cf3f373984478dd12d43c95 /synapse/server.pyi | |
| parent | Convert sending mail to async/await. (#7557) (diff) | |
| download | synapse-1531b214fc57714c14046a8f66c7b5fe5ec5dcdd.tar.xz | |
Add ability to wait for replication streams (#7542)
The idea here is that if an instance persists an event via the replication HTTP API it can return before we receive that event over replication, which can lead to races where code assumes that persisting an event immediately updates various caches (e.g. current state of the room). Most of Synapse doesn't hit such races, so we don't do the waiting automagically, instead we do so where necessary to avoid unnecessary delays. We may decide to change our minds here if it turns out there are a lot of subtle races going on. People probably want to look at this commit by commit.
Diffstat (limited to 'synapse/server.pyi')
| -rw-r--r-- | synapse/server.pyi | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/synapse/server.pyi b/synapse/server.pyi index 9e7fad7e6e..fe8024d2d4 100644 --- a/synapse/server.pyi +++ b/synapse/server.pyi @@ -1,3 +1,5 @@ +from typing import Dict + import twisted.internet import synapse.api.auth @@ -28,6 +30,7 @@ import synapse.server_notices.server_notices_sender import synapse.state import synapse.storage from synapse.events.builder import EventBuilderFactory +from synapse.replication.tcp.streams import Stream class HomeServer(object): @property @@ -136,3 +139,5 @@ class HomeServer(object): pass def get_pusherpool(self) -> synapse.push.pusherpool.PusherPool: pass + def get_replication_streams(self) -> Dict[str, Stream]: + pass |