summary refs log tree commit diff
path: root/synapse/util
diff options
context:
space:
mode:
authorBrendan Abolivier <babolivier@matrix.org>2019-07-26 18:45:31 +0200
committerBrendan Abolivier <babolivier@matrix.org>2019-07-29 09:54:37 +0200
commit08352d44f81a76ba53fc96753cc5038589defaa7 (patch)
tree3cedf8a3413a2d978d4e568c333d196851dd67de /synapse/util
parentMerge branch 'master' into develop (diff)
downloadsynapse-08352d44f81a76ba53fc96753cc5038589defaa7.tar.xz
Add ability to pass arguments to looping calls
Diffstat (limited to 'synapse/util')
-rw-r--r--synapse/util/__init__.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/synapse/util/__init__.py b/synapse/util/__init__.py
index 841625a991..9e0a47d206 100644
--- a/synapse/util/__init__.py
+++ b/synapse/util/__init__.py
@@ -59,7 +59,7 @@ class Clock(object):
         """Returns the current system time in miliseconds since epoch."""
         return int(self.time() * 1000)
 
-    def looping_call(self, f, msec):
+    def looping_call(self, f, msec, *args):
         """Call a function repeatedly.
 
         Waits `msec` initially before calling `f` for the first time.
@@ -71,7 +71,7 @@ class Clock(object):
             f(function): The function to call repeatedly.
             msec(float): How long to wait between calls in milliseconds.
         """
-        call = task.LoopingCall(f)
+        call = task.LoopingCall(f, *args)
         call.clock = self._reactor
         d = call.start(msec / 1000.0, now=False)
         d.addErrback(log_failure, "Looping call died", consumeErrors=False)