matthieu/frr
1
0
Fork 0
forked from Mirror/frr
Code Pull requests Activity

bgpd: add sync for monitored afi/safi of imported bgps

Browse source 
If an imported BGP is configured after BGP updates have been
received, then BMP will not detect those updates in the
monitor messages.

Syncronisation is also needed for separate instances.
For each imported bgp instance, syncronisation is re-done
for monitored afi/safis for ALL available instances.
- upon configuring an afi/safi (as previously)
- when configuring an imported view

Signed-off-by: Philippe Guibert <philippe.guibert@6wind.com>
This commit is contained in:
Philippe Guibert 2024-11-11 22:24:57 +01:00
parent d34fe66a5d
commit b79574b5c6
2 changed files with 142 additions and 33 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

170
bgpd/bgp_bmp.c
View file

@ -246,6 +246,7 @@ static struct bmp *bmp_new(struct bmp_targets *bt, int bmp_sock)
new->targets = bt; new->targets = bt;
new->socket = bmp_sock; new->socket = bmp_sock;
new->syncafi = AFI_MAX; new->syncafi = AFI_MAX;
new->sync_bgp = NULL;
FOREACH_AFI_SAFI (afi, safi) { FOREACH_AFI_SAFI (afi, safi) {
new->afistate[afi][safi] = bt->afimon[afi][safi] new->afistate[afi][safi] = bt->afimon[afi][safi]
@ -1240,17 +1241,91 @@ static void bmp_monitor(struct bmp *bmp, struct peer *peer, uint8_t flags,
stream_free(msg); stream_free(msg);
} }
static struct bgp *bmp_get_next_bgp(struct bmp_targets *bt, struct bgp *bgp, afi_t afi, safi_t safi)
{
struct bmp_imported_bgp *bib;
struct bgp *bgp_inst;
bool get_first = false;
if (bgp == NULL && bt->bgp_request_sync[afi][safi])
return bt->bgp;
if (bgp == NULL)
get_first = true;
frr_each (bmp_imported_bgps, &bt->imported_bgps, bib) {
bgp_inst = bgp_lookup_by_name(bib->name);
if (get_first && bgp_inst && bib->bgp_request_sync[afi][safi])
return bgp_inst;
if (bgp_inst == bgp)
get_first = true;
}
return NULL;
}
static void bmp_update_syncro(struct bmp *bmp, afi_t afi, safi_t safi, struct bgp *bgp)
{
struct bmp_imported_bgp *bib;
if (bmp->syncafi == afi && bmp->syncsafi == safi) {
bmp->syncafi = AFI_MAX;
bmp->syncsafi = SAFI_MAX;
bmp->sync_bgp = NULL;
}
if (!bmp->targets->afimon[afi][safi]) {
bmp->afistate[afi][safi] = BMP_AFI_INACTIVE;
return;
}
bmp->afistate[afi][safi] = BMP_AFI_NEEDSYNC;
if (bgp == NULL || bmp->targets->bgp == bgp)
bmp->targets->bgp_request_sync[afi][safi] = true;
frr_each (bmp_imported_bgps, &bmp->targets->imported_bgps, bib) {
if (bgp != NULL && bgp_lookup_by_name(bib->name) != bgp)
continue;
bib->bgp_request_sync[afi][safi] = true;
}
}
static void bmp_update_syncro_set(struct bmp *bmp, afi_t afi, safi_t safi, struct bgp *bgp,
enum bmp_afi_state state)
{
struct bmp_imported_bgp *bib;
bmp->afistate[afi][safi] = state;
bmp->syncafi = AFI_MAX;
bmp->syncsafi = SAFI_MAX;
if (bgp == NULL || bmp->targets->bgp == bmp->sync_bgp)
bmp->targets->bgp_request_sync[afi][safi] = false;
frr_each (bmp_imported_bgps, &bmp->targets->imported_bgps, bib) {
if (bgp == NULL || bgp_lookup_by_name(bib->name) != bmp->sync_bgp)
continue;
bib->bgp_request_sync[afi][safi] = false;
}
}
static void bmp_eor_afi_safi(struct bmp *bmp, afi_t afi, safi_t safi, uint8_t peer_type_flag) static void bmp_eor_afi_safi(struct bmp *bmp, afi_t afi, safi_t safi, uint8_t peer_type_flag)
{ {
zlog_info("bmp[%s] %s %s table completed (EoR)", bmp->remote, afi2str(afi), safi2str(safi)); struct bgp *sync_bgp;
zlog_info("bmp[%s] %s %s table completed (EoR) (BGP %s)", bmp->remote, afi2str(afi),
safi2str(safi), bmp->sync_bgp->name_pretty);
bmp_eor(bmp, afi, safi, BMP_PEER_FLAG_L, peer_type_flag); bmp_eor(bmp, afi, safi, BMP_PEER_FLAG_L, peer_type_flag);
bmp_eor(bmp, afi, safi, 0, peer_type_flag); bmp_eor(bmp, afi, safi, 0, peer_type_flag);
bmp_eor(bmp, afi, safi, 0, BMP_PEER_TYPE_LOC_RIB_INSTANCE); bmp_eor(bmp, afi, safi, 0, BMP_PEER_TYPE_LOC_RIB_INSTANCE);
bmp->afistate[afi][safi] = BMP_AFI_LIVE; sync_bgp = bmp_get_next_bgp(bmp->targets, bmp->sync_bgp, afi, safi);
bmp->syncafi = AFI_MAX; if (sync_bgp) {
bmp->syncsafi = SAFI_MAX; memset(&bmp->syncpos, 0, sizeof(bmp->syncpos));
bmp->syncpos.family = afi2family(afi);
bmp->syncrdpos = NULL;
bmp->syncpeerid = 0;
} else
bmp_update_syncro_set(bmp, afi, safi, bmp->sync_bgp, BMP_AFI_LIVE);
bmp->sync_bgp = sync_bgp;
} }
static bool bmp_wrsync(struct bmp *bmp, struct pullwr *pullwr) static bool bmp_wrsync(struct bmp *bmp, struct pullwr *pullwr)
@ -1273,10 +1348,13 @@ static bool bmp_wrsync(struct bmp *bmp, struct pullwr *pullwr)
memset(&bmp->syncpos, 0, sizeof(bmp->syncpos)); memset(&bmp->syncpos, 0, sizeof(bmp->syncpos));
bmp->syncpos.family = afi2family(afi); bmp->syncpos.family = afi2family(afi);
bmp->syncrdpos = NULL; bmp->syncrdpos = NULL;
zlog_info("bmp[%s] %s %s sending table", bmp->sync_bgp = bmp_get_next_bgp(bmp->targets, NULL, afi, safi);
bmp->remote, if (bmp->sync_bgp == NULL)
afi2str(bmp->syncafi), /* all BGP instances already synced*/
safi2str(bmp->syncsafi)); return true;
zlog_info("bmp[%s] %s %s sending table (BGP %s)", bmp->remote,
afi2str(bmp->syncafi), safi2str(bmp->syncsafi),
bmp->sync_bgp->name_pretty);
/* break does not work here, 2 loops... */ /* break does not work here, 2 loops... */
goto afibreak; goto afibreak;
} }
@ -1290,18 +1368,22 @@ afibreak:
if (!bmp->targets->afimon[afi][safi]) { if (!bmp->targets->afimon[afi][safi]) {
/* shouldn't happen */ /* shouldn't happen */
bmp->afistate[afi][safi] = BMP_AFI_INACTIVE; bmp_update_syncro_set(bmp, afi, safi, bmp->sync_bgp, BMP_AFI_INACTIVE);
bmp->syncafi = AFI_MAX; bmp->sync_bgp = NULL;
bmp->syncsafi = SAFI_MAX; return true;
}
if (bmp->sync_bgp == NULL) {
bmp->sync_bgp = bmp_get_next_bgp(bmp->targets, NULL, afi, safi);
if (bmp->sync_bgp == NULL)
return true; return true;
} }
struct bgp_table *table = bmp->targets->bgp->rib[afi][safi]; struct bgp_table *table = bmp->sync_bgp->rib[afi][safi];
struct bgp_dest *bn = NULL; struct bgp_dest *bn = NULL;
struct bgp_path_info *bpi = NULL, *bpiter; struct bgp_path_info *bpi = NULL, *bpiter;
struct bgp_adj_in *adjin = NULL, *adjiter; struct bgp_adj_in *adjin = NULL, *adjiter;
peer_type_flag = bmp_get_peer_type_vrf(bmp->targets->bgp->vrf_id); peer_type_flag = bmp_get_peer_type_vrf(bmp->sync_bgp->vrf_id);
if ((afi == AFI_L2VPN && safi == SAFI_EVPN) || if ((afi == AFI_L2VPN && safi == SAFI_EVPN) ||
(safi == SAFI_MPLS_VPN)) { (safi == SAFI_MPLS_VPN)) {
@ -1671,11 +1753,16 @@ out:
static void bmp_wrfill(struct bmp *bmp, struct pullwr *pullwr) static void bmp_wrfill(struct bmp *bmp, struct pullwr *pullwr)
{ {
afi_t afi;
safi_t safi;
switch(bmp->state) { switch(bmp->state) {
case BMP_PeerUp: case BMP_PeerUp:
bmp_send_peerup_vrf(bmp); bmp_send_peerup_vrf(bmp);
bmp_send_peerup(bmp); bmp_send_peerup(bmp);
bmp->state = BMP_Run; bmp->state = BMP_Run;
FOREACH_AFI_SAFI (afi, safi)
bmp_update_syncro(bmp, afi, safi, NULL);
break; break;
case BMP_Run: case BMP_Run:
@ -2234,6 +2321,8 @@ static struct bmp_targets *bmp_targets_find1(struct bgp *bgp, const char *name)
static struct bmp_targets *bmp_targets_get(struct bgp *bgp, const char *name) static struct bmp_targets *bmp_targets_get(struct bgp *bgp, const char *name)
{ {
struct bmp_targets *bt; struct bmp_targets *bt;
afi_t afi;
safi_t safi;
bt = bmp_targets_find1(bgp, name); bt = bmp_targets_find1(bgp, name);
if (bt) if (bt)
@ -2244,6 +2333,8 @@ static struct bmp_targets *bmp_targets_get(struct bgp *bgp, const char *name)
bt->bgp = bgp; bt->bgp = bgp;
bt->bmpbgp = bmp_bgp_get(bgp); bt->bmpbgp = bmp_bgp_get(bgp);
bt->stats_send_experimental = true; bt->stats_send_experimental = true;
FOREACH_AFI_SAFI (afi, safi)
bt->bgp_request_sync[afi][safi] = false;
bmp_session_init(&bt->sessions); bmp_session_init(&bt->sessions);
bmp_qhash_init(&bt->updhash); bmp_qhash_init(&bt->updhash);
bmp_qlist_init(&bt->updlist); bmp_qlist_init(&bt->updlist);
@ -2378,6 +2469,8 @@ static void bmp_imported_bgp_put(struct bmp_targets *bt, struct bmp_imported_bgp
static struct bmp_imported_bgp *bmp_imported_bgp_get(struct bmp_targets *bt, char *name) static struct bmp_imported_bgp *bmp_imported_bgp_get(struct bmp_targets *bt, char *name)
{ {
struct bmp_imported_bgp *bib = bmp_imported_bgp_find(bt, name); struct bmp_imported_bgp *bib = bmp_imported_bgp_find(bt, name);
afi_t afi;
safi_t safi;
if (bib) if (bib)
return bib; return bib;
@ -2386,6 +2479,9 @@ static struct bmp_imported_bgp *bmp_imported_bgp_get(struct bmp_targets *bt, cha
if (name) if (name)
bib->name = XSTRDUP(MTYPE_BMP_IMPORTED_BGP, name); bib->name = XSTRDUP(MTYPE_BMP_IMPORTED_BGP, name);
bib->vrf_state = vrf_state_unknown; bib->vrf_state = vrf_state_unknown;
FOREACH_AFI_SAFI (afi, safi)
bib->bgp_request_sync[afi][safi] = false;
bib->targets = bt; bib->targets = bt;
bmp_imported_bgps_add(&bt->imported_bgps, bib); bmp_imported_bgps_add(&bt->imported_bgps, bib);
@ -2764,6 +2860,8 @@ DEFPY(bmp_import_vrf,
struct bmp_imported_bgp *bib; struct bmp_imported_bgp *bib;
struct bgp *bgp; struct bgp *bgp;
struct bmp *bmp; struct bmp *bmp;
afi_t afi;
safi_t safi;
if (!bt->bgp) { if (!bt->bgp) {
vty_out(vty, "%% BMP target, BGP instance not found\n"); vty_out(vty, "%% BMP target, BGP instance not found\n");
@ -2795,13 +2893,14 @@ DEFPY(bmp_import_vrf,
bgp = bgp_lookup_by_name(bib->name); bgp = bgp_lookup_by_name(bib->name);
if (!bgp) if (!bgp)
return CMD_SUCCESS; return CMD_SUCCESS;
/* TODO: Start the syncronisation
*/
frr_each (bmp_session, &bt->sessions, bmp) { frr_each (bmp_session, &bt->sessions, bmp) {
if (bmp->state != BMP_PeerUp && bmp->state != BMP_Run) if (bmp->state != BMP_PeerUp && bmp->state != BMP_Run)
continue; continue;
bmp_send_peerup_per_instance(bmp, bgp); bmp_send_peerup_per_instance(bmp, bgp);
bmp_send_peerup_vrf_per_instance(bmp, &bib->vrf_state, bgp); bmp_send_peerup_vrf_per_instance(bmp, &bib->vrf_state, bgp);
FOREACH_AFI_SAFI (afi, safi)
bmp_update_syncro(bmp, afi, safi, bgp);
} }
return CMD_SUCCESS; return CMD_SUCCESS;
} }
@ -3008,19 +3107,8 @@ DEFPY(bmp_monitor_cfg, bmp_monitor_cmd,
if (prev == bt->afimon[afi][safi]) if (prev == bt->afimon[afi][safi])
return CMD_SUCCESS; return CMD_SUCCESS;
frr_each (bmp_session, &bt->sessions, bmp) { frr_each (bmp_session, &bt->sessions, bmp)
if (bmp->syncafi == afi && bmp->syncsafi == safi) { bmp_update_syncro(bmp, afi, safi, NULL);
bmp->syncafi = AFI_MAX;
bmp->syncsafi = SAFI_MAX;
}
if (!bt->afimon[afi][safi]) {
bmp->afistate[afi][safi] = BMP_AFI_INACTIVE;
continue;
}
bmp->afistate[afi][safi] = BMP_AFI_NEEDSYNC;
}
return CMD_SUCCESS; return CMD_SUCCESS;
} }
@ -3448,6 +3536,8 @@ static int bmp_bgp_attribute_updated(struct bgp *bgp, bool withdraw)
int ret = 0; int ret = 0;
struct stream *s = bmp_peerstate(bgp->peer_self, withdraw); struct stream *s = bmp_peerstate(bgp->peer_self, withdraw);
struct bmp *bmp; struct bmp *bmp;
afi_t afi;
safi_t safi;
if (!s) if (!s)
return 0; return 0;
@ -3458,8 +3548,11 @@ static int bmp_bgp_attribute_updated(struct bgp *bgp, bool withdraw)
withdraw, s); withdraw, s);
if (withdraw) if (withdraw)
continue; continue;
frr_each (bmp_session, &bt->sessions, bmp) frr_each (bmp_session, &bt->sessions, bmp) {
bmp_send_peerup_per_instance(bmp, bgp); bmp_send_peerup_per_instance(bmp, bgp);
FOREACH_AFI_SAFI (afi, safi)
bmp_update_syncro(bmp, afi, safi, bgp);
}
} }
} }
@ -3477,8 +3570,12 @@ static int bmp_bgp_attribute_updated(struct bgp *bgp, bool withdraw)
withdraw, s); withdraw, s);
if (withdraw) if (withdraw)
continue; continue;
frr_each (bmp_session, &bt->sessions, bmp) frr_each (bmp_session, &bt->sessions, bmp) {
bmp_send_peerup_per_instance(bmp, bgp); bmp_send_peerup_per_instance(bmp, bgp);
FOREACH_AFI_SAFI (afi, safi) {
bmp_update_syncro(bmp, afi, safi, bgp);
}
}
} }
} }
} }
@ -3504,14 +3601,19 @@ static void _bmp_vrf_state_changed_internal(struct bgp *bgp, enum bmp_vrf_state
struct listnode *node; struct listnode *node;
struct bmp_imported_bgp *bib; struct bmp_imported_bgp *bib;
struct bmp *bmp; struct bmp *bmp;
afi_t afi;
safi_t safi;
if (bmpbgp && bmp_bgp_update_vrf_status(&bmpbgp->vrf_state, bgp, vrf_state)) { if (bmpbgp && bmp_bgp_update_vrf_status(&bmpbgp->vrf_state, bgp, vrf_state)) {
bmp_send_all_safe(bmpbgp, bmp_peerstate(bgp->peer_self, bmp_send_all_safe(bmpbgp, bmp_peerstate(bgp->peer_self,
bmpbgp->vrf_state == vrf_state_down)); bmpbgp->vrf_state == vrf_state_down));
if (vrf_state == vrf_state_up && bmpbgp->vrf_state == vrf_state_up) { if (vrf_state == vrf_state_up && bmpbgp->vrf_state == vrf_state_up) {
frr_each (bmp_targets, &bmpbgp->targets, bt) { frr_each (bmp_targets, &bmpbgp->targets, bt) {
frr_each (bmp_session, &bt->sessions, bmp) frr_each (bmp_session, &bt->sessions, bmp) {
bmp_send_peerup_per_instance(bmp, bgp); bmp_send_peerup_per_instance(bmp, bgp);
FOREACH_AFI_SAFI (afi, safi)
bmp_update_syncro(bmp, afi, safi, bgp);
}
} }
} }
} }
@ -3532,8 +3634,12 @@ static void _bmp_vrf_state_changed_internal(struct bgp *bgp, enum bmp_vrf_state
vrf_state_down)); vrf_state_down));
if (vrf_state == vrf_state_up && if (vrf_state == vrf_state_up &&
bib->vrf_state == vrf_state_up) { bib->vrf_state == vrf_state_up) {
frr_each (bmp_session, &bt->sessions, bmp) frr_each (bmp_session, &bt->sessions, bmp) {
bmp_send_peerup_per_instance(bmp, bgp); bmp_send_peerup_per_instance(bmp, bgp);
FOREACH_AFI_SAFI (afi, safi)
bmp_update_syncro(bmp, afi, safi,
bgp);
}
} }
break; break;
} }

