summaryrefslogtreecommitdiffstats
path: root/testsuite/systemtap.samples/tcp_connections.stp
blob: a4449b606e5cc623df565b76f2542d1b9504b90d (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
#! stap

%{
#include <linux/version.h>
#include <net/sock.h>
#include <net/tcp.h>

#if LINUX_VERSION_CODE < KERNEL_VERSION(2,6,11) 
#define LPORT	(inet->inet.num)
#define DADDR	(&inet->inet.daddr)
#else 
#define LPORT 	(inet->num)
#define DADDR	(&inet->daddr)
#endif
%}

function get_local_port:long(sock) 
%{
	unsigned long ptr = (unsigned long) THIS->sock;

	struct inet_sock *inet = (struct inet_sock *) ptr;
	THIS->__retvalue = (long long) LPORT;
%}

function get_ip_source:string(sock)
%{
	unsigned long ptr = (unsigned long) THIS->sock;
	struct inet_sock *inet = (struct inet_sock *) ptr;
	unsigned char addr[4];
	memcpy(addr, DADDR, sizeof(addr));
	sprintf(THIS->__retvalue, "%d.%d.%d.%d", 
		addr[0], addr[1],  addr[2], addr[3]); 

%}


probe begin {
	log ("UID\tCMD\t\tPID\t\tPORT\tIP_SOURCE")
}

probe kernel.function("tcp_accept").return {
	sock = $return
	if (sock != 0)
		log(sprint(uid())."\t".
			execname()."\t\t".
			sprint(pid())."\t\t ".
			sprint(get_local_port(sock))."\t".
 			get_ip_source(sock))
}