]> git.proxmox.com Git - mirror_frr.git/blobdiff - bgpd/bgp_table.c
lib, bgpd: implement pthread lifecycle management
[mirror_frr.git] / bgpd / bgp_table.c
index 5b8c6a490b07bef4e4ab811b4ecc218c1606ecfd..261ab9f76dc0d5af9a2c94fbdfade45f4bf79570 100644 (file)
 /* BGP routing table
  Copyright (C) 1998, 2001 Kunihiro Ishiguro
-
-This file is part of GNU Zebra.
-
-GNU Zebra is free software; you can redistribute it and/or modify it
-under the terms of the GNU General Public License as published by the
-Free Software Foundation; either version 2, or (at your option) any
-later version.
-
-GNU Zebra is distributed in the hope that it will be useful, but
-WITHOUT ANY WARRANTY; without even the implied warranty of
-MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
-General Public License for more details.
-
-You should have received a copy of the GNU General Public License
-along with GNU Zebra; see the file COPYING.  If not, write to the Free
-Software Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA
-02111-1307, USA.  */
* Copyright (C) 1998, 2001 Kunihiro Ishiguro
+ *
+ * This file is part of GNU Zebra.
+ *
+ * GNU Zebra is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU General Public License as published by the
+ * Free Software Foundation; either version 2, or (at your option) any
+ * later version.
+ *
+ * GNU Zebra is distributed in the hope that it will be useful, but
+ * WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License along
+ * with this program; see the file COPYING; if not, write to the Free Software
+ * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
+ */
 
 #include <zebra.h>
 
 #include "prefix.h"
 #include "memory.h"
 #include "sockunion.h"
-#include "vty.h"
+#include "queue.h"
+#include "filter.h"
+#include "command.h"
 
 #include "bgpd/bgpd.h"
 #include "bgpd/bgp_table.h"
 
-static void bgp_node_delete (struct bgp_node *);
-static void bgp_table_free (struct bgp_table *);
-\f
-struct bgp_table *
-bgp_table_init (afi_t afi, safi_t safi)
-{
-  struct bgp_table *rt;
-
-  rt = XCALLOC (MTYPE_BGP_TABLE, sizeof (struct bgp_table));
-
-  bgp_table_lock(rt);
-  rt->type = BGP_TABLE_MAIN;
-  rt->afi = afi;
-  rt->safi = safi;
-  
-  return rt;
-}
-
-void
-bgp_table_lock (struct bgp_table *rt)
-{
-  rt->lock++;
-}
-
-void
-bgp_table_unlock (struct bgp_table *rt)
-{
-  assert (rt->lock > 0);
-  rt->lock--;
-
-  if (rt->lock == 0)
-    bgp_table_free (rt);
-}
-
-void
-bgp_table_finish (struct bgp_table **rt)
-{
-  if (*rt != NULL)
-    {
-      bgp_table_unlock(*rt);
-      *rt = NULL;
-    }
-}
-
-static struct bgp_node *
-bgp_node_create (void)
-{
-  return XCALLOC (MTYPE_BGP_NODE, sizeof (struct bgp_node));
-}
-
-/* Allocate new route node with prefix set. */
-static struct bgp_node *
-bgp_node_set (struct bgp_table *table, struct prefix *prefix)
+void bgp_table_lock(struct bgp_table *rt)
 {
-  struct bgp_node *node;
-  
-  node = bgp_node_create ();
-
-  prefix_copy (&node->p, prefix);
-  node->table = table;
-
-  return node;
+       rt->lock++;
 }
 