5
bgpd/bgp_bmp.h
View file

@ -92,7 +92,7 @@ struct bmp_mirrorq {
uint8_t data[0]; uint8_t data[0];
}; };
enum { enum bmp_afi_state {
BMP_AFI_INACTIVE = 0, BMP_AFI_INACTIVE = 0,
BMP_AFI_NEEDSYNC, BMP_AFI_NEEDSYNC,
BMP_AFI_SYNC, BMP_AFI_SYNC,
@ -148,6 +148,7 @@ struct bmp {
uint64_t syncpeerid; uint64_t syncpeerid;
afi_t syncafi; afi_t syncafi;
safi_t syncsafi; safi_t syncsafi;
struct bgp *sync_bgp;
}; };
/* config & state for an active outbound connection. When the connection /* config & state for an active outbound connection. When the connection
@ -209,6 +210,7 @@ struct bmp_targets {
struct bmp_bgp *bmpbgp; struct bmp_bgp *bmpbgp;
struct bgp *bgp; struct bgp *bgp;
bool bgp_request_sync[AFI_MAX][SAFI_MAX];
char *name; char *name;
struct bmp_listeners_head listeners; struct bmp_listeners_head listeners;
@ -284,6 +286,7 @@ struct bmp_imported_bgp {
struct bmp_targets *targets; struct bmp_targets *targets;
char *name; char *name;
enum bmp_vrf_state vrf_state; enum bmp_vrf_state vrf_state;
bool bgp_request_sync[AFI_MAX][SAFI_MAX];
}; };
struct bmp_bgp { struct bmp_bgp {