FM / general

/usr/share/systemtap/examples/general

Name	Size	Mode	Actions
alias_suffixes.meta	724	0644	edit dl rm
alias_suffixes.stp	1060	0755	edit dl rm
also_ran.meta	605	0644	edit dl rm
also_ran.stp	804	0755	edit dl rm
ansi_colors.meta	507	0644	edit dl rm
ansi_colors.stp	716	0755	edit dl rm
ansi_colors2.meta	570	0644	edit dl rm
ansi_colors2.stp	738	0755	edit dl rm
badname.meta	459	0644	edit dl rm
badname.stp	1335	0755	edit dl rm
badname.txt	126	0644	edit dl rm
callgraph.meta	388	0644	edit dl rm
callgraph.stp	212	0755	edit dl rm
callgraph.txt	3700	0644	edit dl rm
click.wav	1290	0644	edit dl rm
cpu_throttle.meta	795	0644	edit dl rm
cpu_throttle.stp	1481	0755	edit dl rm
eventcount.meta	637	0644	edit dl rm
eventcount.stp	6931	0755	edit dl rm
eventcount.txt	1898	0644	edit dl rm
floatingpoint.meta	479	0644	edit dl rm
floatingpoint.stp	517	0644	edit dl rm
floatingpoint.txt	156	0644	edit dl rm
func_time_stats.meta	696	0644	edit dl rm
func_time_stats.stp	520	0755	edit dl rm
func_time_stats.txt	493	0644	edit dl rm
grapher.stp	1286	0755	edit dl rm
graphs.meta	453	0644	edit dl rm
graphs.stp	1499	0755	edit dl rm
helloworld.meta	397	0644	edit dl rm
helloworld.stp	57	0755	edit dl rm
key.meta	319	0644	edit dl rm
key.stp	414	0755	edit dl rm
keyhack.meta	355	0644	edit dl rm
keyhack.stp	288	0755	edit dl rm
measureinterval.meta	1582	0644	edit dl rm
measureinterval.stp	830	0755	edit dl rm
para-callgraph-verbose.meta	879	0644	edit dl rm
para-callgraph-verbose.stp	407	0755	edit dl rm
para-callgraph.meta	756	0644	edit dl rm
para-callgraph.stp	405	0755	edit dl rm
para-callgraph.txt	4415	0644	edit dl rm
py2example.meta	531	0644	edit dl rm
py2example.tcl	79	0644	edit dl rm
py3example.meta	532	0644	edit dl rm
py3example.tcl	79	0644	edit dl rm
pyexample.py	832	0644	edit dl rm
pyexample.stp	216	0644	edit dl rm
regex.meta	504	0644	edit dl rm
regex.stp	491	0755	edit dl rm
return.wav	6584	0644	edit dl rm
sizeof.meta	664	0644	edit dl rm
sizeof.stp	482	0755	edit dl rm
sizeof.txt	100	0644	edit dl rm
sizeof_interactive.meta	816	0644	edit dl rm
sizeof_interactive.stp	572	0644	edit dl rm
sizeof_interactive.txt	154	0644	edit dl rm
socket-events.meta	563	0644	edit dl rm
socket-events.stp	5451	0755	edit dl rm
stopwatches.meta	860	0644	edit dl rm
stopwatches.stp	957	0755	edit dl rm
tcl-funtop.meta	479	0644	edit dl rm
tcl-funtop.stp	817	0755	edit dl rm
tcl-trace.meta	364	0644	edit dl rm
tcl-trace.stp	1037	0755	edit dl rm
varwatch.meta	583	0644	edit dl rm
varwatch.stp	459	0755	edit dl rm
varwatch.txt	2678	0644	edit dl rm
watchdog.meta	922	0644	edit dl rm
watchdog.stp	447	0755	edit dl rm
whythefail.meta	481	0644	edit dl rm
whythefail.stp	2277	0644	edit dl rm
whythefail.txt	3790	0644	edit dl rm

Edit: /usr/share/systemtap/examples/general/socket-events.stp (5451B)

#!/usr/bin/stap

global socketstart, lastevent, sendtofd
global eventnumber, eventname, eventstart, eventend, eventbytes, eventlength
global writestart, readstart, sendstart, recvstart

probe begin {
  if (target() == 0) {
        println("No PID specified.  Use -c or -x.  See man stap for more information.")
        exit()
  }
}

