diff options
| author | Richard van der Hoff <richard@matrix.org> | 2018-03-13 09:57:54 +0000 |
|---|---|---|
| committer | Richard van der Hoff <richard@matrix.org> | 2018-03-13 10:01:42 +0000 |
| commit | 889a2a853a83057d4f218bb828bf686db786d590 (patch) | |
| tree | 8a2098672dbf4d8e5977842a4e862c43d607efa9 | |
| parent | Merge pull request #2962 from matrix-org/rav/purge_history_txns (diff) | |
| download | synapse-889a2a853a83057d4f218bb828bf686db786d590.tar.xz | |
Add Measure block for persist_events
This seems like a useful thing to measure.
| -rw-r--r-- | synapse/storage/events.py | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/synapse/storage/events.py b/synapse/storage/events.py index 826fad307e..3890878170 100644 --- a/synapse/storage/events.py +++ b/synapse/storage/events.py @@ -283,10 +283,11 @@ class EventsStore(EventsWorkerStore): def _maybe_start_persisting(self, room_id): @defer.inlineCallbacks def persisting_queue(item): - yield self._persist_events( - item.events_and_contexts, - backfilled=item.backfilled, - ) + with Measure(self._clock, "persist_events"): + yield self._persist_events( + item.events_and_contexts, + backfilled=item.backfilled, + ) self._event_persist_queue.handle_queue(room_id, persisting_queue) |