Matrix-Mirrors/synapse-product
1
0
Fork 0
mirror of https://git.anonymousland.org/anonymousland/synapse-product.git synced 2024-10-01 08:25:44 -04:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #3581 from matrix-org/erikj/fixup_stateless

Browse Source 
Fix EventContext when using workers
This commit is contained in:
Erik Johnston 2018-07-23 16:06:59 +01:00 committed by GitHub
commit 37e87611bc
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
changelog.d/3581.misc Normal file
View File

@ -0,0 +1 @@
Lazily load state on master process when using workers to reduce DB consumption

14
synapse/events/snapshot.py
View File

@ -82,6 +82,11 @@ class EventContext(object):
"_fetching_state_deferred", "_fetching_state_deferred",
] ]
def __init__(self):
self.prev_state_events = []
self.rejected = False
self.app_service = None
@staticmethod @staticmethod
def with_state(state_group, current_state_ids, prev_state_ids, def with_state(state_group, current_state_ids, prev_state_ids,
prev_group=None, delta_ids=None): prev_group=None, delta_ids=None):
@ -103,11 +108,6 @@ class EventContext(object):
context.prev_group = prev_group context.prev_group = prev_group
context.delta_ids = delta_ids context.delta_ids = delta_ids
context.prev_state_events = []
context.rejected = False
context.app_service = None
return context return context
def serialize(self, event): def serialize(self, event):
@ -143,7 +143,6 @@ class EventContext(object):
} }
@staticmethod @staticmethod
@defer.inlineCallbacks
def deserialize(store, input): def deserialize(store, input):
"""Converts a dict that was produced by `serialize` back into a """Converts a dict that was produced by `serialize` back into a
EventContext. EventContext.
@ -162,6 +161,7 @@ class EventContext(object):
context._prev_state_id = input["prev_state_id"] context._prev_state_id = input["prev_state_id"]
context._event_type = input["event_type"] context._event_type = input["event_type"]
context._event_state_key = input["event_state_key"] context._event_state_key = input["event_state_key"]
context._fetching_state_deferred = None
context.state_group = input["state_group"] context.state_group = input["state_group"]
context.prev_group = input["prev_group"] context.prev_group = input["prev_group"]
@ -174,7 +174,7 @@ class EventContext(object):
if app_service_id: if app_service_id:
context.app_service = store.get_app_service_by_id(app_service_id) context.app_service = store.get_app_service_by_id(app_service_id)
defer.returnValue(context) return context
@defer.inlineCallbacks @defer.inlineCallbacks
def get_current_state_ids(self, store): def get_current_state_ids(self, store):