[mirror_frr.git] / isisd / isis_dr.c

/*
 * IS-IS Rout(e)ing protocol - isis_dr.c
 *                             IS-IS designated router related routines   
 *
 * Copyright (C) 2001,2002   Sampo Saaristo
 *                           Tampere University of Technology      
 *                           Institute of Communications Engineering
 *
 * This program is free software; you can redistribute it and/or modify it 
 * under the terms of the GNU General Public Licenseas published by the Free 
 * Software Foundation; either version 2 of the License, or (at your option) 
 * any later version.
 *
 * This program is distributed in the hope that it will be useful,but WITHOUT 
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or 
 * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License for 
 * more details.

 * You should have received a copy of the GNU General Public License along 
 * with this program; if not, write to the Free Software Foundation, Inc., 
 * 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
 */


#include <zebra.h>

#include "log.h"
#include "hash.h"
#include "thread.h"
#include "linklist.h"
#include "vty.h"
#include "stream.h"
#include "if.h"

#include "isisd/dict.h"
#include "isisd/isis_constants.h"
#include "isisd/isis_common.h"
#include "isisd/isis_misc.h"
#include "isisd/isis_flags.h"
#include "isisd/isis_circuit.h"
#include "isisd/isisd.h"
#include "isisd/isis_adjacency.h"
#include "isisd/isis_constants.h"
#include "isisd/isis_pdu.h"
#include "isisd/isis_tlv.h"
#include "isisd/isis_lsp.h"
#include "isisd/isis_dr.h"
#include "isisd/isis_events.h"

extern struct isis *isis;
extern struct thread_master *master;

const char *
isis_disflag2string (int disflag)
{

  switch (disflag)
    {
    case ISIS_IS_NOT_DIS:
      return "is not DIS";
    case ISIS_IS_DIS:
      return "is DIS";
    case ISIS_WAS_DIS:
      return "was DIS";
    default:
      return "unknown DIS state";
    }
  return NULL;			/* not reached */
}

int
isis_run_dr_l1 (struct thread *thread)
{
  struct isis_circuit *circuit;

  circuit = THREAD_ARG (thread);
  assert (circuit);

  if (circuit->u.bc.run_dr_elect[0])
    zlog_warn ("isis_run_dr(): run_dr_elect already set for l1");

  circuit->u.bc.t_run_dr[0] = NULL;
  circuit->u.bc.run_dr_elect[0] = 1;

  return ISIS_OK;
}

int
isis_run_dr_l2 (struct thread *thread)
{
  struct isis_circuit *circuit;

  circuit = THREAD_ARG (thread);
  assert (circuit);

  if (circuit->u.bc.run_dr_elect[1])
    zlog_warn ("isis_run_dr(): run_dr_elect already set for l2");


  circuit->u.bc.t_run_dr[1] = NULL;
  circuit->u.bc.run_dr_elect[1] = 1;

  return ISIS_OK;
}

static int
isis_check_dr_change (struct isis_adjacency *adj, int level)
{
  int i;

  if (adj->dis_record[level - 1].dis !=
      adj->dis_record[(1 * ISIS_LEVELS) + level - 1].dis)
    /* was there a DIS state transition ? */
    {
      adj->dischanges[level - 1]++;
      /* ok rotate the history list through */
      for (i = DIS_RECORDS - 1; i > 0; i--)
	{
	  adj->dis_record[(i * ISIS_LEVELS) + level - 1].dis =
	    adj->dis_record[((i - 1) * ISIS_LEVELS) + level - 1].dis;
	  adj->dis_record[(i * ISIS_LEVELS) + level - 1].last_dis_change =
	    adj->dis_record[((i - 1) * ISIS_LEVELS) + level -
			    1].last_dis_change;
	}
    }
  return ISIS_OK;
}

