proxmox-mirrors/mirror_frr
1
0
Fork 0
mirror of https://git.proxmox.com/git/mirror_frr synced 2025-04-28 21:20:48 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

lib: do not reopen a zclient socket for bfd

Browse Source 
b7ca809d1c ("lib: BFD automatic source selection") has added a dedicated
zclient socket for nht tracking. Since the bfd lib is used by daemons
that already has a zclient socket, those daemons has now a second
zclient socket. However, zebra does not distinguish the two zclient
sessions. For example, the interfaces are asked a second via
zebra_message_send(zclient, ZEBRA_INTERFACE_ADD, VRF_DEFAULT) in
zclient_start(). As a result, callbacks functions like bgp_ifp_create()
are called a second time, which causes some processing overhead and
might cause bugs.

Re-use the existing zclient socket for nht tracking.

Note that BFD automatic source selection is only currently implemented
in staticd. Other daemons will require to add the following in their
ZEBRA_NEXTHOP_UPDATE callback function:

> 	if (zclient->bfd_integration)
>		bfd_nht_update(&matched, &nhr);

Fixes: b7ca809d1c ("lib: BFD automatic source selection")
Signed-off-by: Louis Scalbert <louis.scalbert@6wind.com>
This commit is contained in:
Louis Scalbert 2023-01-23 11:57:57 +01:00
parent 1983a80dd6
commit a77ea81ef3
3 changed files with 23 additions and 64 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

73
lib/bfd.c
View File

