OpenCloud
/
MatrixSynapse
mirror of https://github.com/matrix-org/synapse
1
0
Fork 0
Code Issues Releases Wiki Activity

Docstrings

pull/6295/head
Erik Johnston 2019-10-31 15:25:21 +00:00
parent 8f5bbdb987
commit f91f2a1f92
1 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
synapse/storage/data_stores/main/events.py
View File

@ -19,6 +19,7 @@ import itertools
import logging import logging
from collections import Counter as c_counter, OrderedDict, namedtuple from collections import Counter as c_counter, OrderedDict, namedtuple
from functools import wraps from functools import wraps
from typing import Set
from six import iteritems, text_type from six import iteritems, text_type
from six.moves import range from six.moves import range
@ -1370,8 +1371,8 @@ class EventsStore(
state groups). state groups).
Returns: Returns:
Deferred[set[int]]: The set of state groups that reference deleted Deferred[set[int]]: The set of state groups that are referenced by
events. deleted events.
""" """
return self.runInteraction( return self.runInteraction(
@ -1711,9 +1712,16 @@ class EventsStore(
logger.info("[purge] done") logger.info("[purge] done")
def purge_unreferenced_state_groups(self, room_id, state_groups_to_delete): def purge_unreferenced_state_groups(
self, room_id: str, state_groups_to_delete: Set[int]
) -> defer.Deferred:
"""Deletes no longer referenced state groups and de-deltas any state """Deletes no longer referenced state groups and de-deltas any state
groups that reference them. groups that reference them.
Args:
room_id: The room the state groups belong to (must all be in the
same room).
state_groups_to_delete: Set of all state groups to delete.
""" """
return self.runInteraction( return self.runInteraction(