int
isis_dr_elect (struct isis_circuit *circuit, int level)
{
  struct list *adjdb;
  struct listnode *node;
  struct isis_adjacency *adj, *adj_dr = NULL;
  struct list *list = list_new ();
  u_char own_prio;
  int biggest_prio = -1;
  int cmp_res, retval = ISIS_OK;

  own_prio = circuit->u.bc.priority[level - 1];
  adjdb = circuit->u.bc.adjdb[level - 1];

  if (!adjdb)
    {
      zlog_warn ("isis_dr_elect() adjdb == NULL");
      retval = ISIS_WARNING;
      list_delete (list);
      goto out;
    }
  isis_adj_build_up_list (adjdb, list);

  /*
   * Loop the adjacencies and find the one with the biggest priority
   */
  for (node = listhead (list); node; nextnode (node))
    {
      adj = getdata (node);
      /* clear flag for show output */
      adj->dis_record[level - 1].dis = ISIS_IS_NOT_DIS;
      adj->dis_record[level - 1].last_dis_change = time (NULL);

      if (adj->prio[level - 1] > biggest_prio)
	{
	  biggest_prio = adj->prio[level - 1];
	  adj_dr = adj;
	}
      else if (adj->prio[level - 1] == biggest_prio)
	{
	  /*
	   * Comparison of MACs breaks a tie
	   */
	  if (adj_dr)
	    {
	      cmp_res = memcmp (adj_dr->snpa, adj->snpa, ETH_ALEN);
	      if (cmp_res < 0)
		{
		  adj_dr = adj;
		}
	      if (cmp_res == 0)
		zlog_warn
		  ("isis_dr_elect(): multiple adjacencies with same SNPA");
	    }
	  else
	    {
	      adj_dr = adj;
	    }
	}
    }

  if (!adj_dr)
    {
      /*
       * Could not find the DR - means we are alone and thus the DR
       */
      if (!circuit->u.bc.is_dr[level - 1])
	{
	  list_delete (list);
	  list = NULL;
	  return isis_dr_commence (circuit, level);
	}
      goto out;
    }

  /*
   * Now we have the DR adjacency, compare it to self
   */
  if (adj_dr->prio[level - 1] < own_prio
      || (adj_dr->prio[level - 1] == own_prio
	  && memcmp (adj_dr->snpa, circuit->u.bc.snpa, ETH_ALEN) < 0))
    {
      if (!circuit->u.bc.is_dr[level - 1])
	{
	  /*
	   * We are the DR
	   */

	  /* rotate the history log */
	  for (node = listhead (list); node; nextnode (node))
	    {
	      adj = getdata (node);
	      isis_check_dr_change (adj, level);
	    }

	  /* commence */
	  list_delete (list);
	  return isis_dr_commence (circuit, level);
	}
    }
  else
    {

      /* ok we have found the DIS - lets mark the adjacency */
      /* set flag for show output */
      adj_dr->dis_record[level - 1].dis = ISIS_IS_DIS;
      adj_dr->dis_record[level - 1].last_dis_change = time (NULL);

      /* now loop through a second time to check if there has been a DIS change
       * if yes rotate the history log
       */

      for (node = listhead (list); node; nextnode (node))
	{
	  adj = getdata (node);
	  isis_check_dr_change (adj, level);
	}

      /*
       * We are not DR - if we were -> resign
       */

      if (circuit->u.bc.is_dr[level - 1])
	{
	  list_delete (list);
	  return isis_dr_resign (circuit, level);
	}
    }
out:
  if (list)
    list_delete (list);
  return retval;
}

int
isis_dr_resign (struct isis_circuit *circuit, int level)
{
  u_char id[ISIS_SYS_ID_LEN + 2];

  zlog_debug ("isis_dr_resign l%d", level);

  circuit->u.bc.is_dr[level - 1] = 0;
  circuit->u.bc.run_dr_elect[level - 1] = 0;
  THREAD_TIMER_OFF (circuit->u.bc.t_run_dr[level - 1]);
  THREAD_TIMER_OFF (circuit->u.bc.t_refresh_pseudo_lsp[level - 1]);

  memcpy (id, isis->sysid, ISIS_SYS_ID_LEN);
  LSP_PSEUDO_ID (id) = circuit->circuit_id;
  LSP_FRAGMENT (id) = 0;
  lsp_purge_dr (id, circuit, level);

  if (level == 1)
    {
      memset (circuit->u.bc.l1_desig_is, 0, ISIS_SYS_ID_LEN + 1);

      THREAD_TIMER_OFF (circuit->t_send_csnp[0]);

      THREAD_TIMER_ON (master, circuit->u.bc.t_run_dr[0], isis_run_dr_l1,
		       circuit, 2 * circuit->hello_interval[1]);

      THREAD_TIMER_ON (master, circuit->t_send_psnp[0], send_l1_psnp, circuit,
		       isis_jitter (circuit->psnp_interval[level - 1],
				    PSNP_JITTER));
    }
  else
    {
      memset (circuit->u.bc.l2_desig_is, 0, ISIS_SYS_ID_LEN + 1);

      THREAD_TIMER_OFF (circuit->t_send_csnp[1]);

      THREAD_TIMER_ON (master, circuit->u.bc.t_run_dr[1], isis_run_dr_l2,
		       circuit, 2 * circuit->hello_interval[1]);

      THREAD_TIMER_ON (master, circuit->t_send_psnp[1], send_l2_psnp, circuit,
		       isis_jitter (circuit->psnp_interval[level - 1],
				    PSNP_JITTER));
    }

  thread_add_event (master, isis_event_dis_status_change, circuit, 0);

  return ISIS_OK;
}

