Matrix-Mirrors/synapse-product
1
0
Fork 0
mirror of https://git.anonymousland.org/anonymousland/synapse-product.git synced 2024-12-23 16:19:26 -05:00
Code Issues Packages Projects Releases Wiki Activity

Comments

Browse Source
This commit is contained in:
Erik Johnston 2017-01-20 14:38:13 +00:00
parent 4c6a31cd6e
commit f2f40e64a9
1 changed files with 11 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
synapse/storage/events.py
View File

@ -279,6 +279,8 @@ class EventsStore(SQLBaseStore):
# We can't easily parallelize these since different chunks # We can't easily parallelize these since different chunks
# might contain the same event. :( # might contain the same event. :(
# NB: Assumes that we are only persisting events for one room
# at a time.
new_forward_extremeties = {} new_forward_extremeties = {}
current_state_for_room = {} current_state_for_room = {}
if not backfilled: if not backfilled:
@ -361,14 +363,21 @@ class EventsStore(SQLBaseStore):
@defer.inlineCallbacks @defer.inlineCallbacks
def _calculate_new_extremeties(self, room_id, events): def _calculate_new_extremeties(self, room_id, events):
"""Caculates the new forward extremeties for a room given events to
persist.
Assumes that we are only persisting events for one room at a time.
"""
latest_event_ids = yield self.get_latest_event_ids_in_room( latest_event_ids = yield self.get_latest_event_ids_in_room(
room_id room_id
) )
new_latest_event_ids = set(latest_event_ids) new_latest_event_ids = set(latest_event_ids)
# First, add all the new events to the list
new_latest_event_ids.update( new_latest_event_ids.update(
event.event_id for event in events event.event_id for event in events
if not event.internal_metadata.is_outlier() if not event.internal_metadata.is_outlier()
) )
# Now remove all events that are referenced by the to-be-added events
new_latest_event_ids.difference_update( new_latest_event_ids.difference_update(
e_id e_id
for event in events for event in events
@ -376,6 +385,8 @@ class EventsStore(SQLBaseStore):
if not event.internal_metadata.is_outlier() if not event.internal_metadata.is_outlier()
) )
# And finally remove any events that are referenced by previously added
# events.
rows = yield self._simple_select_many_batch( rows = yield self._simple_select_many_batch(
table="event_edges", table="event_edges",
column="prev_event_id", column="prev_event_id",