1 /* BGP-4 Finite State Machine
2 From RFC1771 [A Border Gateway Protocol 4 (BGP-4)]
3 Copyright (C) 1996, 97, 98 Kunihiro Ishiguro
5 This file is part of GNU Zebra.
7 GNU Zebra is free software; you can redistribute it and/or modify it
8 under the terms of the GNU General Public License as published by the
9 Free Software Foundation; either version 2, or (at your option) any
12 GNU Zebra is distributed in the hope that it will be useful, but
13 WITHOUT ANY WARRANTY; without even the implied warranty of
14 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
15 General Public License for more details.
17 You should have received a copy of the GNU General Public License
18 along with GNU Zebra; see the file COPYING. If not, write to the Free
19 Software Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA
27 #include "sockunion.h"
34 #include "bgpd/bgpd.h"
35 #include "bgpd/bgp_attr.h"
36 #include "bgpd/bgp_debug.h"
37 #include "bgpd/bgp_fsm.h"
38 #include "bgpd/bgp_packet.h"
39 #include "bgpd/bgp_network.h"
40 #include "bgpd/bgp_route.h"
41 #include "bgpd/bgp_dump.h"
42 #include "bgpd/bgp_open.h"
44 #include "bgpd/bgp_snmp.h"
45 #endif /* HAVE_SNMP */
47 /* BGP FSM (finite state machine) has three types of functions. Type
48 one is thread functions. Type two is event functions. Type three
49 is FSM functions. Timer functions are set by bgp_timer_set
52 /* BGP event function. */
53 int bgp_event (struct thread
*);
55 /* BGP thread functions. */
56 static int bgp_start_timer (struct thread
*);
57 static int bgp_connect_timer (struct thread
*);
58 static int bgp_holdtime_timer (struct thread
*);
59 static int bgp_keepalive_timer (struct thread
*);
61 /* BGP FSM functions. */
62 static int bgp_start (struct peer
*);
64 /* BGP start timer jitter. */
66 bgp_start_jitter (int time
)
68 return ((rand () % (time
+ 1)) - (time
/ 2));
71 /* Check if suppress start/restart of sessions to peer. */
72 #define BGP_PEER_START_SUPPRESSED(P) \
73 (CHECK_FLAG ((P)->flags, PEER_FLAG_SHUTDOWN) \
74 || CHECK_FLAG ((P)->sflags, PEER_STATUS_PREFIX_OVERFLOW))
76 /* Hook function called after bgp event is occered. And vty's
77 neighbor command invoke this function after making neighbor
80 bgp_timer_set (struct peer
*peer
)
87 /* First entry point of peer's finite state machine. In Idle
88 status start timer is on unless peer is shutdown or peer is
89 inactive. All other timer must be turned off */
90 if (BGP_PEER_START_SUPPRESSED (peer
) || ! peer_active (peer
))
92 BGP_TIMER_OFF (peer
->t_start
);
96 jitter
= bgp_start_jitter (peer
->v_start
);
97 BGP_TIMER_ON (peer
->t_start
, bgp_start_timer
,
98 peer
->v_start
+ jitter
);
100 BGP_TIMER_OFF (peer
->t_connect
);
101 BGP_TIMER_OFF (peer
->t_holdtime
);
102 BGP_TIMER_OFF (peer
->t_keepalive
);
103 BGP_TIMER_OFF (peer
->t_asorig
);
104 BGP_TIMER_OFF (peer
->t_routeadv
);
108 /* After start timer is expired, the peer moves to Connnect
109 status. Make sure start timer is off and connect timer is
111 BGP_TIMER_OFF (peer
->t_start
);
112 BGP_TIMER_ON (peer
->t_connect
, bgp_connect_timer
, peer
->v_connect
);
113 BGP_TIMER_OFF (peer
->t_holdtime
);
114 BGP_TIMER_OFF (peer
->t_keepalive
);
115 BGP_TIMER_OFF (peer
->t_asorig
);
116 BGP_TIMER_OFF (peer
->t_routeadv
);
120 /* Active is waiting connection from remote peer. And if
121 connect timer is expired, change status to Connect. */
122 BGP_TIMER_OFF (peer
->t_start
);
123 /* If peer is passive mode, do not set connect timer. */
124 if (CHECK_FLAG (peer
->flags
, PEER_FLAG_PASSIVE
)
125 || CHECK_FLAG (peer
->sflags
, PEER_STATUS_NSF_WAIT
))
127 BGP_TIMER_OFF (peer
->t_connect
);
131 BGP_TIMER_ON (peer
->t_connect
, bgp_connect_timer
, peer
->v_connect
);
133 BGP_TIMER_OFF (peer
->t_holdtime
);
134 BGP_TIMER_OFF (peer
->t_keepalive
);
135 BGP_TIMER_OFF (peer
->t_asorig
);
136 BGP_TIMER_OFF (peer
->t_routeadv
);
140 /* OpenSent status. */
141 BGP_TIMER_OFF (peer
->t_start
);
142 BGP_TIMER_OFF (peer
->t_connect
);
143 if (peer
->v_holdtime
!= 0)
145 BGP_TIMER_ON (peer
->t_holdtime
, bgp_holdtime_timer
,
150 BGP_TIMER_OFF (peer
->t_holdtime
);
152 BGP_TIMER_OFF (peer
->t_keepalive
);
153 BGP_TIMER_OFF (peer
->t_asorig
);
154 BGP_TIMER_OFF (peer
->t_routeadv
);
158 /* OpenConfirm status. */
159 BGP_TIMER_OFF (peer
->t_start
);
160 BGP_TIMER_OFF (peer
->t_connect
);
162 /* If the negotiated Hold Time value is zero, then the Hold Time
163 timer and KeepAlive timers are not started. */
164 if (peer
->v_holdtime
== 0)
166 BGP_TIMER_OFF (peer
->t_holdtime
);
167 BGP_TIMER_OFF (peer
->t_keepalive
);
171 BGP_TIMER_ON (peer
->t_holdtime
, bgp_holdtime_timer
,
173 BGP_TIMER_ON (peer
->t_keepalive
, bgp_keepalive_timer
,
176 BGP_TIMER_OFF (peer
->t_asorig
);
177 BGP_TIMER_OFF (peer
->t_routeadv
);
181 /* In Established status start and connect timer is turned
183 BGP_TIMER_OFF (peer
->t_start
);
184 BGP_TIMER_OFF (peer
->t_connect
);
186 /* Same as OpenConfirm, if holdtime is zero then both holdtime
187 and keepalive must be turned off. */
188 if (peer
->v_holdtime
== 0)
190 BGP_TIMER_OFF (peer
->t_holdtime
);
191 BGP_TIMER_OFF (peer
->t_keepalive
);
195 BGP_TIMER_ON (peer
->t_holdtime
, bgp_holdtime_timer
,
197 BGP_TIMER_ON (peer
->t_keepalive
, bgp_keepalive_timer
,
200 BGP_TIMER_OFF (peer
->t_asorig
);
203 BGP_TIMER_OFF (peer
->t_gr_restart
);
204 BGP_TIMER_OFF (peer
->t_gr_stale
);
205 BGP_TIMER_OFF (peer
->t_pmax_restart
);
207 BGP_TIMER_OFF (peer
->t_start
);
208 BGP_TIMER_OFF (peer
->t_connect
);
209 BGP_TIMER_OFF (peer
->t_holdtime
);
210 BGP_TIMER_OFF (peer
->t_keepalive
);
211 BGP_TIMER_OFF (peer
->t_asorig
);
212 BGP_TIMER_OFF (peer
->t_routeadv
);
216 /* BGP start timer. This function set BGP_Start event to thread value
217 and process event. */
219 bgp_start_timer (struct thread
*thread
)
223 peer
= THREAD_ARG (thread
);
224 peer
->t_start
= NULL
;
226 if (BGP_DEBUG (fsm
, FSM
))
227 zlog (peer
->log
, LOG_DEBUG
,
228 "%s [FSM] Timer (start timer expire).", peer
->host
);
230 THREAD_VAL (thread
) = BGP_Start
;
231 bgp_event (thread
); /* bgp_event unlocks peer */
236 /* BGP connect retry timer. */
238 bgp_connect_timer (struct thread
*thread
)
242 peer
= THREAD_ARG (thread
);
243 peer
->t_connect
= NULL
;
245 if (BGP_DEBUG (fsm
, FSM
))
246 zlog (peer
->log
, LOG_DEBUG
, "%s [FSM] Timer (connect timer expire)",
249 THREAD_VAL (thread
) = ConnectRetry_timer_expired
;
250 bgp_event (thread
); /* bgp_event unlocks peer */
255 /* BGP holdtime timer. */
257 bgp_holdtime_timer (struct thread
*thread
)
261 peer
= THREAD_ARG (thread
);
262 peer
->t_holdtime
= NULL
;
264 if (BGP_DEBUG (fsm
, FSM
))
265 zlog (peer
->log
, LOG_DEBUG
,
266 "%s [FSM] Timer (holdtime timer expire)",
269 THREAD_VAL (thread
) = Hold_Timer_expired
;
270 bgp_event (thread
); /* bgp_event unlocks peer */
275 /* BGP keepalive fire ! */
277 bgp_keepalive_timer (struct thread
*thread
)
281 peer
= THREAD_ARG (thread
);
282 peer
->t_keepalive
= NULL
;
284 if (BGP_DEBUG (fsm
, FSM
))
285 zlog (peer
->log
, LOG_DEBUG
,
286 "%s [FSM] Timer (keepalive timer expire)",
289 THREAD_VAL (thread
) = KeepAlive_timer_expired
;
290 bgp_event (thread
); /* bgp_event unlocks peer */
296 bgp_routeadv_timer (struct thread
*thread
)
300 peer
= THREAD_ARG (thread
);
301 peer
->t_routeadv
= NULL
;
303 if (BGP_DEBUG (fsm
, FSM
))
304 zlog (peer
->log
, LOG_DEBUG
,
305 "%s [FSM] Timer (routeadv timer expire)",
308 peer
->synctime
= time (NULL
);
310 BGP_WRITE_ON (peer
->t_write
, bgp_write
, peer
->fd
);
312 BGP_TIMER_ON (peer
->t_routeadv
, bgp_routeadv_timer
,
318 /* Reset bgp update timer */
320 bgp_uptime_reset (struct peer
*peer
)
322 peer
->uptime
= time (NULL
);
325 /* BGP Peer Down Cause */
326 const char *peer_down_str
[] =
332 "Cluster ID changed",
333 "Confederation identifier changed",
334 "Confederation peer changed",
335 "RR client config change",
336 "RS client config change",
337 "Update source change",
338 "Address family activated",
341 "BGP Notification received",
342 "BGP Notification send",
343 "Peer closed the session",
345 "Peer-group add member",
346 "Peer-group delete member",
347 "Capability changed",
348 "Passive config change",
349 "Multihop config change",
350 "NSF peer closed the session"
354 bgp_graceful_restart_timer_expire (struct thread
*thread
)
360 peer
= THREAD_ARG (thread
);
361 peer
->t_gr_restart
= NULL
;
363 /* NSF delete stale route */
364 for (afi
= AFI_IP
; afi
< AFI_MAX
; afi
++)
365 for (safi
= SAFI_UNICAST
; safi
< SAFI_UNICAST_MULTICAST
; safi
++)
366 if (peer
->nsf
[afi
][safi
])
367 bgp_clear_stale_route (peer
, afi
, safi
);
369 UNSET_FLAG (peer
->sflags
, PEER_STATUS_NSF_WAIT
);
370 BGP_TIMER_OFF (peer
->t_gr_stale
);
372 if (BGP_DEBUG (events
, EVENTS
))
374 zlog_debug ("%s graceful restart timer expired", peer
->host
);
375 zlog_debug ("%s graceful restart stalepath timer stopped", peer
->host
);
378 bgp_timer_set (peer
);
384 bgp_graceful_stale_timer_expire (struct thread
*thread
)
390 peer
= THREAD_ARG (thread
);
391 peer
->t_gr_stale
= NULL
;
393 if (BGP_DEBUG (events
, EVENTS
))
394 zlog_debug ("%s graceful restart stalepath timer expired", peer
->host
);
396 /* NSF delete stale route */
397 for (afi
= AFI_IP
; afi
< AFI_MAX
; afi
++)
398 for (safi
= SAFI_UNICAST
; safi
< SAFI_UNICAST_MULTICAST
; safi
++)
399 if (peer
->nsf
[afi
][safi
])
400 bgp_clear_stale_route (peer
, afi
, safi
);
405 /* Called after event occured, this function change status and reset
406 read/write and timer thread. */
408 bgp_fsm_change_status (struct peer
*peer
, int status
)
410 bgp_dump_state (peer
, peer
->status
, status
);
412 /* Preserve old status and change into new status. */
413 peer
->ostatus
= peer
->status
;
414 peer
->status
= status
;
416 if (BGP_DEBUG (normal
, NORMAL
))
417 zlog_debug ("%s went from %s to %s",
419 LOOKUP (bgp_status_msg
, peer
->ostatus
),
420 LOOKUP (bgp_status_msg
, peer
->status
));
423 /* Administrative BGP peer stop event. */
425 bgp_stop (struct peer
*peer
)
429 char orf_name
[BUFSIZ
];
431 /* Increment Dropped count. */
432 if (peer
->status
== Established
)
436 /* bgp log-neighbor-changes of neighbor Down */
437 if (bgp_flag_check (peer
->bgp
, BGP_FLAG_LOG_NEIGHBOR_CHANGES
))
438 zlog_info ("%%ADJCHANGE: neighbor %s Down %s", peer
->host
,
439 peer_down_str
[(int) peer
->last_reset
]);
441 /* graceful restart */
442 if (peer
->t_gr_stale
)
444 BGP_TIMER_OFF (peer
->t_gr_stale
);
445 if (BGP_DEBUG (events
, EVENTS
))
446 zlog_debug ("%s graceful restart stalepath timer stopped", peer
->host
);
448 if (CHECK_FLAG (peer
->sflags
, PEER_STATUS_NSF_WAIT
))
450 if (BGP_DEBUG (events
, EVENTS
))
452 zlog_debug ("%s graceful restart timer started for %d sec",
453 peer
->host
, peer
->v_gr_restart
);
454 zlog_debug ("%s graceful restart stalepath timer started for %d sec",
455 peer
->host
, peer
->bgp
->stalepath_time
);
457 BGP_TIMER_ON (peer
->t_gr_restart
, bgp_graceful_restart_timer_expire
,
459 BGP_TIMER_ON (peer
->t_gr_stale
, bgp_graceful_stale_timer_expire
,
460 peer
->bgp
->stalepath_time
);
464 UNSET_FLAG (peer
->sflags
, PEER_STATUS_NSF_MODE
);
466 for (afi
= AFI_IP
; afi
< AFI_MAX
; afi
++)
467 for (safi
= SAFI_UNICAST
; safi
< SAFI_UNICAST_MULTICAST
; safi
++)
468 peer
->nsf
[afi
][safi
] = 0;
471 /* set last reset time */
472 peer
->resettime
= time (NULL
);
474 bgp_uptime_reset (peer
);
477 bgpTrapBackwardTransition (peer
);
478 #endif /* HAVE_SNMP */
481 bgp_uptime_reset (peer
);
483 /* Need of clear of peer. */
484 bgp_clear_route_all (peer
);
486 /* Reset peer synctime */
490 /* Stop read and write threads when exists. */
491 BGP_READ_OFF (peer
->t_read
);
492 BGP_WRITE_OFF (peer
->t_write
);
494 /* Stop all timers. */
495 BGP_TIMER_OFF (peer
->t_start
);
496 BGP_TIMER_OFF (peer
->t_connect
);
497 BGP_TIMER_OFF (peer
->t_holdtime
);
498 BGP_TIMER_OFF (peer
->t_keepalive
);
499 BGP_TIMER_OFF (peer
->t_asorig
);
500 BGP_TIMER_OFF (peer
->t_routeadv
);
502 /* Delete all existing events of the peer */
503 BGP_EVENT_FLUSH (peer
);
506 peer
->packet_size
= 0;
508 /* Clear input and output buffer. */
510 stream_reset (peer
->ibuf
);
512 stream_reset (peer
->work
);
514 stream_fifo_clean (peer
->obuf
);
516 /* Close of file descriptor. */
523 for (afi
= AFI_IP
; afi
< AFI_MAX
; afi
++)
524 for (safi
= SAFI_UNICAST
; safi
< SAFI_MAX
; safi
++)
526 /* Reset all negotiated variables */
527 peer
->afc_nego
[afi
][safi
] = 0;
528 peer
->afc_adv
[afi
][safi
] = 0;
529 peer
->afc_recv
[afi
][safi
] = 0;
531 /* peer address family capability flags*/
532 peer
->af_cap
[afi
][safi
] = 0;
534 /* peer address family status flags*/
535 peer
->af_sflags
[afi
][safi
] = 0;
537 /* Received ORF prefix-filter */
538 peer
->orf_plist
[afi
][safi
] = NULL
;
540 /* ORF received prefix-filter pnt */
541 sprintf (orf_name
, "%s.%d.%d", peer
->host
, afi
, safi
);
542 prefix_bgp_orf_remove_all (orf_name
);
545 /* Reset keepalive and holdtime */
546 if (CHECK_FLAG (peer
->config
, PEER_CONFIG_TIMER
))
548 peer
->v_keepalive
= peer
->keepalive
;
549 peer
->v_holdtime
= peer
->holdtime
;
553 peer
->v_keepalive
= peer
->bgp
->default_keepalive
;
554 peer
->v_holdtime
= peer
->bgp
->default_holdtime
;
557 peer
->update_time
= 0;
559 /* Until we are sure that there is no problem about prefix count
560 this should be commented out.*/
562 /* Reset prefix count */
563 peer
->pcount
[AFI_IP
][SAFI_UNICAST
] = 0;
564 peer
->pcount
[AFI_IP
][SAFI_MULTICAST
] = 0;
565 peer
->pcount
[AFI_IP
][SAFI_MPLS_VPN
] = 0;
566 peer
->pcount
[AFI_IP6
][SAFI_UNICAST
] = 0;
567 peer
->pcount
[AFI_IP6
][SAFI_MULTICAST
] = 0;
573 /* BGP peer is stoped by the error. */
575 bgp_stop_with_error (struct peer
*peer
)
577 /* Double start timer. */
580 /* Overflow check. */
581 if (peer
->v_start
>= (60 * 2))
582 peer
->v_start
= (60 * 2);
589 /* TCP connection open. Next we send open message to remote peer. And
590 add read thread for reading open message. */
592 bgp_connect_success (struct peer
*peer
)
598 zlog_err ("bgp_connect_success peer's fd is negative value %d",
602 BGP_READ_ON (peer
->t_read
, bgp_read
, peer
->fd
);
604 if (! CHECK_FLAG (peer
->sflags
, PEER_STATUS_ACCEPT_PEER
))
605 bgp_getsockname (peer
);
607 if (BGP_DEBUG (normal
, NORMAL
))
609 if (! CHECK_FLAG (peer
->sflags
, PEER_STATUS_ACCEPT_PEER
))
610 zlog_debug ("%s open active, local address %s", peer
->host
,
611 sockunion2str (peer
->su_local
, buf1
, SU_ADDRSTRLEN
));
613 zlog_debug ("%s passive open", peer
->host
);
616 if (! CHECK_FLAG (peer
->sflags
, PEER_STATUS_ACCEPT_PEER
))
617 bgp_open_send (peer
);
622 /* TCP connect fail */
624 bgp_connect_fail (struct peer
*peer
)
630 /* This function is the first starting point of all BGP connection. It
631 try to connect to remote peer with non-blocking IO. */
633 bgp_start (struct peer
*peer
)
637 if (BGP_PEER_START_SUPPRESSED (peer
))
639 if (BGP_DEBUG (fsm
, FSM
))
640 plog_err (peer
->log
, "%s [FSM] Trying to start suppressed peer"
641 " - this is never supposed to happen!", peer
->host
);
645 /* Scrub some information that might be left over from a previous,
648 /* Connection information. */
651 sockunion_free (peer
->su_local
);
652 peer
->su_local
= NULL
;
657 sockunion_free (peer
->su_remote
);
658 peer
->su_remote
= NULL
;
661 /* Clear remote router-id. */
662 peer
->remote_id
.s_addr
= 0;
664 /* Clear peer capability flag. */
667 /* If the peer is passive mode, force to move to Active mode. */
668 if (CHECK_FLAG (peer
->flags
, PEER_FLAG_PASSIVE
))
670 BGP_EVENT_ADD (peer
, TCP_connection_open_failed
);
674 status
= bgp_connect (peer
);
679 if (BGP_DEBUG (fsm
, FSM
))
680 plog_debug (peer
->log
, "%s [FSM] Connect error", peer
->host
);
681 BGP_EVENT_ADD (peer
, TCP_connection_open_failed
);
683 case connect_success
:
684 if (BGP_DEBUG (fsm
, FSM
))
685 plog_debug (peer
->log
, "%s [FSM] Connect immediately success",
687 BGP_EVENT_ADD (peer
, TCP_connection_open
);
689 case connect_in_progress
:
690 /* To check nonblocking connect, we wait until socket is
691 readable or writable. */
692 if (BGP_DEBUG (fsm
, FSM
))
693 plog_debug (peer
->log
, "%s [FSM] Non blocking connect waiting result",
697 zlog_err ("bgp_start peer's fd is negative value %d",
701 BGP_READ_ON (peer
->t_read
, bgp_read
, peer
->fd
);
702 BGP_WRITE_ON (peer
->t_write
, bgp_write
, peer
->fd
);
708 /* Connect retry timer is expired when the peer status is Connect. */
710 bgp_reconnect (struct peer
*peer
)
718 bgp_fsm_open (struct peer
*peer
)
720 /* Send keepalive and make keepalive timer */
721 bgp_keepalive_send (peer
);
723 /* Reset holdtimer value. */
724 BGP_TIMER_OFF (peer
->t_holdtime
);
729 /* Keepalive send to peer. */
731 bgp_fsm_keepalive_expire (struct peer
*peer
)
733 bgp_keepalive_send (peer
);
737 /* Hold timer expire. This is error of BGP connection. So cut the
738 peer and change to Idle status. */
740 bgp_fsm_holdtime_expire (struct peer
*peer
)
742 if (BGP_DEBUG (fsm
, FSM
))
743 zlog (peer
->log
, LOG_DEBUG
, "%s [FSM] Hold timer expire", peer
->host
);
745 /* Send notify to remote peer. */
746 bgp_notify_send (peer
, BGP_NOTIFY_HOLD_ERR
, 0);
748 /* Sweep if it is temporary peer. */
749 if (CHECK_FLAG (peer
->sflags
, PEER_STATUS_ACCEPT_PEER
))
751 zlog_info ("%s [Event] Accepting BGP peer is deleted", peer
->host
);
759 /* Status goes to Established. Send keepalive packet then make first
760 update information. */
762 bgp_establish (struct peer
*peer
)
764 struct bgp_notify
*notify
;
767 int nsf_af_count
= 0;
769 /* Reset capability open status flag. */
770 if (! CHECK_FLAG (peer
->sflags
, PEER_STATUS_CAPABILITY_OPEN
))
771 SET_FLAG (peer
->sflags
, PEER_STATUS_CAPABILITY_OPEN
);
773 /* Clear last notification data. */
774 notify
= &peer
->notify
;
776 XFREE (MTYPE_TMP
, notify
->data
);
777 memset (notify
, 0, sizeof (struct bgp_notify
));
779 /* Clear start timer value to default. */
780 peer
->v_start
= BGP_INIT_START_TIMER
;
782 /* Increment established count. */
784 bgp_fsm_change_status (peer
, Established
);
786 /* bgp log-neighbor-changes of neighbor Up */
787 if (bgp_flag_check (peer
->bgp
, BGP_FLAG_LOG_NEIGHBOR_CHANGES
))
788 zlog_info ("%%ADJCHANGE: neighbor %s Up", peer
->host
);
790 /* graceful restart */
791 UNSET_FLAG (peer
->sflags
, PEER_STATUS_NSF_WAIT
);
792 for (afi
= AFI_IP
; afi
< AFI_MAX
; afi
++)
793 for (safi
= SAFI_UNICAST
; safi
< SAFI_UNICAST_MULTICAST
; safi
++)
795 if (peer
->afc_nego
[afi
][safi
]
796 && CHECK_FLAG (peer
->cap
, PEER_CAP_RESTART_ADV
)
797 && CHECK_FLAG (peer
->af_cap
[afi
][safi
], PEER_CAP_RESTART_AF_RCV
))
799 if (peer
->nsf
[afi
][safi
]
800 && ! CHECK_FLAG (peer
->af_cap
[afi
][safi
], PEER_CAP_RESTART_AF_PRESERVE_RCV
))
801 bgp_clear_stale_route (peer
, afi
, safi
);
803 peer
->nsf
[afi
][safi
] = 1;
808 if (peer
->nsf
[afi
][safi
])
809 bgp_clear_stale_route (peer
, afi
, safi
);
810 peer
->nsf
[afi
][safi
] = 0;
815 SET_FLAG (peer
->sflags
, PEER_STATUS_NSF_MODE
);
818 UNSET_FLAG (peer
->sflags
, PEER_STATUS_NSF_MODE
);
819 if (peer
->t_gr_stale
)
821 BGP_TIMER_OFF (peer
->t_gr_stale
);
822 if (BGP_DEBUG (events
, EVENTS
))
823 zlog_debug ("%s graceful restart stalepath timer stopped", peer
->host
);
827 if (peer
->t_gr_restart
)
829 BGP_TIMER_OFF (peer
->t_gr_restart
);
830 if (BGP_DEBUG (events
, EVENTS
))
831 zlog_debug ("%s graceful restart timer stopped", peer
->host
);
835 bgpTrapEstablished (peer
);
836 #endif /* HAVE_SNMP */
838 /* Reset uptime, send keepalive, send current table. */
839 bgp_uptime_reset (peer
);
841 /* Send route-refresh when ORF is enabled */
842 for (afi
= AFI_IP
; afi
< AFI_MAX
; afi
++)
843 for (safi
= SAFI_UNICAST
; safi
< SAFI_MAX
; safi
++)
844 if (CHECK_FLAG (peer
->af_cap
[afi
][safi
], PEER_CAP_ORF_PREFIX_SM_ADV
))
846 if (CHECK_FLAG (peer
->af_cap
[afi
][safi
], PEER_CAP_ORF_PREFIX_RM_RCV
))
847 bgp_route_refresh_send (peer
, afi
, safi
, ORF_TYPE_PREFIX
,
848 REFRESH_IMMEDIATE
, 0);
849 else if (CHECK_FLAG (peer
->af_cap
[afi
][safi
], PEER_CAP_ORF_PREFIX_RM_OLD_RCV
))
850 bgp_route_refresh_send (peer
, afi
, safi
, ORF_TYPE_PREFIX_OLD
,
851 REFRESH_IMMEDIATE
, 0);
854 if (peer
->v_keepalive
)
855 bgp_keepalive_send (peer
);
857 /* First update is deferred until ORF or ROUTE-REFRESH is received */
858 for (afi
= AFI_IP
; afi
< AFI_MAX
; afi
++)
859 for (safi
= SAFI_UNICAST
; safi
< SAFI_MAX
; safi
++)
860 if (CHECK_FLAG (peer
->af_cap
[afi
][safi
], PEER_CAP_ORF_PREFIX_RM_ADV
))
861 if (CHECK_FLAG (peer
->af_cap
[afi
][safi
], PEER_CAP_ORF_PREFIX_SM_RCV
)
862 || CHECK_FLAG (peer
->af_cap
[afi
][safi
], PEER_CAP_ORF_PREFIX_SM_OLD_RCV
))
863 SET_FLAG (peer
->af_sflags
[afi
][safi
], PEER_STATUS_ORF_WAIT_REFRESH
);
865 bgp_announce_route_all (peer
);
867 BGP_TIMER_ON (peer
->t_routeadv
, bgp_routeadv_timer
, 1);
872 /* Keepalive packet is received. */
874 bgp_fsm_keepalive (struct peer
*peer
)
876 /* peer count update */
877 peer
->keepalive_in
++;
879 BGP_TIMER_OFF (peer
->t_holdtime
);
883 /* Update packet is received. */
885 bgp_fsm_update (struct peer
*peer
)
887 BGP_TIMER_OFF (peer
->t_holdtime
);
891 /* This is empty event. */
893 bgp_ignore (struct peer
*peer
)
895 if (BGP_DEBUG (fsm
, FSM
))
896 zlog (peer
->log
, LOG_DEBUG
, "%s [FSM] bgp_ignore called", peer
->host
);
900 /* Finite State Machine structure */
904 } FSM
[BGP_STATUS_MAX
- 1][BGP_EVENTS_MAX
- 1] =
907 /* Idle state: In Idle state, all events other than BGP_Start is
908 ignored. With BGP_Start event, finite state machine calls
910 {bgp_start
, Connect
}, /* BGP_Start */
911 {bgp_stop
, Idle
}, /* BGP_Stop */
912 {bgp_stop
, Idle
}, /* TCP_connection_open */
913 {bgp_stop
, Idle
}, /* TCP_connection_closed */
914 {bgp_ignore
, Idle
}, /* TCP_connection_open_failed */
915 {bgp_stop
, Idle
}, /* TCP_fatal_error */
916 {bgp_ignore
, Idle
}, /* ConnectRetry_timer_expired */
917 {bgp_ignore
, Idle
}, /* Hold_Timer_expired */
918 {bgp_ignore
, Idle
}, /* KeepAlive_timer_expired */
919 {bgp_ignore
, Idle
}, /* Receive_OPEN_message */
920 {bgp_ignore
, Idle
}, /* Receive_KEEPALIVE_message */
921 {bgp_ignore
, Idle
}, /* Receive_UPDATE_message */
922 {bgp_ignore
, Idle
}, /* Receive_NOTIFICATION_message */
923 {bgp_ignore
, Idle
}, /* Clearing_Completed */
927 {bgp_ignore
, Connect
}, /* BGP_Start */
928 {bgp_stop
, Idle
}, /* BGP_Stop */
929 {bgp_connect_success
, OpenSent
}, /* TCP_connection_open */
930 {bgp_stop
, Idle
}, /* TCP_connection_closed */
931 {bgp_connect_fail
, Active
}, /* TCP_connection_open_failed */
932 {bgp_connect_fail
, Idle
}, /* TCP_fatal_error */
933 {bgp_reconnect
, Connect
}, /* ConnectRetry_timer_expired */
934 {bgp_ignore
, Idle
}, /* Hold_Timer_expired */
935 {bgp_ignore
, Idle
}, /* KeepAlive_timer_expired */
936 {bgp_ignore
, Idle
}, /* Receive_OPEN_message */
937 {bgp_ignore
, Idle
}, /* Receive_KEEPALIVE_message */
938 {bgp_ignore
, Idle
}, /* Receive_UPDATE_message */
939 {bgp_stop
, Idle
}, /* Receive_NOTIFICATION_message */
940 {bgp_ignore
, Idle
}, /* Clearing_Completed */
944 {bgp_ignore
, Active
}, /* BGP_Start */
945 {bgp_stop
, Idle
}, /* BGP_Stop */
946 {bgp_connect_success
, OpenSent
}, /* TCP_connection_open */
947 {bgp_stop
, Idle
}, /* TCP_connection_closed */
948 {bgp_ignore
, Active
}, /* TCP_connection_open_failed */
949 {bgp_ignore
, Idle
}, /* TCP_fatal_error */
950 {bgp_start
, Connect
}, /* ConnectRetry_timer_expired */
951 {bgp_ignore
, Idle
}, /* Hold_Timer_expired */
952 {bgp_ignore
, Idle
}, /* KeepAlive_timer_expired */
953 {bgp_ignore
, Idle
}, /* Receive_OPEN_message */
954 {bgp_ignore
, Idle
}, /* Receive_KEEPALIVE_message */
955 {bgp_ignore
, Idle
}, /* Receive_UPDATE_message */
956 {bgp_stop_with_error
, Idle
}, /* Receive_NOTIFICATION_message */
957 {bgp_ignore
, Idle
}, /* Clearing_Completed */
961 {bgp_ignore
, OpenSent
}, /* BGP_Start */
962 {bgp_stop
, Idle
}, /* BGP_Stop */
963 {bgp_stop
, Idle
}, /* TCP_connection_open */
964 {bgp_stop
, Active
}, /* TCP_connection_closed */
965 {bgp_ignore
, Idle
}, /* TCP_connection_open_failed */
966 {bgp_stop
, Idle
}, /* TCP_fatal_error */
967 {bgp_ignore
, Idle
}, /* ConnectRetry_timer_expired */
968 {bgp_fsm_holdtime_expire
, Idle
}, /* Hold_Timer_expired */
969 {bgp_ignore
, Idle
}, /* KeepAlive_timer_expired */
970 {bgp_fsm_open
, OpenConfirm
}, /* Receive_OPEN_message */
971 {bgp_ignore
, Idle
}, /* Receive_KEEPALIVE_message */
972 {bgp_ignore
, Idle
}, /* Receive_UPDATE_message */
973 {bgp_stop_with_error
, Idle
}, /* Receive_NOTIFICATION_message */
974 {bgp_ignore
, Idle
}, /* Clearing_Completed */
978 {bgp_ignore
, OpenConfirm
}, /* BGP_Start */
979 {bgp_stop
, Idle
}, /* BGP_Stop */
980 {bgp_stop
, Idle
}, /* TCP_connection_open */
981 {bgp_stop
, Idle
}, /* TCP_connection_closed */
982 {bgp_stop
, Idle
}, /* TCP_connection_open_failed */
983 {bgp_stop
, Idle
}, /* TCP_fatal_error */
984 {bgp_ignore
, Idle
}, /* ConnectRetry_timer_expired */
985 {bgp_fsm_holdtime_expire
, Idle
}, /* Hold_Timer_expired */
986 {bgp_ignore
, OpenConfirm
}, /* KeepAlive_timer_expired */
987 {bgp_ignore
, Idle
}, /* Receive_OPEN_message */
988 {bgp_establish
, Established
}, /* Receive_KEEPALIVE_message */
989 {bgp_ignore
, Idle
}, /* Receive_UPDATE_message */
990 {bgp_stop_with_error
, Idle
}, /* Receive_NOTIFICATION_message */
991 {bgp_ignore
, Idle
}, /* Clearing_Completed */
995 {bgp_ignore
, Established
}, /* BGP_Start */
996 {bgp_stop
, Clearing
}, /* BGP_Stop */
997 {bgp_stop
, Clearing
}, /* TCP_connection_open */
998 {bgp_stop
, Clearing
}, /* TCP_connection_closed */
999 {bgp_ignore
, Clearing
}, /* TCP_connection_open_failed */
1000 {bgp_stop
, Clearing
}, /* TCP_fatal_error */
1001 {bgp_ignore
, Clearing
}, /* ConnectRetry_timer_expired */
1002 {bgp_fsm_holdtime_expire
, Clearing
}, /* Hold_Timer_expired */
1003 {bgp_fsm_keepalive_expire
, Established
}, /* KeepAlive_timer_expired */
1004 {bgp_stop
, Clearing
}, /* Receive_OPEN_message */
1005 {bgp_fsm_keepalive
, Established
}, /* Receive_KEEPALIVE_message */
1006 {bgp_fsm_update
, Established
}, /* Receive_UPDATE_message */
1007 {bgp_stop_with_error
, Clearing
}, /* Receive_NOTIFICATION_message */
1008 {bgp_ignore
, Idle
}, /* Clearing_Completed */
1012 {bgp_ignore
, Clearing
}, /* BGP_Start */
1013 {bgp_ignore
, Clearing
}, /* BGP_Stop */
1014 {bgp_ignore
, Clearing
}, /* TCP_connection_open */
1015 {bgp_ignore
, Clearing
}, /* TCP_connection_closed */
1016 {bgp_ignore
, Clearing
}, /* TCP_connection_open_failed */
1017 {bgp_ignore
, Clearing
}, /* TCP_fatal_error */
1018 {bgp_ignore
, Clearing
}, /* ConnectRetry_timer_expired */
1019 {bgp_ignore
, Clearing
}, /* Hold_Timer_expired */
1020 {bgp_ignore
, Clearing
}, /* KeepAlive_timer_expired */
1021 {bgp_ignore
, Clearing
}, /* Receive_OPEN_message */
1022 {bgp_ignore
, Clearing
}, /* Receive_KEEPALIVE_message */
1023 {bgp_ignore
, Clearing
}, /* Receive_UPDATE_message */
1024 {bgp_ignore
, Clearing
}, /* Receive_NOTIFICATION_message */
1025 {bgp_ignore
, Idle
}, /* Clearing_Completed */
1029 {bgp_ignore
, Deleted
}, /* BGP_Start */
1030 {bgp_ignore
, Deleted
}, /* BGP_Stop */
1031 {bgp_ignore
, Deleted
}, /* TCP_connection_open */
1032 {bgp_ignore
, Deleted
}, /* TCP_connection_closed */
1033 {bgp_ignore
, Deleted
}, /* TCP_connection_open_failed */
1034 {bgp_ignore
, Deleted
}, /* TCP_fatal_error */
1035 {bgp_ignore
, Deleted
}, /* ConnectRetry_timer_expired */
1036 {bgp_ignore
, Deleted
}, /* Hold_Timer_expired */
1037 {bgp_ignore
, Deleted
}, /* KeepAlive_timer_expired */
1038 {bgp_ignore
, Deleted
}, /* Receive_OPEN_message */
1039 {bgp_ignore
, Deleted
}, /* Receive_KEEPALIVE_message */
1040 {bgp_ignore
, Deleted
}, /* Receive_UPDATE_message */
1041 {bgp_ignore
, Deleted
}, /* Receive_NOTIFICATION_message */
1042 {bgp_ignore
, Deleted
}, /* Clearing_Completed */
1046 static const char *bgp_event_str
[] =
1051 "TCP_connection_open",
1052 "TCP_connection_closed",
1053 "TCP_connection_open_failed",
1055 "ConnectRetry_timer_expired",
1056 "Hold_Timer_expired",
1057 "KeepAlive_timer_expired",
1058 "Receive_OPEN_message",
1059 "Receive_KEEPALIVE_message",
1060 "Receive_UPDATE_message",
1061 "Receive_NOTIFICATION_message",
1062 "Clearing_Completed",
1065 /* Execute event process. */
1067 bgp_event (struct thread
*thread
)
1074 peer
= THREAD_ARG (thread
);
1075 event
= THREAD_VAL (thread
);
1077 /* Logging this event. */
1078 next
= FSM
[peer
->status
-1][event
- 1].next_state
;
1080 if (BGP_DEBUG (fsm
, FSM
) && peer
->status
!= next
)
1081 plog_debug (peer
->log
, "%s [FSM] %s (%s->%s)", peer
->host
,
1082 bgp_event_str
[event
],
1083 LOOKUP (bgp_status_msg
, peer
->status
),
1084 LOOKUP (bgp_status_msg
, next
));
1086 /* Call function. */
1087 if (FSM
[peer
->status
-1][event
- 1].func
)
1088 ret
= (*(FSM
[peer
->status
- 1][event
- 1].func
))(peer
);
1090 /* When function do not want proceed next job return -1. */
1093 /* If status is changed. */
1094 if (next
!= peer
->status
)
1095 bgp_fsm_change_status (peer
, next
);
1097 /* Make sure timer is set. */
1098 bgp_timer_set (peer
);