@@ -86,13 +86,13 @@ def __createPeer(self, nodeA: Router, nodeB: Router, addrA: str, addrB: str, rel
8686 if node .getRole () == NodeRole .RouteServer :
8787 rsNode = node
8888 continue
89-
89+
9090 if routerA == None : routerA = node
9191 elif routerB == None : routerB = node
9292
9393 if not node .getAttribute ('__bgp_bootstrapped' , False ):
9494 self ._log ('Bootstrapping as{}/{} for BGP...' .format (node .getAsn (), node .getName ()))
95-
95+
9696 node .setAttribute ('__bgp_bootstrapped' , True )
9797 node .appendFile ('/etc/bird/bird.conf' , EbgpFileTemplates ['bgp_commons' ].format (localAsn = node .getAsn ()))
9898
@@ -129,7 +129,7 @@ def __createPeer(self, nodeA: Router, nodeB: Router, addrA: str, addrB: str, rel
129129 ))
130130
131131 return
132-
132+
133133 if rel == PeerRelationship .Peer :
134134 routerA .addProtocol ('bgp' , 'p_as{}' .format (routerB .getAsn ()), EbgpFileTemplates ["rnode_bird_peer" ].format (
135135 localAddress = addrA ,
@@ -191,7 +191,7 @@ def __createPeer(self, nodeA: Router, nodeB: Router, addrA: str, addrB: str, rel
191191 exportFilter = "all" ,
192192 importCommunity = "PROVIDER_COMM" ,
193193 bgpPref = 10
194- ))
194+ ))
195195
196196 def getName (self ) -> str :
197197 return "Ebgp"
@@ -262,7 +262,7 @@ def addCrossConnectPeering(self, a: int, b: int, abRelationship: PeerRelationshi
262262 B. Default to Peer.
263263
264264 @throws AssertionError if peering already exist.
265-
265+
266266 @returns self, for chaining API calls.
267267 """
268268 assert (a , b ) not in self .__xc_peerings , '{} <-> {} already configured as XC peer' .format (a , b )
@@ -320,7 +320,7 @@ def getRsPeers(self) -> List[Tuple[int, int]]:
320320
321321 @returns list of tuple of (ix, peerAsn)
322322 """
323- return self .__rs_peers
323+ return self .__rs_peers
324324
325325 def configure (self , emulator : Emulator ) -> None :
326326 reg = emulator .getRegistry ()
@@ -365,7 +365,7 @@ def configure(self, emulator: Emulator) -> None:
365365
366366 for node in a_reg .getByType ('rnode' ):
367367 router : Router = node
368- for (peername , peerasn ), (localaddr , _ ) in router .getCrossConnects ().items ():
368+ for (peername , peerasn ), (localaddr , _ , _ ) in router .getCrossConnects ().items ():
369369 if peerasn != b : continue
370370 if not b_reg .has ('rnode' , peername ): continue
371371
@@ -374,7 +374,7 @@ def configure(self, emulator: Emulator) -> None:
374374 b_router = b_reg .get ('rnode' , peername )
375375
376376 a_addr = str (localaddr .ip )
377- (b_ifaddr , _ ) = b_router .getCrossConnect (a , a_router .getName ())
377+ (b_ifaddr , _ , _ ) = b_router .getCrossConnect (a , a_router .getName ())
378378 b_addr = str (b_ifaddr .ip )
379379
380380 break
@@ -404,7 +404,7 @@ def configure(self, emulator: Emulator) -> None:
404404 a_ixnode = node
405405 a_ixif = iface
406406 break
407-
407+
408408 assert a_ixnode != None , 'cannot resolve peering: as{} not in ix{}' .format (a , ix )
409409
410410 b_ixnode : Router = None
@@ -416,7 +416,7 @@ def configure(self, emulator: Emulator) -> None:
416416 b_ixnode = node
417417 b_ixif = iface
418418 break
419-
419+
420420 assert b_ixnode != None , 'cannot resolve peering: as{} not in ix{}' .format (b , ix )
421421
422422 self ._log ("adding IX peering: {} as {} <-({})-> {} as {}" .format (a_ixif .getAddress (), a , rel , b_ixif .getAddress (), b ))
@@ -443,10 +443,10 @@ def _doCreateGraphs(self, emulator: Emulator):
443443 ix_graph = self ._addGraph ('IX{} Peering Sessions' .format (ix ), False )
444444
445445 mesh_ases = set ()
446-
446+
447447 for (i , a ) in self .__rs_peers :
448448 if i == ix : mesh_ases .add (a )
449-
449+
450450 self ._log ('IX{} RS-mesh: {}' .format (ix , mesh_ases ))
451451
452452 while len (mesh_ases ) > 0 :
@@ -463,7 +463,7 @@ def _doCreateGraphs(self, emulator: Emulator):
463463
464464 full_graph .addEdge ('AS{}' .format (a ), 'AS{}' .format (b ), 'IX{}' .format (ix ), 'IX{}' .format (ix ), style = 'dashed' , alabel = 'R' , blabel = 'R' )
465465 ix_graph .addEdge ('AS{}' .format (a ), 'AS{}' .format (b ), 'IX{}' .format (ix ), 'IX{}' .format (ix ), style = 'dashed' , alabel = 'R' , blabel = 'R' )
466-
466+
467467 for (i , a , b ), rel in self .__peerings .items ():
468468 self ._log ('Creating private peering sessions graph for IX{} AS{} <-> AS{}...' .format (i , a , b ))
469469
@@ -483,7 +483,7 @@ def _doCreateGraphs(self, emulator: Emulator):
483483 full_graph .addEdge ('AS{}' .format (a ), 'AS{}' .format (b ), 'IX{}' .format (i ), 'IX{}' .format (i ), alabel = 'P' , blabel = 'P' )
484484 ix_graph .addEdge ('AS{}' .format (a ), 'AS{}' .format (b ), 'IX{}' .format (i ), 'IX{}' .format (i ), alabel = 'P' , blabel = 'P' )
485485
486- if rel == PeerRelationship .Provider :
486+ if rel == PeerRelationship .Provider :
487487 full_graph .addEdge ('AS{}' .format (a ), 'AS{}' .format (b ), 'IX{}' .format (i ), 'IX{}' .format (i ), alabel = 'U' , blabel = 'C' )
488488 ix_graph .addEdge ('AS{}' .format (a ), 'AS{}' .format (b ), 'IX{}' .format (i ), 'IX{}' .format (i ), alabel = 'U' , blabel = 'C' )
489489
@@ -516,4 +516,3 @@ def print(self, indent: int) -> str:
516516
517517
518518 return out
519-
0 commit comments