function printshorthistory (fd:long) {
  if (eventnumber[fd] < 1 || eventnumber[fd] % 2 && eventnumber[fd] != 1)
	  return
  wait1 = eventstart[fd, eventnumber[fd] - 1] - eventend[fd, eventnumber[fd] - 2]
  wait2 = eventstart[fd, eventnumber[fd]] - eventend[fd, eventnumber[fd] - 1]
  name1 = eventname[fd, eventnumber[fd] - 1]
  name2 = eventname[fd, eventnumber[fd]]
  length1 = eventlength[fd, eventnumber[fd] - 1]
  length2 = eventlength[fd, eventnumber[fd]]
  bytes1 = eventbytes[fd, eventnumber[fd] -1]
  bytes2 = eventbytes[fd, eventnumber[fd]]
  if (eventnumber[fd] == 1)
       printf("Socket %d connect, wait %d us, %s %d bytes in %d us\n", fd, wait2, name2, bytes2, length2)
  else {
       printf("Socket %d wait %d us, ", fd, wait1)
       printf("%s %d bytes in %d us, wait %d us, ", name1, bytes1, length1, wait2)
       printf("%s %d bytes in %d us\n", name2, bytes2, length2)
  }
}

probe syscall.socket.return {
  if (!target_set_pid(pid()))
         next
  eventnumber[retval] = 0
  socketstart[retval] = gettimeofday_us()
  eventname[retval, eventnumber[retval]] = "connect"
  eventend[retval, eventnumber[retval]] = gettimeofday_us()
  lastevent[retval] = "connect"
}

probe syscall.close {
  @this1 = fd
}

probe syscall.close.return {
  if (!target_set_pid(pid()))
         next
  fd = @this1
  if (socketstart[fd] != 0 && eventnumber[fd] >= 1)
         printf("Socket %d close\n", fd)
  delete socketstart[fd]
}

probe syscall.send, syscall.sendmsg {
  if (!target_set_pid(pid()))
         next
  if (socketstart[s] != 0 && sendstart[s] == 0) {
	  sendstart[s] = gettimeofday_us()
	  if (lastevent[s] == "send")
	        next
	  printshorthistory(s)
	  eventname[s, ++eventnumber[s]] = "send"
          eventstart[s, eventnumber[s]] = sendstart[s]
  }
  @this2 = s
}

probe syscall.sendto {
  if (!target_set_pid(pid()))
         next
  if (socketstart[s] !=0 && sendstart[s] == 0) {
	 sendstart[s] = gettimeofday_us()
         sendtofd[tid()] = s
	 if (lastevent[s] == "send")
	       next
         printshorthistory(s)
	 eventname[s, ++eventnumber[s]] = "send"
	 eventstart[s, eventnumber[s]] = sendstart[s]
  }
}

probe syscall.send.return, syscall.sendmsg.return {
  if (!target_set_pid(pid()))
         next
  fd = @this2
  if (socketstart[fd] != 0 && retval > 0) {
         eventbytes[fd, eventnumber[fd]] += retval
	 eventlength[fd, eventnumber[fd]] += gettimeofday_us() - sendstart[fd]
	 eventend[fd, eventnumber[fd]] = gettimeofday_us()
  }
  sendstart[fd] = 0
  lastevent[fd] = "send"
}

probe syscall.sendto.return {
  if (!target_set_pid(pid()))
         next
  fd = sendtofd[tid()]
  if (socketstart[fd] != 0 && retval > 0) {
         eventbytes[fd, eventnumber[fd]] += retval
	 eventlength[fd, eventnumber[fd]] += gettimeofday_us() - sendstart[fd]
	 eventend[fd, eventnumber[fd]] = gettimeofday_us()
  }
  sendstart[fd] = 0
  lastevent[fd] = "send"
}

probe syscall.recv, syscall.recvfrom, syscall.recvmsg {
  if (!target_set_pid(pid()))
	  next
  if (socketstart[s] != 0 && recvstart[s] == 0) {
	  recvstart[s] = gettimeofday_us()
          if (lastevent[s] == "recv")
		  next
	  printshorthistory(s)
	  eventname[s, ++eventnumber[s]] = "recv"
	  eventstart[s, eventnumber[s]] = recvstart[s]
  }
  @this3 = s
}

