2 * netsniff-ng - the packet sniffing beast
3 * Copyright 2011 - 2013 Daniel Borkmann.
4 * Copyright 2011 Emmanuel Roullit.
5 * Subject to the GPL, version 2.
18 #include <netinet/in.h>
22 #include <sys/fsuid.h>
31 #include "conntrack.h"
45 uint32_t flow_id
, use
, status
;
46 uint8_t l3_proto
, l4_proto
;
47 uint32_t ip4_src_addr
, ip4_dst_addr
;
48 uint32_t ip6_src_addr
[4], ip6_dst_addr
[4];
49 uint16_t port_src
, port_dst
;
50 uint8_t tcp_state
, tcp_flags
, sctp_state
, dccp_state
;
51 uint64_t src_pkts
, src_bytes
;
52 uint64_t dst_pkts
, dst_bytes
;
53 uint64_t timestamp_start
, timestamp_stop
;
54 char country_src
[128], country_dst
[128];
55 char city_src
[128], city_dst
[128];
56 char rev_dns_src
[256], rev_dns_dst
[256];
58 struct flow_entry
*next
;
62 struct nf_conntrack
*ct
;
66 struct flow_entry
*head
;
70 #ifndef ATTR_TIMESTAMP_START
71 # define ATTR_TIMESTAMP_START 63
73 #ifndef ATTR_TIMESTAMP_STOP
74 # define ATTR_TIMESTAMP_STOP 64
77 #define SCROLL_MAX 1000
79 #define INCLUDE_IPV4 (1 << 0)
80 #define INCLUDE_IPV6 (1 << 1)
81 #define INCLUDE_UDP (1 << 2)
82 #define INCLUDE_TCP (1 << 3)
83 #define INCLUDE_DCCP (1 << 4)
84 #define INCLUDE_ICMP (1 << 5)
85 #define INCLUDE_SCTP (1 << 6)
87 static volatile bool is_flow_collecting
;
88 static volatile sig_atomic_t sigint
= 0;
89 static int what
= INCLUDE_IPV4
| INCLUDE_IPV6
| INCLUDE_TCP
, show_src
= 0;
90 static struct flow_list flow_list
;
91 static int nfct_acct_val
= -1;
93 static const char *short_options
= "vhTUsDIS46u";
94 static const struct option long_options
[] = {
95 {"ipv4", no_argument
, NULL
, '4'},
96 {"ipv6", no_argument
, NULL
, '6'},
97 {"tcp", no_argument
, NULL
, 'T'},
98 {"udp", no_argument
, NULL
, 'U'},
99 {"dccp", no_argument
, NULL
, 'D'},
100 {"icmp", no_argument
, NULL
, 'I'},
101 {"sctp", no_argument
, NULL
, 'S'},
102 {"show-src", no_argument
, NULL
, 's'},
103 {"update", no_argument
, NULL
, 'u'},
104 {"version", no_argument
, NULL
, 'v'},
105 {"help", no_argument
, NULL
, 'h'},
109 static const char *copyright
= "Please report bugs to <bugs@netsniff-ng.org>\n"
110 "Copyright (C) 2011-2013 Daniel Borkmann <dborkma@tik.ee.ethz.ch>\n"
111 "Copyright (C) 2011-2012 Emmanuel Roullit <emmanuel.roullit@gmail.com>\n"
112 "Swiss federal institute of technology (ETH Zurich)\n"
113 "License: GNU GPL version 2.0\n"
114 "This is free software: you are free to change and redistribute it.\n"
115 "There is NO WARRANTY, to the extent permitted by law.";
117 static const char *const l3proto2str
[AF_MAX
] = {
122 static const char *const l4proto2str
[IPPROTO_MAX
] = {
123 [IPPROTO_TCP
] = "tcp",
124 [IPPROTO_UDP
] = "udp",
125 [IPPROTO_UDPLITE
] = "udplite",
126 [IPPROTO_ICMP
] = "icmp",
127 [IPPROTO_ICMPV6
] = "icmpv6",
128 [IPPROTO_SCTP
] = "sctp",
129 [IPPROTO_GRE
] = "gre",
130 [IPPROTO_DCCP
] = "dccp",
131 [IPPROTO_IGMP
] = "igmp",
132 [IPPROTO_IPIP
] = "ipip",
133 [IPPROTO_EGP
] = "egp",
134 [IPPROTO_PUP
] = "pup",
135 [IPPROTO_IDP
] = "idp",
136 [IPPROTO_RSVP
] = "rsvp",
137 [IPPROTO_IPV6
] = "ip6tun",
138 [IPPROTO_ESP
] = "esp",
140 [IPPROTO_PIM
] = "pim",
141 [IPPROTO_COMP
] = "comp",
144 static const char *const tcp_state2str
[TCP_CONNTRACK_MAX
] = {
145 [TCP_CONNTRACK_NONE
] = "NOSTATE",
146 [TCP_CONNTRACK_SYN_SENT
] = "SYN_SENT",
147 [TCP_CONNTRACK_SYN_RECV
] = "SYN_RECV",
148 [TCP_CONNTRACK_ESTABLISHED
] = "ESTABLISHED",
149 [TCP_CONNTRACK_FIN_WAIT
] = "FIN_WAIT",
150 [TCP_CONNTRACK_CLOSE_WAIT
] = "CLOSE_WAIT",
151 [TCP_CONNTRACK_LAST_ACK
] = "LAST_ACK",
152 [TCP_CONNTRACK_TIME_WAIT
] = "TIME_WAIT",
153 [TCP_CONNTRACK_CLOSE
] = "CLOSE",
154 [TCP_CONNTRACK_SYN_SENT2
] = "SYN_SENT2",
157 static const char *const dccp_state2str
[DCCP_CONNTRACK_MAX
] = {
158 [DCCP_CONNTRACK_NONE
] = "NOSTATE",
159 [DCCP_CONNTRACK_REQUEST
] = "REQUEST",
160 [DCCP_CONNTRACK_RESPOND
] = "RESPOND",
161 [DCCP_CONNTRACK_PARTOPEN
] = "PARTOPEN",
162 [DCCP_CONNTRACK_OPEN
] = "OPEN",
163 [DCCP_CONNTRACK_CLOSEREQ
] = "CLOSEREQ",
164 [DCCP_CONNTRACK_CLOSING
] = "CLOSING",
165 [DCCP_CONNTRACK_TIMEWAIT
] = "TIMEWAIT",
166 [DCCP_CONNTRACK_IGNORE
] = "IGNORE",
167 [DCCP_CONNTRACK_INVALID
] = "INVALID",
170 static const char *const sctp_state2str
[SCTP_CONNTRACK_MAX
] = {
171 [SCTP_CONNTRACK_NONE
] = "NOSTATE",
172 [SCTP_CONNTRACK_CLOSED
] = "CLOSED",
173 [SCTP_CONNTRACK_COOKIE_WAIT
] = "COOKIE_WAIT",
174 [SCTP_CONNTRACK_COOKIE_ECHOED
] = "COOKIE_ECHOED",
175 [SCTP_CONNTRACK_ESTABLISHED
] = "ESTABLISHED",
176 [SCTP_CONNTRACK_SHUTDOWN_SENT
] = "SHUTDOWN_SENT",
177 [SCTP_CONNTRACK_SHUTDOWN_RECD
] = "SHUTDOWN_RECD",
178 [SCTP_CONNTRACK_SHUTDOWN_ACK_SENT
] = "SHUTDOWN_ACK_SENT",
181 static const struct nfct_filter_ipv4 filter_ipv4
= {
182 .addr
= __constant_htonl(INADDR_LOOPBACK
),
186 static const struct nfct_filter_ipv6 filter_ipv6
= {
187 .addr
= { 0x0, 0x0, 0x0, 0x1 },
188 .mask
= { 0xffffffff, 0xffffffff, 0xffffffff, 0xffffffff },
191 static void signal_handler(int number
)
205 static void flow_entry_from_ct(struct flow_entry
*n
, struct nf_conntrack
*ct
);
206 static void flow_entry_get_extended(struct flow_entry
*n
);
208 static void help(void)
210 printf("flowtop %s, top-like netfilter TCP/UDP/SCTP/.. flow tracking\n",
212 puts("http://www.netsniff-ng.org\n\n"
213 "Usage: flowtop [options]\n"
215 " -4|--ipv4 Show only IPv4 flows (default)\n"
216 " -6|--ipv6 Show only IPv6 flows (default)\n"
217 " -T|--tcp Show only TCP flows (default)\n"
218 " -U|--udp Show only UDP flows\n"
219 " -D|--dccp Show only DCCP flows\n"
220 " -I|--icmp Show only ICMP/ICMPv6 flows\n"
221 " -S|--sctp Show only SCTP flows\n"
222 " -s|--show-src Also show source, not only dest\n"
223 " -u|--update Update GeoIP databases\n"
224 " -v|--version Print version and exit\n"
225 " -h|--help Print this help and exit\n\n"
228 " flowtop -46UTDISs\n\n"
230 " If netfilter is not running, you can activate it with e.g.:\n"
231 " iptables -A INPUT -p tcp -m state --state ESTABLISHED -j ACCEPT\n"
232 " iptables -A OUTPUT -p tcp -m state --state NEW,ESTABLISHED -j ACCEPT\n");
237 static void version(void)
239 printf("flowtop %s, Git id: %s\n", VERSION_LONG
, GITVERSION
);
240 puts("top-like netfilter TCP/UDP/SCTP/.. flow tracking\n"
241 "http://www.netsniff-ng.org\n");
246 static inline struct flow_entry
*flow_entry_xalloc(void)
248 return xzmalloc(sizeof(struct flow_entry
));
251 static inline void flow_entry_xfree(struct flow_entry
*n
)
259 static inline void flow_list_init(struct flow_list
*fl
)
262 spinlock_init(&fl
->lock
);
265 static void flow_list_new_entry(struct flow_list
*fl
, struct nf_conntrack
*ct
)
267 struct flow_entry
*n
= flow_entry_xalloc();
269 n
->ct
= nfct_clone(ct
);
271 flow_entry_from_ct(n
, ct
);
272 flow_entry_get_extended(n
);
274 rcu_assign_pointer(n
->next
, fl
->head
);
275 rcu_assign_pointer(fl
->head
, n
);
278 static struct flow_entry
*flow_list_find_id(struct flow_list
*fl
,
281 struct flow_entry
*n
= rcu_dereference(fl
->head
);
284 if (n
->flow_id
== id
)
287 n
= rcu_dereference(n
->next
);
293 static struct flow_entry
*flow_list_find_prev_id(struct flow_list
*fl
,
296 struct flow_entry
*prev
= rcu_dereference(fl
->head
), *next
;
298 if (prev
->flow_id
== id
)
301 while ((next
= rcu_dereference(prev
->next
)) != NULL
) {
302 if (next
->flow_id
== id
)
311 static void flow_list_update_entry(struct flow_list
*fl
,
312 struct nf_conntrack
*ct
)
314 struct flow_entry
*n
;
316 n
= flow_list_find_id(fl
, nfct_get_attr_u32(ct
, ATTR_ID
));
318 flow_list_new_entry(fl
, ct
);
322 flow_entry_from_ct(n
, ct
);
325 static void flow_list_destroy_entry(struct flow_list
*fl
,
326 struct nf_conntrack
*ct
)
328 struct flow_entry
*n1
, *n2
;
329 uint32_t id
= nfct_get_attr_u32(ct
, ATTR_ID
);
331 n1
= flow_list_find_id(fl
, id
);
333 n2
= flow_list_find_prev_id(fl
, id
);
335 rcu_assign_pointer(n2
->next
, n1
->next
);
338 flow_entry_xfree(n1
);
340 struct flow_entry
*next
= fl
->head
->next
;
342 flow_entry_xfree(fl
->head
);
348 static void flow_list_destroy(struct flow_list
*fl
)
350 struct flow_entry
*n
;
352 while (fl
->head
!= NULL
) {
353 n
= rcu_dereference(fl
->head
->next
);
354 fl
->head
->next
= NULL
;
356 flow_entry_xfree(fl
->head
);
357 rcu_assign_pointer(fl
->head
, n
);
361 spinlock_destroy(&fl
->lock
);
364 static int walk_process(unsigned int pid
, struct flow_entry
*n
)
371 if (snprintf(path
, sizeof(path
), "/proc/%u/fd", pid
) == -1)
372 panic("giant process name! %u\n", pid
);
378 while ((ent
= readdir(dir
))) {
381 if (snprintf(path
, sizeof(path
), "/proc/%u/fd/%s",
382 pid
, ent
->d_name
) < 0)
385 if (stat(path
, &statbuf
) < 0)
388 if (S_ISSOCK(statbuf
.st_mode
) && (ino_t
) n
->inode
== statbuf
.st_ino
) {
389 ret
= proc_get_cmdline(pid
, n
->cmdline
, sizeof(n
->cmdline
));
391 panic("Failed to get process cmdline: %s\n", strerror(errno
));
403 static void walk_processes(struct flow_entry
*n
)
409 /* n->inode must be set */
411 n
->cmdline
[0] = '\0';
415 dir
= opendir("/proc");
417 panic("Cannot open /proc: %s\n", strerror(errno
));
419 while ((ent
= readdir(dir
))) {
420 const char *name
= ent
->d_name
;
422 unsigned int pid
= strtoul(name
, &end
, 10);
425 if (pid
== 0 && end
== name
)
428 ret
= walk_process(pid
, n
);
436 static int get_port_inode(uint16_t port
, int proto
, bool is_ip6
)
439 char path
[128], buff
[1024];
442 memset(path
, 0, sizeof(path
));
443 snprintf(path
, sizeof(path
), "/proc/net/%s%s",
444 l4proto2str
[proto
], is_ip6
? "6" : "");
446 proc
= fopen(path
, "r");
450 memset(buff
, 0, sizeof(buff
));
452 while (fgets(buff
, sizeof(buff
), proc
) != NULL
) {
454 unsigned int lport
= 0;
456 buff
[sizeof(buff
) - 1] = 0;
457 if (sscanf(buff
, "%*u: %*X:%X %*X:%*X %*X %*X:%*X %*X:%*X "
458 "%*X %*u %*u %u", &lport
, &inode
) == 2) {
459 if ((uint16_t) lport
== port
) {
465 memset(buff
, 0, sizeof(buff
));
472 #define CP_NFCT(elem, attr, x) \
473 do { n->elem = nfct_get_attr_u##x(ct,(attr)); } while (0)
474 #define CP_NFCT_BUFF(elem, attr) do { \
475 const uint8_t *buff = nfct_get_attr(ct,(attr)); \
477 memcpy(n->elem, buff, sizeof(n->elem)); \
480 static void flow_entry_from_ct(struct flow_entry
*n
, struct nf_conntrack
*ct
)
482 CP_NFCT(l3_proto
, ATTR_ORIG_L3PROTO
, 8);
483 CP_NFCT(l4_proto
, ATTR_ORIG_L4PROTO
, 8);
485 CP_NFCT(ip4_src_addr
, ATTR_ORIG_IPV4_SRC
, 32);
486 CP_NFCT(ip4_dst_addr
, ATTR_ORIG_IPV4_DST
, 32);
488 CP_NFCT(port_src
, ATTR_ORIG_PORT_SRC
, 16);
489 CP_NFCT(port_dst
, ATTR_ORIG_PORT_DST
, 16);
491 CP_NFCT(status
, ATTR_STATUS
, 32);
493 CP_NFCT(tcp_state
, ATTR_TCP_STATE
, 8);
494 CP_NFCT(tcp_flags
, ATTR_TCP_FLAGS_ORIG
, 8);
495 CP_NFCT(sctp_state
, ATTR_SCTP_STATE
, 8);
496 CP_NFCT(dccp_state
, ATTR_DCCP_STATE
, 8);
498 CP_NFCT(src_pkts
, ATTR_ORIG_COUNTER_PACKETS
, 64);
499 CP_NFCT(src_bytes
, ATTR_ORIG_COUNTER_BYTES
, 64);
501 CP_NFCT(dst_pkts
, ATTR_REPL_COUNTER_PACKETS
, 64);
502 CP_NFCT(dst_bytes
, ATTR_REPL_COUNTER_BYTES
, 64);
504 CP_NFCT(timestamp_start
, ATTR_TIMESTAMP_START
, 64);
505 CP_NFCT(timestamp_stop
, ATTR_TIMESTAMP_STOP
, 64);
507 CP_NFCT(flow_id
, ATTR_ID
, 32);
508 CP_NFCT(use
, ATTR_USE
, 32);
510 CP_NFCT_BUFF(ip6_src_addr
, ATTR_ORIG_IPV6_SRC
);
511 CP_NFCT_BUFF(ip6_dst_addr
, ATTR_ORIG_IPV6_DST
);
513 n
->port_src
= ntohs(n
->port_src
);
514 n
->port_dst
= ntohs(n
->port_dst
);
516 n
->ip4_src_addr
= ntohl(n
->ip4_src_addr
);
517 n
->ip4_dst_addr
= ntohl(n
->ip4_dst_addr
);
520 enum flow_entry_direction
{
525 static inline bool flow_entry_get_extended_is_dns(struct flow_entry
*n
)
527 /* We don't want to analyze / display DNS itself, since we
528 * use it to resolve reverse dns.
530 return n
->port_src
== 53 || n
->port_dst
== 53;
533 #define SELFLD(dir,src_member,dst_member) \
534 (((dir) == flow_entry_src) ? n->src_member : n->dst_member)
536 static void flow_entry_get_sain4_obj(struct flow_entry
*n
,
537 enum flow_entry_direction dir
,
538 struct sockaddr_in
*sa
)
540 memset(sa
, 0, sizeof(*sa
));
541 sa
->sin_family
= PF_INET
;
542 sa
->sin_addr
.s_addr
= htonl(SELFLD(dir
, ip4_src_addr
, ip4_dst_addr
));
545 static void flow_entry_get_sain6_obj(struct flow_entry
*n
,
546 enum flow_entry_direction dir
,
547 struct sockaddr_in6
*sa
)
549 memset(sa
, 0, sizeof(*sa
));
550 sa
->sin6_family
= PF_INET6
;
552 memcpy(&sa
->sin6_addr
, SELFLD(dir
, ip6_src_addr
, ip6_dst_addr
),
553 sizeof(sa
->sin6_addr
));
557 flow_entry_geo_city_lookup_generic(struct flow_entry
*n
,
558 enum flow_entry_direction dir
)
560 struct sockaddr_in sa4
;
561 struct sockaddr_in6 sa6
;
562 const char *city
= NULL
;
564 switch (n
->l3_proto
) {
569 flow_entry_get_sain4_obj(n
, dir
, &sa4
);
570 city
= geoip4_city_name(&sa4
);
574 flow_entry_get_sain6_obj(n
, dir
, &sa6
);
575 city
= geoip6_city_name(&sa6
);
579 build_bug_on(sizeof(n
->city_src
) != sizeof(n
->city_dst
));
582 memcpy(SELFLD(dir
, city_src
, city_dst
), city
,
583 min(sizeof(n
->city_src
), strlen(city
)));
585 memset(SELFLD(dir
, city_src
, city_dst
), 0,
586 sizeof(n
->city_src
));
591 flow_entry_geo_country_lookup_generic(struct flow_entry
*n
,
592 enum flow_entry_direction dir
)
594 struct sockaddr_in sa4
;
595 struct sockaddr_in6 sa6
;
596 const char *country
= NULL
;
598 switch (n
->l3_proto
) {
603 flow_entry_get_sain4_obj(n
, dir
, &sa4
);
604 country
= geoip4_country_name(&sa4
);
608 flow_entry_get_sain6_obj(n
, dir
, &sa6
);
609 country
= geoip6_country_name(&sa6
);
613 build_bug_on(sizeof(n
->country_src
) != sizeof(n
->country_dst
));
616 memcpy(SELFLD(dir
, country_src
, country_dst
), country
,
617 min(sizeof(n
->country_src
), strlen(country
)));
619 memset(SELFLD(dir
, country_src
, country_dst
), 0,
620 sizeof(n
->country_src
));
624 static void flow_entry_get_extended_geo(struct flow_entry
*n
,
625 enum flow_entry_direction dir
)
627 flow_entry_geo_city_lookup_generic(n
, dir
);
628 flow_entry_geo_country_lookup_generic(n
, dir
);
631 static void flow_entry_get_extended_revdns(struct flow_entry
*n
,
632 enum flow_entry_direction dir
)
635 struct sockaddr_in sa4
;
636 struct sockaddr_in6 sa6
;
638 struct hostent
*hent
;
640 switch (n
->l3_proto
) {
645 flow_entry_get_sain4_obj(n
, dir
, &sa4
);
646 sa
= (struct sockaddr
*) &sa4
;
647 sa_len
= sizeof(sa4
);
648 hent
= gethostbyaddr(&sa4
.sin_addr
, sizeof(sa4
.sin_addr
), AF_INET
);
652 flow_entry_get_sain6_obj(n
, dir
, &sa6
);
653 sa
= (struct sockaddr
*) &sa6
;
654 sa_len
= sizeof(sa6
);
655 hent
= gethostbyaddr(&sa6
.sin6_addr
, sizeof(sa6
.sin6_addr
), AF_INET6
);
659 build_bug_on(sizeof(n
->rev_dns_src
) != sizeof(n
->rev_dns_dst
));
660 getnameinfo(sa
, sa_len
, SELFLD(dir
, rev_dns_src
, rev_dns_dst
),
661 sizeof(n
->rev_dns_src
), NULL
, 0, NI_NUMERICHOST
);
664 memset(n
->rev_dns_dst
, 0, sizeof(n
->rev_dns_dst
));
665 memcpy(SELFLD(dir
, rev_dns_src
, rev_dns_dst
),
666 hent
->h_name
, min(sizeof(n
->rev_dns_src
),
667 strlen(hent
->h_name
)));
671 static void flow_entry_get_extended(struct flow_entry
*n
)
673 if (n
->flow_id
== 0 || flow_entry_get_extended_is_dns(n
))
677 flow_entry_get_extended_revdns(n
, flow_entry_src
);
678 flow_entry_get_extended_geo(n
, flow_entry_src
);
681 flow_entry_get_extended_revdns(n
, flow_entry_dst
);
682 flow_entry_get_extended_geo(n
, flow_entry_dst
);
684 /* Lookup application */
685 n
->inode
= get_port_inode(n
->port_src
, n
->l4_proto
,
686 n
->l3_proto
== AF_INET6
);
691 static uint16_t presenter_get_port(uint16_t src
, uint16_t dst
, bool is_tcp
)
693 if (src
< dst
&& src
< 1024) {
695 } else if (dst
< src
&& dst
< 1024) {
698 const char *tmp1
, *tmp2
;
700 tmp1
= lookup_port_tcp(src
);
701 tmp2
= lookup_port_tcp(dst
);
703 tmp1
= lookup_port_udp(src
);
704 tmp2
= lookup_port_udp(dst
);
708 } else if (!tmp1
&& tmp2
) {
719 static char *bandw2str(double bytes
, char *buf
, size_t len
)
721 if (bytes
> 1000000000.)
722 snprintf(buf
, len
, "%.1fG", bytes
/ 1000000000.);
723 else if (bytes
> 1000000.)
724 snprintf(buf
, len
, "%.1fM", bytes
/ 1000000.);
725 else if (bytes
> 1000.)
726 snprintf(buf
, len
, "%.1fK", bytes
/ 1000.);
728 snprintf(buf
, len
, "%g", bytes
);
733 static void presenter_screen_do_line(WINDOW
*screen
, struct flow_entry
*n
,
736 char tmp
[128], *pname
= NULL
;
739 mvwprintw(screen
, *line
, 2, "");
741 /* PID, application name */
742 if (n
->procnum
> 0) {
743 slprintf(tmp
, sizeof(tmp
), "%s(%d)", basename(n
->cmdline
),
747 attron(COLOR_PAIR(3));
749 attroff(COLOR_PAIR(3));
753 /* L3 protocol, L4 protocol, states */
754 printw("%s:%s", l3proto2str
[n
->l3_proto
], l4proto2str
[n
->l4_proto
]);
756 attron(COLOR_PAIR(3));
757 switch (n
->l4_proto
) {
759 printw("%s", tcp_state2str
[n
->tcp_state
]);
762 printw("%s", sctp_state2str
[n
->sctp_state
]);
765 printw("%s", dccp_state2str
[n
->dccp_state
]);
768 case IPPROTO_UDPLITE
:
774 attroff(COLOR_PAIR(3));
777 /* Guess application port */
778 switch (n
->l4_proto
) {
780 port
= presenter_get_port(n
->port_src
, n
->port_dst
, true);
781 pname
= lookup_port_tcp(port
);
784 case IPPROTO_UDPLITE
:
785 port
= presenter_get_port(n
->port_src
, n
->port_dst
, false);
786 pname
= lookup_port_udp(port
);
791 printw(":%s", pname
);
795 /* Show source information: reverse DNS, port, country, city, counters */
797 attron(COLOR_PAIR(1));
798 mvwprintw(screen
, ++(*line
), 8, "src: %s", n
->rev_dns_src
);
799 attroff(COLOR_PAIR(1));
801 printw(":%"PRIu16
, n
->port_src
);
803 if (n
->country_src
[0]) {
806 attron(COLOR_PAIR(4));
807 printw("%s", n
->country_src
);
808 attroff(COLOR_PAIR(4));
811 printw(", %s", n
->city_src
);
816 if (n
->src_pkts
> 0 && n
->src_bytes
> 0) {
819 printw(" -> (%"PRIu64
" pkts, %s bytes)", n
->src_pkts
,
820 bandw2str(n
->src_bytes
, bytes_str
,
821 sizeof(bytes_str
) - 1));
827 /* Show dest information: reverse DNS, port, country, city, counters */
828 attron(COLOR_PAIR(2));
829 mvwprintw(screen
, ++(*line
), 8, "dst: %s", n
->rev_dns_dst
);
830 attroff(COLOR_PAIR(2));
832 printw(":%"PRIu16
, n
->port_dst
);
834 if (n
->country_dst
[0]) {
837 attron(COLOR_PAIR(4));
838 printw("%s", n
->country_dst
);
839 attroff(COLOR_PAIR(4));
842 printw(", %s", n
->city_dst
);
847 if (n
->dst_pkts
> 0 && n
->dst_bytes
> 0) {
850 printw(" -> (%"PRIu64
" pkts, %s bytes)", n
->dst_pkts
,
851 bandw2str(n
->dst_bytes
, bytes_str
,
852 sizeof(bytes_str
) - 1));
856 static inline bool presenter_flow_wrong_state(struct flow_entry
*n
)
858 switch (n
->l4_proto
) {
860 switch (n
->tcp_state
) {
861 case TCP_CONNTRACK_SYN_SENT
:
862 case TCP_CONNTRACK_SYN_RECV
:
863 case TCP_CONNTRACK_ESTABLISHED
:
864 case TCP_CONNTRACK_FIN_WAIT
:
865 case TCP_CONNTRACK_CLOSE_WAIT
:
866 case TCP_CONNTRACK_LAST_ACK
:
867 case TCP_CONNTRACK_TIME_WAIT
:
868 case TCP_CONNTRACK_CLOSE
:
869 case TCP_CONNTRACK_SYN_SENT2
:
870 case TCP_CONNTRACK_NONE
:
876 switch (n
->sctp_state
) {
877 case SCTP_CONNTRACK_NONE
:
878 case SCTP_CONNTRACK_CLOSED
:
879 case SCTP_CONNTRACK_COOKIE_WAIT
:
880 case SCTP_CONNTRACK_COOKIE_ECHOED
:
881 case SCTP_CONNTRACK_ESTABLISHED
:
882 case SCTP_CONNTRACK_SHUTDOWN_SENT
:
883 case SCTP_CONNTRACK_SHUTDOWN_RECD
:
884 case SCTP_CONNTRACK_SHUTDOWN_ACK_SENT
:
890 switch (n
->dccp_state
) {
891 case DCCP_CONNTRACK_NONE
:
892 case DCCP_CONNTRACK_REQUEST
:
893 case DCCP_CONNTRACK_RESPOND
:
894 case DCCP_CONNTRACK_PARTOPEN
:
895 case DCCP_CONNTRACK_OPEN
:
896 case DCCP_CONNTRACK_CLOSEREQ
:
897 case DCCP_CONNTRACK_CLOSING
:
898 case DCCP_CONNTRACK_TIMEWAIT
:
899 case DCCP_CONNTRACK_IGNORE
:
900 case DCCP_CONNTRACK_INVALID
:
906 case IPPROTO_UDPLITE
:
916 static void presenter_screen_update(WINDOW
*screen
, struct flow_list
*fl
,
920 int skip_left
= skip_lines
;
921 unsigned int flows
= 0;
922 unsigned int line
= 3;
923 struct flow_entry
*n
;
927 maxy
= getmaxy(screen
);
931 init_pair(1, COLOR_RED
, COLOR_BLACK
);
932 init_pair(2, COLOR_BLUE
, COLOR_BLACK
);
933 init_pair(3, COLOR_YELLOW
, COLOR_BLACK
);
934 init_pair(4, COLOR_GREEN
, COLOR_BLACK
);
941 n
= rcu_dereference(fl
->head
);
943 mvwprintw(screen
, line
, 2, "(No active sessions! "
944 "Is netfilter running?)");
946 for (; n
; n
= rcu_dereference(n
->next
)) {
947 n
->is_visible
= false;
948 if (presenter_get_port(n
->port_src
, n
->port_dst
, false) == 53)
951 if (presenter_flow_wrong_state(n
))
954 /* count only flows which might be showed */
965 n
->is_visible
= true;
967 presenter_screen_do_line(screen
, n
, &line
);
970 maxy
-= (2 + 1 * show_src
);
973 mvwprintw(screen
, 1, 2,
974 "Kernel netfilter flows(%u) for %s%s%s%s%s%s"
975 "[+%d]", flows
, what
& INCLUDE_TCP
? "TCP, " : "",
976 what
& INCLUDE_UDP
? "UDP, " : "",
977 what
& INCLUDE_SCTP
? "SCTP, " : "",
978 what
& INCLUDE_DCCP
? "DCCP, " : "",
979 what
& INCLUDE_ICMP
&& what
& INCLUDE_IPV4
? "ICMP, " : "",
980 what
& INCLUDE_ICMP
&& what
& INCLUDE_IPV6
? "ICMP6, " : "",
983 if (is_flow_collecting
)
984 printw(" [Collecting flows ...]");
992 static void presenter(void)
997 lookup_init_ports(PORTS_TCP
);
998 lookup_init_ports(PORTS_UDP
);
999 screen
= screen_init(false);
1001 rcu_register_thread();
1018 if (skip_lines
> SCROLL_MAX
)
1019 skip_lines
= SCROLL_MAX
;
1026 presenter_screen_update(screen
, &flow_list
, skip_lines
);
1029 rcu_unregister_thread();
1032 lookup_cleanup_ports(PORTS_UDP
);
1033 lookup_cleanup_ports(PORTS_TCP
);
1036 static int flow_event_cb(enum nf_conntrack_msg_type type
,
1037 struct nf_conntrack
*ct
, void *data __maybe_unused
)
1040 return NFCT_CB_STOP
;
1043 spinlock_lock(&flow_list
.lock
);
1047 flow_list_new_entry(&flow_list
, ct
);
1050 flow_list_update_entry(&flow_list
, ct
);
1052 case NFCT_T_DESTROY
:
1053 flow_list_destroy_entry(&flow_list
, ct
);
1059 spinlock_unlock(&flow_list
.lock
);
1061 return NFCT_CB_CONTINUE
;
1064 static void restore_sysctl(void *value
)
1066 int int_val
= *(int *)value
;
1069 sysctl_set_int("net/netfilter/nf_conntrack_acct", int_val
);
1072 static void on_panic_handler(void *arg
)
1074 restore_sysctl(arg
);
1078 static void conntrack_acct_enable(void)
1080 /* We can still work w/o traffic accounting so just warn about error */
1081 if (sysctl_get_int("net/netfilter/nf_conntrack_acct", &nfct_acct_val
)) {
1082 fprintf(stderr
, "Can't read net/netfilter/nf_conntrack_acct: %s\n",
1086 if (nfct_acct_val
== 1)
1089 if (sysctl_set_int("net/netfilter/nf_conntrack_acct", 1)) {
1090 fprintf(stderr
, "Can't write net/netfilter/nf_conntrack_acct: %s\n",
1095 static int flow_update_cb(enum nf_conntrack_msg_type type
,
1096 struct nf_conntrack
*ct
, void *data __maybe_unused
)
1098 struct flow_entry
*n
;
1100 if (type
!= NFCT_T_UPDATE
)
1101 return NFCT_CB_CONTINUE
;
1104 return NFCT_CB_STOP
;
1106 n
= flow_list_find_id(&flow_list
, nfct_get_attr_u32(ct
, ATTR_ID
));
1108 return NFCT_CB_CONTINUE
;
1110 flow_entry_from_ct(n
, ct
);
1112 return NFCT_CB_CONTINUE
;
1115 static void collector_refresh_flows(struct nfct_handle
*handle
)
1117 struct flow_entry
*n
;
1119 n
= rcu_dereference(flow_list
.head
);
1120 for (; n
; n
= rcu_dereference(n
->next
)) {
1124 nfct_query(handle
, NFCT_Q_GET
, n
->ct
);
1128 static void collector_create_filter(struct nfct_handle
*nfct
)
1130 struct nfct_filter
*filter
;
1133 filter
= nfct_filter_create();
1135 panic("Cannot create a nfct filter: %s\n", strerror(errno
));
1137 if (what
& INCLUDE_UDP
) {
1138 nfct_filter_add_attr_u32(filter
, NFCT_FILTER_L4PROTO
, IPPROTO_UDP
);
1139 nfct_filter_add_attr_u32(filter
, NFCT_FILTER_L4PROTO
, IPPROTO_UDPLITE
);
1141 if (what
& INCLUDE_TCP
)
1142 nfct_filter_add_attr_u32(filter
, NFCT_FILTER_L4PROTO
, IPPROTO_TCP
);
1143 if (what
& INCLUDE_DCCP
)
1144 nfct_filter_add_attr_u32(filter
, NFCT_FILTER_L4PROTO
, IPPROTO_DCCP
);
1145 if (what
& INCLUDE_SCTP
)
1146 nfct_filter_add_attr_u32(filter
, NFCT_FILTER_L4PROTO
, IPPROTO_SCTP
);
1147 if (what
& INCLUDE_ICMP
&& what
& INCLUDE_IPV4
)
1148 nfct_filter_add_attr_u32(filter
, NFCT_FILTER_L4PROTO
, IPPROTO_ICMP
);
1149 if (what
& INCLUDE_ICMP
&& what
& INCLUDE_IPV6
)
1150 nfct_filter_add_attr_u32(filter
, NFCT_FILTER_L4PROTO
, IPPROTO_ICMPV6
);
1151 if (what
& INCLUDE_IPV4
) {
1152 nfct_filter_set_logic(filter
, NFCT_FILTER_SRC_IPV4
, NFCT_FILTER_LOGIC_NEGATIVE
);
1153 nfct_filter_add_attr(filter
, NFCT_FILTER_SRC_IPV4
, &filter_ipv4
);
1155 if (what
& INCLUDE_IPV6
) {
1156 nfct_filter_set_logic(filter
, NFCT_FILTER_SRC_IPV6
, NFCT_FILTER_LOGIC_NEGATIVE
);
1157 nfct_filter_add_attr(filter
, NFCT_FILTER_SRC_IPV6
, &filter_ipv6
);
1160 ret
= nfct_filter_attach(nfct_fd(nfct
), filter
);
1162 panic("Cannot attach filter to handle: %s\n", strerror(errno
));
1164 nfct_filter_destroy(filter
);
1167 /* This hand-crafted filter looks ugly but it allows to do not
1168 * flush nfct connections & filter them by user specified filter.
1169 * May be it is better to replace this one by nfct_cmp. */
1170 static int flow_dump_cb(enum nf_conntrack_msg_type type
,
1171 struct nf_conntrack
*ct
, void *data __maybe_unused
)
1173 struct flow_entry fl
;
1174 struct flow_entry
*n
= &fl
;
1177 return NFCT_CB_STOP
;
1180 spinlock_lock(&flow_list
.lock
);
1182 if (!(what
& ~(INCLUDE_IPV4
| INCLUDE_IPV6
)))
1185 CP_NFCT(l4_proto
, ATTR_ORIG_L4PROTO
, 8);
1187 if (what
& INCLUDE_UDP
) {
1188 if (n
->l4_proto
== IPPROTO_UDP
)
1191 if (n
->l4_proto
== IPPROTO_UDPLITE
)
1195 if ((what
& INCLUDE_TCP
) && n
->l4_proto
== IPPROTO_TCP
)
1198 if ((what
& INCLUDE_DCCP
) && n
->l4_proto
== IPPROTO_DCCP
)
1201 if ((what
& INCLUDE_SCTP
) && n
->l4_proto
== IPPROTO_SCTP
)
1204 if ((what
& INCLUDE_ICMP
) && (what
& INCLUDE_IPV4
) &&
1205 n
->l4_proto
== IPPROTO_ICMP
) {
1209 if ((what
& INCLUDE_ICMP
) && (what
& INCLUDE_IPV6
) &&
1210 n
->l4_proto
== IPPROTO_ICMPV6
) {
1217 /* filter loopback addresses */
1218 if (what
& INCLUDE_IPV4
) {
1219 CP_NFCT(ip4_src_addr
, ATTR_ORIG_IPV4_SRC
, 32);
1221 if (n
->ip4_src_addr
== filter_ipv4
.addr
)
1224 if (what
& INCLUDE_IPV6
) {
1225 CP_NFCT_BUFF(ip6_src_addr
, ATTR_ORIG_IPV6_SRC
);
1227 if (n
->ip6_src_addr
[0] == 0x0 &&
1228 n
->ip6_src_addr
[1] == 0x0 &&
1229 n
->ip6_src_addr
[2] == 0x0 &&
1230 n
->ip6_src_addr
[3] == 0x1)
1234 flow_list_new_entry(&flow_list
, ct
);
1237 spinlock_unlock(&flow_list
.lock
);
1238 return NFCT_CB_CONTINUE
;
1241 static void collector_dump_flows(void)
1243 struct nfct_handle
*nfct
= nfct_open(CONNTRACK
, 0);
1246 panic("Cannot create a nfct handle: %s\n", strerror(errno
));
1248 nfct_callback_register(nfct
, NFCT_T_ALL
, flow_dump_cb
, NULL
);
1250 is_flow_collecting
= true;
1251 if (what
& INCLUDE_IPV4
) {
1252 int family
= AF_INET
;
1253 nfct_query(nfct
, NFCT_Q_DUMP
, &family
);
1255 if (what
& INCLUDE_IPV6
) {
1256 int family
= AF_INET6
;
1257 nfct_query(nfct
, NFCT_Q_DUMP
, &family
);
1259 is_flow_collecting
= false;
1264 static void *collector(void *null __maybe_unused
)
1266 struct nfct_handle
*ct_update
;
1267 struct nfct_handle
*ct_event
;
1268 struct pollfd poll_fd
[1];
1270 flow_list_init(&flow_list
);
1272 ct_event
= nfct_open(CONNTRACK
, NF_NETLINK_CONNTRACK_NEW
|
1273 NF_NETLINK_CONNTRACK_UPDATE
|
1274 NF_NETLINK_CONNTRACK_DESTROY
);
1276 panic("Cannot create a nfct handle: %s\n", strerror(errno
));
1278 collector_create_filter(ct_event
);
1280 nfct_callback_register(ct_event
, NFCT_T_ALL
, flow_event_cb
, NULL
);
1282 ct_update
= nfct_open(CONNTRACK
, NF_NETLINK_CONNTRACK_UPDATE
);
1284 panic("Cannot create a nfct handle: %s\n", strerror(errno
));
1286 nfct_callback_register(ct_update
, NFCT_T_ALL
, flow_update_cb
, NULL
);
1288 poll_fd
[0].fd
= nfct_fd(ct_event
);
1289 poll_fd
[0].events
= POLLIN
;
1291 if (fcntl(nfct_fd(ct_event
), F_SETFL
, O_NONBLOCK
) == -1)
1292 panic("Cannot set non-blocking socket: fcntl(): %s\n",
1295 if (fcntl(nfct_fd(ct_update
), F_SETFL
, O_NONBLOCK
) == -1)
1296 panic("Cannot set non-blocking socket: fcntl(): %s\n",
1299 rcu_register_thread();
1301 collector_dump_flows();
1308 collector_refresh_flows(ct_update
);
1310 status
= poll(poll_fd
, 1, 0);
1312 if (errno
== EAGAIN
|| errno
== EINTR
)
1315 panic("Error while polling: %s\n", strerror(errno
));
1316 } else if (status
== 0) {
1320 if (poll_fd
[0].revents
& POLLIN
)
1321 nfct_catch(ct_event
);
1324 rcu_unregister_thread();
1326 flow_list_destroy(&flow_list
);
1327 nfct_close(ct_event
);
1328 nfct_close(ct_update
);
1333 int main(int argc
, char **argv
)
1336 int ret
, c
, opt_index
, what_cmd
= 0;
1341 while ((c
= getopt_long(argc
, argv
, short_options
, long_options
,
1342 &opt_index
)) != EOF
) {
1345 what_cmd
|= INCLUDE_IPV4
;
1348 what_cmd
|= INCLUDE_IPV6
;
1351 what_cmd
|= INCLUDE_TCP
;
1354 what_cmd
|= INCLUDE_UDP
;
1357 what_cmd
|= INCLUDE_DCCP
;
1360 what_cmd
|= INCLUDE_ICMP
;
1363 what_cmd
|= INCLUDE_SCTP
;
1386 if (!(what
& (INCLUDE_IPV4
| INCLUDE_IPV6
)))
1387 what
|= INCLUDE_IPV4
| INCLUDE_IPV6
;
1392 register_signal(SIGINT
, signal_handler
);
1393 register_signal(SIGQUIT
, signal_handler
);
1394 register_signal(SIGTERM
, signal_handler
);
1395 register_signal(SIGHUP
, signal_handler
);
1397 panic_handler_add(on_panic_handler
, &nfct_acct_val
);
1399 conntrack_acct_enable();
1403 ret
= pthread_create(&tid
, NULL
, collector
, NULL
);
1405 panic("Cannot create phthread!\n");
1411 restore_sysctl(&nfct_acct_val
);