1: /*
2: * OSPF version 2 Neighbor State Machine
3: * From RFC2328 [OSPF Version 2]
4: * Copyright (C) 1999, 2000 Toshiaki Takada
5: *
6: * This file is part of GNU Zebra.
7: *
8: * GNU Zebra is free software; you can redistribute it and/or modify it
9: * under the terms of the GNU General Public License as published by the
10: * Free Software Foundation; either version 2, or (at your option) any
11: * later version.
12: *
13: * GNU Zebra is distributed in the hope that it will be useful, but
14: * WITHOUT ANY WARRANTY; without even the implied warranty of
15: * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
16: * General Public License for more details.
17: *
18: * You should have received a copy of the GNU General Public License
19: * along with GNU Zebra; see the file COPYING. If not, write to the Free
20: * Software Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA
21: * 02111-1307, USA.
22: */
23:
24: #include <zebra.h>
25:
26: #include "thread.h"
27: #include "memory.h"
28: #include "hash.h"
29: #include "linklist.h"
30: #include "prefix.h"
31: #include "if.h"
32: #include "table.h"
33: #include "stream.h"
34: #include "table.h"
35: #include "log.h"
36:
37: #include "ospfd/ospfd.h"
38: #include "ospfd/ospf_interface.h"
39: #include "ospfd/ospf_ism.h"
40: #include "ospfd/ospf_asbr.h"
41: #include "ospfd/ospf_lsa.h"
42: #include "ospfd/ospf_lsdb.h"
43: #include "ospfd/ospf_neighbor.h"
44: #include "ospfd/ospf_nsm.h"
45: #include "ospfd/ospf_network.h"
46: #include "ospfd/ospf_packet.h"
47: #include "ospfd/ospf_dump.h"
48: #include "ospfd/ospf_flood.h"
49: #include "ospfd/ospf_abr.h"
50: #include "ospfd/ospf_snmp.h"
51:
52: static void nsm_clear_adj (struct ospf_neighbor *);
53:
54: /* OSPF NSM Timer functions. */
55: static int
56: ospf_inactivity_timer (struct thread *thread)
57: {
58: struct ospf_neighbor *nbr;
59:
60: nbr = THREAD_ARG (thread);
61: nbr->t_inactivity = NULL;
62:
63: if (IS_DEBUG_OSPF (nsm, NSM_TIMERS))
64: zlog (NULL, LOG_DEBUG, "NSM[%s:%s]: Timer (Inactivity timer expire)",
65: IF_NAME (nbr->oi), inet_ntoa (nbr->router_id));
66:
67: OSPF_NSM_EVENT_SCHEDULE (nbr, NSM_InactivityTimer);
68:
69: return 0;
70: }
71:
72: static int
73: ospf_db_desc_timer (struct thread *thread)
74: {
75: struct ospf_interface *oi;
76: struct ospf_neighbor *nbr;
77:
78: nbr = THREAD_ARG (thread);
79: nbr->t_db_desc = NULL;
80:
81: oi = nbr->oi;
82:
83: if (IS_DEBUG_OSPF (nsm, NSM_TIMERS))
84: zlog (NULL, LOG_DEBUG, "NSM[%s:%s]: Timer (DD Retransmit timer expire)",
85: IF_NAME (nbr->oi), inet_ntoa (nbr->src));
86:
87: /* resent last send DD packet. */
88: assert (nbr->last_send);
89: ospf_db_desc_resend (nbr);
90:
91: /* DD Retransmit timer set. */
92: OSPF_NSM_TIMER_ON (nbr->t_db_desc, ospf_db_desc_timer, nbr->v_db_desc);
93:
94: return 0;
95: }
96:
97: /* Hook function called after ospf NSM event is occured.
98: *
99: * Set/clear any timers whose condition is implicit to the neighbour
100: * state. There may be other timers which are set/unset according to other
101: * state.
102: *
103: * We rely on this function to properly clear timers in lower states,
104: * particularly before deleting a neighbour.
105: */
106: static void
107: nsm_timer_set (struct ospf_neighbor *nbr)
108: {
109: switch (nbr->state)
110: {
111: case NSM_Deleted:
112: case NSM_Down:
113: OSPF_NSM_TIMER_OFF (nbr->t_inactivity);
114: OSPF_NSM_TIMER_OFF (nbr->t_hello_reply);
115: case NSM_Attempt:
116: case NSM_Init:
117: case NSM_TwoWay:
118: OSPF_NSM_TIMER_OFF (nbr->t_db_desc);
119: OSPF_NSM_TIMER_OFF (nbr->t_ls_upd);
120: OSPF_NSM_TIMER_OFF (nbr->t_ls_req);
121: break;
122: case NSM_ExStart:
123: OSPF_NSM_TIMER_ON (nbr->t_db_desc, ospf_db_desc_timer, nbr->v_db_desc);
124: OSPF_NSM_TIMER_OFF (nbr->t_ls_upd);
125: OSPF_NSM_TIMER_OFF (nbr->t_ls_req);
126: break;
127: case NSM_Exchange:
128: OSPF_NSM_TIMER_ON (nbr->t_ls_upd, ospf_ls_upd_timer, nbr->v_ls_upd);
129: if (!IS_SET_DD_MS (nbr->dd_flags))
130: OSPF_NSM_TIMER_OFF (nbr->t_db_desc);
131: break;
132: case NSM_Loading:
133: case NSM_Full:
134: default:
135: OSPF_NSM_TIMER_OFF (nbr->t_db_desc);
136: break;
137: }
138: }
139:
140: /* 10.4 of RFC2328, indicate whether an adjacency is appropriate with
141: * the given neighbour
142: */
143: static int
144: nsm_should_adj (struct ospf_neighbor *nbr)
145: {
146: struct ospf_interface *oi = nbr->oi;
147:
148: /* These network types must always form adjacencies. */
149: if (oi->type == OSPF_IFTYPE_POINTOPOINT
150: || oi->type == OSPF_IFTYPE_POINTOMULTIPOINT
151: || oi->type == OSPF_IFTYPE_VIRTUALLINK
152: /* Router itself is the DRouter or the BDRouter. */
153: || IPV4_ADDR_SAME (&oi->address->u.prefix4, &DR (oi))
154: || IPV4_ADDR_SAME (&oi->address->u.prefix4, &BDR (oi))
155: /* Neighboring Router is the DRouter or the BDRouter. */
156: || IPV4_ADDR_SAME (&nbr->address.u.prefix4, &DR (oi))
157: || IPV4_ADDR_SAME (&nbr->address.u.prefix4, &BDR (oi)))
158: return 1;
159:
160: return 0;
161: }
162:
163: /* OSPF NSM functions. */
164: static int
165: nsm_packet_received (struct ospf_neighbor *nbr)
166: {
167: /* Start or Restart Inactivity Timer. */
168: OSPF_NSM_TIMER_OFF (nbr->t_inactivity);
169:
170: OSPF_NSM_TIMER_ON (nbr->t_inactivity, ospf_inactivity_timer,
171: nbr->v_inactivity);
172:
173: if (nbr->oi->type == OSPF_IFTYPE_NBMA && nbr->nbr_nbma)
174: OSPF_POLL_TIMER_OFF (nbr->nbr_nbma->t_poll);
175:
176: return 0;
177: }
178:
179: static int
180: nsm_start (struct ospf_neighbor *nbr)
181: {
182: if (nbr->nbr_nbma)
183: OSPF_POLL_TIMER_OFF (nbr->nbr_nbma->t_poll);
184:
185: OSPF_NSM_TIMER_OFF (nbr->t_inactivity);
186:
187: OSPF_NSM_TIMER_ON (nbr->t_inactivity, ospf_inactivity_timer,
188: nbr->v_inactivity);
189:
190: return 0;
191: }
192:
193: static int
194: nsm_twoway_received (struct ospf_neighbor *nbr)
195: {
196: return (nsm_should_adj (nbr) ? NSM_ExStart : NSM_TwoWay);
197: }
198:
199: int
200: ospf_db_summary_count (struct ospf_neighbor *nbr)
201: {
202: return ospf_lsdb_count_all (&nbr->db_sum);
203: }
204:
205: int
206: ospf_db_summary_isempty (struct ospf_neighbor *nbr)
207: {
208: return ospf_lsdb_isempty (&nbr->db_sum);
209: }
210:
211: static int
212: ospf_db_summary_add (struct ospf_neighbor *nbr, struct ospf_lsa *lsa)
213: {
214: #ifdef HAVE_OPAQUE_LSA
215: switch (lsa->data->type)
216: {
217: case OSPF_OPAQUE_LINK_LSA:
218: /* Exclude type-9 LSAs that does not have the same "oi" with "nbr". */
219: if (nbr->oi && ospf_if_exists (lsa->oi) != nbr->oi)
220: return 0;
221: break;
222: case OSPF_OPAQUE_AREA_LSA:
223: /*
224: * It is assured by the caller function "nsm_negotiation_done()"
225: * that every given LSA belongs to the same area with "nbr".
226: */
227: break;
228: case OSPF_OPAQUE_AS_LSA:
229: default:
230: break;
231: }
232: #endif /* HAVE_OPAQUE_LSA */
233:
234: /* Stay away from any Local Translated Type-7 LSAs */
235: if (CHECK_FLAG (lsa->flags, OSPF_LSA_LOCAL_XLT))
236: return 0;
237:
238: if (IS_LSA_MAXAGE (lsa))
239: ospf_ls_retransmit_add (nbr, lsa);
240: else
241: ospf_lsdb_add (&nbr->db_sum, lsa);
242:
243: return 0;
244: }
245:
246: void
247: ospf_db_summary_clear (struct ospf_neighbor *nbr)
248: {
249: struct ospf_lsdb *lsdb;
250: int i;
251:
252: lsdb = &nbr->db_sum;
253: for (i = OSPF_MIN_LSA; i < OSPF_MAX_LSA; i++)
254: {
255: struct route_table *table = lsdb->type[i].db;
256: struct route_node *rn;
257:
258: for (rn = route_top (table); rn; rn = route_next (rn))
259: if (rn->info)
260: ospf_lsdb_delete (&nbr->db_sum, rn->info);
261: }
262: }
263:
264:
265:
266: /* The area link state database consists of the router-LSAs,
267: network-LSAs and summary-LSAs contained in the area structure,
268: along with the AS-external-LSAs contained in the global structure.
269: AS-external-LSAs are omitted from a virtual neighbor's Database
270: summary list. AS-external-LSAs are omitted from the Database
271: summary list if the area has been configured as a stub. */
272: static int
273: nsm_negotiation_done (struct ospf_neighbor *nbr)
274: {
275: struct ospf_area *area = nbr->oi->area;
276: struct ospf_lsa *lsa;
277: struct route_node *rn;
278:
279: LSDB_LOOP (ROUTER_LSDB (area), rn, lsa)
280: ospf_db_summary_add (nbr, lsa);
281: LSDB_LOOP (NETWORK_LSDB (area), rn, lsa)
282: ospf_db_summary_add (nbr, lsa);
283: LSDB_LOOP (SUMMARY_LSDB (area), rn, lsa)
284: ospf_db_summary_add (nbr, lsa);
285: LSDB_LOOP (ASBR_SUMMARY_LSDB (area), rn, lsa)
286: ospf_db_summary_add (nbr, lsa);
287:
288: #ifdef HAVE_OPAQUE_LSA
289: /* Process only if the neighbor is opaque capable. */
290: if (CHECK_FLAG (nbr->options, OSPF_OPTION_O))
291: {
292: LSDB_LOOP (OPAQUE_LINK_LSDB (area), rn, lsa)
293: ospf_db_summary_add (nbr, lsa);
294: LSDB_LOOP (OPAQUE_AREA_LSDB (area), rn, lsa)
295: ospf_db_summary_add (nbr, lsa);
296: }
297: #endif /* HAVE_OPAQUE_LSA */
298:
299: if (CHECK_FLAG (nbr->options, OSPF_OPTION_NP))
300: {
301: LSDB_LOOP (NSSA_LSDB (area), rn, lsa)
302: ospf_db_summary_add (nbr, lsa);
303: }
304:
305: if (nbr->oi->type != OSPF_IFTYPE_VIRTUALLINK
306: && area->external_routing == OSPF_AREA_DEFAULT)
307: LSDB_LOOP (EXTERNAL_LSDB (nbr->oi->ospf), rn, lsa)
308: ospf_db_summary_add (nbr, lsa);
309:
310: #ifdef HAVE_OPAQUE_LSA
311: if (CHECK_FLAG (nbr->options, OSPF_OPTION_O)
312: && (nbr->oi->type != OSPF_IFTYPE_VIRTUALLINK
313: && area->external_routing == OSPF_AREA_DEFAULT))
314: LSDB_LOOP (OPAQUE_AS_LSDB (nbr->oi->ospf), rn, lsa)
315: ospf_db_summary_add (nbr, lsa);
316: #endif /* HAVE_OPAQUE_LSA */
317:
318: return 0;
319: }
320:
321: static int
322: nsm_exchange_done (struct ospf_neighbor *nbr)
323: {
324: if (ospf_ls_request_isempty (nbr))
325: return NSM_Full;
326:
327: /* Send Link State Request. */
328: ospf_ls_req_send (nbr);
329:
330: return NSM_Loading;
331: }
332:
333: static int
334: nsm_adj_ok (struct ospf_neighbor *nbr)
335: {
336: int next_state = nbr->state;
337: int adj = nsm_should_adj (nbr);
338:
339: if (nbr->state == NSM_TwoWay && adj == 1)
340: next_state = NSM_ExStart;
341: else if (nbr->state >= NSM_ExStart && adj == 0)
342: next_state = NSM_TwoWay;
343:
344: return next_state;
345: }
346:
347: /* Clear adjacency related state for a neighbour, intended where nbr
348: * transitions from > ExStart (i.e. a Full or forming adjacency)
349: * to <= ExStart.
350: */
351: static void
352: nsm_clear_adj (struct ospf_neighbor *nbr)
353: {
354: /* Clear Database Summary list. */
355: if (!ospf_db_summary_isempty (nbr))
356: ospf_db_summary_clear (nbr);
357:
358: /* Clear Link State Request list. */
359: if (!ospf_ls_request_isempty (nbr))
360: ospf_ls_request_delete_all (nbr);
361:
362: /* Clear Link State Retransmission list. */
363: if (!ospf_ls_retransmit_isempty (nbr))
364: ospf_ls_retransmit_clear (nbr);
365:
366: #ifdef HAVE_OPAQUE_LSA
367: if (CHECK_FLAG (nbr->options, OSPF_OPTION_O))
368: UNSET_FLAG (nbr->options, OSPF_OPTION_O);
369: #endif /* HAVE_OPAQUE_LSA */
370: }
371:
372: static int
373: nsm_kill_nbr (struct ospf_neighbor *nbr)
374: {
375: /* killing nbr_self is invalid */
376: if (nbr == nbr->oi->nbr_self)
377: {
378: assert (nbr != nbr->oi->nbr_self);
379: return 0;
380: }
381:
382: if (nbr->oi->type == OSPF_IFTYPE_NBMA && nbr->nbr_nbma != NULL)
383: {
384: struct ospf_nbr_nbma *nbr_nbma = nbr->nbr_nbma;
385:
386: nbr_nbma->nbr = NULL;
387: nbr_nbma->state_change = nbr->state_change;
388:
389: nbr->nbr_nbma = NULL;
390:
391: OSPF_POLL_TIMER_ON (nbr_nbma->t_poll, ospf_poll_timer,
392: nbr_nbma->v_poll);
393:
394: if (IS_DEBUG_OSPF (nsm, NSM_EVENTS))
395: zlog_debug ("NSM[%s:%s]: Down (PollIntervalTimer scheduled)",
396: IF_NAME (nbr->oi), inet_ntoa (nbr->address.u.prefix4));
397: }
398:
399: return 0;
400: }
401:
402: /* Neighbor State Machine */
403: struct {
404: int (*func) (struct ospf_neighbor *);
405: int next_state;
406: } NSM [OSPF_NSM_STATE_MAX][OSPF_NSM_EVENT_MAX] =
407: {
408: {
409: /* DependUpon: dummy state. */
410: { NULL, NSM_DependUpon }, /* NoEvent */
411: { NULL, NSM_DependUpon }, /* PacketReceived */
412: { NULL, NSM_DependUpon }, /* Start */
413: { NULL, NSM_DependUpon }, /* 2-WayReceived */
414: { NULL, NSM_DependUpon }, /* NegotiationDone */
415: { NULL, NSM_DependUpon }, /* ExchangeDone */
416: { NULL, NSM_DependUpon }, /* BadLSReq */
417: { NULL, NSM_DependUpon }, /* LoadingDone */
418: { NULL, NSM_DependUpon }, /* AdjOK? */
419: { NULL, NSM_DependUpon }, /* SeqNumberMismatch */
420: { NULL, NSM_DependUpon }, /* 1-WayReceived */
421: { NULL, NSM_DependUpon }, /* KillNbr */
422: { NULL, NSM_DependUpon }, /* InactivityTimer */
423: { NULL, NSM_DependUpon }, /* LLDown */
424: },
425: {
426: /* Deleted: dummy state. */
427: { NULL, NSM_Deleted }, /* NoEvent */
428: { NULL, NSM_Deleted }, /* PacketReceived */
429: { NULL, NSM_Deleted }, /* Start */
430: { NULL, NSM_Deleted }, /* 2-WayReceived */
431: { NULL, NSM_Deleted }, /* NegotiationDone */
432: { NULL, NSM_Deleted }, /* ExchangeDone */
433: { NULL, NSM_Deleted }, /* BadLSReq */
434: { NULL, NSM_Deleted }, /* LoadingDone */
435: { NULL, NSM_Deleted }, /* AdjOK? */
436: { NULL, NSM_Deleted }, /* SeqNumberMismatch */
437: { NULL, NSM_Deleted }, /* 1-WayReceived */
438: { NULL, NSM_Deleted }, /* KillNbr */
439: { NULL, NSM_Deleted }, /* InactivityTimer */
440: { NULL, NSM_Deleted }, /* LLDown */
441: },
442: {
443: /* Down: */
444: { NULL, NSM_DependUpon }, /* NoEvent */
445: { nsm_packet_received, NSM_Init }, /* PacketReceived */
446: { nsm_start, NSM_Attempt }, /* Start */
447: { NULL, NSM_Down }, /* 2-WayReceived */
448: { NULL, NSM_Down }, /* NegotiationDone */
449: { NULL, NSM_Down }, /* ExchangeDone */
450: { NULL, NSM_Down }, /* BadLSReq */
451: { NULL, NSM_Down }, /* LoadingDone */
452: { NULL, NSM_Down }, /* AdjOK? */
453: { NULL, NSM_Down }, /* SeqNumberMismatch */
454: { NULL, NSM_Down }, /* 1-WayReceived */
455: { nsm_kill_nbr, NSM_Deleted }, /* KillNbr */
456: { nsm_kill_nbr, NSM_Deleted }, /* InactivityTimer */
457: { nsm_kill_nbr, NSM_Deleted }, /* LLDown */
458: },
459: {
460: /* Attempt: */
461: { NULL, NSM_DependUpon }, /* NoEvent */
462: { nsm_packet_received, NSM_Init }, /* PacketReceived */
463: { NULL, NSM_Attempt }, /* Start */
464: { NULL, NSM_Attempt }, /* 2-WayReceived */
465: { NULL, NSM_Attempt }, /* NegotiationDone */
466: { NULL, NSM_Attempt }, /* ExchangeDone */
467: { NULL, NSM_Attempt }, /* BadLSReq */
468: { NULL, NSM_Attempt }, /* LoadingDone */
469: { NULL, NSM_Attempt }, /* AdjOK? */
470: { NULL, NSM_Attempt }, /* SeqNumberMismatch */
471: { NULL, NSM_Attempt }, /* 1-WayReceived */
472: { nsm_kill_nbr, NSM_Deleted }, /* KillNbr */
473: { nsm_kill_nbr, NSM_Deleted }, /* InactivityTimer */
474: { nsm_kill_nbr, NSM_Deleted }, /* LLDown */
475: },
476: {
477: /* Init: */
478: { NULL, NSM_DependUpon }, /* NoEvent */
479: { nsm_packet_received, NSM_Init }, /* PacketReceived */
480: { NULL, NSM_Init }, /* Start */
481: { nsm_twoway_received, NSM_DependUpon }, /* 2-WayReceived */
482: { NULL, NSM_Init }, /* NegotiationDone */
483: { NULL, NSM_Init }, /* ExchangeDone */
484: { NULL, NSM_Init }, /* BadLSReq */
485: { NULL, NSM_Init }, /* LoadingDone */
486: { NULL, NSM_Init }, /* AdjOK? */
487: { NULL, NSM_Init }, /* SeqNumberMismatch */
488: { NULL, NSM_Init }, /* 1-WayReceived */
489: { nsm_kill_nbr, NSM_Deleted }, /* KillNbr */
490: { nsm_kill_nbr, NSM_Deleted }, /* InactivityTimer */
491: { nsm_kill_nbr, NSM_Deleted }, /* LLDown */
492: },
493: {
494: /* 2-Way: */
495: { NULL, NSM_DependUpon }, /* NoEvent */
496: { nsm_packet_received, NSM_TwoWay }, /* HelloReceived */
497: { NULL, NSM_TwoWay }, /* Start */
498: { NULL, NSM_TwoWay }, /* 2-WayReceived */
499: { NULL, NSM_TwoWay }, /* NegotiationDone */
500: { NULL, NSM_TwoWay }, /* ExchangeDone */
501: { NULL, NSM_TwoWay }, /* BadLSReq */
502: { NULL, NSM_TwoWay }, /* LoadingDone */
503: { nsm_adj_ok, NSM_DependUpon }, /* AdjOK? */
504: { NULL, NSM_TwoWay }, /* SeqNumberMismatch */
505: { NULL, NSM_Init }, /* 1-WayReceived */
506: { nsm_kill_nbr, NSM_Deleted }, /* KillNbr */
507: { nsm_kill_nbr, NSM_Deleted }, /* InactivityTimer */
508: { nsm_kill_nbr, NSM_Deleted }, /* LLDown */
509: },
510: {
511: /* ExStart: */
512: { NULL, NSM_DependUpon }, /* NoEvent */
513: { nsm_packet_received, NSM_ExStart }, /* PacaketReceived */
514: { NULL, NSM_ExStart }, /* Start */
515: { NULL, NSM_ExStart }, /* 2-WayReceived */
516: { nsm_negotiation_done, NSM_Exchange }, /* NegotiationDone */
517: { NULL, NSM_ExStart }, /* ExchangeDone */
518: { NULL, NSM_ExStart }, /* BadLSReq */
519: { NULL, NSM_ExStart }, /* LoadingDone */
520: { nsm_adj_ok, NSM_DependUpon }, /* AdjOK? */
521: { NULL, NSM_ExStart }, /* SeqNumberMismatch */
522: { NULL, NSM_Init }, /* 1-WayReceived */
523: { nsm_kill_nbr, NSM_Deleted }, /* KillNbr */
524: { nsm_kill_nbr, NSM_Deleted }, /* InactivityTimer */
525: { nsm_kill_nbr, NSM_Deleted }, /* LLDown */
526: },
527: {
528: /* Exchange: */
529: { NULL, NSM_DependUpon }, /* NoEvent */
530: { nsm_packet_received, NSM_Exchange }, /* PacketReceived */
531: { NULL, NSM_Exchange }, /* Start */
532: { NULL, NSM_Exchange }, /* 2-WayReceived */
533: { NULL, NSM_Exchange }, /* NegotiationDone */
534: { nsm_exchange_done, NSM_DependUpon }, /* ExchangeDone */
535: { NULL, NSM_ExStart }, /* BadLSReq */
536: { NULL, NSM_Exchange }, /* LoadingDone */
537: { nsm_adj_ok, NSM_DependUpon }, /* AdjOK? */
538: { NULL, NSM_ExStart }, /* SeqNumberMismatch */
539: { NULL, NSM_Init }, /* 1-WayReceived */
540: { nsm_kill_nbr, NSM_Deleted }, /* KillNbr */
541: { nsm_kill_nbr, NSM_Deleted }, /* InactivityTimer */
542: { nsm_kill_nbr, NSM_Deleted }, /* LLDown */
543: },
544: {
545: /* Loading: */
546: { NULL, NSM_DependUpon }, /* NoEvent */
547: { nsm_packet_received, NSM_Loading }, /* PacketReceived */
548: { NULL, NSM_Loading }, /* Start */
549: { NULL, NSM_Loading }, /* 2-WayReceived */
550: { NULL, NSM_Loading }, /* NegotiationDone */
551: { NULL, NSM_Loading }, /* ExchangeDone */
552: { NULL, NSM_ExStart }, /* BadLSReq */
553: { NULL, NSM_Full }, /* LoadingDone */
554: { nsm_adj_ok, NSM_DependUpon }, /* AdjOK? */
555: { NULL, NSM_ExStart }, /* SeqNumberMismatch */
556: { NULL, NSM_Init }, /* 1-WayReceived */
557: { nsm_kill_nbr, NSM_Deleted }, /* KillNbr */
558: { nsm_kill_nbr, NSM_Deleted }, /* InactivityTimer */
559: { nsm_kill_nbr, NSM_Deleted }, /* LLDown */
560: },
561: { /* Full: */
562: { NULL, NSM_DependUpon }, /* NoEvent */
563: { nsm_packet_received, NSM_Full }, /* PacketReceived */
564: { NULL, NSM_Full }, /* Start */
565: { NULL, NSM_Full }, /* 2-WayReceived */
566: { NULL, NSM_Full }, /* NegotiationDone */
567: { NULL, NSM_Full }, /* ExchangeDone */
568: { NULL, NSM_ExStart }, /* BadLSReq */
569: { NULL, NSM_Full }, /* LoadingDone */
570: { nsm_adj_ok, NSM_DependUpon }, /* AdjOK? */
571: { NULL, NSM_ExStart }, /* SeqNumberMismatch */
572: { NULL, NSM_Init }, /* 1-WayReceived */
573: { nsm_kill_nbr, NSM_Deleted }, /* KillNbr */
574: { nsm_kill_nbr, NSM_Deleted }, /* InactivityTimer */
575: { nsm_kill_nbr, NSM_Deleted }, /* LLDown */
576: },
577: };
578:
579: static const char *ospf_nsm_event_str[] =
580: {
581: "NoEvent",
582: "PacketReceived",
583: "Start",
584: "2-WayReceived",
585: "NegotiationDone",
586: "ExchangeDone",
587: "BadLSReq",
588: "LoadingDone",
589: "AdjOK?",
590: "SeqNumberMismatch",
591: "1-WayReceived",
592: "KillNbr",
593: "InactivityTimer",
594: "LLDown",
595: };
596:
597: static void
598: nsm_notice_state_change (struct ospf_neighbor *nbr, int next_state, int event)
599: {
600: /* Logging change of status. */
601: if (IS_DEBUG_OSPF (nsm, NSM_STATUS))
602: zlog_debug ("NSM[%s:%s]: State change %s -> %s (%s)",
603: IF_NAME (nbr->oi), inet_ntoa (nbr->router_id),
604: LOOKUP (ospf_nsm_state_msg, nbr->state),
605: LOOKUP (ospf_nsm_state_msg, next_state),
606: ospf_nsm_event_str [event]);
607:
608: /* Optionally notify about adjacency changes */
609: if (CHECK_FLAG(nbr->oi->ospf->config, OSPF_LOG_ADJACENCY_CHANGES) &&
610: (CHECK_FLAG(nbr->oi->ospf->config, OSPF_LOG_ADJACENCY_DETAIL) ||
611: (next_state == NSM_Full) || (next_state < nbr->state)))
612: zlog_notice("AdjChg: Nbr %s on %s: %s -> %s (%s)",
613: inet_ntoa (nbr->router_id), IF_NAME (nbr->oi),
614: LOOKUP (ospf_nsm_state_msg, nbr->state),
615: LOOKUP (ospf_nsm_state_msg, next_state),
616: ospf_nsm_event_str [event]);
617:
618: /* Advance in NSM */
619: if (next_state > nbr->state)
620: nbr->ts_last_progress = recent_relative_time ();
621: else /* regression in NSM */
622: {
623: nbr->ts_last_regress = recent_relative_time ();
624: nbr->last_regress_str = ospf_nsm_event_str [event];
625: }
626:
627: #ifdef HAVE_SNMP
628: /* Terminal state or regression */
629: if ((next_state == NSM_Full)
630: || (next_state == NSM_TwoWay)
631: || (next_state < nbr->state))
632: {
633: /* ospfVirtNbrStateChange */
634: if (nbr->oi->type == OSPF_IFTYPE_VIRTUALLINK)
635: ospfTrapVirtNbrStateChange(nbr);
636: /* ospfNbrStateChange trap */
637: else
638: /* To/From FULL, only managed by DR */
639: if (((next_state != NSM_Full) && (nbr->state != NSM_Full))
640: || (nbr->oi->state == ISM_DR))
641: ospfTrapNbrStateChange(nbr);
642: }
643: #endif
644: }
645:
646: void
647: nsm_change_state (struct ospf_neighbor *nbr, int state)
648: {
649: struct ospf_interface *oi = nbr->oi;
650: struct ospf_area *vl_area = NULL;
651: u_char old_state;
652: int x;
653: int force = 1;
654:
655: /* Preserve old status. */
656: old_state = nbr->state;
657:
658: /* Change to new status. */
659: nbr->state = state;
660:
661: /* Statistics. */
662: nbr->state_change++;
663:
664: if (oi->type == OSPF_IFTYPE_VIRTUALLINK)
665: vl_area = ospf_area_lookup_by_area_id (oi->ospf, oi->vl_data->vl_area_id);
666:
667: /* One of the neighboring routers changes to/from the FULL state. */
668: if ((old_state != NSM_Full && state == NSM_Full) ||
669: (old_state == NSM_Full && state != NSM_Full))
670: {
671: if (state == NSM_Full)
672: {
673: oi->full_nbrs++;
674: oi->area->full_nbrs++;
675:
676: ospf_check_abr_status (oi->ospf);
677:
678: if (oi->type == OSPF_IFTYPE_VIRTUALLINK && vl_area)
679: if (++vl_area->full_vls == 1)
680: ospf_schedule_abr_task (oi->ospf);
681:
682: /* kevinm: refresh any redistributions */
683: for (x = ZEBRA_ROUTE_SYSTEM; x < ZEBRA_ROUTE_MAX; x++)
684: {
685: if (x == ZEBRA_ROUTE_OSPF || x == ZEBRA_ROUTE_OSPF6)
686: continue;
687: ospf_external_lsa_refresh_type (oi->ospf, x, force);
688: }
689: /* XXX: Clearly some thing is wrong with refresh of external LSAs
690: * this added to hack around defaults not refreshing after a timer
691: * jump.
692: */
693: ospf_external_lsa_refresh_default (oi->ospf);
694: }
695: else
696: {
697: oi->full_nbrs--;
698: oi->area->full_nbrs--;
699:
700: ospf_check_abr_status (oi->ospf);
701:
702: if (oi->type == OSPF_IFTYPE_VIRTUALLINK && vl_area)
703: if (vl_area->full_vls > 0)
704: if (--vl_area->full_vls == 0)
705: ospf_schedule_abr_task (oi->ospf);
706: }
707:
708: zlog_info ("nsm_change_state(%s, %s -> %s): "
709: "scheduling new router-LSA origination",
710: inet_ntoa (nbr->router_id),
711: LOOKUP(ospf_nsm_state_msg, old_state),
712: LOOKUP(ospf_nsm_state_msg, state));
713:
714: ospf_router_lsa_update_area (oi->area);
715:
716: if (oi->type == OSPF_IFTYPE_VIRTUALLINK)
717: {
718: struct ospf_area *vl_area =
719: ospf_area_lookup_by_area_id (oi->ospf, oi->vl_data->vl_area_id);
720:
721: if (vl_area)
722: ospf_router_lsa_update_area (vl_area);
723: }
724:
725: /* Originate network-LSA. */
726: if (oi->state == ISM_DR)
727: {
728: if (oi->network_lsa_self && oi->full_nbrs == 0)
729: {
730: ospf_lsa_flush_area (oi->network_lsa_self, oi->area);
731: ospf_lsa_unlock (&oi->network_lsa_self);
732: oi->network_lsa_self = NULL;
733: }
734: else
735: ospf_network_lsa_update (oi);
736: }
737: }
738:
739: #ifdef HAVE_OPAQUE_LSA
740: ospf_opaque_nsm_change (nbr, old_state);
741: #endif /* HAVE_OPAQUE_LSA */
742:
743: /* State changes from > ExStart to <= ExStart should clear any Exchange
744: * or Full/LSA Update related lists and state.
745: * Potential causal events: BadLSReq, SeqNumberMismatch, AdjOK?
746: */
747: if ((old_state > NSM_ExStart) && (state <= NSM_ExStart))
748: nsm_clear_adj (nbr);
749:
750: /* Start DD exchange protocol */
751: if (state == NSM_ExStart)
752: {
753: if (nbr->dd_seqnum == 0)
754: nbr->dd_seqnum = quagga_time (NULL);
755: else
756: nbr->dd_seqnum++;
757:
758: nbr->dd_flags = OSPF_DD_FLAG_I|OSPF_DD_FLAG_M|OSPF_DD_FLAG_MS;
759: ospf_db_desc_send (nbr);
760: }
761:
762: /* clear cryptographic sequence number */
763: if (state == NSM_Down)
764: nbr->crypt_seqnum = 0;
765:
766: /* Generete NeighborChange ISM event. */
767: switch (oi->state) {
768: case ISM_DROther:
769: case ISM_Backup:
770: case ISM_DR:
771: if ((old_state < NSM_TwoWay && state >= NSM_TwoWay) ||
772: (old_state >= NSM_TwoWay && state < NSM_TwoWay))
773: OSPF_ISM_EVENT_EXECUTE (oi, ISM_NeighborChange);
774: break;
775: default:
776: /* ISM_PointToPoint -> ISM_Down, ISM_Loopback -> ISM_Down, etc. */
777: break;
778: }
779:
780: /* Preserve old status? */
781: }
782:
783: /* Execute NSM event process. */
784: int
785: ospf_nsm_event (struct thread *thread)
786: {
787: int event;
788: int next_state;
789: struct ospf_neighbor *nbr;
790: struct in_addr router_id;
791:
792: nbr = THREAD_ARG (thread);
793: event = THREAD_VAL (thread);
794: router_id = nbr->router_id;
795:
796: if (IS_DEBUG_OSPF (nsm, NSM_EVENTS))
797: zlog_debug ("NSM[%s:%s]: %s (%s)", IF_NAME (nbr->oi),
798: inet_ntoa (nbr->router_id),
799: LOOKUP (ospf_nsm_state_msg, nbr->state),
800: ospf_nsm_event_str [event]);
801:
802: next_state = NSM [nbr->state][event].next_state;
803:
804: /* Call function. */
805: if (NSM [nbr->state][event].func != NULL)
806: {
807: int func_state = (*(NSM [nbr->state][event].func))(nbr);
808:
809: if (NSM [nbr->state][event].next_state == NSM_DependUpon)
810: next_state = func_state;
811: else if (func_state)
812: {
813: /* There's a mismatch between the FSM tables and what an FSM
814: * action/state-change function returned. State changes which
815: * do not have conditional/DependUpon next-states should not
816: * try set next_state.
817: */
818: zlog_warn ("NSM[%s:%s]: %s (%s): "
819: "Warning: action tried to change next_state to %s",
820: IF_NAME (nbr->oi), inet_ntoa (nbr->router_id),
821: LOOKUP (ospf_nsm_state_msg, nbr->state),
822: ospf_nsm_event_str [event],
823: LOOKUP (ospf_nsm_state_msg, func_state));
824: }
825: }
826:
827: assert (next_state != NSM_DependUpon);
828:
829: /* If state is changed. */
830: if (next_state != nbr->state)
831: {
832: nsm_notice_state_change (nbr, next_state, event);
833: nsm_change_state (nbr, next_state);
834: }
835:
836: /* Make sure timer is set. */
837: nsm_timer_set (nbr);
838:
839: /* When event is NSM_KillNbr, InactivityTimer or LLDown, the neighbor
840: * is deleted.
841: *
842: * Rather than encode knowledge here of which events lead to NBR
843: * delete, we take our cue from the NSM table, via the dummy
844: * 'Deleted' neighbour state.
845: */
846: if (nbr->state == NSM_Deleted)
847: ospf_nbr_delete (nbr);
848:
849: return 0;
850: }
851:
852: /* Check loading state. */
853: void
854: ospf_check_nbr_loading (struct ospf_neighbor *nbr)
855: {
856: if (nbr->state == NSM_Loading)
857: {
858: if (ospf_ls_request_isempty (nbr))
859: OSPF_NSM_EVENT_SCHEDULE (nbr, NSM_LoadingDone);
860: else if (nbr->ls_req_last == NULL)
861: ospf_ls_req_event (nbr);
862: }
863: }
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to ospf_nsm.c CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / quagga / ospfd