probe syscall.recv.return, syscall.recvfrom.return, syscall.recvmsg.return {
  if (!target_set_pid(pid()))
	  next
  fd = @this3
  if (socketstart[fd] != 0 && retval > 0) {
	  eventbytes[fd, eventnumber[fd]] += retval
	  eventlength[fd, eventnumber[fd]] += gettimeofday_us() - recvstart[fd]
	  eventend[fd, eventnumber[fd]] = gettimeofday_us()
  }
  recvstart[fd] = 0
  lastevent[fd] = "recv"
}

probe syscall.write, syscall.writev {
  if (!target_set_pid(pid()))
	  next
  if (socketstart[fd] != 0 && writestart[fd] == 0) {
          writestart[fd]  = gettimeofday_us()
	  if (lastevent[fd] == "write")
		  next
	  printshorthistory(fd)
	  eventname[fd, ++eventnumber[fd]] = "write"
	  eventstart[fd, eventnumber[fd]] = writestart[fd]
  }
  @this4 = fd
}

probe syscall.write.return, syscall.writev.return {
  if (!target_set_pid(pid()))
	  next
  fd = @this4
  if (socketstart[fd] != 0 && retval > 0) {
          eventbytes[fd, eventnumber[fd]] += retval
	  eventlength[fd, eventnumber[fd]] += gettimeofday_us() - writestart[fd]
	  eventend[fd, eventnumber[fd]] = gettimeofday_us()
  }
  writestart[fd] = 0
  lastevent[fd] = "write"
}

probe syscall.read, syscall.readv {
  if (!target_set_pid(pid()))
	  next
  if (socketstart[fd] != 0 && readstart[fd] == 0) {
          readstart[fd] = gettimeofday_us()
	  if (lastevent[fd] == "read")
		  next
	  printshorthistory(fd)
	  eventname[fd, ++eventnumber[fd]] = "read"
	  eventstart[fd, eventnumber[fd]] = readstart[fd]
  }
  @this5 = fd
}

probe syscall.read.return, syscall.readv.return {
  if (!target_set_pid(pid()))
	  next
  fd = @this5
  if (socketstart[fd] != 0 && retval > 0) {
          eventbytes[fd, eventnumber[fd]] += retval
	  eventlength[fd, eventnumber[fd]] += gettimeofday_us() - readstart[fd]
	  eventend[fd, eventnumber[fd]] = gettimeofday_us()
  }
  readstart[fd] = 0
  lastevent[fd] = "read"
}

