shaba/virt-manager
1
0
Fork 0
mirror of https://github.com/virt-manager/virt-manager.git synced 2025-01-11 05:17:59 +03:00
Code Issues Projects Releases Wiki Activity

module_trace: Improve output for tracking mainloop libvirt usage

Browse Source
This commit is contained in:
Cole Robinson 2014-09-13 13:52:42 -04:00
parent 226c4562d5
commit 9b62573c0b
2 changed files with 34 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
virt-manager
View File

@ -151,7 +151,7 @@ def main():
logging.debug("Libvirt tracing requested")
import virtManager.module_trace
import libvirt
virtManager.module_trace.wrap_module(libvirt)
virtManager.module_trace.wrap_module(libvirt, regex=None)
# Now we've got basic environment up & running we can fork
do_drop_stdio = False

47
virtManager/module_trace.py
View File

@ -23,8 +23,9 @@
# logging infrastructure. Invoke this with virt-manager --trace-libvirt
import logging
import time
import re
import threading
import time
import traceback
from types import FunctionType
@ -32,48 +33,66 @@ from types import ClassType
from types import MethodType
def generate_wrapper(origfunc, name, do_tb):
def generate_wrapper(origfunc, name):
# This could be used as generic infrastructure, but it has hacks for
# identifying places where libvirt hits the network from the main thread,
# which causes UI blocking on slow network connections.
def newfunc(*args, **kwargs):
tb = do_tb and ("\n%s" % "".join(traceback.format_stack())) or ""
logging.debug("TRACE %s: %s %s %s%s",
time.time(), name, args, kwargs, tb)
threadname = threading.current_thread().name
is_main_thread = (threading.current_thread().name == "MainThread")
# These APIs don't hit the network, so we might not want to see them.
is_non_network_libvirt_call = (name.endswith(".name") or
name.endswith(".UUIDString") or
name.endswith(".__init__") or
name.endswith(".__del__") or
name.endswith(".connect") or
name.startswith("libvirtError"))
if not is_non_network_libvirt_call:
tb = ""
if is_main_thread:
tb = "\n%s" % "".join(traceback.format_stack())
logging.debug("TRACE %s: thread=%s: %s %s %s%s",
time.time(), threadname, name, args, kwargs, tb)
return origfunc(*args, **kwargs)
return newfunc
def wrap_func(module, funcobj, tb):
def wrap_func(module, funcobj):
name = funcobj.__name__
logging.debug("wrapfunc %s %s", funcobj, name)
newfunc = generate_wrapper(funcobj, name, tb)
newfunc = generate_wrapper(funcobj, name)
setattr(module, name, newfunc)
def wrap_method(classobj, methodobj, tb):
def wrap_method(classobj, methodobj):
name = methodobj.__name__
fullname = classobj.__name__ + "." + name
logging.debug("wrapmeth %s", fullname)
newfunc = generate_wrapper(methodobj, fullname, tb)
newfunc = generate_wrapper(methodobj, fullname)
setattr(classobj, name, newfunc)
def wrap_class(classobj, tb):
def wrap_class(classobj):
logging.debug("wrapclas %s %s", classobj, classobj.__name__)
for name in dir(classobj):
obj = getattr(classobj, name)
if type(obj) is MethodType:
wrap_method(classobj, obj, tb)
wrap_method(classobj, obj)
def wrap_module(module, regex=None, tb=False):
def wrap_module(module, regex=None):
for name in dir(module):
if regex and not re.match(regex, name):
continue
obj = getattr(module, name)
if type(obj) is FunctionType:
wrap_func(module, obj, tb)
wrap_func(module, obj)
if type(obj) is ClassType or type(obj) is type:
wrap_class(obj, tb)
wrap_class(obj)