mirror of
				https://git.proxmox.com/git/mirror_frr
				synced 2025-10-26 05:24:56 +00:00 
			
		
		
		
	 51f2d198c2
			
		
	
	
		51f2d198c2
		
	
	
	
	
		
			
			Signed-off-by: Daniel Walton <dwalton@cumulusnetworks.com> Reviewed-by: Donald Sharp <sharpd@cumulusnetworks.com> Ticket: CM-12773 - change "as-ext" to "as-external" - drop "grp-mbr" option, it does not have a handler - drop "type7" option, it does not have a handler
		
			
				
	
	
		
			968 lines
		
	
	
		
			26 KiB
		
	
	
	
		
			C
		
	
	
	
	
	
			
		
		
	
	
			968 lines
		
	
	
		
			26 KiB
		
	
	
	
		
			C
		
	
	
	
	
	
| /*
 | |
|  * Copyright (C) 2003 Yasuhiro Ohara
 | |
|  *
 | |
|  * This file is part of GNU Zebra.
 | |
|  *
 | |
|  * GNU Zebra is free software; you can redistribute it and/or modify it
 | |
|  * under the terms of the GNU General Public License as published by the
 | |
|  * Free Software Foundation; either version 2, or (at your option) any
 | |
|  * later version.
 | |
|  *
 | |
|  * GNU Zebra is distributed in the hope that it will be useful, but
 | |
|  * WITHOUT ANY WARRANTY; without even the implied warranty of
 | |
|  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 | |
|  * General Public License for more details.
 | |
|  *
 | |
|  * You should have received a copy of the GNU General Public License
 | |
|  * along with GNU Zebra; see the file COPYING.  If not, write to the 
 | |
|  * Free Software Foundation, Inc., 59 Temple Place - Suite 330, 
 | |
|  * Boston, MA 02111-1307, USA.  
 | |
|  */
 | |
| 
 | |
| #include <zebra.h>
 | |
| 
 | |
| /* Include other stuffs */
 | |
| #include "log.h"
 | |
| #include "linklist.h"
 | |
| #include "vector.h"
 | |
| #include "vty.h"
 | |
| #include "command.h"
 | |
| #include "memory.h"
 | |
| #include "thread.h"
 | |
| #include "checksum.h"
 | |
| 
 | |
| #include "ospf6_proto.h"
 | |
| #include "ospf6_lsa.h"
 | |
| #include "ospf6_lsdb.h"
 | |
| #include "ospf6_message.h"
 | |
| 
 | |
| #include "ospf6_top.h"
 | |
| #include "ospf6_area.h"
 | |
| #include "ospf6_interface.h"
 | |
| #include "ospf6_neighbor.h"
 | |
| 
 | |
| #include "ospf6_flood.h"
 | |
| #include "ospf6d.h"
 | |
| 
 | |
| vector ospf6_lsa_handler_vector;
 | |
| 
 | |
| static int
 | |
| ospf6_unknown_lsa_show (struct vty *vty, struct ospf6_lsa *lsa)
 | |
| {
 | |
|   u_char *start, *end, *current;
 | |
|   char byte[4];
 | |
| 
 | |
|   start = (u_char *) lsa->header + sizeof (struct ospf6_lsa_header);
 | |
|   end = (u_char *) lsa->header + ntohs (lsa->header->length);
 | |
| 
 | |
|   vty_out (vty, "        Unknown contents:%s", VNL);
 | |
|   for (current = start; current < end; current ++)
 | |
|     {
 | |
|       if ((current - start) % 16 == 0)
 | |
|         vty_out (vty, "%s        ", VNL);
 | |
|       else if ((current - start) % 4 == 0)
 | |
|         vty_out (vty, " ");
 | |
| 
 | |
|       snprintf (byte, sizeof (byte), "%02x", *current);
 | |
|       vty_out (vty, "%s", byte);
 | |
|     }
 | |
| 
 | |
|   vty_out (vty, "%s%s", VNL, VNL);
 | |
|   return 0;
 | |
| }
 | |
| 
 | |
| struct ospf6_lsa_handler unknown_handler =
 | |
| {
 | |
|   OSPF6_LSTYPE_UNKNOWN,
 | |
|   "Unknown",
 | |
|   "Unk",
 | |
|   ospf6_unknown_lsa_show,
 | |
|   NULL,
 | |
|   OSPF6_LSA_DEBUG,
 | |
| };
 | |
| 
 | |
| void
 | |
| ospf6_install_lsa_handler (struct ospf6_lsa_handler *handler)
 | |
| {
 | |
|   /* type in handler is host byte order */
 | |
|   int index = handler->type & OSPF6_LSTYPE_FCODE_MASK;
 | |
|   vector_set_index (ospf6_lsa_handler_vector, index, handler);
 | |
| }
 | |
| 
 | |
| struct ospf6_lsa_handler *
 | |
| ospf6_get_lsa_handler (u_int16_t type)
 | |
| {
 | |
|   struct ospf6_lsa_handler *handler = NULL;
 | |
|   unsigned int index = ntohs (type) & OSPF6_LSTYPE_FCODE_MASK;
 | |
| 
 | |
|   if (index >= vector_active (ospf6_lsa_handler_vector))
 | |
|     handler = &unknown_handler;
 | |
|   else
 | |
|     handler = vector_slot (ospf6_lsa_handler_vector, index);
 | |
| 
 | |
|   if (handler == NULL)
 | |
|     handler = &unknown_handler;
 | |
| 
 | |
|   return handler;
 | |
| }
 | |
| 
 | |
| const char *
 | |
| ospf6_lstype_name (u_int16_t type)
 | |
| {
 | |
|   static char buf[8];
 | |
|   struct ospf6_lsa_handler *handler;
 | |
| 
 | |
|   handler = ospf6_get_lsa_handler (type);
 | |
|   if (handler && handler != &unknown_handler)
 | |
|     return handler->name;
 | |
| 
 | |
|   snprintf (buf, sizeof (buf), "0x%04hx", ntohs (type));
 | |
|   return buf;
 | |
| }
 | |
| 
 | |
| const char *
 | |
| ospf6_lstype_short_name (u_int16_t type)
 | |
| {
 | |
|   static char buf[8];
 | |
|   struct ospf6_lsa_handler *handler;
 | |
| 
 | |
|   handler = ospf6_get_lsa_handler (type);
 | |
|   if (handler && handler != &unknown_handler)
 | |
|     return handler->short_name;
 | |
| 
 | |
|   snprintf (buf, sizeof (buf), "0x%04hx", ntohs (type));
 | |
|   return buf;
 | |
| }
 | |
| 
 | |
| u_char
 | |
| ospf6_lstype_debug (u_int16_t type)
 | |
| {
 | |
|   struct ospf6_lsa_handler *handler;
 | |
|   handler = ospf6_get_lsa_handler (type);
 | |
|   return handler->debug;
 | |
| }
 | |
| 
 | |
| /* RFC2328: Section 13.2 */
 | |
| int
 | |
| ospf6_lsa_is_differ (struct ospf6_lsa *lsa1,
 | |
|                      struct ospf6_lsa *lsa2)
 | |
| {
 | |
|   int len;
 | |
| 
 | |
|   assert (OSPF6_LSA_IS_SAME (lsa1, lsa2));
 | |
| 
 | |
|   /* XXX, Options ??? */
 | |
| 
 | |
|   ospf6_lsa_age_current (lsa1);
 | |
|   ospf6_lsa_age_current (lsa2);
 | |
|   if (ntohs (lsa1->header->age) == OSPF_LSA_MAXAGE &&
 | |
|       ntohs (lsa2->header->age) != OSPF_LSA_MAXAGE)
 | |
|     return 1;
 | |
|   if (ntohs (lsa1->header->age) != OSPF_LSA_MAXAGE &&
 | |
|       ntohs (lsa2->header->age) == OSPF_LSA_MAXAGE)
 | |
|     return 1;
 | |
| 
 | |
|   /* compare body */
 | |
|   if (ntohs (lsa1->header->length) != ntohs (lsa2->header->length))
 | |
|     return 1;
 | |
| 
 | |
|   len = ntohs (lsa1->header->length) - sizeof (struct ospf6_lsa_header);
 | |
|   return memcmp (lsa1->header + 1, lsa2->header + 1, len);
 | |
| }
 | |
| 
 | |
| int
 | |
| ospf6_lsa_is_changed (struct ospf6_lsa *lsa1,
 | |
|                       struct ospf6_lsa *lsa2)
 | |
| {
 | |
|   int length;
 | |
| 
 | |
|   if (OSPF6_LSA_IS_MAXAGE (lsa1) ^ OSPF6_LSA_IS_MAXAGE (lsa2))
 | |
|     return 1;
 | |
|   if (ntohs (lsa1->header->length) != ntohs (lsa2->header->length))
 | |
|     return 1;
 | |
|   /* Going beyond LSA headers to compare the payload only makes sense, when both LSAs aren't header-only. */
 | |
|   if (CHECK_FLAG (lsa1->flag, OSPF6_LSA_HEADERONLY) != CHECK_FLAG (lsa2->flag, OSPF6_LSA_HEADERONLY))
 | |
|   {
 | |
|     zlog_warn ("%s: only one of two (%s, %s) LSAs compared is header-only", __func__, lsa1->name, lsa2->name);
 | |
|     return 1;
 | |
|   }
 | |
|   if (CHECK_FLAG (lsa1->flag, OSPF6_LSA_HEADERONLY))
 | |
|     return 0;
 | |
| 
 | |
|   length = OSPF6_LSA_SIZE (lsa1->header) - sizeof (struct ospf6_lsa_header);
 | |
|   /* Once upper layer verifies LSAs received, length underrun should become a warning. */
 | |
|   if (length <= 0)
 | |
|     return 0;
 | |
| 
 | |
|   return memcmp (OSPF6_LSA_HEADER_END (lsa1->header),
 | |
|                  OSPF6_LSA_HEADER_END (lsa2->header), length);
 | |
| }
 | |
| 
 | |
| /* ospf6 age functions */
 | |
| /* calculate birth */
 | |
| static void
 | |
| ospf6_lsa_age_set (struct ospf6_lsa *lsa)
 | |
| {
 | |
|   struct timeval now;
 | |
| 
 | |
|   assert (lsa && lsa->header);
 | |
| 
 | |
|   if (quagga_gettime (QUAGGA_CLK_MONOTONIC, &now) < 0)
 | |
|     zlog_warn ("LSA: quagga_gettime failed, may fail LSA AGEs: %s",
 | |
|                safe_strerror (errno));
 | |
| 
 | |
|   lsa->birth.tv_sec = now.tv_sec - ntohs (lsa->header->age);
 | |
|   lsa->birth.tv_usec = now.tv_usec;
 | |
| 
 | |
|   return;
 | |
| }
 | |
| 
 | |
| /* this function calculates current age from its birth,
 | |
|    then update age field of LSA header. return value is current age */
 | |
| u_int16_t
 | |
| ospf6_lsa_age_current (struct ospf6_lsa *lsa)
 | |
| {
 | |
|   struct timeval now;
 | |
|   u_int32_t ulage;
 | |
|   u_int16_t age;
 | |
| 
 | |
|   assert (lsa);
 | |
|   assert (lsa->header);
 | |
| 
 | |
|   /* current time */
 | |
|   if (quagga_gettime (QUAGGA_CLK_MONOTONIC, &now) < 0)
 | |
|     zlog_warn ("LSA: quagga_gettime failed, may fail LSA AGEs: %s",
 | |
|                safe_strerror (errno));
 | |
| 
 | |
|   if (ntohs (lsa->header->age) >= OSPF_LSA_MAXAGE)
 | |
|     {
 | |
|       /* ospf6_lsa_premature_aging () sets age to MAXAGE; when using
 | |
|          relative time, we cannot compare against lsa birth time, so
 | |
|          we catch this special case here. */
 | |
|       lsa->header->age = htons (OSPF_LSA_MAXAGE);
 | |
|       return OSPF_LSA_MAXAGE;
 | |
|     }
 | |
|   /* calculate age */
 | |
|   ulage = now.tv_sec - lsa->birth.tv_sec;
 | |
| 
 | |
|   /* if over MAXAGE, set to it */
 | |
|   age = (ulage > OSPF_LSA_MAXAGE ? OSPF_LSA_MAXAGE : ulage);
 | |
| 
 | |
|   lsa->header->age = htons (age);
 | |
|   return age;
 | |
| }
 | |
| 
 | |
| /* update age field of LSA header with adding InfTransDelay */
 | |
| void
 | |
| ospf6_lsa_age_update_to_send (struct ospf6_lsa *lsa, u_int32_t transdelay)
 | |
| {
 | |
|   unsigned short age;
 | |
| 
 | |
|   age = ospf6_lsa_age_current (lsa) + transdelay;
 | |
|   if (age > OSPF_LSA_MAXAGE)
 | |
|     age = OSPF_LSA_MAXAGE;
 | |
|   lsa->header->age = htons (age);
 | |
| }
 | |
| 
 | |
| void
 | |
| ospf6_lsa_premature_aging (struct ospf6_lsa *lsa)
 | |
| {
 | |
|   /* log */
 | |
|   if (IS_OSPF6_DEBUG_LSA_TYPE (lsa->header->type))
 | |
|     zlog_debug ("LSA: Premature aging: %s", lsa->name);
 | |
| 
 | |
|   THREAD_OFF (lsa->expire);
 | |
|   THREAD_OFF (lsa->refresh);
 | |
| 
 | |
|   /*
 | |
|    * We clear the LSA from the neighbor retx lists now because it
 | |
|    * will not get deleted later. Essentially, changing the age to
 | |
|    * MaxAge will prevent this LSA from being matched with its
 | |
|    * existing entries in the retx list thereby causing those entries
 | |
|    * to be silently replaced with its MaxAged version, but with ever
 | |
|    * increasing retx count causing this LSA to remain forever and
 | |
|    * for the MaxAge remover thread to be called forever too.
 | |
|    *
 | |
|    * The reason the previous entry silently disappears is that when
 | |
|    * entry is added to a neighbor's retx list, it replaces the existing
 | |
|    * entry. But since the ospf6_lsdb_add() routine is generic and not aware
 | |
|    * of the special semantics of retx count, the retx count is not
 | |
|    * decremented when its replaced. Attempting to add the incr and decr
 | |
|    * retx count routines as the hook_add and hook_remove for the retx lists
 | |
|    * have a problem because the hook_remove routine is called for MaxAge
 | |
|    * entries (as will be the case in a traditional LSDB, unlike in this case
 | |
|    * where an LSDB is used as an efficient tree structure to store all kinds
 | |
|    * of data) that are added instead of calling the hook_add routine.
 | |
|    */
 | |
| 
 | |
|   ospf6_flood_clear (lsa);
 | |
| 
 | |
|   lsa->header->age = htons (OSPF_LSA_MAXAGE);
 | |
|   thread_execute (master, ospf6_lsa_expire, lsa, 0);
 | |
| }
 | |
| 
 | |
| /* check which is more recent. if a is more recent, return -1;
 | |
|    if the same, return 0; otherwise(b is more recent), return 1 */
 | |
| int
 | |
| ospf6_lsa_compare (struct ospf6_lsa *a, struct ospf6_lsa *b)
 | |
| {
 | |
|   int32_t seqnuma, seqnumb;
 | |
|   u_int16_t cksuma, cksumb;
 | |
|   u_int16_t agea, ageb;
 | |
| 
 | |
|   assert (a && a->header);
 | |
|   assert (b && b->header);
 | |
|   assert (OSPF6_LSA_IS_SAME (a, b));
 | |
| 
 | |
|   seqnuma = (int32_t) ntohl (a->header->seqnum);
 | |
|   seqnumb = (int32_t) ntohl (b->header->seqnum);
 | |
| 
 | |
|   /* compare by sequence number */
 | |
|   if (seqnuma > seqnumb)
 | |
|     return -1;
 | |
|   if (seqnuma < seqnumb)
 | |
|     return 1;
 | |
| 
 | |
|   /* Checksum */
 | |
|   cksuma = ntohs (a->header->checksum);
 | |
|   cksumb = ntohs (b->header->checksum);
 | |
|   if (cksuma > cksumb)
 | |
|     return -1;
 | |
|   if (cksuma < cksumb)
 | |
|     return 0;
 | |
| 
 | |
|   /* Update Age */
 | |
|   agea = ospf6_lsa_age_current (a);
 | |
|   ageb = ospf6_lsa_age_current (b);
 | |
| 
 | |
|   /* MaxAge check */
 | |
|   if (agea == OSPF_LSA_MAXAGE && ageb != OSPF_LSA_MAXAGE)
 | |
|     return -1;
 | |
|   else if (agea != OSPF_LSA_MAXAGE && ageb == OSPF_LSA_MAXAGE)
 | |
|     return 1;
 | |
| 
 | |
|   /* Age check */
 | |
|   if (agea > ageb && agea - ageb >= OSPF_LSA_MAXAGE_DIFF)
 | |
|     return 1;
 | |
|   else if (agea < ageb && ageb - agea >= OSPF_LSA_MAXAGE_DIFF)
 | |
|     return -1;
 | |
| 
 | |
|   /* neither recent */
 | |
|   return 0;
 | |
| }
 | |
| 
 | |
| char *
 | |
| ospf6_lsa_printbuf (struct ospf6_lsa *lsa, char *buf, int size)
 | |
| {
 | |
|   char id[16], adv_router[16];
 | |
|   inet_ntop (AF_INET, &lsa->header->id, id, sizeof (id));
 | |
|   inet_ntop (AF_INET, &lsa->header->adv_router, adv_router,
 | |
|              sizeof (adv_router));
 | |
|   snprintf (buf, size, "[%s Id:%s Adv:%s]",
 | |
|             ospf6_lstype_name (lsa->header->type), id, adv_router);
 | |
|   return buf;
 | |
| }
 | |
| 
 | |
| void
 | |
| ospf6_lsa_header_print_raw (struct ospf6_lsa_header *header)
 | |
| {
 | |
|   char id[16], adv_router[16];
 | |
|   inet_ntop (AF_INET, &header->id, id, sizeof (id));
 | |
|   inet_ntop (AF_INET, &header->adv_router, adv_router,
 | |
|              sizeof (adv_router));
 | |
|   zlog_debug ("    [%s Id:%s Adv:%s]",
 | |
| 	      ospf6_lstype_name (header->type), id, adv_router);
 | |
|   zlog_debug ("    Age: %4hu SeqNum: %#08lx Cksum: %04hx Len: %d",
 | |
| 	      ntohs (header->age), (u_long) ntohl (header->seqnum),
 | |
| 	      ntohs (header->checksum), ntohs (header->length));
 | |
| }
 | |
| 
 | |
| void
 | |
| ospf6_lsa_header_print (struct ospf6_lsa *lsa)
 | |
| {
 | |
|   ospf6_lsa_age_current (lsa);
 | |
|   ospf6_lsa_header_print_raw (lsa->header);
 | |
| }
 | |
| 
 | |
| void
 | |
| ospf6_lsa_show_summary_header (struct vty *vty)
 | |
| {
 | |
|   vty_out (vty, "%-4s %-15s%-15s%4s %8s %30s%s",
 | |
|            "Type", "LSId", "AdvRouter", "Age", "SeqNum",
 | |
|            "Payload", VNL);
 | |
| }
 | |
| 
 | |
| void
 | |
| ospf6_lsa_show_summary (struct vty *vty, struct ospf6_lsa *lsa)
 | |
| {
 | |
|   char adv_router[16], id[16];
 | |
|   int type;
 | |
|   struct ospf6_lsa_handler *handler;
 | |
|   char buf[64], tmpbuf[80];
 | |
|   int cnt = 0;
 | |
| 
 | |
|   assert (lsa);
 | |
|   assert (lsa->header);
 | |
| 
 | |
|   inet_ntop (AF_INET, &lsa->header->id, id, sizeof (id));
 | |
|   inet_ntop (AF_INET, &lsa->header->adv_router, adv_router,
 | |
|              sizeof (adv_router));
 | |
| 
 | |
|   type = ntohs(lsa->header->type);
 | |
|   handler = ospf6_get_lsa_handler (lsa->header->type);
 | |
|   if ((type == OSPF6_LSTYPE_INTER_PREFIX) ||
 | |
|       (type == OSPF6_LSTYPE_INTER_ROUTER) ||
 | |
|       (type == OSPF6_LSTYPE_AS_EXTERNAL))
 | |
|     {
 | |
|       vty_out (vty, "%-4s %-15s%-15s%4hu %8lx %30s%s",
 | |
| 	       ospf6_lstype_short_name (lsa->header->type),
 | |
| 	       id, adv_router, ospf6_lsa_age_current (lsa),
 | |
| 	       (u_long) ntohl (lsa->header->seqnum),
 | |
| 	       handler->get_prefix_str(lsa, buf, sizeof(buf), 0), VNL);
 | |
|     }
 | |
|   else if (type != OSPF6_LSTYPE_UNKNOWN)
 | |
|     {
 | |
|       sprintf (tmpbuf, "%-4s %-15s%-15s%4hu %8lx",
 | |
| 	       ospf6_lstype_short_name (lsa->header->type),
 | |
| 	       id, adv_router, ospf6_lsa_age_current (lsa),
 | |
| 	       (u_long) ntohl (lsa->header->seqnum));
 | |
| 
 | |
|       while (handler->get_prefix_str(lsa, buf, sizeof(buf), cnt) != NULL)
 | |
| 	{
 | |
| 	  vty_out (vty, "%s %30s%s", tmpbuf, buf, VNL);
 | |
| 	  cnt++;
 | |
| 	}
 | |
|     }
 | |
|   else
 | |
|     {
 | |
|       vty_out (vty, "%-4s %-15s%-15s%4hu %8lx%s",
 | |
| 	       ospf6_lstype_short_name (lsa->header->type),
 | |
| 	       id, adv_router, ospf6_lsa_age_current (lsa),
 | |
| 	       (u_long) ntohl (lsa->header->seqnum), VNL);
 | |
|     }
 | |
| }
 | |
| 
 | |
| void
 | |
| ospf6_lsa_show_dump (struct vty *vty, struct ospf6_lsa *lsa)
 | |
| {
 | |
|   u_char *start, *end, *current;
 | |
|   char byte[4];
 | |
| 
 | |
|   start = (u_char *) lsa->header;
 | |
|   end = (u_char *) lsa->header + ntohs (lsa->header->length);
 | |
| 
 | |
|   vty_out (vty, "%s", VNL);
 | |
|   vty_out (vty, "%s:%s", lsa->name, VNL);
 | |
| 
 | |
|   for (current = start; current < end; current ++)
 | |
|     {
 | |
|       if ((current - start) % 16 == 0)
 | |
|         vty_out (vty, "%s        ", VNL);
 | |
|       else if ((current - start) % 4 == 0)
 | |
|         vty_out (vty, " ");
 | |
| 
 | |
|       snprintf (byte, sizeof (byte), "%02x", *current);
 | |
|       vty_out (vty, "%s", byte);
 | |
|     }
 | |
| 
 | |
|   vty_out (vty, "%s%s", VNL, VNL);
 | |
|   return;
 | |
| }
 | |
| 
 | |
| void
 | |
| ospf6_lsa_show_internal (struct vty *vty, struct ospf6_lsa *lsa)
 | |
| {
 | |
|   char adv_router[64], id[64];
 | |
| 
 | |
|   assert (lsa && lsa->header);
 | |
| 
 | |
|   inet_ntop (AF_INET, &lsa->header->id, id, sizeof (id));
 | |
|   inet_ntop (AF_INET, &lsa->header->adv_router,
 | |
|              adv_router, sizeof (adv_router));
 | |
| 
 | |
|   vty_out (vty, "%s", VNL);
 | |
|   vty_out (vty, "Age: %4hu Type: %s%s", ospf6_lsa_age_current (lsa),
 | |
|            ospf6_lstype_name (lsa->header->type), VNL);
 | |
|   vty_out (vty, "Link State ID: %s%s", id, VNL);
 | |
|   vty_out (vty, "Advertising Router: %s%s", adv_router, VNL);
 | |
|   vty_out (vty, "LS Sequence Number: %#010lx%s",
 | |
|            (u_long) ntohl (lsa->header->seqnum), VNL);
 | |
|   vty_out (vty, "CheckSum: %#06hx Length: %hu%s",
 | |
|            ntohs (lsa->header->checksum),
 | |
|            ntohs (lsa->header->length), VNL);
 | |
|   vty_out (vty, "Flag: %x %s", lsa->flag, VNL);
 | |
|   vty_out (vty, "Lock: %d %s", lsa->lock, VNL);
 | |
|   vty_out (vty, "ReTx Count: %d%s", lsa->retrans_count, VNL);
 | |
|   vty_out (vty, "Threads: Expire: 0x%p, Refresh: 0x%p %s",
 | |
|            (void *)lsa->expire, (void *)lsa->refresh, VNL);
 | |
|   vty_out (vty, "%s", VNL);
 | |
|   return;
 | |
| }
 | |
| 
 | |
| void
 | |
| ospf6_lsa_show (struct vty *vty, struct ospf6_lsa *lsa)
 | |
| {
 | |
|   char adv_router[64], id[64];
 | |
|   struct ospf6_lsa_handler *handler;
 | |
|   struct timeval now, res;
 | |
|   char duration[16];
 | |
| 
 | |
|   assert (lsa && lsa->header);
 | |
| 
 | |
|   inet_ntop (AF_INET, &lsa->header->id, id, sizeof (id));
 | |
|   inet_ntop (AF_INET, &lsa->header->adv_router,
 | |
|              adv_router, sizeof (adv_router));
 | |
| 
 | |
|   quagga_gettime (QUAGGA_CLK_MONOTONIC, &now);
 | |
|   timersub (&now, &lsa->installed, &res);
 | |
|   timerstring (&res, duration, sizeof (duration));
 | |
| 
 | |
|   vty_out (vty, "Age: %4hu Type: %s%s", ospf6_lsa_age_current (lsa),
 | |
|            ospf6_lstype_name (lsa->header->type), VNL);
 | |
|   vty_out (vty, "Link State ID: %s%s", id, VNL);
 | |
|   vty_out (vty, "Advertising Router: %s%s", adv_router, VNL);
 | |
|   vty_out (vty, "LS Sequence Number: %#010lx%s",
 | |
|            (u_long) ntohl (lsa->header->seqnum), VNL);
 | |
|   vty_out (vty, "CheckSum: %#06hx Length: %hu%s",
 | |
|            ntohs (lsa->header->checksum),
 | |
|            ntohs (lsa->header->length), VNL);
 | |
|   vty_out (vty, "Duration: %s%s", duration, VNL);
 | |
| 
 | |
|   handler = ospf6_get_lsa_handler (lsa->header->type);
 | |
|   if (handler->show == NULL)
 | |
|     handler = &unknown_handler;
 | |
|   (*handler->show) (vty, lsa);
 | |
| 
 | |
|   vty_out (vty, "%s", VNL);
 | |
| }
 | |
| 
 | |
| /* OSPFv3 LSA creation/deletion function */
 | |
| struct ospf6_lsa *
 | |
| ospf6_lsa_create (struct ospf6_lsa_header *header)
 | |
| {
 | |
|   struct ospf6_lsa *lsa = NULL;
 | |
|   struct ospf6_lsa_header *new_header = NULL;
 | |
|   u_int16_t lsa_size = 0;
 | |
| 
 | |
|   /* size of the entire LSA */
 | |
|   lsa_size = ntohs (header->length);   /* XXX vulnerable */
 | |
| 
 | |
|   /* allocate memory for this LSA */
 | |
|   new_header = (struct ospf6_lsa_header *)
 | |
|     XMALLOC (MTYPE_OSPF6_LSA, lsa_size);
 | |
| 
 | |
|   /* copy LSA from original header */
 | |
|   memcpy (new_header, header, lsa_size);
 | |
| 
 | |
|   /* LSA information structure */
 | |
|   /* allocate memory */
 | |
|   lsa = (struct ospf6_lsa *)
 | |
|     XCALLOC (MTYPE_OSPF6_LSA, sizeof (struct ospf6_lsa));
 | |
| 
 | |
|   lsa->header = (struct ospf6_lsa_header *) new_header;
 | |
| 
 | |
|   /* dump string */
 | |
|   ospf6_lsa_printbuf (lsa, lsa->name, sizeof (lsa->name));
 | |
| 
 | |
|   /* calculate birth of this lsa */
 | |
|   ospf6_lsa_age_set (lsa);
 | |
| 
 | |
|   return lsa;
 | |
| }
 | |
| 
 | |
| struct ospf6_lsa *
 | |
| ospf6_lsa_create_headeronly (struct ospf6_lsa_header *header)
 | |
| {
 | |
|   struct ospf6_lsa *lsa = NULL;
 | |
|   struct ospf6_lsa_header *new_header = NULL;
 | |
| 
 | |
|   /* allocate memory for this LSA */
 | |
|   new_header = (struct ospf6_lsa_header *)
 | |
|     XMALLOC (MTYPE_OSPF6_LSA, sizeof (struct ospf6_lsa_header));
 | |
| 
 | |
|   /* copy LSA from original header */
 | |
|   memcpy (new_header, header, sizeof (struct ospf6_lsa_header));
 | |
| 
 | |
|   /* LSA information structure */
 | |
|   /* allocate memory */
 | |
|   lsa = (struct ospf6_lsa *)
 | |
|     XCALLOC (MTYPE_OSPF6_LSA, sizeof (struct ospf6_lsa));
 | |
| 
 | |
|   lsa->header = (struct ospf6_lsa_header *) new_header;
 | |
|   SET_FLAG (lsa->flag, OSPF6_LSA_HEADERONLY);
 | |
| 
 | |
|   /* dump string */
 | |
|   ospf6_lsa_printbuf (lsa, lsa->name, sizeof (lsa->name));
 | |
| 
 | |
|   /* calculate birth of this lsa */
 | |
|   ospf6_lsa_age_set (lsa);
 | |
| 
 | |
|   return lsa;
 | |
| }
 | |
| 
 | |
| void
 | |
| ospf6_lsa_delete (struct ospf6_lsa *lsa)
 | |
| {
 | |
|   assert (lsa->lock == 0);
 | |
| 
 | |
|   /* cancel threads */
 | |
|   THREAD_OFF (lsa->expire);
 | |
|   THREAD_OFF (lsa->refresh);
 | |
| 
 | |
|   /* do free */
 | |
|   XFREE (MTYPE_OSPF6_LSA, lsa->header);
 | |
|   XFREE (MTYPE_OSPF6_LSA, lsa);
 | |
| }
 | |
| 
 | |
| struct ospf6_lsa *
 | |
| ospf6_lsa_copy (struct ospf6_lsa *lsa)
 | |
| {
 | |
|   struct ospf6_lsa *copy = NULL;
 | |
| 
 | |
|   ospf6_lsa_age_current (lsa);
 | |
|   if (CHECK_FLAG (lsa->flag, OSPF6_LSA_HEADERONLY))
 | |
|     copy = ospf6_lsa_create_headeronly (lsa->header);
 | |
|   else
 | |
|     copy = ospf6_lsa_create (lsa->header);
 | |
|   assert (copy->lock == 0);
 | |
| 
 | |
|   copy->birth = lsa->birth;
 | |
|   copy->originated = lsa->originated;
 | |
|   copy->received = lsa->received;
 | |
|   copy->installed = lsa->installed;
 | |
|   copy->lsdb = lsa->lsdb;
 | |
|   copy->rn = NULL;
 | |
| 
 | |
|   return copy;
 | |
| }
 | |
| 
 | |
| /* increment reference counter of struct ospf6_lsa */
 | |
| void
 | |
| ospf6_lsa_lock (struct ospf6_lsa *lsa)
 | |
| {
 | |
|   lsa->lock++;
 | |
|   return;
 | |
| }
 | |
| 
 | |
| /* decrement reference counter of struct ospf6_lsa */
 | |
| void
 | |
| ospf6_lsa_unlock (struct ospf6_lsa *lsa)
 | |
| {
 | |
|   /* decrement reference counter */
 | |
|   assert (lsa->lock > 0);
 | |
|   lsa->lock--;
 | |
| 
 | |
|   if (lsa->lock != 0)
 | |
|     return;
 | |
| 
 | |
|   ospf6_lsa_delete (lsa);
 | |
| }
 | |
| 
 | |
| 
 | |
| /* ospf6 lsa expiry */
 | |
| int
 | |
| ospf6_lsa_expire (struct thread *thread)
 | |
| {
 | |
|   struct ospf6_lsa *lsa;
 | |
| 
 | |
|   lsa = (struct ospf6_lsa *) THREAD_ARG (thread);
 | |
| 
 | |
|   assert (lsa && lsa->header);
 | |
|   assert (OSPF6_LSA_IS_MAXAGE (lsa));
 | |
|   assert (! lsa->refresh);
 | |
| 
 | |
|   lsa->expire = (struct thread *) NULL;
 | |
| 
 | |
|   if (IS_OSPF6_DEBUG_LSA_TYPE (lsa->header->type))
 | |
|     {
 | |
|       zlog_debug ("LSA Expire:");
 | |
|       ospf6_lsa_header_print (lsa);
 | |
|     }
 | |
| 
 | |
|   if (CHECK_FLAG (lsa->flag, OSPF6_LSA_HEADERONLY))
 | |
|     return 0;    /* dbexchange will do something ... */
 | |
| 
 | |
|   /* reinstall lsa */
 | |
|   ospf6_install_lsa (lsa);
 | |
| 
 | |
|   /* reflood lsa */
 | |
|   ospf6_flood (NULL, lsa);
 | |
| 
 | |
|   /* schedule maxage remover */
 | |
|   ospf6_maxage_remove (ospf6);
 | |
| 
 | |
|   return 0;
 | |
| }
 | |
| 
 | |
| int
 | |
| ospf6_lsa_refresh (struct thread *thread)
 | |
| {
 | |
|   struct ospf6_lsa *old, *self, *new;
 | |
|   struct ospf6_lsdb *lsdb_self;
 | |
| 
 | |
|   assert (thread);
 | |
|   old = (struct ospf6_lsa *) THREAD_ARG (thread);
 | |
|   assert (old && old->header);
 | |
| 
 | |
|   old->refresh = (struct thread *) NULL;
 | |
| 
 | |
|   lsdb_self = ospf6_get_scoped_lsdb_self (old);
 | |
|   self = ospf6_lsdb_lookup (old->header->type, old->header->id,
 | |
|                             old->header->adv_router, lsdb_self);
 | |
|   if (self == NULL)
 | |
|     {
 | |
|       if (IS_OSPF6_DEBUG_LSA_TYPE (old->header->type))
 | |
|         zlog_debug ("Refresh: could not find self LSA, flush %s", old->name);
 | |
|       ospf6_lsa_premature_aging (old);
 | |
|       return 0;
 | |
|     }
 | |
| 
 | |
|   /* Reset age, increment LS sequence number. */
 | |
|   self->header->age = htons (0);
 | |
|   self->header->seqnum =
 | |
|     ospf6_new_ls_seqnum (self->header->type, self->header->id,
 | |
|                          self->header->adv_router, old->lsdb);
 | |
|   ospf6_lsa_checksum (self->header);
 | |
| 
 | |
|   new = ospf6_lsa_create (self->header);
 | |
|   new->lsdb = old->lsdb;
 | |
|   new->refresh = thread_add_timer (master, ospf6_lsa_refresh, new,
 | |
|                                    OSPF_LS_REFRESH_TIME);
 | |
| 
 | |
|   /* store it in the LSDB for self-originated LSAs */
 | |
|   ospf6_lsdb_add (ospf6_lsa_copy (new), lsdb_self);
 | |
| 
 | |
|   if (IS_OSPF6_DEBUG_LSA_TYPE (new->header->type))
 | |
|     {
 | |
|       zlog_debug ("LSA Refresh:");
 | |
|       ospf6_lsa_header_print (new);
 | |
|     }
 | |
| 
 | |
|   ospf6_install_lsa (new);
 | |
|   ospf6_flood (NULL, new);
 | |
| 
 | |
|   return 0;
 | |
| }
 | |