#!/usr/bin/stap global socketstart, lastevent, sendtofd global eventnumber, eventname, eventstart, eventend, eventbytes, eventlength global writestart, readstart, sendstart, recvstart probe begin { if (target() == 0) { println("No PID specified. Use -c or -x. See man stap for more information.") exit() } } function printshorthistory (fd:long) { if (eventnumber[fd] < 1 || eventnumber[fd] % 2 && eventnumber[fd] != 1) return wait1 = eventstart[fd, eventnumber[fd] - 1] - eventend[fd, eventnumber[fd] - 2] wait2 = eventstart[fd, eventnumber[fd]] - eventend[fd, eventnumber[fd] - 1] name1 = eventname[fd, eventnumber[fd] - 1] name2 = eventname[fd, eventnumber[fd]] length1 = eventlength[fd, eventnumber[fd] - 1] length2 = eventlength[fd, eventnumber[fd]] bytes1 = eventbytes[fd, eventnumber[fd] -1] bytes2 = eventbytes[fd, eventnumber[fd]] if (eventnumber[fd] == 1) printf("Socket %d connect, wait %d us, %s %d bytes in %d us\n", fd, wait2, name2, bytes2, length2) else { printf("Socket %d wait %d us, ", fd, wait1) printf("%s %d bytes in %d us, wait %d us, ", name1, bytes1, length1, wait2) printf("%s %d bytes in %d us\n", name2, bytes2, length2) } } probe syscall.socket.return { if (!target_set_pid(pid())) next eventnumber[retval] = 0 socketstart[retval] = gettimeofday_us() eventname[retval, eventnumber[retval]] = "connect" eventend[retval, eventnumber[retval]] = gettimeofday_us() lastevent[retval] = "connect" } probe syscall.close { @this1 = fd } probe syscall.close.return { if (!target_set_pid(pid())) next fd = @this1 if (socketstart[fd] != 0 && eventnumber[fd] >= 1) printf("Socket %d close\n", fd) delete socketstart[fd] } probe syscall.send, syscall.sendmsg { if (!target_set_pid(pid())) next if (socketstart[s] != 0 && sendstart[s] == 0) { sendstart[s] = gettimeofday_us() if (lastevent[s] == "send") next printshorthistory(s) eventname[s, ++eventnumber[s]] = "send" eventstart[s, eventnumber[s]] = sendstart[s] } @this2 = s } probe syscall.sendto { if (!target_set_pid(pid())) next if (socketstart[s] !=0 && sendstart[s] == 0) { sendstart[s] = gettimeofday_us() sendtofd[tid()] = s if (lastevent[s] == "send") next printshorthistory(s) eventname[s, ++eventnumber[s]] = "send" eventstart[s, eventnumber[s]] = sendstart[s] } } probe syscall.send.return, syscall.sendmsg.return { if (!target_set_pid(pid())) next fd = @this2 if (socketstart[fd] != 0 && retval > 0) { eventbytes[fd, eventnumber[fd]] += retval eventlength[fd, eventnumber[fd]] += gettimeofday_us() - sendstart[fd] eventend[fd, eventnumber[fd]] = gettimeofday_us() } sendstart[fd] = 0 lastevent[fd] = "send" } probe syscall.sendto.return { if (!target_set_pid(pid())) next fd = sendtofd[tid()] if (socketstart[fd] != 0 && retval > 0) { eventbytes[fd, eventnumber[fd]] += retval eventlength[fd, eventnumber[fd]] += gettimeofday_us() - sendstart[fd] eventend[fd, eventnumber[fd]] = gettimeofday_us() } sendstart[fd] = 0 lastevent[fd] = "send" } probe syscall.recv, syscall.recvfrom, syscall.recvmsg { if (!target_set_pid(pid())) next if (socketstart[s] != 0 && recvstart[s] == 0) { recvstart[s] = gettimeofday_us() if (lastevent[s] == "recv") next printshorthistory(s) eventname[s, ++eventnumber[s]] = "recv" eventstart[s, eventnumber[s]] = recvstart[s] } @this3 = s } probe syscall.recv.return, syscall.recvfrom.return, syscall.recvmsg.return { if (!target_set_pid(pid())) next fd = @this3 if (socketstart[fd] != 0 && retval > 0) { eventbytes[fd, eventnumber[fd]] += retval eventlength[fd, eventnumber[fd]] += gettimeofday_us() - recvstart[fd] eventend[fd, eventnumber[fd]] = gettimeofday_us() } recvstart[fd] = 0 lastevent[fd] = "recv" } probe syscall.write, syscall.writev { if (!target_set_pid(pid())) next if (socketstart[fd] != 0 && writestart[fd] == 0) { writestart[fd] = gettimeofday_us() if (lastevent[fd] == "write") next printshorthistory(fd) eventname[fd, ++eventnumber[fd]] = "write" eventstart[fd, eventnumber[fd]] = writestart[fd] } @this4 = fd } probe syscall.write.return, syscall.writev.return { if (!target_set_pid(pid())) next fd = @this4 if (socketstart[fd] != 0 && retval > 0) { eventbytes[fd, eventnumber[fd]] += retval eventlength[fd, eventnumber[fd]] += gettimeofday_us() - writestart[fd] eventend[fd, eventnumber[fd]] = gettimeofday_us() } writestart[fd] = 0 lastevent[fd] = "write" } probe syscall.read, syscall.readv { if (!target_set_pid(pid())) next if (socketstart[fd] != 0 && readstart[fd] == 0) { readstart[fd] = gettimeofday_us() if (lastevent[fd] == "read") next printshorthistory(fd) eventname[fd, ++eventnumber[fd]] = "read" eventstart[fd, eventnumber[fd]] = readstart[fd] } @this5 = fd } probe syscall.read.return, syscall.readv.return { if (!target_set_pid(pid())) next fd = @this5 if (socketstart[fd] != 0 && retval > 0) { eventbytes[fd, eventnumber[fd]] += retval eventlength[fd, eventnumber[fd]] += gettimeofday_us() - readstart[fd] eventend[fd, eventnumber[fd]] = gettimeofday_us() } readstart[fd] = 0 lastevent[fd] = "read" }