Update total_events and total_event_bytes on new events.

Signed-off-by: Olivier Wilkinson (reivilibre) <olivier@librepush.net>

1 files changed, 6 insertions, 0 deletions

diff --git a/synapse/handlers/stats.py b/synapse/handlers/stats.py
index 7536e1a54c..e9b1646e0e 100644
--- a/synapse/handlers/stats.py
+++ b/synapse/handlers/stats.py
@@ -111,6 +111,12 @@ class StatsHandler(StateDeltasHandler):
                 if self.pos is not None:
                     yield self.store.update_stats_positions(self.pos)
 
+        # Then count deltas for total_events and total_event_bytes.
+        with Measure(self.clock, "stats_total_events_and_bytes"):
+            self.pos = yield self.store.incremental_update_total_events_and_bytes(
+                self.pos
+            )
+
     @defer.inlineCallbacks
     def _handle_deltas(self, deltas):
         """