]> git.proxmox.com Git - mirror_frr.git/blame - ospfd/ospf_zebra.c
*: list_delete_and_null() -> list_delete()
[mirror_frr.git] / ospfd / ospf_zebra.c
CommitLineData
718e3744 1/*
2 * Zebra connect library for OSPFd
3 * Copyright (C) 1997, 98, 99, 2000 Kunihiro Ishiguro, Toshiaki Takada
4 *
5 * This file is part of GNU Zebra.
6 *
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
10 * later version.
11 *
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.
16 *
896014f4
DL
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
718e3744 20 */
21
22#include <zebra.h>
23
24#include "thread.h"
25#include "command.h"
26#include "network.h"
27#include "prefix.h"
28#include "routemap.h"
29#include "table.h"
30#include "stream.h"
31#include "memory.h"
32#include "zclient.h"
33#include "filter.h"
dd669bb0 34#include "plist.h"
718e3744 35#include "log.h"
2376c3f2 36#include "lib/bfd.h"
5b30316e 37#include "nexthop.h"
718e3744 38
39#include "ospfd/ospfd.h"
40#include "ospfd/ospf_interface.h"
41#include "ospfd/ospf_ism.h"
42#include "ospfd/ospf_asbr.h"
43#include "ospfd/ospf_asbr.h"
44#include "ospfd/ospf_abr.h"
45#include "ospfd/ospf_lsa.h"
46#include "ospfd/ospf_dump.h"
47#include "ospfd/ospf_route.h"
d5a5c8f0
DS
48#include "ospfd/ospf_lsdb.h"
49#include "ospfd/ospf_neighbor.h"
50#include "ospfd/ospf_nsm.h"
718e3744 51#include "ospfd/ospf_zebra.h"
16f1b9ee 52#include "ospfd/ospf_te.h"
718e3744 53
dfac5d39
CS
54DEFINE_MTYPE_STATIC(OSPFD, OSPF_EXTERNAL, "OSPF External route table")
55DEFINE_MTYPE_STATIC(OSPFD, OSPF_REDISTRIBUTE, "OSPF Redistriute")
b5a8894d 56DEFINE_MTYPE_STATIC(OSPFD, OSPF_DIST_ARGS, "OSPF Distribute arguments")
dfac5d39 57
d62a17ae 58DEFINE_HOOK(ospf_if_update, (struct interface * ifp), (ifp))
59DEFINE_HOOK(ospf_if_delete, (struct interface * ifp), (ifp))
3012671f 60
718e3744 61/* Zebra structure to hold current status. */
62struct zclient *zclient = NULL;
63
64/* For registering threads. */
65extern struct thread_master *master;
18a6dce6 66
67/* Router-id update message from zebra. */
d62a17ae 68static int ospf_router_id_update_zebra(int command, struct zclient *zclient,
69 zebra_size_t length, vrf_id_t vrf_id)
18a6dce6 70{
b5a8894d 71 struct ospf *ospf = NULL;
d62a17ae 72 struct prefix router_id;
73 zebra_router_id_update_read(zclient->ibuf, &router_id);
74
75 if (IS_DEBUG_OSPF(zebra, ZEBRA_INTERFACE)) {
76 char buf[PREFIX2STR_BUFFER];
77 prefix2str(&router_id, buf, sizeof(buf));
996c9314
LB
78 zlog_debug("Zebra rcvd: router id update %s vrf %s id %u", buf,
79 ospf_vrf_id_to_name(vrf_id), vrf_id);
d62a17ae 80 }
81
b5a8894d 82 ospf = ospf_lookup_by_vrf_id(vrf_id);
d62a17ae 83
6021c6c0
CS
84 if (ospf != NULL) {
85 ospf->router_id_zebra = router_id.u.prefix4;
d62a17ae 86 ospf_router_id_update(ospf);
6021c6c0 87 } else {
b5a8894d
CS
88 if (IS_DEBUG_OSPF_EVENT) {
89 char buf[PREFIX2STR_BUFFER];
90
91 prefix2str(&router_id, buf, sizeof(buf));
996c9314
LB
92 zlog_debug(
93 "%s: ospf instance not found for vrf %s id %u router_id %s",
94 __PRETTY_FUNCTION__,
95 ospf_vrf_id_to_name(vrf_id), vrf_id, buf);
b5a8894d
CS
96 }
97 }
d62a17ae 98 return 0;
18a6dce6 99}
718e3744 100
101/* Inteface addition message from zebra. */
d62a17ae 102static int ospf_interface_add(int command, struct zclient *zclient,
103 zebra_size_t length, vrf_id_t vrf_id)
718e3744 104{
b5a8894d
CS
105 struct interface *ifp = NULL;
106 struct ospf *ospf = NULL;
718e3744 107
d62a17ae 108 ifp = zebra_interface_add_read(zclient->ibuf, vrf_id);
43b8d1d8
CS
109 if (ifp == NULL)
110 return 0;
718e3744 111
d62a17ae 112 if (IS_DEBUG_OSPF(zebra, ZEBRA_INTERFACE))
113 zlog_debug(
96065dc3 114 "Zebra: interface add %s vrf %s[%u] index %d flags %llx metric %d mtu %d speed %u",
b5a8894d
CS
115 ifp->name, ospf_vrf_id_to_name(ifp->vrf_id),
116 ifp->vrf_id, ifp->ifindex,
96065dc3
CS
117 (unsigned long long)ifp->flags, ifp->metric, ifp->mtu,
118 ifp->speed);
718e3744 119
d62a17ae 120 assert(ifp->info);
f2c80652 121
bcfdc787
QY
122 if (IF_DEF_PARAMS(ifp)
123 && !OSPF_IF_PARAM_CONFIGURED(IF_DEF_PARAMS(ifp), type)) {
d62a17ae 124 SET_IF_PARAM(IF_DEF_PARAMS(ifp), type);
125 IF_DEF_PARAMS(ifp)->type = ospf_default_iftype(ifp);
126 }
718e3744 127
b5a8894d 128 ospf = ospf_lookup_by_vrf_id(vrf_id);
43b8d1d8
CS
129 if (!ospf)
130 return 0;
b5a8894d 131
96065dc3
CS
132 ospf_if_recalculate_output_cost(ifp);
133
b5a8894d 134 ospf_if_update(ospf, ifp);
718e3744 135
d62a17ae 136 hook_call(ospf_if_update, ifp);
718e3744 137
d62a17ae 138 return 0;
718e3744 139}
140
d62a17ae 141static int ospf_interface_delete(int command, struct zclient *zclient,
142 zebra_size_t length, vrf_id_t vrf_id)
718e3744 143{
d62a17ae 144 struct interface *ifp;
145 struct stream *s;
146 struct route_node *rn;
718e3744 147
d62a17ae 148 s = zclient->ibuf;
149 /* zebra_interface_state_read() updates interface structure in iflist */
150 ifp = zebra_interface_state_read(s, vrf_id);
718e3744 151
d62a17ae 152 if (ifp == NULL)
153 return 0;
718e3744 154
d62a17ae 155 if (IS_DEBUG_OSPF(zebra, ZEBRA_INTERFACE))
156 zlog_debug(
b5a8894d
CS
157 "Zebra: interface delete %s vrf %s[%u] index %d flags %llx metric %d mtu %d",
158 ifp->name, ospf_vrf_id_to_name(ifp->vrf_id),
159 ifp->vrf_id, ifp->ifindex,
d62a17ae 160 (unsigned long long)ifp->flags, ifp->metric, ifp->mtu);
718e3744 161
d62a17ae 162 hook_call(ospf_if_delete, ifp);
718e3744 163
d62a17ae 164 for (rn = route_top(IF_OIFS(ifp)); rn; rn = route_next(rn))
165 if (rn->info)
166 ospf_if_free((struct ospf_interface *)rn->info);
718e3744 167
ff880b78 168 if_set_index(ifp, IFINDEX_INTERNAL);
d62a17ae 169 return 0;
718e3744 170}
171
d62a17ae 172static struct interface *zebra_interface_if_lookup(struct stream *s,
173 vrf_id_t vrf_id)
718e3744 174{
d62a17ae 175 char ifname_tmp[INTERFACE_NAMSIZ];
718e3744 176
d62a17ae 177 /* Read interface name. */
178 stream_get(ifname_tmp, s, INTERFACE_NAMSIZ);
718e3744 179
d62a17ae 180 /* And look it up. */
bcc24579 181 return if_lookup_by_name(ifname_tmp, vrf_id);
718e3744 182}
183
d62a17ae 184static int ospf_interface_state_up(int command, struct zclient *zclient,
185 zebra_size_t length, vrf_id_t vrf_id)
718e3744 186{
d62a17ae 187 struct interface *ifp;
188 struct ospf_interface *oi;
189 struct route_node *rn;
190
191 ifp = zebra_interface_if_lookup(zclient->ibuf, vrf_id);
192
193 if (ifp == NULL)
194 return 0;
195
196 /* Interface is already up. */
197 if (if_is_operative(ifp)) {
198 /* Temporarily keep ifp values. */
199 struct interface if_tmp;
200 memcpy(&if_tmp, ifp, sizeof(struct interface));
201
202 zebra_interface_if_set_value(zclient->ibuf, ifp);
203
204 if (IS_DEBUG_OSPF(zebra, ZEBRA_INTERFACE))
205 zlog_debug(
206 "Zebra: Interface[%s] state update speed %u -> %u, bw %d -> %d",
207 ifp->name, if_tmp.speed, ifp->speed,
208 if_tmp.bandwidth, ifp->bandwidth);
209
210 ospf_if_recalculate_output_cost(ifp);
211
212 if (if_tmp.mtu != ifp->mtu) {
213 if (IS_DEBUG_OSPF(zebra, ZEBRA_INTERFACE))
214 zlog_debug(
215 "Zebra: Interface[%s] MTU change %u -> %u.",
216 ifp->name, if_tmp.mtu, ifp->mtu);
217
218 /* Must reset the interface (simulate down/up) when MTU
219 * changes. */
220 ospf_if_reset(ifp);
221 }
222 return 0;
a608bbf2 223 }
cf795c5d 224
d62a17ae 225 zebra_interface_if_set_value(zclient->ibuf, ifp);
cf795c5d 226
d62a17ae 227 if (IS_DEBUG_OSPF(zebra, ZEBRA_INTERFACE))
228 zlog_debug("Zebra: Interface[%s] state change to up.",
229 ifp->name);
cf795c5d 230
d62a17ae 231 for (rn = route_top(IF_OIFS(ifp)); rn; rn = route_next(rn)) {
232 if ((oi = rn->info) == NULL)
233 continue;
cf795c5d 234
d62a17ae 235 ospf_if_up(oi);
236 }
cf795c5d 237
d62a17ae 238 return 0;
718e3744 239}
240
d62a17ae 241static int ospf_interface_state_down(int command, struct zclient *zclient,
242 zebra_size_t length, vrf_id_t vrf_id)
718e3744 243{
d62a17ae 244 struct interface *ifp;
245 struct ospf_interface *oi;
246 struct route_node *node;
718e3744 247
d62a17ae 248 ifp = zebra_interface_state_read(zclient->ibuf, vrf_id);
718e3744 249
d62a17ae 250 if (ifp == NULL)
251 return 0;
718e3744 252
d62a17ae 253 if (IS_DEBUG_OSPF(zebra, ZEBRA_INTERFACE))
254 zlog_debug("Zebra: Interface[%s] state change to down.",
255 ifp->name);
718e3744 256
d62a17ae 257 for (node = route_top(IF_OIFS(ifp)); node; node = route_next(node)) {
258 if ((oi = node->info) == NULL)
259 continue;
260 ospf_if_down(oi);
261 }
718e3744 262
d62a17ae 263 return 0;
718e3744 264}
265
d62a17ae 266static int ospf_interface_address_add(int command, struct zclient *zclient,
267 zebra_size_t length, vrf_id_t vrf_id)
718e3744 268{
d62a17ae 269 struct connected *c;
b5a8894d
CS
270 struct ospf *ospf = NULL;
271
718e3744 272
d62a17ae 273 c = zebra_interface_address_read(command, zclient->ibuf, vrf_id);
718e3744 274
d62a17ae 275 if (c == NULL)
276 return 0;
718e3744 277
d62a17ae 278 if (IS_DEBUG_OSPF(zebra, ZEBRA_INTERFACE)) {
279 char buf[PREFIX2STR_BUFFER];
280 prefix2str(c->address, buf, sizeof(buf));
b5a8894d
CS
281 zlog_debug("Zebra: interface %s address add %s vrf %s id %u",
282 c->ifp->name, buf, ospf_vrf_id_to_name(vrf_id),
283 vrf_id);
d62a17ae 284 }
7f643ebf 285
b5a8894d 286 ospf = ospf_lookup_by_vrf_id(vrf_id);
43b8d1d8
CS
287 if (!ospf)
288 return 0;
b5a8894d
CS
289
290 ospf_if_update(ospf, c->ifp);
718e3744 291
d62a17ae 292 hook_call(ospf_if_update, c->ifp);
718e3744 293
d62a17ae 294 return 0;
718e3744 295}
296
d62a17ae 297static int ospf_interface_address_delete(int command, struct zclient *zclient,
298 zebra_size_t length, vrf_id_t vrf_id)
718e3744 299{
d62a17ae 300 struct connected *c;
301 struct interface *ifp;
302 struct ospf_interface *oi;
303 struct route_node *rn;
304 struct prefix p;
305
306 c = zebra_interface_address_read(command, zclient->ibuf, vrf_id);
307
308 if (c == NULL)
309 return 0;
310
311 if (IS_DEBUG_OSPF(zebra, ZEBRA_INTERFACE)) {
312 char buf[PREFIX2STR_BUFFER];
313 prefix2str(c->address, buf, sizeof(buf));
314 zlog_debug("Zebra: interface %s address delete %s",
315 c->ifp->name, buf);
316 }
7f643ebf 317
d62a17ae 318 ifp = c->ifp;
319 p = *c->address;
320 p.prefixlen = IPV4_MAX_PREFIXLEN;
718e3744 321
d62a17ae 322 rn = route_node_lookup(IF_OIFS(ifp), &p);
323 if (!rn) {
324 connected_free(c);
325 return 0;
326 }
718e3744 327
d62a17ae 328 assert(rn->info);
329 oi = rn->info;
330 route_unlock_node(rn);
cf795c5d 331
d62a17ae 332 /* Call interface hook functions to clean up */
333 ospf_if_free(oi);
cf795c5d 334
d62a17ae 335 hook_call(ospf_if_update, c->ifp);
718e3744 336
d62a17ae 337 connected_free(c);
718e3744 338
d62a17ae 339 return 0;
718e3744 340}
72357f2b 341
d62a17ae 342static int ospf_interface_link_params(int command, struct zclient *zclient,
343 zebra_size_t length)
16f1b9ee 344{
d62a17ae 345 struct interface *ifp;
16f1b9ee 346
d62a17ae 347 ifp = zebra_interface_link_params_read(zclient->ibuf);
16f1b9ee 348
d62a17ae 349 if (ifp == NULL)
350 return 0;
16f1b9ee 351
d62a17ae 352 /* Update TE TLV */
353 ospf_mpls_te_update_if(ifp);
16f1b9ee 354
d62a17ae 355 return 0;
16f1b9ee
OD
356}
357
b5a8894d
CS
358/* VRF update for an interface. */
359static int ospf_interface_vrf_update(int command, struct zclient *zclient,
996c9314 360 zebra_size_t length, vrf_id_t vrf_id)
b5a8894d
CS
361{
362 struct interface *ifp = NULL;
363 vrf_id_t new_vrf_id;
16f1b9ee 364
b5a8894d 365 ifp = zebra_interface_vrf_update_read(zclient->ibuf, vrf_id,
996c9314 366 &new_vrf_id);
b5a8894d
CS
367 if (!ifp)
368 return 0;
369
370 if (IS_DEBUG_OSPF_EVENT)
996c9314
LB
371 zlog_debug(
372 "%s: Rx Interface %s VRF change vrf_id %u New vrf %s id %u",
373 __PRETTY_FUNCTION__, ifp->name, vrf_id,
374 ospf_vrf_id_to_name(new_vrf_id), new_vrf_id);
b5a8894d
CS
375
376 /*if_update(ifp, ifp->name, strlen(ifp->name), new_vrf_id);*/
377 if_update_to_new_vrf(ifp, new_vrf_id);
378
996c9314 379 return 0;
b5a8894d
CS
380}
381
382void ospf_zebra_add(struct ospf *ospf, struct prefix_ipv4 *p,
996c9314 383 struct ospf_route * or)
718e3744 384{
5fef910e
RW
385 struct zapi_route api;
386 struct zapi_nexthop *api_nh;
d7c0a89a 387 uint8_t distance;
d62a17ae 388 struct ospf_path *path;
389 struct listnode *node;
5fef910e 390 int count = 0;
d62a17ae 391
5fef910e 392 memset(&api, 0, sizeof(api));
b5a8894d 393 api.vrf_id = ospf->vrf_id;
5fef910e
RW
394 api.type = ZEBRA_ROUTE_OSPF;
395 api.instance = ospf->instance;
396 api.safi = SAFI_UNICAST;
d00061ea 397
5fef910e
RW
398 memcpy(&api.prefix, p, sizeof(*p));
399 SET_FLAG(api.message, ZAPI_MESSAGE_NEXTHOP);
d00061ea 400
5fef910e
RW
401 /* Metric value. */
402 SET_FLAG(api.message, ZAPI_MESSAGE_METRIC);
403 if (or->path_type == OSPF_PATH_TYPE1_EXTERNAL)
404 api.metric = or->cost + or->u.ext.type2_cost;
405 else if (or->path_type == OSPF_PATH_TYPE2_EXTERNAL)
406 api.metric = or->u.ext.type2_cost;
407 else
408 api.metric = or->cost;
d00061ea
RW
409
410 /* Check if path type is ASE */
411 if (((or->path_type == OSPF_PATH_TYPE1_EXTERNAL)
412 || (or->path_type == OSPF_PATH_TYPE2_EXTERNAL))
5fef910e
RW
413 && (or->u.ext.tag > 0) && (or->u.ext.tag <= ROUTE_TAG_MAX)) {
414 SET_FLAG(api.message, ZAPI_MESSAGE_TAG);
415 api.tag = or->u.ext.tag;
416 }
d00061ea 417
5fef910e 418 /* Distance value. */
b5a8894d 419 distance = ospf_distance_apply(ospf, p, or);
5fef910e
RW
420 if (distance) {
421 SET_FLAG(api.message, ZAPI_MESSAGE_DISTANCE);
422 api.distance = distance;
423 }
d00061ea
RW
424
425 /* Nexthop, ifindex, distance and metric information. */
426 for (ALL_LIST_ELEMENTS_RO(or->paths, node, path)) {
a74e593b
RW
427 if (count >= MULTIPATH_NUM)
428 break;
5fef910e 429 api_nh = &api.nexthops[count];
525c1839 430#ifdef HAVE_NETLINK
d00061ea
RW
431 if (path->unnumbered || (path->nexthop.s_addr != INADDR_ANY
432 && path->ifindex != 0)) {
525c1839 433#else /* HAVE_NETLINK */
d00061ea 434 if (path->nexthop.s_addr != INADDR_ANY && path->ifindex != 0) {
5fef910e
RW
435#endif /* HAVE_NETLINK */
436 api_nh->gate.ipv4 = path->nexthop;
437 api_nh->ifindex = path->ifindex;
438 api_nh->type = NEXTHOP_TYPE_IPV4_IFINDEX;
d00061ea 439 } else if (path->nexthop.s_addr != INADDR_ANY) {
5fef910e
RW
440 api_nh->gate.ipv4 = path->nexthop;
441 api_nh->type = NEXTHOP_TYPE_IPV4;
d00061ea 442 } else {
5fef910e
RW
443 api_nh->ifindex = path->ifindex;
444 api_nh->type = NEXTHOP_TYPE_IFINDEX;
d00061ea 445 }
4a7371e9 446 api_nh->vrf_id = ospf->vrf_id;
5fef910e 447 count++;
72357f2b 448
d00061ea 449 if (IS_DEBUG_OSPF(zebra, ZEBRA_REDISTRIBUTE)) {
96065dc3
CS
450 char buf[2][INET_ADDRSTRLEN];
451 struct interface *ifp;
452
453 ifp = if_lookup_by_index(path->ifindex, ospf->vrf_id);
4259ea81 454
d00061ea 455 zlog_debug(
96065dc3 456 "Zebra: Route add %s nexthop %s, ifindex=%d %s",
4259ea81
MS
457 prefix2str(p, buf[0], sizeof(buf[0])),
458 inet_ntop(AF_INET, &path->nexthop,
459 buf[1], sizeof(buf[1])),
96065dc3 460 path->ifindex, ifp ? ifp->name : " ");
d62a17ae 461 }
d00061ea 462 }
a74e593b 463 api.nexthop_num = count;
d62a17ae 464
5fef910e 465 zclient_route_send(ZEBRA_ROUTE_ADD, zclient, &api);
718e3744 466}
467
b5a8894d 468void ospf_zebra_delete(struct ospf *ospf, struct prefix_ipv4 *p,
996c9314 469 struct ospf_route * or)
718e3744 470{
5fef910e 471 struct zapi_route api;
d62a17ae 472
5fef910e 473 memset(&api, 0, sizeof(api));
b5a8894d 474 api.vrf_id = ospf->vrf_id;
5fef910e
RW
475 api.type = ZEBRA_ROUTE_OSPF;
476 api.instance = ospf->instance;
477 api.safi = SAFI_UNICAST;
478 memcpy(&api.prefix, p, sizeof(*p));
d62a17ae 479
5fef910e 480 if (IS_DEBUG_OSPF(zebra, ZEBRA_REDISTRIBUTE)) {
4259ea81
MS
481 char buf[PREFIX2STR_BUFFER];
482 zlog_debug("Zebra: Route delete %s",
483 prefix2str(p, buf, sizeof(buf)));
ba281d3d 484 }
d00061ea 485
5fef910e 486 zclient_route_send(ZEBRA_ROUTE_DELETE, zclient, &api);
718e3744 487}
488
b5a8894d 489void ospf_zebra_add_discard(struct ospf *ospf, struct prefix_ipv4 *p)
718e3744 490{
5fef910e 491 struct zapi_route api;
d62a17ae 492
5fef910e 493 memset(&api, 0, sizeof(api));
b5a8894d 494 api.vrf_id = ospf->vrf_id;
d00061ea
RW
495 api.type = ZEBRA_ROUTE_OSPF;
496 api.instance = ospf->instance;
d00061ea 497 api.safi = SAFI_UNICAST;
5fef910e 498 memcpy(&api.prefix, p, sizeof(*p));
09a484dd 499 zapi_route_set_blackhole(&api, BLACKHOLE_NULL);
d00061ea 500
5fef910e 501 zclient_route_send(ZEBRA_ROUTE_ADD, zclient, &api);
d00061ea 502
4259ea81
MS
503 if (IS_DEBUG_OSPF(zebra, ZEBRA_REDISTRIBUTE)) {
504 char buf[PREFIX2STR_BUFFER];
505 zlog_debug("Zebra: Route add discard %s",
506 prefix2str(p, buf, sizeof(buf)));
507 }
718e3744 508}
509
b5a8894d 510void ospf_zebra_delete_discard(struct ospf *ospf, struct prefix_ipv4 *p)
718e3744 511{
5fef910e 512 struct zapi_route api;
d62a17ae 513
5fef910e 514 memset(&api, 0, sizeof(api));
b5a8894d 515 api.vrf_id = ospf->vrf_id;
d00061ea
RW
516 api.type = ZEBRA_ROUTE_OSPF;
517 api.instance = ospf->instance;
d00061ea 518 api.safi = SAFI_UNICAST;
5fef910e 519 memcpy(&api.prefix, p, sizeof(*p));
09a484dd 520 zapi_route_set_blackhole(&api, BLACKHOLE_NULL);
d00061ea 521
5fef910e 522 zclient_route_send(ZEBRA_ROUTE_DELETE, zclient, &api);
d00061ea 523
4259ea81
MS
524 if (IS_DEBUG_OSPF(zebra, ZEBRA_REDISTRIBUTE)) {
525 char buf[PREFIX2STR_BUFFER];
526 zlog_debug("Zebra: Route delete discard %s",
527 prefix2str(p, buf, sizeof(buf)));
528 }
718e3744 529}
530
d7c0a89a
QY
531struct ospf_external *ospf_external_lookup(struct ospf *ospf, uint8_t type,
532 unsigned short instance)
7c8ff89e 533{
d62a17ae 534 struct list *ext_list;
535 struct listnode *node;
536 struct ospf_external *ext;
7c8ff89e 537
de1ac5fd 538 ext_list = ospf->external[type];
d62a17ae 539 if (!ext_list)
540 return (NULL);
7c8ff89e 541
d62a17ae 542 for (ALL_LIST_ELEMENTS_RO(ext_list, node, ext))
543 if (ext->instance == instance)
544 return ext;
7c8ff89e 545
d62a17ae 546 return NULL;
7c8ff89e
DS
547}
548
d7c0a89a
QY
549struct ospf_external *ospf_external_add(struct ospf *ospf, uint8_t type,
550 unsigned short instance)
7c8ff89e 551{
d62a17ae 552 struct list *ext_list;
553 struct ospf_external *ext;
7c8ff89e 554
de1ac5fd 555 ext = ospf_external_lookup(ospf, type, instance);
d62a17ae 556 if (ext)
557 return ext;
7c8ff89e 558
de1ac5fd
CS
559 if (!ospf->external[type])
560 ospf->external[type] = list_new();
7c8ff89e 561
de1ac5fd 562 ext_list = ospf->external[type];
7f586094
CS
563 ext = (struct ospf_external *)XCALLOC(MTYPE_OSPF_EXTERNAL,
564 sizeof(struct ospf_external));
d62a17ae 565 ext->instance = instance;
566 EXTERNAL_INFO(ext) = route_table_init();
7c8ff89e 567
d62a17ae 568 listnode_add(ext_list, ext);
7c8ff89e 569
d62a17ae 570 return ext;
7c8ff89e
DS
571}
572
d7c0a89a 573void ospf_external_del(struct ospf *ospf, uint8_t type, unsigned short instance)
7c8ff89e 574{
d62a17ae 575 struct ospf_external *ext;
576
de1ac5fd 577 ext = ospf_external_lookup(ospf, type, instance);
d62a17ae 578
579 if (ext) {
580 if (EXTERNAL_INFO(ext))
581 route_table_finish(EXTERNAL_INFO(ext));
582
de1ac5fd
CS
583 listnode_delete(ospf->external[type], ext);
584
585 if (!ospf->external[type]->count)
6a154c88 586 list_delete(&ospf->external[type]);
de1ac5fd 587
7f586094 588 XFREE(MTYPE_OSPF_EXTERNAL, ext);
d62a17ae 589 }
7c8ff89e
DS
590}
591
d7c0a89a
QY
592struct ospf_redist *ospf_redist_lookup(struct ospf *ospf, uint8_t type,
593 unsigned short instance)
7c8ff89e 594{
d62a17ae 595 struct list *red_list;
596 struct listnode *node;
597 struct ospf_redist *red;
7c8ff89e 598
d62a17ae 599 red_list = ospf->redist[type];
600 if (!red_list)
601 return (NULL);
7c8ff89e 602
d62a17ae 603 for (ALL_LIST_ELEMENTS_RO(red_list, node, red))
604 if (red->instance == instance)
605 return red;
7c8ff89e 606
d62a17ae 607 return NULL;
7c8ff89e
DS
608}
609
d7c0a89a
QY
610struct ospf_redist *ospf_redist_add(struct ospf *ospf, uint8_t type,
611 unsigned short instance)
7c8ff89e 612{
d62a17ae 613 struct list *red_list;
614 struct ospf_redist *red;
7c8ff89e 615
d62a17ae 616 red = ospf_redist_lookup(ospf, type, instance);
617 if (red)
618 return red;
7c8ff89e 619
d62a17ae 620 if (!ospf->redist[type])
621 ospf->redist[type] = list_new();
7c8ff89e 622
d62a17ae 623 red_list = ospf->redist[type];
7f586094
CS
624 red = (struct ospf_redist *)XCALLOC(MTYPE_OSPF_REDISTRIBUTE,
625 sizeof(struct ospf_redist));
d62a17ae 626 red->instance = instance;
627 red->dmetric.type = -1;
628 red->dmetric.value = -1;
7c8ff89e 629
d62a17ae 630 listnode_add(red_list, red);
7c8ff89e 631
d62a17ae 632 return red;
7c8ff89e
DS
633}
634
d7c0a89a 635void ospf_redist_del(struct ospf *ospf, uint8_t type, unsigned short instance)
7c8ff89e 636{
d62a17ae 637 struct ospf_redist *red;
638
639 red = ospf_redist_lookup(ospf, type, instance);
640
641 if (red) {
642 listnode_delete(ospf->redist[type], red);
643 if (!ospf->redist[type]->count) {
6a154c88 644 list_delete(&ospf->redist[type]);
d62a17ae 645 }
97a69b31 646 ospf_routemap_unset(red);
7f586094 647 XFREE(MTYPE_OSPF_REDISTRIBUTE, red);
d62a17ae 648 }
7c8ff89e
DS
649}
650
651
d7c0a89a
QY
652int ospf_is_type_redistributed(struct ospf *ospf, int type,
653 unsigned short instance)
718e3744 654{
d62a17ae 655 return (DEFAULT_ROUTE_TYPE(type)
656 ? vrf_bitmap_check(zclient->default_information,
b5a8894d 657 ospf->vrf_id)
d62a17ae 658 : ((instance
659 && redist_check_instance(
660 &zclient->mi_redist[AFI_IP][type],
661 instance))
662 || (!instance
663 && vrf_bitmap_check(
664 zclient->redist[AFI_IP][type],
b5a8894d 665 ospf->vrf_id))));
718e3744 666}
667
d7c0a89a 668int ospf_redistribute_set(struct ospf *ospf, int type, unsigned short instance,
d62a17ae 669 int mtype, int mvalue)
718e3744 670{
d62a17ae 671 int force = 0;
672 struct ospf_redist *red;
673
674 red = ospf_redist_lookup(ospf, type, instance);
162dbe41 675
676 if (red == NULL) {
677 zlog_err(
678 "Redistribute[%s][%d]: Lookup failed Type[%d] , Metric[%d]",
679 ospf_redist_string(type), instance,
680 metric_type(ospf, type, instance),
681 metric_value(ospf, type, instance));
682 return CMD_WARNING_CONFIG_FAILED;
683 }
684
b5a8894d 685 if (ospf_is_type_redistributed(ospf, type, instance)) {
d62a17ae 686 if (mtype != red->dmetric.type) {
687 red->dmetric.type = mtype;
688 force = LSA_REFRESH_FORCE;
689 }
690 if (mvalue != red->dmetric.value) {
691 red->dmetric.value = mvalue;
692 force = LSA_REFRESH_FORCE;
693 }
694
695 ospf_external_lsa_refresh_type(ospf, type, instance, force);
696
697 if (IS_DEBUG_OSPF(zebra, ZEBRA_REDISTRIBUTE))
698 zlog_debug(
699 "Redistribute[%s][%d]: Refresh Type[%d], Metric[%d]",
700 ospf_redist_string(type), instance,
701 metric_type(ospf, type, instance),
702 metric_value(ospf, type, instance));
703
704 return CMD_SUCCESS;
705 }
706
707 red->dmetric.type = mtype;
708 red->dmetric.value = mvalue;
709
de1ac5fd 710 ospf_external_add(ospf, type, instance);
d62a17ae 711
712 zclient_redistribute(ZEBRA_REDISTRIBUTE_ADD, zclient, AFI_IP, type,
b5a8894d 713 instance, ospf->vrf_id);
d62a17ae 714
715 if (IS_DEBUG_OSPF(zebra, ZEBRA_REDISTRIBUTE))
996c9314
LB
716 zlog_debug(
717 "Redistribute[%s][%d] vrf id %u: Start Type[%d], Metric[%d]",
718 ospf_redist_string(type), instance, ospf->vrf_id,
719 metric_type(ospf, type, instance),
720 metric_value(ospf, type, instance));
d62a17ae 721
722 ospf_asbr_status_update(ospf, ++ospf->redistribute);
723
724 return CMD_SUCCESS;
718e3744 725}
726
d7c0a89a
QY
727int ospf_redistribute_unset(struct ospf *ospf, int type,
728 unsigned short instance)
718e3744 729{
d62a17ae 730 if (type == zclient->redist_default && instance == zclient->instance)
731 return CMD_SUCCESS;
718e3744 732
b5a8894d 733 if (!ospf_is_type_redistributed(ospf, type, instance))
d62a17ae 734 return CMD_SUCCESS;
718e3744 735
d62a17ae 736 zclient_redistribute(ZEBRA_REDISTRIBUTE_DELETE, zclient, AFI_IP, type,
b5a8894d 737 instance, ospf->vrf_id);
cf795c5d 738
d62a17ae 739 if (IS_DEBUG_OSPF(zebra, ZEBRA_REDISTRIBUTE))
b5a8894d
CS
740 zlog_debug("Redistribute[%s][%d] vrf id %u: Stop",
741 ospf_redist_string(type), instance, ospf->vrf_id);
718e3744 742
d62a17ae 743 /* Remove the routes from OSPF table. */
744 ospf_redistribute_withdraw(ospf, type, instance);
7c8ff89e 745
de1ac5fd 746 ospf_external_del(ospf, type, instance);
718e3744 747
d62a17ae 748 ospf_asbr_status_update(ospf, --ospf->redistribute);
718e3744 749
d62a17ae 750 return CMD_SUCCESS;
718e3744 751}
752
d62a17ae 753int ospf_redistribute_default_set(struct ospf *ospf, int originate, int mtype,
754 int mvalue)
718e3744 755{
d62a17ae 756 ospf->default_originate = originate;
020709f9 757
de1ac5fd 758 ospf_external_add(ospf, DEFAULT_ROUTE, 0);
7c8ff89e 759
766b826f 760 if (ospf_is_type_redistributed(ospf, DEFAULT_ROUTE, 0))
d62a17ae 761 if (IS_DEBUG_OSPF(zebra, ZEBRA_REDISTRIBUTE))
762 zlog_debug(
763 "Redistribute[%s]: Refresh Type[%d], Metric[%d]",
764 ospf_redist_string(DEFAULT_ROUTE),
765 metric_type(ospf, DEFAULT_ROUTE, 0),
766 metric_value(ospf, DEFAULT_ROUTE, 0));
718e3744 767
d62a17ae 768 zclient_redistribute_default(ZEBRA_REDISTRIBUTE_DEFAULT_ADD, zclient,
b5a8894d 769 ospf->vrf_id);
cf795c5d 770
d62a17ae 771 if (IS_DEBUG_OSPF(zebra, ZEBRA_REDISTRIBUTE))
772 zlog_debug("Redistribute[DEFAULT]: Start Type[%d], Metric[%d]",
773 metric_type(ospf, DEFAULT_ROUTE, 0),
774 metric_value(ospf, DEFAULT_ROUTE, 0));
718e3744 775
766b826f
DA
776 ospf_external_lsa_refresh_default(ospf);
777
d62a17ae 778 if (ospf->router_id.s_addr == 0)
779 ospf->external_origin |= (1 << DEFAULT_ROUTE);
780 else
781 thread_add_timer(master, ospf_default_originate_timer, ospf, 1,
782 NULL);
718e3744 783
d62a17ae 784 ospf_asbr_status_update(ospf, ++ospf->redistribute);
718e3744 785
d62a17ae 786 return CMD_SUCCESS;
718e3744 787}
788
d62a17ae 789int ospf_redistribute_default_unset(struct ospf *ospf)
718e3744 790{
b5a8894d 791 if (!ospf_is_type_redistributed(ospf, DEFAULT_ROUTE, 0))
d62a17ae 792 return CMD_SUCCESS;
718e3744 793
d62a17ae 794 ospf->default_originate = DEFAULT_ORIGINATE_NONE;
718e3744 795
d62a17ae 796 zclient_redistribute_default(ZEBRA_REDISTRIBUTE_DEFAULT_DELETE, zclient,
b5a8894d 797 ospf->vrf_id);
718e3744 798
d62a17ae 799 if (IS_DEBUG_OSPF(zebra, ZEBRA_REDISTRIBUTE))
800 zlog_debug("Redistribute[DEFAULT]: Stop");
cf795c5d 801
d62a17ae 802 // Pending: how does the external_info cleanup work in this case?
7c8ff89e 803
d62a17ae 804 ospf_asbr_status_update(ospf, --ospf->redistribute);
718e3744 805
d62a17ae 806 return CMD_SUCCESS;
718e3744 807}
808
d62a17ae 809static int ospf_external_lsa_originate_check(struct ospf *ospf,
810 struct external_info *ei)
718e3744 811{
d62a17ae 812 /* If prefix is multicast, then do not originate LSA. */
813 if (IN_MULTICAST(htonl(ei->p.prefix.s_addr))) {
814 zlog_info(
815 "LSA[Type5:%s]: Not originate AS-external-LSA, "
816 "Prefix belongs multicast",
817 inet_ntoa(ei->p.prefix));
818 return 0;
819 }
820
821 /* Take care of default-originate. */
822 if (is_prefix_default(&ei->p))
823 if (ospf->default_originate == DEFAULT_ORIGINATE_NONE) {
824 zlog_info(
825 "LSA[Type5:0.0.0.0]: Not originate AS-external-LSA "
826 "for default");
827 return 0;
828 }
829
830 return 1;
718e3744 831}
832
833/* If connected prefix is OSPF enable interface, then do not announce. */
d62a17ae 834int ospf_distribute_check_connected(struct ospf *ospf, struct external_info *ei)
718e3744 835{
d62a17ae 836 struct listnode *node;
837 struct ospf_interface *oi;
718e3744 838
718e3744 839
d62a17ae 840 for (ALL_LIST_ELEMENTS_RO(ospf->oiflist, node, oi))
841 if (prefix_match(oi->address, (struct prefix *)&ei->p))
842 return 0;
843 return 1;
718e3744 844}
845
846/* return 1 if external LSA must be originated, 0 otherwise */
d62a17ae 847int ospf_redistribute_check(struct ospf *ospf, struct external_info *ei,
848 int *changed)
718e3744 849{
d62a17ae 850 struct route_map_set_values save_values;
851 struct prefix_ipv4 *p = &ei->p;
852 struct ospf_redist *red;
d7c0a89a
QY
853 uint8_t type = is_prefix_default(&ei->p) ? DEFAULT_ROUTE : ei->type;
854 unsigned short instance = is_prefix_default(&ei->p) ? 0 : ei->instance;
d62a17ae 855
856 if (changed)
857 *changed = 0;
858
859 if (!ospf_external_lsa_originate_check(ospf, ei))
860 return 0;
861
862 /* Take care connected route. */
863 if (type == ZEBRA_ROUTE_CONNECT
864 && !ospf_distribute_check_connected(ospf, ei))
865 return 0;
866
867 if (!DEFAULT_ROUTE_TYPE(type) && DISTRIBUTE_NAME(ospf, type))
868 /* distirbute-list exists, but access-list may not? */
869 if (DISTRIBUTE_LIST(ospf, type))
870 if (access_list_apply(DISTRIBUTE_LIST(ospf, type), p)
871 == FILTER_DENY) {
4259ea81
MS
872 if (IS_DEBUG_OSPF(zebra, ZEBRA_REDISTRIBUTE)) {
873 char buf[PREFIX2STR_BUFFER];
d62a17ae 874 zlog_debug(
4259ea81 875 "Redistribute[%s]: %s filtered by distribute-list.",
d62a17ae 876 ospf_redist_string(type),
4259ea81
MS
877 prefix2str(p, buf, sizeof(buf)));
878 }
d62a17ae 879 return 0;
880 }
881
882 save_values = ei->route_map_set;
883 ospf_reset_route_map_set_values(&ei->route_map_set);
884
885 /* apply route-map if needed */
886 red = ospf_redist_lookup(ospf, type, instance);
887 if (red && ROUTEMAP_NAME(red)) {
888 int ret;
889
890 ret = route_map_apply(ROUTEMAP(red), (struct prefix *)p,
891 RMAP_OSPF, ei);
892
893 if (ret == RMAP_DENYMATCH) {
894 ei->route_map_set = save_values;
4259ea81
MS
895 if (IS_DEBUG_OSPF(zebra, ZEBRA_REDISTRIBUTE)) {
896 char buf[PREFIX2STR_BUFFER];
d62a17ae 897 zlog_debug(
4259ea81 898 "Redistribute[%s]: %s filtered by route-map.",
d62a17ae 899 ospf_redist_string(type),
4259ea81
MS
900 prefix2str(p, buf, sizeof(buf)));
901 }
d62a17ae 902 return 0;
903 }
904
905 /* check if 'route-map set' changed something */
906 if (changed)
907 *changed = !ospf_route_map_set_compare(
908 &ei->route_map_set, &save_values);
909 }
910
911 return 1;
718e3744 912}
913
914/* OSPF route-map set for redistribution */
d62a17ae 915void ospf_routemap_set(struct ospf_redist *red, const char *name)
718e3744 916{
d62a17ae 917 if (ROUTEMAP_NAME(red))
918 free(ROUTEMAP_NAME(red));
718e3744 919
d62a17ae 920 ROUTEMAP_NAME(red) = strdup(name);
921 ROUTEMAP(red) = route_map_lookup_by_name(name);
718e3744 922}
923
d62a17ae 924void ospf_routemap_unset(struct ospf_redist *red)
718e3744 925{
d62a17ae 926 if (ROUTEMAP_NAME(red))
927 free(ROUTEMAP_NAME(red));
718e3744 928
d62a17ae 929 ROUTEMAP_NAME(red) = NULL;
930 ROUTEMAP(red) = NULL;
718e3744 931}
932
933/* Zebra route add and delete treatment. */
74489921
RW
934static int ospf_zebra_read_route(int command, struct zclient *zclient,
935 zebra_size_t length, vrf_id_t vrf_id)
718e3744 936{
74489921
RW
937 struct zapi_route api;
938 struct prefix_ipv4 p;
d62a17ae 939 unsigned long ifindex;
940 struct in_addr nexthop;
d62a17ae 941 struct external_info *ei;
942 struct ospf *ospf;
943 int i;
944
b5a8894d 945 ospf = ospf_lookup_by_vrf_id(vrf_id);
74489921
RW
946 if (ospf == NULL)
947 return 0;
d62a17ae 948
74489921
RW
949 if (zapi_route_decode(zclient->ibuf, &api) < 0)
950 return -1;
d62a17ae 951
74489921
RW
952 ifindex = api.nexthops[0].ifindex;
953 nexthop = api.nexthops[0].gate.ipv4;
d62a17ae 954
74489921 955 memcpy(&p, &api.prefix, sizeof(p));
d62a17ae 956 if (IPV4_NET127(ntohl(p.prefix.s_addr)))
957 return 0;
958
5c780bc9
PZ
959 if (IS_DEBUG_OSPF(zebra, ZEBRA_REDISTRIBUTE)) {
960 char buf_prefix[PREFIX_STRLEN];
961 prefix2str(&api.prefix, buf_prefix, sizeof(buf_prefix));
962
963 zlog_debug("%s: from client %s: vrf_id %d, p %s", __func__,
964 zebra_route_string(api.type), vrf_id, buf_prefix);
965 }
966
74489921 967 if (command == ZEBRA_REDISTRIBUTE_ROUTE_ADD) {
d62a17ae 968 /* XXX|HACK|TODO|FIXME:
09a484dd
DL
969 * Maybe we should ignore reject/blackhole routes? Testing
970 * shows that there is no problems though and this is only way
971 * to "summarize" routes in ASBR at the moment. Maybe we need
972 * just a better generalised solution for these types?
d62a17ae 973 */
974
74489921 975 /* Protocol tag overwrites all other tag value sent by zebra */
d62a17ae 976 if (ospf->dtag[api.type] > 0)
977 api.tag = ospf->dtag[api.type];
978
979 /*
980 * Given zebra sends update for a prefix via ADD message, it
981 * should
982 * be considered as an implicit DEL for that prefix with other
983 * source
984 * types.
985 */
986 for (i = 0; i < ZEBRA_ROUTE_MAX; i++)
987 if (i != api.type)
996c9314
LB
988 ospf_external_info_delete(ospf, i, api.instance,
989 p);
d62a17ae 990
de1ac5fd
CS
991 ei = ospf_external_info_add(ospf, api.type, api.instance, p,
992 ifindex, nexthop, api.tag);
d62a17ae 993 if (ei == NULL) {
994 /* Nothing has changed, so nothing to do; return */
995 return 0;
996 }
997 if (ospf->router_id.s_addr == 0)
998 /* Set flags to generate AS-external-LSA originate event
999 for each redistributed protocols later. */
1000 ospf->external_origin |= (1 << api.type);
1001 else {
1002 if (ei) {
1003 if (is_prefix_default(&p))
1004 ospf_external_lsa_refresh_default(ospf);
1005 else {
1006 struct ospf_lsa *current;
1007
1008 current = ospf_external_info_find_lsa(
1009 ospf, &ei->p);
1010 if (!current)
1011 ospf_external_lsa_originate(
1012 ospf, ei);
1013 else {
1014 if (IS_DEBUG_OSPF(
1015 zebra,
1016 ZEBRA_REDISTRIBUTE))
1017 zlog_debug(
74489921 1018 "ospf_zebra_read_route() : %s refreshing LSA",
d62a17ae 1019 inet_ntoa(
1020 p.prefix));
1021 ospf_external_lsa_refresh(
1022 ospf, current, ei,
1023 LSA_REFRESH_FORCE);
1024 }
1025 }
1026 }
1027 }
74489921 1028 } else /* if (command == ZEBRA_REDISTRIBUTE_ROUTE_DEL) */
5048fe14 1029 {
de1ac5fd 1030 ospf_external_info_delete(ospf, api.type, api.instance, p);
d62a17ae 1031 if (is_prefix_default(&p))
1032 ospf_external_lsa_refresh_default(ospf);
1033 else
1034 ospf_external_lsa_flush(ospf, api.type, &p,
1035 ifindex /*, nexthop */);
5048fe14 1036 }
d62a17ae 1037
1038 return 0;
718e3744 1039}
6b0655a2 1040
cf795c5d 1041
d62a17ae 1042int ospf_distribute_list_out_set(struct ospf *ospf, int type, const char *name)
718e3744 1043{
d62a17ae 1044 /* Lookup access-list for distribute-list. */
1045 DISTRIBUTE_LIST(ospf, type) = access_list_lookup(AFI_IP, name);
718e3744 1046
d62a17ae 1047 /* Clear previous distribute-name. */
1048 if (DISTRIBUTE_NAME(ospf, type))
1049 free(DISTRIBUTE_NAME(ospf, type));
718e3744 1050
d62a17ae 1051 /* Set distribute-name. */
1052 DISTRIBUTE_NAME(ospf, type) = strdup(name);
718e3744 1053
d62a17ae 1054 /* If access-list have been set, schedule update timer. */
1055 if (DISTRIBUTE_LIST(ospf, type))
1056 ospf_distribute_list_update(ospf, type, 0);
718e3744 1057
d62a17ae 1058 return CMD_SUCCESS;
718e3744 1059}
1060
d62a17ae 1061int ospf_distribute_list_out_unset(struct ospf *ospf, int type,
1062 const char *name)
718e3744 1063{
d62a17ae 1064 /* Schedule update timer. */
1065 if (DISTRIBUTE_LIST(ospf, type))
1066 ospf_distribute_list_update(ospf, type, 0);
718e3744 1067
d62a17ae 1068 /* Unset distribute-list. */
1069 DISTRIBUTE_LIST(ospf, type) = NULL;
718e3744 1070
d62a17ae 1071 /* Clear distribute-name. */
1072 if (DISTRIBUTE_NAME(ospf, type))
1073 free(DISTRIBUTE_NAME(ospf, type));
cf795c5d 1074
d62a17ae 1075 DISTRIBUTE_NAME(ospf, type) = NULL;
718e3744 1076
d62a17ae 1077 return CMD_SUCCESS;
718e3744 1078}
1079
1080/* distribute-list update timer. */
d62a17ae 1081static int ospf_distribute_list_update_timer(struct thread *thread)
718e3744 1082{
d62a17ae 1083 struct route_node *rn;
1084 struct external_info *ei;
1085 struct route_table *rt;
1086 struct ospf_lsa *lsa;
b5a8894d
CS
1087 int type, default_refresh = 0, arg_type;
1088 struct ospf *ospf = NULL;
996c9314 1089 void **arg = THREAD_ARG(thread);
b5a8894d
CS
1090
1091 ospf = (struct ospf *)arg[0];
1092 arg_type = (int)(intptr_t)arg[1];
d62a17ae 1093
d62a17ae 1094 if (ospf == NULL)
1095 return 0;
1096
1097 ospf->t_distribute_update = NULL;
1098
1099 zlog_info("Zebra[Redistribute]: distribute-list update timer fired!");
1100
b5a8894d 1101 if (IS_DEBUG_OSPF_EVENT) {
996c9314
LB
1102 zlog_debug(
1103 "%s: ospf distribute-list update arg_type %d vrf %s id %d",
1104 __PRETTY_FUNCTION__, arg_type,
1105 ospf_vrf_id_to_name(ospf->vrf_id), ospf->vrf_id);
b5a8894d
CS
1106 }
1107
d62a17ae 1108 /* foreach all external info. */
1109 for (type = 0; type <= ZEBRA_ROUTE_MAX; type++) {
1110 struct list *ext_list;
1111 struct listnode *node;
1112 struct ospf_external *ext;
1113
de1ac5fd 1114 ext_list = ospf->external[type];
d62a17ae 1115 if (!ext_list)
1116 continue;
1117
1118 for (ALL_LIST_ELEMENTS_RO(ext_list, node, ext)) {
1119 rt = ext->external_info;
1120 if (!rt)
1121 continue;
1122 for (rn = route_top(rt); rn; rn = route_next(rn))
1123 if ((ei = rn->info) != NULL) {
1124 if (is_prefix_default(&ei->p))
1125 default_refresh = 1;
1126 else if (
1127 (lsa = ospf_external_info_find_lsa(
1128 ospf, &ei->p)))
1129 ospf_external_lsa_refresh(
1130 ospf, lsa, ei,
1131 LSA_REFRESH_IF_CHANGED);
1132 else
1133 ospf_external_lsa_originate(
1134 ospf, ei);
1135 }
1136 }
1137 }
1138 if (default_refresh)
1139 ospf_external_lsa_refresh_default(ospf);
b5a8894d
CS
1140
1141 XFREE(MTYPE_OSPF_DIST_ARGS, arg);
d62a17ae 1142 return 0;
718e3744 1143}
1144
718e3744 1145/* Update distribute-list and set timer to apply access-list. */
d7c0a89a
QY
1146void ospf_distribute_list_update(struct ospf *ospf, int type,
1147 unsigned short instance)
718e3744 1148{
d62a17ae 1149 struct route_table *rt;
1150 struct ospf_external *ext;
996c9314 1151 void **args = XCALLOC(MTYPE_OSPF_DIST_ARGS, sizeof(void *) * 2);
d62a17ae 1152
b5a8894d 1153 args[0] = ospf;
996c9314 1154 args[1] = (void *)((ptrdiff_t)type);
b5a8894d 1155
d62a17ae 1156 /* External info does not exist. */
de1ac5fd 1157 ext = ospf_external_lookup(ospf, type, instance);
a68730c6
DS
1158 if (!ext || !(rt = EXTERNAL_INFO(ext))) {
1159 XFREE(MTYPE_OSPF_DIST_ARGS, args);
d62a17ae 1160 return;
a68730c6 1161 }
d62a17ae 1162
1163 /* If exists previously invoked thread, then let it continue. */
a68730c6
DS
1164 if (ospf->t_distribute_update) {
1165 XFREE(MTYPE_OSPF_DIST_ARGS, args);
d62a17ae 1166 return;
a68730c6 1167 }
d62a17ae 1168
1169 /* Set timer. */
1170 ospf->t_distribute_update = NULL;
1171 thread_add_timer_msec(master, ospf_distribute_list_update_timer,
b5a8894d 1172 (void **)args, ospf->min_ls_interval,
d62a17ae 1173 &ospf->t_distribute_update);
718e3744 1174}
1175
1176/* If access-list is updated, apply some check. */
d62a17ae 1177static void ospf_filter_update(struct access_list *access)
718e3744 1178{
d62a17ae 1179 struct ospf *ospf;
1180 int type;
1181 int abr_inv = 0;
1182 struct ospf_area *area;
b5a8894d 1183 struct listnode *node, *n1;
d62a17ae 1184
1185 /* If OSPF instance does not exist, return right now. */
b5a8894d 1186 if (listcount(om->ospf) == 0)
d62a17ae 1187 return;
1188
b5a8894d 1189 /* Iterate all ospf [VRF] instances */
43b8d1d8 1190 for (ALL_LIST_ELEMENTS_RO(om->ospf, n1, ospf)) {
b5a8894d
CS
1191 /* Update distribute-list, and apply filter. */
1192 for (type = 0; type <= ZEBRA_ROUTE_MAX; type++) {
1193 struct list *red_list;
b5a8894d
CS
1194 struct ospf_redist *red;
1195
1196 red_list = ospf->redist[type];
1197 if (red_list)
996c9314
LB
1198 for (ALL_LIST_ELEMENTS_RO(red_list, node,
1199 red)) {
b5a8894d 1200 if (ROUTEMAP(red)) {
996c9314
LB
1201 /* if route-map is not NULL it
1202 * may be
b5a8894d
CS
1203 * using this access list */
1204 ospf_distribute_list_update(
996c9314
LB
1205 ospf, type,
1206 red->instance);
b5a8894d 1207 }
d62a17ae 1208 }
d62a17ae 1209
b5a8894d
CS
1210 /* There is place for route-map for default-information
1211 * (ZEBRA_ROUTE_MAX),
1212 * but no distribute list. */
1213 if (type == ZEBRA_ROUTE_MAX)
1214 break;
1215
1216 if (DISTRIBUTE_NAME(ospf, type)) {
1217 /* Keep old access-list for distribute-list. */
996c9314
LB
1218 struct access_list *old =
1219 DISTRIBUTE_LIST(ospf, type);
b5a8894d
CS
1220
1221 /* Update access-list for distribute-list. */
996c9314
LB
1222 DISTRIBUTE_LIST(ospf, type) =
1223 access_list_lookup(
1224 AFI_IP,
1225 DISTRIBUTE_NAME(ospf, type));
b5a8894d
CS
1226
1227 /* No update for this distribute type. */
996c9314
LB
1228 if (old == NULL
1229 && DISTRIBUTE_LIST(ospf, type) == NULL)
b5a8894d
CS
1230 continue;
1231
1232 /* Schedule distribute-list update timer. */
1233 if (DISTRIBUTE_LIST(ospf, type) == NULL
996c9314
LB
1234 || strcmp(DISTRIBUTE_NAME(ospf, type),
1235 access->name)
1236 == 0)
1237 ospf_distribute_list_update(ospf, type,
1238 0);
b5a8894d 1239 }
d62a17ae 1240 }
d62a17ae 1241
b5a8894d
CS
1242 /* Update Area access-list. */
1243 for (ALL_LIST_ELEMENTS_RO(ospf->areas, node, area)) {
1244 if (EXPORT_NAME(area)) {
1245 EXPORT_LIST(area) = NULL;
1246 abr_inv++;
1247 }
d62a17ae 1248
b5a8894d
CS
1249 if (IMPORT_NAME(area)) {
1250 IMPORT_LIST(area) = NULL;
1251 abr_inv++;
1252 }
d62a17ae 1253 }
d62a17ae 1254
b5a8894d
CS
1255 /* Schedule ABR tasks -- this will be changed -- takada. */
1256 if (IS_OSPF_ABR(ospf) && abr_inv)
1257 ospf_schedule_abr_task(ospf);
1258 }
718e3744 1259}
dd669bb0 1260
1261/* If prefix-list is updated, do some updates. */
d62a17ae 1262void ospf_prefix_list_update(struct prefix_list *plist)
dd669bb0 1263{
b5a8894d 1264 struct ospf *ospf = NULL;
d62a17ae 1265 int type;
1266 int abr_inv = 0;
1267 struct ospf_area *area;
b5a8894d 1268 struct listnode *node, *n1;
d62a17ae 1269
1270 /* If OSPF instatnce does not exist, return right now. */
b5a8894d 1271 if (listcount(om->ospf) == 0)
d62a17ae 1272 return;
1273
b5a8894d
CS
1274 /* Iterate all ospf [VRF] instances */
1275 for (ALL_LIST_ELEMENTS_RO(om->ospf, n1, ospf)) {
1276
1277 /* Update all route-maps which are used
1278 * as redistribution filters.
1279 * They might use prefix-list.
1280 */
1281 for (type = 0; type <= ZEBRA_ROUTE_MAX; type++) {
1282 struct list *red_list;
b5a8894d
CS
1283 struct ospf_redist *red;
1284
1285 red_list = ospf->redist[type];
1286 if (red_list) {
996c9314
LB
1287 for (ALL_LIST_ELEMENTS_RO(red_list, node,
1288 red)) {
b5a8894d
CS
1289 if (ROUTEMAP(red)) {
1290 /* if route-map is not NULL
1291 * it may be using
1292 * this prefix list */
1293 ospf_distribute_list_update(
1294 ospf, type,
1295 red->instance);
1296 }
d62a17ae 1297 }
1298 }
b5a8894d 1299 }
d62a17ae 1300
b5a8894d
CS
1301 /* Update area filter-lists. */
1302 for (ALL_LIST_ELEMENTS_RO(ospf->areas, node, area)) {
1303 /* Update filter-list in. */
1304 if (PREFIX_NAME_IN(area))
1305 if (strcmp(PREFIX_NAME_IN(area),
996c9314
LB
1306 prefix_list_name(plist))
1307 == 0) {
b5a8894d
CS
1308 PREFIX_LIST_IN(area) =
1309 prefix_list_lookup(
996c9314
LB
1310 AFI_IP,
1311 PREFIX_NAME_IN(area));
b5a8894d
CS
1312 abr_inv++;
1313 }
d62a17ae 1314
b5a8894d
CS
1315 /* Update filter-list out. */
1316 if (PREFIX_NAME_OUT(area))
1317 if (strcmp(PREFIX_NAME_OUT(area),
996c9314
LB
1318 prefix_list_name(plist))
1319 == 0) {
b5a8894d
CS
1320 PREFIX_LIST_IN(area) =
1321 prefix_list_lookup(
996c9314
LB
1322 AFI_IP,
1323 PREFIX_NAME_OUT(area));
b5a8894d
CS
1324 abr_inv++;
1325 }
1326 }
d62a17ae 1327
b5a8894d
CS
1328 /* Schedule ABR task. */
1329 if (IS_OSPF_ABR(ospf) && abr_inv)
1330 ospf_schedule_abr_task(ospf);
1331 }
dd669bb0 1332}
cf795c5d 1333
d62a17ae 1334static struct ospf_distance *ospf_distance_new(void)
718e3744 1335{
d62a17ae 1336 return XCALLOC(MTYPE_OSPF_DISTANCE, sizeof(struct ospf_distance));
718e3744 1337}
1338
d62a17ae 1339static void ospf_distance_free(struct ospf_distance *odistance)
718e3744 1340{
d62a17ae 1341 XFREE(MTYPE_OSPF_DISTANCE, odistance);
718e3744 1342}
1343
d62a17ae 1344int ospf_distance_set(struct vty *vty, struct ospf *ospf,
1345 const char *distance_str, const char *ip_str,
1346 const char *access_list_str)
718e3744 1347{
d62a17ae 1348 int ret;
1349 struct prefix_ipv4 p;
d7c0a89a 1350 uint8_t distance;
d62a17ae 1351 struct route_node *rn;
1352 struct ospf_distance *odistance;
1353
1354 ret = str2prefix_ipv4(ip_str, &p);
1355 if (ret == 0) {
1356 vty_out(vty, "Malformed prefix\n");
1357 return CMD_WARNING_CONFIG_FAILED;
1358 }
1359
1360 distance = atoi(distance_str);
1361
1362 /* Get OSPF distance node. */
1363 rn = route_node_get(ospf->distance_table, (struct prefix *)&p);
1364 if (rn->info) {
1365 odistance = rn->info;
1366 route_unlock_node(rn);
1367 } else {
1368 odistance = ospf_distance_new();
1369 rn->info = odistance;
1370 }
1371
1372 /* Set distance value. */
1373 odistance->distance = distance;
1374
1375 /* Reset access-list configuration. */
1376 if (odistance->access_list) {
1377 free(odistance->access_list);
1378 odistance->access_list = NULL;
1379 }
1380 if (access_list_str)
1381 odistance->access_list = strdup(access_list_str);
1382
1383 return CMD_SUCCESS;
718e3744 1384}
1385
d62a17ae 1386int ospf_distance_unset(struct vty *vty, struct ospf *ospf,
1387 const char *distance_str, const char *ip_str,
1388 char const *access_list_str)
718e3744 1389{
d62a17ae 1390 int ret;
1391 struct prefix_ipv4 p;
1392 struct route_node *rn;
1393 struct ospf_distance *odistance;
1394
1395 ret = str2prefix_ipv4(ip_str, &p);
1396 if (ret == 0) {
1397 vty_out(vty, "Malformed prefix\n");
1398 return CMD_WARNING_CONFIG_FAILED;
1399 }
1400
1401 rn = route_node_lookup(ospf->distance_table, (struct prefix *)&p);
1402 if (!rn) {
1403 vty_out(vty, "Can't find specified prefix\n");
1404 return CMD_WARNING_CONFIG_FAILED;
1405 }
1406
1407 odistance = rn->info;
1408
1409 if (odistance->access_list)
1410 free(odistance->access_list);
1411 ospf_distance_free(odistance);
1412
1413 rn->info = NULL;
1414 route_unlock_node(rn);
1415 route_unlock_node(rn);
1416
1417 return CMD_SUCCESS;
718e3744 1418}
1419
d62a17ae 1420void ospf_distance_reset(struct ospf *ospf)
718e3744 1421{
d62a17ae 1422 struct route_node *rn;
1423 struct ospf_distance *odistance;
1424
1425 for (rn = route_top(ospf->distance_table); rn; rn = route_next(rn))
1426 if ((odistance = rn->info) != NULL) {
1427 if (odistance->access_list)
1428 free(odistance->access_list);
1429 ospf_distance_free(odistance);
1430 rn->info = NULL;
1431 route_unlock_node(rn);
1432 }
718e3744 1433}
1434
d7c0a89a
QY
1435uint8_t ospf_distance_apply(struct ospf *ospf, struct prefix_ipv4 *p,
1436 struct ospf_route * or)
718e3744 1437{
718e3744 1438
d62a17ae 1439 if (ospf == NULL)
1440 return 0;
718e3744 1441
d62a17ae 1442 if (ospf->distance_intra)
1443 if (or->path_type == OSPF_PATH_INTRA_AREA)
1444 return ospf->distance_intra;
718e3744 1445
d62a17ae 1446 if (ospf->distance_inter)
1447 if (or->path_type == OSPF_PATH_INTER_AREA)
1448 return ospf->distance_inter;
718e3744 1449
d62a17ae 1450 if (ospf->distance_external)
1451 if (or->path_type == OSPF_PATH_TYPE1_EXTERNAL ||
1452 or->path_type == OSPF_PATH_TYPE2_EXTERNAL)
1453 return ospf->distance_external;
cf795c5d 1454
d62a17ae 1455 if (ospf->distance_all)
1456 return ospf->distance_all;
718e3744 1457
d62a17ae 1458 return 0;
718e3744 1459}
1460
b5a8894d
CS
1461void ospf_zebra_vrf_register(struct ospf *ospf)
1462{
1463 if (!zclient || zclient->sock < 0 || !ospf)
1464 return;
1465
6021c6c0 1466 if (ospf->vrf_id != VRF_UNKNOWN) {
b5a8894d
CS
1467 if (IS_DEBUG_OSPF_EVENT)
1468 zlog_debug("%s: Register VRF %s id %u",
1469 __PRETTY_FUNCTION__,
1470 ospf_vrf_id_to_name(ospf->vrf_id),
1471 ospf->vrf_id);
1472 zclient_send_reg_requests(zclient, ospf->vrf_id);
1473 }
1474}
1475
1476void ospf_zebra_vrf_deregister(struct ospf *ospf)
1477{
1478 if (!zclient || zclient->sock < 0 || !ospf)
1479 return;
1480
1481 if (ospf->vrf_id != VRF_DEFAULT && ospf->vrf_id != VRF_UNKNOWN) {
1482 if (IS_DEBUG_OSPF_EVENT)
6021c6c0 1483 zlog_debug("%s: De-Register VRF %s id %u to Zebra.",
b5a8894d
CS
1484 __PRETTY_FUNCTION__,
1485 ospf_vrf_id_to_name(ospf->vrf_id),
1486 ospf->vrf_id);
1487 /* Deregister for router-id, interfaces,
1488 * redistributed routes. */
1489 zclient_send_dereg_requests(zclient, ospf->vrf_id);
1490 }
1491}
d62a17ae 1492static void ospf_zebra_connected(struct zclient *zclient)
7076bb2f 1493{
d62a17ae 1494 /* Send the client registration */
1495 bfd_client_sendmsg(zclient, ZEBRA_BFD_CLIENT_REGISTER);
2376c3f2 1496
d62a17ae 1497 zclient_send_reg_requests(zclient, VRF_DEFAULT);
7076bb2f
FL
1498}
1499
d7c0a89a 1500void ospf_zebra_init(struct thread_master *master, unsigned short instance)
718e3744 1501{
d62a17ae 1502 /* Allocate zebra structure. */
e1a1880d 1503 zclient = zclient_new_notify(master, &zclient_options_default);
342213ea 1504 zclient_init(zclient, ZEBRA_ROUTE_OSPF, instance, &ospfd_privs);
d62a17ae 1505 zclient->zebra_connected = ospf_zebra_connected;
1506 zclient->router_id_update = ospf_router_id_update_zebra;
1507 zclient->interface_add = ospf_interface_add;
1508 zclient->interface_delete = ospf_interface_delete;
1509 zclient->interface_up = ospf_interface_state_up;
1510 zclient->interface_down = ospf_interface_state_down;
1511 zclient->interface_address_add = ospf_interface_address_add;
1512 zclient->interface_address_delete = ospf_interface_address_delete;
1513 zclient->interface_link_params = ospf_interface_link_params;
b5a8894d 1514 zclient->interface_vrf_update = ospf_interface_vrf_update;
d62a17ae 1515
74489921
RW
1516 zclient->redistribute_route_add = ospf_zebra_read_route;
1517 zclient->redistribute_route_del = ospf_zebra_read_route;
d62a17ae 1518
1519 access_list_add_hook(ospf_filter_update);
1520 access_list_delete_hook(ospf_filter_update);
1521 prefix_list_add_hook(ospf_prefix_list_update);
1522 prefix_list_delete_hook(ospf_prefix_list_update);
718e3744 1523}