mirrors/synapse
1
0
Fork 0
mirror of https://github.com/element-hq/synapse.git synced 2024-12-19 01:21:09 +03:00
Code Issues Projects Releases Packages Wiki Activity

Profile and output long iterations of runUntilConcurrent

Browse source
This commit is contained in:
Erik Johnston 2015-05-27 14:40:21 +01:00
parent 99eb1172b0
commit 9f4e9fcb63
1 changed files with 16 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
synapse/app/homeserver.py
View file

@ -516,27 +516,35 @@ class SynapseSite(Site):
def run(hs):
PROFILE_SYNAPSE = False
PROFILE_SYNAPSE = True
if PROFILE_SYNAPSE:
def profile(func):
from cProfile import Profile
from threading import current_thread
import time
def profiled(*args, **kargs):
profile = Profile()
start = int(time.time()*1000)
profile.enable()
func(*args, **kargs)
profile.disable()
ident = current_thread().ident
profile.dump_stats("/tmp/%s.%s.%i.pstat" % (
hs.hostname, func.__name__, ident
))
end = int(time.time()*1000)
if end - start > 100:
ident = current_thread().ident
profile.dump_stats("/tmp/%s.%s.%i.%d-%d.pstat" % (
hs.hostname, func.__name__, ident, start, end
))
return profiled
from twisted.python.threadpool import ThreadPool
ThreadPool._worker = profile(ThreadPool._worker)
reactor.run = profile(reactor.run)
# from twisted.python.threadpool import ThreadPool
# ThreadPool._worker = profile(ThreadPool._worker)
reactor.runUntilCurrent = profile(reactor.runUntilCurrent)
def in_thread():
with LoggingContext("run"):