1 /*
2 * ipmonitor.c "ip monitor".
3 *
4 * This program is free software; you can redistribute it and/or
5 * modify it under the terms of the GNU General Public License
6 * as published by the Free Software Foundation; either version
7 * 2 of the License, or (at your option) any later version.
8 *
9 * Authors: Alexey Kuznetsov, <kuznet@ms2.inr.ac.ru>
10 *
11 */
12
13 #include <stdio.h>
14 #include <stdlib.h>
15 #include <unistd.h>
16 #include <syslog.h>
17 #include <fcntl.h>
18 #include <sys/socket.h>
19 #include <netinet/in.h>
20 #include <arpa/inet.h>
21 #include <string.h>
22 #include <time.h>
23
24 #include "utils.h"
25 #include "ip_common.h"
26
27 static void usage(void) __attribute__((noreturn));
28 int prefix_banner;
29
usage(void)30 static void usage(void)
31 {
32 fprintf(stderr, "Usage: ip monitor [ all | LISTofOBJECTS ]\n");
33 exit(-1);
34 }
35
36
accept_msg(const struct sockaddr_nl * who,struct nlmsghdr * n,void * arg)37 int accept_msg(const struct sockaddr_nl *who,
38 struct nlmsghdr *n, void *arg)
39 {
40 FILE *fp = (FILE*)arg;
41
42 if (timestamp)
43 print_timestamp(fp);
44
45 if (n->nlmsg_type == RTM_NEWROUTE || n->nlmsg_type == RTM_DELROUTE) {
46 if (prefix_banner)
47 fprintf(fp, "[ROUTE]");
48 print_route(who, n, arg);
49 return 0;
50 }
51 if (n->nlmsg_type == RTM_NEWLINK || n->nlmsg_type == RTM_DELLINK) {
52 ll_remember_index(who, n, NULL);
53 if (prefix_banner)
54 fprintf(fp, "[LINK]");
55 print_linkinfo(who, n, arg);
56 return 0;
57 }
58 if (n->nlmsg_type == RTM_NEWADDR || n->nlmsg_type == RTM_DELADDR) {
59 if (prefix_banner)
60 fprintf(fp, "[ADDR]");
61 print_addrinfo(who, n, arg);
62 return 0;
63 }
64 if (n->nlmsg_type == RTM_NEWADDRLABEL || n->nlmsg_type == RTM_DELADDRLABEL) {
65 if (prefix_banner)
66 fprintf(fp, "[ADDRLABEL]");
67 print_addrlabel(who, n, arg);
68 return 0;
69 }
70 if (n->nlmsg_type == RTM_NEWNEIGH || n->nlmsg_type == RTM_DELNEIGH) {
71 if (prefix_banner)
72 fprintf(fp, "[NEIGH]");
73 print_neigh(who, n, arg);
74 return 0;
75 }
76 if (n->nlmsg_type == RTM_NEWPREFIX) {
77 if (prefix_banner)
78 fprintf(fp, "[PREFIX]");
79 print_prefix(who, n, arg);
80 return 0;
81 }
82 if (n->nlmsg_type == RTM_NEWRULE || n->nlmsg_type == RTM_DELRULE) {
83 if (prefix_banner)
84 fprintf(fp, "[RULE]");
85 print_rule(who, n, arg);
86 return 0;
87 }
88 if (n->nlmsg_type == 15) {
89 char *tstr;
90 time_t secs = ((__u32*)NLMSG_DATA(n))[0];
91 long usecs = ((__u32*)NLMSG_DATA(n))[1];
92 tstr = asctime(localtime(&secs));
93 tstr[strlen(tstr)-1] = 0;
94 fprintf(fp, "Timestamp: %s %lu us\n", tstr, usecs);
95 return 0;
96 }
97 if (n->nlmsg_type == RTM_NEWQDISC ||
98 n->nlmsg_type == RTM_DELQDISC ||
99 n->nlmsg_type == RTM_NEWTCLASS ||
100 n->nlmsg_type == RTM_DELTCLASS ||
101 n->nlmsg_type == RTM_NEWTFILTER ||
102 n->nlmsg_type == RTM_DELTFILTER)
103 return 0;
104 if (n->nlmsg_type != NLMSG_ERROR && n->nlmsg_type != NLMSG_NOOP &&
105 n->nlmsg_type != NLMSG_DONE) {
106 fprintf(fp, "Unknown message: %08x %08x %08x\n",
107 n->nlmsg_len, n->nlmsg_type, n->nlmsg_flags);
108 }
109 return 0;
110 }
111
do_ipmonitor(int argc,char ** argv)112 int do_ipmonitor(int argc, char **argv)
113 {
114 char *file = NULL;
115 unsigned groups = ~RTMGRP_TC;
116 int llink=0;
117 int laddr=0;
118 int lroute=0;
119 int lprefix=0;
120 int lneigh=0;
121
122 rtnl_close(&rth);
123 ipaddr_reset_filter(1);
124 iproute_reset_filter();
125 ipneigh_reset_filter();
126
127 while (argc > 0) {
128 if (matches(*argv, "file") == 0) {
129 NEXT_ARG();
130 file = *argv;
131 } else if (matches(*argv, "link") == 0) {
132 llink=1;
133 groups = 0;
134 } else if (matches(*argv, "address") == 0) {
135 laddr=1;
136 groups = 0;
137 } else if (matches(*argv, "route") == 0) {
138 lroute=1;
139 groups = 0;
140 } else if (matches(*argv, "prefix") == 0) {
141 lprefix=1;
142 groups = 0;
143 } else if (matches(*argv, "neigh") == 0) {
144 lneigh = 1;
145 groups = 0;
146 } else if (strcmp(*argv, "all") == 0) {
147 groups = ~RTMGRP_TC;
148 prefix_banner=1;
149 } else if (matches(*argv, "help") == 0) {
150 usage();
151 } else {
152 fprintf(stderr, "Argument \"%s\" is unknown, try \"ip monitor help\".\n", *argv);
153 exit(-1);
154 }
155 argc--; argv++;
156 }
157
158 if (llink)
159 groups |= nl_mgrp(RTNLGRP_LINK);
160 if (laddr) {
161 if (!preferred_family || preferred_family == AF_INET)
162 groups |= nl_mgrp(RTNLGRP_IPV4_IFADDR);
163 if (!preferred_family || preferred_family == AF_INET6)
164 groups |= nl_mgrp(RTNLGRP_IPV6_IFADDR);
165 }
166 if (lroute) {
167 if (!preferred_family || preferred_family == AF_INET)
168 groups |= nl_mgrp(RTNLGRP_IPV4_ROUTE);
169 if (!preferred_family || preferred_family == AF_INET6)
170 groups |= nl_mgrp(RTNLGRP_IPV6_ROUTE);
171 }
172 if (lprefix) {
173 if (!preferred_family || preferred_family == AF_INET6)
174 groups |= nl_mgrp(RTNLGRP_IPV6_PREFIX);
175 }
176 if (lneigh) {
177 groups |= nl_mgrp(RTNLGRP_NEIGH);
178 }
179 if (file) {
180 FILE *fp;
181 fp = fopen(file, "r");
182 if (fp == NULL) {
183 perror("Cannot fopen");
184 exit(-1);
185 }
186 return rtnl_from_file(fp, accept_msg, stdout);
187 }
188
189 if (rtnl_open(&rth, groups) < 0)
190 exit(1);
191 ll_init_map(&rth);
192
193 if (rtnl_listen(&rth, accept_msg, stdout) < 0)
194 exit(2);
195
196 return 0;
197 }
198