diff options
author | Erik Johnston <erikj@jki.re> | 2018-07-23 17:52:45 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2018-07-23 17:52:45 +0100 |
commit | f559119de0009cfa1d396358eb8c788ccc9da53b (patch) | |
tree | 0ee4c637318472f350e0f951ecac96ff1646b108 /synapse/events/snapshot.py | |
parent | Merge pull request #3582 from matrix-org/erikj/fixup_stateless (diff) | |
parent | Comments (diff) | |
download | synapse-f559119de0009cfa1d396358eb8c788ccc9da53b.tar.xz |
Merge pull request #3584 from matrix-org/erikj/use_cached
Only get cached state from context in persist_event
Diffstat (limited to 'synapse/events/snapshot.py')
-rw-r--r-- | synapse/events/snapshot.py | 14 |
1 files changed, 14 insertions, 0 deletions
diff --git a/synapse/events/snapshot.py b/synapse/events/snapshot.py index a59064b416..189212b0fa 100644 --- a/synapse/events/snapshot.py +++ b/synapse/events/snapshot.py @@ -163,6 +163,9 @@ class EventContext(object): context._prev_state_id = input["prev_state_id"] context._event_type = input["event_type"] context._event_state_key = input["event_state_key"] + + context._current_state_ids = None + context._prev_state_ids = None context._fetching_state_deferred = None context.state_group = input["state_group"] @@ -214,6 +217,17 @@ class EventContext(object): defer.returnValue(self._prev_state_ids) + def get_cached_current_state_ids(self): + """Gets the current state IDs if we have them already cached. + + Returns: + dict[(str, str), str]|None: Returns None if we haven't cached the + state or if state_group is None, which happens when the associated + event is an outlier. + """ + + return self._current_state_ids + @defer.inlineCallbacks def _fill_out_state(self, store): """Called to populate the _current_state_ids and _prev_state_ids |