int
isis_dr_commence (struct isis_circuit *circuit, int level)
{
  u_char old_dr[ISIS_SYS_ID_LEN + 2];

  zlog_debug ("isis_dr_commence l%d", level);

  /* Lets keep a pause in DR election */
  circuit->u.bc.run_dr_elect[level - 1] = 0;
  if (level == 1)
    THREAD_TIMER_ON (master, circuit->u.bc.t_run_dr[0], isis_run_dr_l1,
		     circuit, 2 * circuit->hello_interval[0]);
  else
    THREAD_TIMER_ON (master, circuit->u.bc.t_run_dr[1], isis_run_dr_l2,
		     circuit, 2 * circuit->hello_interval[1]);
  circuit->u.bc.is_dr[level - 1] = 1;

  if (level == 1)
    {
      memcpy (old_dr, circuit->u.bc.l1_desig_is, ISIS_SYS_ID_LEN + 1);
      LSP_FRAGMENT (old_dr) = 0;
      if (LSP_PSEUDO_ID (old_dr))
	{
	  /* there was a dr elected, purge its LSPs from the db */
	  lsp_purge_dr (old_dr, circuit, level);
	}
      memcpy (circuit->u.bc.l1_desig_is, isis->sysid, ISIS_SYS_ID_LEN);
      *(circuit->u.bc.l1_desig_is + ISIS_SYS_ID_LEN) = circuit->circuit_id;

      assert (circuit->circuit_id);	/* must be non-zero */
      /*    if (circuit->t_send_l1_psnp)
         thread_cancel (circuit->t_send_l1_psnp); */
      lsp_l1_pseudo_generate (circuit);

      THREAD_TIMER_OFF (circuit->u.bc.t_run_dr[0]);
      THREAD_TIMER_ON (master, circuit->u.bc.t_run_dr[0], isis_run_dr_l1,
		       circuit, 2 * circuit->hello_interval[0]);

      THREAD_TIMER_ON (master, circuit->t_send_csnp[0], send_l1_csnp, circuit,
		       isis_jitter (circuit->csnp_interval[level - 1],
				    CSNP_JITTER));

    }
  else
    {
      memcpy (old_dr, circuit->u.bc.l2_desig_is, ISIS_SYS_ID_LEN + 1);
      LSP_FRAGMENT (old_dr) = 0;
      if (LSP_PSEUDO_ID (old_dr))
	{
	  /* there was a dr elected, purge its LSPs from the db */
	  lsp_purge_dr (old_dr, circuit, level);
	}
      memcpy (circuit->u.bc.l2_desig_is, isis->sysid, ISIS_SYS_ID_LEN);
      *(circuit->u.bc.l2_desig_is + ISIS_SYS_ID_LEN) = circuit->circuit_id;

      assert (circuit->circuit_id);	/* must be non-zero */
      /*    if (circuit->t_send_l1_psnp)
         thread_cancel (circuit->t_send_l1_psnp); */
      lsp_l2_pseudo_generate (circuit);

      THREAD_TIMER_OFF (circuit->u.bc.t_run_dr[1]);
      THREAD_TIMER_ON (master, circuit->u.bc.t_run_dr[1], isis_run_dr_l2,
		       circuit, 2 * circuit->hello_interval[1]);

      THREAD_TIMER_ON (master, circuit->t_send_csnp[1], send_l2_csnp, circuit,
		       isis_jitter (circuit->csnp_interval[level - 1],
				    CSNP_JITTER));
    }

  thread_add_event (master, isis_event_dis_status_change, circuit, 0);

  return ISIS_OK;
}
Commit	Line	Data
eb5d44eb	1	/*
	2	* IS-IS Rout(e)ing protocol - isis_dr.c
	3	* IS-IS designated router related routines
	4	*
	5	* Copyright (C) 2001,2002 Sampo Saaristo
	6	* Tampere University of Technology
	7	* Institute of Communications Engineering
	8	*
	9	* This program is free software; you can redistribute it and/or modify it
	10	* under the terms of the GNU General Public Licenseas published by the Free
	11	* Software Foundation; either version 2 of the License, or (at your option)
	12	* any later version.
	13	*
	14	* This program is distributed in the hope that it will be useful,but WITHOUT
	15	* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
	16	* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
	17	* more details.
	18
	19	* You should have received a copy of the GNU General Public License along
	20	* with this program; if not, write to the Free Software Foundation, Inc.,
	21	* 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
	22	*/
	23
	24
	25	#include <zebra.h>
eb5d44eb	26
	27	#include "log.h"
	28	#include "hash.h"
	29	#include "thread.h"
	30	#include "linklist.h"
	31	#include "vty.h"
	32	#include "stream.h"
	33	#include "if.h"
	34
	35	#include "isisd/dict.h"
	36	#include "isisd/isis_constants.h"
	37	#include "isisd/isis_common.h"
	38	#include "isisd/isis_misc.h"
	39	#include "isisd/isis_flags.h"
	40	#include "isisd/isis_circuit.h"
	41	#include "isisd/isisd.h"
	42	#include "isisd/isis_adjacency.h"
	43	#include "isisd/isis_constants.h"
	44	#include "isisd/isis_pdu.h"
	45	#include "isisd/isis_tlv.h"
	46	#include "isisd/isis_lsp.h"
	47	#include "isisd/isis_dr.h"
	48	#include "isisd/isis_events.h"
	49
	50	extern struct isis *isis;
	51	extern struct thread_master *master;
	52
1cd80845	53	const char *
f390d2c7	54	isis_disflag2string (int disflag)
f390d2c7	55	{
eb5d44eb	56
f390d2c7	57	switch (disflag)
f390d2c7	58	{
eb5d44eb	59	case ISIS_IS_NOT_DIS:
	60	return "is not DIS";
	61	case ISIS_IS_DIS:
	62	return "is DIS";
	63	case ISIS_WAS_DIS:
	64	return "was DIS";
f390d2c7	65	default:
	66	return "unknown DIS state";
	67	}
	68	return NULL; /* not reached */
eb5d44eb	69	}
eb5d44eb	70
eb5d44eb	71	int
	72	isis_run_dr_l1 (struct thread *thread)
	73	{
	74	struct isis_circuit *circuit;
f390d2c7	75
eb5d44eb	76	circuit = THREAD_ARG (thread);
	77	assert (circuit);
	78
	79	if (circuit->u.bc.run_dr_elect[0])
	80	zlog_warn ("isis_run_dr(): run_dr_elect already set for l1");
f390d2c7	81
efc1e725	82	circuit->u.bc.t_run_dr[0] = NULL;
eb5d44eb	83	circuit->u.bc.run_dr_elect[0] = 1;
f390d2c7	84
eb5d44eb	85	return ISIS_OK;
	86	}
	87
	88	int
	89	isis_run_dr_l2 (struct thread *thread)
	90	{
	91	struct isis_circuit *circuit;
f390d2c7	92
eb5d44eb	93	circuit = THREAD_ARG (thread);
	94	assert (circuit);
	95
	96	if (circuit->u.bc.run_dr_elect[1])
	97	zlog_warn ("isis_run_dr(): run_dr_elect already set for l2");
f390d2c7	98
	99
	100	circuit->u.bc.t_run_dr[1] = NULL;
eb5d44eb	101	circuit->u.bc.run_dr_elect[1] = 1;
f390d2c7	102
eb5d44eb	103	return ISIS_OK;
	104	}
	105
