2 * OSPF Sending and Receiving OSPF Packets.
3 * Copyright (C) 1999, 2000 Toshiaki Takada
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 along
18 * with this program; see the file COPYING; if not, write to the Free Software
19 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
31 #include "sockunion.h"
38 #include "ospf_errors.h"
40 #include "ospfd/ospfd.h"
41 #include "ospfd/ospf_network.h"
42 #include "ospfd/ospf_interface.h"
43 #include "ospfd/ospf_ism.h"
44 #include "ospfd/ospf_asbr.h"
45 #include "ospfd/ospf_lsa.h"
46 #include "ospfd/ospf_lsdb.h"
47 #include "ospfd/ospf_neighbor.h"
48 #include "ospfd/ospf_nsm.h"
49 #include "ospfd/ospf_packet.h"
50 #include "ospfd/ospf_spf.h"
51 #include "ospfd/ospf_flood.h"
52 #include "ospfd/ospf_dump.h"
55 * OSPF Fragmentation / fragmented writes
57 * ospfd can support writing fragmented packets, for cases where
58 * kernel will not fragment IP_HDRINCL and/or multicast destined
59 * packets (ie TTBOMK all kernels, BSD, SunOS, Linux). However,
60 * SunOS, probably BSD too, clobber the user supplied IP ID and IP
61 * flags fields, hence user-space fragmentation will not work.
62 * Only Linux is known to leave IP header unmolested.
63 * Further, fragmentation really should be done the kernel, which already
64 * supports it, and which avoids nasty IP ID state problems.
66 * Fragmentation of OSPF packets can be required on networks with router
67 * with many many interfaces active in one area, or on networks with links
71 #define WANT_OSPF_WRITE_FRAGMENT
74 /* Packet Type String. */
75 const struct message ospf_packet_type_str
[] = {
76 {OSPF_MSG_HELLO
, "Hello"},
77 {OSPF_MSG_DB_DESC
, "Database Description"},
78 {OSPF_MSG_LS_REQ
, "Link State Request"},
79 {OSPF_MSG_LS_UPD
, "Link State Update"},
80 {OSPF_MSG_LS_ACK
, "Link State Acknowledgment"},
83 /* Minimum (besides OSPF_HEADER_SIZE) lengths for OSPF packets of
84 particular types, offset is the "type" field of a packet. */
85 static const uint16_t ospf_packet_minlen
[] = {
88 OSPF_DB_DESC_MIN_SIZE
,
94 /* Minimum (besides OSPF_LSA_HEADER_SIZE) lengths for LSAs of particular
95 types, offset is the "LSA type" field. */
96 static const uint16_t ospf_lsa_minlen
[] = {
98 OSPF_ROUTER_LSA_MIN_SIZE
,
99 OSPF_NETWORK_LSA_MIN_SIZE
,
100 OSPF_SUMMARY_LSA_MIN_SIZE
,
101 OSPF_SUMMARY_LSA_MIN_SIZE
,
102 OSPF_AS_EXTERNAL_LSA_MIN_SIZE
,
104 OSPF_AS_EXTERNAL_LSA_MIN_SIZE
,
111 /* for ospf_check_auth() */
112 static int ospf_check_sum(struct ospf_header
*);
114 /* OSPF authentication checking function */
115 static int ospf_auth_type(struct ospf_interface
*oi
)
119 if (OSPF_IF_PARAM(oi
, auth_type
) == OSPF_AUTH_NOTSET
)
120 auth_type
= oi
->area
->auth_type
;
122 auth_type
= OSPF_IF_PARAM(oi
, auth_type
);
124 /* Handle case where MD5 key list is not configured aka Cisco */
125 if (auth_type
== OSPF_AUTH_CRYPTOGRAPHIC
126 && list_isempty(OSPF_IF_PARAM(oi
, auth_crypt
)))
127 return OSPF_AUTH_NULL
;
132 struct ospf_packet
*ospf_packet_new(size_t size
)
134 struct ospf_packet
*new;
136 new = XCALLOC(MTYPE_OSPF_PACKET
, sizeof(struct ospf_packet
));
137 new->s
= stream_new(size
);
142 void ospf_packet_free(struct ospf_packet
*op
)
147 XFREE(MTYPE_OSPF_PACKET
, op
);
150 struct ospf_fifo
*ospf_fifo_new()
152 struct ospf_fifo
*new;
154 new = XCALLOC(MTYPE_OSPF_FIFO
, sizeof(struct ospf_fifo
));
158 /* Add new packet to fifo. */
159 void ospf_fifo_push(struct ospf_fifo
*fifo
, struct ospf_packet
*op
)
162 fifo
->tail
->next
= op
;
171 /* Add new packet to head of fifo. */
172 static void ospf_fifo_push_head(struct ospf_fifo
*fifo
, struct ospf_packet
*op
)
174 op
->next
= fifo
->head
;
176 if (fifo
->tail
== NULL
)
184 /* Delete first packet from fifo. */
185 struct ospf_packet
*ospf_fifo_pop(struct ospf_fifo
*fifo
)
187 struct ospf_packet
*op
;
192 fifo
->head
= op
->next
;
194 if (fifo
->head
== NULL
)
203 /* Return first fifo entry. */
204 struct ospf_packet
*ospf_fifo_head(struct ospf_fifo
*fifo
)
209 /* Flush ospf packet fifo. */
210 void ospf_fifo_flush(struct ospf_fifo
*fifo
)
212 struct ospf_packet
*op
;
213 struct ospf_packet
*next
;
215 for (op
= fifo
->head
; op
; op
= next
) {
217 ospf_packet_free(op
);
219 fifo
->head
= fifo
->tail
= NULL
;
223 /* Free ospf packet fifo. */
224 void ospf_fifo_free(struct ospf_fifo
*fifo
)
226 ospf_fifo_flush(fifo
);
228 XFREE(MTYPE_OSPF_FIFO
, fifo
);
231 void ospf_packet_add(struct ospf_interface
*oi
, struct ospf_packet
*op
)
235 OSPF_ERR_PKT_PROCESS
,
236 "ospf_packet_add(interface %s in state %d [%s], packet type %s, "
237 "destination %s) called with NULL obuf, ignoring "
238 "(please report this bug)!\n",
239 IF_NAME(oi
), oi
->state
,
240 lookup_msg(ospf_ism_state_msg
, oi
->state
, NULL
),
241 lookup_msg(ospf_packet_type_str
,
242 stream_getc_from(op
->s
, 1), NULL
),
247 /* Add packet to end of queue. */
248 ospf_fifo_push(oi
->obuf
, op
);
250 /* Debug of packet fifo*/
251 /* ospf_fifo_debug (oi->obuf); */
254 static void ospf_packet_add_top(struct ospf_interface
*oi
,
255 struct ospf_packet
*op
)
259 OSPF_ERR_PKT_PROCESS
,
260 "ospf_packet_add(interface %s in state %d [%s], packet type %s, "
261 "destination %s) called with NULL obuf, ignoring "
262 "(please report this bug)!\n",
263 IF_NAME(oi
), oi
->state
,
264 lookup_msg(ospf_ism_state_msg
, oi
->state
, NULL
),
265 lookup_msg(ospf_packet_type_str
,
266 stream_getc_from(op
->s
, 1), NULL
),
271 /* Add packet to head of queue. */
272 ospf_fifo_push_head(oi
->obuf
, op
);
274 /* Debug of packet fifo*/
275 /* ospf_fifo_debug (oi->obuf); */
278 void ospf_packet_delete(struct ospf_interface
*oi
)
280 struct ospf_packet
*op
;
282 op
= ospf_fifo_pop(oi
->obuf
);
285 ospf_packet_free(op
);
288 struct ospf_packet
*ospf_packet_dup(struct ospf_packet
*op
)
290 struct ospf_packet
*new;
292 if (stream_get_endp(op
->s
) != op
->length
)
295 "ospf_packet_dup stream %lu ospf_packet %u size mismatch",
296 (unsigned long)STREAM_SIZE(op
->s
), op
->length
);
298 /* Reserve space for MD5 authentication that may be added later. */
299 new = ospf_packet_new(stream_get_endp(op
->s
) + OSPF_AUTH_MD5_SIZE
);
300 stream_copy(new->s
, op
->s
);
303 new->length
= op
->length
;
309 static unsigned int ospf_packet_authspace(struct ospf_interface
*oi
)
313 if (ospf_auth_type(oi
) == OSPF_AUTH_CRYPTOGRAPHIC
)
314 auth
= OSPF_AUTH_MD5_SIZE
;
319 static unsigned int ospf_packet_max(struct ospf_interface
*oi
)
323 max
= oi
->ifp
->mtu
- ospf_packet_authspace(oi
);
325 max
-= (OSPF_HEADER_SIZE
+ sizeof(struct ip
));
331 static int ospf_check_md5_digest(struct ospf_interface
*oi
,
332 struct ospf_header
*ospfh
)
335 unsigned char digest
[OSPF_AUTH_MD5_SIZE
];
336 struct crypt_key
*ck
;
337 struct ospf_neighbor
*nbr
;
338 uint16_t length
= ntohs(ospfh
->length
);
340 /* Get secret key. */
341 ck
= ospf_crypt_key_lookup(OSPF_IF_PARAM(oi
, auth_crypt
),
342 ospfh
->u
.crypt
.key_id
);
344 zlog_warn("interface %s: ospf_check_md5 no key %d", IF_NAME(oi
),
345 ospfh
->u
.crypt
.key_id
);
349 /* check crypto seqnum. */
350 nbr
= ospf_nbr_lookup_by_routerid(oi
->nbrs
, &ospfh
->router_id
);
353 && ntohl(nbr
->crypt_seqnum
) > ntohl(ospfh
->u
.crypt
.crypt_seqnum
)) {
355 "interface %s: ospf_check_md5 bad sequence %d (expect %d)",
356 IF_NAME(oi
), ntohl(ospfh
->u
.crypt
.crypt_seqnum
),
357 ntohl(nbr
->crypt_seqnum
));
361 /* Generate a digest for the ospf packet - their digest + our digest. */
362 memset(&ctx
, 0, sizeof(ctx
));
364 MD5Update(&ctx
, ospfh
, length
);
365 MD5Update(&ctx
, ck
->auth_key
, OSPF_AUTH_MD5_SIZE
);
366 MD5Final(digest
, &ctx
);
368 /* compare the two */
369 if (memcmp((caddr_t
)ospfh
+ length
, digest
, OSPF_AUTH_MD5_SIZE
)) {
370 zlog_warn("interface %s: ospf_check_md5 checksum mismatch",
375 /* save neighbor's crypt_seqnum */
377 nbr
->crypt_seqnum
= ospfh
->u
.crypt
.crypt_seqnum
;
381 /* This function is called from ospf_write(), it will detect the
382 authentication scheme and if it is MD5, it will change the sequence
383 and update the MD5 digest. */
384 static int ospf_make_md5_digest(struct ospf_interface
*oi
,
385 struct ospf_packet
*op
)
387 struct ospf_header
*ospfh
;
388 unsigned char digest
[OSPF_AUTH_MD5_SIZE
] = {0};
392 struct crypt_key
*ck
;
393 const uint8_t *auth_key
;
395 ibuf
= STREAM_DATA(op
->s
);
396 ospfh
= (struct ospf_header
*)ibuf
;
398 if (ntohs(ospfh
->auth_type
) != OSPF_AUTH_CRYPTOGRAPHIC
)
401 /* We do this here so when we dup a packet, we don't have to
402 waste CPU rewriting other headers.
404 Note that quagga_time /deliberately/ is not used here */
405 t
= (time(NULL
) & 0xFFFFFFFF);
406 if (t
> oi
->crypt_seqnum
)
407 oi
->crypt_seqnum
= t
;
411 ospfh
->u
.crypt
.crypt_seqnum
= htonl(oi
->crypt_seqnum
);
413 /* Get MD5 Authentication key from auth_key list. */
414 if (list_isempty(OSPF_IF_PARAM(oi
, auth_crypt
)))
415 auth_key
= (const uint8_t *)digest
;
417 ck
= listgetdata(listtail(OSPF_IF_PARAM(oi
, auth_crypt
)));
418 auth_key
= ck
->auth_key
;
421 /* Generate a digest for the entire packet + our secret key. */
422 memset(&ctx
, 0, sizeof(ctx
));
424 MD5Update(&ctx
, ibuf
, ntohs(ospfh
->length
));
425 MD5Update(&ctx
, auth_key
, OSPF_AUTH_MD5_SIZE
);
426 MD5Final(digest
, &ctx
);
428 /* Append md5 digest to the end of the stream. */
429 stream_put(op
->s
, digest
, OSPF_AUTH_MD5_SIZE
);
431 /* We do *NOT* increment the OSPF header length. */
432 op
->length
= ntohs(ospfh
->length
) + OSPF_AUTH_MD5_SIZE
;
434 if (stream_get_endp(op
->s
) != op
->length
)
437 "ospf_make_md5_digest: length mismatch stream %lu ospf_packet %u",
438 (unsigned long)stream_get_endp(op
->s
), op
->length
);
440 return OSPF_AUTH_MD5_SIZE
;
444 static int ospf_ls_req_timer(struct thread
*thread
)
446 struct ospf_neighbor
*nbr
;
448 nbr
= THREAD_ARG(thread
);
449 nbr
->t_ls_req
= NULL
;
451 /* Send Link State Request. */
452 if (ospf_ls_request_count(nbr
))
453 ospf_ls_req_send(nbr
);
455 /* Set Link State Request retransmission timer. */
456 OSPF_NSM_TIMER_ON(nbr
->t_ls_req
, ospf_ls_req_timer
, nbr
->v_ls_req
);
461 void ospf_ls_req_event(struct ospf_neighbor
*nbr
)
464 thread_cancel(nbr
->t_ls_req
);
465 nbr
->t_ls_req
= NULL
;
467 nbr
->t_ls_req
= NULL
;
468 thread_add_event(master
, ospf_ls_req_timer
, nbr
, 0, &nbr
->t_ls_req
);
471 /* Cyclic timer function. Fist registered in ospf_nbr_new () in
473 int ospf_ls_upd_timer(struct thread
*thread
)
475 struct ospf_neighbor
*nbr
;
477 nbr
= THREAD_ARG(thread
);
478 nbr
->t_ls_upd
= NULL
;
480 /* Send Link State Update. */
481 if (ospf_ls_retransmit_count(nbr
) > 0) {
483 struct ospf_lsdb
*lsdb
;
485 int retransmit_interval
;
487 retransmit_interval
=
488 OSPF_IF_PARAM(nbr
->oi
, retransmit_interval
);
490 lsdb
= &nbr
->ls_rxmt
;
493 for (i
= OSPF_MIN_LSA
; i
< OSPF_MAX_LSA
; i
++) {
494 struct route_table
*table
= lsdb
->type
[i
].db
;
495 struct route_node
*rn
;
497 for (rn
= route_top(table
); rn
; rn
= route_next(rn
)) {
498 struct ospf_lsa
*lsa
;
500 if ((lsa
= rn
->info
) != NULL
) {
501 /* Don't retransmit an LSA if we
503 the last RxmtInterval seconds - this
505 neighbour a chance to acknowledge the
507 have ben just received before the
509 fired. This is a small tweak to what
511 but it will cut out out a lot of
514 if (monotime_since(&lsa
->tv_recv
, NULL
)
515 >= retransmit_interval
* 1000000LL)
516 listnode_add(update
, rn
->info
);
521 if (listcount(update
) > 0)
522 ospf_ls_upd_send(nbr
, update
, OSPF_SEND_PACKET_DIRECT
,
524 list_delete_and_null(&update
);
527 /* Set LS Update retransmission timer. */
528 OSPF_NSM_TIMER_ON(nbr
->t_ls_upd
, ospf_ls_upd_timer
, nbr
->v_ls_upd
);
533 int ospf_ls_ack_timer(struct thread
*thread
)
535 struct ospf_interface
*oi
;
537 oi
= THREAD_ARG(thread
);
540 /* Send Link State Acknowledgment. */
541 if (listcount(oi
->ls_ack
) > 0)
542 ospf_ls_ack_send_delayed(oi
);
544 /* Set LS Ack timer. */
545 OSPF_ISM_TIMER_ON(oi
->t_ls_ack
, ospf_ls_ack_timer
, oi
->v_ls_ack
);
550 #ifdef WANT_OSPF_WRITE_FRAGMENT
551 static void ospf_write_frags(int fd
, struct ospf_packet
*op
, struct ip
*iph
,
552 struct msghdr
*msg
, unsigned int maxdatasize
,
553 unsigned int mtu
, int flags
, uint8_t type
)
555 #define OSPF_WRITE_FRAG_SHIFT 3
560 assert(op
->length
== stream_get_endp(op
->s
));
561 assert(msg
->msg_iovlen
== 2);
565 * SunOS, BSD and BSD derived kernels likely will clear ip_id, as
566 * well as the IP_MF flag, making this all quite pointless.
568 * However, for a system on which IP_MF is left alone, and ip_id left
569 * alone or else which sets same ip_id for each fragment this might
572 * XXX-TODO: It would be much nicer to have the kernel's use their
573 * existing fragmentation support to do this for us. Bugs/RFEs need to
574 * be raised against the various kernels.
578 iph
->ip_off
|= IP_MF
;
580 /* ip frag offset is expressed in units of 8byte words */
581 offset
= maxdatasize
>> OSPF_WRITE_FRAG_SHIFT
;
583 iovp
= &msg
->msg_iov
[1];
585 while ((stream_get_endp(op
->s
) - stream_get_getp(op
->s
))
587 /* data length of this frag is to next offset value */
588 iovp
->iov_len
= offset
<< OSPF_WRITE_FRAG_SHIFT
;
589 iph
->ip_len
= iovp
->iov_len
+ sizeof(struct ip
);
590 assert(iph
->ip_len
<= mtu
);
592 sockopt_iphdrincl_swab_htosys(iph
);
594 ret
= sendmsg(fd
, msg
, flags
);
596 sockopt_iphdrincl_swab_systoh(iph
);
600 "*** ospf_write_frags: sendmsg failed to %s,"
601 " id %d, off %d, len %d, mtu %u failed with %s",
602 inet_ntoa(iph
->ip_dst
), iph
->ip_id
, iph
->ip_off
,
603 iph
->ip_len
, mtu
, safe_strerror(errno
));
605 if (IS_DEBUG_OSPF_PACKET(type
- 1, SEND
)) {
607 "ospf_write_frags: sent id %d, off %d, len %d to %s\n",
608 iph
->ip_id
, iph
->ip_off
, iph
->ip_len
,
609 inet_ntoa(iph
->ip_dst
));
610 if (IS_DEBUG_OSPF_PACKET(type
- 1, DETAIL
)) {
612 "-----------------IP Header Dump----------------------");
613 ospf_ip_header_dump(iph
);
615 "-----------------------------------------------------");
619 iph
->ip_off
+= offset
;
620 stream_forward_getp(op
->s
, iovp
->iov_len
);
621 iovp
->iov_base
= stream_pnt(op
->s
);
624 /* setup for final fragment */
625 iovp
->iov_len
= stream_get_endp(op
->s
) - stream_get_getp(op
->s
);
626 iph
->ip_len
= iovp
->iov_len
+ sizeof(struct ip
);
627 iph
->ip_off
&= (~IP_MF
);
629 #endif /* WANT_OSPF_WRITE_FRAGMENT */
631 static int ospf_write(struct thread
*thread
)
633 struct ospf
*ospf
= THREAD_ARG(thread
);
634 struct ospf_interface
*oi
;
635 struct ospf_interface
*last_serviced_oi
= NULL
;
636 struct ospf_packet
*op
;
637 struct sockaddr_in sa_dst
;
644 struct listnode
*node
;
645 #ifdef WANT_OSPF_WRITE_FRAGMENT
646 static uint16_t ipid
= 0;
647 uint16_t maxdatasize
;
648 #endif /* WANT_OSPF_WRITE_FRAGMENT */
649 #define OSPF_WRITE_IPHL_SHIFT 2
653 unsigned char cmsgbuf
[64] = {};
654 struct cmsghdr
*cm
= (struct cmsghdr
*)cmsgbuf
;
655 struct in_pktinfo
*pi
;
658 ospf
->t_write
= NULL
;
660 node
= listhead(ospf
->oi_write_q
);
662 oi
= listgetdata(node
);
665 #ifdef WANT_OSPF_WRITE_FRAGMENT
666 /* seed ipid static with low order bits of time */
668 ipid
= (time(NULL
) & 0xffff);
669 #endif /* WANT_OSPF_WRITE_FRAGMENT */
671 while ((pkt_count
< ospf
->write_oi_count
) && oi
672 && (last_serviced_oi
!= oi
)) {
673 /* If there is only packet in the queue, the oi is removed from
674 write-q, so fix up the last interface that was serviced */
675 if (last_serviced_oi
== NULL
) {
676 last_serviced_oi
= oi
;
679 #ifdef WANT_OSPF_WRITE_FRAGMENT
680 /* convenience - max OSPF data per packet */
681 maxdatasize
= oi
->ifp
->mtu
- sizeof(struct ip
);
682 #endif /* WANT_OSPF_WRITE_FRAGMENT */
683 /* Get one packet from queue. */
684 op
= ospf_fifo_head(oi
->obuf
);
686 assert(op
->length
>= OSPF_HEADER_SIZE
);
688 if (op
->dst
.s_addr
== htonl(OSPF_ALLSPFROUTERS
)
689 || op
->dst
.s_addr
== htonl(OSPF_ALLDROUTERS
))
690 ospf_if_ipmulticast(ospf
, oi
->address
,
693 /* Rewrite the md5 signature & update the seq */
694 ospf_make_md5_digest(oi
, op
);
696 /* Retrieve OSPF packet type. */
697 stream_set_getp(op
->s
, 1);
698 type
= stream_getc(op
->s
);
700 /* reset get pointer */
701 stream_set_getp(op
->s
, 0);
703 memset(&iph
, 0, sizeof(struct ip
));
704 memset(&sa_dst
, 0, sizeof(sa_dst
));
706 sa_dst
.sin_family
= AF_INET
;
707 #ifdef HAVE_STRUCT_SOCKADDR_IN_SIN_LEN
708 sa_dst
.sin_len
= sizeof(sa_dst
);
709 #endif /* HAVE_STRUCT_SOCKADDR_IN_SIN_LEN */
710 sa_dst
.sin_addr
= op
->dst
;
711 sa_dst
.sin_port
= htons(0);
713 /* Set DONTROUTE flag if dst is unicast. */
714 if (oi
->type
!= OSPF_IFTYPE_VIRTUALLINK
)
715 if (!IN_MULTICAST(htonl(op
->dst
.s_addr
)))
716 flags
= MSG_DONTROUTE
;
718 iph
.ip_hl
= sizeof(struct ip
) >> OSPF_WRITE_IPHL_SHIFT
;
719 /* it'd be very strange for header to not be 4byte-word aligned
721 if (sizeof(struct ip
)
722 > (unsigned int)(iph
.ip_hl
<< OSPF_WRITE_IPHL_SHIFT
))
723 iph
.ip_hl
++; /* we presume sizeof struct ip cant
726 iph
.ip_v
= IPVERSION
;
727 iph
.ip_tos
= IPTOS_PREC_INTERNETCONTROL
;
728 iph
.ip_len
= (iph
.ip_hl
<< OSPF_WRITE_IPHL_SHIFT
) + op
->length
;
730 #if defined(__DragonFly__)
732 * DragonFly's raw socket expects ip_len/ip_off in network byte
735 iph
.ip_len
= htons(iph
.ip_len
);
738 #ifdef WANT_OSPF_WRITE_FRAGMENT
739 /* XXX-MT: not thread-safe at all..
740 * XXX: this presumes this is only programme sending OSPF
742 * otherwise, no guarantee ipid will be unique
745 #endif /* WANT_OSPF_WRITE_FRAGMENT */
748 if (oi
->type
== OSPF_IFTYPE_VIRTUALLINK
)
749 iph
.ip_ttl
= OSPF_VL_IP_TTL
;
751 iph
.ip_ttl
= OSPF_IP_TTL
;
752 iph
.ip_p
= IPPROTO_OSPFIGP
;
754 iph
.ip_src
.s_addr
= oi
->address
->u
.prefix4
.s_addr
;
755 iph
.ip_dst
.s_addr
= op
->dst
.s_addr
;
757 memset(&msg
, 0, sizeof(msg
));
758 msg
.msg_name
= (caddr_t
)&sa_dst
;
759 msg
.msg_namelen
= sizeof(sa_dst
);
763 iov
[0].iov_base
= (char *)&iph
;
764 iov
[0].iov_len
= iph
.ip_hl
<< OSPF_WRITE_IPHL_SHIFT
;
765 iov
[1].iov_base
= stream_pnt(op
->s
);
766 iov
[1].iov_len
= op
->length
;
769 msg
.msg_control
= (caddr_t
)cm
;
770 cm
->cmsg_level
= SOL_IP
;
771 cm
->cmsg_type
= IP_PKTINFO
;
772 cm
->cmsg_len
= CMSG_LEN(sizeof(struct in_pktinfo
));
773 pi
= (struct in_pktinfo
*)CMSG_DATA(cm
);
774 pi
->ipi_ifindex
= oi
->ifp
->ifindex
;
776 msg
.msg_controllen
= cm
->cmsg_len
;
779 /* Sadly we can not rely on kernels to fragment packets
780 * because of either IP_HDRINCL and/or multicast
781 * destination being set.
784 #ifdef WANT_OSPF_WRITE_FRAGMENT
785 if (op
->length
> maxdatasize
)
786 ospf_write_frags(ospf
->fd
, op
, &iph
, &msg
, maxdatasize
,
787 oi
->ifp
->mtu
, flags
, type
);
788 #endif /* WANT_OSPF_WRITE_FRAGMENT */
790 /* send final fragment (could be first) */
791 sockopt_iphdrincl_swab_htosys(&iph
);
792 ret
= sendmsg(ospf
->fd
, &msg
, flags
);
793 sockopt_iphdrincl_swab_systoh(&iph
);
794 if (IS_DEBUG_OSPF_EVENT
)
797 "id %d, off %d, len %d, interface %s, mtu %u:",
798 inet_ntoa(iph
.ip_dst
), iph
.ip_id
, iph
.ip_off
,
799 iph
.ip_len
, oi
->ifp
->name
, oi
->ifp
->mtu
);
803 "*** sendmsg in ospf_write failed to %s, "
804 "id %d, off %d, len %d, interface %s, mtu %u: %s",
805 inet_ntoa(iph
.ip_dst
), iph
.ip_id
, iph
.ip_off
,
806 iph
.ip_len
, oi
->ifp
->name
, oi
->ifp
->mtu
,
807 safe_strerror(errno
));
809 /* Show debug sending packet. */
810 if (IS_DEBUG_OSPF_PACKET(type
- 1, SEND
)) {
811 if (IS_DEBUG_OSPF_PACKET(type
- 1, DETAIL
)) {
813 "-----------------------------------------------------");
814 ospf_ip_header_dump(&iph
);
815 stream_set_getp(op
->s
, 0);
816 ospf_packet_dump(op
->s
);
819 zlog_debug("%s sent to [%s] via [%s].",
820 lookup_msg(ospf_packet_type_str
, type
, NULL
),
821 inet_ntoa(op
->dst
), IF_NAME(oi
));
823 if (IS_DEBUG_OSPF_PACKET(type
- 1, DETAIL
))
825 "-----------------------------------------------------");
832 case OSPF_MSG_DB_DESC
:
835 case OSPF_MSG_LS_REQ
:
838 case OSPF_MSG_LS_UPD
:
841 case OSPF_MSG_LS_ACK
:
848 /* Now delete packet from queue. */
849 ospf_packet_delete(oi
);
851 /* Move this interface to the tail of write_q to
852 serve everyone in a round robin fashion */
853 list_delete_node(ospf
->oi_write_q
, node
);
854 if (ospf_fifo_head(oi
->obuf
) == NULL
) {
856 last_serviced_oi
= NULL
;
859 listnode_add(ospf
->oi_write_q
, oi
);
862 /* Setup to service from the head of the queue again */
863 if (!list_isempty(ospf
->oi_write_q
)) {
864 node
= listhead(ospf
->oi_write_q
);
866 oi
= listgetdata(node
);
871 /* If packets still remain in queue, call write thread. */
872 if (!list_isempty(ospf
->oi_write_q
)) {
873 ospf
->t_write
= NULL
;
874 thread_add_write(master
, ospf_write
, ospf
, ospf
->fd
,
881 /* OSPF Hello message read -- RFC2328 Section 10.5. */
882 static void ospf_hello(struct ip
*iph
, struct ospf_header
*ospfh
,
883 struct stream
*s
, struct ospf_interface
*oi
, int size
)
885 struct ospf_hello
*hello
;
886 struct ospf_neighbor
*nbr
;
890 /* increment statistics. */
893 hello
= (struct ospf_hello
*)stream_pnt(s
);
895 /* If Hello is myself, silently discard. */
896 if (IPV4_ADDR_SAME(&ospfh
->router_id
, &oi
->ospf
->router_id
)) {
897 if (IS_DEBUG_OSPF_PACKET(ospfh
->type
- 1, RECV
)) {
899 "ospf_header[%s/%s]: selforiginated, "
901 lookup_msg(ospf_packet_type_str
, ospfh
->type
,
903 inet_ntoa(iph
->ip_src
));
908 /* get neighbor prefix. */
910 p
.prefixlen
= ip_masklen(hello
->network_mask
);
911 p
.u
.prefix4
= iph
->ip_src
;
913 /* Compare network mask. */
914 /* Checking is ignored for Point-to-Point and Virtual link. */
915 if (oi
->type
!= OSPF_IFTYPE_POINTOPOINT
916 && oi
->type
!= OSPF_IFTYPE_VIRTUALLINK
)
917 if (oi
->address
->prefixlen
!= p
.prefixlen
) {
919 "Packet %s [Hello:RECV]: NetworkMask mismatch on %s (configured prefix length is %d, but hello packet indicates %d).",
920 inet_ntoa(ospfh
->router_id
), IF_NAME(oi
),
921 (int)oi
->address
->prefixlen
, (int)p
.prefixlen
);
925 /* Compare Router Dead Interval. */
926 if (OSPF_IF_PARAM(oi
, v_wait
) != ntohl(hello
->dead_interval
)) {
928 "Packet %s [Hello:RECV]: RouterDeadInterval mismatch "
929 "(expected %u, but received %u).",
930 inet_ntoa(ospfh
->router_id
), OSPF_IF_PARAM(oi
, v_wait
),
931 ntohl(hello
->dead_interval
));
935 /* Compare Hello Interval - ignored if fast-hellos are set. */
936 if (OSPF_IF_PARAM(oi
, fast_hello
) == 0) {
937 if (OSPF_IF_PARAM(oi
, v_hello
)
938 != ntohs(hello
->hello_interval
)) {
940 "Packet %s [Hello:RECV]: HelloInterval mismatch "
941 "(expected %u, but received %u).",
942 inet_ntoa(ospfh
->router_id
),
943 OSPF_IF_PARAM(oi
, v_hello
),
944 ntohs(hello
->hello_interval
));
949 if (IS_DEBUG_OSPF_EVENT
)
950 zlog_debug("Packet %s [Hello:RECV]: Options %s vrf %s",
951 inet_ntoa(ospfh
->router_id
),
952 ospf_options_dump(hello
->options
),
953 ospf_vrf_id_to_name(oi
->ospf
->vrf_id
));
955 /* Compare options. */
956 #define REJECT_IF_TBIT_ON 1 /* XXX */
957 #ifdef REJECT_IF_TBIT_ON
958 if (CHECK_FLAG(hello
->options
, OSPF_OPTION_MT
)) {
960 * This router does not support non-zero TOS.
961 * Drop this Hello packet not to establish neighbor
964 zlog_warn("Packet %s [Hello:RECV]: T-bit on, drop it.",
965 inet_ntoa(ospfh
->router_id
));
968 #endif /* REJECT_IF_TBIT_ON */
970 if (CHECK_FLAG(oi
->ospf
->config
, OSPF_OPAQUE_CAPABLE
)
971 && CHECK_FLAG(hello
->options
, OSPF_OPTION_O
)) {
973 * This router does know the correct usage of O-bit
974 * the bit should be set in DD packet only.
976 zlog_warn("Packet %s [Hello:RECV]: O-bit abuse?",
977 inet_ntoa(ospfh
->router_id
));
978 #ifdef STRICT_OBIT_USAGE_CHECK
979 return; /* Reject this packet. */
980 #else /* STRICT_OBIT_USAGE_CHECK */
981 UNSET_FLAG(hello
->options
, OSPF_OPTION_O
); /* Ignore O-bit. */
982 #endif /* STRICT_OBIT_USAGE_CHECK */
985 /* new for NSSA is to ensure that NP is on and E is off */
987 if (oi
->area
->external_routing
== OSPF_AREA_NSSA
) {
988 if (!(CHECK_FLAG(OPTIONS(oi
), OSPF_OPTION_NP
)
989 && CHECK_FLAG(hello
->options
, OSPF_OPTION_NP
)
990 && !CHECK_FLAG(OPTIONS(oi
), OSPF_OPTION_E
)
991 && !CHECK_FLAG(hello
->options
, OSPF_OPTION_E
))) {
993 "NSSA-Packet-%s[Hello:RECV]: my options: %x, his options %x",
994 inet_ntoa(ospfh
->router_id
), OPTIONS(oi
),
998 if (IS_DEBUG_OSPF_NSSA
)
999 zlog_debug("NSSA-Hello:RECV:Packet from %s:",
1000 inet_ntoa(ospfh
->router_id
));
1002 /* The setting of the E-bit found in the Hello Packet's Options
1003 field must match this area's ExternalRoutingCapability A
1004 mismatch causes processing to stop and the packet to be
1005 dropped. The setting of the rest of the bits in the Hello
1006 Packet's Options field should be ignored. */
1007 if (CHECK_FLAG(OPTIONS(oi
), OSPF_OPTION_E
)
1008 != CHECK_FLAG(hello
->options
, OSPF_OPTION_E
)) {
1010 "Packet %s [Hello:RECV]: my options: %x, his options %x",
1011 inet_ntoa(ospfh
->router_id
), OPTIONS(oi
),
1016 /* get neighbour struct */
1017 nbr
= ospf_nbr_get(oi
, ospfh
, iph
, &p
);
1019 /* neighbour must be valid, ospf_nbr_get creates if none existed */
1022 old_state
= nbr
->state
;
1024 /* Add event to thread. */
1025 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_PacketReceived
);
1027 /* RFC2328 Section 9.5.1
1028 If the router is not eligible to become Designated Router,
1029 (snip) It must also send an Hello Packet in reply to an
1030 Hello Packet received from any eligible neighbor (other than
1031 the current Designated Router and Backup Designated Router). */
1032 if (oi
->type
== OSPF_IFTYPE_NBMA
)
1033 if (PRIORITY(oi
) == 0 && hello
->priority
> 0
1034 && IPV4_ADDR_CMP(&DR(oi
), &iph
->ip_src
)
1035 && IPV4_ADDR_CMP(&BDR(oi
), &iph
->ip_src
))
1036 OSPF_NSM_TIMER_ON(nbr
->t_hello_reply
,
1037 ospf_hello_reply_timer
,
1038 OSPF_HELLO_REPLY_DELAY
);
1040 /* on NBMA network type, it happens to receive bidirectional Hello
1042 without advance 1-Way Received event.
1043 To avoid incorrect DR-seletion, raise 1-Way Received event.*/
1044 if (oi
->type
== OSPF_IFTYPE_NBMA
1045 && (old_state
== NSM_Down
|| old_state
== NSM_Attempt
)) {
1046 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_OneWayReceived
);
1047 nbr
->priority
= hello
->priority
;
1048 nbr
->d_router
= hello
->d_router
;
1049 nbr
->bd_router
= hello
->bd_router
;
1053 if (ospf_nbr_bidirectional(&oi
->ospf
->router_id
, hello
->neighbors
,
1054 size
- OSPF_HELLO_MIN_SIZE
)) {
1055 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_TwoWayReceived
);
1056 nbr
->options
|= hello
->options
;
1058 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_OneWayReceived
);
1059 /* Set neighbor information. */
1060 nbr
->priority
= hello
->priority
;
1061 nbr
->d_router
= hello
->d_router
;
1062 nbr
->bd_router
= hello
->bd_router
;
1066 /* If neighbor itself declares DR and no BDR exists,
1067 cause event BackupSeen */
1068 if (IPV4_ADDR_SAME(&nbr
->address
.u
.prefix4
, &hello
->d_router
))
1069 if (hello
->bd_router
.s_addr
== 0 && oi
->state
== ISM_Waiting
)
1070 OSPF_ISM_EVENT_SCHEDULE(oi
, ISM_BackupSeen
);
1072 /* neighbor itself declares BDR. */
1073 if (oi
->state
== ISM_Waiting
1074 && IPV4_ADDR_SAME(&nbr
->address
.u
.prefix4
, &hello
->bd_router
))
1075 OSPF_ISM_EVENT_SCHEDULE(oi
, ISM_BackupSeen
);
1077 /* had not previously. */
1078 if ((IPV4_ADDR_SAME(&nbr
->address
.u
.prefix4
, &hello
->d_router
)
1079 && IPV4_ADDR_CMP(&nbr
->address
.u
.prefix4
, &nbr
->d_router
))
1080 || (IPV4_ADDR_CMP(&nbr
->address
.u
.prefix4
, &hello
->d_router
)
1081 && IPV4_ADDR_SAME(&nbr
->address
.u
.prefix4
, &nbr
->d_router
)))
1082 OSPF_ISM_EVENT_SCHEDULE(oi
, ISM_NeighborChange
);
1084 /* had not previously. */
1085 if ((IPV4_ADDR_SAME(&nbr
->address
.u
.prefix4
, &hello
->bd_router
)
1086 && IPV4_ADDR_CMP(&nbr
->address
.u
.prefix4
, &nbr
->bd_router
))
1087 || (IPV4_ADDR_CMP(&nbr
->address
.u
.prefix4
, &hello
->bd_router
)
1088 && IPV4_ADDR_SAME(&nbr
->address
.u
.prefix4
, &nbr
->bd_router
)))
1089 OSPF_ISM_EVENT_SCHEDULE(oi
, ISM_NeighborChange
);
1091 /* Neighbor priority check. */
1092 if (nbr
->priority
>= 0 && nbr
->priority
!= hello
->priority
)
1093 OSPF_ISM_EVENT_SCHEDULE(oi
, ISM_NeighborChange
);
1095 /* Set neighbor information. */
1096 nbr
->priority
= hello
->priority
;
1097 nbr
->d_router
= hello
->d_router
;
1098 nbr
->bd_router
= hello
->bd_router
;
1101 /* Save DD flags/options/Seqnum received. */
1102 static void ospf_db_desc_save_current(struct ospf_neighbor
*nbr
,
1103 struct ospf_db_desc
*dd
)
1105 nbr
->last_recv
.flags
= dd
->flags
;
1106 nbr
->last_recv
.options
= dd
->options
;
1107 nbr
->last_recv
.dd_seqnum
= ntohl(dd
->dd_seqnum
);
1110 /* Process rest of DD packet. */
1111 static void ospf_db_desc_proc(struct stream
*s
, struct ospf_interface
*oi
,
1112 struct ospf_neighbor
*nbr
,
1113 struct ospf_db_desc
*dd
, uint16_t size
)
1115 struct ospf_lsa
*new, *find
;
1116 struct lsa_header
*lsah
;
1118 stream_forward_getp(s
, OSPF_DB_DESC_MIN_SIZE
);
1119 for (size
-= OSPF_DB_DESC_MIN_SIZE
; size
>= OSPF_LSA_HEADER_SIZE
;
1120 size
-= OSPF_LSA_HEADER_SIZE
) {
1121 lsah
= (struct lsa_header
*)stream_pnt(s
);
1122 stream_forward_getp(s
, OSPF_LSA_HEADER_SIZE
);
1124 /* Unknown LS type. */
1125 if (lsah
->type
< OSPF_MIN_LSA
|| lsah
->type
>= OSPF_MAX_LSA
) {
1126 zlog_warn("Packet [DD:RECV]: Unknown LS type %d.",
1128 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_SeqNumberMismatch
);
1132 if (IS_OPAQUE_LSA(lsah
->type
)
1133 && !CHECK_FLAG(nbr
->options
, OSPF_OPTION_O
)) {
1134 zlog_warn("LSA[Type%d:%s]: Opaque capability mismatch?",
1135 lsah
->type
, inet_ntoa(lsah
->id
));
1136 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_SeqNumberMismatch
);
1140 switch (lsah
->type
) {
1141 case OSPF_AS_EXTERNAL_LSA
:
1142 case OSPF_OPAQUE_AS_LSA
:
1143 /* Check for stub area. Reject if AS-External from stub
1145 allow if from NSSA. */
1146 if (oi
->area
->external_routing
== OSPF_AREA_STUB
) {
1148 "Packet [DD:RECV]: LSA[Type%d:%s] from %s area.",
1149 lsah
->type
, inet_ntoa(lsah
->id
),
1150 (oi
->area
->external_routing
1154 OSPF_NSM_EVENT_SCHEDULE(nbr
,
1155 NSM_SeqNumberMismatch
);
1163 /* Create LS-request object. */
1164 new = ospf_ls_request_new(lsah
);
1166 /* Lookup received LSA, then add LS request list. */
1167 find
= ospf_lsa_lookup_by_header(oi
->area
, lsah
);
1169 /* ospf_lsa_more_recent is fine with NULL pointers */
1170 switch (ospf_lsa_more_recent(find
, new)) {
1172 /* Neighbour has a more recent LSA, we must request it
1174 ospf_ls_request_add(nbr
, new);
1177 /* If we have a copy of this LSA, it's either less
1179 * and we're requesting it from neighbour (the case
1181 * it's as recent and we both have same copy (this
1184 * In neither of these two cases is there any point in
1185 * describing our copy of the LSA to the neighbour in a
1186 * DB-Summary packet, if we're still intending to do so.
1188 * See: draft-ogier-ospf-dbex-opt-00.txt, describing the
1189 * backward compatible optimisation to OSPF DB Exchange
1191 * DB Description process implemented here.
1194 ospf_lsdb_delete(&nbr
->db_sum
, find
);
1195 ospf_lsa_discard(new);
1198 /* We have the more recent copy, nothing specific to do:
1199 * - no need to request neighbours stale copy
1200 * - must leave DB summary list copy alone
1202 if (IS_DEBUG_OSPF_EVENT
)
1204 "Packet [DD:RECV]: LSA received Type %d, "
1205 "ID %s is not recent.",
1206 lsah
->type
, inet_ntoa(lsah
->id
));
1207 ospf_lsa_discard(new);
1212 if (IS_SET_DD_MS(nbr
->dd_flags
)) {
1215 /* Both sides have no More, then we're done with Exchange */
1216 if (!IS_SET_DD_M(dd
->flags
) && !IS_SET_DD_M(nbr
->dd_flags
))
1217 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_ExchangeDone
);
1219 ospf_db_desc_send(nbr
);
1223 nbr
->dd_seqnum
= ntohl(dd
->dd_seqnum
);
1225 /* Send DD packet in reply.
1227 * Must be done to acknowledge the Master's DD, regardless of
1228 * whether we have more LSAs ourselves to describe.
1230 * This function will clear the 'More' bit, if after this DD
1231 * we have no more LSAs to describe to the master..
1233 ospf_db_desc_send(nbr
);
1235 /* Slave can raise ExchangeDone now, if master is also done */
1236 if (!IS_SET_DD_M(dd
->flags
) && !IS_SET_DD_M(nbr
->dd_flags
))
1237 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_ExchangeDone
);
1240 /* Save received neighbor values from DD. */
1241 ospf_db_desc_save_current(nbr
, dd
);
1244 ospf_ls_req_send(nbr
);
1247 static int ospf_db_desc_is_dup(struct ospf_db_desc
*dd
,
1248 struct ospf_neighbor
*nbr
)
1250 /* Is DD duplicated? */
1251 if (dd
->options
== nbr
->last_recv
.options
1252 && dd
->flags
== nbr
->last_recv
.flags
1253 && dd
->dd_seqnum
== htonl(nbr
->last_recv
.dd_seqnum
))
1259 /* OSPF Database Description message read -- RFC2328 Section 10.6. */
1260 static void ospf_db_desc(struct ip
*iph
, struct ospf_header
*ospfh
,
1261 struct stream
*s
, struct ospf_interface
*oi
,
1264 struct ospf_db_desc
*dd
;
1265 struct ospf_neighbor
*nbr
;
1267 /* Increment statistics. */
1270 dd
= (struct ospf_db_desc
*)stream_pnt(s
);
1272 nbr
= ospf_nbr_lookup(oi
, iph
, ospfh
);
1274 zlog_warn("Packet[DD]: Unknown Neighbor %s",
1275 inet_ntoa(ospfh
->router_id
));
1280 if ((OSPF_IF_PARAM(oi
, mtu_ignore
) == 0)
1281 && (ntohs(dd
->mtu
) > oi
->ifp
->mtu
)) {
1283 "Packet[DD]: Neighbor %s MTU %u is larger than [%s]'s MTU %u",
1284 inet_ntoa(nbr
->router_id
), ntohs(dd
->mtu
), IF_NAME(oi
),
1290 * XXX HACK by Hasso Tepper. Setting N/P bit in NSSA area DD packets is
1292 * required. In fact at least JunOS sends DD packets with P bit clear.
1293 * Until proper solution is developped, this hack should help.
1295 * Update: According to the RFCs, N bit is specified /only/ for Hello
1296 * options, unfortunately its use in DD options is not specified. Hence
1298 * implementations follow E-bit semantics and set it in DD options, and
1300 * treat it as unspecified and hence follow the directive "default for
1301 * options is clear", ie unset.
1303 * Reset the flag, as ospfd follows E-bit semantics.
1305 if ((oi
->area
->external_routing
== OSPF_AREA_NSSA
)
1306 && (CHECK_FLAG(nbr
->options
, OSPF_OPTION_NP
))
1307 && (!CHECK_FLAG(dd
->options
, OSPF_OPTION_NP
))) {
1308 if (IS_DEBUG_OSPF_EVENT
)
1310 "Packet[DD]: Neighbour %s: Has NSSA capability, sends with N bit clear in DD options",
1311 inet_ntoa(nbr
->router_id
));
1312 SET_FLAG(dd
->options
, OSPF_OPTION_NP
);
1315 #ifdef REJECT_IF_TBIT_ON
1316 if (CHECK_FLAG(dd
->options
, OSPF_OPTION_MT
)) {
1318 * In Hello protocol, optional capability must have checked
1319 * to prevent this T-bit enabled router be my neighbor.
1321 zlog_warn("Packet[DD]: Neighbor %s: T-bit on?",
1322 inet_ntoa(nbr
->router_id
));
1325 #endif /* REJECT_IF_TBIT_ON */
1327 if (CHECK_FLAG(dd
->options
, OSPF_OPTION_O
)
1328 && !CHECK_FLAG(oi
->ospf
->config
, OSPF_OPAQUE_CAPABLE
)) {
1330 * This node is not configured to handle O-bit, for now.
1331 * Clear it to ignore unsupported capability proposed by
1334 UNSET_FLAG(dd
->options
, OSPF_OPTION_O
);
1337 /* Add event to thread. */
1338 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_PacketReceived
);
1340 /* Process DD packet by neighbor status. */
1341 switch (nbr
->state
) {
1346 "Packet[DD]: Neighbor %s state is %s, packet discarded.",
1347 inet_ntoa(nbr
->router_id
),
1348 lookup_msg(ospf_nsm_state_msg
, nbr
->state
, NULL
));
1351 OSPF_NSM_EVENT_EXECUTE(nbr
, NSM_TwoWayReceived
);
1352 /* If the new state is ExStart, the processing of the current
1353 packet should then continue in this new state by falling
1354 through to case ExStart below. */
1355 if (nbr
->state
!= NSM_ExStart
)
1360 if ((IS_SET_DD_ALL(dd
->flags
) == OSPF_DD_FLAG_ALL
)
1361 && (size
== OSPF_DB_DESC_MIN_SIZE
)) {
1362 if (IPV4_ADDR_CMP(&nbr
->router_id
, &oi
->ospf
->router_id
)
1364 /* We're Slave---obey */
1365 if (CHECK_FLAG(oi
->ospf
->config
,
1366 OSPF_LOG_ADJACENCY_DETAIL
))
1368 "Packet[DD]: Neighbor %s Negotiation done (Slave).",
1369 inet_ntoa(nbr
->router_id
));
1371 nbr
->dd_seqnum
= ntohl(dd
->dd_seqnum
);
1374 UNSET_FLAG(nbr
->dd_flags
,
1375 (OSPF_DD_FLAG_MS
| OSPF_DD_FLAG_I
));
1377 /* We're Master, ignore the initial DBD from
1379 if (CHECK_FLAG(oi
->ospf
->config
,
1380 OSPF_LOG_ADJACENCY_DETAIL
))
1382 "Packet[DD]: Neighbor %s: Initial DBD from Slave, "
1384 inet_ntoa(nbr
->router_id
));
1388 /* Ack from the Slave */
1389 else if (!IS_SET_DD_MS(dd
->flags
) && !IS_SET_DD_I(dd
->flags
)
1390 && ntohl(dd
->dd_seqnum
) == nbr
->dd_seqnum
1391 && IPV4_ADDR_CMP(&nbr
->router_id
, &oi
->ospf
->router_id
)
1394 "Packet[DD]: Neighbor %s Negotiation done (Master).",
1395 inet_ntoa(nbr
->router_id
));
1396 /* Reset I, leaving MS */
1397 UNSET_FLAG(nbr
->dd_flags
, OSPF_DD_FLAG_I
);
1399 zlog_warn("Packet[DD]: Neighbor %s Negotiation fails.",
1400 inet_ntoa(nbr
->router_id
));
1404 /* This is where the real Options are saved */
1405 nbr
->options
= dd
->options
;
1407 if (CHECK_FLAG(oi
->ospf
->config
, OSPF_OPAQUE_CAPABLE
)) {
1408 if (IS_DEBUG_OSPF_EVENT
)
1410 "Neighbor[%s] is %sOpaque-capable.",
1411 inet_ntoa(nbr
->router_id
),
1412 CHECK_FLAG(nbr
->options
, OSPF_OPTION_O
)
1416 if (!CHECK_FLAG(nbr
->options
, OSPF_OPTION_O
)
1417 && IPV4_ADDR_SAME(&DR(oi
),
1418 &nbr
->address
.u
.prefix4
)) {
1420 "DR-neighbor[%s] is NOT opaque-capable; "
1421 "Opaque-LSAs cannot be reliably advertised "
1423 inet_ntoa(nbr
->router_id
));
1424 /* This situation is undesirable, but not a real
1429 OSPF_NSM_EVENT_EXECUTE(nbr
, NSM_NegotiationDone
);
1431 /* continue processing rest of packet. */
1432 ospf_db_desc_proc(s
, oi
, nbr
, dd
, size
);
1435 if (ospf_db_desc_is_dup(dd
, nbr
)) {
1436 if (IS_SET_DD_MS(nbr
->dd_flags
))
1437 /* Master: discard duplicated DD packet. */
1439 "Packet[DD] (Master): Neighbor %s packet duplicated.",
1440 inet_ntoa(nbr
->router_id
));
1442 /* Slave: cause to retransmit the last Database
1446 "Packet[DD] [Slave]: Neighbor %s packet duplicated.",
1447 inet_ntoa(nbr
->router_id
));
1448 ospf_db_desc_resend(nbr
);
1453 /* Otherwise DD packet should be checked. */
1454 /* Check Master/Slave bit mismatch */
1455 if (IS_SET_DD_MS(dd
->flags
)
1456 != IS_SET_DD_MS(nbr
->last_recv
.flags
)) {
1457 zlog_warn("Packet[DD]: Neighbor %s MS-bit mismatch.",
1458 inet_ntoa(nbr
->router_id
));
1459 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_SeqNumberMismatch
);
1460 if (IS_DEBUG_OSPF_EVENT
)
1462 "Packet[DD]: dd->flags=%d, nbr->dd_flags=%d",
1463 dd
->flags
, nbr
->dd_flags
);
1467 /* Check initialize bit is set. */
1468 if (IS_SET_DD_I(dd
->flags
)) {
1469 zlog_info("Packet[DD]: Neighbor %s I-bit set.",
1470 inet_ntoa(nbr
->router_id
));
1471 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_SeqNumberMismatch
);
1475 /* Check DD Options. */
1476 if (dd
->options
!= nbr
->options
) {
1477 #ifdef ORIGINAL_CODING
1478 /* Save the new options for debugging */
1479 nbr
->options
= dd
->options
;
1480 #endif /* ORIGINAL_CODING */
1481 zlog_warn("Packet[DD]: Neighbor %s options mismatch.",
1482 inet_ntoa(nbr
->router_id
));
1483 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_SeqNumberMismatch
);
1487 /* Check DD sequence number. */
1488 if ((IS_SET_DD_MS(nbr
->dd_flags
)
1489 && ntohl(dd
->dd_seqnum
) != nbr
->dd_seqnum
)
1490 || (!IS_SET_DD_MS(nbr
->dd_flags
)
1491 && ntohl(dd
->dd_seqnum
) != nbr
->dd_seqnum
+ 1)) {
1493 "Packet[DD]: Neighbor %s sequence number mismatch.",
1494 inet_ntoa(nbr
->router_id
));
1495 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_SeqNumberMismatch
);
1499 /* Continue processing rest of packet. */
1500 ospf_db_desc_proc(s
, oi
, nbr
, dd
, size
);
1504 if (ospf_db_desc_is_dup(dd
, nbr
)) {
1505 if (IS_SET_DD_MS(nbr
->dd_flags
)) {
1506 /* Master should discard duplicate DD packet. */
1508 "Packet[DD]: Neighbor %s duplicated, "
1509 "packet discarded.",
1510 inet_ntoa(nbr
->router_id
));
1513 if (monotime_since(&nbr
->last_send_ts
, NULL
)
1514 < nbr
->v_inactivity
* 1000000LL) {
1515 /* In states Loading and Full the slave
1517 its last Database Description packet
1519 duplicate Database Description
1521 from the master. For this reason the
1523 wait RouterDeadInterval seconds
1525 last Database Description packet.
1527 Database Description packet from the
1529 this interval will generate a
1531 neighbor event. RFC2328 Section 10.8
1533 ospf_db_desc_resend(nbr
);
1539 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_SeqNumberMismatch
);
1542 zlog_warn("Packet[DD]: Neighbor %s NSM illegal status %u.",
1543 inet_ntoa(nbr
->router_id
), nbr
->state
);
1548 #define OSPF_LSA_KEY_SIZE 12 /* type(4) + id(4) + ar(4) */
1550 /* OSPF Link State Request Read -- RFC2328 Section 10.7. */
1551 static void ospf_ls_req(struct ip
*iph
, struct ospf_header
*ospfh
,
1552 struct stream
*s
, struct ospf_interface
*oi
,
1555 struct ospf_neighbor
*nbr
;
1557 struct in_addr ls_id
;
1558 struct in_addr adv_router
;
1559 struct ospf_lsa
*find
;
1560 struct list
*ls_upd
;
1561 unsigned int length
;
1563 /* Increment statistics. */
1566 nbr
= ospf_nbr_lookup(oi
, iph
, ospfh
);
1568 zlog_warn("Link State Request: Unknown Neighbor %s.",
1569 inet_ntoa(ospfh
->router_id
));
1573 /* Add event to thread. */
1574 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_PacketReceived
);
1576 /* Neighbor State should be Exchange or later. */
1577 if (nbr
->state
!= NSM_Exchange
&& nbr
->state
!= NSM_Loading
1578 && nbr
->state
!= NSM_Full
) {
1580 "Link State Request received from %s: "
1581 "Neighbor state is %s, packet discarded.",
1582 inet_ntoa(ospfh
->router_id
),
1583 lookup_msg(ospf_nsm_state_msg
, nbr
->state
, NULL
));
1587 /* Send Link State Update for ALL requested LSAs. */
1588 ls_upd
= list_new();
1589 length
= OSPF_HEADER_SIZE
+ OSPF_LS_UPD_MIN_SIZE
;
1591 while (size
>= OSPF_LSA_KEY_SIZE
) {
1592 /* Get one slice of Link State Request. */
1593 ls_type
= stream_getl(s
);
1594 ls_id
.s_addr
= stream_get_ipv4(s
);
1595 adv_router
.s_addr
= stream_get_ipv4(s
);
1597 /* Verify LSA type. */
1598 if (ls_type
< OSPF_MIN_LSA
|| ls_type
>= OSPF_MAX_LSA
) {
1599 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_BadLSReq
);
1600 list_delete_and_null(&ls_upd
);
1604 /* Search proper LSA in LSDB. */
1605 find
= ospf_lsa_lookup(oi
->ospf
, oi
->area
, ls_type
, ls_id
,
1608 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_BadLSReq
);
1609 list_delete_and_null(&ls_upd
);
1613 /* Packet overflows MTU size, send immediately. */
1614 if (length
+ ntohs(find
->data
->length
) > ospf_packet_max(oi
)) {
1615 if (oi
->type
== OSPF_IFTYPE_NBMA
)
1616 ospf_ls_upd_send(nbr
, ls_upd
,
1617 OSPF_SEND_PACKET_DIRECT
, 0);
1619 ospf_ls_upd_send(nbr
, ls_upd
,
1620 OSPF_SEND_PACKET_INDIRECT
, 0);
1622 /* Only remove list contents. Keep ls_upd. */
1623 list_delete_all_node(ls_upd
);
1625 length
= OSPF_HEADER_SIZE
+ OSPF_LS_UPD_MIN_SIZE
;
1628 /* Append LSA to update list. */
1629 listnode_add(ls_upd
, find
);
1630 length
+= ntohs(find
->data
->length
);
1632 size
-= OSPF_LSA_KEY_SIZE
;
1635 /* Send rest of Link State Update. */
1636 if (listcount(ls_upd
) > 0) {
1637 if (oi
->type
== OSPF_IFTYPE_NBMA
)
1638 ospf_ls_upd_send(nbr
, ls_upd
, OSPF_SEND_PACKET_DIRECT
,
1641 ospf_ls_upd_send(nbr
, ls_upd
, OSPF_SEND_PACKET_INDIRECT
,
1644 list_delete_and_null(&ls_upd
);
1646 list_delete_and_null(&ls_upd
);
1649 /* Get the list of LSAs from Link State Update packet.
1650 And process some validation -- RFC2328 Section 13. (1)-(2). */
1651 static struct list
*ospf_ls_upd_list_lsa(struct ospf_neighbor
*nbr
,
1653 struct ospf_interface
*oi
, size_t size
)
1655 uint16_t count
, sum
;
1657 struct lsa_header
*lsah
;
1658 struct ospf_lsa
*lsa
;
1663 count
= stream_getl(s
);
1664 size
-= OSPF_LS_UPD_MIN_SIZE
; /* # LSAs */
1666 for (; size
>= OSPF_LSA_HEADER_SIZE
&& count
> 0;
1667 size
-= length
, stream_forward_getp(s
, length
), count
--) {
1668 lsah
= (struct lsa_header
*)stream_pnt(s
);
1669 length
= ntohs(lsah
->length
);
1671 if (length
> size
) {
1673 "Link State Update: LSA length exceeds packet size.");
1677 /* Validate the LSA's LS checksum. */
1678 sum
= lsah
->checksum
;
1679 if (!ospf_lsa_checksum_valid(lsah
)) {
1680 /* (bug #685) more details in a one-line message make it
1682 * to identify problem source on the one hand and to
1684 * chance to compress repeated messages in syslog on the
1687 "Link State Update: LSA checksum error %x/%x, ID=%s from: nbr %s, router ID %s, adv router %s",
1688 sum
, lsah
->checksum
, inet_ntoa(lsah
->id
),
1689 inet_ntoa(nbr
->src
), inet_ntoa(nbr
->router_id
),
1690 inet_ntoa(lsah
->adv_router
));
1694 /* Examine the LSA's LS type. */
1695 if (lsah
->type
< OSPF_MIN_LSA
|| lsah
->type
>= OSPF_MAX_LSA
) {
1696 zlog_warn("Link State Update: Unknown LS type %d",
1702 * What if the received LSA's age is greater than MaxAge?
1703 * Treat it as a MaxAge case -- endo.
1705 if (ntohs(lsah
->ls_age
) > OSPF_LSA_MAXAGE
)
1706 lsah
->ls_age
= htons(OSPF_LSA_MAXAGE
);
1708 if (CHECK_FLAG(nbr
->options
, OSPF_OPTION_O
)) {
1709 #ifdef STRICT_OBIT_USAGE_CHECK
1710 if ((IS_OPAQUE_LSA(lsah
->type
)
1711 && !CHECK_FLAG(lsah
->options
, OSPF_OPTION_O
))
1712 || (!IS_OPAQUE_LSA(lsah
->type
)
1713 && CHECK_FLAG(lsah
->options
, OSPF_OPTION_O
))) {
1715 * This neighbor must know the exact usage of
1717 * the bit will be set in Type-9,10,11 LSAs
1720 zlog_warn("LSA[Type%d:%s]: O-bit abuse?",
1721 lsah
->type
, inet_ntoa(lsah
->id
));
1724 #endif /* STRICT_OBIT_USAGE_CHECK */
1726 /* Do not take in AS External Opaque-LSAs if we are a
1728 if (lsah
->type
== OSPF_OPAQUE_AS_LSA
1729 && nbr
->oi
->area
->external_routing
1730 != OSPF_AREA_DEFAULT
) {
1731 if (IS_DEBUG_OSPF_EVENT
)
1733 "LSA[Type%d:%s]: We are a stub, don't take this LSA.",
1735 inet_ntoa(lsah
->id
));
1738 } else if (IS_OPAQUE_LSA(lsah
->type
)) {
1739 zlog_warn("LSA[Type%d:%s]: Opaque capability mismatch?",
1740 lsah
->type
, inet_ntoa(lsah
->id
));
1744 /* Create OSPF LSA instance. */
1745 lsa
= ospf_lsa_new();
1747 lsa
->vrf_id
= oi
->ospf
->vrf_id
;
1748 /* We may wish to put some error checking if type NSSA comes in
1749 and area not in NSSA mode */
1750 switch (lsah
->type
) {
1751 case OSPF_AS_EXTERNAL_LSA
:
1752 case OSPF_OPAQUE_AS_LSA
:
1755 case OSPF_OPAQUE_LINK_LSA
:
1756 lsa
->oi
= oi
; /* Remember incoming interface for
1757 flooding control. */
1760 lsa
->area
= oi
->area
;
1764 lsa
->data
= ospf_lsa_data_new(length
);
1765 memcpy(lsa
->data
, lsah
, length
);
1767 if (IS_DEBUG_OSPF_EVENT
)
1769 "LSA[Type%d:%s]: %p new LSA created with Link State Update",
1770 lsa
->data
->type
, inet_ntoa(lsa
->data
->id
),
1772 listnode_add(lsas
, lsa
);
1778 /* Cleanup Update list. */
1779 static void ospf_upd_list_clean(struct list
*lsas
)
1781 struct listnode
*node
, *nnode
;
1782 struct ospf_lsa
*lsa
;
1784 for (ALL_LIST_ELEMENTS(lsas
, node
, nnode
, lsa
))
1785 ospf_lsa_discard(lsa
);
1787 list_delete_and_null(&lsas
);
1790 /* OSPF Link State Update message read -- RFC2328 Section 13. */
1791 static void ospf_ls_upd(struct ospf
*ospf
, struct ip
*iph
,
1792 struct ospf_header
*ospfh
, struct stream
*s
,
1793 struct ospf_interface
*oi
, uint16_t size
)
1795 struct ospf_neighbor
*nbr
;
1797 struct listnode
*node
, *nnode
;
1798 struct ospf_lsa
*lsa
= NULL
;
1799 /* unsigned long ls_req_found = 0; */
1801 /* Dis-assemble the stream, update each entry, re-encapsulate for
1804 /* Increment statistics. */
1807 /* Check neighbor. */
1808 nbr
= ospf_nbr_lookup(oi
, iph
, ospfh
);
1810 zlog_warn("Link State Update: Unknown Neighbor %s on int: %s",
1811 inet_ntoa(ospfh
->router_id
), IF_NAME(oi
));
1815 /* Add event to thread. */
1816 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_PacketReceived
);
1818 /* Check neighbor state. */
1819 if (nbr
->state
< NSM_Exchange
) {
1820 if (IS_DEBUG_OSPF(nsm
, NSM_EVENTS
))
1822 "Link State Update: "
1823 "Neighbor[%s] state %s is less than Exchange",
1824 inet_ntoa(ospfh
->router_id
),
1825 lookup_msg(ospf_nsm_state_msg
, nbr
->state
,
1830 /* Get list of LSAs from Link State Update packet. - Also perorms Stages
1831 * 1 (validate LSA checksum) and 2 (check for LSA consistent type)
1834 lsas
= ospf_ls_upd_list_lsa(nbr
, s
, oi
, size
);
1838 #define DISCARD_LSA(L, N) \
1840 if (IS_DEBUG_OSPF_EVENT) \
1842 "ospf_lsa_discard() in ospf_ls_upd() point %d: lsa %p" \
1844 N, (void *)lsa, (int)lsa->data->type); \
1845 ospf_lsa_discard(L); \
1849 /* Process each LSA received in the one packet.
1851 * Numbers in parentheses, e.g. (1), (2), etc., and the corresponding
1852 * text below are from the steps in RFC 2328, Section 13.
1854 for (ALL_LIST_ELEMENTS(lsas
, node
, nnode
, lsa
)) {
1855 struct ospf_lsa
*ls_ret
, *current
;
1858 if (IS_DEBUG_OSPF_NSSA
) {
1859 char buf1
[INET_ADDRSTRLEN
];
1860 char buf2
[INET_ADDRSTRLEN
];
1861 char buf3
[INET_ADDRSTRLEN
];
1863 zlog_debug("LSA Type-%d from %s, ID: %s, ADV: %s",
1865 inet_ntop(AF_INET
, &ospfh
->router_id
, buf1
,
1867 inet_ntop(AF_INET
, &lsa
->data
->id
, buf2
,
1869 inet_ntop(AF_INET
, &lsa
->data
->adv_router
,
1870 buf3
, INET_ADDRSTRLEN
));
1873 listnode_delete(lsas
,
1874 lsa
); /* We don't need it in list anymore */
1876 /* (1) Validate Checksum - Done above by ospf_ls_upd_list_lsa()
1879 /* (2) LSA Type - Done above by ospf_ls_upd_list_lsa() */
1881 /* (3) Do not take in AS External LSAs if we are a stub or NSSA.
1884 /* Do not take in AS NSSA if this neighbor and we are not NSSA
1887 /* Do take in Type-7's if we are an NSSA */
1889 /* If we are also an ABR, later translate them to a Type-5
1892 /* Later, an NSSA Re-fresh can Re-fresh Type-7's and an ABR will
1893 translate them to a separate Type-5 packet. */
1895 if (lsa
->data
->type
== OSPF_AS_EXTERNAL_LSA
)
1896 /* Reject from STUB or NSSA */
1897 if (nbr
->oi
->area
->external_routing
1898 != OSPF_AREA_DEFAULT
) {
1899 if (IS_DEBUG_OSPF_NSSA
)
1901 "Incoming External LSA Discarded: We are NSSA/STUB Area");
1902 DISCARD_LSA(lsa
, 1);
1905 if (lsa
->data
->type
== OSPF_AS_NSSA_LSA
)
1906 if (nbr
->oi
->area
->external_routing
!= OSPF_AREA_NSSA
) {
1907 if (IS_DEBUG_OSPF_NSSA
)
1909 "Incoming NSSA LSA Discarded: Not NSSA Area");
1910 DISCARD_LSA(lsa
, 2);
1913 /* VU229804: Router-LSA Adv-ID must be equal to LS-ID */
1914 if (lsa
->data
->type
== OSPF_ROUTER_LSA
)
1915 if (!IPV4_ADDR_SAME(&lsa
->data
->id
,
1916 &lsa
->data
->adv_router
)) {
1917 char buf1
[INET_ADDRSTRLEN
];
1918 char buf2
[INET_ADDRSTRLEN
];
1919 char buf3
[INET_ADDRSTRLEN
];
1921 flog_err(OSPF_ERR_ROUTER_LSA_MISMATCH
,
1922 "Incoming Router-LSA from %s with "
1923 "Adv-ID[%s] != LS-ID[%s]",
1924 inet_ntop(AF_INET
, &ospfh
->router_id
,
1925 buf1
, INET_ADDRSTRLEN
),
1926 inet_ntop(AF_INET
, &lsa
->data
->id
,
1927 buf2
, INET_ADDRSTRLEN
),
1929 &lsa
->data
->adv_router
,
1930 buf3
, INET_ADDRSTRLEN
));
1932 OSPF_ERR_DOMAIN_CORRUPT
,
1933 "OSPF domain compromised by attack or corruption. "
1934 "Verify correct operation of -ALL- OSPF routers.");
1935 DISCARD_LSA(lsa
, 0);
1938 /* Find the LSA in the current database. */
1940 current
= ospf_lsa_lookup_by_header(oi
->area
, lsa
->data
);
1942 /* (4) If the LSA's LS age is equal to MaxAge, and there is
1944 no instance of the LSA in the router's link state database,
1945 and none of router's neighbors are in states Exchange or
1947 then take the following actions: */
1949 if (IS_LSA_MAXAGE(lsa
) && !current
1950 && ospf_check_nbr_status(oi
->ospf
)) {
1951 /* (4a) Response Link State Acknowledgment. */
1952 ospf_ls_ack_send(nbr
, lsa
);
1954 /* (4b) Discard LSA. */
1955 if (IS_DEBUG_OSPF(lsa
, LSA
)) {
1957 "Link State Update[%s]: LS age is equal to MaxAge.",
1960 DISCARD_LSA(lsa
, 3);
1963 if (IS_OPAQUE_LSA(lsa
->data
->type
)
1964 && IPV4_ADDR_SAME(&lsa
->data
->adv_router
,
1965 &oi
->ospf
->router_id
)) {
1967 * Even if initial flushing seems to be completed, there
1969 * be a case that self-originated LSA with MaxAge still
1971 * in the routing domain.
1972 * Just send an LSAck message to cease retransmission.
1974 if (IS_LSA_MAXAGE(lsa
)) {
1975 zlog_warn("LSA[%s]: Boomerang effect?",
1977 ospf_ls_ack_send(nbr
, lsa
);
1978 ospf_lsa_discard(lsa
);
1980 if (current
!= NULL
&& !IS_LSA_MAXAGE(current
))
1981 ospf_opaque_lsa_refresh_schedule(
1987 * If an instance of self-originated Opaque-LSA is not
1989 * in the LSDB, there are some possible cases here.
1991 * 1) This node lost opaque-capability after restart.
1992 * 2) Else, a part of opaque-type is no more supported.
1993 * 3) Else, a part of opaque-id is no more supported.
1995 * Anyway, it is still this node's responsibility to
1997 * Otherwise, the LSA instance remains in the routing
1999 * until its age reaches to MaxAge.
2001 /* XXX: We should deal with this for *ALL* LSAs, not
2003 if (current
== NULL
) {
2004 if (IS_DEBUG_OSPF_EVENT
)
2006 "LSA[%s]: Previously originated Opaque-LSA,"
2007 "not found in the LSDB.",
2010 SET_FLAG(lsa
->flags
, OSPF_LSA_SELF
);
2012 ospf_opaque_self_originated_lsa_received(nbr
,
2014 ospf_ls_ack_send(nbr
, lsa
);
2020 /* It might be happen that received LSA is self-originated
2022 * router ID is changed. So, we should check if LSA is a
2024 * Link State ID is one of the router's own IP interface
2025 * addresses but whose
2026 * Advertising Router is not equal to the router's own Router ID
2027 * According to RFC 2328 12.4.2 and 13.4 this LSA should be
2031 if (lsa
->data
->type
== OSPF_NETWORK_LSA
) {
2032 struct listnode
*oinode
, *oinnode
;
2033 struct ospf_interface
*out_if
;
2036 for (ALL_LIST_ELEMENTS(oi
->ospf
->oiflist
, oinode
,
2041 if ((IPV4_ADDR_SAME(&out_if
->address
->u
.prefix4
,
2043 && (!(IPV4_ADDR_SAME(
2044 &oi
->ospf
->router_id
,
2045 &lsa
->data
->adv_router
)))) {
2046 if (out_if
->network_lsa_self
) {
2047 ospf_lsa_flush_area(
2049 if (IS_DEBUG_OSPF_EVENT
)
2051 "ospf_lsa_discard() in ospf_ls_upd() point 9: lsa %p Type-%d",
2055 ospf_lsa_discard(lsa
);
2065 /* (5) Find the instance of this LSA that is currently contained
2066 in the router's link state database. If there is no
2067 database copy, or the received LSA is more recent than
2068 the database copy the following steps must be performed.
2069 (The sub steps from RFC 2328 section 13 step (5) will be
2074 || (ret
= ospf_lsa_more_recent(current
, lsa
)) < 0) {
2075 /* Actual flooding procedure. */
2076 if (ospf_flood(oi
->ospf
, nbr
, current
, lsa
)
2077 < 0) /* Trap NSSA later. */
2078 DISCARD_LSA(lsa
, 4);
2082 /* (6) Else, If there is an instance of the LSA on the sending
2083 neighbor's Link state request list, an error has occurred in
2084 the Database Exchange process. In this case, restart the
2085 Database Exchange process by generating the neighbor event
2086 BadLSReq for the sending neighbor and stop processing the
2087 Link State Update packet. */
2089 if (ospf_ls_request_lookup(nbr
, lsa
)) {
2090 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_BadLSReq
);
2092 "LSA[%s] instance exists on Link state request list",
2095 /* Clean list of LSAs. */
2096 ospf_upd_list_clean(lsas
);
2097 /* this lsa is not on lsas list already. */
2098 ospf_lsa_discard(lsa
);
2102 /* If the received LSA is the same instance as the database copy
2103 (i.e., neither one is more recent) the following two steps
2104 should be performed: */
2107 /* If the LSA is listed in the Link state retransmission
2109 for the receiving adjacency, the router itself is
2111 an acknowledgment for this LSA. The router should
2113 received LSA as an acknowledgment by removing the LSA
2115 the Link state retransmission list. This is termed
2117 "implied acknowledgment". */
2119 ls_ret
= ospf_ls_retransmit_lookup(nbr
, lsa
);
2121 if (ls_ret
!= NULL
) {
2122 ospf_ls_retransmit_delete(nbr
, ls_ret
);
2124 /* Delayed acknowledgment sent if advertisement
2126 from Designated Router, otherwise do nothing.
2128 if (oi
->state
== ISM_Backup
)
2132 ospf_lsa_lock(lsa
));
2134 DISCARD_LSA(lsa
, 5);
2136 /* Acknowledge the receipt of the LSA by sending a
2137 Link State Acknowledgment packet back out the
2141 ospf_ls_ack_send(nbr
, lsa
);
2142 DISCARD_LSA(lsa
, 6);
2146 /* The database copy is more recent. If the database copy
2147 has LS age equal to MaxAge and LS sequence number equal to
2148 MaxSequenceNumber, simply discard the received LSA without
2149 acknowledging it. (In this case, the LSA's LS sequence number
2151 wrapping, and the MaxSequenceNumber LSA must be completely
2152 flushed before any new LSA instance can be introduced). */
2154 else if (ret
> 0) /* Database copy is more recent */
2156 if (IS_LSA_MAXAGE(current
)
2157 && current
->data
->ls_seqnum
2158 == htonl(OSPF_MAX_SEQUENCE_NUMBER
)) {
2159 DISCARD_LSA(lsa
, 7);
2161 /* Otherwise, as long as the database copy has not been
2163 Link State Update within the last MinLSArrival
2165 database copy back to the sending neighbor,
2167 a Link State Update Packet. The Link State Update
2169 be sent directly to the neighbor. In so doing, do not
2171 database copy of the LSA on the neighbor's link state
2172 retransmission list, and do not acknowledge the
2174 recent) LSA instance. */
2176 if (monotime_since(¤t
->tv_orig
, NULL
)
2177 >= ospf
->min_ls_arrival
* 1000LL)
2178 /* Trap NSSA type later.*/
2179 ospf_ls_upd_send_lsa(
2181 OSPF_SEND_PACKET_DIRECT
);
2182 DISCARD_LSA(lsa
, 8);
2188 assert(listcount(lsas
) == 0);
2189 list_delete_and_null(&lsas
);
2192 /* OSPF Link State Acknowledgment message read -- RFC2328 Section 13.7. */
2193 static void ospf_ls_ack(struct ip
*iph
, struct ospf_header
*ospfh
,
2194 struct stream
*s
, struct ospf_interface
*oi
,
2197 struct ospf_neighbor
*nbr
;
2199 /* increment statistics. */
2202 nbr
= ospf_nbr_lookup(oi
, iph
, ospfh
);
2204 zlog_warn("Link State Acknowledgment: Unknown Neighbor %s.",
2205 inet_ntoa(ospfh
->router_id
));
2209 /* Add event to thread. */
2210 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_PacketReceived
);
2212 if (nbr
->state
< NSM_Exchange
) {
2213 if (IS_DEBUG_OSPF(nsm
, NSM_EVENTS
))
2215 "Link State Acknowledgment: "
2216 "Neighbor[%s] state %s is less than Exchange",
2217 inet_ntoa(ospfh
->router_id
),
2218 lookup_msg(ospf_nsm_state_msg
, nbr
->state
,
2223 while (size
>= OSPF_LSA_HEADER_SIZE
) {
2224 struct ospf_lsa
*lsa
, *lsr
;
2226 lsa
= ospf_lsa_new();
2227 lsa
->data
= (struct lsa_header
*)stream_pnt(s
);
2228 lsa
->vrf_id
= oi
->ospf
->vrf_id
;
2230 /* lsah = (struct lsa_header *) stream_pnt (s); */
2231 size
-= OSPF_LSA_HEADER_SIZE
;
2232 stream_forward_getp(s
, OSPF_LSA_HEADER_SIZE
);
2234 if (lsa
->data
->type
< OSPF_MIN_LSA
2235 || lsa
->data
->type
>= OSPF_MAX_LSA
) {
2237 ospf_lsa_discard(lsa
);
2241 lsr
= ospf_ls_retransmit_lookup(nbr
, lsa
);
2243 if (lsr
!= NULL
&& ospf_lsa_more_recent(lsr
, lsa
) == 0)
2244 ospf_ls_retransmit_delete(nbr
, lsr
);
2247 ospf_lsa_discard(lsa
);
2253 static struct stream
*ospf_recv_packet(struct ospf
*ospf
, int fd
,
2254 struct interface
**ifp
,
2255 struct stream
*ibuf
)
2260 ifindex_t ifindex
= 0;
2262 /* Header and data both require alignment. */
2263 char buff
[CMSG_SPACE(SOPT_SIZE_CMSG_IFINDEX_IPV4())];
2266 memset(&msgh
, 0, sizeof(struct msghdr
));
2267 msgh
.msg_iov
= &iov
;
2268 msgh
.msg_iovlen
= 1;
2269 msgh
.msg_control
= (caddr_t
)buff
;
2270 msgh
.msg_controllen
= sizeof(buff
);
2272 ret
= stream_recvmsg(ibuf
, fd
, &msgh
, 0, OSPF_MAX_PACKET_SIZE
+ 1);
2274 zlog_warn("stream_recvmsg failed: %s", safe_strerror(errno
));
2277 if ((unsigned int)ret
< sizeof(iph
)) /* ret must be > 0 now */
2280 "ospf_recv_packet: discarding runt packet of length %d "
2281 "(ip header size is %u)",
2282 ret
, (unsigned int)sizeof(iph
));
2286 /* Note that there should not be alignment problems with this assignment
2287 because this is at the beginning of the stream data buffer. */
2288 iph
= (struct ip
*)STREAM_DATA(ibuf
);
2289 sockopt_iphdrincl_swab_systoh(iph
);
2291 ip_len
= iph
->ip_len
;
2293 #if !defined(GNU_LINUX) && (OpenBSD < 200311) && (__FreeBSD_version < 1000000)
2295 * Kernel network code touches incoming IP header parameters,
2296 * before protocol specific processing.
2298 * 1) Convert byteorder to host representation.
2299 * --> ip_len, ip_id, ip_off
2301 * 2) Adjust ip_len to strip IP header size!
2302 * --> If user process receives entire IP packet via RAW
2303 * socket, it must consider adding IP header size to
2304 * the "ip_len" field of "ip" structure.
2306 * For more details, see <netinet/ip_input.c>.
2308 ip_len
= ip_len
+ (iph
->ip_hl
<< 2);
2311 #if defined(__DragonFly__)
2313 * in DragonFly's raw socket, ip_len/ip_off are read
2314 * in network byte order.
2315 * As OpenBSD < 200311 adjust ip_len to strip IP header size!
2317 ip_len
= ntohs(iph
->ip_len
) + (iph
->ip_hl
<< 2);
2320 ifindex
= getsockopt_ifindex(AF_INET
, &msgh
);
2322 *ifp
= if_lookup_by_index(ifindex
, ospf
->vrf_id
);
2324 if (ret
!= ip_len
) {
2326 "ospf_recv_packet read length mismatch: ip_len is %d, "
2327 "but recvmsg returned %d",
2335 static struct ospf_interface
*
2336 ospf_associate_packet_vl(struct ospf
*ospf
, struct interface
*ifp
,
2337 struct ip
*iph
, struct ospf_header
*ospfh
)
2339 struct ospf_interface
*rcv_oi
;
2340 struct ospf_vl_data
*vl_data
;
2341 struct ospf_area
*vl_area
;
2342 struct listnode
*node
;
2344 if (IN_MULTICAST(ntohl(iph
->ip_dst
.s_addr
))
2345 || !OSPF_IS_AREA_BACKBONE(ospfh
))
2348 /* look for local OSPF interface matching the destination
2349 * to determine Area ID. We presume therefore the destination address
2350 * is unique, or at least (for "unnumbered" links), not used in other
2353 if ((rcv_oi
= ospf_if_lookup_by_local_addr(ospf
, NULL
, iph
->ip_dst
))
2357 for (ALL_LIST_ELEMENTS_RO(ospf
->vlinks
, node
, vl_data
)) {
2359 ospf_area_lookup_by_area_id(ospf
, vl_data
->vl_area_id
);
2363 if (OSPF_AREA_SAME(&vl_area
, &rcv_oi
->area
)
2364 && IPV4_ADDR_SAME(&vl_data
->vl_peer
, &ospfh
->router_id
)) {
2365 if (IS_DEBUG_OSPF_EVENT
)
2366 zlog_debug("associating packet with %s",
2367 IF_NAME(vl_data
->vl_oi
));
2368 if (!CHECK_FLAG(vl_data
->vl_oi
->ifp
->flags
, IFF_UP
)) {
2369 if (IS_DEBUG_OSPF_EVENT
)
2371 "This VL is not up yet, sorry");
2375 return vl_data
->vl_oi
;
2379 if (IS_DEBUG_OSPF_EVENT
)
2380 zlog_debug("couldn't find any VL to associate the packet with");
2385 static int ospf_check_area_id(struct ospf_interface
*oi
,
2386 struct ospf_header
*ospfh
)
2388 /* Check match the Area ID of the receiving interface. */
2389 if (OSPF_AREA_SAME(&oi
->area
, &ospfh
))
2395 /* Unbound socket will accept any Raw IP packets if proto is matched.
2396 To prevent it, compare src IP address and i/f address with masking
2397 i/f network mask. */
2398 static int ospf_check_network_mask(struct ospf_interface
*oi
,
2399 struct in_addr ip_src
)
2401 struct in_addr mask
, me
, him
;
2403 if (oi
->type
== OSPF_IFTYPE_POINTOPOINT
2404 || oi
->type
== OSPF_IFTYPE_VIRTUALLINK
)
2407 masklen2ip(oi
->address
->prefixlen
, &mask
);
2409 me
.s_addr
= oi
->address
->u
.prefix4
.s_addr
& mask
.s_addr
;
2410 him
.s_addr
= ip_src
.s_addr
& mask
.s_addr
;
2412 if (IPV4_ADDR_SAME(&me
, &him
))
2418 /* Return 1, if the packet is properly authenticated and checksummed,
2419 0 otherwise. In particular, check that AuType header field is valid and
2420 matches the locally configured AuType, and that D.5 requirements are met. */
2421 static int ospf_check_auth(struct ospf_interface
*oi
, struct ospf_header
*ospfh
)
2423 struct crypt_key
*ck
;
2424 uint16_t iface_auth_type
;
2425 uint16_t pkt_auth_type
= ntohs(ospfh
->auth_type
);
2427 switch (pkt_auth_type
) {
2428 case OSPF_AUTH_NULL
: /* RFC2328 D.5.1 */
2429 if (OSPF_AUTH_NULL
!= (iface_auth_type
= ospf_auth_type(oi
))) {
2430 if (IS_DEBUG_OSPF_PACKET(ospfh
->type
- 1, RECV
))
2432 "interface %s: auth-type mismatch, local %s, rcvd Null",
2434 lookup_msg(ospf_auth_type_str
,
2435 iface_auth_type
, NULL
));
2438 if (!ospf_check_sum(ospfh
)) {
2439 if (IS_DEBUG_OSPF_PACKET(ospfh
->type
- 1, RECV
))
2441 "interface %s: Null auth OK, but checksum error, Router-ID %s",
2443 inet_ntoa(ospfh
->router_id
));
2447 case OSPF_AUTH_SIMPLE
: /* RFC2328 D.5.2 */
2448 if (OSPF_AUTH_SIMPLE
2449 != (iface_auth_type
= ospf_auth_type(oi
))) {
2450 if (IS_DEBUG_OSPF_PACKET(ospfh
->type
- 1, RECV
))
2452 "interface %s: auth-type mismatch, local %s, rcvd Simple",
2454 lookup_msg(ospf_auth_type_str
,
2455 iface_auth_type
, NULL
));
2458 if (memcmp(OSPF_IF_PARAM(oi
, auth_simple
), ospfh
->u
.auth_data
,
2459 OSPF_AUTH_SIMPLE_SIZE
)) {
2460 if (IS_DEBUG_OSPF_PACKET(ospfh
->type
- 1, RECV
))
2461 zlog_warn("interface %s: Simple auth failed",
2465 if (!ospf_check_sum(ospfh
)) {
2466 if (IS_DEBUG_OSPF_PACKET(ospfh
->type
- 1, RECV
))
2468 "interface %s: Simple auth OK, checksum error, Router-ID %s",
2470 inet_ntoa(ospfh
->router_id
));
2474 case OSPF_AUTH_CRYPTOGRAPHIC
: /* RFC2328 D.5.3 */
2475 if (OSPF_AUTH_CRYPTOGRAPHIC
2476 != (iface_auth_type
= ospf_auth_type(oi
))) {
2477 if (IS_DEBUG_OSPF_PACKET(ospfh
->type
- 1, RECV
))
2479 "interface %s: auth-type mismatch, local %s, rcvd Cryptographic",
2481 lookup_msg(ospf_auth_type_str
,
2482 iface_auth_type
, NULL
));
2485 if (ospfh
->checksum
) {
2486 if (IS_DEBUG_OSPF_PACKET(ospfh
->type
- 1, RECV
))
2488 "interface %s: OSPF header checksum is not 0",
2492 /* only MD5 crypto method can pass ospf_packet_examin() */
2493 if (NULL
== (ck
= listgetdata(
2494 listtail(OSPF_IF_PARAM(oi
, auth_crypt
))))
2495 || ospfh
->u
.crypt
.key_id
!= ck
->key_id
||
2496 /* Condition above uses the last key ID on the list,
2498 different from what ospf_crypt_key_lookup() does. A
2500 !ospf_check_md5_digest(oi
, ospfh
)) {
2501 if (IS_DEBUG_OSPF_PACKET(ospfh
->type
- 1, RECV
))
2502 zlog_warn("interface %s: MD5 auth failed",
2508 if (IS_DEBUG_OSPF_PACKET(ospfh
->type
- 1, RECV
))
2510 "interface %s: invalid packet auth-type (%02x)",
2511 IF_NAME(oi
), pkt_auth_type
);
2516 static int ospf_check_sum(struct ospf_header
*ospfh
)
2521 /* clear auth_data for checksum. */
2522 memset(ospfh
->u
.auth_data
, 0, OSPF_AUTH_SIMPLE_SIZE
);
2524 /* keep checksum and clear. */
2525 sum
= ospfh
->checksum
;
2526 memset(&ospfh
->checksum
, 0, sizeof(uint16_t));
2528 /* calculate checksum. */
2529 ret
= in_cksum(ospfh
, ntohs(ospfh
->length
));
2532 zlog_info("ospf_check_sum(): checksum mismatch, my %X, his %X",
2540 /* Verify, that given link/TOS records are properly sized/aligned and match
2541 Router-LSA "# links" and "# TOS" fields as specified in RFC2328 A.4.2. */
2542 static unsigned ospf_router_lsa_links_examin(struct router_lsa_link
*link
,
2544 const uint16_t num_links
)
2546 unsigned counted_links
= 0, thislinklen
;
2550 OSPF_ROUTER_LSA_LINK_SIZE
+ 4 * link
->m
[0].tos_count
;
2551 if (thislinklen
> linkbytes
) {
2552 if (IS_DEBUG_OSPF_PACKET(0, RECV
))
2553 zlog_debug("%s: length error in link block #%u",
2554 __func__
, counted_links
);
2557 link
= (struct router_lsa_link
*)((caddr_t
)link
+ thislinklen
);
2558 linkbytes
-= thislinklen
;
2561 if (counted_links
!= num_links
) {
2562 if (IS_DEBUG_OSPF_PACKET(0, RECV
))
2563 zlog_debug("%s: %u link blocks declared, %u present",
2564 __func__
, num_links
, counted_links
);
2570 /* Verify, that the given LSA is properly sized/aligned (including type-specific
2571 minimum length constraint). */
2572 static unsigned ospf_lsa_examin(struct lsa_header
*lsah
, const uint16_t lsalen
,
2573 const uint8_t headeronly
)
2576 struct router_lsa
*rlsa
;
2577 if (lsah
->type
< OSPF_MAX_LSA
&& ospf_lsa_minlen
[lsah
->type
]
2578 && lsalen
< OSPF_LSA_HEADER_SIZE
+ ospf_lsa_minlen
[lsah
->type
]) {
2579 if (IS_DEBUG_OSPF_PACKET(0, RECV
))
2580 zlog_debug("%s: undersized (%u B) %s", __func__
, lsalen
,
2581 lookup_msg(ospf_lsa_type_msg
, lsah
->type
,
2585 switch (lsah
->type
) {
2586 case OSPF_ROUTER_LSA
:
2587 /* RFC2328 A.4.2, LSA header + 4 bytes followed by N>=1
2588 * (12+)-byte link blocks */
2590 ret
= (lsalen
- OSPF_LSA_HEADER_SIZE
2591 - OSPF_ROUTER_LSA_MIN_SIZE
)
2597 rlsa
= (struct router_lsa
*)lsah
;
2598 ret
= ospf_router_lsa_links_examin(
2599 (struct router_lsa_link
*)rlsa
->link
,
2600 lsalen
- OSPF_LSA_HEADER_SIZE
- 4, /* skip: basic
2603 ntohs(rlsa
->links
) /* 16 bits */
2606 case OSPF_AS_EXTERNAL_LSA
:
2607 /* RFC2328 A.4.5, LSA header + 4 bytes followed by N>=1 12-bytes long
2609 case OSPF_AS_NSSA_LSA
:
2610 /* RFC3101 C, idem */
2611 ret
= (lsalen
- OSPF_LSA_HEADER_SIZE
2612 - OSPF_AS_EXTERNAL_LSA_MIN_SIZE
)
2617 /* Following LSA types are considered OK length-wise as soon as their
2619 * length constraint is met and length of the whole LSA is a multiple of
2621 * (basic LSA header size is already a multiple of 4). */
2622 case OSPF_NETWORK_LSA
:
2623 /* RFC2328 A.4.3, LSA header + 4 bytes followed by N>=1 router-IDs */
2624 case OSPF_SUMMARY_LSA
:
2625 case OSPF_ASBR_SUMMARY_LSA
:
2626 /* RFC2328 A.4.4, LSA header + 4 bytes followed by N>=1 4-bytes TOS
2628 case OSPF_OPAQUE_LINK_LSA
:
2629 case OSPF_OPAQUE_AREA_LSA
:
2630 case OSPF_OPAQUE_AS_LSA
:
2631 /* RFC5250 A.2, "some number of octets (of application-specific
2632 * data) padded to 32-bit alignment." This is considered
2634 * to 4-byte alignment of all other LSA types, see
2635 * OSPF-ALIGNMENT.txt
2636 * file for the detailed analysis of this passage. */
2637 ret
= lsalen
% 4 ? MSG_NG
: MSG_OK
;
2640 if (IS_DEBUG_OSPF_PACKET(0, RECV
))
2641 zlog_debug("%s: unsupported LSA type 0x%02x", __func__
,
2645 if (ret
!= MSG_OK
&& IS_DEBUG_OSPF_PACKET(0, RECV
))
2646 zlog_debug("%s: alignment error in %s", __func__
,
2647 lookup_msg(ospf_lsa_type_msg
, lsah
->type
, NULL
));
2651 /* Verify if the provided input buffer is a valid sequence of LSAs. This
2652 includes verification of LSA blocks length/alignment and dispatching
2653 of deeper-level checks. */
2655 ospf_lsaseq_examin(struct lsa_header
*lsah
, /* start of buffered data */
2656 size_t length
, const uint8_t headeronly
,
2657 /* When declared_num_lsas is not 0, compare it to the real
2659 and treat the difference as an error. */
2660 const uint32_t declared_num_lsas
)
2662 uint32_t counted_lsas
= 0;
2666 if (length
< OSPF_LSA_HEADER_SIZE
) {
2667 if (IS_DEBUG_OSPF_PACKET(0, RECV
))
2669 "%s: undersized (%zu B) trailing (#%u) LSA header",
2670 __func__
, length
, counted_lsas
);
2673 /* save on ntohs() calls here and in the LSA validator */
2674 lsalen
= ntohs(lsah
->length
);
2675 if (lsalen
< OSPF_LSA_HEADER_SIZE
) {
2676 if (IS_DEBUG_OSPF_PACKET(0, RECV
))
2678 "%s: malformed LSA header #%u, declared length is %u B",
2679 __func__
, counted_lsas
, lsalen
);
2683 /* less checks here and in ospf_lsa_examin() */
2684 if (MSG_OK
!= ospf_lsa_examin(lsah
, lsalen
, 1)) {
2685 if (IS_DEBUG_OSPF_PACKET(0, RECV
))
2687 "%s: malformed header-only LSA #%u",
2688 __func__
, counted_lsas
);
2691 lsah
= (struct lsa_header
*)((caddr_t
)lsah
2692 + OSPF_LSA_HEADER_SIZE
);
2693 length
-= OSPF_LSA_HEADER_SIZE
;
2695 /* make sure the input buffer is deep enough before
2697 if (lsalen
> length
) {
2698 if (IS_DEBUG_OSPF_PACKET(0, RECV
))
2700 "%s: anomaly in LSA #%u: declared length is %u B, buffered length is %zu B",
2701 __func__
, counted_lsas
, lsalen
,
2705 if (MSG_OK
!= ospf_lsa_examin(lsah
, lsalen
, 0)) {
2706 if (IS_DEBUG_OSPF_PACKET(0, RECV
))
2707 zlog_debug("%s: malformed LSA #%u",
2708 __func__
, counted_lsas
);
2711 lsah
= (struct lsa_header
*)((caddr_t
)lsah
+ lsalen
);
2717 if (declared_num_lsas
&& counted_lsas
!= declared_num_lsas
) {
2718 if (IS_DEBUG_OSPF_PACKET(0, RECV
))
2720 "%s: #LSAs declared (%u) does not match actual (%u)",
2721 __func__
, declared_num_lsas
, counted_lsas
);
2727 /* Verify a complete OSPF packet for proper sizing/alignment. */
2728 static unsigned ospf_packet_examin(struct ospf_header
*oh
,
2729 const unsigned bytesonwire
)
2731 uint16_t bytesdeclared
, bytesauth
;
2733 struct ospf_ls_update
*lsupd
;
2735 /* Length, 1st approximation. */
2736 if (bytesonwire
< OSPF_HEADER_SIZE
) {
2737 if (IS_DEBUG_OSPF_PACKET(0, RECV
))
2738 zlog_debug("%s: undersized (%u B) packet", __func__
,
2742 /* Now it is safe to access header fields. Performing length check,
2744 * for possible extra bytes of crypto auth/padding, which are not
2746 * in the OSPF header "length" field. */
2747 if (oh
->version
!= OSPF_VERSION
) {
2748 if (IS_DEBUG_OSPF_PACKET(0, RECV
))
2749 zlog_debug("%s: invalid (%u) protocol version",
2750 __func__
, oh
->version
);
2753 bytesdeclared
= ntohs(oh
->length
);
2754 if (ntohs(oh
->auth_type
) != OSPF_AUTH_CRYPTOGRAPHIC
)
2757 if (oh
->u
.crypt
.auth_data_len
!= OSPF_AUTH_MD5_SIZE
) {
2758 if (IS_DEBUG_OSPF_PACKET(0, RECV
))
2760 "%s: unsupported crypto auth length (%u B)",
2761 __func__
, oh
->u
.crypt
.auth_data_len
);
2764 bytesauth
= OSPF_AUTH_MD5_SIZE
;
2766 if (bytesdeclared
+ bytesauth
> bytesonwire
) {
2767 if (IS_DEBUG_OSPF_PACKET(0, RECV
))
2769 "%s: packet length error (%u real, %u+%u declared)",
2770 __func__
, bytesonwire
, bytesdeclared
,
2774 /* Length, 2nd approximation. The type-specific constraint is checked
2775 against declared length, not amount of bytes on wire. */
2776 if (oh
->type
>= OSPF_MSG_HELLO
&& oh
->type
<= OSPF_MSG_LS_ACK
2778 < OSPF_HEADER_SIZE
+ ospf_packet_minlen
[oh
->type
]) {
2779 if (IS_DEBUG_OSPF_PACKET(0, RECV
))
2780 zlog_debug("%s: undersized (%u B) %s packet", __func__
,
2782 lookup_msg(ospf_packet_type_str
, oh
->type
,
2787 case OSPF_MSG_HELLO
:
2788 /* RFC2328 A.3.2, packet header + OSPF_HELLO_MIN_SIZE bytes
2790 by N>=0 router-IDs. */
2791 ret
= (bytesdeclared
- OSPF_HEADER_SIZE
- OSPF_HELLO_MIN_SIZE
)
2796 case OSPF_MSG_DB_DESC
:
2797 /* RFC2328 A.3.3, packet header + OSPF_DB_DESC_MIN_SIZE bytes
2799 by N>=0 header-only LSAs. */
2800 ret
= ospf_lsaseq_examin(
2801 (struct lsa_header
*)((caddr_t
)oh
+ OSPF_HEADER_SIZE
2802 + OSPF_DB_DESC_MIN_SIZE
),
2803 bytesdeclared
- OSPF_HEADER_SIZE
2804 - OSPF_DB_DESC_MIN_SIZE
,
2805 1, /* header-only LSAs */
2808 case OSPF_MSG_LS_REQ
:
2809 /* RFC2328 A.3.4, packet header followed by N>=0 12-bytes
2810 * request blocks. */
2811 ret
= (bytesdeclared
- OSPF_HEADER_SIZE
- OSPF_LS_REQ_MIN_SIZE
)
2816 case OSPF_MSG_LS_UPD
:
2817 /* RFC2328 A.3.5, packet header + OSPF_LS_UPD_MIN_SIZE bytes
2819 by N>=0 full LSAs (with N declared beforehand). */
2820 lsupd
= (struct ospf_ls_update
*)((caddr_t
)oh
2821 + OSPF_HEADER_SIZE
);
2822 ret
= ospf_lsaseq_examin(
2823 (struct lsa_header
*)((caddr_t
)lsupd
2824 + OSPF_LS_UPD_MIN_SIZE
),
2825 bytesdeclared
- OSPF_HEADER_SIZE
- OSPF_LS_UPD_MIN_SIZE
,
2827 ntohl(lsupd
->num_lsas
) /* 32 bits */
2830 case OSPF_MSG_LS_ACK
:
2831 /* RFC2328 A.3.6, packet header followed by N>=0 header-only
2833 ret
= ospf_lsaseq_examin(
2834 (struct lsa_header
*)((caddr_t
)oh
+ OSPF_HEADER_SIZE
2835 + OSPF_LS_ACK_MIN_SIZE
),
2836 bytesdeclared
- OSPF_HEADER_SIZE
- OSPF_LS_ACK_MIN_SIZE
,
2837 1, /* header-only LSAs */
2841 if (IS_DEBUG_OSPF_PACKET(0, RECV
))
2842 zlog_debug("%s: invalid packet type 0x%02x", __func__
,
2846 if (ret
!= MSG_OK
&& IS_DEBUG_OSPF_PACKET(0, RECV
))
2847 zlog_debug("%s: malformed %s packet", __func__
,
2848 lookup_msg(ospf_packet_type_str
, oh
->type
, NULL
));
2852 /* OSPF Header verification. */
2853 static int ospf_verify_header(struct stream
*ibuf
, struct ospf_interface
*oi
,
2854 struct ip
*iph
, struct ospf_header
*ospfh
)
2856 /* Check Area ID. */
2857 if (!ospf_check_area_id(oi
, ospfh
)) {
2858 zlog_warn("interface %s: ospf_read invalid Area ID %s.",
2859 IF_NAME(oi
), inet_ntoa(ospfh
->area_id
));
2863 /* Check network mask, Silently discarded. */
2864 if (!ospf_check_network_mask(oi
, iph
->ip_src
)) {
2866 "interface %s: ospf_read network address is not same [%s]",
2867 IF_NAME(oi
), inet_ntoa(iph
->ip_src
));
2871 /* Check authentication. The function handles logging actions, where
2873 if (!ospf_check_auth(oi
, ospfh
))
2879 /* Starting point of packet process function. */
2880 int ospf_read(struct thread
*thread
)
2883 struct stream
*ibuf
;
2885 struct ospf_interface
*oi
;
2887 struct ospf_header
*ospfh
;
2889 struct interface
*ifp
= NULL
;
2890 struct connected
*c
;
2892 /* first of all get interface pointer. */
2893 ospf
= THREAD_ARG(thread
);
2895 /* prepare for next packet. */
2896 ospf
->t_read
= NULL
;
2897 thread_add_read(master
, ospf_read
, ospf
, ospf
->fd
, &ospf
->t_read
);
2899 stream_reset(ospf
->ibuf
);
2900 ibuf
= ospf_recv_packet(ospf
, ospf
->fd
, &ifp
, ospf
->ibuf
);
2903 /* This raw packet is known to be at least as big as its IP header. */
2905 /* Note that there should not be alignment problems with this assignment
2906 because this is at the beginning of the stream data buffer. */
2907 iph
= (struct ip
*)STREAM_DATA(ibuf
);
2908 /* Note that sockopt_iphdrincl_swab_systoh was called in
2909 * ospf_recv_packet. */
2912 /* Handle cases where the platform does not support retrieving
2914 and also platforms (such as Solaris 8) that claim to support
2916 retrieval but do not. */
2917 c
= if_lookup_address((void *)&iph
->ip_src
, AF_INET
,
2925 /* IP Header dump. */
2926 if (IS_DEBUG_OSPF_PACKET(0, RECV
))
2927 ospf_ip_header_dump(iph
);
2929 /* Self-originated packet should be discarded silently. */
2930 if (ospf_if_lookup_by_local_addr(ospf
, NULL
, iph
->ip_src
)) {
2931 if (IS_DEBUG_OSPF_PACKET(0, RECV
)) {
2933 "ospf_read[%s]: Dropping self-originated packet",
2934 inet_ntoa(iph
->ip_src
));
2939 /* Advance from IP header to OSPF header (iph->ip_hl has been verified
2940 by ospf_recv_packet() to be correct). */
2941 stream_forward_getp(ibuf
, iph
->ip_hl
* 4);
2943 ospfh
= (struct ospf_header
*)stream_pnt(ibuf
);
2945 != ospf_packet_examin(
2946 ospfh
, stream_get_endp(ibuf
) - stream_get_getp(ibuf
)))
2948 /* Now it is safe to access all fields of OSPF packet header. */
2950 /* associate packet with ospf interface */
2951 oi
= ospf_if_lookup_recv_if(ospf
, iph
->ip_src
, ifp
);
2953 /* ospf_verify_header() relies on a valid "oi" and thus can be called
2955 after the passive/backbone/other checks below are passed. These
2957 in turn access the fields of unverified "ospfh" structure for their
2959 purposes and must remain very accurate in doing this. */
2961 /* If incoming interface is passive one, ignore it. */
2962 if (oi
&& OSPF_IF_PASSIVE_STATUS(oi
) == OSPF_IF_PASSIVE
) {
2963 char buf
[3][INET_ADDRSTRLEN
];
2965 if (IS_DEBUG_OSPF_EVENT
)
2967 "ignoring packet from router %s sent to %s, "
2968 "received on a passive interface, %s",
2969 inet_ntop(AF_INET
, &ospfh
->router_id
, buf
[0],
2971 inet_ntop(AF_INET
, &iph
->ip_dst
, buf
[1],
2973 inet_ntop(AF_INET
, &oi
->address
->u
.prefix4
,
2974 buf
[2], sizeof(buf
[2])));
2976 if (iph
->ip_dst
.s_addr
== htonl(OSPF_ALLSPFROUTERS
)) {
2977 /* Try to fix multicast membership.
2978 * Some OS:es may have problems in this area,
2979 * make sure it is removed.
2981 OI_MEMBER_JOINED(oi
, MEMBER_ALLROUTERS
);
2982 ospf_if_set_multicast(oi
);
2988 /* if no local ospf_interface,
2989 * or header area is backbone but ospf_interface is not
2990 * check for VLINK interface
2992 if ((oi
== NULL
) || (OSPF_IS_AREA_ID_BACKBONE(ospfh
->area_id
)
2993 && !OSPF_IS_AREA_ID_BACKBONE(oi
->area
->area_id
))) {
2994 if ((oi
= ospf_associate_packet_vl(ospf
, ifp
, iph
, ospfh
))
2996 if (!ospf
->instance
&& IS_DEBUG_OSPF_EVENT
)
2998 "Packet from [%s] received on link %s"
2999 " but no ospf_interface",
3000 inet_ntoa(iph
->ip_src
), ifp
->name
);
3005 /* else it must be a local ospf interface, check it was received on
3008 else if (oi
->ifp
!= ifp
) {
3009 if (IS_DEBUG_OSPF_EVENT
)
3010 zlog_warn("Packet from [%s] received on wrong link %s",
3011 inet_ntoa(iph
->ip_src
), ifp
->name
);
3013 } else if (oi
->state
== ISM_Down
) {
3014 char buf
[2][INET_ADDRSTRLEN
];
3016 "Ignoring packet from %s to %s received on interface that is "
3017 "down [%s]; interface flags are %s",
3018 inet_ntop(AF_INET
, &iph
->ip_src
, buf
[0],
3020 inet_ntop(AF_INET
, &iph
->ip_dst
, buf
[1],
3022 ifp
->name
, if_flag_dump(ifp
->flags
));
3023 /* Fix multicast memberships? */
3024 if (iph
->ip_dst
.s_addr
== htonl(OSPF_ALLSPFROUTERS
))
3025 OI_MEMBER_JOINED(oi
, MEMBER_ALLROUTERS
);
3026 else if (iph
->ip_dst
.s_addr
== htonl(OSPF_ALLDROUTERS
))
3027 OI_MEMBER_JOINED(oi
, MEMBER_DROUTERS
);
3028 if (oi
->multicast_memberships
)
3029 ospf_if_set_multicast(oi
);
3034 * If the received packet is destined for AllDRouters, the packet
3035 * should be accepted only if the received ospf interface state is
3036 * either DR or Backup -- endo.
3038 if (iph
->ip_dst
.s_addr
== htonl(OSPF_ALLDROUTERS
)
3039 && (oi
->state
!= ISM_DR
&& oi
->state
!= ISM_Backup
)) {
3041 "Dropping packet for AllDRouters from [%s] via [%s] (ISM: %s)",
3042 inet_ntoa(iph
->ip_src
), IF_NAME(oi
),
3043 lookup_msg(ospf_ism_state_msg
, oi
->state
, NULL
));
3044 /* Try to fix multicast membership. */
3045 SET_FLAG(oi
->multicast_memberships
, MEMBER_DROUTERS
);
3046 ospf_if_set_multicast(oi
);
3050 /* Verify more OSPF header fields. */
3051 ret
= ospf_verify_header(ibuf
, oi
, iph
, ospfh
);
3053 if (IS_DEBUG_OSPF_PACKET(0, RECV
))
3055 "ospf_read[%s]: Header check failed, "
3057 inet_ntoa(iph
->ip_src
));
3061 /* Show debug receiving packet. */
3062 if (IS_DEBUG_OSPF_PACKET(ospfh
->type
- 1, RECV
)) {
3063 if (IS_DEBUG_OSPF_PACKET(ospfh
->type
- 1, DETAIL
)) {
3065 "-----------------------------------------------------");
3066 ospf_packet_dump(ibuf
);
3069 zlog_debug("%s received from [%s] via [%s]",
3070 lookup_msg(ospf_packet_type_str
, ospfh
->type
, NULL
),
3071 inet_ntoa(ospfh
->router_id
), IF_NAME(oi
));
3072 zlog_debug(" src [%s],", inet_ntoa(iph
->ip_src
));
3073 zlog_debug(" dst [%s]", inet_ntoa(iph
->ip_dst
));
3075 if (IS_DEBUG_OSPF_PACKET(ospfh
->type
- 1, DETAIL
))
3077 "-----------------------------------------------------");
3080 stream_forward_getp(ibuf
, OSPF_HEADER_SIZE
);
3082 /* Adjust size to message length. */
3083 length
= ntohs(ospfh
->length
) - OSPF_HEADER_SIZE
;
3085 /* Read rest of the packet and call each sort of packet routine. */
3086 switch (ospfh
->type
) {
3087 case OSPF_MSG_HELLO
:
3088 ospf_hello(iph
, ospfh
, ibuf
, oi
, length
);
3090 case OSPF_MSG_DB_DESC
:
3091 ospf_db_desc(iph
, ospfh
, ibuf
, oi
, length
);
3093 case OSPF_MSG_LS_REQ
:
3094 ospf_ls_req(iph
, ospfh
, ibuf
, oi
, length
);
3096 case OSPF_MSG_LS_UPD
:
3097 ospf_ls_upd(ospf
, iph
, ospfh
, ibuf
, oi
, length
);
3099 case OSPF_MSG_LS_ACK
:
3100 ospf_ls_ack(iph
, ospfh
, ibuf
, oi
, length
);
3103 zlog_warn("interface %s: OSPF packet header type %d is illegal",
3104 IF_NAME(oi
), ospfh
->type
);
3111 /* Make OSPF header. */
3112 static void ospf_make_header(int type
, struct ospf_interface
*oi
,
3115 struct ospf_header
*ospfh
;
3117 ospfh
= (struct ospf_header
*)STREAM_DATA(s
);
3119 ospfh
->version
= (uint8_t)OSPF_VERSION
;
3120 ospfh
->type
= (uint8_t)type
;
3122 ospfh
->router_id
= oi
->ospf
->router_id
;
3124 ospfh
->checksum
= 0;
3125 ospfh
->area_id
= oi
->area
->area_id
;
3126 ospfh
->auth_type
= htons(ospf_auth_type(oi
));
3128 memset(ospfh
->u
.auth_data
, 0, OSPF_AUTH_SIMPLE_SIZE
);
3130 stream_forward_endp(s
, OSPF_HEADER_SIZE
);
3133 /* Make Authentication Data. */
3134 static int ospf_make_auth(struct ospf_interface
*oi
, struct ospf_header
*ospfh
)
3136 struct crypt_key
*ck
;
3138 switch (ospf_auth_type(oi
)) {
3139 case OSPF_AUTH_NULL
:
3140 /* memset (ospfh->u.auth_data, 0, sizeof (ospfh->u.auth_data));
3143 case OSPF_AUTH_SIMPLE
:
3144 memcpy(ospfh
->u
.auth_data
, OSPF_IF_PARAM(oi
, auth_simple
),
3145 OSPF_AUTH_SIMPLE_SIZE
);
3147 case OSPF_AUTH_CRYPTOGRAPHIC
:
3148 /* If key is not set, then set 0. */
3149 if (list_isempty(OSPF_IF_PARAM(oi
, auth_crypt
))) {
3150 ospfh
->u
.crypt
.zero
= 0;
3151 ospfh
->u
.crypt
.key_id
= 0;
3152 ospfh
->u
.crypt
.auth_data_len
= OSPF_AUTH_MD5_SIZE
;
3155 listtail(OSPF_IF_PARAM(oi
, auth_crypt
)));
3156 ospfh
->u
.crypt
.zero
= 0;
3157 ospfh
->u
.crypt
.key_id
= ck
->key_id
;
3158 ospfh
->u
.crypt
.auth_data_len
= OSPF_AUTH_MD5_SIZE
;
3160 /* note: the seq is done in ospf_make_md5_digest() */
3163 /* memset (ospfh->u.auth_data, 0, sizeof (ospfh->u.auth_data));
3171 /* Fill rest of OSPF header. */
3172 static void ospf_fill_header(struct ospf_interface
*oi
, struct stream
*s
,
3175 struct ospf_header
*ospfh
;
3177 ospfh
= (struct ospf_header
*)STREAM_DATA(s
);
3180 ospfh
->length
= htons(length
);
3182 /* Calculate checksum. */
3183 if (ntohs(ospfh
->auth_type
) != OSPF_AUTH_CRYPTOGRAPHIC
)
3184 ospfh
->checksum
= in_cksum(ospfh
, length
);
3186 ospfh
->checksum
= 0;
3188 /* Add Authentication Data. */
3189 ospf_make_auth(oi
, ospfh
);
3192 static int ospf_make_hello(struct ospf_interface
*oi
, struct stream
*s
)
3194 struct ospf_neighbor
*nbr
;
3195 struct route_node
*rn
;
3196 uint16_t length
= OSPF_HELLO_MIN_SIZE
;
3197 struct in_addr mask
;
3201 /* Set netmask of interface. */
3202 if (!(CHECK_FLAG(oi
->connected
->flags
, ZEBRA_IFA_UNNUMBERED
)
3203 && oi
->type
== OSPF_IFTYPE_POINTOPOINT
)
3204 && oi
->type
!= OSPF_IFTYPE_VIRTUALLINK
)
3205 masklen2ip(oi
->address
->prefixlen
, &mask
);
3207 memset((char *)&mask
, 0, sizeof(struct in_addr
));
3208 stream_put_ipv4(s
, mask
.s_addr
);
3210 /* Set Hello Interval. */
3211 if (OSPF_IF_PARAM(oi
, fast_hello
) == 0)
3212 stream_putw(s
, OSPF_IF_PARAM(oi
, v_hello
));
3214 stream_putw(s
, 0); /* hello-interval of 0 for fast-hellos */
3216 if (IS_DEBUG_OSPF_EVENT
)
3217 zlog_debug("make_hello: options: %x, int: %s", OPTIONS(oi
),
3221 stream_putc(s
, OPTIONS(oi
));
3223 /* Set Router Priority. */
3224 stream_putc(s
, PRIORITY(oi
));
3226 /* Set Router Dead Interval. */
3227 stream_putl(s
, OSPF_IF_PARAM(oi
, v_wait
));
3229 /* Set Designated Router. */
3230 stream_put_ipv4(s
, DR(oi
).s_addr
);
3232 p
= stream_get_endp(s
);
3234 /* Set Backup Designated Router. */
3235 stream_put_ipv4(s
, BDR(oi
).s_addr
);
3237 /* Add neighbor seen. */
3238 for (rn
= route_top(oi
->nbrs
); rn
; rn
= route_next(rn
))
3239 if ((nbr
= rn
->info
))
3240 if (nbr
->router_id
.s_addr
3241 != 0) /* Ignore 0.0.0.0 node. */
3243 != NSM_Attempt
) /* Ignore Down neighbor. */
3245 != NSM_Down
) /* This is myself for
3247 if (!IPV4_ADDR_SAME(
3249 &oi
->ospf
->router_id
)) {
3250 /* Check neighbor is
3252 if (nbr
->d_router
.s_addr
3273 /* Let neighbor generate BackupSeen. */
3275 stream_putl_at(s
, p
, 0); /* ipv4 address, normally */
3280 static int ospf_make_db_desc(struct ospf_interface
*oi
,
3281 struct ospf_neighbor
*nbr
, struct stream
*s
)
3283 struct ospf_lsa
*lsa
;
3284 uint16_t length
= OSPF_DB_DESC_MIN_SIZE
;
3288 struct ospf_lsdb
*lsdb
;
3290 /* Set Interface MTU. */
3291 if (oi
->type
== OSPF_IFTYPE_VIRTUALLINK
)
3294 stream_putw(s
, oi
->ifp
->mtu
);
3297 options
= OPTIONS(oi
);
3298 if (CHECK_FLAG(oi
->ospf
->config
, OSPF_OPAQUE_CAPABLE
))
3299 SET_FLAG(options
, OSPF_OPTION_O
);
3300 stream_putc(s
, options
);
3303 pp
= stream_get_endp(s
);
3304 stream_putc(s
, nbr
->dd_flags
);
3306 /* Set DD Sequence Number. */
3307 stream_putl(s
, nbr
->dd_seqnum
);
3309 /* shortcut unneeded walk of (empty) summary LSDBs */
3310 if (ospf_db_summary_isempty(nbr
))
3313 /* Describe LSA Header from Database Summary List. */
3314 lsdb
= &nbr
->db_sum
;
3316 for (i
= OSPF_MIN_LSA
; i
< OSPF_MAX_LSA
; i
++) {
3317 struct route_table
*table
= lsdb
->type
[i
].db
;
3318 struct route_node
*rn
;
3320 for (rn
= route_top(table
); rn
; rn
= route_next(rn
))
3321 if ((lsa
= rn
->info
) != NULL
) {
3322 if (IS_OPAQUE_LSA(lsa
->data
->type
)
3323 && (!CHECK_FLAG(options
, OSPF_OPTION_O
))) {
3324 /* Suppress advertising
3325 * opaque-informations. */
3326 /* Remove LSA from DB summary list. */
3327 ospf_lsdb_delete(lsdb
, lsa
);
3331 if (!CHECK_FLAG(lsa
->flags
, OSPF_LSA_DISCARD
)) {
3332 struct lsa_header
*lsah
;
3335 /* DD packet overflows interface MTU. */
3336 if (length
+ OSPF_LSA_HEADER_SIZE
3337 > ospf_packet_max(oi
))
3340 /* Keep pointer to LS age. */
3341 lsah
= (struct lsa_header
3346 /* Proceed stream pointer. */
3347 stream_put(s
, lsa
->data
,
3348 OSPF_LSA_HEADER_SIZE
);
3349 length
+= OSPF_LSA_HEADER_SIZE
;
3352 ls_age
= LS_AGE(lsa
);
3353 lsah
->ls_age
= htons(ls_age
);
3356 /* Remove LSA from DB summary list. */
3357 ospf_lsdb_delete(lsdb
, lsa
);
3361 /* Update 'More' bit */
3362 if (ospf_db_summary_isempty(nbr
)) {
3364 if (nbr
->state
>= NSM_Exchange
) {
3365 UNSET_FLAG(nbr
->dd_flags
, OSPF_DD_FLAG_M
);
3366 /* Rewrite DD flags */
3367 stream_putc_at(s
, pp
, nbr
->dd_flags
);
3369 assert(IS_SET_DD_M(nbr
->dd_flags
));
3375 static int ospf_make_ls_req_func(struct stream
*s
, uint16_t *length
,
3376 unsigned long delta
, struct ospf_neighbor
*nbr
,
3377 struct ospf_lsa
*lsa
)
3379 struct ospf_interface
*oi
;
3383 /* LS Request packet overflows interface MTU. */
3384 if (*length
+ delta
> ospf_packet_max(oi
))
3387 stream_putl(s
, lsa
->data
->type
);
3388 stream_put_ipv4(s
, lsa
->data
->id
.s_addr
);
3389 stream_put_ipv4(s
, lsa
->data
->adv_router
.s_addr
);
3391 ospf_lsa_unlock(&nbr
->ls_req_last
);
3392 nbr
->ls_req_last
= ospf_lsa_lock(lsa
);
3398 static int ospf_make_ls_req(struct ospf_neighbor
*nbr
, struct stream
*s
)
3400 struct ospf_lsa
*lsa
;
3401 uint16_t length
= OSPF_LS_REQ_MIN_SIZE
;
3402 unsigned long delta
= stream_get_endp(s
) + 12;
3403 struct route_table
*table
;
3404 struct route_node
*rn
;
3406 struct ospf_lsdb
*lsdb
;
3408 lsdb
= &nbr
->ls_req
;
3410 for (i
= OSPF_MIN_LSA
; i
< OSPF_MAX_LSA
; i
++) {
3411 table
= lsdb
->type
[i
].db
;
3412 for (rn
= route_top(table
); rn
; rn
= route_next(rn
))
3413 if ((lsa
= (rn
->info
)) != NULL
)
3414 if (ospf_make_ls_req_func(s
, &length
, delta
,
3417 route_unlock_node(rn
);
3424 static int ls_age_increment(struct ospf_lsa
*lsa
, int delay
)
3428 age
= IS_LSA_MAXAGE(lsa
) ? OSPF_LSA_MAXAGE
: LS_AGE(lsa
) + delay
;
3430 return (age
> OSPF_LSA_MAXAGE
? OSPF_LSA_MAXAGE
: age
);
3433 static int ospf_make_ls_upd(struct ospf_interface
*oi
, struct list
*update
,
3436 struct ospf_lsa
*lsa
;
3437 struct listnode
*node
;
3438 uint16_t length
= 0;
3439 unsigned int size_noauth
;
3440 unsigned long delta
= stream_get_endp(s
);
3444 if (IS_DEBUG_OSPF_EVENT
)
3445 zlog_debug("ospf_make_ls_upd: Start");
3447 pp
= stream_get_endp(s
);
3448 stream_forward_endp(s
, OSPF_LS_UPD_MIN_SIZE
);
3449 length
+= OSPF_LS_UPD_MIN_SIZE
;
3451 /* Calculate amount of packet usable for data. */
3452 size_noauth
= stream_get_size(s
) - ospf_packet_authspace(oi
);
3454 while ((node
= listhead(update
)) != NULL
) {
3455 struct lsa_header
*lsah
;
3458 if (IS_DEBUG_OSPF_EVENT
)
3459 zlog_debug("ospf_make_ls_upd: List Iteration %d",
3462 lsa
= listgetdata(node
);
3467 if (length
+ delta
+ ntohs(lsa
->data
->length
) > size_noauth
)
3470 /* Keep pointer to LS age. */
3471 lsah
= (struct lsa_header
*)(STREAM_DATA(s
)
3472 + stream_get_endp(s
));
3474 /* Put LSA to Link State Request. */
3475 stream_put(s
, lsa
->data
, ntohs(lsa
->data
->length
));
3478 /* each hop must increment an lsa_age by transmit_delay
3479 of OSPF interface */
3480 ls_age
= ls_age_increment(lsa
,
3481 OSPF_IF_PARAM(oi
, transmit_delay
));
3482 lsah
->ls_age
= htons(ls_age
);
3484 length
+= ntohs(lsa
->data
->length
);
3487 list_delete_node(update
, node
);
3488 ospf_lsa_unlock(&lsa
); /* oi->ls_upd_queue */
3491 /* Now set #LSAs. */
3492 stream_putl_at(s
, pp
, count
);
3494 if (IS_DEBUG_OSPF_EVENT
)
3495 zlog_debug("ospf_make_ls_upd: Stop");
3499 static int ospf_make_ls_ack(struct ospf_interface
*oi
, struct list
*ack
,
3502 struct listnode
*node
, *nnode
;
3503 uint16_t length
= OSPF_LS_ACK_MIN_SIZE
;
3504 unsigned long delta
= stream_get_endp(s
) + 24;
3505 struct ospf_lsa
*lsa
;
3507 for (ALL_LIST_ELEMENTS(ack
, node
, nnode
, lsa
)) {
3510 if (length
+ delta
> ospf_packet_max(oi
))
3513 stream_put(s
, lsa
->data
, OSPF_LSA_HEADER_SIZE
);
3514 length
+= OSPF_LSA_HEADER_SIZE
;
3516 listnode_delete(ack
, lsa
);
3517 ospf_lsa_unlock(&lsa
); /* oi->ls_ack_direct.ls_ack */
3523 static void ospf_hello_send_sub(struct ospf_interface
*oi
, in_addr_t addr
)
3525 struct ospf_packet
*op
;
3526 uint16_t length
= OSPF_HEADER_SIZE
;
3528 op
= ospf_packet_new(oi
->ifp
->mtu
);
3530 /* Prepare OSPF common header. */
3531 ospf_make_header(OSPF_MSG_HELLO
, oi
, op
->s
);
3533 /* Prepare OSPF Hello body. */
3534 length
+= ospf_make_hello(oi
, op
->s
);
3536 /* Fill OSPF header. */
3537 ospf_fill_header(oi
, op
->s
, length
);
3539 /* Set packet length. */
3540 op
->length
= length
;
3542 op
->dst
.s_addr
= addr
;
3544 if (IS_DEBUG_OSPF_EVENT
) {
3545 if (oi
->ospf
->vrf_id
)
3547 "%s: Hello Tx interface %s ospf vrf %s id %u",
3548 __PRETTY_FUNCTION__
, oi
->ifp
->name
,
3549 ospf_vrf_id_to_name(oi
->ospf
->vrf_id
),
3552 /* Add packet to the top of the interface output queue, so that they
3553 * can't get delayed by things like long queues of LS Update packets
3555 ospf_packet_add_top(oi
, op
);
3557 /* Hook thread to write packet. */
3558 OSPF_ISM_WRITE_ON(oi
->ospf
);
3561 static void ospf_poll_send(struct ospf_nbr_nbma
*nbr_nbma
)
3563 struct ospf_interface
*oi
;
3568 /* If this is passive interface, do not send OSPF Hello. */
3569 if (OSPF_IF_PASSIVE_STATUS(oi
) == OSPF_IF_PASSIVE
)
3572 if (oi
->type
!= OSPF_IFTYPE_NBMA
)
3575 if (nbr_nbma
->nbr
!= NULL
&& nbr_nbma
->nbr
->state
!= NSM_Down
)
3578 if (PRIORITY(oi
) == 0)
3581 if (nbr_nbma
->priority
== 0 && oi
->state
!= ISM_DR
3582 && oi
->state
!= ISM_Backup
)
3585 ospf_hello_send_sub(oi
, nbr_nbma
->addr
.s_addr
);
3588 int ospf_poll_timer(struct thread
*thread
)
3590 struct ospf_nbr_nbma
*nbr_nbma
;
3592 nbr_nbma
= THREAD_ARG(thread
);
3593 nbr_nbma
->t_poll
= NULL
;
3595 if (IS_DEBUG_OSPF(nsm
, NSM_TIMERS
))
3596 zlog_debug("NSM[%s:%s]: Timer (Poll timer expire)",
3597 IF_NAME(nbr_nbma
->oi
), inet_ntoa(nbr_nbma
->addr
));
3599 ospf_poll_send(nbr_nbma
);
3601 if (nbr_nbma
->v_poll
> 0)
3602 OSPF_POLL_TIMER_ON(nbr_nbma
->t_poll
, ospf_poll_timer
,
3609 int ospf_hello_reply_timer(struct thread
*thread
)
3611 struct ospf_neighbor
*nbr
;
3613 nbr
= THREAD_ARG(thread
);
3614 nbr
->t_hello_reply
= NULL
;
3618 if (IS_DEBUG_OSPF(nsm
, NSM_TIMERS
))
3619 zlog_debug("NSM[%s:%s]: Timer (hello-reply timer expire)",
3620 IF_NAME(nbr
->oi
), inet_ntoa(nbr
->router_id
));
3622 ospf_hello_send_sub(nbr
->oi
, nbr
->address
.u
.prefix4
.s_addr
);
3627 /* Send OSPF Hello. */
3628 void ospf_hello_send(struct ospf_interface
*oi
)
3630 /* If this is passive interface, do not send OSPF Hello. */
3631 if (OSPF_IF_PASSIVE_STATUS(oi
) == OSPF_IF_PASSIVE
)
3634 if (oi
->type
== OSPF_IFTYPE_NBMA
) {
3635 struct ospf_neighbor
*nbr
;
3636 struct route_node
*rn
;
3638 for (rn
= route_top(oi
->nbrs
); rn
; rn
= route_next(rn
))
3639 if ((nbr
= rn
->info
))
3640 if (nbr
!= oi
->nbr_self
)
3641 if (nbr
->state
!= NSM_Down
) {
3642 /* RFC 2328 Section 9.5.1
3643 If the router is not
3644 eligible to become Designated
3646 it must periodically send
3647 Hello Packets to both the
3648 Designated Router and the
3649 Backup Designated Router (if
3652 if (PRIORITY(oi
) == 0
3663 /* If the router is eligible to
3664 become Designated Router, it
3665 must periodically send Hello
3666 Packets to all neighbors that
3667 are also eligible. In
3668 addition, if the router is
3670 Designated Router or Backup
3671 Designated Router, it must
3673 send periodic Hello Packets
3674 to all other neighbors. */
3676 if (nbr
->priority
== 0
3677 && oi
->state
== ISM_DROther
)
3679 /* if oi->state == Waiting, send
3680 * hello to all neighbors */
3681 ospf_hello_send_sub(
3683 nbr
->address
.u
.prefix4
3687 /* Decide destination address. */
3688 if (oi
->type
== OSPF_IFTYPE_VIRTUALLINK
)
3689 ospf_hello_send_sub(oi
, oi
->vl_data
->peer_addr
.s_addr
);
3691 ospf_hello_send_sub(oi
, htonl(OSPF_ALLSPFROUTERS
));
3695 /* Send OSPF Database Description. */
3696 void ospf_db_desc_send(struct ospf_neighbor
*nbr
)
3698 struct ospf_interface
*oi
;
3699 struct ospf_packet
*op
;
3700 uint16_t length
= OSPF_HEADER_SIZE
;
3703 op
= ospf_packet_new(oi
->ifp
->mtu
);
3705 /* Prepare OSPF common header. */
3706 ospf_make_header(OSPF_MSG_DB_DESC
, oi
, op
->s
);
3708 /* Prepare OSPF Database Description body. */
3709 length
+= ospf_make_db_desc(oi
, nbr
, op
->s
);
3711 /* Fill OSPF header. */
3712 ospf_fill_header(oi
, op
->s
, length
);
3714 /* Set packet length. */
3715 op
->length
= length
;
3717 /* Decide destination address. */
3718 if (oi
->type
== OSPF_IFTYPE_POINTOPOINT
)
3719 op
->dst
.s_addr
= htonl(OSPF_ALLSPFROUTERS
);
3721 op
->dst
= nbr
->address
.u
.prefix4
;
3723 /* Add packet to the interface output queue. */
3724 ospf_packet_add(oi
, op
);
3726 /* Hook thread to write packet. */
3727 OSPF_ISM_WRITE_ON(oi
->ospf
);
3729 /* Remove old DD packet, then copy new one and keep in neighbor
3732 ospf_packet_free(nbr
->last_send
);
3733 nbr
->last_send
= ospf_packet_dup(op
);
3734 monotime(&nbr
->last_send_ts
);
3737 /* Re-send Database Description. */
3738 void ospf_db_desc_resend(struct ospf_neighbor
*nbr
)
3740 struct ospf_interface
*oi
;
3744 /* Add packet to the interface output queue. */
3745 ospf_packet_add(oi
, ospf_packet_dup(nbr
->last_send
));
3747 /* Hook thread to write packet. */
3748 OSPF_ISM_WRITE_ON(oi
->ospf
);
3751 /* Send Link State Request. */
3752 void ospf_ls_req_send(struct ospf_neighbor
*nbr
)
3754 struct ospf_interface
*oi
;
3755 struct ospf_packet
*op
;
3756 uint16_t length
= OSPF_HEADER_SIZE
;
3759 op
= ospf_packet_new(oi
->ifp
->mtu
);
3761 /* Prepare OSPF common header. */
3762 ospf_make_header(OSPF_MSG_LS_REQ
, oi
, op
->s
);
3764 /* Prepare OSPF Link State Request body. */
3765 length
+= ospf_make_ls_req(nbr
, op
->s
);
3766 if (length
== OSPF_HEADER_SIZE
) {
3767 ospf_packet_free(op
);
3771 /* Fill OSPF header. */
3772 ospf_fill_header(oi
, op
->s
, length
);
3774 /* Set packet length. */
3775 op
->length
= length
;
3777 /* Decide destination address. */
3778 if (oi
->type
== OSPF_IFTYPE_POINTOPOINT
)
3779 op
->dst
.s_addr
= htonl(OSPF_ALLSPFROUTERS
);
3781 op
->dst
= nbr
->address
.u
.prefix4
;
3783 /* Add packet to the interface output queue. */
3784 ospf_packet_add(oi
, op
);
3786 /* Hook thread to write packet. */
3787 OSPF_ISM_WRITE_ON(oi
->ospf
);
3789 /* Add Link State Request Retransmission Timer. */
3790 OSPF_NSM_TIMER_ON(nbr
->t_ls_req
, ospf_ls_req_timer
, nbr
->v_ls_req
);
3793 /* Send Link State Update with an LSA. */
3794 void ospf_ls_upd_send_lsa(struct ospf_neighbor
*nbr
, struct ospf_lsa
*lsa
,
3797 struct list
*update
;
3799 update
= list_new();
3801 listnode_add(update
, lsa
);
3803 /*ospf instance is going down, send self originated
3804 * MAXAGE LSA update to neighbors to remove from LSDB */
3805 if (nbr
->oi
->ospf
->inst_shutdown
&& IS_LSA_MAXAGE(lsa
))
3806 ospf_ls_upd_send(nbr
, update
, flag
, 1);
3808 ospf_ls_upd_send(nbr
, update
, flag
, 0);
3810 list_delete_and_null(&update
);
3813 /* Determine size for packet. Must be at least big enough to accomodate next
3814 * LSA on list, which may be bigger than MTU size.
3816 * Return pointer to new ospf_packet
3817 * NULL if we can not allocate, eg because LSA is bigger than imposed limit
3818 * on packet sizes (in which case offending LSA is deleted from update list)
3820 static struct ospf_packet
*ospf_ls_upd_packet_new(struct list
*update
,
3821 struct ospf_interface
*oi
)
3823 struct ospf_lsa
*lsa
;
3824 struct listnode
*ln
;
3826 static char warned
= 0;
3828 lsa
= listgetdata((ln
= listhead(update
)));
3831 if ((OSPF_LS_UPD_MIN_SIZE
+ ntohs(lsa
->data
->length
))
3832 > ospf_packet_max(oi
)) {
3835 "ospf_ls_upd_packet_new: oversized LSA encountered!"
3836 "will need to fragment. Not optimal. Try divide up"
3837 " your network with areas. Use 'debug ospf packet send'"
3838 " to see details, or look at 'show ip ospf database ..'");
3842 if (IS_DEBUG_OSPF_PACKET(0, SEND
))
3844 "ospf_ls_upd_packet_new: oversized LSA id:%s,"
3845 " %d bytes originated by %s, will be fragmented!",
3846 inet_ntoa(lsa
->data
->id
),
3847 ntohs(lsa
->data
->length
),
3848 inet_ntoa(lsa
->data
->adv_router
));
3851 * Allocate just enough to fit this LSA only, to avoid including
3853 * LSAs in fragmented LSA Updates.
3855 size
= ntohs(lsa
->data
->length
)
3856 + (oi
->ifp
->mtu
- ospf_packet_max(oi
))
3857 + OSPF_LS_UPD_MIN_SIZE
;
3859 size
= oi
->ifp
->mtu
;
3861 if (size
> OSPF_MAX_PACKET_SIZE
) {
3863 "ospf_ls_upd_packet_new: oversized LSA id:%s too big,"
3864 " %d bytes, packet size %ld, dropping it completely."
3865 " OSPF routing is broken!",
3866 inet_ntoa(lsa
->data
->id
), ntohs(lsa
->data
->length
),
3868 list_delete_node(update
, ln
);
3872 /* IP header is built up separately by ospf_write(). This means, that we
3874 * reduce the "affordable" size just calculated by length of an IP
3876 * This makes sure, that even if we manage to fill the payload with LSA
3878 * completely, the final packet (our data plus IP header) still fits
3880 * outgoing interface MTU. This correction isn't really meaningful for
3882 * oversized LSA, but for consistency the correction is done for both
3885 * P.S. OSPF_MAX_PACKET_SIZE above already includes IP header size
3887 return ospf_packet_new(size
- sizeof(struct ip
));
3890 static void ospf_ls_upd_queue_send(struct ospf_interface
*oi
,
3891 struct list
*update
, struct in_addr addr
,
3894 struct ospf_packet
*op
;
3895 uint16_t length
= OSPF_HEADER_SIZE
;
3897 if (IS_DEBUG_OSPF_EVENT
)
3898 zlog_debug("listcount = %d, [%s]dst %s", listcount(update
),
3899 IF_NAME(oi
), inet_ntoa(addr
));
3901 /* Check that we have really something to process */
3902 if (listcount(update
) == 0)
3905 op
= ospf_ls_upd_packet_new(update
, oi
);
3907 /* Prepare OSPF common header. */
3908 ospf_make_header(OSPF_MSG_LS_UPD
, oi
, op
->s
);
3910 /* Prepare OSPF Link State Update body.
3911 * Includes Type-7 translation.
3913 length
+= ospf_make_ls_upd(oi
, update
, op
->s
);
3915 /* Fill OSPF header. */
3916 ospf_fill_header(oi
, op
->s
, length
);
3918 /* Set packet length. */
3919 op
->length
= length
;
3921 /* Decide destination address. */
3922 if (oi
->type
== OSPF_IFTYPE_POINTOPOINT
)
3923 op
->dst
.s_addr
= htonl(OSPF_ALLSPFROUTERS
);
3925 op
->dst
.s_addr
= addr
.s_addr
;
3927 /* Add packet to the interface output queue. */
3928 ospf_packet_add(oi
, op
);
3929 /* Call ospf_write() right away to send ospf packets to neighbors */
3930 if (send_lsupd_now
) {
3931 struct thread os_packet_thd
;
3933 os_packet_thd
.arg
= (void *)oi
->ospf
;
3934 if (oi
->on_write_q
== 0) {
3935 listnode_add(oi
->ospf
->oi_write_q
, oi
);
3938 ospf_write(&os_packet_thd
);
3940 /* Hook thread to write packet. */
3941 OSPF_ISM_WRITE_ON(oi
->ospf
);
3945 static int ospf_ls_upd_send_queue_event(struct thread
*thread
)
3947 struct ospf_interface
*oi
= THREAD_ARG(thread
);
3948 struct route_node
*rn
;
3949 struct route_node
*rnext
;
3950 struct list
*update
;
3953 oi
->t_ls_upd_event
= NULL
;
3955 if (IS_DEBUG_OSPF_EVENT
)
3956 zlog_debug("ospf_ls_upd_send_queue start");
3958 for (rn
= route_top(oi
->ls_upd_queue
); rn
; rn
= rnext
) {
3959 rnext
= route_next(rn
);
3961 if (rn
->info
== NULL
)
3964 update
= (struct list
*)rn
->info
;
3966 ospf_ls_upd_queue_send(oi
, update
, rn
->p
.u
.prefix4
, 0);
3968 /* list might not be empty. */
3969 if (listcount(update
) == 0) {
3970 list_delete_and_null((struct list
**)&rn
->info
);
3971 route_unlock_node(rn
);
3977 if (IS_DEBUG_OSPF_EVENT
)
3979 "ospf_ls_upd_send_queue: update lists not cleared,"
3980 " %d nodes to try again, raising new event",
3982 oi
->t_ls_upd_event
= NULL
;
3983 thread_add_event(master
, ospf_ls_upd_send_queue_event
, oi
, 0,
3984 &oi
->t_ls_upd_event
);
3987 if (IS_DEBUG_OSPF_EVENT
)
3988 zlog_debug("ospf_ls_upd_send_queue stop");
3993 void ospf_ls_upd_send(struct ospf_neighbor
*nbr
, struct list
*update
, int flag
,
3996 struct ospf_interface
*oi
;
3997 struct ospf_lsa
*lsa
;
3998 struct prefix_ipv4 p
;
3999 struct route_node
*rn
;
4000 struct listnode
*node
;
4005 p
.prefixlen
= IPV4_MAX_BITLEN
;
4007 /* Decide destination address. */
4008 if (oi
->type
== OSPF_IFTYPE_VIRTUALLINK
)
4009 p
.prefix
= oi
->vl_data
->peer_addr
;
4010 else if (oi
->type
== OSPF_IFTYPE_POINTOPOINT
)
4011 p
.prefix
.s_addr
= htonl(OSPF_ALLSPFROUTERS
);
4012 else if (flag
== OSPF_SEND_PACKET_DIRECT
)
4013 p
.prefix
= nbr
->address
.u
.prefix4
;
4014 else if (oi
->state
== ISM_DR
|| oi
->state
== ISM_Backup
)
4015 p
.prefix
.s_addr
= htonl(OSPF_ALLSPFROUTERS
);
4016 else if (oi
->type
== OSPF_IFTYPE_POINTOMULTIPOINT
)
4017 p
.prefix
.s_addr
= htonl(OSPF_ALLSPFROUTERS
);
4019 p
.prefix
.s_addr
= htonl(OSPF_ALLDROUTERS
);
4021 if (oi
->type
== OSPF_IFTYPE_NBMA
) {
4022 if (flag
== OSPF_SEND_PACKET_INDIRECT
)
4024 "* LS-Update is directly sent on NBMA network.");
4025 if (IPV4_ADDR_SAME(&oi
->address
->u
.prefix4
, &p
.prefix
))
4026 zlog_warn("* LS-Update is sent to myself.");
4029 rn
= route_node_get(oi
->ls_upd_queue
, (struct prefix
*)&p
);
4031 if (rn
->info
== NULL
)
4032 rn
->info
= list_new();
4034 route_unlock_node(rn
);
4036 for (ALL_LIST_ELEMENTS_RO(update
, node
, lsa
))
4037 listnode_add(rn
->info
,
4038 ospf_lsa_lock(lsa
)); /* oi->ls_upd_queue */
4039 if (send_lsupd_now
) {
4040 struct list
*send_update_list
;
4041 struct route_node
*rn
, *rnext
;
4043 for (rn
= route_top(oi
->ls_upd_queue
); rn
; rn
= rnext
) {
4044 rnext
= route_next(rn
);
4046 if (rn
->info
== NULL
)
4049 send_update_list
= (struct list
*)rn
->info
;
4051 ospf_ls_upd_queue_send(oi
, send_update_list
,
4052 rn
->p
.u
.prefix4
, 1);
4055 thread_add_event(master
, ospf_ls_upd_send_queue_event
, oi
, 0,
4056 &oi
->t_ls_upd_event
);
4059 static void ospf_ls_ack_send_list(struct ospf_interface
*oi
, struct list
*ack
,
4062 struct ospf_packet
*op
;
4063 uint16_t length
= OSPF_HEADER_SIZE
;
4065 op
= ospf_packet_new(oi
->ifp
->mtu
);
4067 /* Prepare OSPF common header. */
4068 ospf_make_header(OSPF_MSG_LS_ACK
, oi
, op
->s
);
4070 /* Prepare OSPF Link State Acknowledgment body. */
4071 length
+= ospf_make_ls_ack(oi
, ack
, op
->s
);
4073 /* Fill OSPF header. */
4074 ospf_fill_header(oi
, op
->s
, length
);
4076 /* Set packet length. */
4077 op
->length
= length
;
4079 /* Decide destination address. */
4080 if (oi
->type
== OSPF_IFTYPE_POINTOPOINT
)
4081 op
->dst
.s_addr
= htonl(OSPF_ALLSPFROUTERS
);
4083 op
->dst
.s_addr
= dst
.s_addr
;
4085 /* Add packet to the interface output queue. */
4086 ospf_packet_add(oi
, op
);
4088 /* Hook thread to write packet. */
4089 OSPF_ISM_WRITE_ON(oi
->ospf
);
4092 static int ospf_ls_ack_send_event(struct thread
*thread
)
4094 struct ospf_interface
*oi
= THREAD_ARG(thread
);
4096 oi
->t_ls_ack_direct
= NULL
;
4098 while (listcount(oi
->ls_ack_direct
.ls_ack
))
4099 ospf_ls_ack_send_list(oi
, oi
->ls_ack_direct
.ls_ack
,
4100 oi
->ls_ack_direct
.dst
);
4105 void ospf_ls_ack_send(struct ospf_neighbor
*nbr
, struct ospf_lsa
*lsa
)
4107 struct ospf_interface
*oi
= nbr
->oi
;
4109 if (listcount(oi
->ls_ack_direct
.ls_ack
) == 0)
4110 oi
->ls_ack_direct
.dst
= nbr
->address
.u
.prefix4
;
4112 listnode_add(oi
->ls_ack_direct
.ls_ack
, ospf_lsa_lock(lsa
));
4114 thread_add_event(master
, ospf_ls_ack_send_event
, oi
, 0,
4115 &oi
->t_ls_ack_direct
);
4118 /* Send Link State Acknowledgment delayed. */
4119 void ospf_ls_ack_send_delayed(struct ospf_interface
*oi
)
4123 /* Decide destination address. */
4124 /* RFC2328 Section 13.5 On non-broadcast
4125 networks, delayed Link State Acknowledgment packets must be
4126 unicast separately over each adjacency (i.e., neighbor whose
4127 state is >= Exchange). */
4128 if (oi
->type
== OSPF_IFTYPE_NBMA
) {
4129 struct ospf_neighbor
*nbr
;
4130 struct route_node
*rn
;
4132 for (rn
= route_top(oi
->nbrs
); rn
; rn
= route_next(rn
))
4133 if ((nbr
= rn
->info
) != NULL
)
4134 if (nbr
!= oi
->nbr_self
4135 && nbr
->state
>= NSM_Exchange
)
4136 while (listcount(oi
->ls_ack
))
4137 ospf_ls_ack_send_list(
4139 nbr
->address
.u
.prefix4
);
4142 if (oi
->type
== OSPF_IFTYPE_VIRTUALLINK
)
4143 dst
.s_addr
= oi
->vl_data
->peer_addr
.s_addr
;
4144 else if (oi
->state
== ISM_DR
|| oi
->state
== ISM_Backup
)
4145 dst
.s_addr
= htonl(OSPF_ALLSPFROUTERS
);
4146 else if (oi
->type
== OSPF_IFTYPE_POINTOPOINT
)
4147 dst
.s_addr
= htonl(OSPF_ALLSPFROUTERS
);
4148 else if (oi
->type
== OSPF_IFTYPE_POINTOMULTIPOINT
)
4149 dst
.s_addr
= htonl(OSPF_ALLSPFROUTERS
);
4151 dst
.s_addr
= htonl(OSPF_ALLDROUTERS
);
4153 while (listcount(oi
->ls_ack
))
4154 ospf_ls_ack_send_list(oi
, oi
->ls_ack
, dst
);
4158 * On pt-to-pt links, all OSPF control packets are sent to the multicast
4159 * address. As a result, the kernel does not need to learn the interface
4160 * MAC of the OSPF neighbor. However, in our world, this will delay
4161 * convergence. Take the case when due to a link flap, all routes now
4162 * want to use an interface which was deemed to be costlier prior to this
4163 * event. For routes that will be installed, the missing MAC will have
4164 * punt-to-CPU set on them. This may overload the CPU control path that
4165 * can be avoided if the MAC was known apriori.
4167 #define OSPF_PING_NBR_STR_MAX (BUFSIZ)
4168 void ospf_proactively_arp(struct ospf_neighbor
*nbr
)
4170 char ping_nbr
[OSPF_PING_NBR_STR_MAX
];
4173 if (!nbr
|| !nbr
->oi
|| !nbr
->oi
->ifp
)
4176 snprintf(ping_nbr
, sizeof(ping_nbr
),
4177 "ping -c 1 -I %s %s > /dev/null 2>&1 &", nbr
->oi
->ifp
->name
,
4178 inet_ntoa(nbr
->address
.u
.prefix4
));
4180 ret
= system(ping_nbr
);
4181 if (IS_DEBUG_OSPF_EVENT
)
4182 zlog_debug("Executed %s %s", ping_nbr
,
4183 ((ret
== 0) ? "successfully" : "but failed"));