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 <fcntl.h>
  17 #include <sys/socket.h>
  18 #include <netinet/in.h>
  19 #include <arpa/inet.h>
  20 #include <string.h>
  21 #include <time.h>
  22
  23 #include "utils.h"
  24 #include "ip_common.h"
  25
  26 static void usage(void) __attribute__((noreturn));
  27 static int prefix_banner;
  28 int listen_all_nsid;
  29
  30 static void usage(void)
  31 {
  32         fprintf(stderr,
  33                 "Usage: ip monitor [ all | LISTofOBJECTS ] [ FILE ] [ label ] [all-nsid] [dev DEVICE]\n"
  34                 "LISTofOBJECTS := link | address | route | mroute | prefix |\n"
  35                 "                neigh | netconf | rule | nsid\n"
  36                 "FILE := file FILENAME\n");
  37         exit(-1);
  38 }
  39
  40 static void print_headers(FILE *fp, char *label, struct rtnl_ctrl_data *ctrl)
  41 {
  42         if (timestamp)
  43                 print_timestamp(fp);
  44
  45         if (listen_all_nsid) {
  46                 if (ctrl == NULL || ctrl->nsid < 0)
  47                         fprintf(fp, "[nsid current]");
  48                 else
  49                         fprintf(fp, "[nsid %d]", ctrl->nsid);
  50         }
  51
  52         if (prefix_banner)
  53                 fprintf(fp, "%s", label);
  54 }
  55
  56 static int accept_msg(struct rtnl_ctrl_data *ctrl,
  57                       struct nlmsghdr *n, void *arg)
  58 {
  59         FILE *fp = (FILE *)arg;
  60
  61         switch (n->nlmsg_type) {
  62         case RTM_NEWROUTE:
  63         case RTM_DELROUTE: {
  64                 struct rtmsg *r = NLMSG_DATA(n);
  65                 int len = n->nlmsg_len - NLMSG_LENGTH(sizeof(*r));
  66
  67                 if (len < 0) {
  68                         fprintf(stderr, "BUG: wrong nlmsg len %d\n", len);
  69                         return -1;
  70                 }
  71
  72                 if (r->rtm_flags & RTM_F_CLONED)
  73                         return 0;
  74
  75                 if (r->rtm_family == RTNL_FAMILY_IPMR ||
  76                     r->rtm_family == RTNL_FAMILY_IP6MR) {
  77                         print_headers(fp, "[MROUTE]", ctrl);
  78                         print_mroute(n, arg);
  79                         return 0;
  80                 } else {
  81                         print_headers(fp, "[ROUTE]", ctrl);
  82                         print_route(n, arg);
  83                         return 0;
  84                 }
  85         }
  86
  87         case RTM_NEWLINK:
  88         case RTM_DELLINK:
  89                 ll_remember_index(n, NULL);
  90                 print_headers(fp, "[LINK]", ctrl);
  91                 print_linkinfo(n, arg);
  92                 return 0;
  93
  94         case RTM_NEWADDR:
  95         case RTM_DELADDR:
  96                 print_headers(fp, "[ADDR]", ctrl);
  97                 print_addrinfo(n, arg);
  98                 return 0;
  99
 100         case RTM_NEWADDRLABEL:
 101         case RTM_DELADDRLABEL:
 102                 print_headers(fp, "[ADDRLABEL]", ctrl);
 103                 print_addrlabel(n, arg);
 104                 return 0;
 105
 106         case RTM_NEWNEIGH:
 107         case RTM_DELNEIGH:
 108         case RTM_GETNEIGH:
 109                 if (preferred_family) {
 110                         struct ndmsg *r = NLMSG_DATA(n);
 111
 112                         if (r->ndm_family != preferred_family)
 113                                 return 0;
 114                 }
 115
 116                 print_headers(fp, "[NEIGH]", ctrl);
 117                 print_neigh(n, arg);
 118                 return 0;
 119
 120         case RTM_NEWPREFIX:
 121                 print_headers(fp, "[PREFIX]", ctrl);
 122                 print_prefix(n, arg);
 123                 return 0;
 124
 125         case RTM_NEWRULE:
 126         case RTM_DELRULE:
 127                 print_headers(fp, "[RULE]", ctrl);
 128                 print_rule(n, arg);
 129                 return 0;
 130
 131         case NLMSG_TSTAMP:
 132                 print_nlmsg_timestamp(fp, n);
 133                 return 0;
 134
 135         case RTM_NEWNETCONF:
 136         case RTM_DELNETCONF:
 137                 print_headers(fp, "[NETCONF]", ctrl);
 138                 print_netconf(ctrl, n, arg);
 139                 return 0;
 140
 141         case RTM_DELNSID:
 142         case RTM_NEWNSID:
 143                 print_headers(fp, "[NSID]", ctrl);
 144                 print_nsid(n, arg);
 145                 return 0;
 146
 147         case NLMSG_ERROR:
 148         case NLMSG_NOOP:
 149         case NLMSG_DONE:
 150                 break;  /* ignore */
 151
 152         default:
 153                 fprintf(stderr,
 154                         "Unknown message: type=0x%08x(%d) flags=0x%08x(%d) len=0x%08x(%d)\n",
 155                         n->nlmsg_type, n->nlmsg_type,
 156                         n->nlmsg_flags, n->nlmsg_flags, n->nlmsg_len,
 157                         n->nlmsg_len);
 158         }
 159         return 0;
 160 }
 161
 162 int do_ipmonitor(int argc, char **argv)
 163 {
 164         char *file = NULL;
 165         unsigned int groups = 0;
 166         int llink = 0;
 167         int laddr = 0;
 168         int lroute = 0;
 169         int lmroute = 0;
 170         int lprefix = 0;
 171         int lneigh = 0;
 172         int lnetconf = 0;
 173         int lrule = 0;
 174         int lnsid = 0;
 175         int ifindex = 0;
 176
 177         groups |= nl_mgrp(RTNLGRP_LINK);
 178         groups |= nl_mgrp(RTNLGRP_IPV4_IFADDR);
 179         groups |= nl_mgrp(RTNLGRP_IPV6_IFADDR);
 180         groups |= nl_mgrp(RTNLGRP_IPV4_ROUTE);
 181         groups |= nl_mgrp(RTNLGRP_IPV6_ROUTE);
 182         groups |= nl_mgrp(RTNLGRP_MPLS_ROUTE);
 183         groups |= nl_mgrp(RTNLGRP_IPV4_MROUTE);
 184         groups |= nl_mgrp(RTNLGRP_IPV6_MROUTE);
 185         groups |= nl_mgrp(RTNLGRP_IPV6_PREFIX);
 186         groups |= nl_mgrp(RTNLGRP_NEIGH);
 187         groups |= nl_mgrp(RTNLGRP_IPV4_NETCONF);
 188         groups |= nl_mgrp(RTNLGRP_IPV6_NETCONF);
 189         groups |= nl_mgrp(RTNLGRP_IPV4_RULE);
 190         groups |= nl_mgrp(RTNLGRP_IPV6_RULE);
 191         groups |= nl_mgrp(RTNLGRP_NSID);
 192         groups |= nl_mgrp(RTNLGRP_MPLS_NETCONF);
 193
 194         rtnl_close(&rth);
 195
 196         while (argc > 0) {
 197                 if (matches(*argv, "file") == 0) {
 198                         NEXT_ARG();
 199                         file = *argv;
 200                 } else if (matches(*argv, "label") == 0) {
 201                         prefix_banner = 1;
 202                 } else if (matches(*argv, "link") == 0) {
 203                         llink = 1;
 204                         groups = 0;
 205                 } else if (matches(*argv, "address") == 0) {
 206                         laddr = 1;
 207                         groups = 0;
 208                 } else if (matches(*argv, "route") == 0) {
 209                         lroute = 1;
 210                         groups = 0;
 211                 } else if (matches(*argv, "mroute") == 0) {
 212                         lmroute = 1;
 213                         groups = 0;
 214                 } else if (matches(*argv, "prefix") == 0) {
 215                         lprefix = 1;
 216                         groups = 0;
 217                 } else if (matches(*argv, "neigh") == 0) {
 218                         lneigh = 1;
 219                         groups = 0;
 220                 } else if (matches(*argv, "netconf") == 0) {
 221                         lnetconf = 1;
 222                         groups = 0;
 223                 } else if (matches(*argv, "rule") == 0) {
 224                         lrule = 1;
 225                         groups = 0;
 226                 } else if (matches(*argv, "nsid") == 0) {
 227                         lnsid = 1;
 228                         groups = 0;
 229                 } else if (strcmp(*argv, "all") == 0) {
 230                         prefix_banner = 1;
 231                 } else if (matches(*argv, "all-nsid") == 0) {
 232                         listen_all_nsid = 1;
 233                 } else if (matches(*argv, "help") == 0) {
 234                         usage();
 235                 } else if (strcmp(*argv, "dev") == 0) {
 236                         NEXT_ARG();
 237
 238                         ifindex = ll_name_to_index(*argv);
 239                         if (!ifindex)
 240                                 invarg("Device does not exist\n", *argv);
 241                 } else {
 242                         fprintf(stderr, "Argument \"%s\" is unknown, try \"ip monitor help\".\n", *argv);
 243                         exit(-1);
 244                 }
 245                 argc--; argv++;
 246         }
 247
 248         ipaddr_reset_filter(1, ifindex);
 249         iproute_reset_filter(ifindex);
 250         ipmroute_reset_filter(ifindex);
 251         ipneigh_reset_filter(ifindex);
 252         ipnetconf_reset_filter(ifindex);
 253
 254         if (llink)
 255                 groups |= nl_mgrp(RTNLGRP_LINK);
 256         if (laddr) {
 257                 if (!preferred_family || preferred_family == AF_INET)
 258                         groups |= nl_mgrp(RTNLGRP_IPV4_IFADDR);
 259                 if (!preferred_family || preferred_family == AF_INET6)
 260                         groups |= nl_mgrp(RTNLGRP_IPV6_IFADDR);
 261         }
 262         if (lroute) {
 263                 if (!preferred_family || preferred_family == AF_INET)
 264                         groups |= nl_mgrp(RTNLGRP_IPV4_ROUTE);
 265                 if (!preferred_family || preferred_family == AF_INET6)
 266                         groups |= nl_mgrp(RTNLGRP_IPV6_ROUTE);
 267                 if (!preferred_family || preferred_family == AF_MPLS)
 268                         groups |= nl_mgrp(RTNLGRP_MPLS_ROUTE);
 269         }
 270         if (lmroute) {
 271                 if (!preferred_family || preferred_family == AF_INET)
 272                         groups |= nl_mgrp(RTNLGRP_IPV4_MROUTE);
 273                 if (!preferred_family || preferred_family == AF_INET6)
 274                         groups |= nl_mgrp(RTNLGRP_IPV6_MROUTE);
 275         }
 276         if (lprefix) {
 277                 if (!preferred_family || preferred_family == AF_INET6)
 278                         groups |= nl_mgrp(RTNLGRP_IPV6_PREFIX);
 279         }
 280         if (lneigh) {
 281                 groups |= nl_mgrp(RTNLGRP_NEIGH);
 282         }
 283         if (lnetconf) {
 284                 if (!preferred_family || preferred_family == AF_INET)
 285                         groups |= nl_mgrp(RTNLGRP_IPV4_NETCONF);
 286                 if (!preferred_family || preferred_family == AF_INET6)
 287                         groups |= nl_mgrp(RTNLGRP_IPV6_NETCONF);
 288                 if (!preferred_family || preferred_family == AF_MPLS)
 289                         groups |= nl_mgrp(RTNLGRP_MPLS_NETCONF);
 290         }
 291         if (lrule) {
 292                 if (!preferred_family || preferred_family == AF_INET)
 293                         groups |= nl_mgrp(RTNLGRP_IPV4_RULE);
 294                 if (!preferred_family || preferred_family == AF_INET6)
 295                         groups |= nl_mgrp(RTNLGRP_IPV6_RULE);
 296         }
 297         if (lnsid) {
 298                 groups |= nl_mgrp(RTNLGRP_NSID);
 299         }
 300         if (file) {
 301                 FILE *fp;
 302                 int err;
 303
 304                 fp = fopen(file, "r");
 305                 if (fp == NULL) {
 306                         perror("Cannot fopen");
 307                         exit(-1);
 308                 }
 309                 err = rtnl_from_file(fp, accept_msg, stdout);
 310                 fclose(fp);
 311                 return err;
 312         }
 313
 314         if (rtnl_open(&rth, groups) < 0)
 315                 exit(1);
 316         if (listen_all_nsid && rtnl_listen_all_nsid(&rth) < 0)
 317                 exit(1);
 318
 319         ll_init_map(&rth);
 320         netns_nsid_socket_init();
 321         netns_map_init();
 322
 323         if (rtnl_listen(&rth, accept_msg, stdout) < 0)
 324                 exit(2);
 325
 326         return 0;
 327 }