92365889	106	static int
eb5d44eb	107	isis_check_dr_change (struct isis_adjacency *adj, int level)
	108	{
	109	int i;
	110
f390d2c7	111	if (adj->dis_record[level - 1].dis !=
	112	adj->dis_record[(1 * ISIS_LEVELS) + level - 1].dis)
	113	/* was there a DIS state transition ? */
eb5d44eb	114	{
f390d2c7	115	adj->dischanges[level - 1]++;
eb5d44eb	116	/* ok rotate the history list through */
f390d2c7	117	for (i = DIS_RECORDS - 1; i > 0; i--)
eb5d44eb	118	{
f390d2c7	119	adj->dis_record[(i * ISIS_LEVELS) + level - 1].dis =
	120	adj->dis_record[((i - 1) * ISIS_LEVELS) + level - 1].dis;
	121	adj->dis_record[(i * ISIS_LEVELS) + level - 1].last_dis_change =
	122	adj->dis_record[((i - 1) * ISIS_LEVELS) + level -
	123	1].last_dis_change;
eb5d44eb	124	}
	125	}
	126	return ISIS_OK;
	127	}
	128
f390d2c7	129	int
eb5d44eb	130	isis_dr_elect (struct isis_circuit *circuit, int level)
	131	{
	132	struct list *adjdb;
	133	struct listnode *node;
	134	struct isis_adjacency adj, adj_dr = NULL;
	135	struct list *list = list_new ();
	136	u_char own_prio;
	137	int biggest_prio = -1;
	138	int cmp_res, retval = ISIS_OK;
f390d2c7	139
eb5d44eb	140	own_prio = circuit->u.bc.priority[level - 1];
	141	adjdb = circuit->u.bc.adjdb[level - 1];
	142
f390d2c7	143	if (!adjdb)
	144	{
	145	zlog_warn ("isis_dr_elect() adjdb == NULL");
	146	retval = ISIS_WARNING;
	147	list_delete (list);
	148	goto out;
	149	}
eb5d44eb	150	isis_adj_build_up_list (adjdb, list);
	151
	152	/*
	153	* Loop the adjacencies and find the one with the biggest priority
	154	*/
f390d2c7	155	for (node = listhead (list); node; nextnode (node))
	156	{
	157	adj = getdata (node);
	158	/* clear flag for show output */
	159	adj->dis_record[level - 1].dis = ISIS_IS_NOT_DIS;
	160	adj->dis_record[level - 1].last_dis_change = time (NULL);
	161
	162	if (adj->prio[level - 1] > biggest_prio)
	163	{
	164	biggest_prio = adj->prio[level - 1];
	165	adj_dr = adj;
	166	}
	167	else if (adj->prio[level - 1] == biggest_prio)
	168	{
	169	/*
	170	* Comparison of MACs breaks a tie
	171	*/
	172	if (adj_dr)
	173	{
	174	cmp_res = memcmp (adj_dr->snpa, adj->snpa, ETH_ALEN);
	175	if (cmp_res < 0)
	176	{
	177	adj_dr = adj;
	178	}
	179	if (cmp_res == 0)
	180	zlog_warn
	181	("isis_dr_elect(): multiple adjacencies with same SNPA");
	182	}
	183	else
	184	{
	185	adj_dr = adj;
	186	}
	187	}
	188	}
	189
	190	if (!adj_dr)
	191	{
eb5d44eb	192	/*
f390d2c7	193	* Could not find the DR - means we are alone and thus the DR
eb5d44eb	194	*/
f390d2c7	195	if (!circuit->u.bc.is_dr[level - 1])
	196	{
	197	list_delete (list);
	198	list = NULL;
	199	return isis_dr_commence (circuit, level);
eb5d44eb	200	}
f390d2c7	201	goto out;
eb5d44eb	202	}
eb5d44eb	203
	204	/*
	205	* Now we have the DR adjacency, compare it to self
	206	*/
f390d2c7	207	if (adj_dr->prio[level - 1] < own_prio
	208	\|\| (adj_dr->prio[level - 1] == own_prio
	209	&& memcmp (adj_dr->snpa, circuit->u.bc.snpa, ETH_ALEN) < 0))
	210	{
	211	if (!circuit->u.bc.is_dr[level - 1])
	212	{
	213	/*
d9c427b2	214	* We are the DR
f390d2c7	215	*/
d9c427b2	216
	217	/* rotate the history log */
	218	for (node = listhead (list); node; nextnode (node))
	219	{
	220	adj = getdata (node);
	221	isis_check_dr_change (adj, level);
	222	}
	223
	224	/* commence */
f390d2c7	225	list_delete (list);
	226	return isis_dr_commence (circuit, level);
	227	}
eb5d44eb	228	}
f390d2c7	229	else
f390d2c7	230	{
eb5d44eb	231
f390d2c7	232	/* ok we have found the DIS - lets mark the adjacency */
	233	/* set flag for show output */
	234	adj_dr->dis_record[level - 1].dis = ISIS_IS_DIS;
	235	adj_dr->dis_record[level - 1].last_dis_change = time (NULL);
eb5d44eb	236
f390d2c7	237	/* now loop through a second time to check if there has been a DIS change
	238	* if yes rotate the history log
	239	*/
eb5d44eb	240
f390d2c7	241	for (node = listhead (list); node; nextnode (node))
	242	{
	243	adj = getdata (node);
	244	isis_check_dr_change (adj, level);
	245	}
eb5d44eb	246
f390d2c7	247	/*
	248	* We are not DR - if we were -> resign
	249	*/
eb5d44eb	250
f390d2c7	251	if (circuit->u.bc.is_dr[level - 1])
	252	{
	253	list_delete (list);
	254	return isis_dr_resign (circuit, level);
	255	}
eb5d44eb	256	}
f390d2c7	257	out:
eb5d44eb	258	if (list)
	259	list_delete (list);
	260	return retval;
	261	}
	262
f390d2c7	263	int
eb5d44eb	264	isis_dr_resign (struct isis_circuit *circuit, int level)
	265	{
	266	u_char id[ISIS_SYS_ID_LEN + 2];
f390d2c7	267
529d65b3	268	zlog_debug ("isis_dr_resign l%d", level);
eb5d44eb	269
eb5d44eb	270	circuit->u.bc.is_dr[level - 1] = 0;
f390d2c7	271	circuit->u.bc.run_dr_elect[level - 1] = 0;
	272	THREAD_TIMER_OFF (circuit->u.bc.t_run_dr[level - 1]);
	273	THREAD_TIMER_OFF (circuit->u.bc.t_refresh_pseudo_lsp[level - 1]);
	274
eb5d44eb	275	memcpy (id, isis->sysid, ISIS_SYS_ID_LEN);
f390d2c7	276	LSP_PSEUDO_ID (id) = circuit->circuit_id;
f390d2c7	277	LSP_FRAGMENT (id) = 0;
eb5d44eb	278	lsp_purge_dr (id, circuit, level);
eb5d44eb	279
f390d2c7	280	if (level == 1)
	281	{
	282	memset (circuit->u.bc.l1_desig_is, 0, ISIS_SYS_ID_LEN + 1);
	283
	284	THREAD_TIMER_OFF (circuit->t_send_csnp[0]);
	285
	286	THREAD_TIMER_ON (master, circuit->u.bc.t_run_dr[0], isis_run_dr_l1,
	287	circuit, 2 * circuit->hello_interval[1]);
	288
	289	THREAD_TIMER_ON (master, circuit->t_send_psnp[0], send_l1_psnp, circuit,
	290	isis_jitter (circuit->psnp_interval[level - 1],
	291	PSNP_JITTER));
	292	}
	293	else
	294	{
	295	memset (circuit->u.bc.l2_desig_is, 0, ISIS_SYS_ID_LEN + 1);
	296
	297	THREAD_TIMER_OFF (circuit->t_send_csnp[1]);
	298
	299	THREAD_TIMER_ON (master, circuit->u.bc.t_run_dr[1], isis_run_dr_l2,
	300	circuit, 2 * circuit->hello_interval[1]);
	301
	302	THREAD_TIMER_ON (master, circuit->t_send_psnp[1], send_l2_psnp, circuit,
	303	isis_jitter (circuit->psnp_interval[level - 1],
	304	PSNP_JITTER));
	305	}
	306
eb5d44eb	307	thread_add_event (master, isis_event_dis_status_change, circuit, 0);
	308
	309	return ISIS_OK;
	310	}
	311
