ospf_lsdb.c
上传用户:xiaozhuqw
上传日期:2009-11-15
资源大小:1338k
文件大小:6k
源码类别:

网络

开发平台:

Unix_Linux

  1. /*
  2.  * OSPF LSDB support.
  3.  * Copyright (C) 1999, 2000 Alex Zinin, Kunihiro Ishiguro, Toshiaki Takada
  4.  *
  5.  * This file is part of GNU Zebra.
  6.  *
  7.  * GNU Zebra is free software; you can redistribute it and/or modify it
  8.  * under the terms of the GNU General Public License as published by the
  9.  * Free Software Foundation; either version 2, or (at your option) any
  10.  * later version.
  11.  *
  12.  * GNU Zebra is distributed in the hope that it will be useful, but
  13.  * WITHOUT ANY WARRANTY; without even the implied warranty of
  14.  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  15.  * General Public License for more details.
  16.  *
  17.  * You should have received a copy of the GNU General Public License
  18.  * along with GNU Zebra; see the file COPYING.  If not, write to the Free
  19.  * Software Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA
  20.  * 02111-1307, USA.
  21.  */
  22. #include <zebra.h>
  23. #include "prefix.h"
  24. #include "table.h"
  25. #include "memory.h"
  26. #include "log.h"
  27. #include "ospfd/ospfd.h"
  28. #include "ospfd/ospf_asbr.h"
  29. #include "ospfd/ospf_lsa.h"
  30. #include "ospfd/ospf_lsdb.h"
  31. struct ospf_lsdb *
  32. ospf_lsdb_new ()
  33. {
  34.   struct ospf_lsdb *new;
  35.   new = XCALLOC (MTYPE_OSPF_LSDB, sizeof (struct ospf_lsdb));
  36.   ospf_lsdb_init (new);
  37.   return new;
  38. }
  39. void
  40. ospf_lsdb_init (struct ospf_lsdb *lsdb)
  41. {
  42.   int i;
  43.   
  44.   for (i = OSPF_MIN_LSA; i < OSPF_MAX_LSA; i++)
  45.     lsdb->type[i].db = route_table_init ();
  46. }
  47. void
  48. ospf_lsdb_free (struct ospf_lsdb *lsdb)
  49. {
  50.   ospf_lsdb_cleanup (lsdb);
  51.   XFREE (MTYPE_OSPF_LSDB, lsdb);
  52. }
  53. void
  54. ospf_lsdb_cleanup (struct ospf_lsdb *lsdb)
  55. {
  56.   int i;
  57.   assert (lsdb);
  58.   assert (lsdb->total == 0);
  59.   ospf_lsdb_delete_all (lsdb);
  60.   
  61.   for (i = OSPF_MIN_LSA; i < OSPF_MAX_LSA; i++)
  62.     route_table_finish (lsdb->type[i].db);
  63. }
  64. void
  65. lsdb_prefix_set (struct prefix_ls *lp, struct ospf_lsa *lsa)
  66. {
  67.   memset (lp, 0, sizeof (struct prefix_ls));
  68.   lp->family = 0;
  69.   lp->prefixlen = 64;
  70.   lp->id = lsa->data->id;
  71.   lp->adv_router = lsa->data->adv_router;
  72. }
  73. /* Add new LSA to lsdb. */
  74. void
  75. ospf_lsdb_add (struct ospf_lsdb *lsdb, struct ospf_lsa *lsa)
  76. {
  77.   struct route_table *table;
  78.   struct prefix_ls lp;
  79.   struct route_node *rn;
  80.   table = lsdb->type[lsa->data->type].db;
  81.   lsdb_prefix_set (&lp, lsa);
  82.   rn = route_node_get (table, (struct prefix *)&lp);
  83.   if (!rn->info)
  84.     {
  85.       if (IS_LSA_SELF (lsa))
  86. lsdb->type[lsa->data->type].count_self++;
  87.       lsdb->type[lsa->data->type].count++;
  88.       lsdb->total++;
  89.     }
  90.   else
  91.     {
  92.       if (rn->info == lsa)
  93. return;
  94.       
  95.       ospf_lsa_unlock (rn->info);
  96.       route_unlock_node (rn);
  97.     }
  98. #ifdef MONITOR_LSDB_CHANGE
  99.   if (lsdb->new_lsa_hook != NULL)
  100.     (* lsdb->new_lsa_hook)(lsa);
  101. #endif /* MONITOR_LSDB_CHANGE */
  102.   rn->info = ospf_lsa_lock (lsa);
  103. }
  104. void
  105. ospf_lsdb_delete (struct ospf_lsdb *lsdb, struct ospf_lsa *lsa)
  106. {
  107.   struct route_table *table;
  108.   struct prefix_ls lp;
  109.   struct route_node *rn;
  110.   table = lsdb->type[lsa->data->type].db;
  111.   lsdb_prefix_set (&lp, lsa);
  112.   rn = route_node_lookup (table, (struct prefix *) &lp);
  113.   if (rn)
  114.     if (rn->info == lsa)
  115.       {
  116. if (IS_LSA_SELF (lsa))
  117.   lsdb->type[lsa->data->type].count_self--;
  118. lsdb->type[lsa->data->type].count--;
  119. lsdb->total--;
  120. rn->info = NULL;
  121. route_unlock_node (rn);
  122. route_unlock_node (rn);
  123. #ifdef MONITOR_LSDB_CHANGE
  124.         if (lsdb->del_lsa_hook != NULL)
  125.           (* lsdb->del_lsa_hook)(lsa);
  126. #endif /* MONITOR_LSDB_CHANGE */
  127. ospf_lsa_unlock (lsa);
  128. return;
  129.       }
  130. }
  131. void
  132. ospf_lsdb_delete_all (struct ospf_lsdb *lsdb)
  133. {
  134.   struct route_table *table;
  135.   struct route_node *rn;
  136.   struct ospf_lsa *lsa;
  137.   int i;
  138.   for (i = OSPF_MIN_LSA; i < OSPF_MAX_LSA; i++)
  139.     {
  140.       table = lsdb->type[i].db;
  141.       for (rn = route_top (table); rn; rn = route_next (rn))
  142. if ((lsa = (rn->info)) != NULL)
  143.   {
  144.     if (IS_LSA_SELF (lsa))
  145.       lsdb->type[i].count_self--;
  146.     lsdb->type[i].count--;
  147.     lsdb->total--;
  148.     rn->info = NULL;
  149.     route_unlock_node (rn);
  150. #ifdef MONITOR_LSDB_CHANGE
  151.             if (lsdb->del_lsa_hook != NULL)
  152.               (* lsdb->del_lsa_hook)(lsa);
  153. #endif /* MONITOR_LSDB_CHANGE */
  154.     ospf_lsa_unlock (lsa);
  155.   }
  156.     }
  157. }
  158. struct ospf_lsa *
  159. ospf_lsdb_lookup (struct ospf_lsdb *lsdb, struct ospf_lsa *lsa)
  160. {
  161.   struct route_table *table;
  162.   struct prefix_ls lp;
  163.   struct route_node *rn;
  164.   struct ospf_lsa *find;
  165.   table = lsdb->type[lsa->data->type].db;
  166.   lsdb_prefix_set (&lp, lsa);
  167.   rn = route_node_lookup (table, (struct prefix *) &lp);
  168.   if (rn)
  169.     {
  170.       find = rn->info;
  171.       route_unlock_node (rn);
  172.       return find;
  173.     }
  174.   return NULL;
  175. }
  176. struct ospf_lsa *
  177. ospf_lsdb_lookup_by_id (struct ospf_lsdb *lsdb, u_char type,
  178.        struct in_addr id, struct in_addr adv_router)
  179. {
  180.   struct route_table *table;
  181.   struct prefix_ls lp;
  182.   struct route_node *rn;
  183.   struct ospf_lsa *find;
  184.   table = lsdb->type[type].db;
  185.   memset (&lp, 0, sizeof (struct prefix_ls));
  186.   lp.family = 0;
  187.   lp.prefixlen = 64;
  188.   lp.id = id;
  189.   lp.adv_router = adv_router;
  190.   rn = route_node_lookup (table, (struct prefix *) &lp);
  191.   if (rn)
  192.     {
  193.       find = rn->info;
  194.       route_unlock_node (rn);
  195.       return find;
  196.     }
  197.   return NULL;
  198. }
  199. struct ospf_lsa *
  200. ospf_lsdb_lookup_by_id_next (struct ospf_lsdb *lsdb, u_char type,
  201.     struct in_addr id, struct in_addr adv_router,
  202.     int first)
  203. {
  204.   struct route_table *table;
  205.   struct prefix_ls lp;
  206.   struct route_node *rn;
  207.   struct ospf_lsa *find;
  208.   table = lsdb->type[type].db;
  209.   memset (&lp, 0, sizeof (struct prefix_ls));
  210.   lp.family = 0;
  211.   lp.prefixlen = 64;
  212.   lp.id = id;
  213.   lp.adv_router = adv_router;
  214.   if (first)
  215.       rn = route_top (table);
  216.   else
  217.     {
  218.       rn = route_node_get (table, (struct prefix *) &lp);
  219.       rn = route_next (rn);
  220.     }
  221.   for (; rn; rn = route_next (rn))
  222.     if (rn->info)
  223.       break;
  224.   if (rn && rn->info)
  225.     {
  226.       find = rn->info;
  227.       route_unlock_node (rn);
  228.       return find;
  229.     }
  230.   return NULL;
  231. }
  232. unsigned long
  233. ospf_lsdb_count_all (struct ospf_lsdb *lsdb)
  234. {
  235.   return lsdb->total;
  236. }
  237. unsigned long
  238. ospf_lsdb_count (struct ospf_lsdb *lsdb, int type)
  239. {
  240.   return lsdb->type[type].count;
  241. }
  242. unsigned long
  243. ospf_lsdb_count_self (struct ospf_lsdb *lsdb, int type)
  244. {
  245.   return lsdb->type[type].count_self;
  246. }
  247. unsigned long
  248. ospf_lsdb_isempty (struct ospf_lsdb *lsdb)
  249. {
  250.   return (lsdb->total == 0);
  251. }