diff options
author | Erik Johnston <erikj@jki.re> | 2017-05-04 15:07:27 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2017-05-04 15:07:27 +0100 |
commit | 587f07543fcf604da58903b22a7448e631d797ea (patch) | |
tree | db3b6aa0e2224a07c206438e4365c4f9bbbe482a /synapse/storage/_base.py | |
parent | Merge pull request #2183 from matrix-org/luke/username-availability (diff) | |
download | synapse-587f07543fcf604da58903b22a7448e631d797ea.tar.xz |
Revert "Prefill state caches"
Diffstat (limited to 'synapse/storage/_base.py')
-rw-r--r-- | synapse/storage/_base.py | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/synapse/storage/_base.py b/synapse/storage/_base.py index 58b73af7d2..c659004e8d 100644 --- a/synapse/storage/_base.py +++ b/synapse/storage/_base.py @@ -60,12 +60,12 @@ class LoggingTransaction(object): object.__setattr__(self, "database_engine", database_engine) object.__setattr__(self, "after_callbacks", after_callbacks) - def call_after(self, callback, *args, **kwargs): + def call_after(self, callback, *args): """Call the given callback on the main twisted thread after the transaction has finished. Used to invalidate the caches on the correct thread. """ - self.after_callbacks.append((callback, args, kwargs)) + self.after_callbacks.append((callback, args)) def __getattr__(self, name): return getattr(self.txn, name) @@ -319,8 +319,8 @@ class SQLBaseStore(object): inner_func, *args, **kwargs ) finally: - for after_callback, after_args, after_kwargs in after_callbacks: - after_callback(*after_args, **after_kwargs) + for after_callback, after_args in after_callbacks: + after_callback(*after_args) defer.returnValue(result) @defer.inlineCallbacks |