maxmustermann/synapse
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

install timers

Browse source
This commit is contained in:
Erik Johnston 2021-11-08 14:32:48 +00:00
parent 50b8170181
commit 49c9424c0e
1 changed files with 3 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
synapse/metrics/__init__.py
View file

@ -584,7 +584,7 @@ MIN_TIME_BETWEEN_GCS = (1.0, 10.0, 30.0)
_last_gc = [0.0, 0.0, 0.0]
def callFromThreadTimer(reactor, func):
def callFromThreadTimer(func):
@functools.wraps(func)
def callFromThread(
self, f: Callable[..., Any], *args: object, **kwargs: object
@ -695,6 +695,8 @@ try:
# per iteratation after fd polling.
reactor.runUntilCurrent = runUntilCurrentTimer(reactor, reactor.runUntilCurrent) # type: ignore
reactor.callFromThread = callFromThreadTimer(reactor.callFromThread)
# We manually run the GC each reactor tick so that we can get some metrics
# about time spent doing GC,
if not running_on_pypy: