Bug #362 is fixed now.
[jleu-quagga.git] / bgpd / bgp_damp.c
blob5a7c9aaaac9fa052f0c939a6cab2ea7c76d75f8d
1 /* BGP flap dampening
2 Copyright (C) 2001 IP Infusion Inc.
4 This file is part of GNU Zebra.
6 GNU Zebra is free software; you can redistribute it and/or modify it
7 under the terms of the GNU General Public License as published by the
8 Free Software Foundation; either version 2, or (at your option) any
9 later version.
11 GNU Zebra is distributed in the hope that it will be useful, but
12 WITHOUT ANY WARRANTY; without even the implied warranty of
13 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 General Public License for more details.
16 You should have received a copy of the GNU General Public License
17 along with GNU Zebra; see the file COPYING. If not, write to the Free
18 Software Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA
19 02111-1307, USA. */
21 #include <zebra.h>
22 #include <math.h>
24 #include "prefix.h"
25 #include "memory.h"
26 #include "command.h"
27 #include "log.h"
28 #include "thread.h"
30 #include "bgpd/bgpd.h"
31 #include "bgpd/bgp_damp.h"
32 #include "bgpd/bgp_table.h"
33 #include "bgpd/bgp_route.h"
34 #include "bgpd/bgp_attr.h"
35 #include "bgpd/bgp_advertise.h"
37 /* Global variable to access damping configuration */
38 struct bgp_damp_config bgp_damp_cfg;
39 struct bgp_damp_config *damp = &bgp_damp_cfg;
41 /* Utility macro to add and delete BGP dampening information to no
42 used list. */
43 #define BGP_DAMP_LIST_ADD(N,A) BGP_INFO_ADD(N,A,no_reuse_list)
44 #define BGP_DAMP_LIST_DEL(N,A) BGP_INFO_DEL(N,A,no_reuse_list)
46 /* Calculate reuse list index by penalty value. */
47 static int
48 bgp_reuse_index (int penalty)
50 unsigned int i;
51 int index;
53 i = (int)(((double) penalty / damp->reuse_limit - 1.0) * damp->scale_factor);
55 if ( i >= damp->reuse_index_size )
56 i = damp->reuse_index_size - 1;
58 index = damp->reuse_index[i] - damp->reuse_index[0];
60 return (damp->reuse_offset + index) % damp->reuse_list_size;
63 /* Add BGP dampening information to reuse list. */
64 static void
65 bgp_reuse_list_add (struct bgp_damp_info *bdi)
67 int index;
69 index = bdi->index = bgp_reuse_index (bdi->penalty);
71 bdi->prev = NULL;
72 bdi->next = damp->reuse_list[index];
73 if (damp->reuse_list[index])
74 damp->reuse_list[index]->prev = bdi;
75 damp->reuse_list[index] = bdi;
78 /* Delete BGP dampening information from reuse list. */
79 static void
80 bgp_reuse_list_delete (struct bgp_damp_info *bdi)
82 if (bdi->next)
83 bdi->next->prev = bdi->prev;
84 if (bdi->prev)
85 bdi->prev->next = bdi->next;
86 else
87 damp->reuse_list[bdi->index] = bdi->next;
90 /* Return decayed penalty value. */
91 int
92 bgp_damp_decay (time_t tdiff, int penalty)
94 unsigned int i;
96 i = (int) ((double) tdiff / DELTA_T);
98 if (i == 0)
99 return penalty;
101 if (i >= damp->decay_array_size)
102 return 0;
104 return (int) (penalty * damp->decay_array[i]);
107 /* Handler of reuse timer event. Each route in the current reuse-list
108 is evaluated. RFC2439 Section 4.8.7. */
109 static int
110 bgp_reuse_timer (struct thread *t)
112 struct bgp_damp_info *bdi;
113 struct bgp_damp_info *next;
114 time_t t_now, t_diff;
116 damp->t_reuse = NULL;
117 damp->t_reuse =
118 thread_add_timer (master, bgp_reuse_timer, NULL, DELTA_REUSE);
120 t_now = time (NULL);
122 /* 1. save a pointer to the current zeroth queue head and zero the
123 list head entry. */
124 bdi = damp->reuse_list[damp->reuse_offset];
125 damp->reuse_list[damp->reuse_offset] = NULL;
127 /* 2. set offset = modulo reuse-list-size ( offset + 1 ), thereby
128 rotating the circular queue of list-heads. */
129 damp->reuse_offset = (damp->reuse_offset + 1) % damp->reuse_list_size;
131 /* 3. if ( the saved list head pointer is non-empty ) */
132 for (; bdi; bdi = next)
134 struct bgp *bgp = bdi->binfo->peer->bgp;
136 next = bdi->next;
138 /* Set t-diff = t-now - t-updated. */
139 t_diff = t_now - bdi->t_updated;
141 /* Set figure-of-merit = figure-of-merit * decay-array-ok [t-diff] */
142 bdi->penalty = bgp_damp_decay (t_diff, bdi->penalty);
144 /* Set t-updated = t-now. */
145 bdi->t_updated = t_now;
147 /* if (figure-of-merit < reuse). */
148 if (bdi->penalty < damp->reuse_limit)
150 /* Reuse the route. */
151 bgp_info_unset_flag (bdi->rn, bdi->binfo, BGP_INFO_DAMPED);
152 bdi->suppress_time = 0;
154 if (bdi->lastrecord == BGP_RECORD_UPDATE)
156 bgp_info_unset_flag (bdi->rn, bdi->binfo, BGP_INFO_HISTORY);
157 bgp_aggregate_increment (bgp, &bdi->rn->p, bdi->binfo,
158 bdi->afi, bdi->safi);
159 bgp_process (bgp, bdi->rn, bdi->afi, bdi->safi);
162 if (bdi->penalty <= damp->reuse_limit / 2.0)
163 bgp_damp_info_free (bdi, 1);
164 else
165 BGP_DAMP_LIST_ADD (damp, bdi);
167 else
168 /* Re-insert into another list (See RFC2439 Section 4.8.6). */
169 bgp_reuse_list_add (bdi);
172 return 0;
175 /* A route becomes unreachable (RFC2439 Section 4.8.2). */
177 bgp_damp_withdraw (struct bgp_info *binfo, struct bgp_node *rn,
178 afi_t afi, safi_t safi, int attr_change)
180 time_t t_now;
181 struct bgp_damp_info *bdi = NULL;
182 double last_penalty = 0;
184 t_now = time (NULL);
186 /* Processing Unreachable Messages. */
187 if (binfo->extra)
188 bdi = binfo->extra->damp_info;
190 if (bdi == NULL)
192 /* If there is no previous stability history. */
194 /* RFC2439 said:
195 1. allocate a damping structure.
196 2. set figure-of-merit = 1.
197 3. withdraw the route. */
199 bdi = XCALLOC (MTYPE_BGP_DAMP_INFO, sizeof (struct bgp_damp_info));
200 bdi->binfo = binfo;
201 bdi->rn = rn;
202 bdi->penalty = (attr_change ? DEFAULT_PENALTY / 2 : DEFAULT_PENALTY);
203 bdi->flap = 1;
204 bdi->start_time = t_now;
205 bdi->suppress_time = 0;
206 bdi->index = -1;
207 bdi->afi = afi;
208 bdi->safi = safi;
209 (bgp_info_extra_get (binfo))->damp_info = bdi;
210 BGP_DAMP_LIST_ADD (damp, bdi);
212 else
214 last_penalty = bdi->penalty;
216 /* 1. Set t-diff = t-now - t-updated. */
217 bdi->penalty =
218 (bgp_damp_decay (t_now - bdi->t_updated, bdi->penalty)
219 + (attr_change ? DEFAULT_PENALTY / 2 : DEFAULT_PENALTY));
221 if (bdi->penalty > damp->ceiling)
222 bdi->penalty = damp->ceiling;
224 bdi->flap++;
227 assert ((rn == bdi->rn) && (binfo == bdi->binfo));
229 bdi->lastrecord = BGP_RECORD_WITHDRAW;
230 bdi->t_updated = t_now;
232 /* Make this route as historical status. */
233 bgp_info_set_flag (rn, binfo, BGP_INFO_HISTORY);
235 /* Remove the route from a reuse list if it is on one. */
236 if (CHECK_FLAG (bdi->binfo->flags, BGP_INFO_DAMPED))
238 /* If decay rate isn't equal to 0, reinsert brn. */
239 if (bdi->penalty != last_penalty)
241 bgp_reuse_list_delete (bdi);
242 bgp_reuse_list_add (bdi);
244 return BGP_DAMP_SUPPRESSED;
247 /* If not suppressed before, do annonunce this withdraw and
248 insert into reuse_list. */
249 if (bdi->penalty >= damp->suppress_value)
251 bgp_info_set_flag (rn, binfo, BGP_INFO_DAMPED);
252 bdi->suppress_time = t_now;
253 BGP_DAMP_LIST_DEL (damp, bdi);
254 bgp_reuse_list_add (bdi);
257 return BGP_DAMP_USED;
261 bgp_damp_update (struct bgp_info *binfo, struct bgp_node *rn,
262 afi_t afi, safi_t safi)
264 time_t t_now;
265 struct bgp_damp_info *bdi;
266 int status;
268 if (!binfo->extra || !((bdi = binfo->extra->damp_info)))
269 return BGP_DAMP_USED;
271 t_now = time (NULL);
272 bgp_info_unset_flag (rn, binfo, BGP_INFO_HISTORY);
274 bdi->lastrecord = BGP_RECORD_UPDATE;
275 bdi->penalty = bgp_damp_decay (t_now - bdi->t_updated, bdi->penalty);
277 if (! CHECK_FLAG (bdi->binfo->flags, BGP_INFO_DAMPED)
278 && (bdi->penalty < damp->suppress_value))
279 status = BGP_DAMP_USED;
280 else if (CHECK_FLAG (bdi->binfo->flags, BGP_INFO_DAMPED)
281 && (bdi->penalty < damp->reuse_limit) )
283 bgp_info_unset_flag (rn, binfo, BGP_INFO_DAMPED);
284 bgp_reuse_list_delete (bdi);
285 BGP_DAMP_LIST_ADD (damp, bdi);
286 bdi->suppress_time = 0;
287 status = BGP_DAMP_USED;
289 else
290 status = BGP_DAMP_SUPPRESSED;
292 if (bdi->penalty > damp->reuse_limit / 2.0)
293 bdi->t_updated = t_now;
294 else
295 bgp_damp_info_free (bdi, 0);
297 return status;
300 /* Remove dampening information and history route. */
301 int
302 bgp_damp_scan (struct bgp_info *binfo, afi_t afi, safi_t safi)
304 time_t t_now, t_diff;
305 struct bgp_damp_info *bdi;
307 assert (binfo->extra && binfo->extra->damp_info);
309 t_now = time (NULL);
310 bdi = binfo->extra->damp_info;
312 if (CHECK_FLAG (binfo->flags, BGP_INFO_DAMPED))
314 t_diff = t_now - bdi->suppress_time;
316 if (t_diff >= damp->max_suppress_time)
318 bgp_info_unset_flag (bdi->rn, binfo, BGP_INFO_DAMPED);
319 bgp_reuse_list_delete (bdi);
320 BGP_DAMP_LIST_ADD (damp, bdi);
321 bdi->penalty = damp->reuse_limit;
322 bdi->suppress_time = 0;
323 bdi->t_updated = t_now;
325 /* Need to announce UPDATE once this binfo is usable again. */
326 if (bdi->lastrecord == BGP_RECORD_UPDATE)
327 return 1;
328 else
329 return 0;
332 else
334 t_diff = t_now - bdi->t_updated;
335 bdi->penalty = bgp_damp_decay (t_diff, bdi->penalty);
337 if (bdi->penalty <= damp->reuse_limit / 2.0)
339 /* release the bdi, bdi->binfo. */
340 bgp_damp_info_free (bdi, 1);
341 return 0;
343 else
344 bdi->t_updated = t_now;
346 return 0;
349 void
350 bgp_damp_info_free (struct bgp_damp_info *bdi, int withdraw)
352 struct bgp_info *binfo;
354 if (! bdi)
355 return;
357 binfo = bdi->binfo;
358 binfo->extra->damp_info = NULL;
360 if (CHECK_FLAG (binfo->flags, BGP_INFO_DAMPED))
361 bgp_reuse_list_delete (bdi);
362 else
363 BGP_DAMP_LIST_DEL (damp, bdi);
365 bgp_info_unset_flag (bdi->rn, binfo, BGP_INFO_HISTORY|BGP_INFO_DAMPED);
367 if (bdi->lastrecord == BGP_RECORD_WITHDRAW && withdraw)
368 bgp_info_delete (bdi->rn, binfo);
370 XFREE (MTYPE_BGP_DAMP_INFO, bdi);
373 static void
374 bgp_damp_parameter_set (int hlife, int reuse, int sup, int maxsup)
376 double reuse_max_ratio;
377 unsigned int i;
378 double j;
380 damp->suppress_value = sup;
381 damp->half_life = hlife;
382 damp->reuse_limit = reuse;
383 damp->max_suppress_time = maxsup;
385 /* Initialize params per bgp_damp_config. */
386 damp->reuse_index_size = REUSE_ARRAY_SIZE;
388 damp->ceiling = (int)(damp->reuse_limit * (pow(2, (double)damp->max_suppress_time/damp->half_life)));
390 /* Decay-array computations */
391 damp->decay_array_size = ceil ((double) damp->max_suppress_time / DELTA_T);
392 damp->decay_array = XMALLOC (MTYPE_BGP_DAMP_ARRAY,
393 sizeof(double) * (damp->decay_array_size));
394 damp->decay_array[0] = 1.0;
395 damp->decay_array[1] = exp ((1.0/((double)damp->half_life/DELTA_T)) * log(0.5));
397 /* Calculate decay values for all possible times */
398 for (i = 2; i < damp->decay_array_size; i++)
399 damp->decay_array[i] = damp->decay_array[i-1] * damp->decay_array[1];
401 /* Reuse-list computations */
402 i = ceil ((double)damp->max_suppress_time / DELTA_REUSE) + 1;
403 if (i > REUSE_LIST_SIZE || i == 0)
404 i = REUSE_LIST_SIZE;
405 damp->reuse_list_size = i;
407 damp->reuse_list = XCALLOC (MTYPE_BGP_DAMP_ARRAY,
408 damp->reuse_list_size
409 * sizeof (struct bgp_reuse_node *));
410 memset (damp->reuse_list, 0x00,
411 damp->reuse_list_size * sizeof (struct bgp_reuse_node *));
413 /* Reuse-array computations */
414 damp->reuse_index = XMALLOC (MTYPE_BGP_DAMP_ARRAY,
415 sizeof(int) * damp->reuse_index_size);
416 memset (damp->reuse_index, 0x00,
417 damp->reuse_list_size * sizeof (int));
419 reuse_max_ratio = (double)damp->ceiling/damp->reuse_limit;
420 j = (exp((double)damp->max_suppress_time/damp->half_life) * log10(2.0));
421 if ( reuse_max_ratio > j && j != 0 )
422 reuse_max_ratio = j;
424 damp->scale_factor = (double)damp->reuse_index_size/(reuse_max_ratio - 1);
426 for (i = 0; i < damp->reuse_index_size; i++)
428 damp->reuse_index[i] =
429 (int)(((double)damp->half_life / DELTA_REUSE)
430 * log10 (1.0 / (damp->reuse_limit * ( 1.0 + ((double)i/damp->scale_factor)))) / log10(0.5));
435 bgp_damp_enable (struct bgp *bgp, afi_t afi, safi_t safi, time_t half,
436 unsigned int reuse, unsigned int suppress, time_t max)
438 if (CHECK_FLAG (bgp->af_flags[afi][safi], BGP_CONFIG_DAMPENING))
440 if (damp->half_life == half
441 && damp->reuse_limit == reuse
442 && damp->suppress_value == suppress
443 && damp->max_suppress_time == max)
444 return 0;
445 bgp_damp_disable (bgp, afi, safi);
448 SET_FLAG (bgp->af_flags[afi][safi], BGP_CONFIG_DAMPENING);
449 bgp_damp_parameter_set (half, reuse, suppress, max);
451 /* Register reuse timer. */
452 if (! damp->t_reuse)
453 damp->t_reuse =
454 thread_add_timer (master, bgp_reuse_timer, NULL, DELTA_REUSE);
456 return 0;
459 static void
460 bgp_damp_config_clean (struct bgp_damp_config *damp)
462 /* Free decay array */
463 XFREE (MTYPE_BGP_DAMP_ARRAY, damp->decay_array);
465 /* Free reuse index array */
466 XFREE (MTYPE_BGP_DAMP_ARRAY, damp->reuse_index);
468 /* Free reuse list array. */
469 XFREE (MTYPE_BGP_DAMP_ARRAY, damp->reuse_list);
472 /* Clean all the bgp_damp_info stored in reuse_list. */
473 void
474 bgp_damp_info_clean (void)
476 unsigned int i;
477 struct bgp_damp_info *bdi, *next;
479 damp->reuse_offset = 0;
481 for (i = 0; i < damp->reuse_list_size; i++)
483 if (! damp->reuse_list[i])
484 continue;
486 for (bdi = damp->reuse_list[i]; bdi; bdi = next)
488 next = bdi->next;
489 bgp_damp_info_free (bdi, 1);
491 damp->reuse_list[i] = NULL;
494 for (bdi = damp->no_reuse_list; bdi; bdi = next)
496 next = bdi->next;
497 bgp_damp_info_free (bdi, 1);
499 damp->no_reuse_list = NULL;
503 bgp_damp_disable (struct bgp *bgp, afi_t afi, safi_t safi)
505 /* Cancel reuse thread. */
506 if (damp->t_reuse )
507 thread_cancel (damp->t_reuse);
508 damp->t_reuse = NULL;
510 /* Clean BGP dampening information. */
511 bgp_damp_info_clean ();
513 /* Clear configuration */
514 bgp_damp_config_clean (&bgp_damp_cfg);
516 UNSET_FLAG (bgp->af_flags[afi][safi], BGP_CONFIG_DAMPENING);
517 return 0;
521 bgp_config_write_damp (struct vty *vty)
523 if (&bgp_damp_cfg)
525 if (bgp_damp_cfg.half_life == DEFAULT_HALF_LIFE*60
526 && bgp_damp_cfg.reuse_limit == DEFAULT_REUSE
527 && bgp_damp_cfg.suppress_value == DEFAULT_SUPPRESS
528 && bgp_damp_cfg.max_suppress_time == bgp_damp_cfg.half_life*4)
529 vty_out (vty, " bgp dampening%s", VTY_NEWLINE);
530 else if (bgp_damp_cfg.half_life != DEFAULT_HALF_LIFE*60
531 && bgp_damp_cfg.reuse_limit == DEFAULT_REUSE
532 && bgp_damp_cfg.suppress_value == DEFAULT_SUPPRESS
533 && bgp_damp_cfg.max_suppress_time == bgp_damp_cfg.half_life*4)
534 vty_out (vty, " bgp dampening %ld%s",
535 bgp_damp_cfg.half_life/60,
536 VTY_NEWLINE);
537 else
538 vty_out (vty, " bgp dampening %ld %d %d %ld%s",
539 bgp_damp_cfg.half_life/60,
540 bgp_damp_cfg.reuse_limit,
541 bgp_damp_cfg.suppress_value,
542 bgp_damp_cfg.max_suppress_time/60,
543 VTY_NEWLINE);
544 return 1;
546 return 0;
549 #define BGP_UPTIME_LEN 25
551 char *
552 bgp_get_reuse_time (unsigned int penalty, char *buf, size_t len)
554 time_t reuse_time = 0;
555 struct tm *tm = NULL;
557 if (penalty > damp->reuse_limit)
559 reuse_time = (int) (DELTA_T * ((log((double)damp->reuse_limit/penalty))/(log(damp->decay_array[1]))));
561 if (reuse_time > damp->max_suppress_time)
562 reuse_time = damp->max_suppress_time;
564 tm = gmtime (&reuse_time);
566 else
567 reuse_time = 0;
569 /* Making formatted timer strings. */
570 #define ONE_DAY_SECOND 60*60*24
571 #define ONE_WEEK_SECOND 60*60*24*7
572 if (reuse_time == 0)
573 snprintf (buf, len, "00:00:00");
574 else if (reuse_time < ONE_DAY_SECOND)
575 snprintf (buf, len, "%02d:%02d:%02d",
576 tm->tm_hour, tm->tm_min, tm->tm_sec);
577 else if (reuse_time < ONE_WEEK_SECOND)
578 snprintf (buf, len, "%dd%02dh%02dm",
579 tm->tm_yday, tm->tm_hour, tm->tm_min);
580 else
581 snprintf (buf, len, "%02dw%dd%02dh",
582 tm->tm_yday/7, tm->tm_yday - ((tm->tm_yday/7) * 7), tm->tm_hour);
584 return buf;
587 void
588 bgp_damp_info_vty (struct vty *vty, struct bgp_info *binfo)
590 struct bgp_damp_info *bdi;
591 time_t t_now, t_diff;
592 char timebuf[BGP_UPTIME_LEN];
593 int penalty;
595 if (!binfo->extra)
596 return;
598 /* BGP dampening information. */
599 bdi = binfo->extra->damp_info;
601 /* If dampening is not enabled or there is no dampening information,
602 return immediately. */
603 if (! damp || ! bdi)
604 return;
606 /* Calculate new penalty. */
607 t_now = time (NULL);
608 t_diff = t_now - bdi->t_updated;
609 penalty = bgp_damp_decay (t_diff, bdi->penalty);
611 vty_out (vty, " Dampinfo: penalty %d, flapped %d times in %s",
612 penalty, bdi->flap,
613 peer_uptime (bdi->start_time, timebuf, BGP_UPTIME_LEN));
615 if (CHECK_FLAG (binfo->flags, BGP_INFO_DAMPED)
616 && ! CHECK_FLAG (binfo->flags, BGP_INFO_HISTORY))
617 vty_out (vty, ", reuse in %s",
618 bgp_get_reuse_time (penalty, timebuf, BGP_UPTIME_LEN));
620 vty_out (vty, "%s", VTY_NEWLINE);
623 char *
624 bgp_damp_reuse_time_vty (struct vty *vty, struct bgp_info *binfo)
626 struct bgp_damp_info *bdi;
627 time_t t_now, t_diff;
628 char timebuf[BGP_UPTIME_LEN];
629 int penalty;
631 if (!binfo->extra)
632 return NULL;
634 /* BGP dampening information. */
635 bdi = binfo->extra->damp_info;
637 /* If dampening is not enabled or there is no dampening information,
638 return immediately. */
639 if (! damp || ! bdi)
640 return NULL;
642 /* Calculate new penalty. */
643 t_now = time (NULL);
644 t_diff = t_now - bdi->t_updated;
645 penalty = bgp_damp_decay (t_diff, bdi->penalty);
647 return bgp_get_reuse_time (penalty, timebuf, BGP_UPTIME_LEN);