diff options
author | Erik Johnston <erik@matrix.org> | 2015-08-10 10:38:47 +0100 |
---|---|---|
committer | Erik Johnston <erik@matrix.org> | 2015-08-10 10:38:47 +0100 |
commit | 2cd6cb9f65e64ea49e0a8ba7c4851c79821243ad (patch) | |
tree | 0e5b595285e5a43f45750fddd565e40d9fa04390 /synapse | |
parent | Merge branch 'erikj/cache_deferreds' of github.com:matrix-org/synapse into er... (diff) | |
download | synapse-2cd6cb9f65e64ea49e0a8ba7c4851c79821243ad.tar.xz |
Rename keyargs to args in Cache
Diffstat (limited to 'synapse')
-rw-r--r-- | synapse/storage/_base.py | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/synapse/storage/_base.py b/synapse/storage/_base.py index a088a6175c..1e2d436660 100644 --- a/synapse/storage/_base.py +++ b/synapse/storage/_base.py @@ -86,8 +86,8 @@ class Cache(object): "Cache objects can only be accessed from the main thread" ) - def get(self, keyargs, default=_CacheSentinel): - val = self.cache.get(keyargs, _CacheSentinel) + def get(self, key, default=_CacheSentinel): + val = self.cache.get(key, _CacheSentinel) if val is not _CacheSentinel: cache_counter.inc_hits(self.name) return val @@ -99,29 +99,29 @@ class Cache(object): else: return default - def update(self, sequence, keyargs, value): + def update(self, sequence, key, value): self.check_thread() if self.sequence == sequence: # Only update the cache if the caches sequence number matches the # number that the cache had before the SELECT was started (SYN-369) - self.prefill(keyargs, value) + self.prefill(key, value) - def prefill(self, keyargs, value): + def prefill(self, key, value): if self.max_entries is not None: while len(self.cache) >= self.max_entries: self.cache.popitem(last=False) - self.cache[keyargs] = value + self.cache[key] = value - def invalidate(self, keyargs): + def invalidate(self, key): self.check_thread() - if not isinstance(keyargs, tuple): + if not isinstance(key, tuple): raise ValueError("keyargs must be a tuple.") # Increment the sequence number so that any SELECT statements that # raced with the INSERT don't update the cache (SYN-369) self.sequence += 1 - self.cache.pop(keyargs, None) + self.cache.pop(key, None) def invalidate_all(self): self.check_thread() |