diff --git a/synapse/storage/controllers/persist_events.py b/synapse/storage/controllers/persist_events.py index d0e015bf19..b002d482b1 100644 --- a/synapse/storage/controllers/persist_events.py +++ b/synapse/storage/controllers/persist_events.py @@ -1114,6 +1114,9 @@ class EventsPersistenceStorageController: if ev_id != existing_state.get(key) } + logger.info("asdf _calculate_state_delta existing_state %s", existing_state) + logger.info("asdf _calculate_state_delta current_state %s", current_state) + return DeltaState(to_delete=to_delete, to_insert=to_insert) async def _is_server_still_joined( diff --git a/synapse/storage/databases/main/events.py b/synapse/storage/databases/main/events.py index 1f7acdb859..37d7ae6912 100644 --- a/synapse/storage/databases/main/events.py +++ b/synapse/storage/databases/main/events.py @@ -1131,6 +1131,8 @@ class PersistEventsStore: ) -> None: """Update the current state stored in the datatabase for the given room""" + logger.info("asdf state_delta: %s", state_delta) + if state_delta.is_noop(): return