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

Comments

Browse source
This commit is contained in:
Erik Johnston 2017-01-20 17:13:24 +00:00
parent a55fa2047f
commit 5d2134d485
1 changed files with 19 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

27
synapse/storage/events.py
View file

@ -483,6 +483,10 @@ class EventsStore(SQLBaseStore):
retcols=["event_id", "type", "state_key"], retcols=["event_id", "type", "state_key"],
) )
# Figure out what has changed (if anything). Then we simply delete
# and readd the keys that have been changed.
# This saves us from deleting and reinserting thousands of rows for
# large rooms.
existing_events = set(row["event_id"] for row in existing_state_rows) existing_events = set(row["event_id"] for row in existing_state_rows)
new_events = set(ev_id for ev_id in current_state.itervalues()) new_events = set(ev_id for ev_id in current_state.itervalues())
changed_events = existing_events ^ new_events changed_events = existing_events ^ new_events
@ -492,14 +496,6 @@ class EventsStore(SQLBaseStore):
[(ev_id,) for ev_id in changed_events], [(ev_id,) for ev_id in changed_events],
) )
# Add an entry to the current_state_resets table to record the point
# where we clobbered the current state
self._simple_insert_txn(
txn,
table="current_state_resets",
values={"event_stream_ordering": max_stream_order}
)
events_to_insert = (new_events - existing_events) events_to_insert = (new_events - existing_events)
to_insert = [ to_insert = [
(key, ev_id) for key, ev_id in current_state.iteritems() (key, ev_id) for key, ev_id in current_state.iteritems()
@ -519,6 +515,13 @@ class EventsStore(SQLBaseStore):
], ],
) )
# Invalidate the various caches
# Figure out the changes of membership to invalidate the
# `get_rooms_for_user` cache.
# We find out which membership events we may have deleted
# and which we have added, then we invlidate the caches for all
# those users.
members_changed = set( members_changed = set(
row["state_key"] for row in existing_state_rows row["state_key"] for row in existing_state_rows
if row["event_id"] in changed_events if row["event_id"] in changed_events
@ -534,6 +537,14 @@ class EventsStore(SQLBaseStore):
txn.call_after(self.get_users_in_room.invalidate, (room_id,)) txn.call_after(self.get_users_in_room.invalidate, (room_id,))
# Add an entry to the current_state_resets table to record the point
# where we clobbered the current state
self._simple_insert_txn(
txn,
table="current_state_resets",
values={"event_stream_ordering": max_stream_order}
)
for room_id, new_extrem in new_forward_extremeties.items(): for room_id, new_extrem in new_forward_extremeties.items():
self._simple_delete_txn( self._simple_delete_txn(
txn, txn,