FM / network

/usr/share/systemtap/examples/network

Name	Size	Mode	Actions
autofs4.meta	397	0644	edit dl rm
autofs4.stp	4167	0755	edit dl rm
connect_stat.meta	404	0644	edit dl rm
connect_stat.stp	1019	0755	edit dl rm
dropwatch.meta	494	0644	edit dl rm
dropwatch.stp	900	0755	edit dl rm
netdev.meta	389	0644	edit dl rm
netdev.stp	1458	0755	edit dl rm
netfilter_drop.meta	630	0644	edit dl rm
netfilter_drop.stp	1156	0755	edit dl rm
netfilter_summary.meta	587	0644	edit dl rm
netfilter_summary.stp	591	0755	edit dl rm
netfilter_summary.txt	2873	0644	edit dl rm
netfilter_summary_json.meta	511	0644	edit dl rm
netfilter_summary_json.stp	1070	0644	edit dl rm
nettop.meta	519	0644	edit dl rm
nettop.stp	989	0755	edit dl rm
nettop.txt	953	0644	edit dl rm
net_xmit_json.meta	453	0644	edit dl rm
net_xmit_json.stp	1801	0644	edit dl rm
nfsd-recent.meta	423	0644	edit dl rm
nfsd-recent.stp	442	0755	edit dl rm
nfsd-trace.meta	314	0644	edit dl rm
nfsd-trace.stp	701	0644	edit dl rm
nfsd-trace.txt	876	0644	edit dl rm
nfsdtop.meta	405	0644	edit dl rm
nfsdtop.stp	3385	0755	edit dl rm
nfsd_unlink.meta	479	0644	edit dl rm
nfsd_unlink.stp	523	0755	edit dl rm
packet_contents.meta	550	0644	edit dl rm
packet_contents.stp	216	0755	edit dl rm
packet_contents.txt	2066	0644	edit dl rm
sk_stream_wait_memory.meta	742	0644	edit dl rm
sk_stream_wait_memory.stp	999	0755	edit dl rm
socket-trace.meta	702	0644	edit dl rm
socket-trace.stp	222	0755	edit dl rm
socktop	9144	0755	edit dl rm
socktop.meta	548	0644	edit dl rm
socktop.txt	4135	0644	edit dl rm
stp_dump.meta	339	0644	edit dl rm
stp_dump.stp	568	0644	edit dl rm
stp_dump.txt	1632	0644	edit dl rm
tcpdumplike.meta	381	0644	edit dl rm
tcpdumplike.stp	581	0755	edit dl rm
tcpipstat.meta	725	0644	edit dl rm
tcpipstat.stp	18247	0755	edit dl rm
tcpipstat.txt	898	0644	edit dl rm
tcp_connections.meta	625	0644	edit dl rm
tcp_connections.stp	361	0755	edit dl rm
tcp_init_cwnd.meta	589	0644	edit dl rm
tcp_init_cwnd.stp	343	0755	edit dl rm
tcp_retransmission.meta	286	0644	edit dl rm
tcp_retransmission.stp	1182	0644	edit dl rm
tcp_trace.meta	684	0644	edit dl rm
tcp_trace.stp	19095	0755	edit dl rm
tcp_trace.txt	3465	0644	edit dl rm
who_sent_it.meta	583	0644	edit dl rm
who_sent_it.stp	477	0644	edit dl rm
who_sent_it.txt	803	0644	edit dl rm

Edit: /usr/share/systemtap/examples/network/net_xmit_json.stp (1801B)

// This script tracks time between packet queue and transmit. The
// information is provided to userspace via procfs in JSON format.

global net_devices

probe json_data
{
  @json_output_data_start

foreach (dev in net_devices) {
    if (@count(skb_queue_t[dev])) {
      @json_output_array_numeric_value("net_xmit_data", dev, "xmit_count",
				       @sum(skb_queue_t[dev]))
      @json_output_array_numeric_value("net_xmit_data", dev, "xmit_latency",
				       @count(skb_queue_t[dev]))
    }
    else {
      @json_output_array_numeric_value("net_xmit_data", dev, "xmit_count", 0)
      @json_output_array_numeric_value("net_xmit_data", dev, "xmit_latency", 0)
    }
  }

@json_output_data_end
}

// Set up the metrics
probe begin
{
  // fallback instance device "eth0" if none specified
  if (argc == 0) {
    argv[1] = "eth0"
    argc = 1
  }
  
  // remember all the network devices
  for (i = 1; i <= argc; i++) {
    dev = argv[i]
    net_devices[dev] = i - 1
  }

// Set the prefix to be used instead of the module name.
  json_set_prefix("net_xmit")

// Add the metrics
  json_add_array("net_xmit_data",
		 "Network transmit data indexed by ethernet device")
  json_add_array_numeric_metric("net_xmit_data", "xmit_count",
				"number of packets for xmit device", "count")
  json_add_array_numeric_metric("net_xmit_data", "xmit_latency",
				"sum of latency for xmit device", "")
}

// probes to track the information

global skb_queue_start_t, skb_queue_t

probe kernel.trace("net_dev_queue") {
  skb_queue_start_t[$skb] = gettimeofday_ns();
}

probe kernel.trace("net_dev_start_xmit") ?, kernel.trace("net_dev_xmit") {
  t = gettimeofday_ns();
  st = skb_queue_start_t[$skb]
  if (st){
    skb_queue_t[kernel_string($dev->name)] <<< t - st
    delete skb_queue_start_t[$skb]
  }
}

// This script tracks time between packet queue and transmit. The // information is provided to userspace via procfs in JSON format. global net_devices probe json_data { @json_output_data_start foreach (dev in net_devices) { if (@count(skb_queue_t[dev])) { @json_output_array_numeric_value("net_xmit_data", dev, "xmit_count", @sum(skb_queue_t[dev])) @json_output_array_numeric_value("net_xmit_data", dev, "xmit_latency", @count(skb_queue_t[dev])) } else { @json_output_array_numeric_value("net_xmit_data", dev, "xmit_count", 0) @json_output_array_numeric_value("net_xmit_data", dev, "xmit_latency", 0) } } @json_output_data_end } // Set up the metrics probe begin { // fallback instance device "eth0" if none specified if (argc == 0) { argv[1] = "eth0" argc = 1 } // remember all the network devices for (i = 1; i <= argc; i++) { dev = argv[i] net_devices[dev] = i - 1 } // Set the prefix to be used instead of the module name. json_set_prefix("net_xmit") // Add the metrics json_add_array("net_xmit_data", "Network transmit data indexed by ethernet device") json_add_array_numeric_metric("net_xmit_data", "xmit_count", "number of packets for xmit device", "count") json_add_array_numeric_metric("net_xmit_data", "xmit_latency", "sum of latency for xmit device", "") } // probes to track the information global skb_queue_start_t, skb_queue_t probe kernel.trace("net_dev_queue") { skb_queue_start_t[$skb] = gettimeofday_ns(); } probe kernel.trace("net_dev_start_xmit") ?, kernel.trace("net_dev_xmit") { t = gettimeofday_ns(); st = skb_queue_start_t[$skb] if (st){ skb_queue_t[kernel_string($dev->name)] <<< t - st delete skb_queue_start_t[$skb] } }