| #!/usr/bin/python |
| |
| import sys |
| sys.path.append('..') |
| from mininet.topo import Topo |
| from mininet.net import Mininet |
| from mininet.cli import CLI |
| from mininet.log import setLogLevel |
| from mininet.node import RemoteController, OVSBridge, Host |
| from mininet.nodelib import NAT |
| from ipaddress import ip_network |
| from routinglib import BgpRouter |
| from routinglib import RoutedHost |
| |
| class Trellis( Topo ): |
| "Trellis basic topology" |
| |
| def __init__( self, *args, **kwargs ): |
| Topo.__init__( self, *args, **kwargs ) |
| |
| # Spines |
| s226 = self.addSwitch('s226', dpid='226') |
| s227 = self.addSwitch('s227', dpid='227') |
| |
| # Leaves |
| s204 = self.addSwitch('s204', dpid='204') |
| s205 = self.addSwitch('s205', dpid='205') |
| |
| # Switch Links |
| self.addLink(s226, s204) |
| self.addLink(s226, s205) |
| self.addLink(s227, s204) |
| self.addLink(s227, s205) |
| |
| # NOTE avoid using 10.0.1.0/24 which is the default subnet of quaggas |
| # NOTE avoid using 00:00:00:00:00:xx which is the default mac of host behind upstream router |
| # IPv4 Hosts |
| h1 = self.addHost('h1', cls=DhcpClient, mac='00:aa:00:00:00:01') |
| h2 = self.addHost('h2', cls=TaggedDhcpClient, mac='00:aa:00:00:00:02', vlan=20) |
| h3 = self.addHost('h3', cls=DhcpClient, mac='00:aa:00:00:00:03') |
| h4 = self.addHost('h4', cls=TaggedDhcpClient, mac='00:aa:00:00:00:04', vlan=30) |
| self.addLink(h1, s204) |
| self.addLink(h2, s204) |
| self.addLink(h3, s205) |
| self.addLink(h4, s205) |
| |
| # IPv6 Hosts |
| h1v6 = self.addHost('h1v6', cls=RoutedHost, mac='00:bb:00:00:00:01', ips=['2000::201/120'], gateway='2000::2ff') |
| h2v6 = self.addHost('h2v6', cls=RoutedHost, mac='00:bb:00:00:00:02', ips=['2000::202/120'], gateway='2000::2ff') |
| h3v6 = self.addHost('h3v6', cls=RoutedHost, mac='00:bb:00:00:00:03', ips=['2000::301/120'], gateway='2000::3ff') |
| h4v6 = self.addHost('h4v6', cls=RoutedHost, mac='00:bb:00:00:00:04', ips=['2000::302/120'], gateway='2000::3ff') |
| self.addLink(h1v6, s204) |
| self.addLink(h2v6, s204) |
| self.addLink(h3v6, s205) |
| self.addLink(h4v6, s205) |
| |
| # DHCP server |
| dhcp = self.addHost('dhcp', cls=TaggedDhcpServer, mac='00:99:00:00:00:01', ips=['10.0.3.253/24'], gateway='10.0.3.254', vlan=30) |
| self.addLink(dhcp, s205) |
| |
| # Control plane switch (for quagga fpm) |
| cs0 = self.addSwitch('cs0', cls=OVSBridge) |
| |
| # Control plane NAT (for quagga fpm) |
| nat = self.addHost('nat', cls=NAT, |
| ip='172.16.0.1/12', |
| subnet=str(ip_network(u'172.16.0.0/12')), inNamespace=False) |
| self.addLink(cs0, nat) |
| |
| # Internal Quagga bgp1 |
| intfs = {'bgp1-eth0': {'ipAddrs': ['10.0.1.2/24', '2000::102/120'], 'mac': '00:88:00:00:00:02'}, |
| 'bgp1-eth1': {'ipAddrs': ['172.16.0.2/12']}} |
| bgp1 = self.addHost('bgp1', cls=BgpRouter, |
| interfaces=intfs, |
| quaggaConfFile='./bgpdbgp1.conf', |
| zebraConfFile='./zebradbgp1.conf') |
| self.addLink(bgp1, s205) |
| self.addLink(bgp1, cs0) |
| |
| # External Quagga r1 |
| intfs = {'r1-eth0': {'ipAddrs': ['10.0.1.1/24', '2000::101/120'], 'mac': '00:88:00:00:00:01'}, |
| 'r1-eth1': {'ipAddrs': ['10.0.99.1/16']}, |
| 'r1-eth2': {'ipAddrs': ['2000::9901/120']}} |
| r1 = self.addHost('r1', cls=BgpRouter, |
| interfaces=intfs, |
| quaggaConfFile='./bgpdr1.conf') |
| self.addLink(r1, s205) |
| |
| # External IPv4 Host behind r1 |
| rh1 = self.addHost('rh1', cls=RoutedHost, ips=['10.0.99.2/24'], gateway='10.0.99.1') |
| self.addLink(r1, rh1) |
| |
| # External IPv6 Host behind r1 |
| rh1v6 = self.addHost('rh1v6', cls=RoutedHost, ips=['2000::9902/120'], gateway='2000::9901') |
| self.addLink(r1, rh1v6) |
| |
| topos = { 'trellis' : Trellis } |
| |
| class DhcpClient(Host): |
| def __init__(self, name, *args, **kwargs): |
| super(DhcpClient, self).__init__(name, **kwargs) |
| self.pidFile = '/run/dhclient-%s.pid' % self.name |
| |
| def config(self, **kwargs): |
| super(DhcpClient, self).config(**kwargs) |
| self.cmd('ip addr flush dev %s' % self.defaultIntf()) |
| self.cmd('dhclient -q -4 -nw -pf %s %s' % (self.pidFile, self.defaultIntf())) |
| |
| def terminate(self, **kwargs): |
| self.cmd('kill -9 `cat %s`' % self.pidFile) |
| self.cmd('rm -rf %s' % self.pidFile) |
| super(DhcpClient, self).terminate() |
| |
| class TaggedDhcpClient(Host): |
| def __init__(self, name, vlan, *args, **kwargs): |
| super(TaggedDhcpClient, self).__init__(name, **kwargs) |
| self.pidFile = '/run/dhclient-%s.pid' % self.name |
| self.vlan = vlan |
| self.vlanIntf = None |
| |
| def config(self, **kwargs): |
| super(TaggedDhcpClient, self).config(**kwargs) |
| self.vlanIntf = "%s.%s" % (self.defaultIntf(), self.vlan) |
| self.cmd('ip addr flush dev %s' % self.defaultIntf()) |
| self.cmd('ip link add link %s name %s type vlan id %s' % (self.defaultIntf(), self.vlanIntf, self.vlan)) |
| self.cmd('ip link set up %s' % self.vlanIntf) |
| self.cmd('dhclient -q -4 -nw -pf %s %s' % (self.pidFile, self.vlanIntf)) |
| |
| def terminate(self, **kwargs): |
| self.cmd('kill -9 `cat %s`' % self.pidFile) |
| self.cmd('rm -rf %s' % self.pidFile) |
| self.cmd('ip link remove link %s' % self.vlanIntf) |
| super(TaggedDhcpClient, self).terminate() |
| |
| class DhcpServer(RoutedHost): |
| binFile = '/usr/sbin/dhcpd' |
| pidFile = '/run/dhcp-server/dhcpd.pid' |
| configFile = './dhcpd.conf' |
| |
| def config(self, **kwargs): |
| super(DhcpServer, self).config(**kwargs) |
| self.cmd('%s -q -4 -pf %s -cf %s %s' % (self.binFile, self.pidFile, self.configFile, self.defaultIntf())) |
| |
| def terminate(self, **kwargs): |
| self.cmd('kill -9 `cat %s`' % self.pidFile) |
| self.cmd('rm -rf %s' % self.pidFile) |
| super(DhcpServer, self).terminate() |
| |
| class TaggedRoutedHost(RoutedHost): |
| """Host that can be configured with multiple IP addresses.""" |
| def __init__(self, name, ips, gateway, vlan, *args, **kwargs): |
| super(RoutedHost, self).__init__(name, *args, **kwargs) |
| self.ips = ips |
| self.gateway = gateway |
| self.vlan = vlan |
| self.vlanIntf = None |
| |
| def config(self, **kwargs): |
| Host.config(self, **kwargs) |
| self.vlanIntf = "%s.%s" % (self.defaultIntf(), self.vlan) |
| self.cmd('ip -4 addr flush dev %s' % self.defaultIntf()) |
| self.cmd('ip link add link %s name %s type vlan id %s' % (self.defaultIntf(), self.vlanIntf, self.vlan)) |
| self.cmd('ip link set up %s' % self.vlanIntf) |
| |
| for ip in self.ips: |
| self.cmd('ip addr add %s dev %s' % (ip, self.vlanIntf)) |
| |
| self.cmd('ip route add default via %s' % self.gateway) |
| |
| def terminate(self, **kwargs): |
| self.cmd('ip link remove link %s' % self.vlanIntf) |
| super(TaggedRoutedHost, self).terminate() |
| |
| class TaggedDhcpServer(TaggedRoutedHost): |
| binFile = '/usr/sbin/dhcpd' |
| pidFile = '/run/dhcp-server/dhcpd.pid' |
| configFile = './dhcpd.conf' |
| |
| def config(self, **kwargs): |
| super(TaggedDhcpServer, self).config(**kwargs) |
| self.cmd('%s -q -4 -pf %s -cf %s %s' % (self.binFile, self.pidFile, self.configFile, self.vlanIntf)) |
| |
| def terminate(self, **kwargs): |
| self.cmd('kill -9 `cat %s`' % self.pidFile) |
| self.cmd('rm -rf %s' % self.pidFile) |
| super(TaggedDhcpServer, self).terminate() |
| |
| if __name__ == "__main__": |
| setLogLevel('debug') |
| topo = Trellis() |
| |
| net = Mininet(topo=topo, controller=None) |
| net.addController(RemoteController('c0', ip='192.168.56.11')) |
| net.addController(RemoteController('c1', ip='192.168.56.12')) |
| net.addController(RemoteController('c2', ip='192.168.56.13')) |
| |
| net.start() |
| CLI(net) |
| net.stop() |