matthew/sonic-buildimage
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

[bgpmon]: Fix exception in bgpmon caused by duplicate bgp neighbor ID (#6546)

Browse Source 
* Fix exception in bgpmon caused by duplicate keys
It is possible that BGP neighbors in IPv4 and IPv6 address families
share the same name (such as bgp monitor). However, such case is not
handled in bgpmon, and an Exception will be raised. This commit will
address the issue by Using set instead of list to avoid duplicate keys.
This commit is contained in:
bingwang-ms 2021-01-27 15:01:42 +08:00 committed by Guohan Lu
parent a0fd862620
commit be281536e1
1 changed files with 18 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
src/sonic-bgpcfgd/bgpmon/bgpmon.py
View File

@ -34,13 +34,13 @@ PIPE_BATCH_MAX_COUNT = 50
class BgpStateGet:
def __init__(self):
# list peer_l stores the Neighbor peer Ip address
# set peer_l stores the Neighbor peer Ip address
# dic peer_state stores the Neighbor peer state entries
# list new_peer_l stores the new snapshot of Neighbor peer ip address
# set new_peer_l stores the new snapshot of Neighbor peer ip address
# dic new_peer_state stores the new snapshot of Neighbor peer states
self.peer_l = []
self.peer_l = set()
self.peer_state = {}
self.new_peer_l = []
self.new_peer_l = set()
self.new_peer_state = {}
self.cached_timestamp = 0
self.db = swsssdk.SonicV2Connector()
@ -67,7 +67,7 @@ class BgpStateGet:
def update_new_peer_states(self, peer_dict):
peer_l = peer_dict["peers"].keys()
self.new_peer_l.extend(peer_l)
self.new_peer_l.update(peer_l)
for peer in peer_l:
self.new_peer_state[peer] = peer_dict["peers"][peer]["state"]
@ -80,8 +80,8 @@ class BgpStateGet:
return
peer_info = json.loads(output)
# cmd ran successfully, safe to Clean the "new" lists/dic for new snapshot
del self.new_peer_l[:]
# cmd ran successfully, safe to Clean the "new" set/dict for new snapshot
self.new_peer_l.clear()
self.new_peer_state.clear()
for key, value in peer_info.items():
if key == "ipv4Unicast" or key == "ipv6Unicast":
@ -115,8 +115,7 @@ class BgpStateGet:
def update_neigh_states(self):
data = {}
for i in range (0, len(self.new_peer_l)):
peer = self.new_peer_l[i]
for peer in self.new_peer_l:
key = "NEIGH_STATE_TABLE|%s" % peer
if peer in self.peer_l:
# only update the entry if state changed
@ -125,7 +124,7 @@ class BgpStateGet:
state = self.new_peer_state[peer]
data[key] = {'state':state}
self.peer_state[peer] = state
# remove this neighbor from old list since it is accounted for
# remove this neighbor from old set since it is accounted for
self.peer_l.remove(peer)
else:
# New neighbor found case. Add to dictionary and state DB
@ -135,19 +134,19 @@ class BgpStateGet:
if len(data) > PIPE_BATCH_MAX_COUNT:
self.flush_pipe(data)
# Check for stale state entries to be cleaned up
while len(self.peer_l) > 0:
for peer in self.peer_l:
# remove this from the stateDB and the current neighbor state entry
peer = self.peer_l.pop(0)
del_key = "NEIGH_STATE_TABLE|%s" % peer
data[del_key] = None
if peer in self.peer_state:
del self.peer_state[peer]
if len(data) > PIPE_BATCH_MAX_COUNT:
self.flush_pipe(data)
# If anything in the pipeline not yet flushed, flush them now
if len(data) > 0:
self.flush_pipe(data)
# Save the new List
self.peer_l = self.new_peer_l[:]
# Save the new set
self.peer_l = self.new_peer_l.copy()
def main():