| 
 | |
| 
 | |
| 
 | |
| /* Fletcher Checksum -- Refer to RFC1008. */
 | |
| 
 | |
| /* All the offsets are zero-based. The offsets in the RFC1008 are
 | |
|    one-based. */
 | |
| unsigned short
 | |
| ospf6_lsa_checksum (struct ospf6_lsa_header *lsa_header)
 | |
| {
 | |
|   u_char *buffer = (u_char *) &lsa_header->type;
 | |
|   int type_offset = buffer - (u_char *) &lsa_header->age; /* should be 2 */
 | |
| 
 | |
|   /* Skip the AGE field */
 | |
|   u_int16_t len = ntohs(lsa_header->length) - type_offset;
 | |
| 
 | |
|   /* Checksum offset starts from "type" field, not the beginning of the
 | |
|      lsa_header struct. The offset is 14, rather than 16. */
 | |
|   int checksum_offset = (u_char *) &lsa_header->checksum - buffer;
 | |
| 
 | |
|   return (unsigned short)fletcher_checksum(buffer, len, checksum_offset);
 | |
| }
 | |
| 
 | |
| int
 | |
| ospf6_lsa_checksum_valid (struct ospf6_lsa_header *lsa_header)
 | |
| {
 | |
|   u_char *buffer = (u_char *) &lsa_header->type;
 | |
|   int type_offset = buffer - (u_char *) &lsa_header->age; /* should be 2 */
 | |
| 
 | |
|   /* Skip the AGE field */
 | |
|   u_int16_t len = ntohs(lsa_header->length) - type_offset;
 | |
| 
 | |
|   return (fletcher_checksum(buffer, len, FLETCHER_CHECKSUM_VALIDATE) == 0);
 | |
| }
 | |
| 
 | |
| void
 | |
| ospf6_lsa_init (void)
 | |
| {
 | |
|   ospf6_lsa_handler_vector = vector_init (0);
 | |
|   ospf6_install_lsa_handler (&unknown_handler);
 | |
| }
 | |
| 
 | |
| void
 | |
| ospf6_lsa_terminate (void)
 | |
| {
 | |
|   vector_free (ospf6_lsa_handler_vector);
 | |
| }
 | |
| 
 | |
| static char *
 | |
| ospf6_lsa_handler_name (struct ospf6_lsa_handler *h)
 | |
| {
 | |
|   static char buf[64];
 | |
|   unsigned int i; 
 | |
|   unsigned int size = strlen (h->name);
 | |
| 
 | |
|   if (!strcmp(h->name, "unknown") &&
 | |
|       h->type != OSPF6_LSTYPE_UNKNOWN)
 | |
|     {
 | |
|       snprintf (buf, sizeof (buf), "%#04hx", h->type);
 | |
|       return buf;
 | |
|     }
 | |
| 
 | |
|   for (i = 0; i < MIN (size, sizeof (buf)); i++)
 | |
|     {
 | |
|       if (! islower ((unsigned char)h->name[i]))
 | |
|         buf[i] = tolower ((unsigned char)h->name[i]);
 | |
|       else
 | |
|         buf[i] = h->name[i];
 | |
|     }
 | |
|   buf[size] = '\0';
 | |
|   return buf;
 | |
| }
 | |
| 
 | |
| DEFUN (debug_ospf6_lsa_type,
 | |
|        debug_ospf6_lsa_hex_cmd,
 | |
|        "debug ospf6 lsa (router|network|inter-prefix|inter-router|as-external|link|intra-prefix|unknown)",
 | |
|        DEBUG_STR
 | |
|        OSPF6_STR
 | |
|        "Debug Link State Advertisements (LSAs)\n"
 | |
|        "Specify LS type as Hexadecimal\n"
 | |
|       )
 | |
| {
 | |
|   unsigned int i;
 | |
|   struct ospf6_lsa_handler *handler = NULL;
 | |
| 
 | |
|   assert (argc);
 | |
| 
 | |
|   for (i = 0; i < vector_active (ospf6_lsa_handler_vector); i++)
 | |
|     {
 | |
|       handler = vector_slot (ospf6_lsa_handler_vector, i);
 | |
|       if (handler == NULL)
 | |
|         continue;
 | |
|       if (strncmp (argv[0], ospf6_lsa_handler_name(handler), strlen(argv[0])) == 0)
 | |
|         break;
 | |
|       if (! strcasecmp (argv[0], handler->name))
 | |
|         break;
 | |
|       handler = NULL;
 | |
|     }
 | |
| 
 | |
|   if (handler == NULL)
 | |
|     handler = &unknown_handler;
 | |
| 
 | |
|   if (argc >= 2)
 | |
|     {
 | |
|       if (! strcmp (argv[1], "originate"))
 | |
|         SET_FLAG (handler->debug, OSPF6_LSA_DEBUG_ORIGINATE);
 | |
|       if (! strcmp (argv[1], "examine"))
 | |
|         SET_FLAG (handler->debug, OSPF6_LSA_DEBUG_EXAMIN);
 | |
|       if (! strcmp (argv[1], "flooding"))
 | |
|         SET_FLAG (handler->debug, OSPF6_LSA_DEBUG_FLOOD);
 | |
|     }
 | |
|   else
 | |
|     SET_FLAG (handler->debug, OSPF6_LSA_DEBUG);
 | |
| 
 | |
|   return CMD_SUCCESS;
 | |
| }
 | |
