From: "Rafael J. Wysocki" <rjw@rjwysocki.net>
To: todd.e.brandt@linux.intel.com
Cc: linux-pm@vger.kernel.org
Subject: Re: [PATCH v2] analyze_suspend.py: new tool for suspend/resume performance optimization
Date: Fri, 17 Jan 2014 02:18 +0100 [thread overview]
Message-ID: <2954888.old5rRCcAC@vostro.rjw.lan> (raw)
In-Reply-To: <20140117001820.GB11416@linux.intel.com>
On Thursday, January 16, 2014 04:18:22 PM Todd E Brandt wrote:
> Hi Raphael, this is the very latest version. It just includes an
> updated zoomable UI and some fixes to the interpreter for modes
> other than S3.
I've replaced the previous version with this one in linux-next, thanks!
> This tool is designed to assist kernel and OS developers in optimizing
> their linux stack's suspend/resume time. Using a kernel image built with a
> few extra options enabled, the tool will execute a suspend and will
> capture dmesg and ftrace data until resume is complete. This data is
> transformed into a device timeline and a callgraph to give a quick and
> detailed view of which devices and callbacks are taking the most time in
> suspend/resume. The output is a single html file which can be viewed in
> firefox or chrome.
>
> More info here:
> https://01.org/suspendresume
>
> Signed-off-by: Todd Brandt <todd.e.brandt@linux.intel.com>
> ---
> scripts/analyze_suspend.py | 1446 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++
> 1 file changed, 1446 insertions(+)
>
> diff --git a/scripts/analyze_suspend.py b/scripts/analyze_suspend.py
> new file mode 100755
> index 0000000..4157043
> --- /dev/null
> +++ b/scripts/analyze_suspend.py
> @@ -0,0 +1,1446 @@
> +#!/usr/bin/python
> +#
> +# Tool for analyzing suspend/resume timing
> +# Copyright (c) 2013, Intel Corporation.
> +#
> +# This program is free software; you can redistribute it and/or modify it
> +# under the terms and conditions of the GNU General Public License,
> +# version 2, as published by the Free Software Foundation.
> +#
> +# This program is distributed in the hope it will be useful, but WITHOUT
> +# ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
> +# FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
> +# more details.
> +#
> +# You should have received a copy of the GNU General Public License along with
> +# this program; if not, write to the Free Software Foundation, Inc.,
> +# 51 Franklin St - Fifth Floor, Boston, MA 02110-1301 USA.
> +#
> +# Authors:
> +# Todd Brandt <todd.e.brandt@linux.intel.com>
> +#
> +# Description:
> +# This tool is designed to assist kernel and OS developers in optimizing
> +# their linux stack's suspend/resume time. Using a kernel image built
> +# with a few extra options enabled, the tool will execute a suspend and
> +# will capture dmesg and ftrace data until resume is complete. This data
> +# is transformed into a device timeline and a callgraph to give a quick
> +# and detailed view of which devices and callbacks are taking the most
> +# time in suspend/resume. The output is a single html file which can be
> +# viewed in firefox or chrome.
> +#
> +# The following kernel build options are required:
> +# CONFIG_PM_DEBUG=y
> +# CONFIG_PM_SLEEP_DEBUG=y
> +# CONFIG_FTRACE=y
> +# CONFIG_FUNCTION_TRACER=y
> +# CONFIG_FUNCTION_GRAPH_TRACER=y
> +#
> +# The following additional kernel parameters are required:
> +# (e.g. in file /etc/default/grub)
> +# GRUB_CMDLINE_LINUX_DEFAULT="... initcall_debug log_buf_len=16M ..."
> +#
> +
> +import sys
> +import time
> +import os
> +import string
> +import re
> +import array
> +import platform
> +import datetime
> +import struct
> +
> +# -- classes --
> +
> +class SystemValues:
> + testdir = "."
> + tpath = "/sys/kernel/debug/tracing/"
> + mempath = "/dev/mem"
> + powerfile = "/sys/power/state"
> + suspendmode = "mem"
> + prefix = "test"
> + teststamp = ""
> + dmesgfile = ""
> + ftracefile = ""
> + htmlfile = ""
> + rtcwake = False
> + def setOutputFile(self):
> + if((self.htmlfile == "") and (self.dmesgfile != "")):
> + m = re.match(r"(?P<name>.*)_dmesg\.txt$", self.dmesgfile)
> + if(m):
> + self.htmlfile = m.group("name")+".html"
> + if((self.htmlfile == "") and (self.ftracefile != "")):
> + m = re.match(r"(?P<name>.*)_ftrace\.txt$", self.ftracefile)
> + if(m):
> + self.htmlfile = m.group("name")+".html"
> + if(self.htmlfile == ""):
> + self.htmlfile = "output.html"
> + def initTestOutput(self):
> + hostname = platform.node()
> + if(hostname != ""):
> + self.prefix = hostname
> + v = os.popen("cat /proc/version").read().strip()
> + kver = string.split(v)[2]
> + self.testdir = os.popen("date \"+suspend-%m%d%y-%H%M%S\"").read().strip()
> + self.teststamp = "# "+self.testdir+" "+self.prefix+" "+self.suspendmode+" "+kver
> + self.dmesgfile = self.testdir+"/"+self.prefix+"_"+self.suspendmode+"_dmesg.txt"
> + self.ftracefile = self.testdir+"/"+self.prefix+"_"+self.suspendmode+"_ftrace.txt"
> + self.htmlfile = self.testdir+"/"+self.prefix+"_"+self.suspendmode+".html"
> + os.mkdir(self.testdir)
> +
> +class Data:
> + altdevname = dict()
> + usedmesg = False
> + useftrace = False
> + notestrun = False
> + verbose = False
> + phases = []
> + dmesg = {} # root data structure
> + start = 0.0
> + end = 0.0
> + stamp = {'time': "", 'host': "", 'mode': ""}
> + id = 0
> + tSuspended = 0.0
> + fwValid = False
> + fwSuspend = 0
> + fwResume = 0
> + def initialize(self):
> + self.dmesg = { # dmesg log data
> + 'suspend_general': {'list': dict(), 'start': -1.0, 'end': -1.0,
> + 'row': 0, 'color': "#CCFFCC", 'order': 0},
> + 'suspend_early': {'list': dict(), 'start': -1.0, 'end': -1.0,
> + 'row': 0, 'color': "green", 'order': 1},
> + 'suspend_noirq': {'list': dict(), 'start': -1.0, 'end': -1.0,
> + 'row': 0, 'color': "#00FFFF", 'order': 2},
> + 'suspend_cpu': {'list': dict(), 'start': -1.0, 'end': -1.0,
> + 'row': 0, 'color': "blue", 'order': 3},
> + 'resume_cpu': {'list': dict(), 'start': -1.0, 'end': -1.0,
> + 'row': 0, 'color': "red", 'order': 4},
> + 'resume_noirq': {'list': dict(), 'start': -1.0, 'end': -1.0,
> + 'row': 0, 'color': "orange", 'order': 5},
> + 'resume_early': {'list': dict(), 'start': -1.0, 'end': -1.0,
> + 'row': 0, 'color': "yellow", 'order': 6},
> + 'resume_general': {'list': dict(), 'start': -1.0, 'end': -1.0,
> + 'row': 0, 'color': "#FFFFCC", 'order': 7}
> + }
> + self.phases = self.sortedPhases()
> + def normalizeTime(self):
> + tSus = tRes = self.tSuspended
> + if self.fwValid:
> + tSus -= -self.fwSuspend / 1000000000.0
> + tRes -= self.fwResume / 1000000000.0
> + self.tSuspended = 0.0
> + self.start -= tSus
> + self.end -= tRes
> + for phase in self.phases:
> + zero = tRes
> + if "suspend" in phase:
> + zero = tSus
> + p = self.dmesg[phase]
> + p['start'] -= zero
> + p['end'] -= zero
> + list = p['list']
> + for name in list:
> + d = list[name]
> + d['start'] -= zero
> + d['end'] -= zero
> + if('ftrace' in d):
> + cg = d['ftrace']
> + cg.start -= zero
> + cg.end -= zero
> + for line in cg.list:
> + line.time -= zero
> + if self.fwValid:
> + fws = -self.fwSuspend / 1000000000.0
> + fwr = self.fwResume / 1000000000.0
> + list = dict()
> + self.id += 1
> + devid = "dc%d" % self.id
> + list["firmware-suspend"] = \
> + {'start': fws, 'end': 0, 'pid': 0, 'par': "",
> + 'length': -fws, 'row': 0, 'id': devid };
> + self.id += 1
> + devid = "dc%d" % self.id
> + list["firmware-resume"] = \
> + {'start': 0, 'end': fwr, 'pid': 0, 'par': "",
> + 'length': fwr, 'row': 0, 'id': devid };
> + self.dmesg['BIOS'] = \
> + {'list': list, 'start': fws, 'end': fwr,
> + 'row': 0, 'color': "purple", 'order': 4}
> + self.dmesg['resume_cpu']['order'] += 1
> + self.dmesg['resume_noirq']['order'] += 1
> + self.dmesg['resume_early']['order'] += 1
> + self.dmesg['resume_general']['order'] += 1
> + self.phases = self.sortedPhases()
> + def vprint(self, msg):
> + if(self.verbose):
> + print(msg)
> + def dmesgSortVal(self, phase):
> + return self.dmesg[phase]['order']
> + def sortedPhases(self):
> + return sorted(self.dmesg, key=self.dmesgSortVal)
> + def sortedDevices(self, phase):
> + list = self.dmesg[phase]['list']
> + slist = []
> + tmp = dict()
> + for devname in list:
> + dev = list[devname]
> + tmp[dev['start']] = devname
> + for t in sorted(tmp):
> + slist.append(tmp[t])
> + return slist
> + def fixupInitcalls(self, phase, end):
> + # if any calls never returned, clip them at system resume end
> + phaselist = self.dmesg[phase]['list']
> + for devname in phaselist:
> + dev = phaselist[devname]
> + if(dev['end'] < 0):
> + dev['end'] = end
> + self.vprint("%s (%s): callback didn't return" % (devname, phase))
> + def fixupInitcallsThatDidntReturn(self):
> + # if any calls never returned, clip them at system resume end
> + for phase in self.phases:
> + self.fixupInitcalls(phase, self.dmesg['resume_general']['end'])
> + if(phase == "resume_general"):
> + break
> + def newAction(self, phase, name, pid, parent, start, end):
> + self.id += 1
> + devid = "dc%d" % self.id
> + list = self.dmesg[phase]['list']
> + length = -1.0
> + if(start >= 0 and end >= 0):
> + length = end - start
> + list[name] = {'start': start, 'end': end, 'pid': pid, 'par': parent,
> + 'length': length, 'row': 0, 'id': devid }
> + def deviceIDs(self, devlist, phase):
> + idlist = []
> + for p in self.phases:
> + if(p[0] != phase[0]):
> + continue
> + list = data.dmesg[p]['list']
> + for devname in list:
> + if devname in devlist:
> + idlist.append(list[devname]['id'])
> + return idlist
> + def deviceParentID(self, devname, phase):
> + pdev = ""
> + pdevid = ""
> + for p in self.phases:
> + if(p[0] != phase[0]):
> + continue
> + list = data.dmesg[p]['list']
> + if devname in list:
> + pdev = list[devname]['par']
> + for p in self.phases:
> + if(p[0] != phase[0]):
> + continue
> + list = data.dmesg[p]['list']
> + if pdev in list:
> + return list[pdev]['id']
> + return pdev
> + def deviceChildrenIDs(self, devname, phase):
> + devlist = []
> + for p in self.phases:
> + if(p[0] != phase[0]):
> + continue
> + list = data.dmesg[p]['list']
> + for child in list:
> + if(list[child]['par'] == devname):
> + devlist.append(child)
> + return self.deviceIDs(devlist, phase)
> +
> +class FTraceLine:
> + time = 0.0
> + length = 0.0
> + fcall = False
> + freturn = False
> + fevent = False
> + depth = 0
> + name = ""
> + def __init__(self, t, m, d):
> + self.time = float(t)
> + # check to see if this is a trace event
> + em = re.match(r"^ *\/\* *(?P<msg>.*) \*\/ *$", m)
> + if(em):
> + self.name = em.group("msg")
> + self.fevent = True
> + return
> + # convert the duration to seconds
> + if(d):
> + self.length = float(d)/1000000
> + # the indentation determines the depth
> + match = re.match(r"^(?P<d> *)(?P<o>.*)$", m)
> + if(not match):
> + return
> + self.depth = self.getDepth(match.group('d'))
> + m = match.group('o')
> + # function return
> + if(m[0] == '}'):
> + self.freturn = True
> + if(len(m) > 1):
> + # includes comment with function name
> + match = re.match(r"^} *\/\* *(?P<n>.*) *\*\/$", m)
> + if(match):
> + self.name = match.group('n')
> + # function call
> + else:
> + self.fcall = True
> + # function call with children
> + if(m[-1] == '{'):
> + match = re.match(r"^(?P<n>.*) *\(.*", m)
> + if(match):
> + self.name = match.group('n')
> + # function call with no children (leaf)
> + elif(m[-1] == ';'):
> + self.freturn = True
> + match = re.match(r"^(?P<n>.*) *\(.*", m)
> + if(match):
> + self.name = match.group('n')
> + # something else (possibly a trace marker)
> + else:
> + self.name = m
> + def getDepth(self, str):
> + return len(str)/2
> +
> +class FTraceCallGraph:
> + start = -1.0
> + end = -1.0
> + list = []
> + invalid = False
> + depth = 0
> + def __init__(self):
> + self.start = -1.0
> + self.end = -1.0
> + self.list = []
> + self.depth = 0
> + def setDepth(self, line):
> + if(line.fcall and not line.freturn):
> + line.depth = self.depth
> + self.depth += 1
> + elif(line.freturn and not line.fcall):
> + self.depth -= 1
> + line.depth = self.depth
> + else:
> + line.depth = self.depth
> + def addLine(self, line, match):
> + if(not self.invalid):
> + self.setDepth(line)
> + if(line.depth == 0 and line.freturn):
> + self.end = line.time
> + self.list.append(line)
> + return True
> + if(self.invalid):
> + return False
> + if(len(self.list) >= 1000000 or self.depth < 0):
> + first = self.list[0]
> + self.list = []
> + self.list.append(first)
> + self.invalid = True
> + id = "task %s cpu %s" % (match.group("pid"), match.group("cpu"))
> + window = "(%f - %f)" % (self.start, line.time)
> + data.vprint("Too much data for "+id+" "+window+", ignoring this callback")
> + return False
> + self.list.append(line)
> + if(self.start < 0):
> + self.start = line.time
> + return False
> + def sanityCheck(self):
> + stack = dict()
> + cnt = 0
> + for l in self.list:
> + if(l.fcall and not l.freturn):
> + stack[l.depth] = l
> + cnt += 1
> + elif(l.freturn and not l.fcall):
> + if(not stack[l.depth]):
> + return False
> + stack[l.depth].length = l.length
> + stack[l.depth] = 0
> + l.length = 0
> + cnt -= 1
> + if(cnt == 0):
> + return True
> + return False
> + def debugPrint(self, filename):
> + if(filename == "stdout"):
> + print("[%f - %f]") % (self.start, self.end)
> + for l in self.list:
> + if(l.freturn and l.fcall):
> + print("%f (%02d): %s(); (%.3f us)" % (l.time, l.depth, l.name, l.length*1000000))
> + elif(l.freturn):
> + print("%f (%02d): %s} (%.3f us)" % (l.time, l.depth, l.name, l.length*1000000))
> + else:
> + print("%f (%02d): %s() { (%.3f us)" % (l.time, l.depth, l.name, l.length*1000000))
> + print(" ")
> + else:
> + fp = open(filename, 'w')
> + print(filename)
> + for l in self.list:
> + if(l.freturn and l.fcall):
> + fp.write("%f (%02d): %s(); (%.3f us)\n" % (l.time, l.depth, l.name, l.length*1000000))
> + elif(l.freturn):
> + fp.write("%f (%02d): %s} (%.3f us)\n" % (l.time, l.depth, l.name, l.length*1000000))
> + else:
> + fp.write("%f (%02d): %s() { (%.3f us)\n" % (l.time, l.depth, l.name, l.length*1000000))
> + fp.close()
> +
> +class Timeline:
> + html = {}
> + scaleH = 0.0 # height of the timescale row as a percent of the timeline height
> + rowH = 0.0 # height of each row in percent of the timeline height
> + row_height_pixels = 30
> + maxrows = 0
> + height = 0
> + def __init__(self):
> + self.html = {
> + 'timeline': "",
> + 'legend': "",
> + 'scale': ""
> + }
> + def setRows(self, rows):
> + self.maxrows = int(rows)
> + self.scaleH = 100.0/float(self.maxrows)
> + self.height = self.maxrows*self.row_height_pixels
> + r = float(self.maxrows - 1)
> + if(r < 1.0):
> + r = 1.0
> + self.rowH = (100.0 - self.scaleH)/r
> +
> +# -- global objects --
> +
> +sysvals = SystemValues()
> +data = Data()
> +
> +# -- functions --
> +
> +# Function: initFtrace
> +# Description:
> +# Configure ftrace to capture a function trace during suspend/resume
> +def initFtrace():
> + global sysvals
> +
> + print("INITIALIZING FTRACE...")
> + # turn trace off
> + os.system("echo 0 > "+sysvals.tpath+"tracing_on")
> + # set the trace clock to global
> + os.system("echo global > "+sysvals.tpath+"trace_clock")
> + # set trace buffer to a huge value
> + os.system("echo nop > "+sysvals.tpath+"current_tracer")
> + os.system("echo 100000 > "+sysvals.tpath+"buffer_size_kb")
> + # clear the trace buffer
> + os.system("echo \"\" > "+sysvals.tpath+"trace")
> + # set trace type
> + os.system("echo function_graph > "+sysvals.tpath+"current_tracer")
> + os.system("echo \"\" > "+sysvals.tpath+"set_ftrace_filter")
> + # set trace format options
> + os.system("echo funcgraph-abstime > "+sysvals.tpath+"trace_options")
> + os.system("echo funcgraph-proc > "+sysvals.tpath+"trace_options")
> + # focus only on device suspend and resume
> + os.system("cat "+sysvals.tpath+"available_filter_functions | grep dpm_run_callback > "+sysvals.tpath+"set_graph_function")
> +
> +# Function: verifyFtrace
> +# Description:
> +# Check that ftrace is working on the system
> +def verifyFtrace():
> + global sysvals
> + files = ["available_filter_functions", "buffer_size_kb",
> + "current_tracer", "set_ftrace_filter",
> + "trace", "trace_marker"]
> + for f in files:
> + if(os.path.exists(sysvals.tpath+f) == False):
> + return False
> + return True
> +
> +def parseStamp(line):
> + global data, sysvals
> + stampfmt = r"# suspend-(?P<m>[0-9]{2})(?P<d>[0-9]{2})(?P<y>[0-9]{2})-"+\
> + "(?P<H>[0-9]{2})(?P<M>[0-9]{2})(?P<S>[0-9]{2})"+\
> + " (?P<host>.*) (?P<mode>.*) (?P<kernel>.*)$"
> + m = re.match(stampfmt, line)
> + if(m):
> + dt = datetime.datetime(int(m.group("y"))+2000, int(m.group("m")),
> + int(m.group("d")), int(m.group("H")), int(m.group("M")),
> + int(m.group("S")))
> + data.stamp['time'] = dt.strftime("%B %d %Y, %I:%M:%S %p")
> + data.stamp['host'] = m.group("host")
> + data.stamp['mode'] = m.group("mode")
> + data.stamp['kernel'] = m.group("kernel")
> + sysvals.suspendmode = data.stamp['mode']
> +
> +# Function: analyzeTraceLog
> +# Description:
> +# Analyse an ftrace log output file generated from this app during
> +# the execution phase. Create an "ftrace" structure in memory for
> +# subsequent formatting in the html output file
> +def analyzeTraceLog():
> + global sysvals, data
> +
> + # the ftrace data is tied to the dmesg data
> + if(not data.usedmesg):
> + return
> +
> + # read through the ftrace and parse the data
> + data.vprint("Analyzing the ftrace data...")
> + ftrace_line_fmt = r"^ *(?P<time>[0-9\.]*) *\| *(?P<cpu>[0-9]*)\)"+\
> + " *(?P<proc>.*)-(?P<pid>[0-9]*) *\|"+\
> + "[ +!]*(?P<dur>[0-9\.]*) .*\| (?P<msg>.*)"
> + ftemp = dict()
> + inthepipe = False
> + tf = open(sysvals.ftracefile, 'r')
> + count = 0
> + for line in tf:
> + count = count + 1
> + # grab the time stamp if it's valid
> + if(count == 1):
> + parseStamp(line)
> + continue
> + # parse only valid lines
> + m = re.match(ftrace_line_fmt, line)
> + if(not m):
> + continue
> + m_time = m.group("time")
> + m_pid = m.group("pid")
> + m_msg = m.group("msg")
> + m_dur = m.group("dur")
> + if(m_time and m_pid and m_msg):
> + t = FTraceLine(m_time, m_msg, m_dur)
> + pid = int(m_pid)
> + else:
> + continue
> + # the line should be a call, return, or event
> + if(not t.fcall and not t.freturn and not t.fevent):
> + continue
> + # only parse the ftrace data during suspend/resume
> + if(not inthepipe):
> + # look for the suspend start marker
> + if(t.fevent):
> + if(t.name == "SUSPEND START"):
> + data.vprint("SUSPEND START %f %s:%d" % (t.time, sysvals.ftracefile, count))
> + inthepipe = True
> + continue
> + else:
> + # look for the resume end marker
> + if(t.fevent):
> + if(t.name == "RESUME COMPLETE"):
> + data.vprint("RESUME COMPLETE %f %s:%d" % (t.time, sysvals.ftracefile, count))
> + inthepipe = False
> + break
> + continue
> + # create a callgraph object for the data
> + if(pid not in ftemp):
> + ftemp[pid] = FTraceCallGraph()
> + # when the call is finished, see which device matches it
> + if(ftemp[pid].addLine(t, m)):
> + if(not ftemp[pid].sanityCheck()):
> + id = "task %s cpu %s" % (pid, m.group("cpu"))
> + data.vprint("Sanity check failed for "+id+", ignoring this callback")
> + continue
> + callstart = ftemp[pid].start
> + callend = ftemp[pid].end
> + for p in data.phases:
> + if(data.dmesg[p]['start'] <= callstart and callstart <= data.dmesg[p]['end']):
> + list = data.dmesg[p]['list']
> + for devname in list:
> + dev = list[devname]
> + if(pid == dev['pid'] and callstart <= dev['start'] and callend >= dev['end']):
> + data.vprint("%15s [%f - %f] %s(%d)" % (p, callstart, callend, devname, pid))
> + dev['ftrace'] = ftemp[pid]
> + break
> + ftemp[pid] = FTraceCallGraph()
> + tf.close()
> +
> +# Function: sortKernelLog
> +# Description:
> +# The dmesg output log sometimes comes with with lines that have
> +# timestamps out of order. This could cause issues since a call
> +# could accidentally end up in the wrong phase
> +def sortKernelLog():
> + global sysvals, data
> + lf = open(sysvals.dmesgfile, 'r')
> + dmesglist = []
> + count = 0
> + for line in lf:
> + line = line.replace("\r\n", "")
> + if(count == 0):
> + parseStamp(line)
> + elif(count == 1):
> + m = re.match(r"# fwsuspend (?P<s>[0-9]*) fwresume (?P<r>[0-9]*)$", line)
> + if(m):
> + data.fwSuspend = int(m.group("s"))
> + data.fwResume = int(m.group("r"))
> + if(data.fwSuspend > 0 or data.fwResume > 0):
> + data.fwValid = True
> + if(re.match(r".*(\[ *)(?P<ktime>[0-9\.]*)(\]) (?P<msg>.*)", line)):
> + dmesglist.append(line)
> + count += 1
> + lf.close()
> + last = ""
> +
> + # fix lines with the same time stamp and function with the call and return swapped
> + for line in dmesglist:
> + mc = re.match(r".*(\[ *)(?P<t>[0-9\.]*)(\]) calling (?P<f>.*)\+ @ .*, parent: .*", line)
> + mr = re.match(r".*(\[ *)(?P<t>[0-9\.]*)(\]) call (?P<f>.*)\+ returned .* after (?P<dt>.*) usecs", last)
> + if(mc and mr and (mc.group("t") == mr.group("t")) and (mc.group("f") == mr.group("f"))):
> + i = dmesglist.index(last)
> + j = dmesglist.index(line)
> + dmesglist[i] = line
> + dmesglist[j] = last
> + last = line
> + return dmesglist
> +
> +# Function: analyzeKernelLog
> +# Description:
> +# Analyse a dmesg log output file generated from this app during
> +# the execution phase. Create a set of device structures in memory
> +# for subsequent formatting in the html output file
> +def analyzeKernelLog():
> + global sysvals, data
> +
> + print("PROCESSING DATA")
> + data.vprint("Analyzing the dmesg data...")
> + if(os.path.exists(sysvals.dmesgfile) == False):
> + print("ERROR: %s doesn't exist") % sysvals.dmesgfile
> + return False
> +
> + lf = sortKernelLog()
> + phase = "suspend_runtime"
> +
> + dm = {
> + 'suspend_general': r"PM: Syncing filesystems.*",
> + 'suspend_early': r"PM: suspend of devices complete after.*",
> + 'suspend_noirq': r"PM: late suspend of devices complete after.*",
> + 'suspend_cpu': r"PM: noirq suspend of devices complete after.*",
> + 'resume_cpu': r"ACPI: Low-level resume complete.*",
> + 'resume_noirq': r"ACPI: Waking up from system sleep state.*",
> + 'resume_early': r"PM: noirq resume of devices complete after.*",
> + 'resume_general': r"PM: early resume of devices complete after.*",
> + 'resume_complete': r".*Restarting tasks \.\.\..*",
> + }
> + if(sysvals.suspendmode == "standby"):
> + dm['resume_cpu'] = r"PM: Restoring platform NVS memory"
> + elif(sysvals.suspendmode == "disk"):
> + dm['suspend_early'] = r"PM: freeze of devices complete after.*"
> + dm['suspend_noirq'] = r"PM: late freeze of devices complete after.*"
> + dm['suspend_cpu'] = r"PM: noirq freeze of devices complete after.*"
> + dm['resume_cpu'] = r"PM: Restoring platform NVS memory"
> + dm['resume_early'] = r"PM: noirq restore of devices complete after.*"
> + dm['resume_general'] = r"PM: early restore of devices complete after.*"
> +
> + action_start = 0.0
> + for line in lf:
> + # -- preprocessing --
> + # parse each dmesg line into the time and message
> + m = re.match(r".*(\[ *)(?P<ktime>[0-9\.]*)(\]) (?P<msg>.*)", line)
> + if(m):
> + ktime = float(m.group("ktime"))
> + msg = m.group("msg")
> + else:
> + print line
> + continue
> +
> + # -- phase changes --
> + # suspend_general start
> + if(re.match(dm['suspend_general'], msg)):
> + phase = "suspend_general"
> + data.dmesg[phase]['start'] = ktime
> + data.start = ktime
> + # action start: syncing filesystems
> + action_start = ktime
> + # suspend_early start
> + elif(re.match(dm['suspend_early'], msg)):
> + data.dmesg["suspend_general"]['end'] = ktime
> + phase = "suspend_early"
> + data.dmesg[phase]['start'] = ktime
> + # suspend_noirq start
> + elif(re.match(dm['suspend_noirq'], msg)):
> + data.dmesg["suspend_early"]['end'] = ktime
> + phase = "suspend_noirq"
> + data.dmesg[phase]['start'] = ktime
> + # suspend_cpu start
> + elif(re.match(dm['suspend_cpu'], msg)):
> + data.dmesg["suspend_noirq"]['end'] = ktime
> + phase = "suspend_cpu"
> + data.dmesg[phase]['start'] = ktime
> + # resume_cpu start
> + elif(re.match(dm['resume_cpu'], msg)):
> + data.tSuspended = ktime
> + data.dmesg["suspend_cpu"]['end'] = ktime
> + phase = "resume_cpu"
> + data.dmesg[phase]['start'] = ktime
> + # resume_noirq start
> + elif(re.match(dm['resume_noirq'], msg)):
> + data.dmesg["resume_cpu"]['end'] = ktime
> + phase = "resume_noirq"
> + data.dmesg[phase]['start'] = ktime
> + # action end: ACPI resume
> + data.newAction("resume_cpu", "ACPI", -1, "", action_start, ktime)
> + # resume_early start
> + elif(re.match(dm['resume_early'], msg)):
> + data.dmesg["resume_noirq"]['end'] = ktime
> + phase = "resume_early"
> + data.dmesg[phase]['start'] = ktime
> + # resume_general start
> + elif(re.match(dm['resume_general'], msg)):
> + data.dmesg["resume_early"]['end'] = ktime
> + phase = "resume_general"
> + data.dmesg[phase]['start'] = ktime
> + # resume complete start
> + elif(re.match(dm['resume_complete'], msg)):
> + data.dmesg["resume_general"]['end'] = ktime
> + data.end = ktime
> + phase = "resume_runtime"
> + break
> +
> + # -- device callbacks --
> + if(phase in data.phases):
> + # device init call
> + if(re.match(r"calling (?P<f>.*)\+ @ .*, parent: .*", msg)):
> + sm = re.match(r"calling (?P<f>.*)\+ @ (?P<n>.*), parent: (?P<p>.*)", msg);
> + f = sm.group("f")
> + n = sm.group("n")
> + p = sm.group("p")
> + if(f and n and p):
> + data.newAction(phase, f, int(n), p, ktime, -1)
> + # device init return
> + elif(re.match(r"call (?P<f>.*)\+ returned .* after (?P<t>.*) usecs", msg)):
> + sm = re.match(r"call (?P<f>.*)\+ returned .* after (?P<t>.*) usecs(?P<a>.*)", msg);
> + f = sm.group("f")
> + t = sm.group("t")
> + list = data.dmesg[phase]['list']
> + if(f in list):
> + dev = list[f]
> + dev['length'] = int(t)
> + dev['end'] = ktime
> + data.vprint("%15s [%f - %f] %s(%d) %s" %
> + (phase, dev['start'], dev['end'], f, dev['pid'], dev['par']))
> +
> + # -- phase specific actions --
> + if(phase == "suspend_general"):
> + if(re.match(r"PM: Preparing system for mem sleep.*", msg)):
> + data.newAction(phase, "filesystem-sync", -1, "", action_start, ktime)
> + elif(re.match(r"Freezing user space processes .*", msg)):
> + action_start = ktime
> + elif(re.match(r"Freezing remaining freezable tasks.*", msg)):
> + data.newAction(phase, "freeze-user-processes", -1, "", action_start, ktime)
> + action_start = ktime
> + elif(re.match(r"PM: Entering (?P<mode>[a-z,A-Z]*) sleep.*", msg)):
> + data.newAction(phase, "freeze-tasks", -1, "", action_start, ktime)
> + elif(phase == "suspend_cpu"):
> + m = re.match(r"smpboot: CPU (?P<cpu>[0-9]*) is now offline", msg)
> + if(m):
> + cpu = "CPU"+m.group("cpu")
> + data.newAction(phase, cpu, -1, "", action_start, ktime)
> + action_start = ktime
> + elif(re.match(r"ACPI: Preparing to enter system sleep state.*", msg)):
> + action_start = ktime
> + elif(re.match(r"Disabling non-boot CPUs .*", msg)):
> + data.newAction(phase, "ACPI", -1, "", action_start, ktime)
> + action_start = ktime
> + elif(phase == "resume_cpu"):
> + m = re.match(r"CPU(?P<cpu>[0-9]*) is up", msg)
> + if(m):
> + cpu = "CPU"+m.group("cpu")
> + data.newAction(phase, cpu, -1, "", action_start, ktime)
> + action_start = ktime
> + elif(re.match(r"Enabling non-boot CPUs .*", msg)):
> + action_start = ktime
> +
> + # fill in any missing phases
> + lp = "suspend_general"
> + for p in data.phases:
> + if(p == "suspend_general"):
> + continue
> + if(data.dmesg[p]['start'] < 0):
> + data.dmesg[p]['start'] = data.dmesg[lp]['end']
> + if(p == "resume_cpu"):
> + data.tSuspended = data.dmesg[lp]['end']
> + if(data.dmesg[p]['end'] < 0):
> + data.dmesg[p]['end'] = data.dmesg[p]['start']
> + lp = p
> +
> + data.fixupInitcallsThatDidntReturn()
> + return True
> +
> +# Function: setTimelineRows
> +# Description:
> +# Organize the device or thread lists into the smallest
> +# number of rows possible, with no entry overlapping
> +# Arguments:
> +# list: the list to sort (dmesg or ftrace)
> +# sortedkeys: sorted key list to use
> +def setTimelineRows(list, sortedkeys):
> + global data
> +
> + # clear all rows and set them to undefined
> + remaining = len(list)
> + rowdata = dict()
> + row = 0
> + for item in list:
> + list[item]['row'] = -1
> +
> + # try to pack each row with as many ranges as possible
> + while(remaining > 0):
> + if(row not in rowdata):
> + rowdata[row] = []
> + for item in sortedkeys:
> + if(list[item]['row'] < 0):
> + s = list[item]['start']
> + e = list[item]['end']
> + valid = True
> + for ritem in rowdata[row]:
> + rs = ritem['start']
> + re = ritem['end']
> + if(not (((s <= rs) and (e <= rs)) or ((s >= re) and (e >= re)))):
> + valid = False
> + break
> + if(valid):
> + rowdata[row].append(list[item])
> + list[item]['row'] = row
> + remaining -= 1
> + row += 1
> + return row
> +
> +# Function: createTimeScale
> +# Description:
> +# Create timescale lines for the dmesg and ftrace timelines
> +# Arguments:
> +# t0: start time (suspend begin)
> +# tMax: end time (resume end)
> +# tSuspend: time when suspend occurs
> +def createTimeScale(t0, tMax, tSuspended):
> + global data
> + timescale = "<div class=\"t\" style=\"right:{0}%\">{1}</div>\n"
> + output = '<div id="timescale">\n'
> +
> + # set scale for timeline
> + tTotal = tMax - t0
> + tS = 0.1
> + if(tTotal <= 0):
> + return output
> + if(tTotal > 4):
> + tS = 1
> + if(tSuspended < 0):
> + for i in range(int(tTotal/tS)+1):
> + pos = "%0.3f" % (100 - ((float(i)*tS*100)/tTotal))
> + if(i > 0):
> + val = "%0.f" % (float(i)*tS*1000)
> + else:
> + val = ""
> + output += timescale.format(pos, val)
> + else:
> + tSuspend = tSuspended - t0
> + divTotal = int(tTotal/tS) + 1
> + divSuspend = int(tSuspend/tS)
> + s0 = (tSuspend - tS*divSuspend)*100/tTotal
> + for i in range(divTotal):
> + pos = "%0.3f" % (100 - ((float(i)*tS*100)/tTotal) - s0)
> + if((i == 0) and (s0 < 3)):
> + val = ""
> + elif(i == divSuspend):
> + val = "S/R"
> + else:
> + val = "%0.f" % (float(i-divSuspend)*tS*1000)
> + output += timescale.format(pos, val)
> + output += '</div>\n'
> + return output
> +
> +# Function: createHTML
> +# Description:
> +# Create the output html file.
> +def createHTML():
> + global sysvals, data
> +
> + data.normalizeTime()
> +
> + # html function templates
> + headline_stamp = '<div class="stamp">{0} {1} {2} {3}</div>\n'
> + html_zoombox = '<center><button id="zoomin">ZOOM IN</button><button id="zoomout">ZOOM OUT</button><button id="zoomdef">ZOOM 1:1</button></center>\n<div id="dmesgzoombox" class="zoombox">\n'
> + html_timeline = '<div id="{0}" class="timeline" style="height:{1}px">\n'
> + html_device = '<div id="{0}" title="{1}" class="thread" style="left:{2}%;top:{3}%;height:{4}%;width:{5}%;">{6}</div>\n'
> + html_phase = '<div class="phase" style="left:{0}%;width:{1}%;top:{2}%;height:{3}%;background-color:{4}">{5}</div>\n'
> + html_legend = '<div class="square" style="left:{0}%;background-color:{1}"> {2}</div>\n'
> + html_timetotal = '<table class="time1">\n<tr>'\
> + '<td class="gray">{2} Suspend Time: <b>{0} ms</b></td>'\
> + '<td class="gray">{2} Resume Time: <b>{1} ms</b></td>'\
> + '</tr>\n</table>\n'
> + html_timegroups = '<table class="time2">\n<tr>'\
> + '<td class="green">Kernel Suspend: {0} ms</td>'\
> + '<td class="purple">Firmware Suspend: {1} ms</td>'\
> + '<td class="purple">Firmware Resume: {2} ms</td>'\
> + '<td class="yellow">Kernel Resume: {3} ms</td>'\
> + '</tr>\n</table>\n'
> +
> + # device timeline (dmesg)
> + if(data.usedmesg):
> + data.vprint("Creating Device Timeline...")
> + devtl = Timeline()
> +
> + # Generate the header for this timeline
> + t0 = data.start
> + tMax = data.end
> + tTotal = tMax - t0
> + if(tTotal == 0):
> + print("ERROR: No timeline data")
> + sys.exit()
> + suspend_time = "%.0f"%(-data.start*1000)
> + resume_time = "%.0f"%(data.end*1000)
> + if data.fwValid:
> + devtl.html['timeline'] = html_timetotal.format(suspend_time, resume_time, "Total")
> + sktime = "%.3f"%((data.dmesg['suspend_cpu']['end'] - data.dmesg['suspend_general']['start'])*1000)
> + sftime = "%.3f"%(data.fwSuspend / 1000000.0)
> + rftime = "%.3f"%(data.fwResume / 1000000.0)
> + rktime = "%.3f"%((data.dmesg['resume_general']['end'] - data.dmesg['resume_cpu']['start'])*1000)
> + devtl.html['timeline'] += html_timegroups.format(sktime, sftime, rftime, rktime)
> + else:
> + devtl.html['timeline'] = html_timetotal.format(suspend_time, resume_time, "Kernel")
> +
> + # determine the maximum number of rows we need to draw
> + timelinerows = 0
> + for phase in data.dmesg:
> + list = data.dmesg[phase]['list']
> + rows = setTimelineRows(list, list)
> + data.dmesg[phase]['row'] = rows
> + if(rows > timelinerows):
> + timelinerows = rows
> +
> + # calculate the timeline height and create its bounding box
> + devtl.setRows(timelinerows + 1)
> + devtl.html['timeline'] += html_zoombox;
> + devtl.html['timeline'] += html_timeline.format("dmesg", devtl.height);
> +
> + # draw the colored boxes for each of the phases
> + for b in data.dmesg:
> + phase = data.dmesg[b]
> + left = "%.3f" % (((phase['start']-data.start)*100)/tTotal)
> + width = "%.3f" % (((phase['end']-phase['start'])*100)/tTotal)
> + devtl.html['timeline'] += html_phase.format(left, width, "%.3f"%devtl.scaleH, "%.3f"%(100-devtl.scaleH), data.dmesg[b]['color'], "")
> +
> + # draw the time scale, try to make the number of labels readable
> + devtl.html['scale'] = createTimeScale(t0, tMax, data.tSuspended)
> + devtl.html['timeline'] += devtl.html['scale']
> + for b in data.dmesg:
> + phaselist = data.dmesg[b]['list']
> + for d in phaselist:
> + name = d
> + if(d in data.altdevname):
> + name = data.altdevname[d]
> + dev = phaselist[d]
> + height = (100.0 - devtl.scaleH)/data.dmesg[b]['row']
> + top = "%.3f" % ((dev['row']*height) + devtl.scaleH)
> + left = "%.3f" % (((dev['start']-data.start)*100)/tTotal)
> + width = "%.3f" % (((dev['end']-dev['start'])*100)/tTotal)
> + len = " (%0.3f ms) " % ((dev['end']-dev['start'])*1000)
> + color = "rgba(204,204,204,0.5)"
> + devtl.html['timeline'] += html_device.format(dev['id'], name+len+b, left, top, "%.3f"%height, width, name)
> +
> + # timeline is finished
> + devtl.html['timeline'] += "</div>\n</div>\n"
> +
> + # draw a legend which describes the phases by color
> + devtl.html['legend'] = "<div class=\"legend\">\n"
> + pdelta = 100.0/data.phases.__len__()
> + pmargin = pdelta / 4.0
> + for phase in data.phases:
> + order = "%.2f" % ((data.dmesg[phase]['order'] * pdelta) + pmargin)
> + name = string.replace(phase, "_", " ")
> + devtl.html['legend'] += html_legend.format(order, data.dmesg[phase]['color'], name)
> + devtl.html['legend'] += "</div>\n"
> +
> + hf = open(sysvals.htmlfile, 'w')
> + thread_height = 0
> +
> + # write the html header first (html head, css code, everything up to the start of body)
> + html_header = "<!DOCTYPE html>\n<html>\n<head>\n\
> + <meta http-equiv=\"content-type\" content=\"text/html; charset=UTF-8\">\n\
> + <title>AnalyzeSuspend</title>\n\
> + <style type='text/css'>\n\
> + body {overflow-y: scroll;}\n\
> + .stamp {width: 100%;text-align:center;background-color:gray;line-height:30px;color:white;font: 25px Arial;}\n\
> + .callgraph {margin-top: 30px;box-shadow: 5px 5px 20px black;}\n\
> + .callgraph article * {padding-left: 28px;}\n\
> + h1 {color:black;font: bold 30px Times;}\n\
> + table {width:100%;}\n\
> + .gray {background-color:rgba(80,80,80,0.1);}\n\
> + .green {background-color:rgba(204,255,204,0.4);}\n\
> + .purple {background-color:rgba(128,0,128,0.2);}\n\
> + .yellow {background-color:rgba(255,255,204,0.4);}\n\
> + .time1 {font: 22px Arial;border:1px solid;}\n\
> + .time2 {font: 15px Arial;border-bottom:1px solid;border-left:1px solid;border-right:1px solid;}\n\
> + td {text-align: center;}\n\
> + .tdhl {color: red;}\n\
> + .hide {display: none;}\n\
> + .pf {display: none;}\n\
> + .pf:checked + label {background: url(\'data:image/svg+xml;utf,<?xml version=\"1.0\" standalone=\"no\"?><svg xmlns=\"http://www.w3.org/2000/svg\" height=\"18\" width=\"18\" version=\"1.1\"><circle cx=\"9\" cy=\"9\" r=\"8\" stroke=\"black\" stroke-width=\"1\" fill=\"white\"/><rect x=\"4\" y=\"8\" width=\"10\" height=\"2\" style=\"fill:black;stroke-width:0\"/><rect x=\"8\" y=\"4\" width=\"2\" height=\"10\" style=\"fill:black;stroke-width:0\"/></svg>\') no-repeat left center;}\n\
> + .pf:not(:checked) ~ label {background: url(\'data:image/svg+xml;utf,<?xml version=\"1.0\" standalone=\"no\"?><svg xmlns=\"http://www.w3.org/2000/svg\" height=\"18\" width=\"18\" version=\"1.1\"><circle cx=\"9\" cy=\"9\" r=\"8\" stroke=\"black\" stroke-width=\"1\" fill=\"white\"/><rect x=\"4\" y=\"8\" width=\"10\" height=\"2\" style=\"fill:black;stroke-width:0\"/></svg>\') no-repeat left center;}\n\
> + .pf:checked ~ *:not(:nth-child(2)) {display: none;}\n\
> + .zoombox {position: relative; width: 100%; overflow-x: scroll;}\n\
> + .timeline {position: relative; font-size: 14px;cursor: pointer;width: 100%; overflow: hidden; background-color:#dddddd;}\n\
> + .thread {position: absolute; height: "+"%.3f"%thread_height+"%; overflow: hidden; line-height: 30px; border:1px solid;text-align:center;white-space:nowrap;background-color:rgba(204,204,204,0.5);}\n\
> + .thread:hover {background-color:white;border:1px solid red;z-index:10;}\n\
> + .phase {position: absolute;overflow: hidden;border:0px;text-align:center;}\n\
> + .t {position: absolute; top: 0%; height: 100%; border-right:1px solid black;}\n\
> + .legend {position: relative; width: 100%; height: 40px; text-align: center;margin-bottom:20px}\n\
> + .legend .square {position:absolute;top:10px; width: 0px;height: 20px;border:1px solid;padding-left:20px;}\n\
> + button {height:40px;width:200px;margin-bottom:20px;margin-top:20px;font-size:24px;}\n\
> + </style>\n</head>\n<body>\n"
> + hf.write(html_header)
> +
> + # write the test title and general info header
> + if(data.stamp['time'] != ""):
> + hf.write(headline_stamp.format(data.stamp['host'],
> + data.stamp['kernel'], data.stamp['mode'], data.stamp['time']))
> +
> + # write the dmesg data (device timeline)
> + if(data.usedmesg):
> + hf.write(devtl.html['timeline'])
> + hf.write(devtl.html['legend'])
> + hf.write('<div id="devicedetail"></div>\n')
> + hf.write('<div id="devicetree"></div>\n')
> +
> + # write the ftrace data (callgraph)
> + if(data.useftrace):
> + hf.write('<section id="callgraphs" class="callgraph">\n')
> + # write out the ftrace data converted to html
> + html_func_top = '<article id="{0}" class="atop" style="background-color:{1}">\n<input type="checkbox" class="pf" id="f{2}" checked/><label for="f{2}">{3} {4}</label>\n'
> + html_func_start = '<article>\n<input type="checkbox" class="pf" id="f{0}" checked/><label for="f{0}">{1} {2}</label>\n'
> + html_func_end = '</article>\n'
> + html_func_leaf = '<article>{0} {1}</article>\n'
> + num = 0
> + for p in data.phases:
> + list = data.dmesg[p]['list']
> + for devname in data.sortedDevices(p):
> + if('ftrace' not in list[devname]):
> + continue
> + name = devname
> + if(devname in data.altdevname):
> + name = data.altdevname[devname]
> + devid = list[devname]['id']
> + cg = list[devname]['ftrace']
> + flen = "(%.3f ms)" % ((cg.end - cg.start)*1000)
> + hf.write(html_func_top.format(devid, data.dmesg[p]['color'], num, name+" "+p, flen))
> + num += 1
> + for line in cg.list:
> + if(line.length < 0.000000001):
> + flen = ""
> + else:
> + flen = "(%.3f ms)" % (line.length*1000)
> + if(line.freturn and line.fcall):
> + hf.write(html_func_leaf.format(line.name, flen))
> + elif(line.freturn):
> + hf.write(html_func_end)
> + else:
> + hf.write(html_func_start.format(num, line.name, flen))
> + num += 1
> + hf.write(html_func_end)
> + hf.write("\n\n </section>\n")
> + # write the footer and close
> + addScriptCode(hf)
> + hf.write("</body>\n</html>\n")
> + hf.close()
> + return True
> +
> +def addScriptCode(hf):
> + global data
> +
> + t0 = (data.start - data.tSuspended) * 1000
> + tMax = (data.end - data.tSuspended) * 1000
> + # create an array in javascript memory with the device details
> + detail = ' var bounds = [%f,%f];\n' % (t0, tMax)
> + detail += ' var d = [];\n'
> + dfmt = ' d["%s"] = { n:"%s", p:"%s", c:[%s] };\n';
> + for p in data.dmesg:
> + list = data.dmesg[p]['list']
> + for d in list:
> + parent = data.deviceParentID(d, p)
> + idlist = data.deviceChildrenIDs(d, p)
> + idstr = ""
> + for i in idlist:
> + if(idstr == ""):
> + idstr += '"'+i+'"'
> + else:
> + idstr += ', '+'"'+i+'"'
> + detail += dfmt % (list[d]['id'], d, parent, idstr)
> +
> + # add the code which will manipulate the data in the browser
> + script_code = \
> + '<script type="text/javascript">\n'+detail+\
> + ' var filter = [];\n'\
> + ' var table = [];\n'\
> + ' function deviceParent(devid) {\n'\
> + ' var devlist = [];\n'\
> + ' if(filter.indexOf(devid) < 0) filter[filter.length] = devid;\n'\
> + ' if(d[devid].p in d)\n'\
> + ' devlist = deviceParent(d[devid].p);\n'\
> + ' else if(d[devid].p != "")\n'\
> + ' devlist = [d[devid].p];\n'\
> + ' devlist[devlist.length] = d[devid].n;\n'\
> + ' return devlist;\n'\
> + ' }\n'\
> + ' function deviceChildren(devid, column, row) {\n'\
> + ' if(!(devid in d)) return;\n'\
> + ' if(filter.indexOf(devid) < 0) filter[filter.length] = devid;\n'\
> + ' var cell = {name: d[devid].n, span: 1};\n'\
> + ' var span = 0;\n'\
> + ' if(column >= table.length) table[column] = [];\n'\
> + ' table[column][row] = cell;\n'\
> + ' for(var i = 0; i < d[devid].c.length; i++) {\n'\
> + ' var cid = d[devid].c[i];\n'\
> + ' span += deviceChildren(cid, column+1, row+span);\n'\
> + ' }\n'\
> + ' if(span == 0) span = 1;\n'\
> + ' table[column][row].span = span;\n'\
> + ' return span;\n'\
> + ' }\n'\
> + ' function deviceTree(devid, resume) {\n'\
> + ' var html = "<table border=1>";\n'\
> + ' filter = [];\n'\
> + ' table = [];\n'\
> + ' plist = deviceParent(devid);\n'\
> + ' var devidx = plist.length - 1;\n'\
> + ' for(var i = 0; i < devidx; i++)\n'\
> + ' table[i] = [{name: plist[i], span: 1}];\n'\
> + ' deviceChildren(devid, devidx, 0);\n'\
> + ' for(var i = 0; i < devidx; i++)\n'\
> + ' table[i][0].span = table[devidx][0].span;\n'\
> + ' for(var row = 0; row < table[0][0].span; row++) {\n'\
> + ' html += "<tr>";\n'\
> + ' for(var col = 0; col < table.length; col++)\n'\
> + ' if(row in table[col]) {\n'\
> + ' var cell = table[col][row];\n'\
> + ' var args = "";\n'\
> + ' if(cell.span > 1)\n'\
> + ' args += " rowspan="+cell.span;\n'\
> + ' if((col == devidx) && (row == 0))\n'\
> + ' args += " class=tdhl";\n'\
> + ' if(resume)\n'\
> + ' html += "<td"+args+">"+cell.name+" →</td>";\n'\
> + ' else\n'\
> + ' html += "<td"+args+">← "+cell.name+"</td>";\n'\
> + ' }\n'\
> + ' html += "</tr>";\n'\
> + ' }\n'\
> + ' html += "</table>";\n'\
> + ' return html;\n'\
> + ' }\n'\
> + ' function zoomTimeline() {\n'\
> + ' var timescale = document.getElementById("timescale");\n'\
> + ' var dmesg = document.getElementById("dmesg");\n'\
> + ' var zoombox = document.getElementById("dmesgzoombox");\n'\
> + ' var val = parseFloat(dmesg.style.width);\n'\
> + ' var newval = 100;\n'\
> + ' var sh = window.outerWidth / 2;\n'\
> + ' if(this.id == "zoomin") {\n'\
> + ' newval = val * 1.2;\n'\
> + ' if(newval > 40000) newval = 40000;\n'\
> + ' dmesg.style.width = newval+"%";\n'\
> + ' zoombox.scrollLeft = ((zoombox.scrollLeft + sh) * newval / val) - sh;\n'\
> + ' } else if (this.id == "zoomout") {\n'\
> + ' newval = val / 1.2;\n'\
> + ' if(newval < 100) newval = 100;\n'\
> + ' dmesg.style.width = newval+"%";\n'\
> + ' zoombox.scrollLeft = ((zoombox.scrollLeft + sh) * newval / val) - sh;\n'\
> + ' } else {\n'\
> + ' zoombox.scrollLeft = 0;\n'\
> + ' dmesg.style.width = "100%";\n'\
> + ' }\n'\
> + ' var html = "";\n'\
> + ' var t0 = bounds[0];\n'\
> + ' var tMax = bounds[1];\n'\
> + ' var tTotal = tMax - t0;\n'\
> + ' var wTotal = tTotal * 100.0 / newval;\n'\
> + ' for(var tS = 1000; (wTotal / tS) < 3; tS /= 10);\n'\
> + ' if(tS < 1) tS = 1;\n'\
> + ' for(var s = ((t0 / tS)|0) * tS; s < tMax; s += tS) {\n'\
> + ' var pos = (tMax - s) * 100.0 / tTotal;\n'\
> + ' var name = (s == 0)?"S/R":(s+"ms");\n'\
> + ' html += \"<div class=\\\"t\\\" style=\\\"right:\"+pos+\"%\\\">\"+name+\"</div>\";\n'\
> + ' }\n'\
> + ' timescale.innerHTML = html;\n'\
> + ' }\n'\
> + ' function deviceDetail() {\n'\
> + ' var devtitle = document.getElementById("devicedetail");\n'\
> + ' devtitle.innerHTML = "<h1>"+this.title+"</h1>";\n'\
> + ' var devtree = document.getElementById("devicetree");\n'\
> + ' devtree.innerHTML = deviceTree(this.id, (this.title.indexOf("resume") >= 0));\n'\
> + ' var cglist = document.getElementById("callgraphs");\n'\
> + ' if(!cglist) return;\n'\
> + ' var cg = cglist.getElementsByClassName("atop");\n'\
> + ' for (var i = 0; i < cg.length; i++) {\n'\
> + ' if(filter.indexOf(cg[i].id) >= 0) {\n'\
> + ' cg[i].style.display = "block";\n'\
> + ' } else {\n'\
> + ' cg[i].style.display = "none";\n'\
> + ' }\n'\
> + ' }\n'\
> + ' }\n'\
> + ' window.addEventListener("load", function () {\n'\
> + ' var dmesg = document.getElementById("dmesg");\n'\
> + ' dmesg.style.width = "100%"\n'\
> + ' document.getElementById("zoomin").onclick = zoomTimeline;\n'\
> + ' document.getElementById("zoomout").onclick = zoomTimeline;\n'\
> + ' document.getElementById("zoomdef").onclick = zoomTimeline;\n'\
> + ' var dev = dmesg.getElementsByClassName("thread");\n'\
> + ' for (var i = 0; i < dev.length; i++) {\n'\
> + ' dev[i].onclick = deviceDetail;\n'\
> + ' }\n'\
> + ' zoomTimeline();\n'\
> + ' });\n'\
> + '</script>\n'
> + hf.write(script_code);
> +
> +# Function: executeSuspend
> +# Description:
> +# Execute system suspend through the sysfs interface
> +def executeSuspend():
> + global sysvals, data
> +
> + detectUSB()
> + pf = open(sysvals.powerfile, 'w')
> + # clear the kernel ring buffer just as we start
> + os.system("dmesg -C")
> + # start ftrace
> + if(data.useftrace):
> + print("START TRACING")
> + os.system("echo 1 > "+sysvals.tpath+"tracing_on")
> + os.system("echo SUSPEND START > "+sysvals.tpath+"trace_marker")
> + # initiate suspend
> + if(sysvals.rtcwake):
> + print("SUSPEND START")
> + os.system("rtcwake -s 10 -m "+sysvals.suspendmode)
> + else:
> + print("SUSPEND START (press a key to resume)")
> + pf.write(sysvals.suspendmode)
> + # execution will pause here
> + pf.close()
> + # return from suspend
> + print("RESUME COMPLETE")
> + # stop ftrace
> + if(data.useftrace):
> + os.system("echo RESUME COMPLETE > "+sysvals.tpath+"trace_marker")
> + os.system("echo 0 > "+sysvals.tpath+"tracing_on")
> + print("CAPTURING FTRACE")
> + os.system("echo \""+sysvals.teststamp+"\" > "+sysvals.ftracefile)
> + os.system("cat "+sysvals.tpath+"trace >> "+sysvals.ftracefile)
> + # grab a copy of the dmesg output
> + print("CAPTURING DMESG")
> + os.system("echo \""+sysvals.teststamp+"\" > "+sysvals.dmesgfile)
> + os.system("dmesg -c >> "+sysvals.dmesgfile)
> +
> +# Function: detectUSB
> +# Description:
> +# Detect all the USB hosts and devices currently connected
> +def detectUSB():
> + global sysvals, data
> +
> + for dirname, dirnames, filenames in os.walk("/sys/devices"):
> + if(re.match(r".*/usb[0-9]*.*", dirname) and
> + "idVendor" in filenames and "idProduct" in filenames):
> + vid = os.popen("cat %s/idVendor 2>/dev/null" % dirname).read().replace('\n', '')
> + pid = os.popen("cat %s/idProduct 2>/dev/null" % dirname).read().replace('\n', '')
> + product = os.popen("cat %s/product 2>/dev/null" % dirname).read().replace('\n', '')
> + name = dirname.split('/')[-1]
> + if(len(product) > 0):
> + data.altdevname[name] = "%s [%s]" % (product, name)
> + else:
> + data.altdevname[name] = "%s:%s [%s]" % (vid, pid, name)
> +
> +def getModes():
> + global sysvals
> + modes = ""
> + if(os.path.exists(sysvals.powerfile)):
> + fp = open(sysvals.powerfile, 'r')
> + modes = string.split(fp.read())
> + fp.close()
> + return modes
> +
> +# Function: statusCheck
> +# Description:
> +# Verify that the requested command and options will work
> +def statusCheck(dryrun):
> + global sysvals, data
> + res = dict()
> +
> + if(data.notestrun):
> + print("SUCCESS: The command should run!")
> + return
> +
> + # check we have root access
> + check = "YES"
> + if(os.environ['USER'] != "root"):
> + if(not dryrun):
> + doError("root access is required", False)
> + check = "NO"
> + res[" have root access: "] = check
> +
> + # check sysfs is mounted
> + check = "YES"
> + if(not os.path.exists(sysvals.powerfile)):
> + if(not dryrun):
> + doError("sysfs must be mounted", False)
> + check = "NO"
> + res[" is sysfs mounted: "] = check
> +
> + # check target mode is a valid mode
> + check = "YES"
> + modes = getModes()
> + if(sysvals.suspendmode not in modes):
> + if(not dryrun):
> + doError("%s is not a value power mode" % sysvals.suspendmode, False)
> + check = "NO"
> + res[" is "+sysvals.suspendmode+" a power mode: "] = check
> +
> + # check if ftrace is available
> + if(data.useftrace):
> + check = "YES"
> + if(not verifyFtrace()):
> + if(not dryrun):
> + doError("ftrace is not configured", False)
> + check = "NO"
> + res[" is ftrace usable: "] = check
> +
> + # check if rtcwake
> + if(sysvals.rtcwake):
> + check = "YES"
> + version = os.popen("rtcwake -V 2>/dev/null").read()
> + if(not version.startswith("rtcwake")):
> + if(not dryrun):
> + doError("rtcwake is not installed", False)
> + check = "NO"
> + res[" is rtcwake usable: "] = check
> +
> + if(dryrun):
> + status = True
> + print("Checking if system can run the current command:")
> + for r in res:
> + print("%s\t%s" % (r, res[r]))
> + if(res[r] != "YES"):
> + status = False
> + if(status):
> + print("SUCCESS: The command should run!")
> + else:
> + print("FAILURE: The command won't run!")
> +
> +def printHelp():
> + global sysvals
> + modes = getModes()
> +
> + print("")
> + print("AnalyzeSuspend")
> + print("Usage: sudo analyze_suspend.py <options>")
> + print("")
> + print("Description:")
> + print(" Initiates a system suspend/resume while capturing dmesg")
> + print(" and (optionally) ftrace data to analyze device timing")
> + print("")
> + print(" Generates output files in subdirectory: suspend-mmddyy-HHMMSS")
> + print(" HTML output: <hostname>_<mode>.html")
> + print(" raw dmesg output: <hostname>_<mode>_dmesg.txt")
> + print(" raw ftrace output (with -f): <hostname>_<mode>_ftrace.txt")
> + print("")
> + print("Options:")
> + print(" [general]")
> + print(" -h Print this help text")
> + print(" -verbose Print extra information during execution and analysis")
> + print(" -status Test to see if the system is enabled to run this tool")
> + print(" -modes List available suspend modes")
> + print(" -m mode Mode to initiate for suspend %s (default: %s)") % (modes, sysvals.suspendmode)
> + print(" -rtcwake Use rtcwake to autoresume after 10 seconds (default: disabled)")
> + print(" -f Use ftrace to create device callgraphs (default: disabled)")
> + print(" [re-analyze data from previous runs]")
> + print(" -dmesg dmesgfile Create HTML timeline from dmesg file")
> + print(" -ftrace ftracefile Create HTML callgraph from ftrace file")
> + print("")
> + return True
> +
> +def doError(msg, help):
> + print("ERROR: %s") % msg
> + if(help == True):
> + printHelp()
> + sys.exit()
> +
> +# -- script main --
> +# loop through the command line arguments
> +cmd = ""
> +args = iter(sys.argv[1:])
> +for arg in args:
> + if(arg == "-m"):
> + try:
> + val = args.next()
> + except:
> + doError("No mode supplied", True)
> + sysvals.suspendmode = val
> + elif(arg == "-f"):
> + data.useftrace = True
> + elif(arg == "-modes"):
> + cmd = "modes"
> + elif(arg == "-status"):
> + cmd = "status"
> + elif(arg == "-verbose"):
> + data.verbose = True
> + elif(arg == "-rtcwake"):
> + sysvals.rtcwake = True
> + elif(arg == "-dmesg"):
> + try:
> + val = args.next()
> + except:
> + doError("No dmesg file supplied", True)
> + data.notestrun = True
> + data.usedmesg = True
> + sysvals.dmesgfile = val
> + elif(arg == "-ftrace"):
> + try:
> + val = args.next()
> + except:
> + doError("No ftrace file supplied", True)
> + data.notestrun = True
> + data.useftrace = True
> + sysvals.ftracefile = val
> + elif(arg == "-h"):
> + printHelp()
> + sys.exit()
> + else:
> + doError("Invalid argument: "+arg, True)
> +
> +# just run a utility command and exit
> +if(cmd != ""):
> + if(cmd == "status"):
> + statusCheck(True)
> + elif(cmd == "modes"):
> + modes = getModes()
> + print modes
> + sys.exit()
> +
> +data.initialize()
> +
> +# if instructed, re-analyze existing data files
> +if(data.notestrun):
> + sysvals.setOutputFile()
> + data.vprint("Output file: %s" % sysvals.htmlfile)
> + if(sysvals.dmesgfile != ""):
> + analyzeKernelLog()
> + if(sysvals.ftracefile != ""):
> + analyzeTraceLog()
> + createHTML()
> + sys.exit()
> +
> +# verify that we can run a test
> +data.usedmesg = True
> +statusCheck(False)
> +
> +# prepare for the test
> +if(data.useftrace):
> + initFtrace()
> +sysvals.initTestOutput()
> +
> +data.vprint("Output files:\n %s" % sysvals.dmesgfile)
> +if(data.useftrace):
> + data.vprint(" %s" % sysvals.ftracefile)
> +data.vprint(" %s" % sysvals.htmlfile)
> +
> +# execute the test
> +executeSuspend()
> +analyzeKernelLog()
> +if(data.useftrace):
> + analyzeTraceLog()
> +createHTML()
--
I speak only for myself.
Rafael J. Wysocki, Intel Open Source Technology Center.
prev parent reply other threads:[~2014-01-17 1:04 UTC|newest]
Thread overview: 2+ messages / expand[flat|nested] mbox.gz Atom feed top
2014-01-17 0:18 [PATCH v2] analyze_suspend.py: new tool for suspend/resume performance optimization Todd E Brandt
2014-01-17 1:18 ` Rafael J. Wysocki [this message]
Reply instructions:
You may reply publicly to this message via plain-text email
using any one of the following methods:
* Save the following mbox file, import it into your mail client,
and reply-to-all from there: mbox
Avoid top-posting and favor interleaved quoting:
https://en.wikipedia.org/wiki/Posting_style#Interleaved_style
* Reply using the --to, --cc, and --in-reply-to
switches of git-send-email(1):
git send-email \
--in-reply-to=2954888.old5rRCcAC@vostro.rjw.lan \
--to=rjw@rjwysocki.net \
--cc=linux-pm@vger.kernel.org \
--cc=todd.e.brandt@linux.intel.com \
/path/to/YOUR_REPLY
https://kernel.org/pub/software/scm/git/docs/git-send-email.html
* If your mail client supports setting the In-Reply-To header
via mailto: links, try the mailto: link
Be sure your reply has a Subject: header at the top and a blank line
before the message body.
This is a public inbox, see mirroring instructions
for how to clone and mirror all data and code used for this inbox