Gecko [ dataharbor.africa ]

Name	Size	Permission
?;tapset	[ DIR ]	drwxr-xr-x
alias_suffixes.meta	724 B	-rw-r--r--
alias_suffixes.stp	1.04 KB	-rwxr-xr-x
also_ran.meta	605 B	-rw-r--r--
also_ran.stp	769 B	-rwxr-xr-x
ansi_colors.meta	406 B	-rw-r--r--
ansi_colors.stp	716 B	-rwxr-xr-x
ansi_colors2.meta	467 B	-rw-r--r--
ansi_colors2.stp	738 B	-rwxr-xr-x
badname.meta	459 B	-rw-r--r--
badname.stp	1.3 KB	-rwxr-xr-x
badname.txt	126 B	-rw-r--r--
callgraph.meta	388 B	-rw-r--r--
callgraph.stp	212 B	-rwxr-xr-x
callgraph.txt	3.61 KB	-rw-r--r--
click.wav	1.26 KB	-rw-r--r--
cpu_throttle.meta	795 B	-rw-r--r--
cpu_throttle.stp	1.45 KB	-rwxr-xr-x
eventcount.meta	637 B	-rw-r--r--
eventcount.stp	6.77 KB	-rwxr-xr-x
eventcount.txt	1.85 KB	-rw-r--r--
func_time_stats.meta	696 B	-rw-r--r--
func_time_stats.stp	520 B	-rwxr-xr-x
func_time_stats.txt	493 B	-rw-r--r--
grapher.stp	1.26 KB	-rwxr-xr-x
graphs.meta	453 B	-rw-r--r--
graphs.stp	1.46 KB	-rwxr-xr-x
helloworld.meta	298 B	-rw-r--r--
helloworld.stp	57 B	-rwxr-xr-x
key.meta	319 B	-rw-r--r--
key.stp	414 B	-rwxr-xr-x
keyhack.meta	355 B	-rw-r--r--
keyhack.stp	288 B	-rwxr-xr-x
measureinterval.meta	1.54 KB	-rw-r--r--
measureinterval.stp	830 B	-rwxr-xr-x
para-callgraph-verbose.meta	879 B	-rw-r--r--
para-callgraph-verbose.stp	407 B	-rwxr-xr-x
para-callgraph.meta	756 B	-rw-r--r--
para-callgraph.stp	405 B	-rwxr-xr-x
para-callgraph.txt	4.31 KB	-rw-r--r--
py2example.meta	489 B	-rw-r--r--
py2example.stp	761 B	-rw-r--r--
py2example.tcl	79 B	-rw-r--r--
py3example.meta	515 B	-rw-r--r--
py3example.stp	761 B	-rw-r--r--
py3example.tcl	79 B	-rw-r--r--
pyexample.py	832 B	-rw-r--r--
pyexample.pyc	1.06 KB	-rw-r--r--
pyexample.pyo	1.06 KB	-rw-r--r--
regex.meta	504 B	-rw-r--r--
regex.stp	491 B	-rwxr-xr-x
return.wav	6.43 KB	-rw-r--r--
sizeof.meta	499 B	-rw-r--r--
sizeof.stp	496 B	-rwxr-xr-x
sizeof.txt	100 B	-rw-r--r--
sizeof_interactive.meta	816 B	-rw-r--r--
sizeof_interactive.stp	572 B	-rw-r--r--
sizeof_interactive.txt	154 B	-rw-r--r--
socket-events.meta	563 B	-rw-r--r--
socket-events.stp	5.28 KB	-rwxr-xr-x
stopwatches.meta	754 B	-rw-r--r--
stopwatches.stp	957 B	-rwxr-xr-x
tcl-funtop.meta	479 B	-rw-r--r--
tcl-funtop.stp	817 B	-rwxr-xr-x
tcl-trace.meta	364 B	-rw-r--r--
tcl-trace.stp	1.01 KB	-rwxr-xr-x
varwatch.meta	583 B	-rw-r--r--
varwatch.stp	635 B	-rwxr-xr-x
varwatch.txt	2.62 KB	-rw-r--r--
watchdog.meta	922 B	-rw-r--r--
watchdog.stp	447 B	-rwxr-xr-x
whythefail.meta	481 B	-rw-r--r--
whythefail.stp	2.22 KB	-rw-r--r--
whythefail.txt	3.7 KB	-rw-r--r--

Code Editor : socket-events.stp

#!/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[$return] = 0
  socketstart[$return] = gettimeofday_us()
  eventname[$return, eventnumber[$return]] = "connect"
  eventend[$return, eventnumber[$return]] = gettimeofday_us()
  lastevent[$return] = "connect"
}

probe syscall.close.return {
  if (!target_set_pid(pid()))
         next
  fd = @entry($fd)
  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]
  }
}

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 = @entry($fd)
  if (socketstart[fd] != 0 && $return > 0) {
         eventbytes[fd, eventnumber[fd]] += $return
	 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 && $return > 0) {
         eventbytes[fd, eventnumber[fd]] += $return
	 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]
  }
}

probe __syscall.recv.return, __syscall.recvfrom.return, __syscall.recvmsg.return {
  if (!target_set_pid(pid()))
	  next
  fd = @entry($fd)
  if (socketstart[fd] != 0 && $return > 0) {
	  eventbytes[fd, eventnumber[fd]] += $return
	  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]
  }
}

probe syscall.write.return, syscall.writev.return {
  if (!target_set_pid(pid()))
	  next
  fd = @entry($fd)
  if (socketstart[fd] != 0 && $return > 0) {
          eventbytes[fd, eventnumber[fd]] += $return
	  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]
  }
}

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

${this.title}

Code Editor : socket-events.stp