[net-next-2.6.git] / tools / perf / scripts / python / futex-contention.py

# futex contention
# (c) 2010, Arnaldo Carvalho de Melo <acme@redhat.com>
# Licensed under the terms of the GNU GPL License version 2
#
# Translation of:
#
# http://sourceware.org/systemtap/wiki/WSFutexContention
#
# to perf python scripting.
#
# Measures futex contention

import os, sys
sys.path.append(os.environ['PERF_EXEC_PATH'] + '/scripts/python/Perf-Trace-Util/lib/Perf/Trace')
from Util import *

process_names = {}
thread_thislock = {}
thread_blocktime = {}

lock_waits = {} # long-lived stats on (tid,lock) blockage elapsed time
process_names = {} # long-lived pid-to-execname mapping

def syscalls__sys_enter_futex(event, ctxt, cpu, s, ns, tid, comm,
			      nr, uaddr, op, val, utime, uaddr2, val3):
	cmd = op & FUTEX_CMD_MASK
	if cmd != FUTEX_WAIT:
		return # we don't care about originators of WAKE events

	process_names[tid] = comm
	thread_thislock[tid] = uaddr
	thread_blocktime[tid] = nsecs(s, ns)

def syscalls__sys_exit_futex(event, ctxt, cpu, s, ns, tid, comm,
			     nr, ret):
	if thread_blocktime.has_key(tid):
		elapsed = nsecs(s, ns) - thread_blocktime[tid]
		add_stats(lock_waits, (tid, thread_thislock[tid]), elapsed)
		del thread_blocktime[tid]
		del thread_thislock[tid]

def trace_begin():
	print "Press control+C to stop and show the summary"

def trace_end():
	for (tid, lock) in lock_waits:
		min, max, avg, count = lock_waits[tid, lock]
		print "%s[%d] lock %x contended %d times, %d avg ns" % \
		      (process_names[tid], tid, lock, count, avg)
Commit	Line	Data
00204c33 ACM	1	# futex contention
	2	# (c) 2010, Arnaldo Carvalho de Melo <acme@redhat.com>
	3	# Licensed under the terms of the GNU GPL License version 2
	4	#
	5	# Translation of:
	6	#
	7	# http://sourceware.org/systemtap/wiki/WSFutexContention
	8	#
	9	# to perf python scripting.
	10	#
	11	# Measures futex contention
	12
	13	import os, sys
	14	sys.path.append(os.environ['PERF_EXEC_PATH'] + '/scripts/python/Perf-Trace-Util/lib/Perf/Trace')
	15	from Util import *
	16
	17	process_names = {}
	18	thread_thislock = {}
	19	thread_blocktime = {}
	20
	21	lock_waits = {} # long-lived stats on (tid,lock) blockage elapsed time
	22	process_names = {} # long-lived pid-to-execname mapping
	23
	24	def syscalls__sys_enter_futex(event, ctxt, cpu, s, ns, tid, comm,
	25	nr, uaddr, op, val, utime, uaddr2, val3):
	26	cmd = op & FUTEX_CMD_MASK
	27	if cmd != FUTEX_WAIT:
	28	return # we don't care about originators of WAKE events
	29
	30	process_names[tid] = comm
	31	thread_thislock[tid] = uaddr
	32	thread_blocktime[tid] = nsecs(s, ns)
	33
	34	def syscalls__sys_exit_futex(event, ctxt, cpu, s, ns, tid, comm,
	35	nr, ret):
	36	if thread_blocktime.has_key(tid):
	37	elapsed = nsecs(s, ns) - thread_blocktime[tid]
	38	add_stats(lock_waits, (tid, thread_thislock[tid]), elapsed)
	39	del thread_blocktime[tid]
	40	del thread_thislock[tid]
	41
	42	def trace_begin():
	43	print "Press control+C to stop and show the summary"
	44
	45	def trace_end():
	46	for (tid, lock) in lock_waits:
	47	min, max, avg, count = lock_waits[tid, lock]
	48	print "%s[%d] lock %x contended %d times, %d avg ns" % \
	49	(process_names[tid], tid, lock, count, avg)
	50