Matrix/synapse
Matrix/synapse
1
0
Fork 0
mirror of https://github.com/element-hq/synapse synced 2024-07-08 14:04:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

Remove duplicated code to evict entries. (#14410)

Browse source 
This code was factored out to a method, but also left in-place.

Calling this twice in a row makes no sense: the first call will reduce
the size appropriately, but the loop will immediately exit since the
cache size was already reduced.
This commit is contained in:
Patrick Cloke 2022-11-10 15:33:34 -05:00 committed by GitHub
parent b2c2b03079
commit 13ca8bb2fc
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 3 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
changelog.d/14410.misc Normal file
View file

@ -0,0 +1 @@
Remove unreachable code.

11
synapse/util/caches/stream_change_cache.py
View file

@ -72,7 +72,7 @@ class StreamChangeCache:
items from the cache. items from the cache.
Returns: Returns:
bool: Whether the cache changed size or not. Whether the cache changed size or not.
""" """
new_size = math.floor(self._original_max_size * factor) new_size = math.floor(self._original_max_size * factor)
if new_size != self._max_size: if new_size != self._max_size:
@ -188,14 +188,8 @@ class StreamChangeCache:
self._entity_to_key[entity] = stream_pos self._entity_to_key[entity] = stream_pos
self._evict() self._evict()
# if the cache is too big, remove entries
while len(self._cache) > self._max_size:
k, r = self._cache.popitem(0)
self._earliest_known_stream_pos = max(k, self._earliest_known_stream_pos)
for entity in r:
del self._entity_to_key[entity]
def _evict(self) -> None: def _evict(self) -> None:
# if the cache is too big, remove entries
while len(self._cache) > self._max_size: while len(self._cache) > self._max_size:
k, r = self._cache.popitem(0) k, r = self._cache.popitem(0)
self._earliest_known_stream_pos = max(k, self._earliest_known_stream_pos) self._earliest_known_stream_pos = max(k, self._earliest_known_stream_pos)
@ -203,7 +197,6 @@ class StreamChangeCache:
self._entity_to_key.pop(entity, None) self._entity_to_key.pop(entity, None)
def get_max_pos_of_last_change(self, entity: EntityType) -> int: def get_max_pos_of_last_change(self, entity: EntityType) -> int:
"""Returns an upper bound of the stream id of the last change to an """Returns an upper bound of the stream id of the last change to an
entity. entity.
""" """