ip/ipmonitor.c

   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
  30 static void usage(void)
  31 {
  32         fprintf(stderr, "Usage: ip monitor [ all | LISTofOBJECTS ] [ FILE ] [ label ]\n");
  33         fprintf(stderr, "LISTofOBJECTS := link | address | route | mroute | prefix |\n");
  34         fprintf(stderr, "                 neigh | netconf\n");
  35         fprintf(stderr, "FILE := file FILENAME\n");
  36         exit(-1);
  37 }
  38
  39 static int accept_msg(const struct sockaddr_nl *who,
  40                       struct nlmsghdr *n, void *arg)
  41 {
  42         FILE *fp = (FILE*)arg;
  43
  44         if (timestamp)
  45                 print_timestamp(fp);
  46
  47         if (n->nlmsg_type == RTM_NEWROUTE || n->nlmsg_type == RTM_DELROUTE) {
  48                 struct rtmsg *r = NLMSG_DATA(n);
  49                 int len = n->nlmsg_len - NLMSG_LENGTH(sizeof(*r));
  50
  51                 if (len < 0) {
  52                         fprintf(stderr, "BUG: wrong nlmsg len %d\n", len);
  53                         return -1;
  54                 }
  55
  56                 if (r->rtm_family == RTNL_FAMILY_IPMR ||
  57                     r->rtm_family == RTNL_FAMILY_IP6MR) {
  58                         if (prefix_banner)
  59                                 fprintf(fp, "[MROUTE]");
  60                         print_mroute(who, n, arg);
  61                         return 0;
  62                 } else {
  63                         if (prefix_banner)
  64                                 fprintf(fp, "[ROUTE]");
  65                         print_route(who, n, arg);
  66                         return 0;
  67                 }
  68         }
  69         if (n->nlmsg_type == RTM_NEWLINK || n->nlmsg_type == RTM_DELLINK) {
  70                 ll_remember_index(who, n, NULL);
  71                 if (prefix_banner)
  72                         fprintf(fp, "[LINK]");
  73                 print_linkinfo(who, n, arg);
  74                 return 0;
  75         }
  76         if (n->nlmsg_type == RTM_NEWADDR || n->nlmsg_type == RTM_DELADDR) {
  77                 if (prefix_banner)
  78                         fprintf(fp, "[ADDR]");
  79                 print_addrinfo(who, n, arg);
  80                 return 0;
  81         }
  82         if (n->nlmsg_type == RTM_NEWADDRLABEL || n->nlmsg_type == RTM_DELADDRLABEL) {
  83                 if (prefix_banner)
  84                         fprintf(fp, "[ADDRLABEL]");
  85                 print_addrlabel(who, n, arg);
  86                 return 0;
  87         }
  88         if (n->nlmsg_type == RTM_NEWNEIGH || n->nlmsg_type == RTM_DELNEIGH ||
  89             n->nlmsg_type == RTM_GETNEIGH) {
  90                 if (preferred_family) {
  91                         struct ndmsg *r = NLMSG_DATA(n);
  92
  93                         if (r->ndm_family != preferred_family)
  94                                 return 0;
  95                 }
  96
  97                 if (prefix_banner)
  98                         fprintf(fp, "[NEIGH]");
  99                 print_neigh(who, n, arg);
 100                 return 0;
 101         }
 102         if (n->nlmsg_type == RTM_NEWPREFIX) {
 103                 if (prefix_banner)
 104                         fprintf(fp, "[PREFIX]");
 105                 print_prefix(who, n, arg);
 106                 return 0;
 107         }
 108         if (n->nlmsg_type == RTM_NEWRULE || n->nlmsg_type == RTM_DELRULE) {
 109                 if (prefix_banner)
 110                         fprintf(fp, "[RULE]");
 111                 print_rule(who, n, arg);
 112                 return 0;
 113         }
 114         if (n->nlmsg_type == RTM_NEWNETCONF) {
 115                 if (prefix_banner)
 116                         fprintf(fp, "[NETCONF]");
 117                 print_netconf(who, n, arg);
 118                 return 0;
 119         }
 120         if (n->nlmsg_type == 15) {
 121                 char *tstr;
 122                 time_t secs = ((__u32*)NLMSG_DATA(n))[0];
 123                 long usecs = ((__u32*)NLMSG_DATA(n))[1];
 124                 tstr = asctime(localtime(&secs));
 125                 tstr[strlen(tstr)-1] = 0;
 126                 fprintf(fp, "Timestamp: %s %lu us\n", tstr, usecs);
 127                 return 0;
 128         }
 129         if (n->nlmsg_type == RTM_NEWQDISC ||
 130             n->nlmsg_type == RTM_DELQDISC ||
 131             n->nlmsg_type == RTM_NEWTCLASS ||
 132             n->nlmsg_type == RTM_DELTCLASS ||
 133             n->nlmsg_type == RTM_NEWTFILTER ||
 134             n->nlmsg_type == RTM_DELTFILTER)
 135                 return 0;
 136         if (n->nlmsg_type != NLMSG_ERROR && n->nlmsg_type != NLMSG_NOOP &&
 137             n->nlmsg_type != NLMSG_DONE) {
 138                 fprintf(fp, "Unknown message: %08x %08x %08x\n",
 139                         n->nlmsg_len, n->nlmsg_type, n->nlmsg_flags);
 140         }
 141         return 0;
 142 }
 143
 144 int do_ipmonitor(int argc, char **argv)
 145 {
 146         char *file = NULL;
 147         unsigned groups = ~RTMGRP_TC;
 148         int llink=0;
 149         int laddr=0;
 150         int lroute=0;
 151         int lmroute=0;
 152         int lprefix=0;
 153         int lneigh=0;
 154         int lnetconf=0;
 155
 156         rtnl_close(&rth);
 157         ipaddr_reset_filter(1);
 158         iproute_reset_filter();
 159         ipmroute_reset_filter();
 160         ipneigh_reset_filter();
 161
 162         while (argc > 0) {
 163                 if (matches(*argv, "file") == 0) {
 164                         NEXT_ARG();
 165                         file = *argv;
 166                 } else if (matches(*argv, "label") == 0) {
 167                         prefix_banner = 1;
 168                 } else if (matches(*argv, "link") == 0) {
 169                         llink=1;
 170                         groups = 0;
 171                 } else if (matches(*argv, "address") == 0) {
 172                         laddr=1;
 173                         groups = 0;
 174                 } else if (matches(*argv, "route") == 0) {
 175                         lroute=1;
 176                         groups = 0;
 177                 } else if (matches(*argv, "mroute") == 0) {
 178                         lmroute=1;
 179                         groups = 0;
 180                 } else if (matches(*argv, "prefix") == 0) {
 181                         lprefix=1;
 182                         groups = 0;
 183                 } else if (matches(*argv, "neigh") == 0) {
 184                         lneigh = 1;
 185                         groups = 0;
 186                 } else if (matches(*argv, "netconf") == 0) {
 187                         lnetconf = 1;
 188                         groups = 0;
 189                 } else if (strcmp(*argv, "all") == 0) {
 190                         groups = ~RTMGRP_TC;
 191                         prefix_banner=1;
 192                 } else if (matches(*argv, "help") == 0) {
 193                         usage();
 194                 } else {
 195                         fprintf(stderr, "Argument \"%s\" is unknown, try \"ip monitor help\".\n", *argv);
 196                         exit(-1);
 197                 }
 198                 argc--; argv++;
 199         }
 200
 201         if (llink)
 202                 groups |= nl_mgrp(RTNLGRP_LINK);
 203         if (laddr) {
 204                 if (!preferred_family || preferred_family == AF_INET)
 205                         groups |= nl_mgrp(RTNLGRP_IPV4_IFADDR);
 206                 if (!preferred_family || preferred_family == AF_INET6)
 207                         groups |= nl_mgrp(RTNLGRP_IPV6_IFADDR);
 208         }
 209         if (lroute) {
 210                 if (!preferred_family || preferred_family == AF_INET)
 211                         groups |= nl_mgrp(RTNLGRP_IPV4_ROUTE);
 212                 if (!preferred_family || preferred_family == AF_INET6)
 213                         groups |= nl_mgrp(RTNLGRP_IPV6_ROUTE);
 214         }
 215         if (lmroute) {
 216                 if (!preferred_family || preferred_family == AF_INET)
 217                         groups |= nl_mgrp(RTNLGRP_IPV4_MROUTE);
 218                 if (!preferred_family || preferred_family == AF_INET6)
 219                         groups |= nl_mgrp(RTNLGRP_IPV6_MROUTE);
 220         }
 221         if (lprefix) {
 222                 if (!preferred_family || preferred_family == AF_INET6)
 223                         groups |= nl_mgrp(RTNLGRP_IPV6_PREFIX);
 224         }
 225         if (lneigh) {
 226                 groups |= nl_mgrp(RTNLGRP_NEIGH);
 227         }
 228         if (lnetconf) {
 229                 if (!preferred_family || preferred_family == AF_INET)
 230                         groups |= nl_mgrp(RTNLGRP_IPV4_NETCONF);
 231                 if (!preferred_family || preferred_family == AF_INET6)
 232                         groups |= nl_mgrp(RTNLGRP_IPV6_NETCONF);
 233         }
 234         if (file) {
 235                 FILE *fp;
 236                 fp = fopen(file, "r");
 237                 if (fp == NULL) {
 238                         perror("Cannot fopen");
 239                         exit(-1);
 240                 }
 241                 return rtnl_from_file(fp, accept_msg, stdout);
 242         }
 243
 244         if (rtnl_open(&rth, groups) < 0)
 245                 exit(1);
 246         ll_init_map(&rth);
 247
 248         if (rtnl_listen(&rth, accept_msg, stdout) < 0)
 249                 exit(2);
 250
 251         return 0;
 252 }