开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Linux/Unix编程 > 网络 > 查看源码
ospf_opaque.c
资源名称：zebra-0.95a.tar.gz　[点击查看]
上传用户：xiaozhuqw
上传日期：2009-11-15
资源大小：1338k
文件大小：70k
源码类别：

网络

开发平台：

Unix_Linux

ospf_opaque.c：源码内容
  1. /*
  2.  * This is an implementation of rfc2370.
  3.  * Copyright (C) 2001 KDD R&D Laboratories, Inc.
  4.  * http://www.kddlabs.co.jp/
  5.  *
  6.  * This file is part of GNU Zebra.
  7.  *
  8.  * GNU Zebra is free software; you can redistribute it and/or modify it
  9.  * under the terms of the GNU General Public License as published by the
  10.  * Free Software Foundation; either version 2, or (at your option) any
  11.  * later version.
  12.  * 
  13.  * GNU Zebra is distributed in the hope that it will be useful, but
  14.  * WITHOUT ANY WARRANTY; without even the implied warranty of
  15.  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  16.  * General Public License for more details.
  17.  *
  18.  * You should have received a copy of the GNU General Public License
  19.  * along with GNU Zebra; see the file COPYING.  If not, write to the Free
  20.  * Software Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA
  21.  * 02111-1307, USA.
  22.  */
  24. /***** MTYPE definitions are not reflected to "memory.h" yet. *****/
  25. #define MTYPE_OSPF_OPAQUE_FUNCTAB 0
  26. #define MTYPE_OPAQUE_INFO_PER_TYPE 0
  27. #define MTYPE_OPAQUE_INFO_PER_ID 0
  29. #include <zebra.h>
  30. #ifdef HAVE_OPAQUE_LSA
  32. #include "linklist.h"
  33. #include "prefix.h"
  34. #include "if.h"
  35. #include "table.h"
  36. #include "memory.h"
  37. #include "command.h"
  38. #include "vty.h"
  39. #include "stream.h"
  40. #include "log.h"
  41. #include "thread.h"
  42. #include "hash.h"
  43. #include "sockunion.h" /* for inet_aton() */
  45. #include "ospfd/ospfd.h"
  46. #include "ospfd/ospf_interface.h"
  47. #include "ospfd/ospf_ism.h"
  48. #include "ospfd/ospf_asbr.h"
  49. #include "ospfd/ospf_lsa.h"
  50. #include "ospfd/ospf_lsdb.h"
  51. #include "ospfd/ospf_neighbor.h"
  52. #include "ospfd/ospf_nsm.h"
  53. #include "ospfd/ospf_flood.h"
  54. #include "ospfd/ospf_packet.h"
  55. #include "ospfd/ospf_spf.h"
  56. #include "ospfd/ospf_dump.h"
  57. #include "ospfd/ospf_route.h"
  58. #include "ospfd/ospf_ase.h"
  59. #include "ospfd/ospf_zebra.h"
  61. /*------------------------------------------------------------------------*
  62.  * Followings are initialize/terminate functions for Opaque-LSAs handling.
  63.  *------------------------------------------------------------------------*/
  65. #ifdef HAVE_OSPF_TE
  66. #include "ospfd/ospf_te.h"
  67. #endif /* HAVE_OSPF_TE */
  69. static void ospf_opaque_register_vty (void);
  70. static void ospf_opaque_funclist_init (void);
  71. static void ospf_opaque_funclist_term (void);
  72. static void free_opaque_info_per_type (void *val);
  73. static void free_opaque_info_per_id (void *val);
  74. static int ospf_opaque_lsa_install_hook (struct ospf_lsa *lsa);
  75. static int ospf_opaque_lsa_delete_hook (struct ospf_lsa *lsa);
  77. void
  78. ospf_opaque_init (void)
  79. {
  80.   ospf_opaque_register_vty ();
  81.   ospf_opaque_funclist_init ();
  83. #ifdef HAVE_OSPF_TE
  84.   if (ospf_mpls_te_init () != 0)
  85.     exit (1);
  86. #endif /* HAVE_OSPF_TE */
  88.   return;
  89. }
  91. void
  92. ospf_opaque_term (void)
  93. {
  94. #ifdef HAVE_OSPF_TE
  95.   ospf_mpls_te_term ();
  96. #endif /* HAVE_OSPF_TE */
  98.   ospf_opaque_funclist_term ();
  99.   return;
  100. }
  102. int
  103. ospf_opaque_type9_lsa_init (struct ospf_interface *oi)
  104. {
  105.   if (oi->opaque_lsa_self != NULL)
  106.     list_delete (oi->opaque_lsa_self);
  108.   oi->opaque_lsa_self = list_new ();
  109.   oi->opaque_lsa_self->del = free_opaque_info_per_type;
  110.   oi->t_opaque_lsa_self = NULL;
  111.   return 0;
  112. }
  114. void
  115. ospf_opaque_type9_lsa_term (struct ospf_interface *oi)
  116. {
  117.   OSPF_TIMER_OFF (oi->t_opaque_lsa_self);
  118.   if (oi->opaque_lsa_self != NULL)
  119.     list_delete (oi->opaque_lsa_self);
  120.   oi->opaque_lsa_self = NULL;
  121.   return;
  122. }
  124. int
  125. ospf_opaque_type10_lsa_init (struct ospf_area *area)
  126. {
  127.   if (area->opaque_lsa_self != NULL)
  128.     list_delete (area->opaque_lsa_self);
  130.   area->opaque_lsa_self = list_new ();
  131.   area->opaque_lsa_self->del = free_opaque_info_per_type;
  132.   area->t_opaque_lsa_self = NULL;
  134. #ifdef MONITOR_LSDB_CHANGE
  135.   area->lsdb->new_lsa_hook = ospf_opaque_lsa_install_hook;
  136.   area->lsdb->del_lsa_hook = ospf_opaque_lsa_delete_hook;
  137. #endif /* MONITOR_LSDB_CHANGE */
  138.   return 0;
  139. }
  141. void
  142. ospf_opaque_type10_lsa_term (struct ospf_area *area)
  143. {
  144. #ifdef MONITOR_LSDB_CHANGE
  145.   area->lsdb->new_lsa_hook = 
  146.   area->lsdb->del_lsa_hook = NULL;
  147. #endif /* MONITOR_LSDB_CHANGE */
  149.   OSPF_TIMER_OFF (area->t_opaque_lsa_self);
  150.   if (area->opaque_lsa_self != NULL)
  151.     list_delete (area->opaque_lsa_self);
  152.   area->opaque_lsa_self = NULL;
  153.   return;
  154. }
  156. int
  157. ospf_opaque_type11_lsa_init (struct ospf *top)
  158. {
  159.   if (top->opaque_lsa_self != NULL)
  160.     list_delete (top->opaque_lsa_self);
  162.   top->opaque_lsa_self = list_new ();
  163.   top->opaque_lsa_self->del = free_opaque_info_per_type;
  164.   top->t_opaque_lsa_self = NULL;
  166. #ifdef MONITOR_LSDB_CHANGE
  167.   top->lsdb->new_lsa_hook = ospf_opaque_lsa_install_hook;
  168.   top->lsdb->del_lsa_hook = ospf_opaque_lsa_delete_hook;
  169. #endif /* MONITOR_LSDB_CHANGE */
  170.   return 0;
  171. }
  173. void
  174. ospf_opaque_type11_lsa_term (struct ospf *top)
  175. {
  176. #ifdef MONITOR_LSDB_CHANGE
  177.   top->lsdb->new_lsa_hook = 
  178.   top->lsdb->del_lsa_hook = NULL;
  179. #endif /* MONITOR_LSDB_CHANGE */
  181.   OSPF_TIMER_OFF (top->t_opaque_lsa_self);
  182.   if (top->opaque_lsa_self != NULL)
  183.     list_delete (top->opaque_lsa_self);
  184.   top->opaque_lsa_self = NULL;
  185.   return;
  186. }
  188. static const char *
  189. ospf_opaque_type_name (u_char opaque_type)
  190. {
  191.   const char *name = "Unknown";
  193.   switch (opaque_type)
  194.     {
  195.     case OPAQUE_TYPE_WILDCARD: /* This is a special assignment! */
  196.       name = "Wildcard";
  197.       break;
  198.     case OPAQUE_TYPE_TRAFFIC_ENGINEERING_LSA:
  199.       name = "Traffic Engineering LSA";
  200.       break;
  201.     case OPAQUE_TYPE_SYCAMORE_OPTICAL_TOPOLOGY_DESC:
  202.       name = "Sycamore optical topology description";
  203.       break;
  204.     case OPAQUE_TYPE_GRACE_LSA:
  205.       name = "Grace-LSA";
  206.       break;
  207.     default:
  208.       if (OPAQUE_TYPE_RANGE_UNASSIGNED (opaque_type))
  209.         name = "Unassigned";
  210.       else if (OPAQUE_TYPE_RANGE_RESERVED (opaque_type))
  211.         name = "Private/Experimental";
  212.       break;
  213.     }
  214.   return name;
  215. }
  217. /*------------------------------------------------------------------------*
  218.  * Followings are management functions to store user specified callbacks.
  219.  *------------------------------------------------------------------------*/
  221. struct opaque_info_per_type; /* Forward declaration. */
  223. struct ospf_opaque_functab
  224. {
  225.   u_char opaque_type;
  226.   struct opaque_info_per_type *oipt;
  228.   int (* new_if_hook)(struct interface *ifp);
  229.   int (* del_if_hook)(struct interface *ifp);
  230.   void (* ism_change_hook)(struct ospf_interface *oi, int old_status);
  231.   void (* nsm_change_hook)(struct ospf_neighbor *nbr, int old_status);
  232.   void (* config_write_router)(struct vty *vty);
  233.   void (* config_write_if    )(struct vty *vty, struct interface *ifp);
  234.   void (* config_write_debug )(struct vty *vty);
  235.   void (* show_opaque_info   )(struct vty *vty, struct ospf_lsa *lsa);
  236.   int  (* lsa_originator)(void *arg);
  237.   void (* lsa_refresher )(struct ospf_lsa *lsa);
  238.   int (* new_lsa_hook)(struct ospf_lsa *lsa);
  239.   int (* del_lsa_hook)(struct ospf_lsa *lsa);
  240. };
  242. static list ospf_opaque_wildcard_funclist; /* Handle LSA-9/10/11 altogether. */
  243. static list ospf_opaque_type9_funclist;
  244. static list ospf_opaque_type10_funclist;
  245. static list ospf_opaque_type11_funclist;
  247. static void
  248. ospf_opaque_del_functab (void *val)
  249. {
  250.   XFREE (MTYPE_OSPF_OPAQUE_FUNCTAB, val);
  251.   return;
  252. }
  254. static void
  255. ospf_opaque_funclist_init (void)
  256. {
  257.   list funclist;
  259.   funclist = ospf_opaque_wildcard_funclist = list_new ();
  260.   funclist->del = ospf_opaque_del_functab;
  262.   funclist = ospf_opaque_type9_funclist  = list_new ();
  263.   funclist->del = ospf_opaque_del_functab;
  265.   funclist = ospf_opaque_type10_funclist = list_new ();
  266.   funclist->del = ospf_opaque_del_functab;
  268.   funclist = ospf_opaque_type11_funclist = list_new ();
  269.   funclist->del = ospf_opaque_del_functab;
  270.   return;
  271. }
  273. static void
  274. ospf_opaque_funclist_term (void)
  275. {
  276.   list funclist;
  278.   funclist = ospf_opaque_wildcard_funclist;
  279.   list_delete (funclist);
  281.   funclist = ospf_opaque_type9_funclist;
  282.   list_delete (funclist);
  284.   funclist = ospf_opaque_type10_funclist;
  285.   list_delete (funclist);
  287.   funclist = ospf_opaque_type11_funclist;
  288.   list_delete (funclist);
  289.   return;
  290. }
  292. static list
  293. ospf_get_opaque_funclist (u_char lsa_type)
  294. {
  295.   list funclist = NULL;
  297.   switch (lsa_type)
  298.     {
  299.     case OPAQUE_TYPE_WILDCARD:
  300.       /* XXX
  301.        * This is an ugly trick to handle type-9/10/11 LSA altogether.
  302.        * Yes, "OPAQUE_TYPE_WILDCARD (value 0)" is not an LSA-type, nor
  303.        * an officially assigned opaque-type.
  304.        * Though it is possible that the value might be officially used
  305.        * in the future, we use it internally as a special label, for now.
  306.        */
  307.       funclist = ospf_opaque_wildcard_funclist;
  308.       break;
  309.     case OSPF_OPAQUE_LINK_LSA:
  310.       funclist = ospf_opaque_type9_funclist;
  311.       break;
  312.     case OSPF_OPAQUE_AREA_LSA:
  313.       funclist = ospf_opaque_type10_funclist;
  314.       break;
  315.     case OSPF_OPAQUE_AS_LSA:
  316.       funclist = ospf_opaque_type11_funclist;
  317.       break;
  318.     default:
  319.       zlog_warn ("ospf_get_opaque_funclist: Unexpected LSA-type(%u)", lsa_type);
  320.       break;
  321.     }
  322.   return funclist;
  323. }
  325. int
  326. ospf_register_opaque_functab (
  327.   u_char lsa_type,
  328.   u_char opaque_type,
  329.   int (* new_if_hook)(struct interface *ifp),
  330.   int (* del_if_hook)(struct interface *ifp),
  331.   void (* ism_change_hook)(struct ospf_interface *oi, int old_status),
  332.   void (* nsm_change_hook)(struct ospf_neighbor *nbr, int old_status),
  333.   void (* config_write_router)(struct vty *vty),
  334.   void (* config_write_if    )(struct vty *vty, struct interface *ifp),
  335.   void (* config_write_debug )(struct vty *vty),
  336.   void (* show_opaque_info   )(struct vty *vty, struct ospf_lsa *lsa),
  337.   int  (* lsa_originator)(void *arg),
  338.   void (* lsa_refresher )(struct ospf_lsa *lsa),
  339.   int (* new_lsa_hook)(struct ospf_lsa *lsa),
  340.   int (* del_lsa_hook)(struct ospf_lsa *lsa))
  341. {
  342.   list funclist;
  343.   struct ospf_opaque_functab *new;
  344.   int rc = -1;
  346.   if ((funclist = ospf_get_opaque_funclist (lsa_type)) == NULL)
  347.     {
  348.       zlog_warn ("ospf_register_opaque_functab: Cannot get funclist for Type-%u LSAs?", lsa_type);
  349.       goto out;
  350.     }
  351.   else
  352.     {
  353.       listnode node;
  354.       struct ospf_opaque_functab *functab;
  356.       for (node = listhead (funclist); node; nextnode (node))
  357.         if ((functab = getdata (node)) != NULL)
  358.           if (functab->opaque_type == opaque_type)
  359.             {
  360.               zlog_warn ("ospf_register_opaque_functab: Duplicated entry?: lsa_type(%u), opaque_type(%u)", lsa_type, opaque_type);
  361.               goto out;
  362.             }
  363.     }
  365.   if ((new = XCALLOC (MTYPE_OSPF_OPAQUE_FUNCTAB,
  366.       sizeof (struct ospf_opaque_functab))) == NULL)
  367.     {
  368.       zlog_warn ("ospf_register_opaque_functab: XMALLOC: %s", strerror (errno));
  369.       goto out;
  370.     }
  372.   new->opaque_type    = opaque_type;
  373.   new->oipt           = NULL;
  374.   new->new_if_hook    = new_if_hook;
  375.   new->del_if_hook    = del_if_hook;
  376.   new->ism_change_hook     = ism_change_hook;
  377.   new->nsm_change_hook     = nsm_change_hook;
  378.   new->config_write_router = config_write_router;
  379.   new->config_write_if     = config_write_if;
  380.   new->config_write_debug  = config_write_debug;
  381.   new->show_opaque_info    = show_opaque_info;
  382.   new->lsa_originator = lsa_originator;
  383.   new->lsa_refresher  = lsa_refresher;
  384.   new->new_lsa_hook   = new_lsa_hook;
  385.   new->del_lsa_hook   = del_lsa_hook;
  387.   listnode_add (funclist, new);
  388.   rc = 0;
  390. out:
  391.   return rc;
  392. }
  394. void
  395. ospf_delete_opaque_functab (u_char lsa_type, u_char opaque_type)
  396. {
  397.   list funclist;
  398.   listnode node;
  399.   struct ospf_opaque_functab *functab;
  401.   if ((funclist = ospf_get_opaque_funclist (lsa_type)) != NULL)
  402.     for (node = listhead (funclist); node; nextnode (node))
  403.       {
  404.         if ((functab = getdata (node)) != NULL
  405.         &&   functab->opaque_type == opaque_type)
  406.           {
  407.             /* Cleanup internal control information, if it still remains. */
  408.             if (functab->oipt != NULL)
  409.               free_opaque_info_per_type (functab->oipt);
  411.             /* Dequeue listnode entry from the list. */
  412.             listnode_delete (funclist, functab);
  414.             /* Avoid misjudgement in the next lookup. */
  415.             if (listcount (funclist) == 0)
  416.               funclist->head = funclist->tail = NULL;
  418.             XFREE (MTYPE_OSPF_OPAQUE_FUNCTAB, functab);
  419.             goto out;
  420.   }
  421.       }
  422. out:
  423.   return;
  424. }
  426. static struct ospf_opaque_functab *
  427. ospf_opaque_functab_lookup (struct ospf_lsa *lsa)
  428. {
  429.   list funclist;
  430.   listnode node;
  431.   struct ospf_opaque_functab *functab;
  432.   u_char key = GET_OPAQUE_TYPE (ntohl (lsa->data->id.s_addr));
  434.   if ((funclist = ospf_get_opaque_funclist (lsa->data->type)) != NULL)
  435.     for (node = listhead (funclist); node; nextnode (node))
  436.       if ((functab = getdata (node)) != NULL)
  437.         if (functab->opaque_type == key)
  438.           return functab;
  440.   return NULL;
  441. }
  443. /*------------------------------------------------------------------------*
  444.  * Followings are management functions for self-originated LSA entries.
  445.  *------------------------------------------------------------------------*/
  447. /*
  448.  * Opaque-LSA control information per opaque-type.
  449.  * Single Opaque-Type may have multiple instances; each of them will be
  450.  * identified by their opaque-id.
  451.  */
  452. struct opaque_info_per_type
  453. {
  454.   u_char lsa_type;
  455.   u_char opaque_type;
  457.   enum { PROC_NORMAL, PROC_SUSPEND } status;
  459.   /*
  460.    * Thread for (re-)origination scheduling for this opaque-type.
  461.    *
  462.    * Initial origination of Opaque-LSAs is controlled by generic
  463.    * Opaque-LSA handling module so that same opaque-type entries are
  464.    * called all at once when certain conditions are met.
  465.    * However, there might be cases that some Opaque-LSA clients need
  466.    * to (re-)originate their own Opaque-LSAs out-of-sync with others.
  467.    * This thread is prepared for that specific purpose.
  468.    */
  469.   struct thread *t_opaque_lsa_self;
  471.   /*
  472.    * Backpointer to an "owner" which is LSA-type dependent.
  473.    *   type-9:  struct ospf_interface
  474.    *   type-10: struct ospf_area
  475.    *   type-11: struct ospf
  476.    */
  477.   void *owner;
  479.   /* Collection of callback functions for this opaque-type. */
  480.   struct ospf_opaque_functab *functab;
  482.   /* List of Opaque-LSA control informations per opaque-id. */
  483.   list id_list;
  484. };
  486. /* Opaque-LSA control information per opaque-id. */
  487. struct opaque_info_per_id
  488. {
  489.   u_int32_t opaque_id;
  491.   /* Thread for refresh/flush scheduling for this opaque-type/id. */
  492.   struct thread *t_opaque_lsa_self;
  494.   /* Backpointer to Opaque-LSA control information per opaque-type. */
  495.   struct opaque_info_per_type *opqctl_type;
  497.   /* Here comes an actual Opaque-LSA entry for this opaque-type/id. */
  498.   struct ospf_lsa *lsa;
  499. };
  501. static struct opaque_info_per_type *register_opaque_info_per_type (struct ospf_opaque_functab *functab, struct ospf_lsa *new);
  502. static struct opaque_info_per_type *lookup_opaque_info_by_type (struct ospf_lsa *lsa);
  503. static struct opaque_info_per_id *register_opaque_info_per_id (struct opaque_info_per_type *oipt, struct ospf_lsa *new);
  504. static struct opaque_info_per_id *lookup_opaque_info_by_id (struct opaque_info_per_type *oipt, struct ospf_lsa *lsa);
  505. static struct opaque_info_per_id *register_opaque_lsa (struct ospf_lsa *new);
  508. static struct opaque_info_per_type *
  509. register_opaque_info_per_type (struct ospf_opaque_functab *functab,
  510.                                struct ospf_lsa *new)
  511. {
  512.   struct ospf *top;
  513.   struct opaque_info_per_type *oipt;
  515.   if ((oipt = XCALLOC (MTYPE_OPAQUE_INFO_PER_TYPE,
  516.        sizeof (struct opaque_info_per_type))) == NULL)
  517.     {
  518.       zlog_warn ("register_opaque_info_per_type: XMALLOC: %s", strerror (errno));
  519.       goto out;
  520.     }
  522.   switch (new->data->type)
  523.     {
  524.     case OSPF_OPAQUE_LINK_LSA:
  525.       oipt->owner = new->oi;
  526.       listnode_add (new->oi->opaque_lsa_self, oipt);
  527.       break;
  528.     case OSPF_OPAQUE_AREA_LSA:
  529.       oipt->owner = new->area;
  530.       listnode_add (new->area->opaque_lsa_self, oipt);
  531.       break;
  532.     case OSPF_OPAQUE_AS_LSA:
  533.       top = ospf_lookup ();
  534.       if (new->area != NULL && (top = new->area->ospf) == NULL)
  535.         {
  536.           free_opaque_info_per_type ((void *) oipt);
  537.           oipt = NULL;
  538.           goto out; /* This case may not exist. */
  539.         }
  540.       oipt->owner = top;
  541.       listnode_add (top->opaque_lsa_self, oipt);
  542.       break;
  543.     default:
  544.       zlog_warn ("register_opaque_info_per_type: Unexpected LSA-type(%u)", new->data->type);
  545.       free_opaque_info_per_type ((void *) oipt);
  546.       oipt = NULL;
  547.       goto out; /* This case may not exist. */
  548.     }
  550.   oipt->lsa_type = new->data->type;
  551.   oipt->opaque_type = GET_OPAQUE_TYPE (ntohl (new->data->id.s_addr));
  552.   oipt->status = PROC_NORMAL;
  553.   oipt->t_opaque_lsa_self = NULL;
  554.   oipt->functab = functab;
  555.   functab->oipt = oipt;
  556.   oipt->id_list = list_new ();
  557.   oipt->id_list->del = free_opaque_info_per_id;
  559. out:
  560.   return oipt;
  561. }
  563. static void
  564. free_opaque_info_per_type (void *val)
  565. {
  566.   struct opaque_info_per_type *oipt = (struct opaque_info_per_type *) val;
  567.   struct opaque_info_per_id *oipi;
  568.   struct ospf_lsa *lsa;
  569.   listnode node;
  571.   /* Control information per opaque-id may still exist. */
  572.   for (node = listhead (oipt->id_list); node; nextnode (node))
  573.     {
  574.       if ((oipi = getdata (node)) == NULL)
  575.         continue;
  576.       if ((lsa = oipi->lsa) == NULL)
  577.         continue;
  578.       if (IS_LSA_MAXAGE (lsa))
  579.         continue;
  580.       ospf_opaque_lsa_flush_schedule (lsa);
  581.     }
  583.   /* Remove "oipt" from its owner's self-originated LSA list. */
  584.   switch (oipt->lsa_type)
  585.     {
  586.     case OSPF_OPAQUE_LINK_LSA:
  587.       {
  588.         struct ospf_interface *oi = (struct ospf_interface *)(oipt->owner);
  589.         listnode_delete (oi->opaque_lsa_self, oipt);
  590.         break;
  591.       }
  592.     case OSPF_OPAQUE_AREA_LSA:
  593.       {
  594.         struct ospf_area *area = (struct ospf_area *)(oipt->owner);
  595.         listnode_delete (area->opaque_lsa_self, oipt);
  596.         break;
  597.       }
  598.     case OSPF_OPAQUE_AS_LSA:
  599.       {
  600.         struct ospf *top = (struct ospf *)(oipt->owner);
  601.         listnode_delete (top->opaque_lsa_self, oipt);
  602.         break;
  603.       }
  604.     default:
  605.       zlog_warn ("free_opaque_info_per_type: Unexpected LSA-type(%u)", oipt->lsa_type);
  606.       break; /* This case may not exist. */
  607.     }
  609.   OSPF_TIMER_OFF (oipt->t_opaque_lsa_self);
  610.   list_delete (oipt->id_list);
  611.   XFREE (MTYPE_OPAQUE_INFO_PER_TYPE, oipt);
  612.   return;
  613. }
  615. static struct opaque_info_per_type *
  616. lookup_opaque_info_by_type (struct ospf_lsa *lsa)
  617. {
  618.   struct ospf *top;
  619.   struct ospf_area *area;
  620.   struct ospf_interface *oi;
  621.   list listtop = NULL;
  622.   listnode node;
  623.   struct opaque_info_per_type *oipt = NULL;
  624.   u_char key = GET_OPAQUE_TYPE (ntohl (lsa->data->id.s_addr));
  626.   switch (lsa->data->type)
  627.     {
  628.     case OSPF_OPAQUE_LINK_LSA:
  629.       if ((oi = lsa->oi) != NULL)
  630.         listtop = oi->opaque_lsa_self;
  631.       else
  632.         zlog_warn ("Type-9 Opaque-LSA: Reference to OI is missing?");
  633.       break;
  634.     case OSPF_OPAQUE_AREA_LSA:
  635.       if ((area = lsa->area) != NULL)
  636.         listtop = area->opaque_lsa_self;
  637.       else
  638.         zlog_warn ("Type-10 Opaque-LSA: Reference to AREA is missing?");
  639.       break;
  640.     case OSPF_OPAQUE_AS_LSA:
  641.       top = ospf_lookup ();
  642.       if ((area = lsa->area) != NULL && (top = area->ospf) == NULL)
  643.         {
  644.           zlog_warn ("Type-11 Opaque-LSA: Reference to OSPF is missing?");
  645.           break; /* Unlikely to happen. */
  646.         }
  647.       listtop = top->opaque_lsa_self;
  648.       break;
  649.     default:
  650.       zlog_warn ("lookup_opaque_info_by_type: Unexpected LSA-type(%u)", lsa->data->type);
  651.       break;
  652.     }
  654.   if (listtop != NULL)
  655.     for (node = listhead (listtop); node; nextnode (node))
  656.       if ((oipt = getdata (node)) != NULL)
  657.         if (oipt->opaque_type == key)
  658.           return oipt;
  660.   return NULL;
  661. }
  663. static struct opaque_info_per_id *
  664. register_opaque_info_per_id (struct opaque_info_per_type *oipt,
  665.                              struct ospf_lsa *new)
  666. {
  667.   struct opaque_info_per_id *oipi;
  669.   if ((oipi = XCALLOC (MTYPE_OPAQUE_INFO_PER_ID,
  670.        sizeof (struct opaque_info_per_id))) == NULL)
  671.     {
  672.       zlog_warn ("register_opaque_info_per_id: XMALLOC: %s", strerror (errno));
  673.       goto out;
  674.     }
  675.   oipi->opaque_id = GET_OPAQUE_ID (ntohl (new->data->id.s_addr));
  676.   oipi->t_opaque_lsa_self = NULL;
  677.   oipi->opqctl_type = oipt;
  678.   oipi->lsa = ospf_lsa_lock (new);
  680.   listnode_add (oipt->id_list, oipi);
  682. out:
  683.   return oipi;
  684. }
  686. static void
  687. free_opaque_info_per_id (void *val)
  688. {
  689.   struct opaque_info_per_id *oipi = (struct opaque_info_per_id *) val;
  691.   OSPF_TIMER_OFF (oipi->t_opaque_lsa_self);
  692.   if (oipi->lsa != NULL)
  693.     ospf_lsa_unlock (oipi->lsa);
  694.   XFREE (MTYPE_OPAQUE_INFO_PER_ID, oipi);
  695.   return;
  696. }
  698. static struct opaque_info_per_id *
  699. lookup_opaque_info_by_id (struct opaque_info_per_type *oipt,
  700.                           struct ospf_lsa *lsa)
  701. {
  702.   listnode node;
  703.   struct opaque_info_per_id   *oipi;
  704.   u_int32_t key = GET_OPAQUE_ID (ntohl (lsa->data->id.s_addr));
  706.   for (node = listhead (oipt->id_list); node; nextnode (node))
  707.     if ((oipi = getdata (node)) != NULL)
  708.       if (oipi->opaque_id == key)
  709.         return oipi;
  711.   return NULL;
  712. }
  714. static struct opaque_info_per_id *
  715. register_opaque_lsa (struct ospf_lsa *new)
  716. {
  717.   struct ospf_opaque_functab *functab;
  718.   struct opaque_info_per_type *oipt;
  719.   struct opaque_info_per_id *oipi = NULL;
  721.   if ((functab = ospf_opaque_functab_lookup (new)) == NULL)
  722.     goto out;
  724.   if ((oipt = lookup_opaque_info_by_type (new)) == NULL
  725.   &&  (oipt = register_opaque_info_per_type (functab, new)) == NULL)
  726.     goto out;
  728.   if ((oipi = register_opaque_info_per_id (oipt, new)) == NULL)
  729.     goto out;
  731. out:
  732.   return oipi;
  733. }
  735. /*------------------------------------------------------------------------*
  736.  * Followings are (vty) configuration functions for Opaque-LSAs handling.
  737.  *------------------------------------------------------------------------*/
  739. DEFUN (capability_opaque,
  740.        capability_opaque_cmd,
  741.        "capability opaque",
  742.        "Enable specific OSPF featuren"
  743.        "Opaque LSAn")
  744. {
  745.   struct ospf *ospf = (struct ospf *) vty->index;
  747.   /* Turn on the "master switch" of opaque-lsa capability. */
  748.   if (!CHECK_FLAG (ospf->config, OSPF_OPAQUE_CAPABLE))
  749.     {
  750.       if (IS_DEBUG_OSPF_EVENT)
  751.         zlog_info ("Opaque capability: OFF -> ON");
  753.       SET_FLAG (ospf->config, OSPF_OPAQUE_CAPABLE);
  754.       ospf_renegotiate_optional_capabilities (ospf);
  755.     }
  756.   return CMD_SUCCESS;
  757. }
  759. ALIAS (capability_opaque,
  760.        ospf_opaque_capable_cmd,
  761.        "ospf opaque-lsa",
  762.        "OSPF specific commandsn"
  763.        "Enable the Opaque-LSA capability (rfc2370)n");
  765. DEFUN (no_capability_opaque,
  766.        no_capability_opaque_cmd,
  767.        "no capability opaque",
  768.        NO_STR
  769.        "Enable specific OSPF featuren"
  770.        "Opaque LSAn")
  771. {
  772.   struct ospf *ospf = (struct ospf *) vty->index;
  774.   /* Turn off the "master switch" of opaque-lsa capability. */
  775.   if (CHECK_FLAG (ospf->config, OSPF_OPAQUE_CAPABLE))
  776.     {
  777.       if (IS_DEBUG_OSPF_EVENT)
  778.         zlog_info ("Opaque capability: ON -> OFF");
  780.       UNSET_FLAG (ospf->config, OSPF_OPAQUE_CAPABLE);
  781.       ospf_renegotiate_optional_capabilities (ospf);
  782.     }
  783.   return CMD_SUCCESS;
  784. }
  786. ALIAS (no_capability_opaque,
  787.        no_ospf_opaque_capable_cmd,
  788.        "no ospf opaque-lsa",
  789.        NO_STR
  790.        "OSPF specific commandsn"
  791.        "Disable the Opaque-LSA capability (rfc2370)n");
  793. static void
  794. ospf_opaque_register_vty (void)
  795. {
  796.   install_element (OSPF_NODE, &capability_opaque_cmd);
  797.   install_element (OSPF_NODE, &no_capability_opaque_cmd);
  798.   install_element (OSPF_NODE, &ospf_opaque_capable_cmd);
  799.   install_element (OSPF_NODE, &no_ospf_opaque_capable_cmd);
  800.   return;
  801. }
  803. /*------------------------------------------------------------------------*
  804.  * Followings are collection of user-registered function callers.
  805.  *------------------------------------------------------------------------*/
  807. static int
  808. opaque_lsa_new_if_callback (list funclist, struct interface *ifp)
  809. {
  810.   listnode node;
  811.   struct ospf_opaque_functab *functab;
  812.   int rc = -1;
  814.   for (node = listhead (funclist); node; nextnode (node))
  815.     if ((functab = getdata (node)) != NULL)
  816.       if (functab->new_if_hook != NULL)
  817.         if ((* functab->new_if_hook)(ifp) != 0)
  818.           goto out;
  819.   rc = 0;
  820. out:
  821.   return rc;
  822. }
  824. static int
  825. opaque_lsa_del_if_callback (list funclist, struct interface *ifp)
  826. {
  827.   listnode node;
  828.   struct ospf_opaque_functab *functab;
  829.   int rc = -1;
  831.   for (node = listhead (funclist); node; nextnode (node))
  832.     if ((functab = getdata (node)) != NULL)
  833.       if (functab->del_if_hook != NULL)
  834.         if ((* functab->del_if_hook)(ifp) != 0)
  835.           goto out;
  836.   rc = 0;
  837. out:
  838.   return rc;
  839. }
  841. static void
  842. opaque_lsa_ism_change_callback (list funclist,
  843.                                 struct ospf_interface *oi, int old_status)
  844. {
  845.   listnode node;
  846.   struct ospf_opaque_functab *functab;
  848.   for (node = listhead (funclist); node; nextnode (node))
  849.     if ((functab = getdata (node)) != NULL)
  850.       if (functab->ism_change_hook != NULL)
  851.         (* functab->ism_change_hook)(oi, old_status);
  852.   return;
  853. }
  855. static void
  856. opaque_lsa_nsm_change_callback (list funclist,
  857.                                 struct ospf_neighbor *nbr, int old_status)
  858. {
  859.   listnode node;
  860.   struct ospf_opaque_functab *functab;
  862.   for (node = listhead (funclist); node; nextnode (node))
  863.     if ((functab = getdata (node)) != NULL)
  864.       if (functab->nsm_change_hook != NULL)
  865.         (* functab->nsm_change_hook)(nbr, old_status);
  866.   return;
  867. }
  869. static void
  870. opaque_lsa_config_write_router_callback (list funclist, struct vty *vty)
  871. {
  872.   listnode node;
  873.   struct ospf_opaque_functab *functab;
  875.   for (node = listhead (funclist); node; nextnode (node))
  876.     if ((functab = getdata (node)) != NULL)
  877.       if (functab->config_write_router != NULL)
  878.         (* functab->config_write_router)(vty);
  879.   return;
  880. }
  882. static void
  883. opaque_lsa_config_write_if_callback (list funclist,
  884.                                      struct vty *vty, struct interface *ifp)
  885. {
  886.   listnode node;
  887.   struct ospf_opaque_functab *functab;
  889.   for (node = listhead (funclist); node; nextnode (node))
  890.     if ((functab = getdata (node)) != NULL)
  891.       if (functab->config_write_if != NULL)
  892.         (* functab->config_write_if)(vty, ifp);
  893.   return;
  894. }
  896. static void
  897. opaque_lsa_config_write_debug_callback (list funclist, struct vty *vty)
  898. {
  899.   listnode node;
  900.   struct ospf_opaque_functab *functab;
  902.   for (node = listhead (funclist); node; nextnode (node))
  903.     if ((functab = getdata (node)) != NULL)
  904.       if (functab->config_write_debug != NULL)
  905.         (* functab->config_write_debug)(vty);
  906.   return;
  907. }
  909. static int
  910. opaque_lsa_originate_callback (list funclist, void *lsa_type_dependent)
  911. {
  912.   listnode node;
  913.   struct ospf_opaque_functab *functab;
  914.   int rc = -1;
  916.   for (node = listhead (funclist); node; nextnode (node))
  917.     if ((functab = getdata (node)) != NULL)
  918.       if (functab->lsa_originator != NULL)
  919.         if ((* functab->lsa_originator)(lsa_type_dependent) != 0)
  920.            goto out;
  921.   rc = 0;
  922. out:
  923.   return rc;
  924. }
  926. static int
  927. new_lsa_callback (list funclist, struct ospf_lsa *lsa)
  928. {
  929.   listnode node;
  930.   struct ospf_opaque_functab *functab;
  931.   int rc = -1;
  933.   /* This function handles ALL types of LSAs, not only opaque ones. */
  934.   for (node = listhead (funclist); node; nextnode (node))
  935.     if ((functab = getdata (node)) != NULL)
  936.       if (functab->new_lsa_hook != NULL)
  937.         if ((* functab->new_lsa_hook)(lsa) != 0)
  938.           goto out;
  939.   rc = 0;
  940. out:
  941.   return rc;
  942. }
  944. static int
  945. del_lsa_callback (list funclist, struct ospf_lsa *lsa)
  946. {
  947.   listnode node;
  948.   struct ospf_opaque_functab *functab;
  949.   int rc = -1;
  951.   /* This function handles ALL types of LSAs, not only opaque ones. */
  952.   for (node = listhead (funclist); node; nextnode (node))
  953.     if ((functab = getdata (node)) != NULL)
  954.       if (functab->del_lsa_hook != NULL)
  955.         if ((* functab->del_lsa_hook)(lsa) != 0)
  956.           goto out;
  957.   rc = 0;
  958. out:
  959.   return rc;
  960. }
  962. /*------------------------------------------------------------------------*
  963.  * Followings are glue functions to call Opaque-LSA specific processing.
  964.  *------------------------------------------------------------------------*/
  966. int
  967. ospf_opaque_new_if (struct interface *ifp)
  968. {
  969.   list funclist;
  970.   int rc = -1;
  972.   funclist = ospf_opaque_wildcard_funclist;
  973.   if (opaque_lsa_new_if_callback (funclist, ifp) != 0)
  974.     goto out;
  976.   funclist = ospf_opaque_type9_funclist;
  977.   if (opaque_lsa_new_if_callback (funclist, ifp) != 0)
  978.     goto out;
  980.   funclist = ospf_opaque_type10_funclist;
  981.   if (opaque_lsa_new_if_callback (funclist, ifp) != 0)
  982.     goto out;
  984.   funclist = ospf_opaque_type11_funclist;
  985.   if (opaque_lsa_new_if_callback (funclist, ifp) != 0)
  986.     goto out;
  988.   rc = 0;
  989. out:
  990.   return rc;
  991. }
  993. int
  994. ospf_opaque_del_if (struct interface *ifp)
  995. {
  996.   list funclist;
  997.   int rc = -1;
  999.   funclist = ospf_opaque_wildcard_funclist;
  1000.   if (opaque_lsa_del_if_callback (funclist, ifp) != 0)
  1001.     goto out;
  1003.   funclist = ospf_opaque_type9_funclist;
  1004.   if (opaque_lsa_del_if_callback (funclist, ifp) != 0)
  1005.     goto out;
  1007.   funclist = ospf_opaque_type10_funclist;
  1008.   if (opaque_lsa_del_if_callback (funclist, ifp) != 0)
  1009.     goto out;
  1011.   funclist = ospf_opaque_type11_funclist;
  1012.   if (opaque_lsa_del_if_callback (funclist, ifp) != 0)
  1013.     goto out;
  1015.   rc = 0;
  1016. out:
  1017.   return rc;
  1018. }
  1020. void
  1021. ospf_opaque_ism_change (struct ospf_interface *oi, int old_status)
  1022. {
  1023.   list funclist;
  1025.   funclist = ospf_opaque_wildcard_funclist;
  1026.   opaque_lsa_ism_change_callback (funclist, oi, old_status);
  1028.   funclist = ospf_opaque_type9_funclist;
  1029.   opaque_lsa_ism_change_callback (funclist, oi, old_status);
  1031.   funclist = ospf_opaque_type10_funclist;
  1032.   opaque_lsa_ism_change_callback (funclist, oi, old_status);
  1034.   funclist = ospf_opaque_type11_funclist;
  1035.   opaque_lsa_ism_change_callback (funclist, oi, old_status);
  1037.   return;
  1038. }
  1040. void
  1041. ospf_opaque_nsm_change (struct ospf_neighbor *nbr, int old_state)
  1042. {
  1043.   struct ospf *top;
  1044.   list funclist;
  1046.   if ((top = oi_to_top (nbr->oi)) == NULL)
  1047.     goto out;
  1049.   if (old_state != NSM_Full && nbr->state == NSM_Full)
  1050.     {
  1051.       if (CHECK_FLAG (nbr->options, OSPF_OPTION_O))
  1052.         {
  1053.           if (! CHECK_FLAG (top->opaque, OPAQUE_OPERATION_READY_BIT))
  1054.             {
  1055.               if (IS_DEBUG_OSPF_EVENT)
  1056.                 zlog_info ("Opaque-LSA: Now get operational!");
  1058.               SET_FLAG (top->opaque, OPAQUE_OPERATION_READY_BIT);
  1059.             }
  1061.           ospf_opaque_lsa_originate_schedule (nbr->oi, NULL);
  1062.         }
  1063.     }
  1064.   else
  1065.   if (old_state == NSM_Full && nbr->state != NSM_Full)
  1066.     {
  1067. #ifdef NOTYET
  1068.       /*
  1069.        * If no more opaque-capable full-state neighbor remains in the
  1070.        * flooding scope which corresponds to Opaque-LSA type, periodic
  1071.        * LS flooding should be stopped.
  1072.        */
  1073. #endif /* NOTYET */
  1074.       ;
  1075.     }
  1077.   funclist = ospf_opaque_wildcard_funclist;
  1078.   opaque_lsa_nsm_change_callback (funclist, nbr, old_state);
  1080.   funclist = ospf_opaque_type9_funclist;
  1081.   opaque_lsa_nsm_change_callback (funclist, nbr, old_state);
  1083.   funclist = ospf_opaque_type10_funclist;
  1084.   opaque_lsa_nsm_change_callback (funclist, nbr, old_state);
  1086.   funclist = ospf_opaque_type11_funclist;
  1087.   opaque_lsa_nsm_change_callback (funclist, nbr, old_state);
  1089. out:
  1090.   return;
  1091. }
  1093. void
  1094. ospf_opaque_config_write_router (struct vty *vty, struct ospf *ospf)
  1095. {
  1096.   list funclist;
  1098.   if (CHECK_FLAG (ospf->config, OSPF_OPAQUE_CAPABLE))
  1099.     vty_out (vty, " capability opaque%s", VTY_NEWLINE);
  1101.   funclist = ospf_opaque_wildcard_funclist;
  1102.   opaque_lsa_config_write_router_callback (funclist, vty);
  1104.   funclist = ospf_opaque_type9_funclist;
  1105.   opaque_lsa_config_write_router_callback (funclist, vty);
  1107.   funclist = ospf_opaque_type10_funclist;
  1108.   opaque_lsa_config_write_router_callback (funclist, vty);
  1110.   funclist = ospf_opaque_type11_funclist;
  1111.   opaque_lsa_config_write_router_callback (funclist, vty);
  1113.   return;
  1114. }
  1116. void
  1117. ospf_opaque_config_write_if (struct vty *vty, struct interface *ifp)
  1118. {
  1119.   list funclist;
  1121.   funclist = ospf_opaque_wildcard_funclist;
  1122.   opaque_lsa_config_write_if_callback (funclist, vty, ifp);
  1124.   funclist = ospf_opaque_type9_funclist;
  1125.   opaque_lsa_config_write_if_callback (funclist, vty, ifp);
  1127.   funclist = ospf_opaque_type10_funclist;
  1128.   opaque_lsa_config_write_if_callback (funclist, vty, ifp);
  1130.   funclist = ospf_opaque_type11_funclist;
  1131.   opaque_lsa_config_write_if_callback (funclist, vty, ifp);
  1133.   return;
  1134. }
  1136. void
  1137. ospf_opaque_config_write_debug (struct vty *vty)
  1138. {
  1139.   list funclist;
  1141.   funclist = ospf_opaque_wildcard_funclist;
  1142.   opaque_lsa_config_write_debug_callback (funclist, vty);
  1144.   funclist = ospf_opaque_type9_funclist;
  1145.   opaque_lsa_config_write_debug_callback (funclist, vty);
  1147.   funclist = ospf_opaque_type10_funclist;
  1148.   opaque_lsa_config_write_debug_callback (funclist, vty);
  1150.   funclist = ospf_opaque_type11_funclist;
  1151.   opaque_lsa_config_write_debug_callback (funclist, vty);
  1153.   return;
  1154. }
  1156. void
  1157. show_opaque_info_detail (struct vty *vty, struct ospf_lsa *lsa)
  1158. {
  1159.   struct lsa_header *lsah = (struct lsa_header *) lsa->data;
  1160.   u_int32_t lsid = ntohl (lsah->id.s_addr);
  1161.   u_char    opaque_type = GET_OPAQUE_TYPE (lsid);
  1162.   u_int32_t opaque_id = GET_OPAQUE_ID (lsid);
  1163.   struct ospf_opaque_functab *functab;
  1165.   /* Switch output functionality by vty address. */
  1166.   if (vty != NULL)
  1167.     {
  1168.       vty_out (vty, "  Opaque-Type %u (%s)%s", opaque_type,
  1169.        ospf_opaque_type_name (opaque_type), VTY_NEWLINE);
  1170.       vty_out (vty, "  Opaque-ID   0x%x%s", opaque_id, VTY_NEWLINE);
  1172.       vty_out (vty, "  Opaque-Info: %u octets of data%s%s",
  1173.                ntohs (lsah->length) - OSPF_LSA_HEADER_SIZE,
  1174.                VALID_OPAQUE_INFO_LEN(lsah) ? "" : "(Invalid length?)",
  1175.                VTY_NEWLINE);
  1176.     }
  1177.   else
  1178.     {
  1179.       zlog_info ("    Opaque-Type %u (%s)", opaque_type,
  1180.  ospf_opaque_type_name (opaque_type));
  1181.       zlog_info ("    Opaque-ID   0x%x", opaque_id);
  1183.       zlog_info ("    Opaque-Info: %u octets of data%s",
  1184.                ntohs (lsah->length) - OSPF_LSA_HEADER_SIZE,
  1185.                VALID_OPAQUE_INFO_LEN(lsah) ? "" : "(Invalid length?)");
  1186.     }
  1188.   /* Call individual output functions. */
  1189.   if ((functab = ospf_opaque_functab_lookup (lsa)) != NULL)
  1190.     if (functab->show_opaque_info != NULL)
  1191.       (* functab->show_opaque_info)(vty, lsa);
  1193.   return;
  1194. }
  1196. void
  1197. ospf_opaque_lsa_dump (struct stream *s, u_int16_t length)
  1198. {
  1199.   struct ospf_lsa lsa;
  1201.   lsa.data = (struct lsa_header *) STREAM_PNT (s);
  1202.   show_opaque_info_detail (NULL, &lsa);
  1203.   return;
  1204. }
  1206. static int
  1207. ospf_opaque_lsa_install_hook (struct ospf_lsa *lsa)
  1208. {
  1209.   list funclist;
  1210.   int rc = -1;
  1212.   /*
  1213.    * Some Opaque-LSA user may want to monitor every LSA installation
  1214.    * into the LSDB, regardless with target LSA type.
  1215.    */
  1216.   funclist = ospf_opaque_wildcard_funclist;
  1217.   if (new_lsa_callback (funclist, lsa) != 0)
  1218.     goto out;
  1220.   funclist = ospf_opaque_type9_funclist;
  1221.   if (new_lsa_callback (funclist, lsa) != 0)
  1222.     goto out;
  1224.   funclist = ospf_opaque_type10_funclist;
  1225.   if (new_lsa_callback (funclist, lsa) != 0)
  1226.     goto out;
  1228.   funclist = ospf_opaque_type11_funclist;
  1229.   if (new_lsa_callback (funclist, lsa) != 0)
  1230.     goto out;
  1232.   rc = 0;
  1233. out:
  1234.   return rc;
  1235. }
  1237. static int
  1238. ospf_opaque_lsa_delete_hook (struct ospf_lsa *lsa)
  1239. {
  1240.   list funclist;
  1241.   int rc = -1;
  1243.   /*
  1244.    * Some Opaque-LSA user may want to monitor every LSA deletion
  1245.    * from the LSDB, regardless with target LSA type.
  1246.    */
  1247.   funclist = ospf_opaque_wildcard_funclist;
  1248.   if (del_lsa_callback (funclist, lsa) != 0)
  1249.     goto out;
  1251.   funclist = ospf_opaque_type9_funclist;
  1252.   if (del_lsa_callback (funclist, lsa) != 0)
  1253.     goto out;
  1255.   funclist = ospf_opaque_type10_funclist;
  1256.   if (del_lsa_callback (funclist, lsa) != 0)
  1257.     goto out;
  1259.   funclist = ospf_opaque_type11_funclist;
  1260.   if (del_lsa_callback (funclist, lsa) != 0)
  1261.     goto out;
  1263.   rc = 0;
  1264. out:
  1265.   return rc;
  1266. }
  1268. /*------------------------------------------------------------------------*
  1269.  * Followings are Opaque-LSA origination/refresh management functions.
  1270.  *------------------------------------------------------------------------*/
  1272. static int ospf_opaque_type9_lsa_originate (struct thread *t);
  1273. static int ospf_opaque_type10_lsa_originate (struct thread *t);
  1274. static int ospf_opaque_type11_lsa_originate (struct thread *t);
  1275. static void ospf_opaque_lsa_reoriginate_resume (list listtop, void *arg);
  1277. void
  1278. ospf_opaque_lsa_originate_schedule (struct ospf_interface *oi, int *delay0)
  1279. {
  1280.   struct ospf *top;
  1281.   struct ospf_area *area;
  1282.   listnode node;
  1283.   struct opaque_info_per_type *oipt;
  1284.   int delay = 0;
  1286.   if ((top = oi_to_top (oi)) == NULL || (area = oi->area) == NULL)
  1287.     {
  1288.       zlog_warn ("ospf_opaque_lsa_originate_schedule: Invalid argument?");
  1289.       goto out;
  1290.     }
  1292.   /* It may not a right time to schedule origination now. */
  1293.   if (! CHECK_FLAG (top->opaque, OPAQUE_OPERATION_READY_BIT))
  1294.     {
  1295.       if (IS_DEBUG_OSPF_EVENT)
  1296.         zlog_info ("ospf_opaque_lsa_originate_schedule: Not operational.");
  1297.       goto out; /* This is not an error. */
  1298.     }
  1299.   if (IS_OPAQUE_LSA_ORIGINATION_BLOCKED (top->opaque))
  1300.     {
  1301.       if (IS_DEBUG_OSPF_EVENT)
  1302.         zlog_info ("ospf_opaque_lsa_originate_schedule: Under blockade.");
  1303.       goto out; /* This is not an error, too. */
  1304.     }
  1306.   if (delay0 != NULL)
  1307.     delay = *delay0;
  1309.   /*
  1310.    * There might be some entries that have been waiting for triggering
  1311.    * of per opaque-type re-origination get resumed.
  1312.    */
  1313.   ospf_opaque_lsa_reoriginate_resume (  oi->opaque_lsa_self, (void *)   oi);
  1314.   ospf_opaque_lsa_reoriginate_resume (area->opaque_lsa_self, (void *) area);
  1315.   ospf_opaque_lsa_reoriginate_resume ( top->opaque_lsa_self, (void *)  top);
  1317.   /*
  1318.    * Now, schedule origination of all Opaque-LSAs per opaque-type.
  1319.    */
  1320.   if (! list_isempty (ospf_opaque_type9_funclist)
  1321.   &&    list_isempty (oi->opaque_lsa_self)
  1322.   &&    oi->t_opaque_lsa_self == NULL)
  1323.     {
  1324.       if (IS_DEBUG_OSPF_EVENT)
  1325.         zlog_info ("Schedule Type-9 Opaque-LSA origination in %d sec later.", delay);
  1326.       oi->t_opaque_lsa_self =
  1327. thread_add_timer (master, ospf_opaque_type9_lsa_originate, oi, delay);
  1328.       delay += OSPF_MIN_LS_INTERVAL;
  1329.     }
  1331.   if (! list_isempty (ospf_opaque_type10_funclist)
  1332.   &&    list_isempty (area->opaque_lsa_self)
  1333.   &&    area->t_opaque_lsa_self == NULL)
  1334.     {
  1335.       /*
  1336.        * One AREA may contain multiple OIs, but above 2nd and 3rd
  1337.        * conditions prevent from scheduling the originate function
  1338.        * again and again.
  1339.        */
  1340.       if (IS_DEBUG_OSPF_EVENT)
  1341.         zlog_info ("Schedule Type-10 Opaque-LSA origination in %d sec later.", delay);
  1342.       area->t_opaque_lsa_self =
  1343.         thread_add_timer (master, ospf_opaque_type10_lsa_originate,
  1344.                           area, delay);
  1345.       delay += OSPF_MIN_LS_INTERVAL;
  1346.     }
  1348.   if (! list_isempty (ospf_opaque_type11_funclist)
  1349.   &&    list_isempty (top->opaque_lsa_self)
  1350.   &&    top->t_opaque_lsa_self == NULL)
  1351.     {
  1352.       /*
  1353.        * One OSPF may contain multiple AREAs, but above 2nd and 3rd
  1354.        * conditions prevent from scheduling the originate function
  1355.        * again and again.
  1356.        */
  1357.       if (IS_DEBUG_OSPF_EVENT)
  1358.         zlog_info ("Schedule Type-11 Opaque-LSA origination in %d sec later.", delay);
  1359.       top->t_opaque_lsa_self =
  1360.         thread_add_timer (master, ospf_opaque_type11_lsa_originate,
  1361.                           top, delay);
  1362.       delay += OSPF_MIN_LS_INTERVAL;
  1363.     }
  1365.   /*
  1366.    * Following section treats a special situation that this node's
  1367.    * opaque capability has changed as "ON -> OFF -> ON".
  1368.    */
  1369.   if (! list_isempty (ospf_opaque_type9_funclist)
  1370.   &&  ! list_isempty (oi->opaque_lsa_self))
  1371.     {
  1372.       for (node = listhead (oi->opaque_lsa_self); node; nextnode (node))
  1373.         {
  1374.           if ((oipt = getdata (node))  == NULL /* Something wrong? */
  1375.           ||   oipt->t_opaque_lsa_self != NULL /* Waiting for a thread call. */
  1376.           ||   oipt->status == PROC_SUSPEND    /* Cannot originate now. */
  1377.           ||  ! list_isempty (oipt->id_list))  /* Handler is already active. */
  1378.               continue;
  1380.           ospf_opaque_lsa_reoriginate_schedule ((void *) oi,
  1381.             OSPF_OPAQUE_LINK_LSA, oipt->opaque_type);
  1382.         }
  1383.     }
  1385.   if (! list_isempty (ospf_opaque_type10_funclist)
  1386.   &&  ! list_isempty (area->opaque_lsa_self))
  1387.     {
  1388.       for (node = listhead (area->opaque_lsa_self); node; nextnode (node))
  1389.         {
  1390.           if ((oipt = getdata (node))  == NULL /* Something wrong? */
  1391.           ||   oipt->t_opaque_lsa_self != NULL /* Waiting for a thread call. */
  1392.           ||   oipt->status == PROC_SUSPEND    /* Cannot originate now. */
  1393.           ||  ! list_isempty (oipt->id_list))  /* Handler is already active. */
  1394.             continue;
  1396.           ospf_opaque_lsa_reoriginate_schedule ((void *) area,
  1397.             OSPF_OPAQUE_AREA_LSA, oipt->opaque_type);
  1398.         }
  1399.     }
  1401.   if (! list_isempty (ospf_opaque_type11_funclist)
  1402.   &&  ! list_isempty (top->opaque_lsa_self))
  1403.     {
  1404.       for (node = listhead (top->opaque_lsa_self); node; nextnode (node))
  1405.         {
  1406.           if ((oipt = getdata (node))  == NULL /* Something wrong? */
  1407.           ||   oipt->t_opaque_lsa_self != NULL /* Waiting for a thread call. */
  1408.           ||   oipt->status == PROC_SUSPEND    /* Cannot originate now. */
  1409.           ||  ! list_isempty (oipt->id_list))  /* Handler is already active. */
  1410.             continue;
  1412.           ospf_opaque_lsa_reoriginate_schedule ((void *) top,
  1413.             OSPF_OPAQUE_AS_LSA, oipt->opaque_type);
  1414.         }
  1415.     }
  1417.   if (delay0 != NULL)
  1418.     *delay0 = delay;
  1420. out:
  1421.   return;
  1422. }
  1424. static int
  1425. ospf_opaque_type9_lsa_originate (struct thread *t)
  1426. {
  1427.   struct ospf_interface *oi;
  1428.   int rc;
  1430.   oi = THREAD_ARG (t);
  1431.   oi->t_opaque_lsa_self = NULL;
  1433.   if (IS_DEBUG_OSPF_EVENT)
  1434.     zlog_info ("Timer[Type9-LSA]: Originate Opaque-LSAs for OI %s",
  1435.                 IF_NAME (oi));
  1437.   rc = opaque_lsa_originate_callback (ospf_opaque_type9_funclist, oi);
  1439.   return rc;
  1440. }
  1442. static int
  1443. ospf_opaque_type10_lsa_originate (struct thread *t)
  1444. {
  1445.   struct ospf_area *area;
  1446.   int rc;
  1448.   area = THREAD_ARG (t);
  1449.   area->t_opaque_lsa_self = NULL;
  1451.   if (IS_DEBUG_OSPF_EVENT)
  1452.     zlog_info ("Timer[Type10-LSA]: Originate Opaque-LSAs for Area %s",
  1453.                 inet_ntoa (area->area_id));
  1455.   rc = opaque_lsa_originate_callback (ospf_opaque_type10_funclist, area);
  1457.   return rc;
  1458. }
  1460. static int
  1461. ospf_opaque_type11_lsa_originate (struct thread *t)
  1462. {
  1463.   struct ospf *top;
  1464.   int rc;
  1466.   top = THREAD_ARG (t);
  1467.   top->t_opaque_lsa_self = NULL;
  1469.   if (IS_DEBUG_OSPF_EVENT)
  1470.     zlog_info ("Timer[Type11-LSA]: Originate AS-External Opaque-LSAs");
  1472.   rc = opaque_lsa_originate_callback (ospf_opaque_type11_funclist, top);
  1474.   return rc;
  1475. }
  1477. static void
  1478. ospf_opaque_lsa_reoriginate_resume (list listtop, void *arg)
  1479. {
  1480.   listnode node;
  1481.   struct opaque_info_per_type *oipt;
  1482.   struct ospf_opaque_functab *functab;
  1484.   if (listtop == NULL)
  1485.     goto out;
  1487.   /*
  1488.    * Pickup oipt entries those which in SUSPEND status, and give
  1489.    * them a chance to start re-origination now.
  1490.    */
  1491.   for (node = listhead (listtop); node; nextnode (node))
  1492.     {
  1493.       if ((oipt = getdata (node)) == NULL
  1494.       ||   oipt->status != PROC_SUSPEND)
  1495.           continue;
  1497.       oipt->status = PROC_NORMAL;
  1499.       if ((functab = oipt->functab) == NULL
  1500.       ||   functab->lsa_originator  == NULL)
  1501.         continue;
  1503.       if ((* functab->lsa_originator)(arg) != 0)
  1504.         {
  1505.           zlog_warn ("ospf_opaque_lsa_reoriginate_resume: Failed (opaque-type=%u)", oipt->opaque_type);
  1506.           continue;
  1507.         }
  1508.     }
  1510. out:
  1511.   return;
  1512. }
  1514. struct ospf_lsa *
  1515. ospf_opaque_lsa_install (struct ospf_lsa *lsa, int rt_recalc)
  1516. {
  1517.   struct ospf_lsa *new = NULL;
  1518.   struct opaque_info_per_type *oipt;
  1519.   struct opaque_info_per_id *oipi;
  1520.   struct ospf *top;
  1522.   /* Don't take "rt_recalc" into consideration for now. *//* XXX */
  1524.   if (! IS_LSA_SELF (lsa))
  1525.     {
  1526.       new = lsa; /* Don't touch this LSA. */
  1527.       goto out;
  1528.     }
  1530.   if (IS_DEBUG_OSPF (lsa, LSA_INSTALL))
  1531.     zlog_info ("Install Type-%u Opaque-LSA: [opaque-type=%u, opaque-id=%x]", lsa->data->type, GET_OPAQUE_TYPE (ntohl (lsa->data->id.s_addr)), GET_OPAQUE_ID (ntohl (lsa->data->id.s_addr)));
  1533.   /* Replace the existing lsa with the new one. */
  1534.   if ((oipt = lookup_opaque_info_by_type (lsa)) != NULL
  1535.   &&  (oipi = lookup_opaque_info_by_id (oipt, lsa)) != NULL)
  1536.     {
  1537.       ospf_lsa_unlock (oipi->lsa);
  1538.       oipi->lsa = ospf_lsa_lock (lsa);
  1539.     }
  1540.   /* Register the new lsa entry and get its control info. */
  1541.   else
  1542.   if ((oipi = register_opaque_lsa (lsa)) == NULL)
  1543.     {
  1544.       zlog_warn ("ospf_opaque_lsa_install: register_opaque_lsa() ?");
  1545.       goto out;
  1546.     }
  1548.   /*
  1549.    * Make use of a common mechanism (ospf_lsa_refresh_walker)
  1550.    * for periodic refresh of self-originated Opaque-LSAs.
  1551.    */
  1552.   switch (lsa->data->type)
  1553.     {
  1554.     case OSPF_OPAQUE_LINK_LSA:
  1555.       if ((top = oi_to_top (lsa->oi)) == NULL)
  1556.         {
  1557.           /* Above conditions must have passed. */
  1558.           zlog_warn ("ospf_opaque_lsa_install: Sonmething wrong?");
  1559.           goto out;
  1560.         }
  1561.       break;
  1562.     case OSPF_OPAQUE_AREA_LSA:
  1563.       if (lsa->area == NULL || (top = lsa->area->ospf) == NULL)
  1564.         {
  1565.           /* Above conditions must have passed. */
  1566.           zlog_warn ("ospf_opaque_lsa_install: Sonmething wrong?");
  1567.           goto out;
  1568.         }
  1569.       break;
  1570.     case OSPF_OPAQUE_AS_LSA:
  1571.       top = ospf_lookup ();
  1572.       if (lsa->area != NULL && (top = lsa->area->ospf) == NULL)
  1573.         {
  1574.           /* Above conditions must have passed. */
  1575.           zlog_warn ("ospf_opaque_lsa_install: Sonmething wrong?");
  1576.           goto out;
  1577.         }
  1578.       break;
  1579.     default:
  1580.       zlog_warn ("ospf_opaque_lsa_install: Unexpected LSA-type(%u)", lsa->data->type);
  1581.       goto out;
  1582.     }
  1584.   ospf_refresher_register_lsa (top, lsa);
  1585.   new = lsa;
  1587. out:
  1588.   return new;
  1589. }
  1591. void
  1592. ospf_opaque_lsa_refresh (struct ospf_lsa *lsa)
  1593. {
  1594.   struct ospf *ospf;
  1595.   struct ospf_opaque_functab *functab;
  1597.   ospf = ospf_lookup ();
  1599.   if ((functab = ospf_opaque_functab_lookup (lsa)) == NULL
  1600.   ||   functab->lsa_refresher == NULL)
  1601.     {
  1602.       /*
  1603.        * Though this LSA seems to have originated on this node, the
  1604.        * handling module for this "lsa-type and opaque-type" was
  1605.        * already deleted sometime ago.
  1606.        * Anyway, this node still has a responsibility to flush this
  1607.        * LSA from the routing domain.
  1608.        */
  1609.       if (IS_DEBUG_OSPF_EVENT)
  1610.         zlog_info ("LSA[Type%d:%s]: Flush stray Opaque-LSA", lsa->data->type, inet_ntoa (lsa->data->id));
  1612.       lsa->data->ls_age = htons (OSPF_LSA_MAXAGE);
  1613.       ospf_lsa_maxage (ospf, lsa);
  1614.     }
  1615.   else
  1616.     (* functab->lsa_refresher)(lsa);
  1618.   return;
  1619. }
  1621. /*------------------------------------------------------------------------*
  1622.  * Followings are re-origination/refresh/flush operations of Opaque-LSAs,
  1623.  * triggered by external interventions (vty session, signaling, etc).
  1624.  *------------------------------------------------------------------------*/
  1626. #define OSPF_OPAQUE_TIMER_ON(T,F,L,V) 
  1627.       if (!(T)) 
  1628.         (T) = thread_add_timer (master, (F), (L), (V))
  1630. static struct ospf_lsa *pseudo_lsa (struct ospf_interface *oi, struct ospf_area *area, u_char lsa_type, u_char opaque_type);
  1631. static int ospf_opaque_type9_lsa_reoriginate_timer (struct thread *t);
  1632. static int ospf_opaque_type10_lsa_reoriginate_timer (struct thread *t);
  1633. static int ospf_opaque_type11_lsa_reoriginate_timer (struct thread *t);
  1634. static int ospf_opaque_lsa_refresh_timer (struct thread *t);
  1636. void
  1637. ospf_opaque_lsa_reoriginate_schedule (void *lsa_type_dependent,
  1638.                                       u_char lsa_type, u_char opaque_type)
  1639. {
  1640.   struct ospf *top;
  1641.   struct ospf_area dummy, *area = NULL;
  1642.   struct ospf_interface *oi = NULL;
  1644.   struct ospf_lsa *lsa;
  1645.   struct opaque_info_per_type *oipt;
  1646.   int (* func)(struct thread *t) = NULL;
  1647.   int delay;
  1649.   switch (lsa_type)
  1650.     {
  1651.     case OSPF_OPAQUE_LINK_LSA:
  1652.       if ((oi = (struct ospf_interface *) lsa_type_dependent) == NULL)
  1653.         {
  1654.           zlog_warn ("ospf_opaque_lsa_reoriginate_schedule: Type-9 Opaque-LSA: Invalid parameter?");
  1655.   goto out;
  1656.         }
  1657.       if ((top = oi_to_top (oi)) == NULL)
  1658.         {
  1659.           zlog_warn ("ospf_opaque_lsa_reoriginate_schedule: OI(%s) -> TOP?", IF_NAME (oi));
  1660.           goto out;
  1661.         }
  1662.       if (! list_isempty (ospf_opaque_type9_funclist)
  1663.       &&    list_isempty (oi->opaque_lsa_self)
  1664.       &&    oi->t_opaque_lsa_self != NULL)
  1665.         {
  1666.           zlog_warn ("Type-9 Opaque-LSA (opaque_type=%u): Common origination for OI(%s) has already started", opaque_type, IF_NAME (oi));
  1667.           goto out;
  1668.         }
  1669.       func = ospf_opaque_type9_lsa_reoriginate_timer;
  1670.       break;
  1671.     case OSPF_OPAQUE_AREA_LSA:
  1672.       if ((area = (struct ospf_area *) lsa_type_dependent) == NULL)
  1673.         {
  1674.           zlog_warn ("ospf_opaque_lsa_reoriginate_schedule: Type-10 Opaque-LSA: Invalid parameter?");
  1675.           goto out;
  1676.         }
  1677.       if ((top = area->ospf) == NULL)
  1678.         {
  1679.           zlog_warn ("ospf_opaque_lsa_reoriginate_schedule: AREA(%s) -> TOP?", inet_ntoa (area->area_id));
  1680.           goto out;
  1681.         }
  1682.       if (! list_isempty (ospf_opaque_type10_funclist)
  1683.       &&    list_isempty (area->opaque_lsa_self)
  1684.       &&    area->t_opaque_lsa_self != NULL)
  1685.         {
  1686.           zlog_warn ("Type-10 Opaque-LSA (opaque_type=%u): Common origination for AREA(%s) has already started", opaque_type, inet_ntoa (area->area_id));
  1687.           goto out;
  1688.         }
  1689.       func = ospf_opaque_type10_lsa_reoriginate_timer;
  1690.       break;
  1691.     case OSPF_OPAQUE_AS_LSA:
  1692.       if ((top = (struct ospf *) lsa_type_dependent) == NULL)
  1693.         {
  1694.           zlog_warn ("ospf_opaque_lsa_reoriginate_schedule: Type-11 Opaque-LSA: Invalid parameter?");
  1695.   goto out;
  1696.         }
  1697.       if (! list_isempty (ospf_opaque_type11_funclist)
  1698.       &&    list_isempty (top->opaque_lsa_self)
  1699.       &&    top->t_opaque_lsa_self != NULL)
  1700.         {
  1701.           zlog_warn ("Type-11 Opaque-LSA (opaque_type=%u): Common origination has already started", opaque_type);
  1702.           goto out;
  1703.         }
  1705.       /* Fake "area" to pass "ospf" to a lookup function later. */
  1706.       dummy.ospf = top;
  1707.       area = &dummy;
  1709.       func = ospf_opaque_type11_lsa_reoriginate_timer;
  1710.       break;
  1711.     default:
  1712.       zlog_warn ("ospf_opaque_lsa_reoriginate_schedule: Unexpected LSA-type(%u)", lsa_type);
  1713.       goto out;
  1714.     }
  1716.   /* It may not a right time to schedule reorigination now. */
  1717.   if (! CHECK_FLAG (top->opaque, OPAQUE_OPERATION_READY_BIT))
  1718.     {
  1719.       if (IS_DEBUG_OSPF_EVENT)
  1720.         zlog_info ("ospf_opaque_lsa_reoriginate_schedule: Not operational.");
  1721.       goto out; /* This is not an error. */
  1722.     }
  1723.   if (IS_OPAQUE_LSA_ORIGINATION_BLOCKED (top->opaque))
  1724.     {
  1725.       if (IS_DEBUG_OSPF_EVENT)
  1726.         zlog_info ("ospf_opaque_lsa_reoriginate_schedule: Under blockade.");
  1727.       goto out; /* This is not an error, too. */
  1728.     }
  1730.   /* Generate a dummy lsa to be passed for a lookup function. */
  1731.   lsa = pseudo_lsa (oi, area, lsa_type, opaque_type);
  1733.   if ((oipt = lookup_opaque_info_by_type (lsa)) == NULL)
  1734.     {
  1735.       struct ospf_opaque_functab *functab;
  1736.       if ((functab = ospf_opaque_functab_lookup (lsa)) == NULL)
  1737.         {
  1738.           zlog_warn ("ospf_opaque_lsa_reoriginate_schedule: No associated function?: lsa_type(%u), opaque_type(%u)", lsa_type, opaque_type);
  1739.           goto out;
  1740.         }
  1741.       if ((oipt = register_opaque_info_per_type (functab, lsa)) == NULL)
  1742.         {
  1743.           zlog_warn ("ospf_opaque_lsa_reoriginate_schedule: Cannot get a control info?: lsa_type(%u), opaque_type(%u)", lsa_type, opaque_type);
  1744.           goto out;
  1745.         }
  1746.     }
  1748.   if (oipt->t_opaque_lsa_self != NULL)
  1749.     {
  1750.       if (IS_DEBUG_OSPF_EVENT)
  1751.         zlog_info ("Type-%u Opaque-LSA has already scheduled to RE-ORIGINATE: [opaque-type=%u]", lsa_type, GET_OPAQUE_TYPE (ntohl (lsa->data->id.s_addr)));
  1752.       goto out;
  1753.     }
  1755.   /*
  1756.    * Different from initial origination time, in which various conditions
  1757.    * (opaque capability, neighbor status etc) are assured by caller of
  1758.    * the originating function "ospf_opaque_lsa_originate_schedule ()",
  1759.    * it is highly possible that these conditions might not be satisfied
  1760.    * at the time of re-origination function is to be called.
  1761.    */
  1762.   delay = OSPF_MIN_LS_INTERVAL; /* XXX */
  1764.   if (IS_DEBUG_OSPF_EVENT)
  1765.     zlog_info ("Schedule Type-%u Opaque-LSA to RE-ORIGINATE in %d sec later: [opaque-type=%u]", lsa_type, delay, GET_OPAQUE_TYPE (ntohl (lsa->data->id.s_addr)));
  1767.   OSPF_OPAQUE_TIMER_ON (oipt->t_opaque_lsa_self, func, oipt, delay);
  1769. out:
  1770.   return;
  1771. }
  1773. static struct ospf_lsa *
  1774. pseudo_lsa (struct ospf_interface *oi, struct ospf_area *area,
  1775.             u_char lsa_type, u_char opaque_type)
  1776. {
  1777.   static struct ospf_lsa lsa = { 0 };
  1778.   static struct lsa_header lsah = { 0 };
  1779.   u_int32_t tmp;
  1781.   lsa.oi   = oi;
  1782.   lsa.area = area;
  1783.   lsa.data = &lsah;
  1785.   lsah.type = lsa_type;
  1786.   tmp = SET_OPAQUE_LSID (opaque_type, 0); /* Opaque-ID is unused here. */
  1787.   lsah.id.s_addr = htonl (tmp);
  1789.   return &lsa;
  1790. }
  1792. static int
  1793. ospf_opaque_type9_lsa_reoriginate_timer (struct thread *t)
  1794. {
  1795.   struct opaque_info_per_type *oipt;
  1796.   struct ospf_opaque_functab *functab;
  1797.   struct ospf *top;
  1798.   struct ospf_interface *oi;
  1799.   int rc = -1;
  1801.   oipt = THREAD_ARG (t);
  1802.   oipt->t_opaque_lsa_self = NULL;
  1804.   if ((functab = oipt->functab) == NULL
  1805.   ||   functab->lsa_originator == NULL)
  1806.     {
  1807.       zlog_warn ("ospf_opaque_type9_lsa_reoriginate_timer: No associated function?");
  1808.       goto out;
  1809.     }
  1811.   oi = (struct ospf_interface *) oipt->owner;
  1812.   if ((top = oi_to_top (oi)) == NULL)
  1813.     {
  1814.       zlog_warn ("ospf_opaque_type9_lsa_reoriginate_timer: Something wrong?");
  1815.       goto out;
  1816.     }
  1818.   if (! CHECK_FLAG (top->config, OSPF_OPAQUE_CAPABLE)
  1819.   ||  ! ospf_if_is_enable (oi)
  1820.   ||    ospf_nbr_count_opaque_capable (oi) == 0)
  1821.     {
  1822.       if (IS_DEBUG_OSPF_EVENT)
  1823.         zlog_info ("Suspend re-origination of Type-9 Opaque-LSAs (opaque-type=%u) for a while...", oipt->opaque_type);
  1824.     
  1825.       oipt->status = PROC_SUSPEND;
  1826.       rc = 0;
  1827.       goto out;
  1828.     }
  1830.   if (IS_DEBUG_OSPF_EVENT)
  1831.     zlog_info ("Timer[Type9-LSA]: Re-originate Opaque-LSAs (opaque-type=%u) for OI (%s)", oipt->opaque_type, IF_NAME (oi));
  1833.   rc = (* functab->lsa_originator)(oi);
  1834. out:
  1835.   return rc;
  1836. }
  1838. static int
  1839. ospf_opaque_type10_lsa_reoriginate_timer (struct thread *t)
  1840. {
  1841.   struct opaque_info_per_type *oipt;
  1842.   struct ospf_opaque_functab *functab;
  1843.   listnode node;
  1844.   struct ospf *top;
  1845.   struct ospf_area *area;
  1846.   struct ospf_interface *oi;
  1847.   int n, rc = -1;
  1849.   oipt = THREAD_ARG (t);
  1850.   oipt->t_opaque_lsa_self = NULL;
  1852.   if ((functab = oipt->functab) == NULL
  1853.   ||   functab->lsa_originator == NULL)
  1854.     {
  1855.       zlog_warn ("ospf_opaque_type10_lsa_reoriginate_timer: No associated function?");
  1856.       goto out;
  1857.     }
  1859.   area = (struct ospf_area *) oipt->owner;
  1860.   if (area == NULL || (top = area->ospf) == NULL)
  1861.     {
  1862.       zlog_warn ("ospf_opaque_type10_lsa_reoriginate_timer: Something wrong?");
  1863.       goto out;
  1864.     }
  1866.   /* There must be at least one "opaque-capable, full-state" neighbor. */
  1867.   n = 0;
  1868.   for (node = listhead (area->oiflist); node; nextnode (node))
  1869.     {
  1870.       if ((oi = getdata (node)) == NULL)
  1871.         continue;
  1872.       if ((n = ospf_nbr_count_opaque_capable (oi)) > 0)
  1873.         break;
  1874.     }
  1876.   if (n == 0 || ! CHECK_FLAG (top->config, OSPF_OPAQUE_CAPABLE))
  1877.     {
  1878.       if (IS_DEBUG_OSPF_EVENT)
  1879.         zlog_info ("Suspend re-origination of Type-10 Opaque-LSAs (opaque-type=%u) for a while...", oipt->opaque_type);
  1881.       oipt->status = PROC_SUSPEND;
  1882.       rc = 0;
  1883.       goto out;
  1884.     }
  1886.   if (IS_DEBUG_OSPF_EVENT)
  1887.     zlog_info ("Timer[Type10-LSA]: Re-originate Opaque-LSAs (opaque-type=%u) for Area %s", oipt->opaque_type, inet_ntoa (area->area_id));
  1889.   rc = (* functab->lsa_originator)(area);
  1890. out:
  1891.   return rc;
  1892. }
  1894. static int
  1895. ospf_opaque_type11_lsa_reoriginate_timer (struct thread *t)
  1896. {
  1897.   struct opaque_info_per_type *oipt;
  1898.   struct ospf_opaque_functab *functab;
  1899.   struct ospf *top;
  1900.   int rc = -1;
  1902.   oipt = THREAD_ARG (t);
  1903.   oipt->t_opaque_lsa_self = NULL;
  1905.   if ((functab = oipt->functab) == NULL
  1906.   ||   functab->lsa_originator == NULL)
  1907.     {
  1908.       zlog_warn ("ospf_opaque_type11_lsa_reoriginate_timer: No associated function?");
  1909.       goto out;
  1910.     }
  1912.   if ((top = (struct ospf *) oipt->owner) == NULL)
  1913.     {
  1914.       zlog_warn ("ospf_opaque_type11_lsa_reoriginate_timer: Something wrong?");
  1915.       goto out;
  1916.     }
  1918.   if (! CHECK_FLAG (top->config, OSPF_OPAQUE_CAPABLE))
  1919.     {
  1920.       if (IS_DEBUG_OSPF_EVENT)
  1921.         zlog_info ("Suspend re-origination of Type-11 Opaque-LSAs (opaque-type=%u) for a while...", oipt->opaque_type);
  1922.     
  1923.       oipt->status = PROC_SUSPEND;
  1924.       rc = 0;
  1925.       goto out;
  1926.     }
  1928.   if (IS_DEBUG_OSPF_EVENT)
  1929.     zlog_info ("Timer[Type11-LSA]: Re-originate Opaque-LSAs (opaque-type=%u).", oipt->opaque_type);
  1931.   rc = (* functab->lsa_originator)(top);
  1932. out:
  1933.   return rc;
  1934. }
  1936. extern int ospf_lsa_refresh_delay (struct ospf_lsa *); /* ospf_lsa.c */
  1938. void
  1939. ospf_opaque_lsa_refresh_schedule (struct ospf_lsa *lsa0)
  1940. {
  1941.   struct ospf *ospf = ospf;
  1942.   struct opaque_info_per_type *oipt;
  1943.   struct opaque_info_per_id *oipi;
  1944.   struct ospf_lsa *lsa;
  1945.   int delay;
  1947.   ospf = ospf_lookup ();
  1949.   if ((oipt = lookup_opaque_info_by_type (lsa0)) == NULL
  1950.   ||  (oipi = lookup_opaque_info_by_id (oipt, lsa0)) == NULL)
  1951.     {
  1952.       zlog_warn ("ospf_opaque_lsa_refresh_schedule: Invalid parameter?");
  1953.       goto out;
  1954.     }
  1956.   /* Given "lsa0" and current "oipi->lsa" may different, but harmless. */
  1957.   if ((lsa = oipi->lsa) == NULL)
  1958.     {
  1959.       zlog_warn ("ospf_opaque_lsa_refresh_schedule: Something wrong?");
  1960.       goto out;
  1961.     }
  1963.   if (oipi->t_opaque_lsa_self != NULL)
  1964.     {
  1965.       if (IS_DEBUG_OSPF_EVENT)
  1966.         zlog_info ("Type-%u Opaque-LSA has already scheduled to REFRESH: [opaque-type=%u, opaque-id=%x]", lsa->data->type, GET_OPAQUE_TYPE (ntohl (lsa->data->id.s_addr)), GET_OPAQUE_ID (ntohl (lsa->data->id.s_addr)));
  1967.       goto out;
  1968.     }
  1970.   /* Delete this lsa from neighbor retransmit-list. */
  1971.   switch (lsa->data->type)
  1972.     {
  1973.     case OSPF_OPAQUE_LINK_LSA:
  1974.     case OSPF_OPAQUE_AREA_LSA:
  1975.       ospf_ls_retransmit_delete_nbr_area (lsa->area, lsa);
  1976.       break;
  1977.     case OSPF_OPAQUE_AS_LSA:
  1978.       ospf_ls_retransmit_delete_nbr_as (ospf, lsa);
  1979.       break;
  1980.     default:
  1981.       zlog_warn ("ospf_opaque_lsa_refresh_schedule: Unexpected LSA-type(%u)", lsa->data->type);
  1982.       goto out;
  1983.     }
  1985.   delay = ospf_lsa_refresh_delay (lsa);
  1987.   if (IS_DEBUG_OSPF_EVENT)
  1988.     zlog_info ("Schedule Type-%u Opaque-LSA to REFRESH in %d sec later: [opaque-type=%u, opaque-id=%x]", lsa->data->type, delay, GET_OPAQUE_TYPE (ntohl (lsa->data->id.s_addr)), GET_OPAQUE_ID (ntohl (lsa->data->id.s_addr)));
  1990.   OSPF_OPAQUE_TIMER_ON (oipi->t_opaque_lsa_self,
  1991.                         ospf_opaque_lsa_refresh_timer, oipi, delay);
  1992. out:
  1993.   return;
  1994. }
  1996. static int
  1997. ospf_opaque_lsa_refresh_timer (struct thread *t)
  1998. {
  1999.   struct opaque_info_per_id *oipi;
  2000.   struct ospf_opaque_functab *functab;
  2001.   struct ospf_lsa *lsa;
  2003.   if (IS_DEBUG_OSPF_EVENT)
  2004.     zlog_info ("Timer[Opaque-LSA]: (Opaque-LSA Refresh expire)");
  2006.   oipi = THREAD_ARG (t);
  2007.   oipi->t_opaque_lsa_self = NULL;
  2009.   if ((lsa = oipi->lsa) != NULL)
  2010.     if ((functab = oipi->opqctl_type->functab) != NULL)
  2011.       if (functab->lsa_refresher != NULL)
  2012.         (* functab->lsa_refresher)(lsa);
  2014.   return 0;
  2015. }
  2017. void
  2018. ospf_opaque_lsa_flush_schedule (struct ospf_lsa *lsa0)
  2019. {
  2020.   struct ospf *ospf = ospf;
  2021.   struct opaque_info_per_type *oipt;
  2022.   struct opaque_info_per_id *oipi;
  2023.   struct ospf_lsa *lsa;
  2025.   ospf = ospf_lookup ();
  2027.   if ((oipt = lookup_opaque_info_by_type (lsa0)) == NULL
  2028.   ||  (oipi = lookup_opaque_info_by_id (oipt, lsa0)) == NULL)
  2029.     {
  2030.       zlog_warn ("ospf_opaque_lsa_flush_schedule: Invalid parameter?");
  2031.       goto out;
  2032.     }
  2034.   /* Given "lsa0" and current "oipi->lsa" may different, but harmless. */
  2035.   if ((lsa = oipi->lsa) == NULL)
  2036.     {
  2037.       zlog_warn ("ospf_opaque_lsa_flush_schedule: Something wrong?");
  2038.       goto out;
  2039.     }
  2041.   /* Delete this lsa from neighbor retransmit-list. */
  2042.   switch (lsa->data->type)
  2043.     {
  2044.     case OSPF_OPAQUE_LINK_LSA:
  2045.     case OSPF_OPAQUE_AREA_LSA:
  2046.       ospf_ls_retransmit_delete_nbr_area (lsa->area, lsa);
  2047.       break;
  2048.     case OSPF_OPAQUE_AS_LSA:
  2049.       ospf_ls_retransmit_delete_nbr_as (ospf, lsa);
  2050.       break;
  2051.     default:
  2052.       zlog_warn ("ospf_opaque_lsa_flush_schedule: Unexpected LSA-type(%u)", lsa->data->type);
  2053.       goto out;
  2054.     }
  2056.   /* Dequeue listnode entry from the list. */
  2057.   listnode_delete (oipt->id_list, oipi);
  2059.   /* Avoid misjudgement in the next lookup. */
  2060.   if (listcount (oipt->id_list) == 0)
  2061.     oipt->id_list->head = oipt->id_list->tail = NULL;
  2063.   /* Disassociate internal control information with the given lsa. */
  2064.   oipi->lsa = NULL;
  2065.   free_opaque_info_per_id ((void *) oipi);
  2067.   /* Force given lsa's age to MaxAge. */
  2068.   lsa->data->ls_age = htons (OSPF_LSA_MAXAGE);
  2070.   if (IS_DEBUG_OSPF_EVENT)
  2071.     zlog_info ("Schedule Type-%u Opaque-LSA to FLUSH: [opaque-type=%u, opaque-id=%x]", lsa->data->type, GET_OPAQUE_TYPE (ntohl (lsa->data->id.s_addr)), GET_OPAQUE_ID (ntohl (lsa->data->id.s_addr)));
  2073.   /* This lsa will be flushed and removed eventually. */
  2074.   ospf_lsa_maxage (ospf, lsa);
  2076. out:
  2077.   return;
  2078. }
  2080. /*------------------------------------------------------------------------*
  2081.  * Followings are control functions to block origination after restart.
  2082.  *------------------------------------------------------------------------*/
  2084. static void ospf_opaque_exclude_lsa_from_lsreq (struct route_table *nbrs, struct ospf_neighbor *inbr, struct ospf_lsa *lsa);
  2085. static void ospf_opaque_type9_lsa_rxmt_nbr_check (struct ospf_interface *oi);
  2086. static void ospf_opaque_type10_lsa_rxmt_nbr_check (struct ospf_area *area);
  2087. static void ospf_opaque_type11_lsa_rxmt_nbr_check (struct ospf *top);
  2088. static unsigned long ospf_opaque_nrxmt_self (struct route_table *nbrs, int lsa_type);
  2090. void
  2091. ospf_opaque_adjust_lsreq (struct ospf_neighbor *nbr, list lsas)
  2092. {
  2093.   struct ospf *top;
  2094.   struct ospf_area *area;
  2095.   struct ospf_interface *oi;
  2096.   listnode node1, node2;
  2097.   struct ospf_lsa *lsa;
  2099.   if ((top = oi_to_top (nbr->oi)) == NULL)
  2100.     goto out;
  2102.   /*
  2103.    * If an instance of self-originated Opaque-LSA is found in the given
  2104.    * LSA list, and it is not installed to LSDB yet, exclude it from the
  2105.    * list "nbr->ls_req". In this way, it is assured that an LSReq message,
  2106.    * which might be sent in the process of flooding, will not request for
  2107.    * the LSA to be flushed immediately; otherwise, depending on timing,
  2108.    * an LSUpd message will carry instances of target LSAs with MaxAge,
  2109.    * while other LSUpd message might carry old LSA instances (non-MaxAge).
  2110.    * Obviously, the latter would trigger miserable situations that repeat
  2111.    * installation and removal of unwanted LSAs indefinitely.
  2112.    */
  2113.   for (node1 = listhead (lsas); node1; nextnode (node1))
  2114.     {
  2115.       if ((lsa = getdata (node1)) == NULL)
  2116.         continue;
  2118.       /* Filter out unwanted LSAs. */
  2119.       if (! IS_OPAQUE_LSA (lsa->data->type))
  2120.         continue;
  2121.       if (! IPV4_ADDR_SAME (&lsa->data->adv_router, &top->router_id))
  2122.         continue;
  2124.       /*
  2125.        * Don't touch an LSA which has MaxAge; two possible cases.
  2126.        *
  2127.        *   1) This LSA has originally flushed by myself (received LSUpd
  2128.        *      message's router-id is equal to my router-id), and flooded
  2129.        *      back by an opaque-capable router.
  2130.        *
  2131.        *   2) This LSA has expired in an opaque-capable router and thus
  2132.        *      flushed by the router.
  2133.        */
  2134.       if (IS_LSA_MAXAGE (lsa))
  2135.         continue;
  2137.       /* If the LSA has installed in the LSDB, nothing to do here. */
  2138.       if (ospf_lsa_lookup_by_header (nbr->oi->area, lsa->data) != NULL)
  2139.         continue;
  2141.       /* Ok, here we go. */
  2142.       switch (lsa->data->type)
  2143.         {
  2144.         case OSPF_OPAQUE_LINK_LSA:
  2145.           oi = nbr->oi;
  2146.           ospf_opaque_exclude_lsa_from_lsreq (oi->nbrs, nbr, lsa);
  2147.           break;
  2148.         case OSPF_OPAQUE_AREA_LSA:
  2149.           area = nbr->oi->area;
  2150.           for (node2 = listhead (area->oiflist); node2; nextnode (node2))
  2151.             {
  2152.               if ((oi = getdata (node2)) == NULL)
  2153.                 continue;
  2154.               ospf_opaque_exclude_lsa_from_lsreq (oi->nbrs, nbr, lsa);
  2155.             }
  2156.           break;
  2157.         case OSPF_OPAQUE_AS_LSA:
  2158.           for (node2 = listhead (top->oiflist); node2; nextnode (node2))
  2159.             {
  2160.               if ((oi = getdata (node2)) == NULL)
  2161.                 continue;
  2162.               ospf_opaque_exclude_lsa_from_lsreq (oi->nbrs, nbr, lsa);
  2163.             }
  2164.           break;
  2165.         default:
  2166.           break;
  2167.         }
  2168.     }
  2170. out:
  2171.   return;
  2172. }
  2174. static void
  2175. ospf_opaque_exclude_lsa_from_lsreq (struct route_table *nbrs,
  2176.                                     struct ospf_neighbor *inbr,
  2177.                                     struct ospf_lsa *lsa)
  2178. {
  2179.   struct route_node *rn;
  2180.   struct ospf_neighbor *onbr;
  2181.   struct ospf_lsa *ls_req;
  2183.   for (rn = route_top (nbrs); rn; rn = route_next (rn))
  2184.     {
  2185.       if ((onbr = rn->info) == NULL)
  2186.         continue;
  2187.       if (onbr == inbr)
  2188.         continue;
  2189.       if ((ls_req = ospf_ls_request_lookup (onbr, lsa)) == NULL)
  2190.         continue;
  2192.       if (IS_DEBUG_OSPF_EVENT)
  2193.         zlog_info ("LSA[%s]: Exclude this entry from LSReq to send.", dump_lsa_key (lsa));
  2195.       ospf_ls_request_delete (onbr, ls_req);
  2196. /*    ospf_check_nbr_loading (onbr);*//* XXX */
  2197.     }
  2199.   return;
  2200. }
  2202. void
  2203. ospf_opaque_self_originated_lsa_received (struct ospf_neighbor *nbr, list lsas)
  2204. {
  2205.   struct ospf *top;
  2206.   listnode node, next;
  2207.   struct ospf_lsa *lsa;
  2208.   u_char before;
  2210.   if ((top = oi_to_top (nbr->oi)) == NULL)
  2211.     goto out;
  2213.   before = IS_OPAQUE_LSA_ORIGINATION_BLOCKED (top->opaque);
  2215.   for (node = listhead (lsas); node; node = next)
  2216.     {
  2217.       next = node->next;
  2219.       if ((lsa = getdata (node)) == NULL)
  2220.         continue;
  2222.       listnode_delete (lsas, lsa);
  2224.       /*
  2225.        * Since these LSA entries are not yet installed into corresponding
  2226.        * LSDB, just flush them without calling ospf_ls_maxage() afterward.
  2227.        */
  2228.       lsa->data->ls_age = htons (OSPF_LSA_MAXAGE);
  2229.       switch (lsa->data->type)
  2230.         {
  2231.         case OSPF_OPAQUE_LINK_LSA:
  2232.           SET_FLAG (top->opaque, OPAQUE_BLOCK_TYPE_09_LSA_BIT);
  2233.           ospf_flood_through_area (nbr->oi->area, NULL/*inbr*/, lsa);
  2234.           break;
  2235.         case OSPF_OPAQUE_AREA_LSA:
  2236.           SET_FLAG (top->opaque, OPAQUE_BLOCK_TYPE_10_LSA_BIT);
  2237.           ospf_flood_through_area (nbr->oi->area, NULL/*inbr*/, lsa);
  2238.           break;
  2239.         case OSPF_OPAQUE_AS_LSA:
  2240.           SET_FLAG (top->opaque, OPAQUE_BLOCK_TYPE_11_LSA_BIT);
  2241.           ospf_flood_through_as (top, NULL/*inbr*/, lsa);
  2242.           break;
  2243.         default:
  2244.           zlog_warn ("ospf_opaque_self_originated_lsa_received: Unexpected LSA-type(%u)", lsa->data->type);
  2245.           goto out;
  2246.         }
  2248.       ospf_lsa_discard (lsa); /* List "lsas" will be deleted by caller. */
  2249.     }
  2251.   if (before == 0 && IS_OPAQUE_LSA_ORIGINATION_BLOCKED (top->opaque))
  2252.     {
  2253.       if (IS_DEBUG_OSPF_EVENT)
  2254.         zlog_info ("Block Opaque-LSA origination: OFF -> ON");
  2255.     }
  2257. out:
  2258.   return;
  2259. }
  2261. void
  2262. ospf_opaque_ls_ack_received (struct ospf_neighbor *nbr, list acks)
  2263. {
  2264.   struct ospf *top;
  2265.   listnode node;
  2266.   struct ospf_lsa *lsa;
  2267.   char type9_lsa_rcv = 0, type10_lsa_rcv = 0, type11_lsa_rcv = 0;
  2269.   if ((top = oi_to_top (nbr->oi)) == NULL)
  2270.     goto out;
  2272.   for (node = listhead (acks); node; nextnode (node))
  2273.     {
  2274.       if ((lsa = getdata (node)) == NULL)
  2275.         continue;
  2277.       switch (lsa->data->type)
  2278.         {
  2279.         case OSPF_OPAQUE_LINK_LSA:
  2280.           type9_lsa_rcv = 1;
  2281.           /* Callback function... */
  2282.           break;
  2283.         case OSPF_OPAQUE_AREA_LSA:
  2284.           type10_lsa_rcv = 1;
  2285.           /* Callback function... */
  2286.           break;
  2287.         case OSPF_OPAQUE_AS_LSA:
  2288.           type11_lsa_rcv = 1;
  2289.           /* Callback function... */
  2290.           break;
  2291.         default:
  2292.           zlog_warn ("ospf_opaque_ls_ack_received: Unexpected LSA-type(%u)", lsa->data->type);
  2293.           goto out;
  2294.         }
  2295.     }
  2297.   if (IS_OPAQUE_LSA_ORIGINATION_BLOCKED (top->opaque))
  2298.     {
  2299.       int delay;
  2300.       struct ospf_interface *oi;
  2302.       if (type9_lsa_rcv
  2303.       &&  CHECK_FLAG (top->opaque, OPAQUE_BLOCK_TYPE_09_LSA_BIT))
  2304.         ospf_opaque_type9_lsa_rxmt_nbr_check (nbr->oi);
  2306.       if (type10_lsa_rcv
  2307.       &&  CHECK_FLAG (top->opaque, OPAQUE_BLOCK_TYPE_10_LSA_BIT))
  2308.         ospf_opaque_type10_lsa_rxmt_nbr_check (nbr->oi->area);
  2310.       if (type11_lsa_rcv
  2311.       &&  CHECK_FLAG (top->opaque, OPAQUE_BLOCK_TYPE_11_LSA_BIT))
  2312.         ospf_opaque_type11_lsa_rxmt_nbr_check (top);
  2314.       if (IS_OPAQUE_LSA_ORIGINATION_BLOCKED (top->opaque))
  2315.         goto out; /* Blocking still in progress. */
  2317.       if (IS_DEBUG_OSPF_EVENT)
  2318.         zlog_info ("Block Opaque-LSA origination: ON -> OFF");
  2320.       if (! CHECK_FLAG (top->config, OSPF_OPAQUE_CAPABLE))
  2321.         goto out; /* Opaque capability condition must have changed. */
  2323.       /* Ok, let's start origination of Opaque-LSAs. */
  2324.       delay = OSPF_MIN_LS_INTERVAL;
  2325.       for (node = listhead (top->oiflist); node; nextnode (node))
  2326.         {
  2327.           if ((oi = getdata (node)) == NULL)
  2328.             continue;
  2330.           if (! ospf_if_is_enable (oi)
  2331.           ||    ospf_nbr_count_opaque_capable (oi) == 0)
  2332.             continue;
  2334.           ospf_opaque_lsa_originate_schedule (oi, &delay);
  2335.         }
  2336.     }
  2338. out:
  2339.   return;
  2340. }
  2342. static void
  2343. ospf_opaque_type9_lsa_rxmt_nbr_check (struct ospf_interface *oi)
  2344. {
  2345.   unsigned long n;
  2347.   n = ospf_opaque_nrxmt_self (oi->nbrs, OSPF_OPAQUE_LINK_LSA);
  2348.   if (n == 0)
  2349.     {
  2350.       if (IS_DEBUG_OSPF_EVENT)
  2351.         zlog_info ("Self-originated type-9 Opaque-LSAs: OI(%s): Flush completed", IF_NAME (oi));
  2353.       UNSET_FLAG (oi->area->ospf->opaque, OPAQUE_BLOCK_TYPE_09_LSA_BIT);
  2354.     }
  2355.   return;
  2356. }
  2358. static void
  2359. ospf_opaque_type10_lsa_rxmt_nbr_check (struct ospf_area *area)
  2360. {
  2361.   listnode node;
  2362.   struct ospf_interface *oi;
  2363.   unsigned long n = 0;
  2365.   for (node = listhead (area->oiflist); node; nextnode (node))
  2366.     {
  2367.       if ((oi = getdata (node)) == NULL)
  2368.         continue;
  2370.       if (area->area_id.s_addr != OSPF_AREA_BACKBONE
  2371.       &&  oi->type == OSPF_IFTYPE_VIRTUALLINK) 
  2372.         continue;
  2374.       n = ospf_opaque_nrxmt_self (oi->nbrs, OSPF_OPAQUE_AREA_LSA);
  2375.       if (n > 0)
  2376.         break;
  2377.     }
  2379.   if (n == 0)
  2380.     {
  2381.       if (IS_DEBUG_OSPF_EVENT)
  2382.         zlog_info ("Self-originated type-10 Opaque-LSAs: AREA(%s): Flush completed", inet_ntoa (area->area_id));
  2384.       UNSET_FLAG (area->ospf->opaque, OPAQUE_BLOCK_TYPE_10_LSA_BIT);
  2385.     }
  2387.   return;
  2388. }
  2390. static void
  2391. ospf_opaque_type11_lsa_rxmt_nbr_check (struct ospf *top)
  2392. {
  2393.   listnode node;
  2394.   struct ospf_interface *oi;
  2395.   unsigned long n = 0;
  2397.   for (node = listhead (top->oiflist); node; nextnode (node))
  2398.     {
  2399.       if ((oi = getdata (node)) == NULL)
  2400.         continue;
  2402.       switch (oi->type)
  2403.         {
  2404.         case OSPF_IFTYPE_VIRTUALLINK:
  2405.           continue;
  2406.         default:
  2407.           break;
  2408.         }
  2410.       n = ospf_opaque_nrxmt_self (oi->nbrs, OSPF_OPAQUE_AS_LSA);
  2411.       if (n > 0)
  2412.         goto out;
  2413.     }
  2415.   if (n == 0)
  2416.     {
  2417.       if (IS_DEBUG_OSPF_EVENT)
  2418.         zlog_info ("Self-originated type-11 Opaque-LSAs: Flush completed");
  2420.       UNSET_FLAG (top->opaque, OPAQUE_BLOCK_TYPE_11_LSA_BIT);
  2421.     }
  2423. out:
  2424.   return;
  2425. }
  2427. static unsigned long
  2428. ospf_opaque_nrxmt_self (struct route_table *nbrs, int lsa_type)
  2429. {
  2430.   struct route_node *rn;
  2431.   struct ospf_neighbor *nbr;
  2432.   struct ospf *top;
  2433.   unsigned long n = 0;
  2435.   for (rn = route_top (nbrs); rn; rn = route_next (rn))
  2436.     {
  2437.       if ((nbr = rn->info) == NULL)
  2438.         continue;
  2439.       if ((top = oi_to_top (nbr->oi)) == NULL)
  2440.         continue;
  2441.       if (IPV4_ADDR_SAME (&nbr->router_id, &top->router_id))
  2442.         continue;
  2443.       n += ospf_ls_retransmit_count_self (nbr, lsa_type);
  2444.     }
  2446.   return n;
  2447. }
  2449. /*------------------------------------------------------------------------*
  2450.  * Followings are util functions; probably be used by Opaque-LSAs only...
  2451.  *------------------------------------------------------------------------*/
  2453. void
  2454. htonf (float *src, float *dst)
  2455. {
  2456.   u_int32_t lu1, lu2;
  2458.   memcpy (&lu1, src, sizeof (u_int32_t));
  2459.   lu2 = htonl (lu1);
  2460.   memcpy (dst, &lu2, sizeof (u_int32_t));
  2461.   return;
  2462. }
  2464. void
  2465. ntohf (float *src, float *dst)
  2466. {
  2467.   u_int32_t lu1, lu2;
  2469.   memcpy (&lu1, src, sizeof (u_int32_t));
  2470.   lu2 = ntohl (lu1);
  2471.   memcpy (dst, &lu2, sizeof (u_int32_t));
  2472.   return;
  2473. }
  2475. struct ospf *
  2476. oi_to_top (struct ospf_interface *oi)
  2477. {
  2478.   struct ospf *top = NULL;
  2479.   struct ospf_area *area;
  2481.   if (oi == NULL || (area = oi->area) == NULL || (top = area->ospf) == NULL)
  2482.     zlog_warn ("Broken relationship for "OI -> AREA -> OSPF"?");
  2484.   return top;
  2485. }
  2487. #endif /* HAVE_OPAQUE_LSA */