diff options
author | Erik Johnston <erik@matrix.org> | 2017-03-31 11:46:20 +0100 |
---|---|---|
committer | Erik Johnston <erik@matrix.org> | 2017-03-31 15:42:22 +0100 |
commit | 36d2b66f90dcdfae843c4b0ee7cba1dea23486f4 (patch) | |
tree | ed3497a65596f9daf3158330db858de02c47ea16 /synapse/replication/tcp/resource.py | |
parent | Fix up presence (diff) | |
download | synapse-36d2b66f90dcdfae843c4b0ee7cba1dea23486f4.tar.xz |
Add a timestamp to USER_SYNC command
This timestamp is used to indicate when the user last sync'd
Diffstat (limited to '')
-rw-r--r-- | synapse/replication/tcp/resource.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/synapse/replication/tcp/resource.py b/synapse/replication/tcp/resource.py index d5da0496a8..243a81d488 100644 --- a/synapse/replication/tcp/resource.py +++ b/synapse/replication/tcp/resource.py @@ -220,12 +220,12 @@ class ReplicationStreamer(object): self.federation_sender.federation_ack(token) @measure_func("repl.on_user_sync") - def on_user_sync(self, conn_id, user_id, is_syncing): + def on_user_sync(self, conn_id, user_id, is_syncing, last_sync_ms): """A client has started/stopped syncing on a worker. """ user_sync_counter.inc() self.presence_handler.update_external_syncs_row( - conn_id, user_id, is_syncing + conn_id, user_id, is_syncing, last_sync_ms, ) @measure_func("repl.on_remove_pusher") |