@ -129,8 +129,6 @@ struct bfd_sessions_global {
struct thread_master *tm;
/** Pointer to zebra client data structure. */
struct zclient *zc;
/** Zebra next hop tracking (NHT) client. */
struct zclient *nht_zclient;
/** Debugging state. */
bool debugging;
@ -147,10 +145,6 @@ static const struct in6_addr i6a_zero;
/*
* Prototypes
*/
static void bfd_nht_zclient_connect(struct thread *thread);
static void bfd_nht_zclient_connected(struct zclient *zclient);
static int bfd_nht_update(ZAPI_CALLBACK_ARGS);
static void bfd_source_cache_get(struct bfd_session_params *session);
static void bfd_source_cache_put(struct bfd_session_params *session);
@ -158,15 +152,14 @@ static void bfd_source_cache_put(struct bfd_session_params *session);
static inline void
bfd_source_cache_register(const struct bfd_source_cache *source)
{
zclient_send_rnh(bsglobal.nht_zclient, ZEBRA_NEXTHOP_REGISTER,
&source->address, SAFI_UNICAST, false, false,
source->vrf_id);
zclient_send_rnh(bsglobal.zc, ZEBRA_NEXTHOP_REGISTER, &source->address,
SAFI_UNICAST, false, false, source->vrf_id);
}
static inline void
bfd_source_cache_unregister(const struct bfd_source_cache *source)
{
zclient_send_rnh(bsglobal.nht_zclient, ZEBRA_NEXTHOP_UNREGISTER,
zclient_send_rnh(bsglobal.zc, ZEBRA_NEXTHOP_UNREGISTER,
&source->address, SAFI_UNICAST, false, false,
source->vrf_id);
}
@ -1074,20 +1067,11 @@ static int bfd_protocol_integration_finish(void)
if (!SLIST_EMPTY(&bsglobal.source_list))
zlog_warn("BFD integration source cache not empty");
zclient_stop(bsglobal.nht_zclient);
zclient_free(bsglobal.nht_zclient);
return 0;
}
static zclient_handler *const bfd_nht_handlers[] = {
[ZEBRA_NEXTHOP_UPDATE] = bfd_nht_update,
};
void bfd_protocol_integration_init(struct zclient *zc, struct thread_master *tm)
{
struct zclient_options bfd_nht_options = zclient_options_default;
/* Initialize data structure. */
TAILQ_INIT(&bsglobal.bsplist);
SLIST_INIT(&bsglobal.source_list);
@ -1102,16 +1086,6 @@ void bfd_protocol_integration_init(struct zclient *zc, struct thread_master *tm)
/* Send the client registration */
bfd_client_sendmsg(zc, ZEBRA_BFD_CLIENT_REGISTER, VRF_DEFAULT);
/* Start NHT client (for automatic source decisions). */
bsglobal.nht_zclient =
zclient_new(tm, &bfd_nht_options, bfd_nht_handlers,
array_size(bfd_nht_handlers));
bsglobal.nht_zclient->sock = -1;
bsglobal.nht_zclient->privs = zc->privs;
bsglobal.nht_zclient->zebra_connected = bfd_nht_zclient_connected;
thread_add_timer(tm, bfd_nht_zclient_connect, bsglobal.nht_zclient, 1,
&bsglobal.nht_zclient->t_connect);
hook_register(frr_fini, bfd_protocol_integration_finish);
}
@ -1378,27 +1352,7 @@ static bool bfd_source_cache_update(struct bfd_source_cache *source,
return false;
}
static void bfd_nht_zclient_connect(struct thread *thread)
{
struct zclient *zclient = THREAD_ARG(thread);
if (bsglobal.debugging)
zlog_debug("BFD NHT zclient connection attempt");
if (zclient_start(zclient) == -1) {
if (bsglobal.debugging)
zlog_debug("BFD NHT zclient connection failed");
thread_add_timer(bsglobal.tm, bfd_nht_zclient_connect, zclient,
3, &zclient->t_connect);
return;
}
if (bsglobal.debugging)
zlog_debug("BFD NHT zclient connection succeeded");
}
static void bfd_nht_zclient_connected(struct zclient *zclient)
void bfd_nht_zclient_connected(struct zclient *zclient)
{
struct bfd_source_cache *source;
@ -1409,28 +1363,19 @@ static void bfd_nht_zclient_connected(struct zclient *zclient)
bfd_source_cache_register(source);
}
static int bfd_nht_update(ZAPI_CALLBACK_ARGS)
int bfd_nht_update(const struct prefix *match, const struct zapi_route *route)
{
struct bfd_source_cache *source;
struct zapi_route route;
struct prefix match;
if (!zapi_nexthop_update_decode(zclient->ibuf, &match, &route)) {
zlog_warn("BFD NHT update decode failure");
return 0;
}
if (cmd != ZEBRA_NEXTHOP_UPDATE)
return 0;
if (bsglobal.debugging)
zlog_debug("BFD NHT update for %pFX", &route.prefix);
zlog_debug("BFD NHT update for %pFX", &route->prefix);
SLIST_FOREACH (source, &bsglobal.source_list, entry) {
if (source->vrf_id != route.vrf_id)
if (source->vrf_id != route->vrf_id)
continue;
if (!prefix_same(&match, &source->address))
if (!prefix_same(match, &source->address))
continue;
if (bfd_source_cache_update(source, &route))
if (bfd_source_cache_update(source, route))
bfd_source_cache_update_sessions(source);
}

9
lib/bfd.h
View File

@ -473,6 +473,15 @@ extern bool bfd_protocol_integration_debug(void);
*/
extern bool bfd_protocol_integration_shutting_down(void);
extern void bfd_nht_zclient_connected(struct zclient *zclient);
/* Update nexthop-tracking (nht) information for BFD auto source selection.
* The function must be called from the daemon callback function
* that deals with the ZEBRA_NEXTHOP_UPDATE zclient command
*/
extern int bfd_nht_update(const struct prefix *match,
const struct zapi_route *route);
#ifdef __cplusplus
}
#endif

5
staticd/static_zebra.c
View File

@ -182,6 +182,8 @@ static void zebra_connected(struct zclient *zclient)
zclient_send_reg_requests(zclient, VRF_DEFAULT);
static_fixup_vrf_ids(vrf_info_lookup(VRF_DEFAULT));
bfd_nht_zclient_connected(zclient);
}
/* API to check whether the configured nexthop address is
@ -211,6 +213,9 @@ static int static_zebra_nexthop_update(ZAPI_CALLBACK_ARGS)
return 1;
}
if (zclient->bfd_integration)
bfd_nht_update(&matched, &nhr);
if (matched.family == AF_INET6)
afi = AFI_IP6;