f390d2c7	312	int
eb5d44eb	313	isis_dr_commence (struct isis_circuit *circuit, int level)
	314	{
	315	u_char old_dr[ISIS_SYS_ID_LEN + 2];
f390d2c7	316
529d65b3	317	zlog_debug ("isis_dr_commence l%d", level);
eb5d44eb	318
	319	/* Lets keep a pause in DR election */
	320	circuit->u.bc.run_dr_elect[level - 1] = 0;
f390d2c7	321	if (level == 1)
f390d2c7	322	THREAD_TIMER_ON (master, circuit->u.bc.t_run_dr[0], isis_run_dr_l1,
a211d65d	323	circuit, 2 * circuit->hello_interval[0]);
f390d2c7	324	else
f390d2c7	325	THREAD_TIMER_ON (master, circuit->u.bc.t_run_dr[1], isis_run_dr_l2,
a211d65d	326	circuit, 2 * circuit->hello_interval[1]);
eb5d44eb	327	circuit->u.bc.is_dr[level - 1] = 1;
eb5d44eb	328
f390d2c7	329	if (level == 1)
	330	{
	331	memcpy (old_dr, circuit->u.bc.l1_desig_is, ISIS_SYS_ID_LEN + 1);
	332	LSP_FRAGMENT (old_dr) = 0;
	333	if (LSP_PSEUDO_ID (old_dr))
	334	{
	335	/* there was a dr elected, purge its LSPs from the db */
	336	lsp_purge_dr (old_dr, circuit, level);
	337	}
	338	memcpy (circuit->u.bc.l1_desig_is, isis->sysid, ISIS_SYS_ID_LEN);
	339	*(circuit->u.bc.l1_desig_is + ISIS_SYS_ID_LEN) = circuit->circuit_id;
	340
	341	assert (circuit->circuit_id); /* must be non-zero */
	342	/* if (circuit->t_send_l1_psnp)
	343	thread_cancel (circuit->t_send_l1_psnp); */
	344	lsp_l1_pseudo_generate (circuit);
	345
	346	THREAD_TIMER_OFF (circuit->u.bc.t_run_dr[0]);
	347	THREAD_TIMER_ON (master, circuit->u.bc.t_run_dr[0], isis_run_dr_l1,
	348	circuit, 2 * circuit->hello_interval[0]);
	349
	350	THREAD_TIMER_ON (master, circuit->t_send_csnp[0], send_l1_csnp, circuit,
	351	isis_jitter (circuit->csnp_interval[level - 1],
	352	CSNP_JITTER));
	353
eb5d44eb	354	}
f390d2c7	355	else
	356	{
	357	memcpy (old_dr, circuit->u.bc.l2_desig_is, ISIS_SYS_ID_LEN + 1);
	358	LSP_FRAGMENT (old_dr) = 0;
	359	if (LSP_PSEUDO_ID (old_dr))
	360	{
	361	/* there was a dr elected, purge its LSPs from the db */
	362	lsp_purge_dr (old_dr, circuit, level);
	363	}
	364	memcpy (circuit->u.bc.l2_desig_is, isis->sysid, ISIS_SYS_ID_LEN);
	365	*(circuit->u.bc.l2_desig_is + ISIS_SYS_ID_LEN) = circuit->circuit_id;
	366
	367	assert (circuit->circuit_id); /* must be non-zero */
	368	/* if (circuit->t_send_l1_psnp)
	369	thread_cancel (circuit->t_send_l1_psnp); */
	370	lsp_l2_pseudo_generate (circuit);
	371
	372	THREAD_TIMER_OFF (circuit->u.bc.t_run_dr[1]);
	373	THREAD_TIMER_ON (master, circuit->u.bc.t_run_dr[1], isis_run_dr_l2,
	374	circuit, 2 * circuit->hello_interval[1]);
	375
	376	THREAD_TIMER_ON (master, circuit->t_send_csnp[1], send_l2_csnp, circuit,
	377	isis_jitter (circuit->csnp_interval[level - 1],
	378	CSNP_JITTER));
eb5d44eb	379	}
eb5d44eb	380
eb5d44eb	381	thread_add_event (master, isis_event_dis_status_change, circuit, 0);
f390d2c7	382
eb5d44eb	383	return ISIS_OK;
eb5d44eb	384	}