diff options
| author | Erik Johnston <erik@matrix.org> | 2016-11-23 11:11:41 +0000 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2016-11-23 11:11:41 +0000 |
| commit | 4d9b5c60f958320fb80f968a312eb83cf48258d5 (patch) | |
| tree | 58ac2fa1936d07ceef91c10f99dbe716494d84d4 /synapse/app | |
| parent | Explicit federation ack (diff) | |
| download | synapse-4d9b5c60f958320fb80f968a312eb83cf48258d5.tar.xz | |
Comment
Diffstat (limited to 'synapse/app')
| -rw-r--r-- | synapse/app/federation_sender.py | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/synapse/app/federation_sender.py b/synapse/app/federation_sender.py index dcdbe79a17..80ea4c8062 100644 --- a/synapse/app/federation_sender.py +++ b/synapse/app/federation_sender.py @@ -237,6 +237,9 @@ class FederationSenderHandler(object): stream_id = yield self.store.get_federation_out_pos("federation") defer.returnValue({ "federation": stream_id, + + # Ack stuff we've "processed", this should only be called from + # one process. "federation_ack": stream_id, }) |