From c07c1ad344e5d2939ffa4351fb0ce26e80339088 Mon Sep 17 00:00:00 2001
From: "Chris St. Pierre" <chris.a.st.pierre@gmail.com>
Date: Thu, 15 Dec 2011 13:40:29 -0500
Subject: added tools for SVN postcommit log message, template render
 benchmarking; improved tools README

---
 tools/bcfg2-profile-templates.py | 119 +++++++++++++++++++++++++++++++++++++++
 1 file changed, 119 insertions(+)
 create mode 100755 tools/bcfg2-profile-templates.py

(limited to 'tools/bcfg2-profile-templates.py')

diff --git a/tools/bcfg2-profile-templates.py b/tools/bcfg2-profile-templates.py
new file mode 100755
index 000000000..e8916e6a4
--- /dev/null
+++ b/tools/bcfg2-profile-templates.py
@@ -0,0 +1,119 @@
+#!/usr/bin/python -Ott
+""" Benchmark template rendering times """
+
+import sys
+import time
+import logging
+import logging.handlers
+import operator
+import lxml.etree
+import Bcfg2.Server.Core
+
+LOGGER = None
+
+def get_logger(setup=None):
+    """ set up logging according to the verbose level given on the
+    command line """
+    global LOGGER
+    if LOGGER is None:
+        if setup is None:
+            setup = dict()
+        LOGGER = logging.getLogger(sys.argv[0])
+        stderr = logging.StreamHandler()
+        level = logging.WARNING
+        lformat = "%(message)s"
+        if setup.get("debug", False):
+            stderr.setFormatter(logging.Formatter("%(asctime)s: %(levelname)s: %(message)s"))
+            level = logging.DEBUG
+        elif setup.get("verbose", False):
+            level = logging.INFO
+        LOGGER.setLevel(level)
+        LOGGER.addHandler(stderr)
+        syslog = logging.handlers.SysLogHandler("/dev/log")
+        syslog.setFormatter(logging.Formatter("%(name)s: %(message)s"))
+        LOGGER.addHandler(syslog)
+    return LOGGER
+
+def main():
+    optinfo = dict(configfile=Bcfg2.Options.CFILE,
+                   help=Bcfg2.Options.HELP,
+                   encoding=Bcfg2.Options.ENCODING,
+                   repo=Bcfg2.Options.SERVER_REPOSITORY,
+                   plugins=Bcfg2.Options.SERVER_PLUGINS,
+                   password=Bcfg2.Options.SERVER_PASSWORD,
+                   debug=Bcfg2.Options.DEBUG,
+                   verbose=Bcfg2.Options.VERBOSE)
+    setup = Bcfg2.Options.OptionParser(optinfo)
+    setup.parse(sys.argv[1:])
+    logger = get_logger(setup)
+
+    core = Bcfg2.Server.Core.Core(setup['repo'],
+                                  setup['plugins'],
+                                  setup['password'],
+                                  setup['encoding'])
+    logger.info("Bcfg2 server core loaded")
+    core.fam.handle_events_in_interval(4)
+    logger.debug("Repository events processed")
+
+    # how many times to render each template for each client
+    runs = 5
+
+    if setup['args']:
+        templates = setup['args']
+
+    times = dict()
+    for plugin in ['Cfg', 'TGenshi', 'TCheetah']:
+        if plugin not in core.plugins:
+            logger.debug("Skipping disabled plugin %s" % plugin)
+            continue
+        logger.info("Rendering templates from plugin %s" % plugin)
+
+        entrysets = []
+        for template in templates:
+            try:
+                entrysets.append(core.plugins[plugin].entries[template])
+            except KeyError:
+                logger.debug("Template %s not found in plugin %s" %
+                             (template, plugin))
+        if not entrysets:
+            logger.debug("Using all entrysets in plugin %s" % plugin)
+            entrysets = core.plugins[plugin].entries.values()
+
+        for eset in entrysets:
+            path = eset.path.replace(setup['repo'], '')
+            logger.info("Rendering %s..." % path)
+            times[path] = dict()
+            for client in core.metadata.clients:
+                avg = 0.0
+                metadata = core.build_metadata(client)
+                for i in range(runs):
+                    entry = lxml.etree.Element("Path")
+                    start = time.time()
+                    try:
+                        eset.bind_entry(entry, metadata)
+                        avg += (time.time() - start) / runs
+                    except:
+                        break
+                if avg:
+                    logger.debug("   %s: %.02f sec" % (client, avg))
+                    times[path][client] = avg
+
+    # print out per-template results
+    tmpltimes = []
+    for tmpl, clients in times.items():
+        try:
+            avg = sum(clients.values()) / len(clients)
+        except ZeroDivisionError:
+            continue
+        if avg > 0.01 or templates:
+            tmpltimes.append((tmpl, avg))
+    print "%-50s %s" % ("Template", "Average Render Time")
+    for tmpl, avg in reversed(sorted(tmpltimes, key=operator.itemgetter(1))):
+        print "%-50s %.02f" % (tmpl, avg)
+
+    # TODO: complain about templates that on average were quick but
+    # for which some clients were slow
+
+
+if __name__ == "__main__":
+    sys.exit(main())
-- 
cgit v1.2.3-1-g7c22