src/interfaces.c

   1
   2 /*
   3  * The olsr.org Optimized Link-State Routing daemon(olsrd)
   4  * Copyright (c) 2004, Andreas Tonnesen(andreto@olsr.org)
   5  * All rights reserved.
   6  *
   7  * Redistribution and use in source and binary forms, with or without
   8  * modification, are permitted provided that the following conditions
   9  * are met:
  10  *
  11  * * Redistributions of source code must retain the above copyright
  12  *   notice, this list of conditions and the following disclaimer.
  13  * * Redistributions in binary form must reproduce the above copyright
  14  *   notice, this list of conditions and the following disclaimer in
  15  *   the documentation and/or other materials provided with the
  16  *   distribution.
  17  * * Neither the name of olsr.org, olsrd nor the names of its
  18  *   contributors may be used to endorse or promote products derived
  19  *   from this software without specific prior written permission.
  20  *
  21  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
  22  * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
  23  * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
  24  * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
  25  * COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
  26  * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING,
  27  * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
  28  * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
  29  * CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
  30  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN
  31  * ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
  32  * POSSIBILITY OF SUCH DAMAGE.
  33  *
  34  * Visit http://www.olsr.org for more information.
  35  *
  36  * If you find this software useful feel free to make a donation
  37  * to the project. For more information see the website or contact
  38  * the copyright holders.
  39  *
  40  */
  41
  42 #include "defs.h"
  43 #include "interfaces.h"
  44 #include "ifnet.h"
  45 #include "scheduler.h"
  46 #include "olsr.h"
  47 #include "net_olsr.h"
  48 #include "ipcalc.h"
  49 #include "log.h"
  50 #include "parser.h"
  51 #include "socket_parser.h"
  52
  53 #include <signal.h>
  54 #include <sys/types.h>
  55 #include <net/if.h>
  56 #include <net/if_arp.h>
  57 #include <netinet/in_systm.h>
  58 #include <netinet/ip.h>
  59 #include <arpa/inet.h>
  60 #include <netdb.h>
  61 #include <unistd.h>
  62
  63 /* The interface linked-list */
  64 struct interface *ifnet;
  65
  66 /* Ifchange functions */
  67 struct ifchgf {
  68   int (*function) (struct interface *, int);
  69   struct ifchgf *next;
  70 };
  71
  72 static struct ifchgf *ifchgf_list;
  73
  74 /* Some cookies for stats keeping */
  75 struct olsr_cookie_info *interface_poll_timer_cookie = NULL;
  76 struct olsr_cookie_info *hello_gen_timer_cookie = NULL;
  77 struct olsr_cookie_info *tc_gen_timer_cookie = NULL;
  78 struct olsr_cookie_info *mid_gen_timer_cookie = NULL;
  79 struct olsr_cookie_info *hna_gen_timer_cookie = NULL;
  80
  81 /**
  82  *Do initialization of various data needed for
  83  *network interface management.
  84  *This function also tries to set up the given interfaces.
  85  *
  86  *@return the number of interfaces configured
  87  */
  88 int
  89 olsr_init_interfacedb(void)
  90 {
  91   struct olsr_if *tmp_if;
  92
  93   /* Initial values */
  94   ifnet = NULL;
  95
  96   /*
  97    * Get some cookies for getting stats to ease troubleshooting.
  98    */
  99   interface_poll_timer_cookie = olsr_alloc_cookie("Interface Polling", OLSR_COOKIE_TYPE_TIMER);
 100
 101   hello_gen_timer_cookie = olsr_alloc_cookie("Hello Generation", OLSR_COOKIE_TYPE_TIMER);
 102   tc_gen_timer_cookie = olsr_alloc_cookie("TC Generation", OLSR_COOKIE_TYPE_TIMER);
 103   mid_gen_timer_cookie = olsr_alloc_cookie("MID Generation", OLSR_COOKIE_TYPE_TIMER);
 104   hna_gen_timer_cookie = olsr_alloc_cookie("HNA Generation", OLSR_COOKIE_TYPE_TIMER);
 105
 106   OLSR_PRINTF(1, "\n ---- Interface configuration ---- \n\n");
 107   /* Run trough all interfaces immedeatly */
 108   for (tmp_if = olsr_cnf->interfaces; tmp_if != NULL; tmp_if = tmp_if->next) {
 109     if (!tmp_if->host_emul) {
 110       if (!olsr_cnf->host_emul) /* XXX: TEMPORARY! */
 111         chk_if_up(tmp_if, 1);
 112     } else {
 113       add_hemu_if(tmp_if);
 114     }
 115   }
 116
 117   /* Kick a periodic timer for the network interface update function */
 118   olsr_start_timer((unsigned int)olsr_cnf->nic_chgs_pollrate * MSEC_PER_SEC, 5, OLSR_TIMER_PERIODIC, &check_interface_updates, NULL,
 119                    interface_poll_timer_cookie->ci_id);
 120
 121   return (ifnet == NULL) ? 0 : 1;
 122 }
 123
 124 void
 125 olsr_trigger_ifchange(struct interface *ifp, int flag)
 126 {
 127   struct ifchgf *tmp_ifchgf_list = ifchgf_list;
 128
 129   while (tmp_ifchgf_list != NULL) {
 130     tmp_ifchgf_list->function(ifp, flag);
 131     tmp_ifchgf_list = tmp_ifchgf_list->next;
 132   }
 133 }
 134
 135 /**
 136  *Find the local interface with a given address.
 137  *
 138  *@param addr the address to check.
 139  *
 140  *@return the interface struct representing the interface
 141  *that matched the address.
 142  */
 143
 144 struct interface *
 145 if_ifwithaddr(const union olsr_ip_addr *addr)
 146 {
 147   struct interface *ifp;
 148
 149   if (!addr)
 150     return NULL;
 151
 152   for (ifp = ifnet; ifp; ifp = ifp->int_next) {
 153     if (olsr_cnf->ip_version == AF_INET) {
 154       /* IPv4 */
 155       //printf("Checking: %s == ", inet_ntoa(((struct sockaddr_in *)&ifp->int_addr)->sin_addr));
 156       //printf("%s\n", olsr_ip_to_string(addr));
 157
 158       if (((struct sockaddr_in *)&ifp->int_addr)->sin_addr.s_addr == addr->v4.s_addr)
 159         return ifp;
 160     } else {
 161       /* IPv6 */
 162       //printf("Checking %s ", olsr_ip_to_string((union olsr_ip_addr *)&ifp->int6_addr.sin6_addr));
 163       //printf("== %s\n", olsr_ip_to_string((union olsr_ip_addr *)&((struct sockaddr_in6 *)addr)->sin6_addr));
 164       if (ip6equal(&ifp->int6_addr.sin6_addr, &addr->v6))
 165         return ifp;
 166     }
 167   }
 168   return NULL;
 169 }
 170
 171 /**
 172  *Find the interface with a given number.
 173  *
 174  *@param nr the number of the interface to find.
 175  *
 176  *@return return the interface struct representing the interface
 177  *that matched the number.
 178  */
 179 struct interface *
 180 if_ifwithsock(int fd)
 181 {
 182   struct interface *ifp;
 183   ifp = ifnet;
 184
 185   while (ifp) {
 186     if (ifp->olsr_socket == fd || ifp->send_socket == fd)
 187       return ifp;
 188     ifp = ifp->int_next;
 189   }
 190
 191   return NULL;
 192 }
 193
 194 /**
 195  *Find the interface with a given label.
 196  *
 197  *@param if_name the label of the interface to find.
 198  *
 199  *@return return the interface struct representing the interface
 200  *that matched the label.
 201  */
 202 struct interface *
 203 if_ifwithname(const char *if_name)
 204 {
 205   struct interface *ifp = ifnet;
 206   while (ifp) {
 207     /* good ol' strcmp should be sufficcient here */
 208     if (strcmp(ifp->int_name, if_name) == 0) {
 209       return ifp;
 210     }
 211     ifp = ifp->int_next;
 212   }
 213   return NULL;
 214 }
 215
 216 /**
 217  *Find the interface with a given interface index.
 218  *
 219  *@param iif_index of the interface to find.
 220  *
 221  *@return return the interface struct representing the interface
 222  *that matched the iif_index.
 223  */
 224 struct interface *
 225 if_ifwithindex(const int if_index)
 226 {
 227   struct interface *ifp = ifnet;
 228   while (ifp != NULL) {
 229     if (ifp->if_index == if_index) {
 230       return ifp;
 231     }
 232     ifp = ifp->int_next;
 233   }
 234   return NULL;
 235 }
 236
 237 /**
 238  *Get an interface name for a given interface index
 239  *
 240  *@param iif_index of the interface to find.
 241  *
 242  *@return "" or interface name.
 243  */
 244 const char *
 245 if_ifwithindex_name(const int if_index)
 246 {
 247   const struct interface *const ifp = if_ifwithindex(if_index);
 248   return ifp == NULL ? "void" : ifp->int_name;
 249 }
 250
 251 /**
 252  *Create a new interf_name struct using a given
 253  *name and insert it into the interface list.
 254  *
 255  *@param name the name of the interface.
 256  *
 257  *@return nada
 258  */
 259 struct olsr_if *
 260 olsr_create_olsrif(const char *name, int hemu)
 261 {
 262   struct olsr_if *interf_n = olsr_cnf->interfaces;
 263   size_t name_size;
 264
 265   //printf("Adding interface %s\n", name);
 266
 267   /* check if the inerfaces already exists */
 268   while (interf_n != NULL) {
 269     if (strcmp(interf_n->name, name) == 0) {
 270       fprintf(stderr, "Duplicate interfaces defined... not adding %s\n", name);
 271       return NULL;
 272     }
 273     interf_n = interf_n->next;
 274   }
 275
 276   interf_n = olsr_malloc(sizeof(struct olsr_if), "queue interface");
 277
 278   name_size = strlen(name) + 1;
 279   interf_n->name = olsr_malloc(name_size, "queue interface name");
 280   strscpy(interf_n->name, name, name_size);
 281
 282   interf_n->cnf = olsr_malloc(sizeof(*interf_n->cnf), "queue cnf");
 283
 284   interf_n->cnfi = olsr_malloc(sizeof(*interf_n->cnfi), "queue cnfi");
 285   memset(interf_n->cnfi, 0xFF, sizeof(*interf_n->cnfi));
 286   interf_n->cnfi->orig_lq_mult_cnt=0;
 287
 288   interf_n->host_emul = hemu ? true : false;
 289
 290   interf_n->next = olsr_cnf->interfaces;
 291   olsr_cnf->interfaces = interf_n;
 292
 293   return interf_n;
 294 }
 295
 296 /**
 297  *Add an ifchange function. These functions are called on all (non-initial)
 298  *changes in the interface set.
 299  *
 300  *@param
 301  *
 302  *@return
 303  */
 304 int
 305 olsr_add_ifchange_handler(int (*f) (struct interface *, int))
 306 {
 307
 308   struct ifchgf *new_ifchgf;
 309
 310   new_ifchgf = olsr_malloc(sizeof(struct ifchgf), "Add ifchgfunction");
 311
 312   new_ifchgf->next = ifchgf_list;
 313   new_ifchgf->function = f;
 314
 315   ifchgf_list = new_ifchgf;
 316
 317   return 1;
 318 }
 319
 320 /*
 321  * Remove an ifchange function
 322  */
 323 int
 324 olsr_remove_ifchange_handler(int (*f) (struct interface *, int))
 325 {
 326   struct ifchgf *tmp_ifchgf, *prev;
 327
 328   tmp_ifchgf = ifchgf_list;
 329   prev = NULL;
 330
 331   while (tmp_ifchgf) {
 332     if (tmp_ifchgf->function == f) {
 333       /* Remove entry */
 334       if (prev == NULL) {
 335         ifchgf_list = tmp_ifchgf->next;
 336         free(tmp_ifchgf);
 337       } else {
 338         prev->next = tmp_ifchgf->next;
 339         free(tmp_ifchgf);
 340       }
 341       return 1;
 342     }
 343     prev = tmp_ifchgf;
 344     tmp_ifchgf = tmp_ifchgf->next;
 345   }
 346
 347   return 0;
 348 }
 349
 350 void
 351 olsr_remove_interface(struct olsr_if * iface, bool went_down)
 352 {
 353   struct interface *ifp, *tmp_ifp;
 354   struct rt_entry *rt;
 355   ifp = iface->interf;
 356
 357   OLSR_PRINTF(1, "Removing interface %s\n", iface->name);
 358   olsr_syslog(OLSR_LOG_INFO, "Removing interface %s\n", iface->name);
 359
 360   olsr_delete_link_entry_by_ip(&ifp->ip_addr);
 361
 362   /*
 363    *Call possible ifchange functions registered by plugins
 364    */
 365   olsr_trigger_ifchange(ifp, IFCHG_IF_REMOVE);
 366
 367   /*remove all routes*/
 368   if (went_down) {
 369     OLSR_FOR_ALL_RT_ENTRIES(rt) {
 370       if (rt->rt_nexthop.iif_index == ifp->if_index) {
 371         //marks route as unexisting in kernel, do this better !?
 372         rt->rt_nexthop.iif_index=-1;
 373       }
 374     }
 375     OLSR_FOR_ALL_RT_ENTRIES_END(rt);
 376   }
 377
 378   /* Dequeue */
 379   if (ifp == ifnet) {
 380     ifnet = ifp->int_next;
 381   } else {
 382     tmp_ifp = ifnet;
 383     while (tmp_ifp->int_next != ifp) {
 384       tmp_ifp = tmp_ifp->int_next;
 385     }
 386     tmp_ifp->int_next = ifp->int_next;
 387   }
 388
 389   /* Remove output buffer */
 390   net_remove_buffer(ifp);
 391
 392   /* Check main addr */
 393   /* deactivated to prevent change of originator IP */
 394 #if 0
 395   if (ipequal(&olsr_cnf->main_addr, &ifp->ip_addr)) {
 396     if (ifnet == NULL) {
 397       /* No more interfaces */
 398       memset(&olsr_cnf->main_addr, 0, olsr_cnf->ipsize);
 399       OLSR_PRINTF(1, "No more interfaces...\n");
 400     } else {
 401       struct ipaddr_str buf;
 402       olsr_cnf->main_addr = ifnet->ip_addr;
 403       OLSR_PRINTF(1, "New main address: %s\n", olsr_ip_to_string(&buf, &olsr_cnf->main_addr));
 404       olsr_syslog(OLSR_LOG_INFO, "New main address: %s\n", olsr_ip_to_string(&buf, &olsr_cnf->main_addr));
 405     }
 406   }
 407 #endif
 408   /*
 409    * Deregister functions for periodic message generation
 410    */
 411   olsr_stop_timer(ifp->hello_gen_timer);
 412   olsr_stop_timer(ifp->tc_gen_timer);
 413   olsr_stop_timer(ifp->mid_gen_timer);
 414   olsr_stop_timer(ifp->hna_gen_timer);
 415
 416   iface->configured = 0;
 417   iface->interf = NULL;
 418   /* Close olsr socket */
 419   close(ifp->olsr_socket);
 420   remove_olsr_socket(ifp->olsr_socket, &olsr_input);
 421
 422   /* Free memory */
 423   free(ifp->int_name);
 424   free(ifp);
 425
 426   if ((ifnet == NULL) && (!olsr_cnf->allow_no_interfaces)) {
 427     OLSR_PRINTF(1, "No more active interfaces - exiting.\n");
 428     olsr_syslog(OLSR_LOG_INFO, "No more active interfaces - exiting.\n");
 429     olsr_cnf->exit_value = EXIT_FAILURE;
 430 #ifndef win32
 431     kill(getpid(), SIGINT);
 432 #else
 433     CallSignalHandler();
 434 #endif
 435   }
 436 }
 437
 438 /*
 439  * Local Variables:
 440  * c-basic-offset: 2
 441  * indent-tabs-mode: nil
 442  * End:
 443  */