From a4ad9b95567cc821b493e4b73477ed9f7cba9932 Mon Sep 17 00:00:00 2001 From: Erik Johnston Date: Mon, 22 Jun 2015 17:17:25 +0100 Subject: Only persist a maximum of 100 events at a time --- synapse/storage/events.py | 13 +++++++++++++ 1 file changed, 13 insertions(+) diff --git a/synapse/storage/events.py b/synapse/storage/events.py index ec798704dc..f9984b7444 100644 --- a/synapse/storage/events.py +++ b/synapse/storage/events.py @@ -416,6 +416,19 @@ class EventsStore(SQLBaseStore): def _persist_events_txn(self, txn, events_and_contexts, backfilled, is_new_state=True): + if len(events_and_contexts) > 100: + chunks = [ + events_and_contexts[x:x+100] + for x in xrange(0, len(events_and_contexts), 100) + ] + + for chunk in chunks: + self._persist_events_txn( + txn, + chunk, backfilled, is_new_state, + ) + return + # Remove the any existing cache entries for the event_ids for event, _ in events_and_contexts: txn.call_after(self._invalidate_get_event_cache, event.event_id) -- cgit 1.4.1