| 
 | |
| ALIAS (debug_ospf6_lsa_type,
 | |
|        debug_ospf6_lsa_hex_detail_cmd,
 | |
|        "debug ospf6 lsa (router|network|inter-prefix|inter-router|as-external|link|intra-prefix|unknown) (originate|examine|flooding)",
 | |
|        DEBUG_STR
 | |
|        OSPF6_STR
 | |
|        "Debug Link State Advertisements (LSAs)\n"
 | |
|        "Specify LS type as Hexadecimal\n"
 | |
|       )
 | |
| 
 | |
| DEFUN (no_debug_ospf6_lsa_type,
 | |
|        no_debug_ospf6_lsa_hex_cmd,
 | |
|        "no debug ospf6 lsa (router|network|inter-prefix|inter-router|as-external|link|intra-prefix|unknown)",
 | |
|        NO_STR
 | |
|        DEBUG_STR
 | |
|        OSPF6_STR
 | |
|        "Debug Link State Advertisements (LSAs)\n"
 | |
|        "Specify LS type as Hexadecimal\n"
 | |
|       )
 | |
| {
 | |
|   u_int i;
 | |
|   struct ospf6_lsa_handler *handler = NULL;
 | |
| 
 | |
|   assert (argc);
 | |
| 
 | |
|   for (i = 0; i < vector_active (ospf6_lsa_handler_vector); i++)
 | |
|     {
 | |
|       handler = vector_slot (ospf6_lsa_handler_vector, i);
 | |
|       if (handler == NULL)
 | |
|         continue;
 | |
|       if (strncmp (argv[0], ospf6_lsa_handler_name(handler), strlen(argv[0])) == 0)
 | |
|         break;
 | |
|       if (! strcasecmp (argv[0], handler->name))
 | |
|         break;
 | |
|     }
 | |
| 
 | |
|   if (handler == NULL)
 | |
|     return CMD_SUCCESS;
 | |
| 
 | |
|   if (argc >= 2)
 | |
|     {
 | |
|       if (! strcmp (argv[1], "originate"))
 | |
|         UNSET_FLAG (handler->debug, OSPF6_LSA_DEBUG_ORIGINATE);
 | |
|       if (! strcmp (argv[1], "examine"))
 | |
|         UNSET_FLAG (handler->debug, OSPF6_LSA_DEBUG_EXAMIN);
 | |
|       if (! strcmp (argv[1], "flooding"))
 | |
|         UNSET_FLAG (handler->debug, OSPF6_LSA_DEBUG_FLOOD);
 | |
|     }
 | |
|   else
 | |
|     UNSET_FLAG (handler->debug, OSPF6_LSA_DEBUG);
 | |
| 
 | |
|   return CMD_SUCCESS;
 | |
| }
 | |
| 
 | |
| ALIAS (no_debug_ospf6_lsa_type,
 | |
|        no_debug_ospf6_lsa_hex_detail_cmd,
 | |
|        "no debug ospf6 lsa (router|network|inter-prefix|inter-router|as-external|link|intra-prefix) (originate|examine|flooding)",
 | |
|        NO_STR
 | |
|        DEBUG_STR
 | |
|        OSPF6_STR
 | |
|        "Debug Link State Advertisements (LSAs)\n"
 | |
|        "Specify LS type as Hexadecimal\n"
 | |
|       )
 | |
| 
 | |
| void
 | |
| install_element_ospf6_debug_lsa (void)
 | |
| {
 | |
|   install_element (ENABLE_NODE, &debug_ospf6_lsa_hex_cmd);
 | |
|   install_element (ENABLE_NODE, &debug_ospf6_lsa_hex_detail_cmd);
 | |
|   install_element (ENABLE_NODE, &no_debug_ospf6_lsa_hex_cmd);
 | |
|   install_element (ENABLE_NODE, &no_debug_ospf6_lsa_hex_detail_cmd);
 | |
|   install_element (CONFIG_NODE, &debug_ospf6_lsa_hex_cmd);
 | |
|   install_element (CONFIG_NODE, &debug_ospf6_lsa_hex_detail_cmd);
 | |
|   install_element (CONFIG_NODE, &no_debug_ospf6_lsa_hex_cmd);
 | |
|   install_element (CONFIG_NODE, &no_debug_ospf6_lsa_hex_detail_cmd);
 | |
| }
 | |
| 
 | |
| int
 | |
| config_write_ospf6_debug_lsa (struct vty *vty)
 | |
| {
 | |
|   u_int i;
 | |
|   struct ospf6_lsa_handler *handler;
 | |
| 
 | |
|   for (i = 0; i < vector_active (ospf6_lsa_handler_vector); i++)
 | |
|     {
 | |
|       handler = vector_slot (ospf6_lsa_handler_vector, i);
 | |
|       if (handler == NULL)
 | |
|         continue;
 | |
|       if (CHECK_FLAG (handler->debug, OSPF6_LSA_DEBUG))
 | |
|         vty_out (vty, "debug ospf6 lsa %s%s",
 | |
|                  ospf6_lsa_handler_name (handler), VNL);
 | |
|       if (CHECK_FLAG (handler->debug, OSPF6_LSA_DEBUG_ORIGINATE))
 | |
|         vty_out (vty, "debug ospf6 lsa %s originate%s",
 | |
|                  ospf6_lsa_handler_name (handler), VNL);
 | |
|       if (CHECK_FLAG (handler->debug, OSPF6_LSA_DEBUG_EXAMIN))
 | |
|         vty_out (vty, "debug ospf6 lsa %s examine%s",
 | |
|                  ospf6_lsa_handler_name (handler), VNL);
 | |
|       if (CHECK_FLAG (handler->debug, OSPF6_LSA_DEBUG_FLOOD))
 | |
|         vty_out (vty, "debug ospf6 lsa %s flooding%s",
 | |
|                  ospf6_lsa_handler_name (handler), VNL);
 | |
|     }
 | |
| 
 | |
|   return 0;
 | |
| }
 | |
| 
 | |
| 
 |