lab/mininet-sample
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

WIP: putting several links between router and server(s)

Browse Source
This commit is contained in:
Quentin De Coninck 2020-07-02 16:33:42 +02:00
parent 98b4a63704
commit a99746cb9e
2 changed files with 46 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
core/topo.py
View File

@ -139,11 +139,13 @@ class TopoParameter(Parameter):
RIGHT_SUBNET = "rightSubnet" RIGHT_SUBNET = "rightSubnet"
NETEM_AT = "netem_at_" NETEM_AT = "netem_at_"
CHANGE_NETEM = "changeNetem" CHANGE_NETEM = "changeNetem"
SERVER_PATHS = "serverPaths"
DEFAULT_PARAMETERS = { DEFAULT_PARAMETERS = {
LEFT_SUBNET: "10.1.", LEFT_SUBNET: "10.1.",
RIGHT_SUBNET: "10.2.", RIGHT_SUBNET: "10.2.",
CHANGE_NETEM: "false", CHANGE_NETEM: "false",
SERVER_PATHS: "1",
} }
def __init__(self, parameter_filename): def __init__(self, parameter_filename):

58
topos/multi_interface.py
View File

@ -19,6 +19,8 @@ class MultiInterfaceTopo(Topo):
self.server_switches.append(self.add_router_side_switch(l)) self.server_switches.append(self.add_router_side_switch(l))
self.add_bottleneck_link(self.client_switches[-1], self.server_switches[-1], link_characteristics=l) self.add_bottleneck_link(self.client_switches[-1], self.server_switches[-1], link_characteristics=l)
self.add_link(self.server_switches[-1],self.router) self.add_link(self.server_switches[-1],self.router)
for i in range(int(self.topo_parameter.get(TopoParameter.SERVER_PATHS))):
self.add_link(self.router, self.server) self.add_link(self.router, self.server)
def add_client_side_switch(self, link): def add_client_side_switch(self, link):
@ -60,15 +62,28 @@ class MultiInterfaceConfig(TopoConfig):
self.get_client_interface(0, i), i) self.get_client_interface(0, i), i)
self.topo.command_to(self.client, cmd) self.topo.command_to(self.client, cmd)
cmd = self.add_table_default_route_command(self.get_router_ip_to_switch(i), cmd = self.add_table_default_route_command(self.get_router_ip_to_client_switch(i),
i) i)
self.topo.command_to(self.client, cmd) self.topo.command_to(self.client, cmd)
cmd = self.add_global_default_route_command(self.get_router_ip_to_switch(0), for i in range(int(self.topo_parameter.get(TopoParameter.SERVER_PATHS))):
cmd = self.add_table_route_command(self.get_server_ip(i), i)
self.topo.command_to(self.server, cmd)
cmd = self.add_link_scope_route_command(
self.get_server_subnet(i),
self.get_server_interface(0, i), i)
self.topo.command_to(self.server, cmd)
cmd = self.add_table_default_route_command(self.get_router_ip_to_server_switch(i),
i)
self.topo.command_to(self.server, cmd)
cmd = self.add_global_default_route_command(self.get_router_ip_to_client_switch(0),
self.get_client_interface(0, 0)) self.get_client_interface(0, 0))
self.topo.command_to(self.client, cmd) self.topo.command_to(self.client, cmd)
cmd = self.add_simple_default_route_command(self.get_router_ip_to_server()) cmd = self.add_simple_default_route_command(self.get_router_ip_to_server_switch(0))
self.topo.command_to(self.server, cmd) self.topo.command_to(self.server, cmd)
@ -93,24 +108,26 @@ class MultiInterfaceConfig(TopoConfig):
for i, l in enumerate(self.topo.server_switches): for i, l in enumerate(self.topo.server_switches):
cmd = self.interface_up_command(self.get_router_interface_to_switch(i), cmd = self.interface_up_command(self.get_router_interface_to_switch(i),
self.get_router_ip_to_switch(i), netmask) self.get_router_ip_to_client_switch(i), netmask)
self.topo.command_to(self.router, cmd) self.topo.command_to(self.router, cmd)
router_interface_mac = self.router.intf(self.get_router_interface_to_switch(i)).MAC() router_interface_mac = self.router.intf(self.get_router_interface_to_switch(i)).MAC()
self.topo.command_to(self.client, "arp -s {} {}".format( self.topo.command_to(self.client, "arp -s {} {}".format(
self.get_router_ip_to_switch(i), router_interface_mac)) self.get_router_ip_to_client_switch(i), router_interface_mac))
cmd = self.interface_up_command(self.get_router_interface_to_server(), for i in range(int(self.topo_parameter.get(TopoParameter.SERVER_PATHS))):
self.get_router_ip_to_server(), netmask) cmd = self.interface_up_command(self.get_router_interface_to_server(i),
self.get_router_ip_to_server_switch(i), netmask)
self.topo.command_to(self.router, cmd) self.topo.command_to(self.router, cmd)
router_interface_mac = self.router.intf(self.get_router_interface_to_server()).MAC() router_interface_mac = self.router.intf(self.get_router_interface_to_server(i)).MAC()
self.topo.command_to(self.server, "arp -s {} {}".format( self.topo.command_to(self.server, "arp -s {} {}".format(
self.get_router_ip_to_server(), router_interface_mac)) self.get_router_ip_to_server_switch(i), router_interface_mac))
cmd = self.interface_up_command(self.get_server_interface(0), self.get_server_ip(), netmask) for i in range(int(self.topo_parameter.get(TopoParameter.SERVER_PATHS))):
cmd = self.interface_up_command(self.get_server_interface(i), self.get_server_ip(i), netmask)
self.topo.command_to(self.server, cmd) self.topo.command_to(self.server, cmd)
server_interface_mac = self.server.intf(self.get_server_interface(0)).MAC() server_interface_mac = self.server.intf(self.get_server_interface(i)).MAC()
self.topo.command_to(self.router, "arp -s {} {}".format( self.topo.command_to(self.router, "arp -s {} {}".format(
self.get_server_ip(), server_interface_mac)) self.get_server_ip(i), server_interface_mac))
def get_client_ip(self, interface_index): def get_client_ip(self, interface_index):
return "{}{}.1".format(self.param.get(TopoParameter.LEFT_SUBNET), interface_index) return "{}{}.1".format(self.param.get(TopoParameter.LEFT_SUBNET), interface_index)
@ -118,20 +135,23 @@ class MultiInterfaceConfig(TopoConfig):
def get_client_subnet(self, interface_index): def get_client_subnet(self, interface_index):
return "{}{}.0/24".format(self.param.get(TopoParameter.LEFT_SUBNET), interface_index) return "{}{}.0/24".format(self.param.get(TopoParameter.LEFT_SUBNET), interface_index)
def get_router_ip_to_switch(self, switch_index): def get_router_ip_to_client_switch(self, switch_index):
return "{}{}.2".format(self.param.get(TopoParameter.LEFT_SUBNET), switch_index) return "{}{}.2".format(self.param.get(TopoParameter.LEFT_SUBNET), switch_index)
def get_router_ip_to_server(self): def get_router_ip_to_server_switch(self, switch_index):
return "{}0.2".format(self.param.get(TopoParameter.RIGHT_SUBNET)) return "{}{}.2".format(self.param.get(TopoParameter.RIGHT_SUBNET))
def get_server_ip(self): def get_server_ip(self, interface_index):
return "{}0.1".format(self.param.get(TopoParameter.RIGHT_SUBNET)) return "{}{}.1".format(self.param.get(TopoParameter.RIGHT_SUBNET))
def get_server_subnet(self, interface_index):
return "{}{}.0/24".format(self.param.get(TopoParameter.RIGHT_SUBNET), interface_index)
def client_interface_count(self): def client_interface_count(self):
return len(self.topo.client_switches) return len(self.topo.client_switches)
def get_router_interface_to_server(self): def get_router_interface_to_server(self, switch_index):
return self.get_router_interface_to_switch(len(self.topo.server_switches)) return self.get_router_interface_to_switch(len(self.topo.server_switches) + switch_index)
def get_client_interface(self, client_index, interface_index): def get_client_interface(self, client_index, interface_index):
return "{}-eth{}".format(self.topo.get_client_name(client_index), interface_index) return "{}-eth{}".format(self.topo.get_client_name(client_index), interface_index)