Matrix-Mirrors/synapse-product
1
0
Fork 0
mirror of https://git.anonymousland.org/anonymousland/synapse-product.git synced 2024-12-11 09:14:22 -05:00
Code Issues Packages Projects Releases Wiki Activity

Correctly update _entity_to_key

Browse Source
This commit is contained in:
Erik Johnston 2016-01-28 18:05:43 +00:00
parent 82cf3a8043
commit 40431251cb
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
synapse/util/caches/stream_change_cache.py
View File

@ -82,18 +82,19 @@ class StreamChangeCache(object):
return result return result
def entity_has_changed(self, entitiy, stream_pos): def entity_has_changed(self, entity, stream_pos):
"""Informs the cache that the entitiy has been changed at the given """Informs the cache that the entity has been changed at the given
position. position.
""" """
assert type(stream_pos) is int assert type(stream_pos) is int
if stream_pos > self._earliest_known_stream_pos: if stream_pos > self._earliest_known_stream_pos:
old_pos = self._entity_to_key.get(entitiy, None) old_pos = self._entity_to_key.get(entity, None)
if old_pos: if old_pos:
stream_pos = max(stream_pos, old_pos) stream_pos = max(stream_pos, old_pos)
self._cache.pop(old_pos, None) self._cache.pop(old_pos, None)
self._cache[stream_pos] = entitiy self._cache[stream_pos] = entity
self._entity_to_key[entity] = stream_pos
while len(self._cache) > self._max_size: while len(self._cache) > self._max_size:
k, r = self._cache.popitem() k, r = self._cache.popitem()