Matrix-Mirrors/synapse-product
1
0
Fork 0
mirror of https://git.anonymousland.org/anonymousland/synapse-product.git synced 2024-10-01 08:25:44 -04:00
Code Issues Packages Projects Releases Wiki Activity

Also check for presence of 'threadCallQueue' in reactor

Browse Source
This commit is contained in:
Erik Johnston 2015-08-18 11:51:08 +01:00
parent d3da63f766
commit 6e7d36a72c
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
synapse/metrics/__init__.py
View File

@ -184,7 +184,14 @@ def runUntilCurrentTimer(func):
return f return f
if hasattr(reactor, "runUntilCurrent") and hasattr(reactor, "_newTimedCalls"): try:
# Ensure the reactor has all the attributes we expect
reactor.runUntilCurrent
reactor._newTimedCalls
reactor.threadCallQueue
# runUntilCurrent is called when we have pending calls. It is called once # runUntilCurrent is called when we have pending calls. It is called once
# per iteratation after fd polling. # per iteratation after fd polling.
reactor.runUntilCurrent = runUntilCurrentTimer(reactor.runUntilCurrent) reactor.runUntilCurrent = runUntilCurrentTimer(reactor.runUntilCurrent)
except AttributeError:
pass