diff options
author | Kegan Dougal <kegan@matrix.org> | 2016-11-14 11:19:24 +0000 |
---|---|---|
committer | Kegan Dougal <kegan@matrix.org> | 2016-11-14 11:19:24 +0000 |
commit | 3991b4cbdb5f5fbdf61ad6efa879b3881143c214 (patch) | |
tree | 7bfdac2259cf1226931ca52a101c172eda0a1133 /synapse/util | |
parent | Move .observe() up to the cache to make things neater (diff) | |
download | synapse-3991b4cbdb5f5fbdf61ad6efa879b3881143c214.tar.xz |
Clean transactions based on time. Add HttpTransactionCache tests.
Diffstat (limited to 'synapse/util')
-rw-r--r-- | synapse/util/__init__.py | 10 |
1 files changed, 9 insertions, 1 deletions
diff --git a/synapse/util/__init__.py b/synapse/util/__init__.py index 2b3f0bef3c..c05b9450be 100644 --- a/synapse/util/__init__.py +++ b/synapse/util/__init__.py @@ -34,7 +34,7 @@ class Clock(object): """A small utility that obtains current time-of-day so that time may be mocked during unit-tests. - TODO(paul): Also move the sleep() functionallity into it + TODO(paul): Also move the sleep() functionality into it """ def time(self): @@ -46,6 +46,14 @@ class Clock(object): return int(self.time() * 1000) def looping_call(self, f, msec): + """Call a function repeatedly. + + Waits `msec` initially before calling `f` for the first time. + + Args: + f(function): The function to call repeatedly. + msec(float): How long to wait between calls in milliseconds. + """ l = task.LoopingCall(f) l.start(msec / 1000.0, now=False) return l |