OpenCloud
/
MatrixSynapse
mirror of https://github.com/matrix-org/synapse
1
0
Fork 0
Code Issues Releases Wiki Activity

Use pyinstrument

erikj/profile_rununtilconcurrent
Erik Johnston 2015-05-27 15:31:00 +01:00
parent 9f4e9fcb63
commit 2b0eb839db
1 changed files with 11 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
synapse/app/homeserver.py
View File

@ -519,26 +519,30 @@ def run(hs):
PROFILE_SYNAPSE = True PROFILE_SYNAPSE = True
if PROFILE_SYNAPSE: if PROFILE_SYNAPSE:
def profile(func): def profile(func):
from cProfile import Profile from pyinstrument import Profiler
from threading import current_thread from threading import current_thread
import time import time
def profiled(*args, **kargs): def profiled(*args, **kargs):
profile = Profile() profile = Profiler()
start = int(time.time()*1000) start = int(time.time()*1000)
profile.enable() profile.start()
func(*args, **kargs) func(*args, **kargs)
profile.disable() profile.stop()
end = int(time.time()*1000) end = int(time.time()*1000)
if end - start > 100: if end - start > 10:
ident = current_thread().ident ident = current_thread().ident
profile.dump_stats("/tmp/%s.%s.%i.%d-%d.pstat" % ( name = "/tmp/%s.%s.%i.%d-%d" % (
hs.hostname, func.__name__, ident, start, end hs.hostname, func.__name__, ident, start, end
)) )
# profile.dump_stats(name + ".pstat")
html = profile.output_html()
with open(name + ".html", "w") as f:
f.write(html)
return profiled return profiled