mirrors/synapse
1
0
Fork 0
mirror of https://github.com/element-hq/synapse.git synced 2024-11-27 20:22:07 +03:00
Code Issues Projects Releases Packages Wiki Activity

Report size of ExpiringCache

Browse source
This commit is contained in:
Erik Johnston 2016-02-23 11:54:48 +00:00
parent b5f77eb12a
commit 278d6c0527
1 changed files with 13 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
synapse/util/caches/expiringcache.py
View file

@ -13,6 +13,8 @@
# See the License for the specific language governing permissions and
# limitations under the License.
from synapse.util.caches import cache_counter, caches_by_name
import logging
@ -47,6 +49,8 @@ class ExpiringCache(object):
self._cache = {}
caches_by_name[cache_name] = self._cache
def start(self):
if not self._expiry_ms:
# Don't bother starting the loop if things never expire
@ -72,7 +76,11 @@ class ExpiringCache(object):
self._cache.pop(k)
def __getitem__(self, key):
try:
entry = self._cache[key]
cache_counter.inc_hits(self._cache_name)
finally:
cache_counter.inc_misses(self._cache_name)
if self._reset_expiry_on_get:
entry.time = self._clock.time_msec()
@ -105,9 +113,12 @@ class ExpiringCache(object):
logger.debug(
"[%s] _prune_cache before: %d, after len: %d",
self._cache_name, begin_length, len(self._cache.keys())
self._cache_name, begin_length, len(self._cache)
)
def __len__(self):
return len(self._cache)
class _CacheEntry(object):
def __init__(self, time, value):