diff options
| author | Kegan Dougal <kegan@matrix.org> | 2015-02-09 15:20:56 +0000 |
|---|---|---|
| committer | Kegan Dougal <kegan@matrix.org> | 2015-02-09 15:20:56 +0000 |
| commit | 53557fc53259631d71055ef2ab8a6916b00d229b (patch) | |
| tree | 208db19fb5bbcc5416e669bc496adc49acdcb1a7 /synapse/util/__init__.py | |
| parent | Fix bugs so lazy room joining works as intended. (diff) | |
| parent | Merge pull request #55 from matrix-org/profiling (diff) | |
| download | synapse-53557fc53259631d71055ef2ab8a6916b00d229b.tar.xz | |
Merge branch 'develop' into application-services
Diffstat (limited to 'synapse/util/__init__.py')
| -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 4e837a918e..fee76b0a9b 100644 --- a/synapse/util/__init__.py +++ b/synapse/util/__init__.py @@ -15,7 +15,7 @@ from synapse.util.logcontext import LoggingContext -from twisted.internet import reactor +from twisted.internet import reactor, task import time @@ -35,6 +35,14 @@ class Clock(object): """Returns the current system time in miliseconds since epoch.""" return self.time() * 1000 + def looping_call(self, f, msec): + l = task.LoopingCall(f) + l.start(msec/1000.0, now=False) + return l + + def stop_looping_call(self, loop): + loop.stop() + def call_later(self, delay, callback): current_context = LoggingContext.current_context() |