EdgeVPNio
/
evio
mirror of https://github.com/EdgeVPNio/evio.git
1
0
Fork 0
Code Issues Releases Wiki Activity

Log messages

master
Ken 2024-02-09 19:59:45 +00:00
parent 90409df806
commit 151ccce5de
1 changed files with 18 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
evio/controllers/topology.py
View File

@ -431,7 +431,13 @@ class Topology(ControllerModule):
ce: ConnectionEdge = ovl.adjacency_list.pop(peer_id, None) ce: ConnectionEdge = ovl.adjacency_list.pop(peer_id, None)
if ce: if ce:
ce.edge_state = EDGE_STATES.Deleting ce.edge_state = EDGE_STATES.Deleting
self.logger.info("Edge %s removed from adjacency list", ce.edge_id) self.logger.info(
"Edge %s/%s<->%s (%s) was removed",
ovl.overlay_id[:7],
ce.edge_id[:7],
peer_id[:7],
ce.edge_type,
)
else: else:
self.logger.warning("Invalid UpdateType specified for event %s", event) self.logger.warning("Invalid UpdateType specified for event %s", event)
@ -603,13 +609,21 @@ class Topology(ControllerModule):
def resp_handler_remote_action(self, cbt: CBT): def resp_handler_remote_action(self, cbt: CBT):
"""Role Node A, initiate edge creation on successful neogtiation""" """Role Node A, initiate edge creation on successful neogtiation"""
rem_act = cbt.response.data rem_act: RemoteAction = cbt.response.data
olid = rem_act.overlay_id olid = rem_act.overlay_id
ovl = self._net_ovls[olid] ovl = self._net_ovls[olid]
peer_id = rem_act.recipient_id
self.free_cbt(cbt) self.free_cbt(cbt)
if not cbt.response.status and isinstance(rem_act.data, str): if not cbt.response.status and isinstance(rem_act.data, str):
self.logger.info("The remote action expired %s", rem_act) self.logger.info(
peer_id = rem_act.recipient_id "Remote Action expired %s/%s->%s (%s). %s",
olid[:7],
rem_act.params["edge_id"][:7],
peer_id[:7],
rem_act.action,
rem_act.data,
)
del ovl.adjacency_list[peer_id] del ovl.adjacency_list[peer_id]
ovl.known_peers[peer_id].exclude() ovl.known_peers[peer_id].exclude()
self._process_next_transition(ovl) self._process_next_transition(ovl)
@ -1030,7 +1044,6 @@ class Topology(ControllerModule):
) # succ threshold -> at/below the min required ) # succ threshold -> at/below the min required
): ):
raise ValueError("Successor threshold not met") raise ValueError("Successor threshold not met")
self.logger.debug("Removing edge %s", ce)
self._remove_tunnel( self._remove_tunnel(
net_ovl, ce.dataplane, ce.peer_id, ce.edge_id, ce.edge_type net_ovl, ce.dataplane, ce.peer_id, ce.edge_id, ce.edge_type
) )