nikon/tuned
1
0
Fork 0
Code Activity Actions

jhutar@redhat.com: scomes now watches also forked sub-processes

Browse source 
KNOWN BUG: Scomes ends when main process ends. So if there is some forked process in the background which lasts longer, some part of it will be missed.
This commit is contained in:
Petr Lautrbach 2009-08-27 13:19:40 +02:00
parent b596ac9f1f
commit e5c73033ae
1 changed files with 22 additions and 17 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

39
contrib/scomes Normal file → Executable file
View file

@ -3,12 +3,17 @@
# =================================================================== # ===================================================================
# Do this when we have started # Do this when we have started
global report_period = 0 global report_period = 0
# For watch_forked variable:
# 0 = watch only main thread
# 1 = watch forked with same execname as well
# 2 = watch all forked processes
global watch_forked = 2
probe begin { probe begin {
if ($# == 1) { if ($# == 1) {
report_period = $1 report_period = $1
} }
PIDS[target()] = 1 # initialise list of watched pids
print("Collecting data...\n") print("Collecting data...\n")
printf("... for pid %d - %s\n", target(), pid2execname(target()))
} }
# =================================================================== # ===================================================================
@ -19,7 +24,8 @@ function compute_score() {
} }
function print_status() { function print_status() {
printf("-----------------------------------\n") printf("-----------------------------------\n")
printf("Monitored execname: %s\n", pid2execname(target())) ###target_set_report()
printf("Monitored process: %d (%s)\n", target(), pid2execname(target()))
printf("Number of syscalls: %d\n", syscalls) printf("Number of syscalls: %d\n", syscalls)
printf("Kernel/Userspace ticks: %d/%d (%d)\n", kticks, uticks, kticks+uticks) printf("Kernel/Userspace ticks: %d/%d (%d)\n", kticks, uticks, kticks+uticks)
printf("Read/Written bytes: %d/%d (%d)\n", reads, writes, reads+writes) printf("Read/Written bytes: %d/%d (%d)\n", reads, writes, reads+writes)
@ -32,9 +38,9 @@ function print_status() {
# Define helper function for comparing if this is relevant pid # Define helper function for comparing if this is relevant pid
# and for watching if our watched pid forked # and for watching if our watched pid forked
# ... from http://sourceware.org/systemtap/wiki/systemtapstarters # ... from http://sourceware.org/systemtap/wiki/systemtapstarters
global PIDS global PIDS = 1 # as target() is already running
function is_watched(p) { function is_watched(p) {
if (p == target() || p in PIDS) { if ( (watch_forked == 0 && p == target()) || (watch_forked == 1 && target_set_pid(p) && pid2execname(target()) == pid2execname(p)) || (watch_forked == 2 && target_set_pid(p)) ) {
#printf("Process %d is relevant to process %d\n", p, target()) #printf("Process %d is relevant to process %d\n", p, target())
return 1 # yes, we are watching this pid return 1 # yes, we are watching this pid
} else { } else {
@ -43,26 +49,22 @@ function is_watched(p) {
} }
# Add a relevant forked process to the list of watched processes # Add a relevant forked process to the list of watched processes
probe kernel.function("do_fork") { probe kernel.function("do_fork") {
if (is_watched(ppid()) && pexecname() == execname()) { # we do not care about forked processes with different name (e.g. when cron lunches something) #printf("Fork of %d (%s) detected\n", pid(), execname())
#printf("Proces forked with %d(%d)->%d as %s->%s - adding\n", ppid(), target(), pid(), pexecname(), execname()) if (is_watched(pid())) {
PIDS[pid()] = 1 #printf("Proces %d forked\n", pid())
#foreach (p in PIDS) { PIDS = PIDS + 1
# println(p, PIDS[p]) #printf("Currently watching %d pids (1 just added)\n", PIDS)
#}
} }
} }
# Remove pid from the list of watched pids and print report when # Remove pid from the list of watched pids and print report when
# all relevant processes ends # all relevant processes ends
probe syscall.exit { probe syscall.exit {
if (pid() in PIDS) { if (is_watched(pid())) {
#printf("Removing process %d\n", pid()) #printf("Removing process %d\n", pid())
delete PIDS[pid()] PIDS = PIDS - 1
} }
count = 0 #printf("Currently watching %d pids (1 just removed)\n", PIDS)
foreach (p in PIDS) { if (PIDS == 0) {
count++
}
if (count == 0) {
printf("-----------------------------------\n") printf("-----------------------------------\n")
printf("LAST RESULTS:\n") printf("LAST RESULTS:\n")
print_status() print_status()
@ -187,6 +189,9 @@ probe timer.s(1) {
# =================================================================== # ===================================================================
# Print quit message # Print quit message
probe end { probe end {
printf("-----------------------------------\n")
printf("LAST RESULTS:\n")
print_status()
printf("-----------------------------------\n") printf("-----------------------------------\n")
printf("QUITTING\n") printf("QUITTING\n")
printf("-----------------------------------\n") printf("-----------------------------------\n")