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 "lib_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"
53 #include "ospfd/ospf_errors.h"
56 * OSPF Fragmentation / fragmented writes
58 * ospfd can support writing fragmented packets, for cases where
59 * kernel will not fragment IP_HDRINCL and/or multicast destined
60 * packets (ie TTBOMK all kernels, BSD, SunOS, Linux). However,
61 * SunOS, probably BSD too, clobber the user supplied IP ID and IP
62 * flags fields, hence user-space fragmentation will not work.
63 * Only Linux is known to leave IP header unmolested.
64 * Further, fragmentation really should be done the kernel, which already
65 * supports it, and which avoids nasty IP ID state problems.
67 * Fragmentation of OSPF packets can be required on networks with router
68 * with many many interfaces active in one area, or on networks with links
72 #define WANT_OSPF_WRITE_FRAGMENT
75 /* Packet Type String. */
76 const struct message ospf_packet_type_str
[] = {
77 {OSPF_MSG_HELLO
, "Hello"},
78 {OSPF_MSG_DB_DESC
, "Database Description"},
79 {OSPF_MSG_LS_REQ
, "Link State Request"},
80 {OSPF_MSG_LS_UPD
, "Link State Update"},
81 {OSPF_MSG_LS_ACK
, "Link State Acknowledgment"},
84 /* Minimum (besides OSPF_HEADER_SIZE) lengths for OSPF packets of
85 particular types, offset is the "type" field of a packet. */
86 static const uint16_t ospf_packet_minlen
[] = {
89 OSPF_DB_DESC_MIN_SIZE
,
95 /* Minimum (besides OSPF_LSA_HEADER_SIZE) lengths for LSAs of particular
96 types, offset is the "LSA type" field. */
97 static const uint16_t ospf_lsa_minlen
[] = {
99 OSPF_ROUTER_LSA_MIN_SIZE
,
100 OSPF_NETWORK_LSA_MIN_SIZE
,
101 OSPF_SUMMARY_LSA_MIN_SIZE
,
102 OSPF_SUMMARY_LSA_MIN_SIZE
,
103 OSPF_AS_EXTERNAL_LSA_MIN_SIZE
,
105 OSPF_AS_EXTERNAL_LSA_MIN_SIZE
,
112 /* for ospf_check_auth() */
113 static int ospf_check_sum(struct ospf_header
*);
115 /* OSPF authentication checking function */
116 static int ospf_auth_type(struct ospf_interface
*oi
)
120 if (OSPF_IF_PARAM(oi
, auth_type
) == OSPF_AUTH_NOTSET
)
121 auth_type
= oi
->area
->auth_type
;
123 auth_type
= OSPF_IF_PARAM(oi
, auth_type
);
125 /* Handle case where MD5 key list is not configured aka Cisco */
126 if (auth_type
== OSPF_AUTH_CRYPTOGRAPHIC
127 && list_isempty(OSPF_IF_PARAM(oi
, auth_crypt
)))
128 return OSPF_AUTH_NULL
;
133 struct ospf_packet
*ospf_packet_new(size_t size
)
135 struct ospf_packet
*new;
137 new = XCALLOC(MTYPE_OSPF_PACKET
, sizeof(struct ospf_packet
));
138 new->s
= stream_new(size
);
143 void ospf_packet_free(struct ospf_packet
*op
)
148 XFREE(MTYPE_OSPF_PACKET
, op
);
151 struct ospf_fifo
*ospf_fifo_new()
153 struct ospf_fifo
*new;
155 new = XCALLOC(MTYPE_OSPF_FIFO
, sizeof(struct ospf_fifo
));
159 /* Add new packet to fifo. */
160 void ospf_fifo_push(struct ospf_fifo
*fifo
, struct ospf_packet
*op
)
163 fifo
->tail
->next
= op
;
172 /* Add new packet to head of fifo. */
173 static void ospf_fifo_push_head(struct ospf_fifo
*fifo
, struct ospf_packet
*op
)
175 op
->next
= fifo
->head
;
177 if (fifo
->tail
== NULL
)
185 /* Delete first packet from fifo. */
186 struct ospf_packet
*ospf_fifo_pop(struct ospf_fifo
*fifo
)
188 struct ospf_packet
*op
;
193 fifo
->head
= op
->next
;
195 if (fifo
->head
== NULL
)
204 /* Return first fifo entry. */
205 struct ospf_packet
*ospf_fifo_head(struct ospf_fifo
*fifo
)
210 /* Flush ospf packet fifo. */
211 void ospf_fifo_flush(struct ospf_fifo
*fifo
)
213 struct ospf_packet
*op
;
214 struct ospf_packet
*next
;
216 for (op
= fifo
->head
; op
; op
= next
) {
218 ospf_packet_free(op
);
220 fifo
->head
= fifo
->tail
= NULL
;
224 /* Free ospf packet fifo. */
225 void ospf_fifo_free(struct ospf_fifo
*fifo
)
227 ospf_fifo_flush(fifo
);
229 XFREE(MTYPE_OSPF_FIFO
, fifo
);
232 void ospf_packet_add(struct ospf_interface
*oi
, struct ospf_packet
*op
)
236 OSPF_ERR_PKT_PROCESS
,
237 "ospf_packet_add(interface %s in state %d [%s], packet type %s, "
238 "destination %s) called with NULL obuf, ignoring "
239 "(please report this bug)!\n",
240 IF_NAME(oi
), oi
->state
,
241 lookup_msg(ospf_ism_state_msg
, oi
->state
, NULL
),
242 lookup_msg(ospf_packet_type_str
,
243 stream_getc_from(op
->s
, 1), NULL
),
248 /* Add packet to end of queue. */
249 ospf_fifo_push(oi
->obuf
, op
);
251 /* Debug of packet fifo*/
252 /* ospf_fifo_debug (oi->obuf); */
255 static void ospf_packet_add_top(struct ospf_interface
*oi
,
256 struct ospf_packet
*op
)
260 OSPF_ERR_PKT_PROCESS
,
261 "ospf_packet_add(interface %s in state %d [%s], packet type %s, "
262 "destination %s) called with NULL obuf, ignoring "
263 "(please report this bug)!\n",
264 IF_NAME(oi
), oi
->state
,
265 lookup_msg(ospf_ism_state_msg
, oi
->state
, NULL
),
266 lookup_msg(ospf_packet_type_str
,
267 stream_getc_from(op
->s
, 1), NULL
),
272 /* Add packet to head of queue. */
273 ospf_fifo_push_head(oi
->obuf
, op
);
275 /* Debug of packet fifo*/
276 /* ospf_fifo_debug (oi->obuf); */
279 void ospf_packet_delete(struct ospf_interface
*oi
)
281 struct ospf_packet
*op
;
283 op
= ospf_fifo_pop(oi
->obuf
);
286 ospf_packet_free(op
);
289 struct ospf_packet
*ospf_packet_dup(struct ospf_packet
*op
)
291 struct ospf_packet
*new;
293 if (stream_get_endp(op
->s
) != op
->length
)
296 "ospf_packet_dup stream %lu ospf_packet %u size mismatch",
297 (unsigned long)STREAM_SIZE(op
->s
), op
->length
);
299 /* Reserve space for MD5 authentication that may be added later. */
300 new = ospf_packet_new(stream_get_endp(op
->s
) + OSPF_AUTH_MD5_SIZE
);
301 stream_copy(new->s
, op
->s
);
304 new->length
= op
->length
;
310 static unsigned int ospf_packet_authspace(struct ospf_interface
*oi
)
314 if (ospf_auth_type(oi
) == OSPF_AUTH_CRYPTOGRAPHIC
)
315 auth
= OSPF_AUTH_MD5_SIZE
;
320 static unsigned int ospf_packet_max(struct ospf_interface
*oi
)
324 max
= oi
->ifp
->mtu
- ospf_packet_authspace(oi
);
326 max
-= (OSPF_HEADER_SIZE
+ sizeof(struct ip
));
332 static int ospf_check_md5_digest(struct ospf_interface
*oi
,
333 struct ospf_header
*ospfh
)
336 unsigned char digest
[OSPF_AUTH_MD5_SIZE
];
337 struct crypt_key
*ck
;
338 struct ospf_neighbor
*nbr
;
339 uint16_t length
= ntohs(ospfh
->length
);
341 /* Get secret key. */
342 ck
= ospf_crypt_key_lookup(OSPF_IF_PARAM(oi
, auth_crypt
),
343 ospfh
->u
.crypt
.key_id
);
345 flog_warn(OSPF_WARN_MD5
,
346 "interface %s: ospf_check_md5 no key %d", IF_NAME(oi
),
347 ospfh
->u
.crypt
.key_id
);
351 /* check crypto seqnum. */
352 nbr
= ospf_nbr_lookup_by_routerid(oi
->nbrs
, &ospfh
->router_id
);
355 && ntohl(nbr
->crypt_seqnum
) > ntohl(ospfh
->u
.crypt
.crypt_seqnum
)) {
358 "interface %s: ospf_check_md5 bad sequence %d (expect %d)",
359 IF_NAME(oi
), ntohl(ospfh
->u
.crypt
.crypt_seqnum
),
360 ntohl(nbr
->crypt_seqnum
));
364 /* Generate a digest for the ospf packet - their digest + our digest. */
365 memset(&ctx
, 0, sizeof(ctx
));
367 MD5Update(&ctx
, ospfh
, length
);
368 MD5Update(&ctx
, ck
->auth_key
, OSPF_AUTH_MD5_SIZE
);
369 MD5Final(digest
, &ctx
);
371 /* compare the two */
372 if (memcmp((caddr_t
)ospfh
+ length
, digest
, OSPF_AUTH_MD5_SIZE
)) {
373 flog_warn(OSPF_WARN_MD5
,
374 "interface %s: ospf_check_md5 checksum mismatch",
379 /* save neighbor's crypt_seqnum */
381 nbr
->crypt_seqnum
= ospfh
->u
.crypt
.crypt_seqnum
;
385 /* This function is called from ospf_write(), it will detect the
386 authentication scheme and if it is MD5, it will change the sequence
387 and update the MD5 digest. */
388 static int ospf_make_md5_digest(struct ospf_interface
*oi
,
389 struct ospf_packet
*op
)
391 struct ospf_header
*ospfh
;
392 unsigned char digest
[OSPF_AUTH_MD5_SIZE
] = {0};
396 struct crypt_key
*ck
;
397 const uint8_t *auth_key
;
399 ibuf
= STREAM_DATA(op
->s
);
400 ospfh
= (struct ospf_header
*)ibuf
;
402 if (ntohs(ospfh
->auth_type
) != OSPF_AUTH_CRYPTOGRAPHIC
)
405 /* We do this here so when we dup a packet, we don't have to
406 waste CPU rewriting other headers.
408 Note that quagga_time /deliberately/ is not used here */
409 t
= (time(NULL
) & 0xFFFFFFFF);
410 if (t
> oi
->crypt_seqnum
)
411 oi
->crypt_seqnum
= t
;
415 ospfh
->u
.crypt
.crypt_seqnum
= htonl(oi
->crypt_seqnum
);
417 /* Get MD5 Authentication key from auth_key list. */
418 if (list_isempty(OSPF_IF_PARAM(oi
, auth_crypt
)))
419 auth_key
= (const uint8_t *)digest
;
421 ck
= listgetdata(listtail(OSPF_IF_PARAM(oi
, auth_crypt
)));
422 auth_key
= ck
->auth_key
;
425 /* Generate a digest for the entire packet + our secret key. */
426 memset(&ctx
, 0, sizeof(ctx
));
428 MD5Update(&ctx
, ibuf
, ntohs(ospfh
->length
));
429 MD5Update(&ctx
, auth_key
, OSPF_AUTH_MD5_SIZE
);
430 MD5Final(digest
, &ctx
);
432 /* Append md5 digest to the end of the stream. */
433 stream_put(op
->s
, digest
, OSPF_AUTH_MD5_SIZE
);
435 /* We do *NOT* increment the OSPF header length. */
436 op
->length
= ntohs(ospfh
->length
) + OSPF_AUTH_MD5_SIZE
;
438 if (stream_get_endp(op
->s
) != op
->length
)
442 "ospf_make_md5_digest: length mismatch stream %lu ospf_packet %u",
443 (unsigned long)stream_get_endp(op
->s
), op
->length
);
445 return OSPF_AUTH_MD5_SIZE
;
449 static int ospf_ls_req_timer(struct thread
*thread
)
451 struct ospf_neighbor
*nbr
;
453 nbr
= THREAD_ARG(thread
);
454 nbr
->t_ls_req
= NULL
;
456 /* Send Link State Request. */
457 if (ospf_ls_request_count(nbr
))
458 ospf_ls_req_send(nbr
);
460 /* Set Link State Request retransmission timer. */
461 OSPF_NSM_TIMER_ON(nbr
->t_ls_req
, ospf_ls_req_timer
, nbr
->v_ls_req
);
466 void ospf_ls_req_event(struct ospf_neighbor
*nbr
)
469 thread_cancel(nbr
->t_ls_req
);
470 nbr
->t_ls_req
= NULL
;
472 nbr
->t_ls_req
= NULL
;
473 thread_add_event(master
, ospf_ls_req_timer
, nbr
, 0, &nbr
->t_ls_req
);
476 /* Cyclic timer function. Fist registered in ospf_nbr_new () in
478 int ospf_ls_upd_timer(struct thread
*thread
)
480 struct ospf_neighbor
*nbr
;
482 nbr
= THREAD_ARG(thread
);
483 nbr
->t_ls_upd
= NULL
;
485 /* Send Link State Update. */
486 if (ospf_ls_retransmit_count(nbr
) > 0) {
488 struct ospf_lsdb
*lsdb
;
490 int retransmit_interval
;
492 retransmit_interval
=
493 OSPF_IF_PARAM(nbr
->oi
, retransmit_interval
);
495 lsdb
= &nbr
->ls_rxmt
;
498 for (i
= OSPF_MIN_LSA
; i
< OSPF_MAX_LSA
; i
++) {
499 struct route_table
*table
= lsdb
->type
[i
].db
;
500 struct route_node
*rn
;
502 for (rn
= route_top(table
); rn
; rn
= route_next(rn
)) {
503 struct ospf_lsa
*lsa
;
505 if ((lsa
= rn
->info
) != NULL
) {
506 /* Don't retransmit an LSA if we
508 the last RxmtInterval seconds - this
510 neighbour a chance to acknowledge the
512 have ben just received before the
514 fired. This is a small tweak to what
516 but it will cut out out a lot of
519 if (monotime_since(&lsa
->tv_recv
, NULL
)
520 >= retransmit_interval
* 1000000LL)
521 listnode_add(update
, rn
->info
);
526 if (listcount(update
) > 0)
527 ospf_ls_upd_send(nbr
, update
, OSPF_SEND_PACKET_DIRECT
,
529 list_delete_and_null(&update
);
532 /* Set LS Update retransmission timer. */
533 OSPF_NSM_TIMER_ON(nbr
->t_ls_upd
, ospf_ls_upd_timer
, nbr
->v_ls_upd
);
538 int ospf_ls_ack_timer(struct thread
*thread
)
540 struct ospf_interface
*oi
;
542 oi
= THREAD_ARG(thread
);
545 /* Send Link State Acknowledgment. */
546 if (listcount(oi
->ls_ack
) > 0)
547 ospf_ls_ack_send_delayed(oi
);
549 /* Set LS Ack timer. */
550 OSPF_ISM_TIMER_ON(oi
->t_ls_ack
, ospf_ls_ack_timer
, oi
->v_ls_ack
);
555 #ifdef WANT_OSPF_WRITE_FRAGMENT
556 static void ospf_write_frags(int fd
, struct ospf_packet
*op
, struct ip
*iph
,
557 struct msghdr
*msg
, unsigned int maxdatasize
,
558 unsigned int mtu
, int flags
, uint8_t type
)
560 #define OSPF_WRITE_FRAG_SHIFT 3
565 assert(op
->length
== stream_get_endp(op
->s
));
566 assert(msg
->msg_iovlen
== 2);
570 * SunOS, BSD and BSD derived kernels likely will clear ip_id, as
571 * well as the IP_MF flag, making this all quite pointless.
573 * However, for a system on which IP_MF is left alone, and ip_id left
574 * alone or else which sets same ip_id for each fragment this might
577 * XXX-TODO: It would be much nicer to have the kernel's use their
578 * existing fragmentation support to do this for us. Bugs/RFEs need to
579 * be raised against the various kernels.
583 iph
->ip_off
|= IP_MF
;
585 /* ip frag offset is expressed in units of 8byte words */
586 offset
= maxdatasize
>> OSPF_WRITE_FRAG_SHIFT
;
588 iovp
= &msg
->msg_iov
[1];
590 while ((stream_get_endp(op
->s
) - stream_get_getp(op
->s
))
592 /* data length of this frag is to next offset value */
593 iovp
->iov_len
= offset
<< OSPF_WRITE_FRAG_SHIFT
;
594 iph
->ip_len
= iovp
->iov_len
+ sizeof(struct ip
);
595 assert(iph
->ip_len
<= mtu
);
597 sockopt_iphdrincl_swab_htosys(iph
);
599 ret
= sendmsg(fd
, msg
, flags
);
601 sockopt_iphdrincl_swab_systoh(iph
);
606 "*** ospf_write_frags: sendmsg failed to %s,"
607 " id %d, off %d, len %d, mtu %u failed with %s",
608 inet_ntoa(iph
->ip_dst
), iph
->ip_id
, iph
->ip_off
,
609 iph
->ip_len
, mtu
, safe_strerror(errno
));
611 if (IS_DEBUG_OSPF_PACKET(type
- 1, SEND
)) {
613 "ospf_write_frags: sent id %d, off %d, len %d to %s\n",
614 iph
->ip_id
, iph
->ip_off
, iph
->ip_len
,
615 inet_ntoa(iph
->ip_dst
));
616 if (IS_DEBUG_OSPF_PACKET(type
- 1, DETAIL
)) {
618 "-----------------IP Header Dump----------------------");
619 ospf_ip_header_dump(iph
);
621 "-----------------------------------------------------");
625 iph
->ip_off
+= offset
;
626 stream_forward_getp(op
->s
, iovp
->iov_len
);
627 iovp
->iov_base
= stream_pnt(op
->s
);
630 /* setup for final fragment */
631 iovp
->iov_len
= stream_get_endp(op
->s
) - stream_get_getp(op
->s
);
632 iph
->ip_len
= iovp
->iov_len
+ sizeof(struct ip
);
633 iph
->ip_off
&= (~IP_MF
);
635 #endif /* WANT_OSPF_WRITE_FRAGMENT */
637 static int ospf_write(struct thread
*thread
)
639 struct ospf
*ospf
= THREAD_ARG(thread
);
640 struct ospf_interface
*oi
;
641 struct ospf_interface
*last_serviced_oi
= NULL
;
642 struct ospf_packet
*op
;
643 struct sockaddr_in sa_dst
;
650 struct listnode
*node
;
651 #ifdef WANT_OSPF_WRITE_FRAGMENT
652 static uint16_t ipid
= 0;
653 uint16_t maxdatasize
;
654 #endif /* WANT_OSPF_WRITE_FRAGMENT */
655 #define OSPF_WRITE_IPHL_SHIFT 2
659 unsigned char cmsgbuf
[64] = {};
660 struct cmsghdr
*cm
= (struct cmsghdr
*)cmsgbuf
;
661 struct in_pktinfo
*pi
;
664 ospf
->t_write
= NULL
;
666 node
= listhead(ospf
->oi_write_q
);
668 oi
= listgetdata(node
);
671 #ifdef WANT_OSPF_WRITE_FRAGMENT
672 /* seed ipid static with low order bits of time */
674 ipid
= (time(NULL
) & 0xffff);
675 #endif /* WANT_OSPF_WRITE_FRAGMENT */
677 while ((pkt_count
< ospf
->write_oi_count
) && oi
678 && (last_serviced_oi
!= oi
)) {
679 /* If there is only packet in the queue, the oi is removed from
680 write-q, so fix up the last interface that was serviced */
681 if (last_serviced_oi
== NULL
) {
682 last_serviced_oi
= oi
;
685 #ifdef WANT_OSPF_WRITE_FRAGMENT
686 /* convenience - max OSPF data per packet */
687 maxdatasize
= oi
->ifp
->mtu
- sizeof(struct ip
);
688 #endif /* WANT_OSPF_WRITE_FRAGMENT */
689 /* Get one packet from queue. */
690 op
= ospf_fifo_head(oi
->obuf
);
692 assert(op
->length
>= OSPF_HEADER_SIZE
);
694 if (op
->dst
.s_addr
== htonl(OSPF_ALLSPFROUTERS
)
695 || op
->dst
.s_addr
== htonl(OSPF_ALLDROUTERS
))
696 ospf_if_ipmulticast(ospf
, oi
->address
,
699 /* Rewrite the md5 signature & update the seq */
700 ospf_make_md5_digest(oi
, op
);
702 /* Retrieve OSPF packet type. */
703 stream_set_getp(op
->s
, 1);
704 type
= stream_getc(op
->s
);
706 /* reset get pointer */
707 stream_set_getp(op
->s
, 0);
709 memset(&iph
, 0, sizeof(struct ip
));
710 memset(&sa_dst
, 0, sizeof(sa_dst
));
712 sa_dst
.sin_family
= AF_INET
;
713 #ifdef HAVE_STRUCT_SOCKADDR_IN_SIN_LEN
714 sa_dst
.sin_len
= sizeof(sa_dst
);
715 #endif /* HAVE_STRUCT_SOCKADDR_IN_SIN_LEN */
716 sa_dst
.sin_addr
= op
->dst
;
717 sa_dst
.sin_port
= htons(0);
719 /* Set DONTROUTE flag if dst is unicast. */
720 if (oi
->type
!= OSPF_IFTYPE_VIRTUALLINK
)
721 if (!IN_MULTICAST(htonl(op
->dst
.s_addr
)))
722 flags
= MSG_DONTROUTE
;
724 iph
.ip_hl
= sizeof(struct ip
) >> OSPF_WRITE_IPHL_SHIFT
;
725 /* it'd be very strange for header to not be 4byte-word aligned
727 if (sizeof(struct ip
)
728 > (unsigned int)(iph
.ip_hl
<< OSPF_WRITE_IPHL_SHIFT
))
729 iph
.ip_hl
++; /* we presume sizeof struct ip cant
732 iph
.ip_v
= IPVERSION
;
733 iph
.ip_tos
= IPTOS_PREC_INTERNETCONTROL
;
734 iph
.ip_len
= (iph
.ip_hl
<< OSPF_WRITE_IPHL_SHIFT
) + op
->length
;
736 #if defined(__DragonFly__)
738 * DragonFly's raw socket expects ip_len/ip_off in network byte
741 iph
.ip_len
= htons(iph
.ip_len
);
744 #ifdef WANT_OSPF_WRITE_FRAGMENT
745 /* XXX-MT: not thread-safe at all..
746 * XXX: this presumes this is only programme sending OSPF
748 * otherwise, no guarantee ipid will be unique
751 #endif /* WANT_OSPF_WRITE_FRAGMENT */
754 if (oi
->type
== OSPF_IFTYPE_VIRTUALLINK
)
755 iph
.ip_ttl
= OSPF_VL_IP_TTL
;
757 iph
.ip_ttl
= OSPF_IP_TTL
;
758 iph
.ip_p
= IPPROTO_OSPFIGP
;
760 iph
.ip_src
.s_addr
= oi
->address
->u
.prefix4
.s_addr
;
761 iph
.ip_dst
.s_addr
= op
->dst
.s_addr
;
763 memset(&msg
, 0, sizeof(msg
));
764 msg
.msg_name
= (caddr_t
)&sa_dst
;
765 msg
.msg_namelen
= sizeof(sa_dst
);
769 iov
[0].iov_base
= (char *)&iph
;
770 iov
[0].iov_len
= iph
.ip_hl
<< OSPF_WRITE_IPHL_SHIFT
;
771 iov
[1].iov_base
= stream_pnt(op
->s
);
772 iov
[1].iov_len
= op
->length
;
775 msg
.msg_control
= (caddr_t
)cm
;
776 cm
->cmsg_level
= SOL_IP
;
777 cm
->cmsg_type
= IP_PKTINFO
;
778 cm
->cmsg_len
= CMSG_LEN(sizeof(struct in_pktinfo
));
779 pi
= (struct in_pktinfo
*)CMSG_DATA(cm
);
780 pi
->ipi_ifindex
= oi
->ifp
->ifindex
;
782 msg
.msg_controllen
= cm
->cmsg_len
;
785 /* Sadly we can not rely on kernels to fragment packets
786 * because of either IP_HDRINCL and/or multicast
787 * destination being set.
790 #ifdef WANT_OSPF_WRITE_FRAGMENT
791 if (op
->length
> maxdatasize
)
792 ospf_write_frags(ospf
->fd
, op
, &iph
, &msg
, maxdatasize
,
793 oi
->ifp
->mtu
, flags
, type
);
794 #endif /* WANT_OSPF_WRITE_FRAGMENT */
796 /* send final fragment (could be first) */
797 sockopt_iphdrincl_swab_htosys(&iph
);
798 ret
= sendmsg(ospf
->fd
, &msg
, flags
);
799 sockopt_iphdrincl_swab_systoh(&iph
);
800 if (IS_DEBUG_OSPF_EVENT
)
803 "id %d, off %d, len %d, interface %s, mtu %u:",
804 inet_ntoa(iph
.ip_dst
), iph
.ip_id
, iph
.ip_off
,
805 iph
.ip_len
, oi
->ifp
->name
, oi
->ifp
->mtu
);
810 "*** sendmsg in ospf_write failed to %s, "
811 "id %d, off %d, len %d, interface %s, mtu %u: %s",
812 inet_ntoa(iph
.ip_dst
), iph
.ip_id
, iph
.ip_off
,
813 iph
.ip_len
, oi
->ifp
->name
, oi
->ifp
->mtu
,
814 safe_strerror(errno
));
816 /* Show debug sending packet. */
817 if (IS_DEBUG_OSPF_PACKET(type
- 1, SEND
)) {
818 if (IS_DEBUG_OSPF_PACKET(type
- 1, DETAIL
)) {
820 "-----------------------------------------------------");
821 ospf_ip_header_dump(&iph
);
822 stream_set_getp(op
->s
, 0);
823 ospf_packet_dump(op
->s
);
826 zlog_debug("%s sent to [%s] via [%s].",
827 lookup_msg(ospf_packet_type_str
, type
, NULL
),
828 inet_ntoa(op
->dst
), IF_NAME(oi
));
830 if (IS_DEBUG_OSPF_PACKET(type
- 1, DETAIL
))
832 "-----------------------------------------------------");
839 case OSPF_MSG_DB_DESC
:
842 case OSPF_MSG_LS_REQ
:
845 case OSPF_MSG_LS_UPD
:
848 case OSPF_MSG_LS_ACK
:
855 /* Now delete packet from queue. */
856 ospf_packet_delete(oi
);
858 /* Move this interface to the tail of write_q to
859 serve everyone in a round robin fashion */
860 list_delete_node(ospf
->oi_write_q
, node
);
861 if (ospf_fifo_head(oi
->obuf
) == NULL
) {
863 last_serviced_oi
= NULL
;
866 listnode_add(ospf
->oi_write_q
, oi
);
869 /* Setup to service from the head of the queue again */
870 if (!list_isempty(ospf
->oi_write_q
)) {
871 node
= listhead(ospf
->oi_write_q
);
873 oi
= listgetdata(node
);
878 /* If packets still remain in queue, call write thread. */
879 if (!list_isempty(ospf
->oi_write_q
)) {
880 ospf
->t_write
= NULL
;
881 thread_add_write(master
, ospf_write
, ospf
, ospf
->fd
,
888 /* OSPF Hello message read -- RFC2328 Section 10.5. */
889 static void ospf_hello(struct ip
*iph
, struct ospf_header
*ospfh
,
890 struct stream
*s
, struct ospf_interface
*oi
, int size
)
892 struct ospf_hello
*hello
;
893 struct ospf_neighbor
*nbr
;
897 /* increment statistics. */
900 hello
= (struct ospf_hello
*)stream_pnt(s
);
902 /* If Hello is myself, silently discard. */
903 if (IPV4_ADDR_SAME(&ospfh
->router_id
, &oi
->ospf
->router_id
)) {
904 if (IS_DEBUG_OSPF_PACKET(ospfh
->type
- 1, RECV
)) {
906 "ospf_header[%s/%s]: selforiginated, "
908 lookup_msg(ospf_packet_type_str
, ospfh
->type
,
910 inet_ntoa(iph
->ip_src
));
915 /* get neighbor prefix. */
917 p
.prefixlen
= ip_masklen(hello
->network_mask
);
918 p
.u
.prefix4
= iph
->ip_src
;
920 /* Compare network mask. */
921 /* Checking is ignored for Point-to-Point and Virtual link. */
922 if (oi
->type
!= OSPF_IFTYPE_POINTOPOINT
923 && oi
->type
!= OSPF_IFTYPE_VIRTUALLINK
)
924 if (oi
->address
->prefixlen
!= p
.prefixlen
) {
927 "Packet %s [Hello:RECV]: NetworkMask mismatch on %s (configured prefix length is %d, but hello packet indicates %d).",
928 inet_ntoa(ospfh
->router_id
), IF_NAME(oi
),
929 (int)oi
->address
->prefixlen
, (int)p
.prefixlen
);
933 /* Compare Router Dead Interval. */
934 if (OSPF_IF_PARAM(oi
, v_wait
) != ntohl(hello
->dead_interval
)) {
935 flog_warn(OSPF_WARN_PACKET
,
936 "Packet %s [Hello:RECV]: RouterDeadInterval mismatch "
937 "(expected %u, but received %u).",
938 inet_ntoa(ospfh
->router_id
),
939 OSPF_IF_PARAM(oi
, v_wait
),
940 ntohl(hello
->dead_interval
));
944 /* Compare Hello Interval - ignored if fast-hellos are set. */
945 if (OSPF_IF_PARAM(oi
, fast_hello
) == 0) {
946 if (OSPF_IF_PARAM(oi
, v_hello
)
947 != ntohs(hello
->hello_interval
)) {
950 "Packet %s [Hello:RECV]: HelloInterval mismatch "
951 "(expected %u, but received %u).",
952 inet_ntoa(ospfh
->router_id
),
953 OSPF_IF_PARAM(oi
, v_hello
),
954 ntohs(hello
->hello_interval
));
959 if (IS_DEBUG_OSPF_EVENT
)
960 zlog_debug("Packet %s [Hello:RECV]: Options %s vrf %s",
961 inet_ntoa(ospfh
->router_id
),
962 ospf_options_dump(hello
->options
),
963 ospf_vrf_id_to_name(oi
->ospf
->vrf_id
));
965 /* Compare options. */
966 #define REJECT_IF_TBIT_ON 1 /* XXX */
967 #ifdef REJECT_IF_TBIT_ON
968 if (CHECK_FLAG(hello
->options
, OSPF_OPTION_MT
)) {
970 * This router does not support non-zero TOS.
971 * Drop this Hello packet not to establish neighbor
974 flog_warn(OSPF_WARN_PACKET
,
975 "Packet %s [Hello:RECV]: T-bit on, drop it.",
976 inet_ntoa(ospfh
->router_id
));
979 #endif /* REJECT_IF_TBIT_ON */
981 if (CHECK_FLAG(oi
->ospf
->config
, OSPF_OPAQUE_CAPABLE
)
982 && CHECK_FLAG(hello
->options
, OSPF_OPTION_O
)) {
984 * This router does know the correct usage of O-bit
985 * the bit should be set in DD packet only.
987 flog_warn(OSPF_WARN_PACKET
,
988 "Packet %s [Hello:RECV]: O-bit abuse?",
989 inet_ntoa(ospfh
->router_id
));
990 #ifdef STRICT_OBIT_USAGE_CHECK
991 return; /* Reject this packet. */
992 #else /* STRICT_OBIT_USAGE_CHECK */
993 UNSET_FLAG(hello
->options
, OSPF_OPTION_O
); /* Ignore O-bit. */
994 #endif /* STRICT_OBIT_USAGE_CHECK */
997 /* new for NSSA is to ensure that NP is on and E is off */
999 if (oi
->area
->external_routing
== OSPF_AREA_NSSA
) {
1000 if (!(CHECK_FLAG(OPTIONS(oi
), OSPF_OPTION_NP
)
1001 && CHECK_FLAG(hello
->options
, OSPF_OPTION_NP
)
1002 && !CHECK_FLAG(OPTIONS(oi
), OSPF_OPTION_E
)
1003 && !CHECK_FLAG(hello
->options
, OSPF_OPTION_E
))) {
1006 "NSSA-Packet-%s[Hello:RECV]: my options: %x, his options %x",
1007 inet_ntoa(ospfh
->router_id
), OPTIONS(oi
),
1011 if (IS_DEBUG_OSPF_NSSA
)
1012 zlog_debug("NSSA-Hello:RECV:Packet from %s:",
1013 inet_ntoa(ospfh
->router_id
));
1015 /* The setting of the E-bit found in the Hello Packet's Options
1016 field must match this area's ExternalRoutingCapability A
1017 mismatch causes processing to stop and the packet to be
1018 dropped. The setting of the rest of the bits in the Hello
1019 Packet's Options field should be ignored. */
1020 if (CHECK_FLAG(OPTIONS(oi
), OSPF_OPTION_E
)
1021 != CHECK_FLAG(hello
->options
, OSPF_OPTION_E
)) {
1024 "Packet %s [Hello:RECV]: my options: %x, his options %x",
1025 inet_ntoa(ospfh
->router_id
), OPTIONS(oi
),
1030 /* get neighbour struct */
1031 nbr
= ospf_nbr_get(oi
, ospfh
, iph
, &p
);
1033 /* neighbour must be valid, ospf_nbr_get creates if none existed */
1036 old_state
= nbr
->state
;
1038 /* Add event to thread. */
1039 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_PacketReceived
);
1041 /* RFC2328 Section 9.5.1
1042 If the router is not eligible to become Designated Router,
1043 (snip) It must also send an Hello Packet in reply to an
1044 Hello Packet received from any eligible neighbor (other than
1045 the current Designated Router and Backup Designated Router). */
1046 if (oi
->type
== OSPF_IFTYPE_NBMA
)
1047 if (PRIORITY(oi
) == 0 && hello
->priority
> 0
1048 && IPV4_ADDR_CMP(&DR(oi
), &iph
->ip_src
)
1049 && IPV4_ADDR_CMP(&BDR(oi
), &iph
->ip_src
))
1050 OSPF_NSM_TIMER_ON(nbr
->t_hello_reply
,
1051 ospf_hello_reply_timer
,
1052 OSPF_HELLO_REPLY_DELAY
);
1054 /* on NBMA network type, it happens to receive bidirectional Hello
1056 without advance 1-Way Received event.
1057 To avoid incorrect DR-seletion, raise 1-Way Received event.*/
1058 if (oi
->type
== OSPF_IFTYPE_NBMA
1059 && (old_state
== NSM_Down
|| old_state
== NSM_Attempt
)) {
1060 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_OneWayReceived
);
1061 nbr
->priority
= hello
->priority
;
1062 nbr
->d_router
= hello
->d_router
;
1063 nbr
->bd_router
= hello
->bd_router
;
1067 if (ospf_nbr_bidirectional(&oi
->ospf
->router_id
, hello
->neighbors
,
1068 size
- OSPF_HELLO_MIN_SIZE
)) {
1069 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_TwoWayReceived
);
1070 nbr
->options
|= hello
->options
;
1072 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_OneWayReceived
);
1073 /* Set neighbor information. */
1074 nbr
->priority
= hello
->priority
;
1075 nbr
->d_router
= hello
->d_router
;
1076 nbr
->bd_router
= hello
->bd_router
;
1080 /* If neighbor itself declares DR and no BDR exists,
1081 cause event BackupSeen */
1082 if (IPV4_ADDR_SAME(&nbr
->address
.u
.prefix4
, &hello
->d_router
))
1083 if (hello
->bd_router
.s_addr
== 0 && oi
->state
== ISM_Waiting
)
1084 OSPF_ISM_EVENT_SCHEDULE(oi
, ISM_BackupSeen
);
1086 /* neighbor itself declares BDR. */
1087 if (oi
->state
== ISM_Waiting
1088 && IPV4_ADDR_SAME(&nbr
->address
.u
.prefix4
, &hello
->bd_router
))
1089 OSPF_ISM_EVENT_SCHEDULE(oi
, ISM_BackupSeen
);
1091 /* had not previously. */
1092 if ((IPV4_ADDR_SAME(&nbr
->address
.u
.prefix4
, &hello
->d_router
)
1093 && IPV4_ADDR_CMP(&nbr
->address
.u
.prefix4
, &nbr
->d_router
))
1094 || (IPV4_ADDR_CMP(&nbr
->address
.u
.prefix4
, &hello
->d_router
)
1095 && IPV4_ADDR_SAME(&nbr
->address
.u
.prefix4
, &nbr
->d_router
)))
1096 OSPF_ISM_EVENT_SCHEDULE(oi
, ISM_NeighborChange
);
1098 /* had not previously. */
1099 if ((IPV4_ADDR_SAME(&nbr
->address
.u
.prefix4
, &hello
->bd_router
)
1100 && IPV4_ADDR_CMP(&nbr
->address
.u
.prefix4
, &nbr
->bd_router
))
1101 || (IPV4_ADDR_CMP(&nbr
->address
.u
.prefix4
, &hello
->bd_router
)
1102 && IPV4_ADDR_SAME(&nbr
->address
.u
.prefix4
, &nbr
->bd_router
)))
1103 OSPF_ISM_EVENT_SCHEDULE(oi
, ISM_NeighborChange
);
1105 /* Neighbor priority check. */
1106 if (nbr
->priority
>= 0 && nbr
->priority
!= hello
->priority
)
1107 OSPF_ISM_EVENT_SCHEDULE(oi
, ISM_NeighborChange
);
1109 /* Set neighbor information. */
1110 nbr
->priority
= hello
->priority
;
1111 nbr
->d_router
= hello
->d_router
;
1112 nbr
->bd_router
= hello
->bd_router
;
1115 /* Save DD flags/options/Seqnum received. */
1116 static void ospf_db_desc_save_current(struct ospf_neighbor
*nbr
,
1117 struct ospf_db_desc
*dd
)
1119 nbr
->last_recv
.flags
= dd
->flags
;
1120 nbr
->last_recv
.options
= dd
->options
;
1121 nbr
->last_recv
.dd_seqnum
= ntohl(dd
->dd_seqnum
);
1124 /* Process rest of DD packet. */
1125 static void ospf_db_desc_proc(struct stream
*s
, struct ospf_interface
*oi
,
1126 struct ospf_neighbor
*nbr
,
1127 struct ospf_db_desc
*dd
, uint16_t size
)
1129 struct ospf_lsa
*new, *find
;
1130 struct lsa_header
*lsah
;
1132 stream_forward_getp(s
, OSPF_DB_DESC_MIN_SIZE
);
1133 for (size
-= OSPF_DB_DESC_MIN_SIZE
; size
>= OSPF_LSA_HEADER_SIZE
;
1134 size
-= OSPF_LSA_HEADER_SIZE
) {
1135 lsah
= (struct lsa_header
*)stream_pnt(s
);
1136 stream_forward_getp(s
, OSPF_LSA_HEADER_SIZE
);
1138 /* Unknown LS type. */
1139 if (lsah
->type
< OSPF_MIN_LSA
|| lsah
->type
>= OSPF_MAX_LSA
) {
1140 flog_warn(OSPF_WARN_PACKET
,
1141 "Packet [DD:RECV]: Unknown LS type %d.",
1143 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_SeqNumberMismatch
);
1147 if (IS_OPAQUE_LSA(lsah
->type
)
1148 && !CHECK_FLAG(nbr
->options
, OSPF_OPTION_O
)) {
1149 flog_warn(OSPF_WARN_PACKET
,
1150 "LSA[Type%d:%s]: Opaque capability mismatch?",
1151 lsah
->type
, inet_ntoa(lsah
->id
));
1152 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_SeqNumberMismatch
);
1156 switch (lsah
->type
) {
1157 case OSPF_AS_EXTERNAL_LSA
:
1158 case OSPF_OPAQUE_AS_LSA
:
1159 /* Check for stub area. Reject if AS-External from stub
1161 allow if from NSSA. */
1162 if (oi
->area
->external_routing
== OSPF_AREA_STUB
) {
1165 "Packet [DD:RECV]: LSA[Type%d:%s] from %s area.",
1166 lsah
->type
, inet_ntoa(lsah
->id
),
1167 (oi
->area
->external_routing
1171 OSPF_NSM_EVENT_SCHEDULE(nbr
,
1172 NSM_SeqNumberMismatch
);
1180 /* Create LS-request object. */
1181 new = ospf_ls_request_new(lsah
);
1183 /* Lookup received LSA, then add LS request list. */
1184 find
= ospf_lsa_lookup_by_header(oi
->area
, lsah
);
1186 /* ospf_lsa_more_recent is fine with NULL pointers */
1187 switch (ospf_lsa_more_recent(find
, new)) {
1189 /* Neighbour has a more recent LSA, we must request it
1191 ospf_ls_request_add(nbr
, new);
1194 /* If we have a copy of this LSA, it's either less
1196 * and we're requesting it from neighbour (the case
1198 * it's as recent and we both have same copy (this
1201 * In neither of these two cases is there any point in
1202 * describing our copy of the LSA to the neighbour in a
1203 * DB-Summary packet, if we're still intending to do so.
1205 * See: draft-ogier-ospf-dbex-opt-00.txt, describing the
1206 * backward compatible optimisation to OSPF DB Exchange
1208 * DB Description process implemented here.
1211 ospf_lsdb_delete(&nbr
->db_sum
, find
);
1212 ospf_lsa_discard(new);
1215 /* We have the more recent copy, nothing specific to do:
1216 * - no need to request neighbours stale copy
1217 * - must leave DB summary list copy alone
1219 if (IS_DEBUG_OSPF_EVENT
)
1221 "Packet [DD:RECV]: LSA received Type %d, "
1222 "ID %s is not recent.",
1223 lsah
->type
, inet_ntoa(lsah
->id
));
1224 ospf_lsa_discard(new);
1229 if (IS_SET_DD_MS(nbr
->dd_flags
)) {
1232 /* Both sides have no More, then we're done with Exchange */
1233 if (!IS_SET_DD_M(dd
->flags
) && !IS_SET_DD_M(nbr
->dd_flags
))
1234 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_ExchangeDone
);
1236 ospf_db_desc_send(nbr
);
1240 nbr
->dd_seqnum
= ntohl(dd
->dd_seqnum
);
1242 /* Send DD packet in reply.
1244 * Must be done to acknowledge the Master's DD, regardless of
1245 * whether we have more LSAs ourselves to describe.
1247 * This function will clear the 'More' bit, if after this DD
1248 * we have no more LSAs to describe to the master..
1250 ospf_db_desc_send(nbr
);
1252 /* Slave can raise ExchangeDone now, if master is also done */
1253 if (!IS_SET_DD_M(dd
->flags
) && !IS_SET_DD_M(nbr
->dd_flags
))
1254 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_ExchangeDone
);
1257 /* Save received neighbor values from DD. */
1258 ospf_db_desc_save_current(nbr
, dd
);
1261 ospf_ls_req_send(nbr
);
1264 static int ospf_db_desc_is_dup(struct ospf_db_desc
*dd
,
1265 struct ospf_neighbor
*nbr
)
1267 /* Is DD duplicated? */
1268 if (dd
->options
== nbr
->last_recv
.options
1269 && dd
->flags
== nbr
->last_recv
.flags
1270 && dd
->dd_seqnum
== htonl(nbr
->last_recv
.dd_seqnum
))
1276 /* OSPF Database Description message read -- RFC2328 Section 10.6. */
1277 static void ospf_db_desc(struct ip
*iph
, struct ospf_header
*ospfh
,
1278 struct stream
*s
, struct ospf_interface
*oi
,
1281 struct ospf_db_desc
*dd
;
1282 struct ospf_neighbor
*nbr
;
1284 /* Increment statistics. */
1287 dd
= (struct ospf_db_desc
*)stream_pnt(s
);
1289 nbr
= ospf_nbr_lookup(oi
, iph
, ospfh
);
1291 flog_warn(OSPF_WARN_PACKET
, "Packet[DD]: Unknown Neighbor %s",
1292 inet_ntoa(ospfh
->router_id
));
1297 if ((OSPF_IF_PARAM(oi
, mtu_ignore
) == 0)
1298 && (ntohs(dd
->mtu
) > oi
->ifp
->mtu
)) {
1301 "Packet[DD]: Neighbor %s MTU %u is larger than [%s]'s MTU %u",
1302 inet_ntoa(nbr
->router_id
), ntohs(dd
->mtu
), IF_NAME(oi
),
1308 * XXX HACK by Hasso Tepper. Setting N/P bit in NSSA area DD packets is
1310 * required. In fact at least JunOS sends DD packets with P bit clear.
1311 * Until proper solution is developped, this hack should help.
1313 * Update: According to the RFCs, N bit is specified /only/ for Hello
1314 * options, unfortunately its use in DD options is not specified. Hence
1316 * implementations follow E-bit semantics and set it in DD options, and
1318 * treat it as unspecified and hence follow the directive "default for
1319 * options is clear", ie unset.
1321 * Reset the flag, as ospfd follows E-bit semantics.
1323 if ((oi
->area
->external_routing
== OSPF_AREA_NSSA
)
1324 && (CHECK_FLAG(nbr
->options
, OSPF_OPTION_NP
))
1325 && (!CHECK_FLAG(dd
->options
, OSPF_OPTION_NP
))) {
1326 if (IS_DEBUG_OSPF_EVENT
)
1328 "Packet[DD]: Neighbour %s: Has NSSA capability, sends with N bit clear in DD options",
1329 inet_ntoa(nbr
->router_id
));
1330 SET_FLAG(dd
->options
, OSPF_OPTION_NP
);
1333 #ifdef REJECT_IF_TBIT_ON
1334 if (CHECK_FLAG(dd
->options
, OSPF_OPTION_MT
)) {
1336 * In Hello protocol, optional capability must have checked
1337 * to prevent this T-bit enabled router be my neighbor.
1339 flog_warn(OSPF_WARN_PACKET
,
1340 "Packet[DD]: Neighbor %s: T-bit on?",
1341 inet_ntoa(nbr
->router_id
));
1344 #endif /* REJECT_IF_TBIT_ON */
1346 if (CHECK_FLAG(dd
->options
, OSPF_OPTION_O
)
1347 && !CHECK_FLAG(oi
->ospf
->config
, OSPF_OPAQUE_CAPABLE
)) {
1349 * This node is not configured to handle O-bit, for now.
1350 * Clear it to ignore unsupported capability proposed by
1353 UNSET_FLAG(dd
->options
, OSPF_OPTION_O
);
1356 /* Add event to thread. */
1357 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_PacketReceived
);
1359 /* Process DD packet by neighbor status. */
1360 switch (nbr
->state
) {
1366 "Packet[DD]: Neighbor %s state is %s, packet discarded.",
1367 inet_ntoa(nbr
->router_id
),
1368 lookup_msg(ospf_nsm_state_msg
, nbr
->state
, NULL
));
1371 OSPF_NSM_EVENT_EXECUTE(nbr
, NSM_TwoWayReceived
);
1372 /* If the new state is ExStart, the processing of the current
1373 packet should then continue in this new state by falling
1374 through to case ExStart below. */
1375 if (nbr
->state
!= NSM_ExStart
)
1380 if ((IS_SET_DD_ALL(dd
->flags
) == OSPF_DD_FLAG_ALL
)
1381 && (size
== OSPF_DB_DESC_MIN_SIZE
)) {
1382 if (IPV4_ADDR_CMP(&nbr
->router_id
, &oi
->ospf
->router_id
)
1384 /* We're Slave---obey */
1385 if (CHECK_FLAG(oi
->ospf
->config
,
1386 OSPF_LOG_ADJACENCY_DETAIL
))
1388 "Packet[DD]: Neighbor %s Negotiation done (Slave).",
1389 inet_ntoa(nbr
->router_id
));
1391 nbr
->dd_seqnum
= ntohl(dd
->dd_seqnum
);
1394 UNSET_FLAG(nbr
->dd_flags
,
1395 (OSPF_DD_FLAG_MS
| OSPF_DD_FLAG_I
));
1397 /* We're Master, ignore the initial DBD from
1399 if (CHECK_FLAG(oi
->ospf
->config
,
1400 OSPF_LOG_ADJACENCY_DETAIL
))
1402 "Packet[DD]: Neighbor %s: Initial DBD from Slave, "
1404 inet_ntoa(nbr
->router_id
));
1408 /* Ack from the Slave */
1409 else if (!IS_SET_DD_MS(dd
->flags
) && !IS_SET_DD_I(dd
->flags
)
1410 && ntohl(dd
->dd_seqnum
) == nbr
->dd_seqnum
1411 && IPV4_ADDR_CMP(&nbr
->router_id
, &oi
->ospf
->router_id
)
1414 "Packet[DD]: Neighbor %s Negotiation done (Master).",
1415 inet_ntoa(nbr
->router_id
));
1416 /* Reset I, leaving MS */
1417 UNSET_FLAG(nbr
->dd_flags
, OSPF_DD_FLAG_I
);
1419 flog_warn(OSPF_WARN_PACKET
,
1420 "Packet[DD]: Neighbor %s Negotiation fails.",
1421 inet_ntoa(nbr
->router_id
));
1425 /* This is where the real Options are saved */
1426 nbr
->options
= dd
->options
;
1428 if (CHECK_FLAG(oi
->ospf
->config
, OSPF_OPAQUE_CAPABLE
)) {
1429 if (IS_DEBUG_OSPF_EVENT
)
1431 "Neighbor[%s] is %sOpaque-capable.",
1432 inet_ntoa(nbr
->router_id
),
1433 CHECK_FLAG(nbr
->options
, OSPF_OPTION_O
)
1437 if (!CHECK_FLAG(nbr
->options
, OSPF_OPTION_O
)
1438 && IPV4_ADDR_SAME(&DR(oi
),
1439 &nbr
->address
.u
.prefix4
)) {
1442 "DR-neighbor[%s] is NOT opaque-capable; Opaque-LSAs cannot be reliably advertised in this network.",
1443 inet_ntoa(nbr
->router_id
));
1444 /* This situation is undesirable, but not a real
1449 OSPF_NSM_EVENT_EXECUTE(nbr
, NSM_NegotiationDone
);
1451 /* continue processing rest of packet. */
1452 ospf_db_desc_proc(s
, oi
, nbr
, dd
, size
);
1455 if (ospf_db_desc_is_dup(dd
, nbr
)) {
1456 if (IS_SET_DD_MS(nbr
->dd_flags
))
1457 /* Master: discard duplicated DD packet. */
1459 "Packet[DD] (Master): Neighbor %s packet duplicated.",
1460 inet_ntoa(nbr
->router_id
));
1462 /* Slave: cause to retransmit the last Database
1466 "Packet[DD] [Slave]: Neighbor %s packet duplicated.",
1467 inet_ntoa(nbr
->router_id
));
1468 ospf_db_desc_resend(nbr
);
1473 /* Otherwise DD packet should be checked. */
1474 /* Check Master/Slave bit mismatch */
1475 if (IS_SET_DD_MS(dd
->flags
)
1476 != IS_SET_DD_MS(nbr
->last_recv
.flags
)) {
1477 flog_warn(OSPF_WARN_PACKET
,
1478 "Packet[DD]: Neighbor %s MS-bit mismatch.",
1479 inet_ntoa(nbr
->router_id
));
1480 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_SeqNumberMismatch
);
1481 if (IS_DEBUG_OSPF_EVENT
)
1483 "Packet[DD]: dd->flags=%d, nbr->dd_flags=%d",
1484 dd
->flags
, nbr
->dd_flags
);
1488 /* Check initialize bit is set. */
1489 if (IS_SET_DD_I(dd
->flags
)) {
1490 zlog_info("Packet[DD]: Neighbor %s I-bit set.",
1491 inet_ntoa(nbr
->router_id
));
1492 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_SeqNumberMismatch
);
1496 /* Check DD Options. */
1497 if (dd
->options
!= nbr
->options
) {
1498 #ifdef ORIGINAL_CODING
1499 /* Save the new options for debugging */
1500 nbr
->options
= dd
->options
;
1501 #endif /* ORIGINAL_CODING */
1502 flog_warn(OSPF_WARN_PACKET
,
1503 "Packet[DD]: Neighbor %s options mismatch.",
1504 inet_ntoa(nbr
->router_id
));
1505 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_SeqNumberMismatch
);
1509 /* Check DD sequence number. */
1510 if ((IS_SET_DD_MS(nbr
->dd_flags
)
1511 && ntohl(dd
->dd_seqnum
) != nbr
->dd_seqnum
)
1512 || (!IS_SET_DD_MS(nbr
->dd_flags
)
1513 && ntohl(dd
->dd_seqnum
) != nbr
->dd_seqnum
+ 1)) {
1516 "Packet[DD]: Neighbor %s sequence number mismatch.",
1517 inet_ntoa(nbr
->router_id
));
1518 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_SeqNumberMismatch
);
1522 /* Continue processing rest of packet. */
1523 ospf_db_desc_proc(s
, oi
, nbr
, dd
, size
);
1527 if (ospf_db_desc_is_dup(dd
, nbr
)) {
1528 if (IS_SET_DD_MS(nbr
->dd_flags
)) {
1529 /* Master should discard duplicate DD packet. */
1531 "Packet[DD]: Neighbor %s duplicated, "
1532 "packet discarded.",
1533 inet_ntoa(nbr
->router_id
));
1536 if (monotime_since(&nbr
->last_send_ts
, NULL
)
1537 < nbr
->v_inactivity
* 1000000LL) {
1538 /* In states Loading and Full the slave
1540 its last Database Description packet
1542 duplicate Database Description
1544 from the master. For this reason the
1546 wait RouterDeadInterval seconds
1548 last Database Description packet.
1550 Database Description packet from the
1552 this interval will generate a
1554 neighbor event. RFC2328 Section 10.8
1556 ospf_db_desc_resend(nbr
);
1562 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_SeqNumberMismatch
);
1565 flog_warn(OSPF_WARN_PACKET
,
1566 "Packet[DD]: Neighbor %s NSM illegal status %u.",
1567 inet_ntoa(nbr
->router_id
), nbr
->state
);
1572 #define OSPF_LSA_KEY_SIZE 12 /* type(4) + id(4) + ar(4) */
1574 /* OSPF Link State Request Read -- RFC2328 Section 10.7. */
1575 static void ospf_ls_req(struct ip
*iph
, struct ospf_header
*ospfh
,
1576 struct stream
*s
, struct ospf_interface
*oi
,
1579 struct ospf_neighbor
*nbr
;
1581 struct in_addr ls_id
;
1582 struct in_addr adv_router
;
1583 struct ospf_lsa
*find
;
1584 struct list
*ls_upd
;
1585 unsigned int length
;
1587 /* Increment statistics. */
1590 nbr
= ospf_nbr_lookup(oi
, iph
, ospfh
);
1592 flog_warn(OSPF_WARN_PACKET
,
1593 "Link State Request: Unknown Neighbor %s.",
1594 inet_ntoa(ospfh
->router_id
));
1598 /* Add event to thread. */
1599 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_PacketReceived
);
1601 /* Neighbor State should be Exchange or later. */
1602 if (nbr
->state
!= NSM_Exchange
&& nbr
->state
!= NSM_Loading
1603 && nbr
->state
!= NSM_Full
) {
1606 "Link State Request received from %s: Neighbor state is %s, packet discarded.",
1607 inet_ntoa(ospfh
->router_id
),
1608 lookup_msg(ospf_nsm_state_msg
, nbr
->state
, NULL
));
1612 /* Send Link State Update for ALL requested LSAs. */
1613 ls_upd
= list_new();
1614 length
= OSPF_HEADER_SIZE
+ OSPF_LS_UPD_MIN_SIZE
;
1616 while (size
>= OSPF_LSA_KEY_SIZE
) {
1617 /* Get one slice of Link State Request. */
1618 ls_type
= stream_getl(s
);
1619 ls_id
.s_addr
= stream_get_ipv4(s
);
1620 adv_router
.s_addr
= stream_get_ipv4(s
);
1622 /* Verify LSA type. */
1623 if (ls_type
< OSPF_MIN_LSA
|| ls_type
>= OSPF_MAX_LSA
) {
1624 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_BadLSReq
);
1625 list_delete_and_null(&ls_upd
);
1629 /* Search proper LSA in LSDB. */
1630 find
= ospf_lsa_lookup(oi
->ospf
, oi
->area
, ls_type
, ls_id
,
1633 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_BadLSReq
);
1634 list_delete_and_null(&ls_upd
);
1638 /* Packet overflows MTU size, send immediately. */
1639 if (length
+ ntohs(find
->data
->length
) > ospf_packet_max(oi
)) {
1640 if (oi
->type
== OSPF_IFTYPE_NBMA
)
1641 ospf_ls_upd_send(nbr
, ls_upd
,
1642 OSPF_SEND_PACKET_DIRECT
, 0);
1644 ospf_ls_upd_send(nbr
, ls_upd
,
1645 OSPF_SEND_PACKET_INDIRECT
, 0);
1647 /* Only remove list contents. Keep ls_upd. */
1648 list_delete_all_node(ls_upd
);
1650 length
= OSPF_HEADER_SIZE
+ OSPF_LS_UPD_MIN_SIZE
;
1653 /* Append LSA to update list. */
1654 listnode_add(ls_upd
, find
);
1655 length
+= ntohs(find
->data
->length
);
1657 size
-= OSPF_LSA_KEY_SIZE
;
1660 /* Send rest of Link State Update. */
1661 if (listcount(ls_upd
) > 0) {
1662 if (oi
->type
== OSPF_IFTYPE_NBMA
)
1663 ospf_ls_upd_send(nbr
, ls_upd
, OSPF_SEND_PACKET_DIRECT
,
1666 ospf_ls_upd_send(nbr
, ls_upd
, OSPF_SEND_PACKET_INDIRECT
,
1669 list_delete_and_null(&ls_upd
);
1671 list_delete_and_null(&ls_upd
);
1674 /* Get the list of LSAs from Link State Update packet.
1675 And process some validation -- RFC2328 Section 13. (1)-(2). */
1676 static struct list
*ospf_ls_upd_list_lsa(struct ospf_neighbor
*nbr
,
1678 struct ospf_interface
*oi
, size_t size
)
1680 uint16_t count
, sum
;
1682 struct lsa_header
*lsah
;
1683 struct ospf_lsa
*lsa
;
1688 count
= stream_getl(s
);
1689 size
-= OSPF_LS_UPD_MIN_SIZE
; /* # LSAs */
1691 for (; size
>= OSPF_LSA_HEADER_SIZE
&& count
> 0;
1692 size
-= length
, stream_forward_getp(s
, length
), count
--) {
1693 lsah
= (struct lsa_header
*)stream_pnt(s
);
1694 length
= ntohs(lsah
->length
);
1696 if (length
> size
) {
1699 "Link State Update: LSA length exceeds packet size.");
1703 /* Validate the LSA's LS checksum. */
1704 sum
= lsah
->checksum
;
1705 if (!ospf_lsa_checksum_valid(lsah
)) {
1706 /* (bug #685) more details in a one-line message make it
1708 * to identify problem source on the one hand and to
1710 * chance to compress repeated messages in syslog on the
1714 "Link State Update: LSA checksum error %x/%x, ID=%s from: nbr %s, router ID %s, adv router %s",
1715 sum
, lsah
->checksum
, inet_ntoa(lsah
->id
),
1716 inet_ntoa(nbr
->src
), inet_ntoa(nbr
->router_id
),
1717 inet_ntoa(lsah
->adv_router
));
1721 /* Examine the LSA's LS type. */
1722 if (lsah
->type
< OSPF_MIN_LSA
|| lsah
->type
>= OSPF_MAX_LSA
) {
1723 flog_warn(OSPF_WARN_PACKET
,
1724 "Link State Update: Unknown LS type %d",
1730 * What if the received LSA's age is greater than MaxAge?
1731 * Treat it as a MaxAge case -- endo.
1733 if (ntohs(lsah
->ls_age
) > OSPF_LSA_MAXAGE
)
1734 lsah
->ls_age
= htons(OSPF_LSA_MAXAGE
);
1736 if (CHECK_FLAG(nbr
->options
, OSPF_OPTION_O
)) {
1737 #ifdef STRICT_OBIT_USAGE_CHECK
1738 if ((IS_OPAQUE_LSA(lsah
->type
)
1739 && !CHECK_FLAG(lsah
->options
, OSPF_OPTION_O
))
1740 || (!IS_OPAQUE_LSA(lsah
->type
)
1741 && CHECK_FLAG(lsah
->options
, OSPF_OPTION_O
))) {
1743 * This neighbor must know the exact usage of
1745 * the bit will be set in Type-9,10,11 LSAs
1748 flog_warn(OSPF_WARN_PACKET
,
1749 "LSA[Type%d:%s]: O-bit abuse?",
1750 lsah
->type
, inet_ntoa(lsah
->id
));
1753 #endif /* STRICT_OBIT_USAGE_CHECK */
1755 /* Do not take in AS External Opaque-LSAs if we are a
1757 if (lsah
->type
== OSPF_OPAQUE_AS_LSA
1758 && nbr
->oi
->area
->external_routing
1759 != OSPF_AREA_DEFAULT
) {
1760 if (IS_DEBUG_OSPF_EVENT
)
1762 "LSA[Type%d:%s]: We are a stub, don't take this LSA.",
1764 inet_ntoa(lsah
->id
));
1767 } else if (IS_OPAQUE_LSA(lsah
->type
)) {
1768 flog_warn(OSPF_WARN_PACKET
,
1769 "LSA[Type%d:%s]: Opaque capability mismatch?",
1770 lsah
->type
, inet_ntoa(lsah
->id
));
1774 /* Create OSPF LSA instance. */
1775 lsa
= ospf_lsa_new_and_data(length
);
1777 lsa
->vrf_id
= oi
->ospf
->vrf_id
;
1778 /* We may wish to put some error checking if type NSSA comes in
1779 and area not in NSSA mode */
1780 switch (lsah
->type
) {
1781 case OSPF_AS_EXTERNAL_LSA
:
1782 case OSPF_OPAQUE_AS_LSA
:
1785 case OSPF_OPAQUE_LINK_LSA
:
1786 lsa
->oi
= oi
; /* Remember incoming interface for
1787 flooding control. */
1790 lsa
->area
= oi
->area
;
1794 memcpy(lsa
->data
, lsah
, length
);
1796 if (IS_DEBUG_OSPF_EVENT
)
1798 "LSA[Type%d:%s]: %p new LSA created with Link State Update",
1799 lsa
->data
->type
, inet_ntoa(lsa
->data
->id
),
1801 listnode_add(lsas
, lsa
);
1807 /* Cleanup Update list. */
1808 static void ospf_upd_list_clean(struct list
*lsas
)
1810 struct listnode
*node
, *nnode
;
1811 struct ospf_lsa
*lsa
;
1813 for (ALL_LIST_ELEMENTS(lsas
, node
, nnode
, lsa
))
1814 ospf_lsa_discard(lsa
);
1816 list_delete_and_null(&lsas
);
1819 /* OSPF Link State Update message read -- RFC2328 Section 13. */
1820 static void ospf_ls_upd(struct ospf
*ospf
, struct ip
*iph
,
1821 struct ospf_header
*ospfh
, struct stream
*s
,
1822 struct ospf_interface
*oi
, uint16_t size
)
1824 struct ospf_neighbor
*nbr
;
1826 struct listnode
*node
, *nnode
;
1827 struct ospf_lsa
*lsa
= NULL
;
1828 /* unsigned long ls_req_found = 0; */
1830 /* Dis-assemble the stream, update each entry, re-encapsulate for
1833 /* Increment statistics. */
1836 /* Check neighbor. */
1837 nbr
= ospf_nbr_lookup(oi
, iph
, ospfh
);
1839 flog_warn(OSPF_WARN_PACKET
,
1840 "Link State Update: Unknown Neighbor %s on int: %s",
1841 inet_ntoa(ospfh
->router_id
), IF_NAME(oi
));
1845 /* Add event to thread. */
1846 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_PacketReceived
);
1848 /* Check neighbor state. */
1849 if (nbr
->state
< NSM_Exchange
) {
1850 if (IS_DEBUG_OSPF(nsm
, NSM_EVENTS
))
1852 "Link State Update: "
1853 "Neighbor[%s] state %s is less than Exchange",
1854 inet_ntoa(ospfh
->router_id
),
1855 lookup_msg(ospf_nsm_state_msg
, nbr
->state
,
1860 /* Get list of LSAs from Link State Update packet. - Also perorms Stages
1861 * 1 (validate LSA checksum) and 2 (check for LSA consistent type)
1864 lsas
= ospf_ls_upd_list_lsa(nbr
, s
, oi
, size
);
1868 #define DISCARD_LSA(L, N) \
1870 if (IS_DEBUG_OSPF_EVENT) \
1872 "ospf_lsa_discard() in ospf_ls_upd() point %d: lsa %p" \
1874 N, (void *)lsa, (int)lsa->data->type); \
1875 ospf_lsa_discard(L); \
1879 /* Process each LSA received in the one packet.
1881 * Numbers in parentheses, e.g. (1), (2), etc., and the corresponding
1882 * text below are from the steps in RFC 2328, Section 13.
1884 for (ALL_LIST_ELEMENTS(lsas
, node
, nnode
, lsa
)) {
1885 struct ospf_lsa
*ls_ret
, *current
;
1888 if (IS_DEBUG_OSPF_NSSA
) {
1889 char buf1
[INET_ADDRSTRLEN
];
1890 char buf2
[INET_ADDRSTRLEN
];
1891 char buf3
[INET_ADDRSTRLEN
];
1893 zlog_debug("LSA Type-%d from %s, ID: %s, ADV: %s",
1895 inet_ntop(AF_INET
, &ospfh
->router_id
, buf1
,
1897 inet_ntop(AF_INET
, &lsa
->data
->id
, buf2
,
1899 inet_ntop(AF_INET
, &lsa
->data
->adv_router
,
1900 buf3
, INET_ADDRSTRLEN
));
1903 listnode_delete(lsas
,
1904 lsa
); /* We don't need it in list anymore */
1906 /* (1) Validate Checksum - Done above by ospf_ls_upd_list_lsa()
1909 /* (2) LSA Type - Done above by ospf_ls_upd_list_lsa() */
1911 /* (3) Do not take in AS External LSAs if we are a stub or NSSA.
1914 /* Do not take in AS NSSA if this neighbor and we are not NSSA
1917 /* Do take in Type-7's if we are an NSSA */
1919 /* If we are also an ABR, later translate them to a Type-5
1922 /* Later, an NSSA Re-fresh can Re-fresh Type-7's and an ABR will
1923 translate them to a separate Type-5 packet. */
1925 if (lsa
->data
->type
== OSPF_AS_EXTERNAL_LSA
)
1926 /* Reject from STUB or NSSA */
1927 if (nbr
->oi
->area
->external_routing
1928 != OSPF_AREA_DEFAULT
) {
1929 if (IS_DEBUG_OSPF_NSSA
)
1931 "Incoming External LSA Discarded: We are NSSA/STUB Area");
1932 DISCARD_LSA(lsa
, 1);
1935 if (lsa
->data
->type
== OSPF_AS_NSSA_LSA
)
1936 if (nbr
->oi
->area
->external_routing
!= OSPF_AREA_NSSA
) {
1937 if (IS_DEBUG_OSPF_NSSA
)
1939 "Incoming NSSA LSA Discarded: Not NSSA Area");
1940 DISCARD_LSA(lsa
, 2);
1943 /* VU229804: Router-LSA Adv-ID must be equal to LS-ID */
1944 if (lsa
->data
->type
== OSPF_ROUTER_LSA
)
1945 if (!IPV4_ADDR_SAME(&lsa
->data
->id
,
1946 &lsa
->data
->adv_router
)) {
1947 char buf1
[INET_ADDRSTRLEN
];
1948 char buf2
[INET_ADDRSTRLEN
];
1949 char buf3
[INET_ADDRSTRLEN
];
1951 flog_err(OSPF_ERR_ROUTER_LSA_MISMATCH
,
1952 "Incoming Router-LSA from %s with "
1953 "Adv-ID[%s] != LS-ID[%s]",
1954 inet_ntop(AF_INET
, &ospfh
->router_id
,
1955 buf1
, INET_ADDRSTRLEN
),
1956 inet_ntop(AF_INET
, &lsa
->data
->id
,
1957 buf2
, INET_ADDRSTRLEN
),
1959 &lsa
->data
->adv_router
,
1960 buf3
, INET_ADDRSTRLEN
));
1962 OSPF_ERR_DOMAIN_CORRUPT
,
1963 "OSPF domain compromised by attack or corruption. "
1964 "Verify correct operation of -ALL- OSPF routers.");
1965 DISCARD_LSA(lsa
, 0);
1968 /* Find the LSA in the current database. */
1970 current
= ospf_lsa_lookup_by_header(oi
->area
, lsa
->data
);
1972 /* (4) If the LSA's LS age is equal to MaxAge, and there is
1974 no instance of the LSA in the router's link state database,
1975 and none of router's neighbors are in states Exchange or
1977 then take the following actions: */
1979 if (IS_LSA_MAXAGE(lsa
) && !current
1980 && ospf_check_nbr_status(oi
->ospf
)) {
1981 /* (4a) Response Link State Acknowledgment. */
1982 ospf_ls_ack_send(nbr
, lsa
);
1984 /* (4b) Discard LSA. */
1985 if (IS_DEBUG_OSPF(lsa
, LSA
)) {
1987 "Link State Update[%s]: LS age is equal to MaxAge.",
1990 DISCARD_LSA(lsa
, 3);
1993 if (IS_OPAQUE_LSA(lsa
->data
->type
)
1994 && IPV4_ADDR_SAME(&lsa
->data
->adv_router
,
1995 &oi
->ospf
->router_id
)) {
1997 * Even if initial flushing seems to be completed, there
1999 * be a case that self-originated LSA with MaxAge still
2001 * in the routing domain.
2002 * Just send an LSAck message to cease retransmission.
2004 if (IS_LSA_MAXAGE(lsa
)) {
2005 zlog_info("LSA[%s]: Boomerang effect?",
2007 ospf_ls_ack_send(nbr
, lsa
);
2008 ospf_lsa_discard(lsa
);
2010 if (current
!= NULL
&& !IS_LSA_MAXAGE(current
))
2011 ospf_opaque_lsa_refresh_schedule(
2017 * If an instance of self-originated Opaque-LSA is not
2019 * in the LSDB, there are some possible cases here.
2021 * 1) This node lost opaque-capability after restart.
2022 * 2) Else, a part of opaque-type is no more supported.
2023 * 3) Else, a part of opaque-id is no more supported.
2025 * Anyway, it is still this node's responsibility to
2027 * Otherwise, the LSA instance remains in the routing
2029 * until its age reaches to MaxAge.
2031 /* XXX: We should deal with this for *ALL* LSAs, not
2033 if (current
== NULL
) {
2034 if (IS_DEBUG_OSPF_EVENT
)
2036 "LSA[%s]: Previously originated Opaque-LSA,"
2037 "not found in the LSDB.",
2040 SET_FLAG(lsa
->flags
, OSPF_LSA_SELF
);
2042 ospf_opaque_self_originated_lsa_received(nbr
,
2044 ospf_ls_ack_send(nbr
, lsa
);
2050 /* It might be happen that received LSA is self-originated
2052 * router ID is changed. So, we should check if LSA is a
2054 * Link State ID is one of the router's own IP interface
2055 * addresses but whose
2056 * Advertising Router is not equal to the router's own Router ID
2057 * According to RFC 2328 12.4.2 and 13.4 this LSA should be
2061 if (lsa
->data
->type
== OSPF_NETWORK_LSA
) {
2062 struct listnode
*oinode
, *oinnode
;
2063 struct ospf_interface
*out_if
;
2066 for (ALL_LIST_ELEMENTS(oi
->ospf
->oiflist
, oinode
,
2071 if ((IPV4_ADDR_SAME(&out_if
->address
->u
.prefix4
,
2073 && (!(IPV4_ADDR_SAME(
2074 &oi
->ospf
->router_id
,
2075 &lsa
->data
->adv_router
)))) {
2076 if (out_if
->network_lsa_self
) {
2077 ospf_lsa_flush_area(
2079 if (IS_DEBUG_OSPF_EVENT
)
2081 "ospf_lsa_discard() in ospf_ls_upd() point 9: lsa %p Type-%d",
2085 ospf_lsa_discard(lsa
);
2095 /* (5) Find the instance of this LSA that is currently contained
2096 in the router's link state database. If there is no
2097 database copy, or the received LSA is more recent than
2098 the database copy the following steps must be performed.
2099 (The sub steps from RFC 2328 section 13 step (5) will be
2104 || (ret
= ospf_lsa_more_recent(current
, lsa
)) < 0) {
2105 /* Actual flooding procedure. */
2106 if (ospf_flood(oi
->ospf
, nbr
, current
, lsa
)
2107 < 0) /* Trap NSSA later. */
2108 DISCARD_LSA(lsa
, 4);
2112 /* (6) Else, If there is an instance of the LSA on the sending
2113 neighbor's Link state request list, an error has occurred in
2114 the Database Exchange process. In this case, restart the
2115 Database Exchange process by generating the neighbor event
2116 BadLSReq for the sending neighbor and stop processing the
2117 Link State Update packet. */
2119 if (ospf_ls_request_lookup(nbr
, lsa
)) {
2120 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_BadLSReq
);
2123 "LSA[%s] instance exists on Link state request list",
2126 /* Clean list of LSAs. */
2127 ospf_upd_list_clean(lsas
);
2128 /* this lsa is not on lsas list already. */
2129 ospf_lsa_discard(lsa
);
2133 /* If the received LSA is the same instance as the database copy
2134 (i.e., neither one is more recent) the following two steps
2135 should be performed: */
2138 /* If the LSA is listed in the Link state retransmission
2140 for the receiving adjacency, the router itself is
2142 an acknowledgment for this LSA. The router should
2144 received LSA as an acknowledgment by removing the LSA
2146 the Link state retransmission list. This is termed
2148 "implied acknowledgment". */
2150 ls_ret
= ospf_ls_retransmit_lookup(nbr
, lsa
);
2152 if (ls_ret
!= NULL
) {
2153 ospf_ls_retransmit_delete(nbr
, ls_ret
);
2155 /* Delayed acknowledgment sent if advertisement
2157 from Designated Router, otherwise do nothing.
2159 if (oi
->state
== ISM_Backup
)
2163 ospf_lsa_lock(lsa
));
2165 DISCARD_LSA(lsa
, 5);
2167 /* Acknowledge the receipt of the LSA by sending a
2168 Link State Acknowledgment packet back out the
2172 ospf_ls_ack_send(nbr
, lsa
);
2173 DISCARD_LSA(lsa
, 6);
2177 /* The database copy is more recent. If the database copy
2178 has LS age equal to MaxAge and LS sequence number equal to
2179 MaxSequenceNumber, simply discard the received LSA without
2180 acknowledging it. (In this case, the LSA's LS sequence number
2182 wrapping, and the MaxSequenceNumber LSA must be completely
2183 flushed before any new LSA instance can be introduced). */
2185 else if (ret
> 0) /* Database copy is more recent */
2187 if (IS_LSA_MAXAGE(current
)
2188 && current
->data
->ls_seqnum
2189 == htonl(OSPF_MAX_SEQUENCE_NUMBER
)) {
2190 DISCARD_LSA(lsa
, 7);
2192 /* Otherwise, as long as the database copy has not been
2194 Link State Update within the last MinLSArrival
2196 database copy back to the sending neighbor,
2198 a Link State Update Packet. The Link State Update
2200 be sent directly to the neighbor. In so doing, do not
2202 database copy of the LSA on the neighbor's link state
2203 retransmission list, and do not acknowledge the
2205 recent) LSA instance. */
2207 if (monotime_since(¤t
->tv_orig
, NULL
)
2208 >= ospf
->min_ls_arrival
* 1000LL)
2209 /* Trap NSSA type later.*/
2210 ospf_ls_upd_send_lsa(
2212 OSPF_SEND_PACKET_DIRECT
);
2213 DISCARD_LSA(lsa
, 8);
2219 assert(listcount(lsas
) == 0);
2220 list_delete_and_null(&lsas
);
2223 /* OSPF Link State Acknowledgment message read -- RFC2328 Section 13.7. */
2224 static void ospf_ls_ack(struct ip
*iph
, struct ospf_header
*ospfh
,
2225 struct stream
*s
, struct ospf_interface
*oi
,
2228 struct ospf_neighbor
*nbr
;
2230 /* increment statistics. */
2233 nbr
= ospf_nbr_lookup(oi
, iph
, ospfh
);
2235 flog_warn(OSPF_WARN_PACKET
,
2236 "Link State Acknowledgment: Unknown Neighbor %s.",
2237 inet_ntoa(ospfh
->router_id
));
2241 /* Add event to thread. */
2242 OSPF_NSM_EVENT_SCHEDULE(nbr
, NSM_PacketReceived
);
2244 if (nbr
->state
< NSM_Exchange
) {
2245 if (IS_DEBUG_OSPF(nsm
, NSM_EVENTS
))
2247 "Link State Acknowledgment: "
2248 "Neighbor[%s] state %s is less than Exchange",
2249 inet_ntoa(ospfh
->router_id
),
2250 lookup_msg(ospf_nsm_state_msg
, nbr
->state
,
2255 while (size
>= OSPF_LSA_HEADER_SIZE
) {
2256 struct ospf_lsa
*lsa
, *lsr
;
2258 lsa
= ospf_lsa_new();
2259 lsa
->data
= (struct lsa_header
*)stream_pnt(s
);
2260 lsa
->vrf_id
= oi
->ospf
->vrf_id
;
2262 /* lsah = (struct lsa_header *) stream_pnt (s); */
2263 size
-= OSPF_LSA_HEADER_SIZE
;
2264 stream_forward_getp(s
, OSPF_LSA_HEADER_SIZE
);
2266 if (lsa
->data
->type
< OSPF_MIN_LSA
2267 || lsa
->data
->type
>= OSPF_MAX_LSA
) {
2269 ospf_lsa_discard(lsa
);
2273 lsr
= ospf_ls_retransmit_lookup(nbr
, lsa
);
2275 if (lsr
!= NULL
&& ospf_lsa_more_recent(lsr
, lsa
) == 0)
2276 ospf_ls_retransmit_delete(nbr
, lsr
);
2279 ospf_lsa_discard(lsa
);
2285 static struct stream
*ospf_recv_packet(struct ospf
*ospf
, int fd
,
2286 struct interface
**ifp
,
2287 struct stream
*ibuf
)
2292 ifindex_t ifindex
= 0;
2294 /* Header and data both require alignment. */
2295 char buff
[CMSG_SPACE(SOPT_SIZE_CMSG_IFINDEX_IPV4())];
2298 memset(&msgh
, 0, sizeof(struct msghdr
));
2299 msgh
.msg_iov
= &iov
;
2300 msgh
.msg_iovlen
= 1;
2301 msgh
.msg_control
= (caddr_t
)buff
;
2302 msgh
.msg_controllen
= sizeof(buff
);
2304 ret
= stream_recvmsg(ibuf
, fd
, &msgh
, 0, OSPF_MAX_PACKET_SIZE
+ 1);
2306 flog_warn(OSPF_WARN_PACKET
, "stream_recvmsg failed: %s",
2307 safe_strerror(errno
));
2310 if ((unsigned int)ret
< sizeof(iph
)) /* ret must be > 0 now */
2314 "ospf_recv_packet: discarding runt packet of length %d "
2315 "(ip header size is %u)",
2316 ret
, (unsigned int)sizeof(iph
));
2320 /* Note that there should not be alignment problems with this assignment
2321 because this is at the beginning of the stream data buffer. */
2322 iph
= (struct ip
*)STREAM_DATA(ibuf
);
2323 sockopt_iphdrincl_swab_systoh(iph
);
2325 ip_len
= iph
->ip_len
;
2327 #if !defined(GNU_LINUX) && (OpenBSD < 200311) && (__FreeBSD_version < 1000000)
2329 * Kernel network code touches incoming IP header parameters,
2330 * before protocol specific processing.
2332 * 1) Convert byteorder to host representation.
2333 * --> ip_len, ip_id, ip_off
2335 * 2) Adjust ip_len to strip IP header size!
2336 * --> If user process receives entire IP packet via RAW
2337 * socket, it must consider adding IP header size to
2338 * the "ip_len" field of "ip" structure.
2340 * For more details, see <netinet/ip_input.c>.
2342 ip_len
= ip_len
+ (iph
->ip_hl
<< 2);
2345 #if defined(__DragonFly__)
2347 * in DragonFly's raw socket, ip_len/ip_off are read
2348 * in network byte order.
2349 * As OpenBSD < 200311 adjust ip_len to strip IP header size!
2351 ip_len
= ntohs(iph
->ip_len
) + (iph
->ip_hl
<< 2);
2354 ifindex
= getsockopt_ifindex(AF_INET
, &msgh
);
2356 *ifp
= if_lookup_by_index(ifindex
, ospf
->vrf_id
);
2358 if (ret
!= ip_len
) {
2361 "ospf_recv_packet read length mismatch: ip_len is %d, "
2362 "but recvmsg returned %d",
2370 static struct ospf_interface
*
2371 ospf_associate_packet_vl(struct ospf
*ospf
, struct interface
*ifp
,
2372 struct ip
*iph
, struct ospf_header
*ospfh
)
2374 struct ospf_interface
*rcv_oi
;
2375 struct ospf_vl_data
*vl_data
;
2376 struct ospf_area
*vl_area
;
2377 struct listnode
*node
;
2379 if (IN_MULTICAST(ntohl(iph
->ip_dst
.s_addr
))
2380 || !OSPF_IS_AREA_BACKBONE(ospfh
))
2383 /* look for local OSPF interface matching the destination
2384 * to determine Area ID. We presume therefore the destination address
2385 * is unique, or at least (for "unnumbered" links), not used in other
2388 if ((rcv_oi
= ospf_if_lookup_by_local_addr(ospf
, NULL
, iph
->ip_dst
))
2392 for (ALL_LIST_ELEMENTS_RO(ospf
->vlinks
, node
, vl_data
)) {
2394 ospf_area_lookup_by_area_id(ospf
, vl_data
->vl_area_id
);
2398 if (OSPF_AREA_SAME(&vl_area
, &rcv_oi
->area
)
2399 && IPV4_ADDR_SAME(&vl_data
->vl_peer
, &ospfh
->router_id
)) {
2400 if (IS_DEBUG_OSPF_EVENT
)
2401 zlog_debug("associating packet with %s",
2402 IF_NAME(vl_data
->vl_oi
));
2403 if (!CHECK_FLAG(vl_data
->vl_oi
->ifp
->flags
, IFF_UP
)) {
2404 if (IS_DEBUG_OSPF_EVENT
)
2406 "This VL is not up yet, sorry");
2410 return vl_data
->vl_oi
;
2414 if (IS_DEBUG_OSPF_EVENT
)
2415 zlog_debug("couldn't find any VL to associate the packet with");
2420 static int ospf_check_area_id(struct ospf_interface
*oi
,
2421 struct ospf_header
*ospfh
)
2423 /* Check match the Area ID of the receiving interface. */
2424 if (OSPF_AREA_SAME(&oi
->area
, &ospfh
))
2430 /* Unbound socket will accept any Raw IP packets if proto is matched.
2431 To prevent it, compare src IP address and i/f address with masking
2432 i/f network mask. */
2433 static int ospf_check_network_mask(struct ospf_interface
*oi
,
2434 struct in_addr ip_src
)
2436 struct in_addr mask
, me
, him
;
2438 if (oi
->type
== OSPF_IFTYPE_POINTOPOINT
2439 || oi
->type
== OSPF_IFTYPE_VIRTUALLINK
)
2442 masklen2ip(oi
->address
->prefixlen
, &mask
);
2444 me
.s_addr
= oi
->address
->u
.prefix4
.s_addr
& mask
.s_addr
;
2445 him
.s_addr
= ip_src
.s_addr
& mask
.s_addr
;
2447 if (IPV4_ADDR_SAME(&me
, &him
))
2453 /* Return 1, if the packet is properly authenticated and checksummed,
2454 0 otherwise. In particular, check that AuType header field is valid and
2455 matches the locally configured AuType, and that D.5 requirements are met. */
2456 static int ospf_check_auth(struct ospf_interface
*oi
, struct ospf_header
*ospfh
)
2458 struct crypt_key
*ck
;
2459 uint16_t iface_auth_type
;
2460 uint16_t pkt_auth_type
= ntohs(ospfh
->auth_type
);
2462 switch (pkt_auth_type
) {
2463 case OSPF_AUTH_NULL
: /* RFC2328 D.5.1 */
2464 if (OSPF_AUTH_NULL
!= (iface_auth_type
= ospf_auth_type(oi
))) {
2465 if (IS_DEBUG_OSPF_PACKET(ospfh
->type
- 1, RECV
))
2468 "interface %s: auth-type mismatch, local %s, rcvd Null",
2470 lookup_msg(ospf_auth_type_str
,
2471 iface_auth_type
, NULL
));
2474 if (!ospf_check_sum(ospfh
)) {
2475 if (IS_DEBUG_OSPF_PACKET(ospfh
->type
- 1, RECV
))
2478 "interface %s: Null auth OK, but checksum error, Router-ID %s",
2480 inet_ntoa(ospfh
->router_id
));
2484 case OSPF_AUTH_SIMPLE
: /* RFC2328 D.5.2 */
2485 if (OSPF_AUTH_SIMPLE
2486 != (iface_auth_type
= ospf_auth_type(oi
))) {
2487 if (IS_DEBUG_OSPF_PACKET(ospfh
->type
- 1, RECV
))
2490 "interface %s: auth-type mismatch, local %s, rcvd Simple",
2492 lookup_msg(ospf_auth_type_str
,
2493 iface_auth_type
, NULL
));
2496 if (memcmp(OSPF_IF_PARAM(oi
, auth_simple
), ospfh
->u
.auth_data
,
2497 OSPF_AUTH_SIMPLE_SIZE
)) {
2498 if (IS_DEBUG_OSPF_PACKET(ospfh
->type
- 1, RECV
))
2499 flog_warn(OSPF_WARN_PACKET
,
2500 "interface %s: Simple auth failed",
2504 if (!ospf_check_sum(ospfh
)) {
2505 if (IS_DEBUG_OSPF_PACKET(ospfh
->type
- 1, RECV
))
2508 "interface %s: Simple auth OK, checksum error, Router-ID %s",
2510 inet_ntoa(ospfh
->router_id
));
2514 case OSPF_AUTH_CRYPTOGRAPHIC
: /* RFC2328 D.5.3 */
2515 if (OSPF_AUTH_CRYPTOGRAPHIC
2516 != (iface_auth_type
= ospf_auth_type(oi
))) {
2517 if (IS_DEBUG_OSPF_PACKET(ospfh
->type
- 1, RECV
))
2520 "interface %s: auth-type mismatch, local %s, rcvd Cryptographic",
2522 lookup_msg(ospf_auth_type_str
,
2523 iface_auth_type
, NULL
));
2526 if (ospfh
->checksum
) {
2527 if (IS_DEBUG_OSPF_PACKET(ospfh
->type
- 1, RECV
))
2530 "interface %s: OSPF header checksum is not 0",
2534 /* only MD5 crypto method can pass ospf_packet_examin() */
2535 if (NULL
== (ck
= listgetdata(
2536 listtail(OSPF_IF_PARAM(oi
, auth_crypt
))))
2537 || ospfh
->u
.crypt
.key_id
!= ck
->key_id
||
2538 /* Condition above uses the last key ID on the list,
2540 different from what ospf_crypt_key_lookup() does. A
2542 !ospf_check_md5_digest(oi
, ospfh
)) {
2543 if (IS_DEBUG_OSPF_PACKET(ospfh
->type
- 1, RECV
))
2544 flog_warn(OSPF_WARN_MD5
,
2545 "interface %s: MD5 auth failed",
2551 if (IS_DEBUG_OSPF_PACKET(ospfh
->type
- 1, RECV
))
2554 "interface %s: invalid packet auth-type (%02x)",
2555 IF_NAME(oi
), pkt_auth_type
);
2560 static int ospf_check_sum(struct ospf_header
*ospfh
)
2565 /* clear auth_data for checksum. */
2566 memset(ospfh
->u
.auth_data
, 0, OSPF_AUTH_SIMPLE_SIZE
);
2568 /* keep checksum and clear. */
2569 sum
= ospfh
->checksum
;
2570 memset(&ospfh
->checksum
, 0, sizeof(uint16_t));
2572 /* calculate checksum. */
2573 ret
= in_cksum(ospfh
, ntohs(ospfh
->length
));
2576 zlog_info("ospf_check_sum(): checksum mismatch, my %X, his %X",
2584 /* Verify, that given link/TOS records are properly sized/aligned and match
2585 Router-LSA "# links" and "# TOS" fields as specified in RFC2328 A.4.2. */
2586 static unsigned ospf_router_lsa_links_examin(struct router_lsa_link
*link
,
2588 const uint16_t num_links
)
2590 unsigned counted_links
= 0, thislinklen
;
2594 OSPF_ROUTER_LSA_LINK_SIZE
+ 4 * link
->m
[0].tos_count
;
2595 if (thislinklen
> linkbytes
) {
2596 if (IS_DEBUG_OSPF_PACKET(0, RECV
))
2597 zlog_debug("%s: length error in link block #%u",
2598 __func__
, counted_links
);
2601 link
= (struct router_lsa_link
*)((caddr_t
)link
+ thislinklen
);
2602 linkbytes
-= thislinklen
;
2605 if (counted_links
!= num_links
) {
2606 if (IS_DEBUG_OSPF_PACKET(0, RECV
))
2607 zlog_debug("%s: %u link blocks declared, %u present",
2608 __func__
, num_links
, counted_links
);
2614 /* Verify, that the given LSA is properly sized/aligned (including type-specific
2615 minimum length constraint). */
2616 static unsigned ospf_lsa_examin(struct lsa_header
*lsah
, const uint16_t lsalen
,
2617 const uint8_t headeronly
)
2620 struct router_lsa
*rlsa
;
2621 if (lsah
->type
< OSPF_MAX_LSA
&& ospf_lsa_minlen
[lsah
->type
]
2622 && lsalen
< OSPF_LSA_HEADER_SIZE
+ ospf_lsa_minlen
[lsah
->type
]) {
2623 if (IS_DEBUG_OSPF_PACKET(0, RECV
))
2624 zlog_debug("%s: undersized (%u B) %s", __func__
, lsalen
,
2625 lookup_msg(ospf_lsa_type_msg
, lsah
->type
,
2629 switch (lsah
->type
) {
2630 case OSPF_ROUTER_LSA
:
2631 /* RFC2328 A.4.2, LSA header + 4 bytes followed by N>=1
2632 * (12+)-byte link blocks */
2634 ret
= (lsalen
- OSPF_LSA_HEADER_SIZE
2635 - OSPF_ROUTER_LSA_MIN_SIZE
)
2641 rlsa
= (struct router_lsa
*)lsah
;
2642 ret
= ospf_router_lsa_links_examin(
2643 (struct router_lsa_link
*)rlsa
->link
,
2644 lsalen
- OSPF_LSA_HEADER_SIZE
- 4, /* skip: basic
2647 ntohs(rlsa
->links
) /* 16 bits */
2650 case OSPF_AS_EXTERNAL_LSA
:
2651 /* RFC2328 A.4.5, LSA header + 4 bytes followed by N>=1 12-bytes long
2653 case OSPF_AS_NSSA_LSA
:
2654 /* RFC3101 C, idem */
2655 ret
= (lsalen
- OSPF_LSA_HEADER_SIZE
2656 - OSPF_AS_EXTERNAL_LSA_MIN_SIZE
)
2661 /* Following LSA types are considered OK length-wise as soon as their
2663 * length constraint is met and length of the whole LSA is a multiple of
2665 * (basic LSA header size is already a multiple of 4). */
2666 case OSPF_NETWORK_LSA
:
2667 /* RFC2328 A.4.3, LSA header + 4 bytes followed by N>=1 router-IDs */
2668 case OSPF_SUMMARY_LSA
:
2669 case OSPF_ASBR_SUMMARY_LSA
:
2670 /* RFC2328 A.4.4, LSA header + 4 bytes followed by N>=1 4-bytes TOS
2672 case OSPF_OPAQUE_LINK_LSA
:
2673 case OSPF_OPAQUE_AREA_LSA
:
2674 case OSPF_OPAQUE_AS_LSA
:
2675 /* RFC5250 A.2, "some number of octets (of application-specific
2676 * data) padded to 32-bit alignment." This is considered
2678 * to 4-byte alignment of all other LSA types, see
2679 * OSPF-ALIGNMENT.txt
2680 * file for the detailed analysis of this passage. */
2681 ret
= lsalen
% 4 ? MSG_NG
: MSG_OK
;
2684 if (IS_DEBUG_OSPF_PACKET(0, RECV
))
2685 zlog_debug("%s: unsupported LSA type 0x%02x", __func__
,
2689 if (ret
!= MSG_OK
&& IS_DEBUG_OSPF_PACKET(0, RECV
))
2690 zlog_debug("%s: alignment error in %s", __func__
,
2691 lookup_msg(ospf_lsa_type_msg
, lsah
->type
, NULL
));
2695 /* Verify if the provided input buffer is a valid sequence of LSAs. This
2696 includes verification of LSA blocks length/alignment and dispatching
2697 of deeper-level checks. */
2699 ospf_lsaseq_examin(struct lsa_header
*lsah
, /* start of buffered data */
2700 size_t length
, const uint8_t headeronly
,
2701 /* When declared_num_lsas is not 0, compare it to the real
2703 and treat the difference as an error. */
2704 const uint32_t declared_num_lsas
)
2706 uint32_t counted_lsas
= 0;
2710 if (length
< OSPF_LSA_HEADER_SIZE
) {
2711 if (IS_DEBUG_OSPF_PACKET(0, RECV
))
2713 "%s: undersized (%zu B) trailing (#%u) LSA header",
2714 __func__
, length
, counted_lsas
);
2717 /* save on ntohs() calls here and in the LSA validator */
2718 lsalen
= ntohs(lsah
->length
);
2719 if (lsalen
< OSPF_LSA_HEADER_SIZE
) {
2720 if (IS_DEBUG_OSPF_PACKET(0, RECV
))
2722 "%s: malformed LSA header #%u, declared length is %u B",
2723 __func__
, counted_lsas
, lsalen
);
2727 /* less checks here and in ospf_lsa_examin() */
2728 if (MSG_OK
!= ospf_lsa_examin(lsah
, lsalen
, 1)) {
2729 if (IS_DEBUG_OSPF_PACKET(0, RECV
))
2731 "%s: malformed header-only LSA #%u",
2732 __func__
, counted_lsas
);
2735 lsah
= (struct lsa_header
*)((caddr_t
)lsah
2736 + OSPF_LSA_HEADER_SIZE
);
2737 length
-= OSPF_LSA_HEADER_SIZE
;
2739 /* make sure the input buffer is deep enough before
2741 if (lsalen
> length
) {
2742 if (IS_DEBUG_OSPF_PACKET(0, RECV
))
2744 "%s: anomaly in LSA #%u: declared length is %u B, buffered length is %zu B",
2745 __func__
, counted_lsas
, lsalen
,
2749 if (MSG_OK
!= ospf_lsa_examin(lsah
, lsalen
, 0)) {
2750 if (IS_DEBUG_OSPF_PACKET(0, RECV
))
2751 zlog_debug("%s: malformed LSA #%u",
2752 __func__
, counted_lsas
);
2755 lsah
= (struct lsa_header
*)((caddr_t
)lsah
+ lsalen
);
2761 if (declared_num_lsas
&& counted_lsas
!= declared_num_lsas
) {
2762 if (IS_DEBUG_OSPF_PACKET(0, RECV
))
2764 "%s: #LSAs declared (%u) does not match actual (%u)",
2765 __func__
, declared_num_lsas
, counted_lsas
);
2771 /* Verify a complete OSPF packet for proper sizing/alignment. */
2772 static unsigned ospf_packet_examin(struct ospf_header
*oh
,
2773 const unsigned bytesonwire
)
2775 uint16_t bytesdeclared
, bytesauth
;
2777 struct ospf_ls_update
*lsupd
;
2779 /* Length, 1st approximation. */
2780 if (bytesonwire
< OSPF_HEADER_SIZE
) {
2781 if (IS_DEBUG_OSPF_PACKET(0, RECV
))
2782 zlog_debug("%s: undersized (%u B) packet", __func__
,
2786 /* Now it is safe to access header fields. Performing length check,
2788 * for possible extra bytes of crypto auth/padding, which are not
2790 * in the OSPF header "length" field. */
2791 if (oh
->version
!= OSPF_VERSION
) {
2792 if (IS_DEBUG_OSPF_PACKET(0, RECV
))
2793 zlog_debug("%s: invalid (%u) protocol version",
2794 __func__
, oh
->version
);
2797 bytesdeclared
= ntohs(oh
->length
);
2798 if (ntohs(oh
->auth_type
) != OSPF_AUTH_CRYPTOGRAPHIC
)
2801 if (oh
->u
.crypt
.auth_data_len
!= OSPF_AUTH_MD5_SIZE
) {
2802 if (IS_DEBUG_OSPF_PACKET(0, RECV
))
2804 "%s: unsupported crypto auth length (%u B)",
2805 __func__
, oh
->u
.crypt
.auth_data_len
);
2808 bytesauth
= OSPF_AUTH_MD5_SIZE
;
2810 if (bytesdeclared
+ bytesauth
> bytesonwire
) {
2811 if (IS_DEBUG_OSPF_PACKET(0, RECV
))
2813 "%s: packet length error (%u real, %u+%u declared)",
2814 __func__
, bytesonwire
, bytesdeclared
,
2818 /* Length, 2nd approximation. The type-specific constraint is checked
2819 against declared length, not amount of bytes on wire. */
2820 if (oh
->type
>= OSPF_MSG_HELLO
&& oh
->type
<= OSPF_MSG_LS_ACK
2822 < OSPF_HEADER_SIZE
+ ospf_packet_minlen
[oh
->type
]) {
2823 if (IS_DEBUG_OSPF_PACKET(0, RECV
))
2824 zlog_debug("%s: undersized (%u B) %s packet", __func__
,
2826 lookup_msg(ospf_packet_type_str
, oh
->type
,
2831 case OSPF_MSG_HELLO
:
2832 /* RFC2328 A.3.2, packet header + OSPF_HELLO_MIN_SIZE bytes
2834 by N>=0 router-IDs. */
2835 ret
= (bytesdeclared
- OSPF_HEADER_SIZE
- OSPF_HELLO_MIN_SIZE
)
2840 case OSPF_MSG_DB_DESC
:
2841 /* RFC2328 A.3.3, packet header + OSPF_DB_DESC_MIN_SIZE bytes
2843 by N>=0 header-only LSAs. */
2844 ret
= ospf_lsaseq_examin(
2845 (struct lsa_header
*)((caddr_t
)oh
+ OSPF_HEADER_SIZE
2846 + OSPF_DB_DESC_MIN_SIZE
),
2847 bytesdeclared
- OSPF_HEADER_SIZE
2848 - OSPF_DB_DESC_MIN_SIZE
,
2849 1, /* header-only LSAs */
2852 case OSPF_MSG_LS_REQ
:
2853 /* RFC2328 A.3.4, packet header followed by N>=0 12-bytes
2854 * request blocks. */
2855 ret
= (bytesdeclared
- OSPF_HEADER_SIZE
- OSPF_LS_REQ_MIN_SIZE
)
2860 case OSPF_MSG_LS_UPD
:
2861 /* RFC2328 A.3.5, packet header + OSPF_LS_UPD_MIN_SIZE bytes
2863 by N>=0 full LSAs (with N declared beforehand). */
2864 lsupd
= (struct ospf_ls_update
*)((caddr_t
)oh
2865 + OSPF_HEADER_SIZE
);
2866 ret
= ospf_lsaseq_examin(
2867 (struct lsa_header
*)((caddr_t
)lsupd
2868 + OSPF_LS_UPD_MIN_SIZE
),
2869 bytesdeclared
- OSPF_HEADER_SIZE
- OSPF_LS_UPD_MIN_SIZE
,
2871 ntohl(lsupd
->num_lsas
) /* 32 bits */
2874 case OSPF_MSG_LS_ACK
:
2875 /* RFC2328 A.3.6, packet header followed by N>=0 header-only
2877 ret
= ospf_lsaseq_examin(
2878 (struct lsa_header
*)((caddr_t
)oh
+ OSPF_HEADER_SIZE
2879 + OSPF_LS_ACK_MIN_SIZE
),
2880 bytesdeclared
- OSPF_HEADER_SIZE
- OSPF_LS_ACK_MIN_SIZE
,
2881 1, /* header-only LSAs */
2885 if (IS_DEBUG_OSPF_PACKET(0, RECV
))
2886 zlog_debug("%s: invalid packet type 0x%02x", __func__
,
2890 if (ret
!= MSG_OK
&& IS_DEBUG_OSPF_PACKET(0, RECV
))
2891 zlog_debug("%s: malformed %s packet", __func__
,
2892 lookup_msg(ospf_packet_type_str
, oh
->type
, NULL
));
2896 /* OSPF Header verification. */
2897 static int ospf_verify_header(struct stream
*ibuf
, struct ospf_interface
*oi
,
2898 struct ip
*iph
, struct ospf_header
*ospfh
)
2900 /* Check Area ID. */
2901 if (!ospf_check_area_id(oi
, ospfh
)) {
2902 flog_warn(OSPF_WARN_PACKET
,
2903 "interface %s: ospf_read invalid Area ID %s.",
2904 IF_NAME(oi
), inet_ntoa(ospfh
->area_id
));
2908 /* Check network mask, Silently discarded. */
2909 if (!ospf_check_network_mask(oi
, iph
->ip_src
)) {
2912 "interface %s: ospf_read network address is not same [%s]",
2913 IF_NAME(oi
), inet_ntoa(iph
->ip_src
));
2917 /* Check authentication. The function handles logging actions, where
2919 if (!ospf_check_auth(oi
, ospfh
))
2925 /* Starting point of packet process function. */
2926 int ospf_read(struct thread
*thread
)
2929 struct stream
*ibuf
;
2931 struct ospf_interface
*oi
;
2933 struct ospf_header
*ospfh
;
2935 struct interface
*ifp
= NULL
;
2936 struct connected
*c
;
2938 /* first of all get interface pointer. */
2939 ospf
= THREAD_ARG(thread
);
2941 /* prepare for next packet. */
2942 ospf
->t_read
= NULL
;
2943 thread_add_read(master
, ospf_read
, ospf
, ospf
->fd
, &ospf
->t_read
);
2945 stream_reset(ospf
->ibuf
);
2946 ibuf
= ospf_recv_packet(ospf
, ospf
->fd
, &ifp
, ospf
->ibuf
);
2949 /* This raw packet is known to be at least as big as its IP header. */
2951 /* Note that there should not be alignment problems with this assignment
2952 because this is at the beginning of the stream data buffer. */
2953 iph
= (struct ip
*)STREAM_DATA(ibuf
);
2954 /* Note that sockopt_iphdrincl_swab_systoh was called in
2955 * ospf_recv_packet. */
2958 /* Handle cases where the platform does not support retrieving
2960 and also platforms (such as Solaris 8) that claim to support
2962 retrieval but do not. */
2963 c
= if_lookup_address((void *)&iph
->ip_src
, AF_INET
,
2971 /* IP Header dump. */
2972 if (IS_DEBUG_OSPF_PACKET(0, RECV
))
2973 ospf_ip_header_dump(iph
);
2975 /* Self-originated packet should be discarded silently. */
2976 if (ospf_if_lookup_by_local_addr(ospf
, NULL
, iph
->ip_src
)) {
2977 if (IS_DEBUG_OSPF_PACKET(0, RECV
)) {
2979 "ospf_read[%s]: Dropping self-originated packet",
2980 inet_ntoa(iph
->ip_src
));
2985 /* Advance from IP header to OSPF header (iph->ip_hl has been verified
2986 by ospf_recv_packet() to be correct). */
2987 stream_forward_getp(ibuf
, iph
->ip_hl
* 4);
2989 ospfh
= (struct ospf_header
*)stream_pnt(ibuf
);
2991 != ospf_packet_examin(
2992 ospfh
, stream_get_endp(ibuf
) - stream_get_getp(ibuf
)))
2994 /* Now it is safe to access all fields of OSPF packet header. */
2996 /* associate packet with ospf interface */
2997 oi
= ospf_if_lookup_recv_if(ospf
, iph
->ip_src
, ifp
);
2999 /* ospf_verify_header() relies on a valid "oi" and thus can be called
3001 after the passive/backbone/other checks below are passed. These
3003 in turn access the fields of unverified "ospfh" structure for their
3005 purposes and must remain very accurate in doing this. */
3007 /* If incoming interface is passive one, ignore it. */
3008 if (oi
&& OSPF_IF_PASSIVE_STATUS(oi
) == OSPF_IF_PASSIVE
) {
3009 char buf
[3][INET_ADDRSTRLEN
];
3011 if (IS_DEBUG_OSPF_EVENT
)
3013 "ignoring packet from router %s sent to %s, "
3014 "received on a passive interface, %s",
3015 inet_ntop(AF_INET
, &ospfh
->router_id
, buf
[0],
3017 inet_ntop(AF_INET
, &iph
->ip_dst
, buf
[1],
3019 inet_ntop(AF_INET
, &oi
->address
->u
.prefix4
,
3020 buf
[2], sizeof(buf
[2])));
3022 if (iph
->ip_dst
.s_addr
== htonl(OSPF_ALLSPFROUTERS
)) {
3023 /* Try to fix multicast membership.
3024 * Some OS:es may have problems in this area,
3025 * make sure it is removed.
3027 OI_MEMBER_JOINED(oi
, MEMBER_ALLROUTERS
);
3028 ospf_if_set_multicast(oi
);
3034 /* if no local ospf_interface,
3035 * or header area is backbone but ospf_interface is not
3036 * check for VLINK interface
3038 if ((oi
== NULL
) || (OSPF_IS_AREA_ID_BACKBONE(ospfh
->area_id
)
3039 && !OSPF_IS_AREA_ID_BACKBONE(oi
->area
->area_id
))) {
3040 if ((oi
= ospf_associate_packet_vl(ospf
, ifp
, iph
, ospfh
))
3042 if (!ospf
->instance
&& IS_DEBUG_OSPF_EVENT
)
3044 "Packet from [%s] received on link %s"
3045 " but no ospf_interface",
3046 inet_ntoa(iph
->ip_src
), ifp
->name
);
3051 /* else it must be a local ospf interface, check it was received on
3054 else if (oi
->ifp
!= ifp
) {
3055 if (IS_DEBUG_OSPF_EVENT
)
3056 flog_warn(OSPF_WARN_PACKET
,
3057 "Packet from [%s] received on wrong link %s",
3058 inet_ntoa(iph
->ip_src
), ifp
->name
);
3060 } else if (oi
->state
== ISM_Down
) {
3061 char buf
[2][INET_ADDRSTRLEN
];
3064 "Ignoring packet from %s to %s received on interface that is "
3065 "down [%s]; interface flags are %s",
3066 inet_ntop(AF_INET
, &iph
->ip_src
, buf
[0],
3068 inet_ntop(AF_INET
, &iph
->ip_dst
, buf
[1],
3070 ifp
->name
, if_flag_dump(ifp
->flags
));
3071 /* Fix multicast memberships? */
3072 if (iph
->ip_dst
.s_addr
== htonl(OSPF_ALLSPFROUTERS
))
3073 OI_MEMBER_JOINED(oi
, MEMBER_ALLROUTERS
);
3074 else if (iph
->ip_dst
.s_addr
== htonl(OSPF_ALLDROUTERS
))
3075 OI_MEMBER_JOINED(oi
, MEMBER_DROUTERS
);
3076 if (oi
->multicast_memberships
)
3077 ospf_if_set_multicast(oi
);
3082 * If the received packet is destined for AllDRouters, the packet
3083 * should be accepted only if the received ospf interface state is
3084 * either DR or Backup -- endo.
3086 if (iph
->ip_dst
.s_addr
== htonl(OSPF_ALLDROUTERS
)
3087 && (oi
->state
!= ISM_DR
&& oi
->state
!= ISM_Backup
)) {
3090 "Dropping packet for AllDRouters from [%s] via [%s] (ISM: %s)",
3091 inet_ntoa(iph
->ip_src
), IF_NAME(oi
),
3092 lookup_msg(ospf_ism_state_msg
, oi
->state
, NULL
));
3093 /* Try to fix multicast membership. */
3094 SET_FLAG(oi
->multicast_memberships
, MEMBER_DROUTERS
);
3095 ospf_if_set_multicast(oi
);
3099 /* Verify more OSPF header fields. */
3100 ret
= ospf_verify_header(ibuf
, oi
, iph
, ospfh
);
3102 if (IS_DEBUG_OSPF_PACKET(0, RECV
))
3104 "ospf_read[%s]: Header check failed, "
3106 inet_ntoa(iph
->ip_src
));
3110 /* Show debug receiving packet. */
3111 if (IS_DEBUG_OSPF_PACKET(ospfh
->type
- 1, RECV
)) {
3112 if (IS_DEBUG_OSPF_PACKET(ospfh
->type
- 1, DETAIL
)) {
3114 "-----------------------------------------------------");
3115 ospf_packet_dump(ibuf
);
3118 zlog_debug("%s received from [%s] via [%s]",
3119 lookup_msg(ospf_packet_type_str
, ospfh
->type
, NULL
),
3120 inet_ntoa(ospfh
->router_id
), IF_NAME(oi
));
3121 zlog_debug(" src [%s],", inet_ntoa(iph
->ip_src
));
3122 zlog_debug(" dst [%s]", inet_ntoa(iph
->ip_dst
));
3124 if (IS_DEBUG_OSPF_PACKET(ospfh
->type
- 1, DETAIL
))
3126 "-----------------------------------------------------");
3129 stream_forward_getp(ibuf
, OSPF_HEADER_SIZE
);
3131 /* Adjust size to message length. */
3132 length
= ntohs(ospfh
->length
) - OSPF_HEADER_SIZE
;
3134 /* Read rest of the packet and call each sort of packet routine. */
3135 switch (ospfh
->type
) {
3136 case OSPF_MSG_HELLO
:
3137 ospf_hello(iph
, ospfh
, ibuf
, oi
, length
);
3139 case OSPF_MSG_DB_DESC
:
3140 ospf_db_desc(iph
, ospfh
, ibuf
, oi
, length
);
3142 case OSPF_MSG_LS_REQ
:
3143 ospf_ls_req(iph
, ospfh
, ibuf
, oi
, length
);
3145 case OSPF_MSG_LS_UPD
:
3146 ospf_ls_upd(ospf
, iph
, ospfh
, ibuf
, oi
, length
);
3148 case OSPF_MSG_LS_ACK
:
3149 ospf_ls_ack(iph
, ospfh
, ibuf
, oi
, length
);
3152 flog_warn(OSPF_WARN_PACKET
,
3153 "interface %s: OSPF packet header type %d is illegal",
3154 IF_NAME(oi
), ospfh
->type
);
3161 /* Make OSPF header. */
3162 static void ospf_make_header(int type
, struct ospf_interface
*oi
,
3165 struct ospf_header
*ospfh
;
3167 ospfh
= (struct ospf_header
*)STREAM_DATA(s
);
3169 ospfh
->version
= (uint8_t)OSPF_VERSION
;
3170 ospfh
->type
= (uint8_t)type
;
3172 ospfh
->router_id
= oi
->ospf
->router_id
;
3174 ospfh
->checksum
= 0;
3175 ospfh
->area_id
= oi
->area
->area_id
;
3176 ospfh
->auth_type
= htons(ospf_auth_type(oi
));
3178 memset(ospfh
->u
.auth_data
, 0, OSPF_AUTH_SIMPLE_SIZE
);
3180 stream_forward_endp(s
, OSPF_HEADER_SIZE
);
3183 /* Make Authentication Data. */
3184 static int ospf_make_auth(struct ospf_interface
*oi
, struct ospf_header
*ospfh
)
3186 struct crypt_key
*ck
;
3188 switch (ospf_auth_type(oi
)) {
3189 case OSPF_AUTH_NULL
:
3190 /* memset (ospfh->u.auth_data, 0, sizeof (ospfh->u.auth_data));
3193 case OSPF_AUTH_SIMPLE
:
3194 memcpy(ospfh
->u
.auth_data
, OSPF_IF_PARAM(oi
, auth_simple
),
3195 OSPF_AUTH_SIMPLE_SIZE
);
3197 case OSPF_AUTH_CRYPTOGRAPHIC
:
3198 /* If key is not set, then set 0. */
3199 if (list_isempty(OSPF_IF_PARAM(oi
, auth_crypt
))) {
3200 ospfh
->u
.crypt
.zero
= 0;
3201 ospfh
->u
.crypt
.key_id
= 0;
3202 ospfh
->u
.crypt
.auth_data_len
= OSPF_AUTH_MD5_SIZE
;
3205 listtail(OSPF_IF_PARAM(oi
, auth_crypt
)));
3206 ospfh
->u
.crypt
.zero
= 0;
3207 ospfh
->u
.crypt
.key_id
= ck
->key_id
;
3208 ospfh
->u
.crypt
.auth_data_len
= OSPF_AUTH_MD5_SIZE
;
3210 /* note: the seq is done in ospf_make_md5_digest() */
3213 /* memset (ospfh->u.auth_data, 0, sizeof (ospfh->u.auth_data));
3221 /* Fill rest of OSPF header. */
3222 static void ospf_fill_header(struct ospf_interface
*oi
, struct stream
*s
,
3225 struct ospf_header
*ospfh
;
3227 ospfh
= (struct ospf_header
*)STREAM_DATA(s
);
3230 ospfh
->length
= htons(length
);
3232 /* Calculate checksum. */
3233 if (ntohs(ospfh
->auth_type
) != OSPF_AUTH_CRYPTOGRAPHIC
)
3234 ospfh
->checksum
= in_cksum(ospfh
, length
);
3236 ospfh
->checksum
= 0;
3238 /* Add Authentication Data. */
3239 ospf_make_auth(oi
, ospfh
);
3242 static int ospf_make_hello(struct ospf_interface
*oi
, struct stream
*s
)
3244 struct ospf_neighbor
*nbr
;
3245 struct route_node
*rn
;
3246 uint16_t length
= OSPF_HELLO_MIN_SIZE
;
3247 struct in_addr mask
;
3251 /* Set netmask of interface. */
3252 if (!(CHECK_FLAG(oi
->connected
->flags
, ZEBRA_IFA_UNNUMBERED
)
3253 && oi
->type
== OSPF_IFTYPE_POINTOPOINT
)
3254 && oi
->type
!= OSPF_IFTYPE_VIRTUALLINK
)
3255 masklen2ip(oi
->address
->prefixlen
, &mask
);
3257 memset((char *)&mask
, 0, sizeof(struct in_addr
));
3258 stream_put_ipv4(s
, mask
.s_addr
);
3260 /* Set Hello Interval. */
3261 if (OSPF_IF_PARAM(oi
, fast_hello
) == 0)
3262 stream_putw(s
, OSPF_IF_PARAM(oi
, v_hello
));
3264 stream_putw(s
, 0); /* hello-interval of 0 for fast-hellos */
3266 if (IS_DEBUG_OSPF_EVENT
)
3267 zlog_debug("make_hello: options: %x, int: %s", OPTIONS(oi
),
3271 stream_putc(s
, OPTIONS(oi
));
3273 /* Set Router Priority. */
3274 stream_putc(s
, PRIORITY(oi
));
3276 /* Set Router Dead Interval. */
3277 stream_putl(s
, OSPF_IF_PARAM(oi
, v_wait
));
3279 /* Set Designated Router. */
3280 stream_put_ipv4(s
, DR(oi
).s_addr
);
3282 p
= stream_get_endp(s
);
3284 /* Set Backup Designated Router. */
3285 stream_put_ipv4(s
, BDR(oi
).s_addr
);
3287 /* Add neighbor seen. */
3288 for (rn
= route_top(oi
->nbrs
); rn
; rn
= route_next(rn
))
3289 if ((nbr
= rn
->info
))
3290 if (nbr
->router_id
.s_addr
3291 != 0) /* Ignore 0.0.0.0 node. */
3293 != NSM_Attempt
) /* Ignore Down neighbor. */
3295 != NSM_Down
) /* This is myself for
3297 if (!IPV4_ADDR_SAME(
3299 &oi
->ospf
->router_id
)) {
3300 /* Check neighbor is
3302 if (nbr
->d_router
.s_addr
3323 /* Let neighbor generate BackupSeen. */
3325 stream_putl_at(s
, p
, 0); /* ipv4 address, normally */
3330 static int ospf_make_db_desc(struct ospf_interface
*oi
,
3331 struct ospf_neighbor
*nbr
, struct stream
*s
)
3333 struct ospf_lsa
*lsa
;
3334 uint16_t length
= OSPF_DB_DESC_MIN_SIZE
;
3338 struct ospf_lsdb
*lsdb
;
3340 /* Set Interface MTU. */
3341 if (oi
->type
== OSPF_IFTYPE_VIRTUALLINK
)
3344 stream_putw(s
, oi
->ifp
->mtu
);
3347 options
= OPTIONS(oi
);
3348 if (CHECK_FLAG(oi
->ospf
->config
, OSPF_OPAQUE_CAPABLE
))
3349 SET_FLAG(options
, OSPF_OPTION_O
);
3350 stream_putc(s
, options
);
3353 pp
= stream_get_endp(s
);
3354 stream_putc(s
, nbr
->dd_flags
);
3356 /* Set DD Sequence Number. */
3357 stream_putl(s
, nbr
->dd_seqnum
);
3359 /* shortcut unneeded walk of (empty) summary LSDBs */
3360 if (ospf_db_summary_isempty(nbr
))
3363 /* Describe LSA Header from Database Summary List. */
3364 lsdb
= &nbr
->db_sum
;
3366 for (i
= OSPF_MIN_LSA
; i
< OSPF_MAX_LSA
; i
++) {
3367 struct route_table
*table
= lsdb
->type
[i
].db
;
3368 struct route_node
*rn
;
3370 for (rn
= route_top(table
); rn
; rn
= route_next(rn
))
3371 if ((lsa
= rn
->info
) != NULL
) {
3372 if (IS_OPAQUE_LSA(lsa
->data
->type
)
3373 && (!CHECK_FLAG(options
, OSPF_OPTION_O
))) {
3374 /* Suppress advertising
3375 * opaque-informations. */
3376 /* Remove LSA from DB summary list. */
3377 ospf_lsdb_delete(lsdb
, lsa
);
3381 if (!CHECK_FLAG(lsa
->flags
, OSPF_LSA_DISCARD
)) {
3382 struct lsa_header
*lsah
;
3385 /* DD packet overflows interface MTU. */
3386 if (length
+ OSPF_LSA_HEADER_SIZE
3387 > ospf_packet_max(oi
))
3390 /* Keep pointer to LS age. */
3391 lsah
= (struct lsa_header
3396 /* Proceed stream pointer. */
3397 stream_put(s
, lsa
->data
,
3398 OSPF_LSA_HEADER_SIZE
);
3399 length
+= OSPF_LSA_HEADER_SIZE
;
3402 ls_age
= LS_AGE(lsa
);
3403 lsah
->ls_age
= htons(ls_age
);
3406 /* Remove LSA from DB summary list. */
3407 ospf_lsdb_delete(lsdb
, lsa
);
3411 /* Update 'More' bit */
3412 if (ospf_db_summary_isempty(nbr
)) {
3414 if (nbr
->state
>= NSM_Exchange
) {
3415 UNSET_FLAG(nbr
->dd_flags
, OSPF_DD_FLAG_M
);
3416 /* Rewrite DD flags */
3417 stream_putc_at(s
, pp
, nbr
->dd_flags
);
3419 assert(IS_SET_DD_M(nbr
->dd_flags
));
3425 static int ospf_make_ls_req_func(struct stream
*s
, uint16_t *length
,
3426 unsigned long delta
, struct ospf_neighbor
*nbr
,
3427 struct ospf_lsa
*lsa
)
3429 struct ospf_interface
*oi
;
3433 /* LS Request packet overflows interface MTU. */
3434 if (*length
+ delta
> ospf_packet_max(oi
))
3437 stream_putl(s
, lsa
->data
->type
);
3438 stream_put_ipv4(s
, lsa
->data
->id
.s_addr
);
3439 stream_put_ipv4(s
, lsa
->data
->adv_router
.s_addr
);
3441 ospf_lsa_unlock(&nbr
->ls_req_last
);
3442 nbr
->ls_req_last
= ospf_lsa_lock(lsa
);
3448 static int ospf_make_ls_req(struct ospf_neighbor
*nbr
, struct stream
*s
)
3450 struct ospf_lsa
*lsa
;
3451 uint16_t length
= OSPF_LS_REQ_MIN_SIZE
;
3452 unsigned long delta
= stream_get_endp(s
) + 12;
3453 struct route_table
*table
;
3454 struct route_node
*rn
;
3456 struct ospf_lsdb
*lsdb
;
3458 lsdb
= &nbr
->ls_req
;
3460 for (i
= OSPF_MIN_LSA
; i
< OSPF_MAX_LSA
; i
++) {
3461 table
= lsdb
->type
[i
].db
;
3462 for (rn
= route_top(table
); rn
; rn
= route_next(rn
))
3463 if ((lsa
= (rn
->info
)) != NULL
)
3464 if (ospf_make_ls_req_func(s
, &length
, delta
,
3467 route_unlock_node(rn
);
3474 static int ls_age_increment(struct ospf_lsa
*lsa
, int delay
)
3478 age
= IS_LSA_MAXAGE(lsa
) ? OSPF_LSA_MAXAGE
: LS_AGE(lsa
) + delay
;
3480 return (age
> OSPF_LSA_MAXAGE
? OSPF_LSA_MAXAGE
: age
);
3483 static int ospf_make_ls_upd(struct ospf_interface
*oi
, struct list
*update
,
3486 struct ospf_lsa
*lsa
;
3487 struct listnode
*node
;
3488 uint16_t length
= 0;
3489 unsigned int size_noauth
;
3490 unsigned long delta
= stream_get_endp(s
);
3494 if (IS_DEBUG_OSPF_EVENT
)
3495 zlog_debug("ospf_make_ls_upd: Start");
3497 pp
= stream_get_endp(s
);
3498 stream_forward_endp(s
, OSPF_LS_UPD_MIN_SIZE
);
3499 length
+= OSPF_LS_UPD_MIN_SIZE
;
3501 /* Calculate amount of packet usable for data. */
3502 size_noauth
= stream_get_size(s
) - ospf_packet_authspace(oi
);
3504 while ((node
= listhead(update
)) != NULL
) {
3505 struct lsa_header
*lsah
;
3508 if (IS_DEBUG_OSPF_EVENT
)
3509 zlog_debug("ospf_make_ls_upd: List Iteration %d",
3512 lsa
= listgetdata(node
);
3517 if (length
+ delta
+ ntohs(lsa
->data
->length
) > size_noauth
)
3520 /* Keep pointer to LS age. */
3521 lsah
= (struct lsa_header
*)(STREAM_DATA(s
)
3522 + stream_get_endp(s
));
3524 /* Put LSA to Link State Request. */
3525 stream_put(s
, lsa
->data
, ntohs(lsa
->data
->length
));
3528 /* each hop must increment an lsa_age by transmit_delay
3529 of OSPF interface */
3530 ls_age
= ls_age_increment(lsa
,
3531 OSPF_IF_PARAM(oi
, transmit_delay
));
3532 lsah
->ls_age
= htons(ls_age
);
3534 length
+= ntohs(lsa
->data
->length
);
3537 list_delete_node(update
, node
);
3538 ospf_lsa_unlock(&lsa
); /* oi->ls_upd_queue */
3541 /* Now set #LSAs. */
3542 stream_putl_at(s
, pp
, count
);
3544 if (IS_DEBUG_OSPF_EVENT
)
3545 zlog_debug("ospf_make_ls_upd: Stop");
3549 static int ospf_make_ls_ack(struct ospf_interface
*oi
, struct list
*ack
,
3552 struct listnode
*node
, *nnode
;
3553 uint16_t length
= OSPF_LS_ACK_MIN_SIZE
;
3554 unsigned long delta
= stream_get_endp(s
) + 24;
3555 struct ospf_lsa
*lsa
;
3557 for (ALL_LIST_ELEMENTS(ack
, node
, nnode
, lsa
)) {
3560 if (length
+ delta
> ospf_packet_max(oi
))
3563 stream_put(s
, lsa
->data
, OSPF_LSA_HEADER_SIZE
);
3564 length
+= OSPF_LSA_HEADER_SIZE
;
3566 listnode_delete(ack
, lsa
);
3567 ospf_lsa_unlock(&lsa
); /* oi->ls_ack_direct.ls_ack */
3573 static void ospf_hello_send_sub(struct ospf_interface
*oi
, in_addr_t addr
)
3575 struct ospf_packet
*op
;
3576 uint16_t length
= OSPF_HEADER_SIZE
;
3578 op
= ospf_packet_new(oi
->ifp
->mtu
);
3580 /* Prepare OSPF common header. */
3581 ospf_make_header(OSPF_MSG_HELLO
, oi
, op
->s
);
3583 /* Prepare OSPF Hello body. */
3584 length
+= ospf_make_hello(oi
, op
->s
);
3586 /* Fill OSPF header. */
3587 ospf_fill_header(oi
, op
->s
, length
);
3589 /* Set packet length. */
3590 op
->length
= length
;
3592 op
->dst
.s_addr
= addr
;
3594 if (IS_DEBUG_OSPF_EVENT
) {
3595 if (oi
->ospf
->vrf_id
)
3597 "%s: Hello Tx interface %s ospf vrf %s id %u",
3598 __PRETTY_FUNCTION__
, oi
->ifp
->name
,
3599 ospf_vrf_id_to_name(oi
->ospf
->vrf_id
),
3602 /* Add packet to the top of the interface output queue, so that they
3603 * can't get delayed by things like long queues of LS Update packets
3605 ospf_packet_add_top(oi
, op
);
3607 /* Hook thread to write packet. */
3608 OSPF_ISM_WRITE_ON(oi
->ospf
);
3611 static void ospf_poll_send(struct ospf_nbr_nbma
*nbr_nbma
)
3613 struct ospf_interface
*oi
;
3618 /* If this is passive interface, do not send OSPF Hello. */
3619 if (OSPF_IF_PASSIVE_STATUS(oi
) == OSPF_IF_PASSIVE
)
3622 if (oi
->type
!= OSPF_IFTYPE_NBMA
)
3625 if (nbr_nbma
->nbr
!= NULL
&& nbr_nbma
->nbr
->state
!= NSM_Down
)
3628 if (PRIORITY(oi
) == 0)
3631 if (nbr_nbma
->priority
== 0 && oi
->state
!= ISM_DR
3632 && oi
->state
!= ISM_Backup
)
3635 ospf_hello_send_sub(oi
, nbr_nbma
->addr
.s_addr
);
3638 int ospf_poll_timer(struct thread
*thread
)
3640 struct ospf_nbr_nbma
*nbr_nbma
;
3642 nbr_nbma
= THREAD_ARG(thread
);
3643 nbr_nbma
->t_poll
= NULL
;
3645 if (IS_DEBUG_OSPF(nsm
, NSM_TIMERS
))
3646 zlog_debug("NSM[%s:%s]: Timer (Poll timer expire)",
3647 IF_NAME(nbr_nbma
->oi
), inet_ntoa(nbr_nbma
->addr
));
3649 ospf_poll_send(nbr_nbma
);
3651 if (nbr_nbma
->v_poll
> 0)
3652 OSPF_POLL_TIMER_ON(nbr_nbma
->t_poll
, ospf_poll_timer
,
3659 int ospf_hello_reply_timer(struct thread
*thread
)
3661 struct ospf_neighbor
*nbr
;
3663 nbr
= THREAD_ARG(thread
);
3664 nbr
->t_hello_reply
= NULL
;
3668 if (IS_DEBUG_OSPF(nsm
, NSM_TIMERS
))
3669 zlog_debug("NSM[%s:%s]: Timer (hello-reply timer expire)",
3670 IF_NAME(nbr
->oi
), inet_ntoa(nbr
->router_id
));
3672 ospf_hello_send_sub(nbr
->oi
, nbr
->address
.u
.prefix4
.s_addr
);
3677 /* Send OSPF Hello. */
3678 void ospf_hello_send(struct ospf_interface
*oi
)
3680 /* If this is passive interface, do not send OSPF Hello. */
3681 if (OSPF_IF_PASSIVE_STATUS(oi
) == OSPF_IF_PASSIVE
)
3684 if (oi
->type
== OSPF_IFTYPE_NBMA
) {
3685 struct ospf_neighbor
*nbr
;
3686 struct route_node
*rn
;
3688 for (rn
= route_top(oi
->nbrs
); rn
; rn
= route_next(rn
))
3689 if ((nbr
= rn
->info
))
3690 if (nbr
!= oi
->nbr_self
)
3691 if (nbr
->state
!= NSM_Down
) {
3692 /* RFC 2328 Section 9.5.1
3693 If the router is not
3694 eligible to become Designated
3696 it must periodically send
3697 Hello Packets to both the
3698 Designated Router and the
3699 Backup Designated Router (if
3702 if (PRIORITY(oi
) == 0
3713 /* If the router is eligible to
3714 become Designated Router, it
3715 must periodically send Hello
3716 Packets to all neighbors that
3717 are also eligible. In
3718 addition, if the router is
3720 Designated Router or Backup
3721 Designated Router, it must
3723 send periodic Hello Packets
3724 to all other neighbors. */
3726 if (nbr
->priority
== 0
3727 && oi
->state
== ISM_DROther
)
3729 /* if oi->state == Waiting, send
3730 * hello to all neighbors */
3731 ospf_hello_send_sub(
3733 nbr
->address
.u
.prefix4
3737 /* Decide destination address. */
3738 if (oi
->type
== OSPF_IFTYPE_VIRTUALLINK
)
3739 ospf_hello_send_sub(oi
, oi
->vl_data
->peer_addr
.s_addr
);
3741 ospf_hello_send_sub(oi
, htonl(OSPF_ALLSPFROUTERS
));
3745 /* Send OSPF Database Description. */
3746 void ospf_db_desc_send(struct ospf_neighbor
*nbr
)
3748 struct ospf_interface
*oi
;
3749 struct ospf_packet
*op
;
3750 uint16_t length
= OSPF_HEADER_SIZE
;
3753 op
= ospf_packet_new(oi
->ifp
->mtu
);
3755 /* Prepare OSPF common header. */
3756 ospf_make_header(OSPF_MSG_DB_DESC
, oi
, op
->s
);
3758 /* Prepare OSPF Database Description body. */
3759 length
+= ospf_make_db_desc(oi
, nbr
, op
->s
);
3761 /* Fill OSPF header. */
3762 ospf_fill_header(oi
, op
->s
, length
);
3764 /* Set packet length. */
3765 op
->length
= length
;
3767 /* Decide destination address. */
3768 if (oi
->type
== OSPF_IFTYPE_POINTOPOINT
)
3769 op
->dst
.s_addr
= htonl(OSPF_ALLSPFROUTERS
);
3771 op
->dst
= nbr
->address
.u
.prefix4
;
3773 /* Add packet to the interface output queue. */
3774 ospf_packet_add(oi
, op
);
3776 /* Hook thread to write packet. */
3777 OSPF_ISM_WRITE_ON(oi
->ospf
);
3779 /* Remove old DD packet, then copy new one and keep in neighbor
3782 ospf_packet_free(nbr
->last_send
);
3783 nbr
->last_send
= ospf_packet_dup(op
);
3784 monotime(&nbr
->last_send_ts
);
3787 /* Re-send Database Description. */
3788 void ospf_db_desc_resend(struct ospf_neighbor
*nbr
)
3790 struct ospf_interface
*oi
;
3794 /* Add packet to the interface output queue. */
3795 ospf_packet_add(oi
, ospf_packet_dup(nbr
->last_send
));
3797 /* Hook thread to write packet. */
3798 OSPF_ISM_WRITE_ON(oi
->ospf
);
3801 /* Send Link State Request. */
3802 void ospf_ls_req_send(struct ospf_neighbor
*nbr
)
3804 struct ospf_interface
*oi
;
3805 struct ospf_packet
*op
;
3806 uint16_t length
= OSPF_HEADER_SIZE
;
3809 op
= ospf_packet_new(oi
->ifp
->mtu
);
3811 /* Prepare OSPF common header. */
3812 ospf_make_header(OSPF_MSG_LS_REQ
, oi
, op
->s
);
3814 /* Prepare OSPF Link State Request body. */
3815 length
+= ospf_make_ls_req(nbr
, op
->s
);
3816 if (length
== OSPF_HEADER_SIZE
) {
3817 ospf_packet_free(op
);
3821 /* Fill OSPF header. */
3822 ospf_fill_header(oi
, op
->s
, length
);
3824 /* Set packet length. */
3825 op
->length
= length
;
3827 /* Decide destination address. */
3828 if (oi
->type
== OSPF_IFTYPE_POINTOPOINT
)
3829 op
->dst
.s_addr
= htonl(OSPF_ALLSPFROUTERS
);
3831 op
->dst
= nbr
->address
.u
.prefix4
;
3833 /* Add packet to the interface output queue. */
3834 ospf_packet_add(oi
, op
);
3836 /* Hook thread to write packet. */
3837 OSPF_ISM_WRITE_ON(oi
->ospf
);
3839 /* Add Link State Request Retransmission Timer. */
3840 OSPF_NSM_TIMER_ON(nbr
->t_ls_req
, ospf_ls_req_timer
, nbr
->v_ls_req
);
3843 /* Send Link State Update with an LSA. */
3844 void ospf_ls_upd_send_lsa(struct ospf_neighbor
*nbr
, struct ospf_lsa
*lsa
,
3847 struct list
*update
;
3849 update
= list_new();
3851 listnode_add(update
, lsa
);
3853 /*ospf instance is going down, send self originated
3854 * MAXAGE LSA update to neighbors to remove from LSDB */
3855 if (nbr
->oi
->ospf
->inst_shutdown
&& IS_LSA_MAXAGE(lsa
))
3856 ospf_ls_upd_send(nbr
, update
, flag
, 1);
3858 ospf_ls_upd_send(nbr
, update
, flag
, 0);
3860 list_delete_and_null(&update
);
3863 /* Determine size for packet. Must be at least big enough to accomodate next
3864 * LSA on list, which may be bigger than MTU size.
3866 * Return pointer to new ospf_packet
3867 * NULL if we can not allocate, eg because LSA is bigger than imposed limit
3868 * on packet sizes (in which case offending LSA is deleted from update list)
3870 static struct ospf_packet
*ospf_ls_upd_packet_new(struct list
*update
,
3871 struct ospf_interface
*oi
)
3873 struct ospf_lsa
*lsa
;
3874 struct listnode
*ln
;
3876 static char warned
= 0;
3878 lsa
= listgetdata((ln
= listhead(update
)));
3881 if ((OSPF_LS_UPD_MIN_SIZE
+ ntohs(lsa
->data
->length
))
3882 > ospf_packet_max(oi
)) {
3885 OSPF_WARN_LARGE_LSA
,
3886 "ospf_ls_upd_packet_new: oversized LSA encountered!"
3887 "will need to fragment. Not optimal. Try divide up"
3888 " your network with areas. Use 'debug ospf packet send'"
3889 " to see details, or look at 'show ip ospf database ..'");
3893 if (IS_DEBUG_OSPF_PACKET(0, SEND
))
3895 "ospf_ls_upd_packet_new: oversized LSA id:%s,"
3896 " %d bytes originated by %s, will be fragmented!",
3897 inet_ntoa(lsa
->data
->id
),
3898 ntohs(lsa
->data
->length
),
3899 inet_ntoa(lsa
->data
->adv_router
));
3902 * Allocate just enough to fit this LSA only, to avoid including
3904 * LSAs in fragmented LSA Updates.
3906 size
= ntohs(lsa
->data
->length
)
3907 + (oi
->ifp
->mtu
- ospf_packet_max(oi
))
3908 + OSPF_LS_UPD_MIN_SIZE
;
3910 size
= oi
->ifp
->mtu
;
3912 if (size
> OSPF_MAX_PACKET_SIZE
) {
3913 flog_warn(OSPF_WARN_LARGE_LSA
,
3914 "ospf_ls_upd_packet_new: oversized LSA id:%s too big,"
3915 " %d bytes, packet size %ld, dropping it completely."
3916 " OSPF routing is broken!",
3917 inet_ntoa(lsa
->data
->id
), ntohs(lsa
->data
->length
),
3919 list_delete_node(update
, ln
);
3923 /* IP header is built up separately by ospf_write(). This means, that we
3925 * reduce the "affordable" size just calculated by length of an IP
3927 * This makes sure, that even if we manage to fill the payload with LSA
3929 * completely, the final packet (our data plus IP header) still fits
3931 * outgoing interface MTU. This correction isn't really meaningful for
3933 * oversized LSA, but for consistency the correction is done for both
3936 * P.S. OSPF_MAX_PACKET_SIZE above already includes IP header size
3938 return ospf_packet_new(size
- sizeof(struct ip
));
3941 static void ospf_ls_upd_queue_send(struct ospf_interface
*oi
,
3942 struct list
*update
, struct in_addr addr
,
3945 struct ospf_packet
*op
;
3946 uint16_t length
= OSPF_HEADER_SIZE
;
3948 if (IS_DEBUG_OSPF_EVENT
)
3949 zlog_debug("listcount = %d, [%s]dst %s", listcount(update
),
3950 IF_NAME(oi
), inet_ntoa(addr
));
3952 /* Check that we have really something to process */
3953 if (listcount(update
) == 0)
3956 op
= ospf_ls_upd_packet_new(update
, oi
);
3958 /* Prepare OSPF common header. */
3959 ospf_make_header(OSPF_MSG_LS_UPD
, oi
, op
->s
);
3961 /* Prepare OSPF Link State Update body.
3962 * Includes Type-7 translation.
3964 length
+= ospf_make_ls_upd(oi
, update
, op
->s
);
3966 /* Fill OSPF header. */
3967 ospf_fill_header(oi
, op
->s
, length
);
3969 /* Set packet length. */
3970 op
->length
= length
;
3972 /* Decide destination address. */
3973 if (oi
->type
== OSPF_IFTYPE_POINTOPOINT
)
3974 op
->dst
.s_addr
= htonl(OSPF_ALLSPFROUTERS
);
3976 op
->dst
.s_addr
= addr
.s_addr
;
3978 /* Add packet to the interface output queue. */
3979 ospf_packet_add(oi
, op
);
3980 /* Call ospf_write() right away to send ospf packets to neighbors */
3981 if (send_lsupd_now
) {
3982 struct thread os_packet_thd
;
3984 os_packet_thd
.arg
= (void *)oi
->ospf
;
3985 if (oi
->on_write_q
== 0) {
3986 listnode_add(oi
->ospf
->oi_write_q
, oi
);
3989 ospf_write(&os_packet_thd
);
3991 /* Hook thread to write packet. */
3992 OSPF_ISM_WRITE_ON(oi
->ospf
);
3996 static int ospf_ls_upd_send_queue_event(struct thread
*thread
)
3998 struct ospf_interface
*oi
= THREAD_ARG(thread
);
3999 struct route_node
*rn
;
4000 struct route_node
*rnext
;
4001 struct list
*update
;
4004 oi
->t_ls_upd_event
= NULL
;
4006 if (IS_DEBUG_OSPF_EVENT
)
4007 zlog_debug("ospf_ls_upd_send_queue start");
4009 for (rn
= route_top(oi
->ls_upd_queue
); rn
; rn
= rnext
) {
4010 rnext
= route_next(rn
);
4012 if (rn
->info
== NULL
)
4015 update
= (struct list
*)rn
->info
;
4017 ospf_ls_upd_queue_send(oi
, update
, rn
->p
.u
.prefix4
, 0);
4019 /* list might not be empty. */
4020 if (listcount(update
) == 0) {
4021 list_delete_and_null((struct list
**)&rn
->info
);
4022 route_unlock_node(rn
);
4028 if (IS_DEBUG_OSPF_EVENT
)
4030 "ospf_ls_upd_send_queue: update lists not cleared,"
4031 " %d nodes to try again, raising new event",
4033 oi
->t_ls_upd_event
= NULL
;
4034 thread_add_event(master
, ospf_ls_upd_send_queue_event
, oi
, 0,
4035 &oi
->t_ls_upd_event
);
4038 if (IS_DEBUG_OSPF_EVENT
)
4039 zlog_debug("ospf_ls_upd_send_queue stop");
4044 void ospf_ls_upd_send(struct ospf_neighbor
*nbr
, struct list
*update
, int flag
,
4047 struct ospf_interface
*oi
;
4048 struct ospf_lsa
*lsa
;
4049 struct prefix_ipv4 p
;
4050 struct route_node
*rn
;
4051 struct listnode
*node
;
4056 p
.prefixlen
= IPV4_MAX_BITLEN
;
4058 /* Decide destination address. */
4059 if (oi
->type
== OSPF_IFTYPE_VIRTUALLINK
)
4060 p
.prefix
= oi
->vl_data
->peer_addr
;
4061 else if (oi
->type
== OSPF_IFTYPE_POINTOPOINT
)
4062 p
.prefix
.s_addr
= htonl(OSPF_ALLSPFROUTERS
);
4063 else if (flag
== OSPF_SEND_PACKET_DIRECT
)
4064 p
.prefix
= nbr
->address
.u
.prefix4
;
4065 else if (oi
->state
== ISM_DR
|| oi
->state
== ISM_Backup
)
4066 p
.prefix
.s_addr
= htonl(OSPF_ALLSPFROUTERS
);
4067 else if (oi
->type
== OSPF_IFTYPE_POINTOMULTIPOINT
)
4068 p
.prefix
.s_addr
= htonl(OSPF_ALLSPFROUTERS
);
4070 p
.prefix
.s_addr
= htonl(OSPF_ALLDROUTERS
);
4072 if (oi
->type
== OSPF_IFTYPE_NBMA
) {
4073 if (flag
== OSPF_SEND_PACKET_INDIRECT
)
4076 "* LS-Update is directly sent on NBMA network.");
4077 if (IPV4_ADDR_SAME(&oi
->address
->u
.prefix4
, &p
.prefix
))
4078 flog_warn(OSPF_WARN_PACKET
,
4079 "* LS-Update is sent to myself.");
4082 rn
= route_node_get(oi
->ls_upd_queue
, (struct prefix
*)&p
);
4084 if (rn
->info
== NULL
)
4085 rn
->info
= list_new();
4087 route_unlock_node(rn
);
4089 for (ALL_LIST_ELEMENTS_RO(update
, node
, lsa
))
4090 listnode_add(rn
->info
,
4091 ospf_lsa_lock(lsa
)); /* oi->ls_upd_queue */
4092 if (send_lsupd_now
) {
4093 struct list
*send_update_list
;
4094 struct route_node
*rn
, *rnext
;
4096 for (rn
= route_top(oi
->ls_upd_queue
); rn
; rn
= rnext
) {
4097 rnext
= route_next(rn
);
4099 if (rn
->info
== NULL
)
4102 send_update_list
= (struct list
*)rn
->info
;
4104 ospf_ls_upd_queue_send(oi
, send_update_list
,
4105 rn
->p
.u
.prefix4
, 1);
4108 thread_add_event(master
, ospf_ls_upd_send_queue_event
, oi
, 0,
4109 &oi
->t_ls_upd_event
);
4112 static void ospf_ls_ack_send_list(struct ospf_interface
*oi
, struct list
*ack
,
4115 struct ospf_packet
*op
;
4116 uint16_t length
= OSPF_HEADER_SIZE
;
4118 op
= ospf_packet_new(oi
->ifp
->mtu
);
4120 /* Prepare OSPF common header. */
4121 ospf_make_header(OSPF_MSG_LS_ACK
, oi
, op
->s
);
4123 /* Prepare OSPF Link State Acknowledgment body. */
4124 length
+= ospf_make_ls_ack(oi
, ack
, op
->s
);
4126 /* Fill OSPF header. */
4127 ospf_fill_header(oi
, op
->s
, length
);
4129 /* Set packet length. */
4130 op
->length
= length
;
4132 /* Decide destination address. */
4133 if (oi
->type
== OSPF_IFTYPE_POINTOPOINT
)
4134 op
->dst
.s_addr
= htonl(OSPF_ALLSPFROUTERS
);
4136 op
->dst
.s_addr
= dst
.s_addr
;
4138 /* Add packet to the interface output queue. */
4139 ospf_packet_add(oi
, op
);
4141 /* Hook thread to write packet. */
4142 OSPF_ISM_WRITE_ON(oi
->ospf
);
4145 static int ospf_ls_ack_send_event(struct thread
*thread
)
4147 struct ospf_interface
*oi
= THREAD_ARG(thread
);
4149 oi
->t_ls_ack_direct
= NULL
;
4151 while (listcount(oi
->ls_ack_direct
.ls_ack
))
4152 ospf_ls_ack_send_list(oi
, oi
->ls_ack_direct
.ls_ack
,
4153 oi
->ls_ack_direct
.dst
);
4158 void ospf_ls_ack_send(struct ospf_neighbor
*nbr
, struct ospf_lsa
*lsa
)
4160 struct ospf_interface
*oi
= nbr
->oi
;
4162 if (listcount(oi
->ls_ack_direct
.ls_ack
) == 0)
4163 oi
->ls_ack_direct
.dst
= nbr
->address
.u
.prefix4
;
4165 listnode_add(oi
->ls_ack_direct
.ls_ack
, ospf_lsa_lock(lsa
));
4167 thread_add_event(master
, ospf_ls_ack_send_event
, oi
, 0,
4168 &oi
->t_ls_ack_direct
);
4171 /* Send Link State Acknowledgment delayed. */
4172 void ospf_ls_ack_send_delayed(struct ospf_interface
*oi
)
4176 /* Decide destination address. */
4177 /* RFC2328 Section 13.5 On non-broadcast
4178 networks, delayed Link State Acknowledgment packets must be
4179 unicast separately over each adjacency (i.e., neighbor whose
4180 state is >= Exchange). */
4181 if (oi
->type
== OSPF_IFTYPE_NBMA
) {
4182 struct ospf_neighbor
*nbr
;
4183 struct route_node
*rn
;
4185 for (rn
= route_top(oi
->nbrs
); rn
; rn
= route_next(rn
))
4186 if ((nbr
= rn
->info
) != NULL
)
4187 if (nbr
!= oi
->nbr_self
4188 && nbr
->state
>= NSM_Exchange
)
4189 while (listcount(oi
->ls_ack
))
4190 ospf_ls_ack_send_list(
4192 nbr
->address
.u
.prefix4
);
4195 if (oi
->type
== OSPF_IFTYPE_VIRTUALLINK
)
4196 dst
.s_addr
= oi
->vl_data
->peer_addr
.s_addr
;
4197 else if (oi
->state
== ISM_DR
|| oi
->state
== ISM_Backup
)
4198 dst
.s_addr
= htonl(OSPF_ALLSPFROUTERS
);
4199 else if (oi
->type
== OSPF_IFTYPE_POINTOPOINT
)
4200 dst
.s_addr
= htonl(OSPF_ALLSPFROUTERS
);
4201 else if (oi
->type
== OSPF_IFTYPE_POINTOMULTIPOINT
)
4202 dst
.s_addr
= htonl(OSPF_ALLSPFROUTERS
);
4204 dst
.s_addr
= htonl(OSPF_ALLDROUTERS
);
4206 while (listcount(oi
->ls_ack
))
4207 ospf_ls_ack_send_list(oi
, oi
->ls_ack
, dst
);
4211 * On pt-to-pt links, all OSPF control packets are sent to the multicast
4212 * address. As a result, the kernel does not need to learn the interface
4213 * MAC of the OSPF neighbor. However, in our world, this will delay
4214 * convergence. Take the case when due to a link flap, all routes now
4215 * want to use an interface which was deemed to be costlier prior to this
4216 * event. For routes that will be installed, the missing MAC will have
4217 * punt-to-CPU set on them. This may overload the CPU control path that
4218 * can be avoided if the MAC was known apriori.
4220 #define OSPF_PING_NBR_STR_MAX (BUFSIZ)
4221 void ospf_proactively_arp(struct ospf_neighbor
*nbr
)
4223 char ping_nbr
[OSPF_PING_NBR_STR_MAX
];
4226 if (!nbr
|| !nbr
->oi
|| !nbr
->oi
->ifp
)
4229 snprintf(ping_nbr
, sizeof(ping_nbr
),
4230 "ping -c 1 -I %s %s > /dev/null 2>&1 &", nbr
->oi
->ifp
->name
,
4231 inet_ntoa(nbr
->address
.u
.prefix4
));
4233 ret
= system(ping_nbr
);
4234 if (IS_DEBUG_OSPF_EVENT
)
4235 zlog_debug("Executed %s %s", ping_nbr
,
4236 ((ret
== 0) ? "successfully" : "but failed"));