|
|
@ -59,7 +59,7 @@ class Clock(object): |
|
|
|
"""Returns the current system time in miliseconds since epoch.""" |
|
|
|
"""Returns the current system time in miliseconds since epoch.""" |
|
|
|
return int(self.time() * 1000) |
|
|
|
return int(self.time() * 1000) |
|
|
|
|
|
|
|
|
|
|
|
def looping_call(self, f, msec, *args): |
|
|
|
def looping_call(self, f, msec, *args, **kwargs): |
|
|
|
"""Call a function repeatedly. |
|
|
|
"""Call a function repeatedly. |
|
|
|
|
|
|
|
|
|
|
|
Waits `msec` initially before calling `f` for the first time. |
|
|
|
Waits `msec` initially before calling `f` for the first time. |
|
|
@ -70,8 +70,10 @@ class Clock(object): |
|
|
|
Args: |
|
|
|
Args: |
|
|
|
f(function): The function to call repeatedly. |
|
|
|
f(function): The function to call repeatedly. |
|
|
|
msec(float): How long to wait between calls in milliseconds. |
|
|
|
msec(float): How long to wait between calls in milliseconds. |
|
|
|
|
|
|
|
*args: Postional arguments to pass to function. |
|
|
|
|
|
|
|
**kwargs: Key arguments to pass to function. |
|
|
|
""" |
|
|
|
""" |
|
|
|
call = task.LoopingCall(f, *args) |
|
|
|
call = task.LoopingCall(f, *args, **kwargs) |
|
|
|
call.clock = self._reactor |
|
|
|
call.clock = self._reactor |
|
|
|
d = call.start(msec / 1000.0, now=False) |
|
|
|
d = call.start(msec / 1000.0, now=False) |
|
|
|
d.addErrback(log_failure, "Looping call died", consumeErrors=False) |
|
|
|
d.addErrback(log_failure, "Looping call died", consumeErrors=False) |
|
|
|