mirrors/synapse
1
0
Fork 0
mirror of https://github.com/element-hq/synapse.git synced 2024-11-26 11:36:03 +03:00
Code Issues Projects Releases Packages Wiki Activity

Limit batch size

Browse source
This commit is contained in:
Erik Johnston 2015-05-13 15:26:49 +01:00
parent ca4f458787
commit 5971d240d4
1 changed files with 10 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
synapse/storage/_base.py
View file

@ -28,6 +28,7 @@ from twisted.internet import defer
from collections import namedtuple, OrderedDict from collections import namedtuple, OrderedDict
import functools import functools
import itertools
import simplejson as json import simplejson as json
import sys import sys
import time import time
@ -875,11 +876,15 @@ class SQLBaseStore(object):
def _get_events_txn(self, txn, event_ids, check_redacted=True, def _get_events_txn(self, txn, event_ids, check_redacted=True,
get_prev_content=False): get_prev_content=False):
return self._fetch_events_txn( N = 50 # Only fetch 100 events at a time.
txn, event_ids, return list(itertools.chain(*[
check_redacted=check_redacted, self._fetch_events_txn(
get_prev_content=get_prev_content, txn, event_ids[i*N:(i+1)*N],
) check_redacted=check_redacted,
get_prev_content=get_prev_content,
)
for i in range(1 + len(event_ids) / N)
]))
def _invalidate_get_event_cache(self, event_id): def _invalidate_get_event_cache(self, event_id):
for check_redacted in (False, True): for check_redacted in (False, True):