babeld/babel_zebra.c

   1 /*
   2 Copyright 2011 by Matthieu Boutier and Juliusz Chroboczek
   3
   4 Permission is hereby granted, free of charge, to any person obtaining a copy
   5 of this software and associated documentation files (the "Software"), to deal
   6 in the Software without restriction, including without limitation the rights
   7 to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
   8 copies of the Software, and to permit persons to whom the Software is
   9 furnished to do so, subject to the following conditions:
  10
  11 The above copyright notice and this permission notice shall be included in
  12 all copies or substantial portions of the Software.
  13
  14 THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
  15 IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
  16 FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.  IN NO EVENT SHALL THE
  17 AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
  18 LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
  19 OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
  20 THE SOFTWARE.
  21 */
  22
  23 /* FRR's includes */
  24 #include <zebra.h>
  25 #include "command.h"
  26 #include "zclient.h"
  27 #include "stream.h"
  28
  29 /* babel's includes*/
  30 #include "babel_zebra.h"
  31 #include "babel_interface.h"
  32 #include "xroute.h"
  33 #include "util.h"
  34
  35 void babelz_zebra_init(void);
  36
  37
  38 /* we must use a pointer because of zclient.c's functions (new, free). */
  39 struct zclient *zclient;
  40
  41 /* Debug types */
  42 static struct {
  43     int type;
  44     int str_min_len;
  45     const char *str;
  46 } debug_type[] = {
  47     {BABEL_DEBUG_COMMON,  1, "common"},
  48     {BABEL_DEBUG_KERNEL,  1, "kernel"},
  49     {BABEL_DEBUG_FILTER,  1, "filter"},
  50     {BABEL_DEBUG_TIMEOUT, 1, "timeout"},
  51     {BABEL_DEBUG_IF,      1, "interface"},
  52     {BABEL_DEBUG_ROUTE,   1, "route"},
  53     {BABEL_DEBUG_ALL,     1, "all"},
  54     {0, 0, NULL}
  55 };
  56
  57 /* Zebra route add and delete treatment. */
  58 static int
  59 babel_zebra_read_route (int command, struct zclient *zclient,
  60                         zebra_size_t length, vrf_id_t vrf)
  61 {
  62     struct zapi_route api;
  63
  64     if (zapi_route_decode(zclient->ibuf, &api) < 0)
  65         return -1;
  66
  67     /* we completely ignore srcdest routes for now. */
  68     if (CHECK_FLAG(api.message, ZAPI_MESSAGE_SRCPFX))
  69         return 0;
  70
  71     if (command == ZEBRA_REDISTRIBUTE_ROUTE_ADD) {
  72         babel_route_add(&api);
  73     } else {
  74         babel_route_delete(&api);
  75     }
  76
  77     return 0;
  78 }
  79
  80 /* [Babel Command] */
  81 DEFUN (babel_redistribute_type,
  82        babel_redistribute_type_cmd,
  83        "[no] redistribute <ipv4 " FRR_IP_REDIST_STR_BABELD "|ipv6 " FRR_IP6_REDIST_STR_BABELD ">",
  84        NO_STR
  85        "Redistribute\n"
  86        "Redistribute IPv4 routes\n"
  87        FRR_IP_REDIST_HELP_STR_BABELD
  88        "Redistribute IPv6 routes\n"
  89        FRR_IP6_REDIST_HELP_STR_BABELD)
  90 {
  91     int negate = 0;
  92     int family;
  93     int afi;
  94     int type;
  95     int idx = 0;
  96
  97     if (argv_find(argv, argc, "no", &idx))
  98         negate = 1;
  99     argv_find(argv, argc, "redistribute", &idx);
 100     family = str2family(argv[idx + 1]->text);
 101     if (family < 0)
 102         return CMD_WARNING_CONFIG_FAILED;
 103
 104     afi = family2afi(family);
 105     if (!afi)
 106         return CMD_WARNING_CONFIG_FAILED;
 107
 108     type = proto_redistnum(afi, argv[idx + 2]->text);
 109     if (type < 0) {
 110         vty_out (vty, "Invalid type %s\n", argv[idx + 2]->arg);
 111         return CMD_WARNING_CONFIG_FAILED;
 112     }
 113
 114     if (!negate)
 115         zclient_redistribute (ZEBRA_REDISTRIBUTE_ADD, zclient, afi, type, 0, VRF_DEFAULT);
 116     else {
 117         zclient_redistribute (ZEBRA_REDISTRIBUTE_DELETE, zclient, afi, type, 0, VRF_DEFAULT);
 118         /* perhaps should we remove xroutes having the same type... */
 119     }
 120     return CMD_SUCCESS;
 121 }
 122
 123 #ifndef NO_DEBUG
 124 /* [Babel Command] */
 125 DEFUN (debug_babel,
 126        debug_babel_cmd,
 127        "debug babel <common|kernel|filter|timeout|interface|route|all>",
 128        "Enable debug messages for specific or all part.\n"
 129        "Babel information\n"
 130        "Common messages (default)\n"
 131        "Kernel messages\n"
 132        "Filter messages\n"
 133        "Timeout messages\n"
 134        "Interface messages\n"
 135        "Route messages\n"
 136        "All messages\n")
 137 {
 138     int i;
 139
 140     for(i = 0; debug_type[i].str != NULL; i++) {
 141         if (strncmp (debug_type[i].str, argv[2]->arg,
 142                      debug_type[i].str_min_len) == 0) {
 143             debug |= debug_type[i].type;
 144             return CMD_SUCCESS;
 145         }
 146     }
 147
 148     vty_out (vty, "Invalid type %s\n", argv[2]->arg);
 149
 150     return CMD_WARNING_CONFIG_FAILED;
 151 }
 152
 153 /* [Babel Command] */
 154 DEFUN (no_debug_babel,
 155        no_debug_babel_cmd,
 156        "no debug babel <common|kernel|filter|timeout|interface|route|all>",
 157        NO_STR
 158        "Disable debug messages for specific or all part.\n"
 159        "Babel information\n"
 160        "Common messages (default)\n"
 161        "Kernel messages\n"
 162        "Filter messages\n"
 163        "Timeout messages\n"
 164        "Interface messages\n"
 165        "Route messages\n"
 166        "All messages\n")
 167 {
 168     int i;
 169
 170     for (i = 0; debug_type[i].str; i++) {
 171         if (strncmp(debug_type[i].str, argv[3]->arg,
 172                     debug_type[i].str_min_len) == 0) {
 173             debug &= ~debug_type[i].type;
 174             return CMD_SUCCESS;
 175         }
 176     }
 177
 178     vty_out (vty, "Invalid type %s\n", argv[3]->arg);
 179
 180     return CMD_WARNING_CONFIG_FAILED;
 181 }
 182 #endif /* NO_DEBUG */
 183
 184 /* Output "debug" statement lines, if necessary. */
 185 int
 186 debug_babel_config_write (struct vty * vty)
 187 {
 188 #ifdef NO_DEBUG
 189     return 0;
 190 #else
 191     int i, lines = 0;
 192
 193     if (debug == BABEL_DEBUG_ALL)
 194     {
 195         vty_out (vty, "debug babel all\n");
 196         lines++;
 197     }
 198     else
 199         for (i = 0; debug_type[i].str != NULL; i++)
 200             if
 201             (
 202                 debug_type[i].type != BABEL_DEBUG_ALL
 203                 && CHECK_FLAG (debug, debug_type[i].type)
 204             )
 205             {
 206                 vty_out (vty, "debug babel %s\n", debug_type[i].str);
 207                 lines++;
 208             }
 209     if (lines)
 210     {
 211         vty_out (vty, "!\n");
 212         lines++;
 213     }
 214     return lines;
 215 #endif /* NO_DEBUG */
 216 }
 217
 218 DEFUN_NOSH (show_debugging_babel,
 219             show_debugging_babel_cmd,
 220             "show debugging [babel]",
 221             SHOW_STR
 222             DEBUG_STR
 223             "Babel")
 224 {
 225         vty_out(vty, "BABEL debugging status\n");
 226
 227         debug_babel_config_write(vty);
 228
 229         return CMD_SUCCESS;
 230 }
 231
 232 static void
 233 babel_zebra_connected (struct zclient *zclient)
 234 {
 235   zclient_send_reg_requests (zclient, VRF_DEFAULT);
 236 }
 237
 238 void babelz_zebra_init(void)
 239 {
 240     zclient = zclient_new(master, &zclient_options_default);
 241     zclient_init(zclient, ZEBRA_ROUTE_BABEL, 0, &babeld_privs);
 242
 243     zclient->zebra_connected = babel_zebra_connected;
 244     zclient->interface_add = babel_interface_add;
 245     zclient->interface_delete = babel_interface_delete;
 246     zclient->interface_up = babel_interface_up;
 247     zclient->interface_down = babel_interface_down;
 248     zclient->interface_address_add = babel_interface_address_add;
 249     zclient->interface_address_delete = babel_interface_address_delete;
 250     zclient->redistribute_route_add = babel_zebra_read_route;
 251     zclient->redistribute_route_del = babel_zebra_read_route;
 252
 253     install_element(BABEL_NODE, &babel_redistribute_type_cmd);
 254     install_element(ENABLE_NODE, &debug_babel_cmd);
 255     install_element(ENABLE_NODE, &no_debug_babel_cmd);
 256     install_element(CONFIG_NODE, &debug_babel_cmd);
 257     install_element(CONFIG_NODE, &no_debug_babel_cmd);
 258
 259     install_element(VIEW_NODE, &show_debugging_babel_cmd);
 260 }
 261
 262 void
 263 babel_zebra_close_connexion(void)
 264 {
 265     zclient_stop(zclient);
 266     zclient_free(zclient);
 267 }