3 * Copyright (C) 2008 Everton da Silva Marques
5 * This program is free software; you can redistribute it and/or modify
6 * it under the terms of the GNU General Public License as published by
7 * the Free Software Foundation; either version 2 of the License, or
8 * (at your option) any later version.
10 * This program is distributed in the hope that it will be useful, but
11 * WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 * General Public License for more details.
15 * You should have received a copy of the GNU General Public License along
16 * with this program; see the file COPYING; if not, write to the Free Software
17 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
21 #include "zebra/rib.h"
33 #include "pim_iface.h"
37 #include "pim_zlookup.h"
39 static struct zclient
*zlookup
= NULL
;
41 static void zclient_lookup_sched(struct zclient
*zlookup
, int delay
);
43 /* Connect to zebra for nexthop lookup. */
44 static int zclient_lookup_connect(struct thread
*t
)
46 struct zclient
*zlookup
;
48 zlookup
= THREAD_ARG(t
);
50 if (zlookup
->sock
>= 0) {
54 if (zclient_socket_connect(zlookup
) < 0) {
56 zlog_warn("%s: failure connecting zclient socket: failures=%d",
57 __PRETTY_FUNCTION__
, zlookup
->fail
);
59 zlookup
->fail
= 0; /* reset counter on connection */
62 if (zlookup
->sock
< 0) {
63 /* Since last connect failed, retry within 10 secs */
64 zclient_lookup_sched(zlookup
, 10);
71 /* Schedule connection with delay. */
72 static void zclient_lookup_sched(struct zclient
*zlookup
, int delay
)
74 thread_add_timer(master
, zclient_lookup_connect
, zlookup
, delay
,
77 zlog_notice("%s: zclient lookup connection scheduled for %d seconds",
78 __PRETTY_FUNCTION__
, delay
);
81 /* Schedule connection for now. */
82 static void zclient_lookup_sched_now(struct zclient
*zlookup
)
84 thread_add_event(master
, zclient_lookup_connect
, zlookup
, 0,
87 zlog_notice("%s: zclient lookup immediate connection scheduled",
91 /* Schedule reconnection, if needed. */
92 static void zclient_lookup_reconnect(struct zclient
*zlookup
)
94 if (zlookup
->t_connect
) {
98 zclient_lookup_sched_now(zlookup
);
101 static void zclient_lookup_failed(struct zclient
*zlookup
)
103 if (zlookup
->sock
>= 0) {
104 if (close(zlookup
->sock
)) {
105 zlog_warn("%s: closing fd=%d: errno=%d %s", __func__
,
106 zlookup
->sock
, errno
, safe_strerror(errno
));
111 zclient_lookup_reconnect(zlookup
);
114 void zclient_lookup_free(void)
116 zclient_stop(zlookup
);
117 zclient_free(zlookup
);
121 void zclient_lookup_new(void)
123 zlookup
= zclient_new(master
);
125 zlog_err("%s: zclient_new() failure", __PRETTY_FUNCTION__
);
130 zlookup
->t_connect
= NULL
;
132 zclient_lookup_sched_now(zlookup
);
134 zlog_notice("%s: zclient lookup socket initialized",
135 __PRETTY_FUNCTION__
);
138 static int zclient_read_nexthop(struct pim_instance
*pim
,
139 struct zclient
*zlookup
,
140 struct pim_zlookup_nexthop nexthop_tab
[],
141 const int tab_size
, struct in_addr addr
)
149 uint16_t command
= 0;
150 struct in_addr raddr
;
156 if (PIM_DEBUG_PIM_NHT_DETAIL
) {
157 char addr_str
[INET_ADDRSTRLEN
];
158 pim_inet4_dump("<addr?>", addr
, addr_str
, sizeof(addr_str
));
159 zlog_debug("%s: addr=%s(%s)", __PRETTY_FUNCTION__
, addr_str
,
165 while (command
!= ZEBRA_IPV4_NEXTHOP_LOOKUP_MRIB
) {
167 err
= zclient_read_header(s
, zlookup
->sock
, &length
, &marker
,
168 &version
, &vrf_id
, &command
);
170 zlog_err("%s: zclient_read_header() failed",
171 __PRETTY_FUNCTION__
);
172 zclient_lookup_failed(zlookup
);
177 raddr
.s_addr
= stream_get_ipv4(s
);
179 if (raddr
.s_addr
!= addr
.s_addr
) {
180 char addr_str
[INET_ADDRSTRLEN
];
181 char raddr_str
[INET_ADDRSTRLEN
];
182 pim_inet4_dump("<addr?>", addr
, addr_str
, sizeof(addr_str
));
183 pim_inet4_dump("<raddr?>", raddr
, raddr_str
, sizeof(raddr_str
));
184 zlog_warn("%s: address mismatch: addr=%s(%s) raddr=%s",
185 __PRETTY_FUNCTION__
, addr_str
, pim
->vrf
->name
,
190 distance
= stream_getc(s
);
191 metric
= stream_getl(s
);
192 nexthop_num
= stream_getc(s
);
194 if (nexthop_num
< 1) {
195 if (PIM_DEBUG_PIM_NHT_DETAIL
)
196 zlog_debug("%s: socket %d bad nexthop_num=%d", __func__
,
197 zlookup
->sock
, nexthop_num
);
201 for (i
= 0; i
< nexthop_num
; ++i
) {
202 enum nexthop_types_t nexthop_type
;
203 struct pim_neighbor
*nbr
;
206 nexthop_type
= stream_getc(s
);
207 if (num_ifindex
>= tab_size
) {
208 char addr_str
[INET_ADDRSTRLEN
];
209 pim_inet4_dump("<addr?>", addr
, addr_str
,
212 "%s: found too many nexthop ifindexes (%d > %d) for address %s(%s)",
213 __PRETTY_FUNCTION__
, (num_ifindex
+ 1),
214 tab_size
, addr_str
, pim
->vrf
->name
);
217 switch (nexthop_type
) {
218 case NEXTHOP_TYPE_IFINDEX
:
219 case NEXTHOP_TYPE_IPV4_IFINDEX
:
220 case NEXTHOP_TYPE_IPV4
:
221 nexthop_tab
[num_ifindex
].nexthop_addr
.family
= AF_INET
;
222 if (nexthop_type
== NEXTHOP_TYPE_IPV4_IFINDEX
223 || nexthop_type
== NEXTHOP_TYPE_IPV4
) {
224 nexthop_tab
[num_ifindex
]
225 .nexthop_addr
.u
.prefix4
.s_addr
=
228 nexthop_tab
[num_ifindex
]
229 .nexthop_addr
.u
.prefix4
.s_addr
=
232 nexthop_tab
[num_ifindex
].ifindex
= stream_getl(s
);
233 nexthop_tab
[num_ifindex
].protocol_distance
= distance
;
234 nexthop_tab
[num_ifindex
].route_metric
= metric
;
237 case NEXTHOP_TYPE_IPV6_IFINDEX
:
238 nexthop_tab
[num_ifindex
].nexthop_addr
.family
= AF_INET6
;
239 stream_get(&nexthop_tab
[num_ifindex
]
240 .nexthop_addr
.u
.prefix6
,
241 s
, sizeof(struct in6_addr
));
242 nexthop_tab
[num_ifindex
].ifindex
= stream_getl(s
);
245 p
.prefixlen
= IPV6_MAX_PREFIXLEN
;
247 &nexthop_tab
[num_ifindex
].nexthop_addr
.u
.prefix6
,
248 sizeof(struct in6_addr
));
251 * If we are sending v6 secondary assume we receive v6
254 if (pim
->send_v6_secondary
)
255 nbr
= pim_neighbor_find_by_secondary(
257 nexthop_tab
[num_ifindex
]
262 nbr
= pim_neighbor_find_if(if_lookup_by_index(
263 nexthop_tab
[num_ifindex
].ifindex
,
266 nexthop_tab
[num_ifindex
].nexthop_addr
.family
=
268 nexthop_tab
[num_ifindex
]
269 .nexthop_addr
.u
.prefix4
=
277 char addr_str
[INET_ADDRSTRLEN
];
278 pim_inet4_dump("<addr?>", addr
, addr_str
,
281 "%s: found non-ifindex nexthop type=%d for address %s(%s)",
282 __PRETTY_FUNCTION__
, nexthop_type
,
283 addr_str
, pim
->vrf
->name
);
292 static int zclient_lookup_nexthop_once(struct pim_instance
*pim
,
293 struct pim_zlookup_nexthop nexthop_tab
[],
294 const int tab_size
, struct in_addr addr
)
299 if (PIM_DEBUG_PIM_NHT_DETAIL
) {
300 char addr_str
[INET_ADDRSTRLEN
];
301 pim_inet4_dump("<addr?>", addr
, addr_str
, sizeof(addr_str
));
302 zlog_debug("%s: addr=%s(%s)", __PRETTY_FUNCTION__
, addr_str
,
307 if (zlookup
->sock
< 0) {
308 zlog_err("%s: zclient lookup socket is not connected",
309 __PRETTY_FUNCTION__
);
310 zclient_lookup_failed(zlookup
);
314 if (pim
->vrf
->vrf_id
== VRF_UNKNOWN
) {
316 "%s: VRF: %s does not fully exist yet, delaying lookup",
317 __PRETTY_FUNCTION__
, pim
->vrf
->name
);
323 zclient_create_header(s
, ZEBRA_IPV4_NEXTHOP_LOOKUP_MRIB
, pim
->vrf_id
);
324 stream_put_in_addr(s
, &addr
);
325 stream_putw_at(s
, 0, stream_get_endp(s
));
327 ret
= writen(zlookup
->sock
, s
->data
, stream_get_endp(s
));
330 "%s: writen() failure: %d writing to zclient lookup socket",
331 __PRETTY_FUNCTION__
, errno
);
332 zclient_lookup_failed(zlookup
);
336 zlog_err("%s: connection closed on zclient lookup socket",
337 __PRETTY_FUNCTION__
);
338 zclient_lookup_failed(zlookup
);
342 return zclient_read_nexthop(pim
, zlookup
, nexthop_tab
, tab_size
, addr
);
345 int zclient_lookup_nexthop(struct pim_instance
*pim
,
346 struct pim_zlookup_nexthop nexthop_tab
[],
347 const int tab_size
, struct in_addr addr
,
351 uint32_t route_metric
= 0xFFFFFFFF;
352 uint8_t protocol_distance
= 0xFF;
354 qpim_nexthop_lookups
++;
356 for (lookup
= 0; lookup
< max_lookup
; ++lookup
) {
359 struct prefix nexthop_addr
;
361 num_ifindex
= zclient_lookup_nexthop_once(pim
, nexthop_tab
,
363 if (num_ifindex
< 1) {
364 if (PIM_DEBUG_PIM_NHT
) {
365 char addr_str
[INET_ADDRSTRLEN
];
366 pim_inet4_dump("<addr?>", addr
, addr_str
,
369 "%s: lookup=%d/%d: could not find nexthop ifindex for address %s(%s)",
370 __PRETTY_FUNCTION__
, lookup
, max_lookup
,
371 addr_str
, pim
->vrf
->name
);
377 /* this is the non-recursive lookup - save original
379 route_metric
= nexthop_tab
[0].route_metric
;
380 protocol_distance
= nexthop_tab
[0].protocol_distance
;
384 * FIXME: Non-recursive nexthop ensured only for first ifindex.
385 * However, recursive route lookup should really be fixed in
389 * So Zebra for NEXTHOP_TYPE_IPV4 returns the ifindex now since
390 * it was being stored. This Doesn't solve all cases of
391 * recursive lookup but for the most common types it does.
393 first_ifindex
= nexthop_tab
[0].ifindex
;
394 nexthop_addr
= nexthop_tab
[0].nexthop_addr
;
395 if (first_ifindex
> 0) {
396 /* found: first ifindex is non-recursive nexthop */
399 /* Report non-recursive success after first
401 if (PIM_DEBUG_PIM_NHT
) {
402 char addr_str
[INET_ADDRSTRLEN
];
403 pim_inet4_dump("<addr?>", addr
,
407 "%s: lookup=%d/%d: found non-recursive ifindex=%d for address %s(%s) dist=%d met=%d",
408 __PRETTY_FUNCTION__
, lookup
,
409 max_lookup
, first_ifindex
,
410 addr_str
, pim
->vrf
->name
,
413 nexthop_tab
[0].route_metric
);
416 /* use last address as nexthop address */
417 nexthop_tab
[0].nexthop_addr
.u
.prefix4
= addr
;
419 /* report original route metric/distance */
420 nexthop_tab
[0].route_metric
= route_metric
;
421 nexthop_tab
[0].protocol_distance
=
428 if (PIM_DEBUG_PIM_NHT
) {
429 char addr_str
[INET_ADDRSTRLEN
];
430 char nexthop_str
[PREFIX_STRLEN
];
431 pim_inet4_dump("<addr?>", addr
, addr_str
,
433 pim_addr_dump("<nexthop?>", &nexthop_addr
, nexthop_str
,
434 sizeof(nexthop_str
));
436 "%s: lookup=%d/%d: zebra returned recursive nexthop %s for address %s(%s) dist=%d met=%d",
437 __PRETTY_FUNCTION__
, lookup
, max_lookup
,
438 nexthop_str
, addr_str
, pim
->vrf
->name
,
439 nexthop_tab
[0].protocol_distance
,
440 nexthop_tab
[0].route_metric
);
444 nexthop_addr
.u
.prefix4
; /* use nexthop addr for
447 } /* for (max_lookup) */
449 if (PIM_DEBUG_PIM_NHT
) {
450 char addr_str
[INET_ADDRSTRLEN
];
451 pim_inet4_dump("<addr?>", addr
, addr_str
, sizeof(addr_str
));
453 "%s: lookup=%d/%d: failure searching recursive nexthop ifindex for address %s(%s)",
454 __PRETTY_FUNCTION__
, lookup
, max_lookup
, addr_str
,
461 void pim_zlookup_show_ip_multicast(struct vty
*vty
)
463 vty_out(vty
, "Zclient lookup socket: ");
465 vty_out(vty
, "%d failures=%d\n", zlookup
->sock
, zlookup
->fail
);
467 vty_out(vty
, "<null zclient>\n");
471 int pim_zlookup_sg_statistics(struct channel_oil
*c_oil
)
473 struct stream
*s
= zlookup
->obuf
;
474 uint16_t command
= 0;
475 unsigned long long lastused
;
479 struct interface
*ifp
=
480 pim_if_find_by_vif_index(c_oil
->pim
, c_oil
->oil
.mfcc_parent
);
482 if (PIM_DEBUG_ZEBRA
) {
483 struct prefix_sg more
;
485 more
.src
= c_oil
->oil
.mfcc_origin
;
486 more
.grp
= c_oil
->oil
.mfcc_mcastgrp
;
488 "Sending Request for New Channel Oil Information(%s) VIIF %d(%s)",
489 pim_str_sg_dump(&more
), c_oil
->oil
.mfcc_parent
,
490 c_oil
->pim
->vrf
->name
);
497 zclient_create_header(s
, ZEBRA_IPMR_ROUTE_STATS
, c_oil
->pim
->vrf_id
);
498 stream_put_in_addr(s
, &c_oil
->oil
.mfcc_origin
);
499 stream_put_in_addr(s
, &c_oil
->oil
.mfcc_mcastgrp
);
500 stream_putl(s
, ifp
->ifindex
);
501 stream_putw_at(s
, 0, stream_get_endp(s
));
503 count
= stream_get_endp(s
);
504 ret
= writen(zlookup
->sock
, s
->data
, count
);
507 "%s: writen() failure: %d writing to zclient lookup socket",
508 __PRETTY_FUNCTION__
, errno
);
514 while (command
!= ZEBRA_IPMR_ROUTE_STATS
) {
522 err
= zclient_read_header(s
, zlookup
->sock
, &length
, &marker
,
523 &version
, &vrf_id
, &command
);
525 zlog_err("%s: zclient_read_header() failed",
526 __PRETTY_FUNCTION__
);
527 zclient_lookup_failed(zlookup
);
532 sg
.src
.s_addr
= stream_get_ipv4(s
);
533 sg
.grp
.s_addr
= stream_get_ipv4(s
);
534 if (sg
.src
.s_addr
!= c_oil
->oil
.mfcc_origin
.s_addr
535 || sg
.grp
.s_addr
!= c_oil
->oil
.mfcc_mcastgrp
.s_addr
) {
536 if (PIM_DEBUG_ZEBRA
) {
537 struct prefix_sg more
;
539 more
.src
= c_oil
->oil
.mfcc_origin
;
540 more
.grp
= c_oil
->oil
.mfcc_mcastgrp
;
542 "%s: Received wrong %s(%s) information requested",
543 __PRETTY_FUNCTION__
, pim_str_sg_dump(&more
),
544 c_oil
->pim
->vrf
->name
);
546 zclient_lookup_failed(zlookup
);
550 stream_get(&lastused
, s
, sizeof(lastused
));
553 c_oil
->cc
.lastused
= lastused
;