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

bgpd: bmp, handle imported bgp instances in bmp end of rib

Browse source 
Modify the bmp_eor() function to send end of rib messages for each peer
of the current BGP instance.

Signed-off-by: Philippe Guibert <philippe.guibert@6wind.com>
This commit is contained in:
Philippe Guibert 2024-12-03 09:05:45 +01:00
parent b79574b5c6
commit ffdb4cd0f5
2 changed files with 10 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
bgpd/bgp_bmp.c
View file

@ -1042,8 +1042,8 @@ static int bmp_peer_backward(struct peer *peer)
return 0; return 0;
} }
static void bmp_eor(struct bmp *bmp, afi_t afi, safi_t safi, uint8_t flags, static void bmp_eor(struct bmp *bmp, afi_t afi, safi_t safi, uint8_t flags, uint8_t peer_type_flag,
uint8_t peer_type_flag) struct bgp *bgp)
{ {
struct peer *peer; struct peer *peer;
struct listnode *node; struct listnode *node;
@ -1051,7 +1051,7 @@ static void bmp_eor(struct bmp *bmp, afi_t afi, safi_t safi, uint8_t flags,
iana_afi_t pkt_afi = IANA_AFI_IPV4; iana_afi_t pkt_afi = IANA_AFI_IPV4;
iana_safi_t pkt_safi = IANA_SAFI_UNICAST; iana_safi_t pkt_safi = IANA_SAFI_UNICAST;
frrtrace(4, frr_bgp, bmp_eor, afi, safi, flags, peer_type_flag); frrtrace(5, frr_bgp, bmp_eor, afi, safi, flags, peer_type_flag, bgp);
s = stream_new(BGP_MAX_PACKET_SIZE); s = stream_new(BGP_MAX_PACKET_SIZE);
@ -1079,7 +1079,7 @@ static void bmp_eor(struct bmp *bmp, afi_t afi, safi_t safi, uint8_t flags,
bgp_packet_set_size(s); bgp_packet_set_size(s);
for (ALL_LIST_ELEMENTS_RO(bmp->targets->bgp->peer, node, peer)) { for (ALL_LIST_ELEMENTS_RO(bgp->peer, node, peer)) {
if (!peer->afc_nego[afi][safi]) if (!peer->afc_nego[afi][safi])
continue; continue;
@ -1096,8 +1096,7 @@ static void bmp_eor(struct bmp *bmp, afi_t afi, safi_t safi, uint8_t flags,
bmp_common_hdr(s2, BMP_VERSION_3, bmp_common_hdr(s2, BMP_VERSION_3,
BMP_TYPE_ROUTE_MONITORING); BMP_TYPE_ROUTE_MONITORING);
bmp_per_peer_hdr(s2, bmp->targets->bgp, peer, flags, bmp_per_peer_hdr(s2, bgp, peer, flags, peer_type_flag, peer_distinguisher, NULL);
peer_type_flag, peer_distinguisher, NULL);
stream_putl_at(s2, BMP_LENGTH_POS, stream_putl_at(s2, BMP_LENGTH_POS,
stream_get_endp(s) + stream_get_endp(s2)); stream_get_endp(s) + stream_get_endp(s2));
@ -1313,9 +1312,9 @@ static void bmp_eor_afi_safi(struct bmp *bmp, afi_t afi, safi_t safi, uint8_t pe
zlog_info("bmp[%s] %s %s table completed (EoR) (BGP %s)", bmp->remote, afi2str(afi), zlog_info("bmp[%s] %s %s table completed (EoR) (BGP %s)", bmp->remote, afi2str(afi),
safi2str(safi), bmp->sync_bgp->name_pretty); 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->sync_bgp);
bmp_eor(bmp, afi, safi, 0, peer_type_flag); bmp_eor(bmp, afi, safi, 0, peer_type_flag, bmp->sync_bgp);
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->sync_bgp);
sync_bgp = bmp_get_next_bgp(bmp->targets, bmp->sync_bgp, afi, safi); sync_bgp = bmp_get_next_bgp(bmp->targets, bmp->sync_bgp, afi, safi);
if (sync_bgp) { if (sync_bgp) {

3
bgpd/bgp_trace.h
View file

@ -135,12 +135,13 @@ TRACEPOINT_LOGLEVEL(frr_bgp, bmp_mirror_packet, TRACE_INFO)
TRACEPOINT_EVENT( TRACEPOINT_EVENT(
frr_bgp, frr_bgp,
bmp_eor, bmp_eor,
TP_ARGS(afi_t, afi, safi_t, safi, uint8_t, flags, uint8_t, peer_type_flag), TP_ARGS(afi_t, afi, safi_t, safi, uint8_t, flags, uint8_t, peer_type_flag, bgp),
TP_FIELDS( TP_FIELDS(
ctf_integer(afi_t, afi, afi) ctf_integer(afi_t, afi, afi)
ctf_integer(safi_t, safi, safi) ctf_integer(safi_t, safi, safi)
ctf_integer(uint8_t, flags, flags) ctf_integer(uint8_t, flags, flags)
ctf_integer(uint8_t, peer_type_flag, peer_type_flag) ctf_integer(uint8_t, peer_type_flag, peer_type_flag)
ctf_string(bgp, bgp->name_pretty)
) )
) )