-/* Free route node. */
-static void
-bgp_node_free (struct bgp_node *node)
+void bgp_table_unlock(struct bgp_table *rt)
 {
-  XFREE (MTYPE_BGP_NODE, node);
-}
-
-/* Free route table. */
-static void
-bgp_table_free (struct bgp_table *rt)
-{
-  struct bgp_node *tmp_node;
-  struct bgp_node *node;
-  if (rt == NULL)
-    return;
-
-  node = rt->top;
+       assert(rt->lock > 0);
+       rt->lock--;
 
-  /* Bulk deletion of nodes remaining in this table.  This function is not
-     called until workers have completed their dependency on this table.
-     A final bgp_unlock_node() will not be called for these nodes. */
-  while (node)
-    {
-      if (node->l_left)
-       {
-         node = node->l_left;
-         continue;
+       if (rt->lock != 0) {
+               return;
        }
 
-      if (node->l_right)
-       {
-         node = node->l_right;
-         continue;
-       }
-
-      tmp_node = node;
-      node = node->parent;
-
-      tmp_node->table->count--;
-      tmp_node->lock = 0;  /* to cause assert if unlocked after this */
-      bgp_node_free (tmp_node);
-
-      if (node != NULL)
-       {
-         if (node->l_left == tmp_node)
-           node->l_left = NULL;
-         else
-           node->l_right = NULL;
-       }
-      else
-       {
-         break;
-       }
-    }
-  assert (rt->count == 0);
-
-  if (rt->owner)
-    {
-      peer_unlock (rt->owner);
-      rt->owner = NULL;
-    }
+       route_table_finish(rt->route_table);
+       rt->route_table = NULL;
 
-  XFREE (MTYPE_BGP_TABLE, rt);
-  return;
+       XFREE(MTYPE_BGP_TABLE, rt);
 }
 
-/* Utility mask array. */
-static u_char maskbit[] = 
+void bgp_table_finish(struct bgp_table **rt)
 {
-  0x00, 0x80, 0xc0, 0xe0, 0xf0, 0xf8, 0xfc, 0xfe, 0xff
-};
-
-/* Common prefix route genaration. */
-static void
-route_common (struct prefix *n, struct prefix *p, struct prefix *new)
-{
-  int i;
-  u_char diff;
-  u_char mask;
-
-  u_char *np = (u_char *)&n->u.prefix;
-  u_char *pp = (u_char *)&p->u.prefix;
-  u_char *newp = (u_char *)&new->u.prefix;
-
-  for (i = 0; i < p->prefixlen / 8; i++)
-    {
-      if (np[i] == pp[i])
-       newp[i] = np[i];
-      else
-       break;
-    }
-
-  new->prefixlen = i * 8;
-
-  if (new->prefixlen != p->prefixlen)
-    {
-      diff = np[i] ^ pp[i];
-      mask = 0x80;
-      while (new->prefixlen < p->prefixlen && !(mask & diff))
-       {
-         mask >>= 1;
-         new->prefixlen++;
+       if (*rt != NULL) {
+               bgp_table_unlock(*rt);
+               *rt = NULL;
        }
-      newp[i] = np[i] & maskbit[new->prefixlen % 8];
-    }
 }
 
-/* Macro version of check_bit (). */
-#define CHECK_BIT(X,P) ((((u_char *)(X))[(P) / 8]) >> (7 - ((P) % 8)) & 1)
-
-/* Check bit of the prefix. */
-static int
-check_bit (u_char *prefix, u_char prefixlen)
+/*
+ * bgp_node_create
+ */
+static struct route_node *bgp_node_create(route_table_delegate_t *delegate,
+                                         struct route_table *table)
 {
-  int offset;
-  int shift;
-  u_char *p = (u_char *)prefix;
-
-  assert (prefixlen <= 128);
-
-  offset = prefixlen / 8;
-  shift = 7 - (prefixlen % 8);
-  
-  return (p[offset] >> shift & 1);
+       struct bgp_node *node;
+       node = XCALLOC(MTYPE_BGP_NODE, sizeof(struct bgp_node));
+       return bgp_node_to_rnode(node);
 }
 
-/* Macro version of set_link (). */
-#define SET_LINK(X,Y) (X)->link[CHECK_BIT(&(Y)->prefix,(X)->prefixlen)] = (Y);\
-                      (Y)->parent = (X)
-
-static void
-set_link (struct bgp_node *node, struct bgp_node *new)
+/*
+ * bgp_node_destroy
+ */
+static void bgp_node_destroy(route_table_delegate_t *delegate,
+                            struct route_table *table, struct route_node *node)
 {
-  int bit;
-    
-  bit = check_bit (&new->p.u.prefix, node->p.prefixlen);
-
-  assert (bit == 0 || bit == 1);
-
-  node->link[bit] = new;
-  new->parent = node;
+       struct bgp_node *bgp_node;
+       bgp_node = bgp_node_from_rnode(node);
+       XFREE(MTYPE_BGP_NODE, bgp_node);
 }
 
-/* Lock node. */
-struct bgp_node *
-bgp_lock_node (struct bgp_node *node)
-{
-  node->lock++;
-  return node;
-}
+/*
+ * Function vector to customize the behavior of the route table
+ * library for BGP route tables.
+ */
+route_table_delegate_t bgp_table_delegate = {.create_node = bgp_node_create,
+                                            .destroy_node = bgp_node_destroy};
 
-/* Unlock node. */
-void
-bgp_unlock_node (struct bgp_node *node)
+/*
+ * bgp_table_init
+ */
+struct bgp_table *bgp_table_init(afi_t afi, safi_t safi)
 {
-  assert (node->lock > 0);
-  node->lock--;
+       struct bgp_table *rt;
 
-  if (node->lock == 0)
-    bgp_node_delete (node);
-}
-
-/* Find matched prefix. */
-struct bgp_node *
-bgp_node_match (const struct bgp_table *table, struct prefix *p)
-{
-  struct bgp_node *node;
-  struct bgp_node *matched;
+       rt = XCALLOC(MTYPE_BGP_TABLE, sizeof(struct bgp_table));
 
-  matched = NULL;
-  node = table->top;
+       rt->route_table = route_table_init_with_delegate(&bgp_table_delegate);
 
-  /* Walk down tree.  If there is matched route then store it to
-     matched. */
-  while (node && node->p.prefixlen <= p->prefixlen && 
-        prefix_match (&node->p, p))
-    {
-      if (node->info)
-       matched = node;
-      node = node->link[check_bit(&p->u.prefix, node->p.prefixlen)];
-    }
+       /*
+        * Set up back pointer to bgp_table.
+        */
+       rt->route_table->info = rt;
 
-  /* If matched route found, return it. */
-  if (matched)
-    return bgp_lock_node (matched);
+       bgp_table_lock(rt);
+       rt->afi = afi;
+       rt->safi = safi;
 
-  return NULL;
-}
-
-struct bgp_node *
-bgp_node_match_ipv4 (const struct bgp_table *table, struct in_addr *addr)
-{
-  struct prefix_ipv4 p;
-
-  memset (&p, 0, sizeof (struct prefix_ipv4));
-  p.family = AF_INET;
-  p.prefixlen = IPV4_MAX_PREFIXLEN;
-  p.prefix = *addr;
-
-  return bgp_node_match (table, (struct prefix *) &p);
-}
-
-#ifdef HAVE_IPV6
-struct bgp_node *
-bgp_node_match_ipv6 (const struct bgp_table *table, struct in6_addr *addr)
-{
-  struct prefix_ipv6 p;
-
-  memset (&p, 0, sizeof (struct prefix_ipv6));
-  p.family = AF_INET6;
-  p.prefixlen = IPV6_MAX_PREFIXLEN;
-  p.prefix = *addr;
-
-  return bgp_node_match (table, (struct prefix *) &p);
-}
-#endif /* HAVE_IPV6 */
-
-/* Lookup same prefix node.  Return NULL when we can't find route. */
-struct bgp_node *
-bgp_node_lookup (const struct bgp_table *table, struct prefix *p)
-{
-  struct bgp_node *node;
-
-  node = table->top;
-
-  while (node && node->p.prefixlen <= p->prefixlen && 
-        prefix_match (&node->p, p))
-    {
-      if (node->p.prefixlen == p->prefixlen && node->info)
-       return bgp_lock_node (node);
-
-      node = node->link[check_bit(&p->u.prefix, node->p.prefixlen)];
-    }
-
-  return NULL;
-}
-
-/* Add node to routing table. */
-struct bgp_node *
-bgp_node_get (struct bgp_table *const table, struct prefix *p)
-{
-  struct bgp_node *new;
-  struct bgp_node *node;
-  struct bgp_node *match;
-
-  match = NULL;
-  node = table->top;
-  while (node && node->p.prefixlen <= p->prefixlen && 
-        prefix_match (&node->p, p))
-    {
-      if (node->p.prefixlen == p->prefixlen)
-       {
-         bgp_lock_node (node);
-         return node;
-       }
-      match = node;
-      node = node->link[check_bit(&p->u.prefix, node->p.prefixlen)];
-    }
-
-  if (node == NULL)
-    {
-      new = bgp_node_set (table, p);
-      if (match)
-       set_link (match, new);
-      else
-       table->top = new;
-    }
-  else
-    {
-      new = bgp_node_create ();
-      route_common (&node->p, p, &new->p);
-      new->p.family = p->family;
-      new->table = table;
-      set_link (new, node);
-
-      if (match)
-       set_link (match, new);
-      else
-       table->top = new;
-
-      if (new->p.prefixlen != p->prefixlen)
-       {
-         match = new;
-         bgp_lock_node (match);
-         new = bgp_node_set (table, p);
-         set_link (match, new);
-         table->count++;
-       }
-    }
-  table->count++;
-  bgp_lock_node (new);
-  
-  return new;
-}
-
-/* Delete node from the routing table. */
-static void
-bgp_node_delete (struct bgp_node *node)
-{
-  struct bgp_node *child;
-  struct bgp_node *parent;
-
-  assert (node->lock == 0);
-  assert (node->info == NULL);
-
-  if (node->l_left && node->l_right)
-    return;
-
-  if (node->l_left)
-    child = node->l_left;
-  else
-    child = node->l_right;
-
-  parent = node->parent;
-
-  if (child)
-    child->parent = parent;
-
-  if (parent)
-    {
-      if (parent->l_left == node)
-       parent->l_left = child;
-      else
-       parent->l_right = child;
-    }
-  else
-    node->table->top = child;
-  
-  node->table->count--;
-  
-  bgp_node_free (node);
-
-  /* If parent node is stub then delete it also. */
-  if (parent && parent->lock == 0)
-    bgp_node_delete (parent);
-}
-
-/* Get fist node and lock it.  This function is useful when one want
-   to lookup all the node exist in the routing table. */
-struct bgp_node *
-bgp_table_top (const struct bgp_table *const table)
-{
-  /* If there is no node in the routing table return NULL. */
-  if (table->top == NULL)
-    return NULL;
-
-  /* Lock the top node and return it. */
-  bgp_lock_node (table->top);
-  return table->top;
-}
-
-/* Unlock current node and lock next node then return it. */
-struct bgp_node *
-bgp_route_next (struct bgp_node *node)
-{
-  struct bgp_node *next;
-  struct bgp_node *start;
-
-  /* Node may be deleted from bgp_unlock_node so we have to preserve
-     next node's pointer. */
-
-  if (node->l_left)
-    {
-      next = node->l_left;
-      bgp_lock_node (next);
-      bgp_unlock_node (node);
-      return next;
-    }
-  if (node->l_right)
-    {
-      next = node->l_right;
-      bgp_lock_node (next);
-      bgp_unlock_node (node);
-      return next;
-    }
-
-  start = node;
-  while (node->parent)
-    {
-      if (node->parent->l_left == node && node->parent->l_right)
-       {
-         next = node->parent->l_right;
-         bgp_lock_node (next);
-         bgp_unlock_node (start);
-         return next;
-       }
-      node = node->parent;
-    }
-  bgp_unlock_node (start);
-  return NULL;
-}
-
-/* Unlock current node and lock next node until limit. */
-struct bgp_node *
-bgp_route_next_until (struct bgp_node *node, struct bgp_node *limit)
-{
-  struct bgp_node *next;
-  struct bgp_node *start;
-
-  /* Node may be deleted from bgp_unlock_node so we have to preserve
-     next node's pointer. */
-
-  if (node->l_left)
-    {
-      next = node->l_left;
-      bgp_lock_node (next);
-      bgp_unlock_node (node);
-      return next;
-    }
-  if (node->l_right)
-    {
-      next = node->l_right;
-      bgp_lock_node (next);
-      bgp_unlock_node (node);
-      return next;
-    }
-
-  start = node;
-  while (node->parent && node != limit)
-    {
-      if (node->parent->l_left == node && node->parent->l_right)
-       {
-         next = node->parent->l_right;
-         bgp_lock_node (next);
-         bgp_unlock_node (start);
-         return next;
-       }
-      node = node->parent;
-    }
-  bgp_unlock_node (start);
-  return NULL;
-}
-
-unsigned long
-bgp_table_count (const struct bgp_table *table)
-{
-  return table->count;
+       return rt;
 }