#!/usr/bin/env python from mininet.net import Mininet from mininet.node import UserSwitch, DefaultController, RemoteController, Host from mininet.topo import Topo from mininet.log import setLogLevel, info from mininet.cli import CLI from mininet.link import OVSIntf from opticalUtils import LINCSwitch, LINCLink class Domain(object): """ A container for switch, host, link, and controller information to be dumped into the Mininet mid-level API. """ def __init__ (self, did=0): # each Domain has a numeric ID for sanity/convenience self.__dId = did # information about network elements - for calling the "mid-level" APIs self.__ctrls = {} self.__switches = {} self.__hosts = {} self.__links = {} # maps of devices, hosts, and controller names to actual objects self.__smap = {} self.__hmap = {} self.__cmap = {} def addController(self, name, **args): self.__ctrls[name] = args if args else {} return name def addSwitch(self, name, **args): self.__switches[name] = args if args else {} return name def addHost(self, name, **args): self.__hosts[name] = args if args else {} return name def addLink(self, src, dst, **args): self.__links[(src, dst)] = args if args else {} return (src, dst) def getId( self): return self.__dId def getControllers(self, name=None): return self.__cmap.values() if not name else self.__cmap.get(name) def getSwitches(self, name=None): return self.__smap.values() if not name else self.__smap.get(name) def getHosts(self, name=None): return self.__hmap.values() if not name else self.__hmap.get(name) def injectInto(self, net): """ Adds available topology info to a supplied Mininet object. """ # add switches, hosts, then links to mininet object for sw, args in self.__switches.iteritems(): self.__smap[sw] = net.addSwitch(sw, **args) for h, args in self.__hosts.iteritems(): self.__hmap[h] = net.addHost(h, **args) for l, args in self.__links.iteritems(): src = self.__smap.get(l[0]) dst = self.__smap.get(l[1]) net.addLink(src if src else self.__hmap.get(l[0]), dst if dst else self.__hmap.get(l[1]), **args) # then controllers for c, args in self.__ctrls.iteritems(): self.__cmap[c] = net.addController(c, **args) def start(self): """ starts the switches with the correct controller. """ map(lambda c: c.start(), self.__cmap.values()) map(lambda s: s.start(self.__cmap.values()), self.__smap.values()) def build(self, *args): """ override for custom topology, similar to Topo """ pass class OpticalDomain(Domain): """ An emulated optical metro core. It is Domain 0. """ def build(self): oean = { "optical.regens": 0 } for i in range (1,4): self.addSwitch('OE%s' % i, dpid='0000ffffffffff0%s' % i, annotations=oean, cls=LINCSwitch) an = { "optical.waves": 80, "optical.type": "WDM", "optical.kms": 1000, "durable": "true" } self.addLink('OE1', 'OE2', port1=50, port2=30, annotations=an, cls=LINCLink) self.addLink('OE2', 'OE3', port1=50, port2=30, annotations=an, cls=LINCLink) self.addLink('OE3', 'OE1', port1=50, port2=30, annotations=an, cls=LINCLink) class FabricDomain(Domain): """ An emulated CO fabric, which is basically a K(n,m) bipartite graph. Each FabricDomain should be given a unique Domain ID (did) to ensure unique names and addressing. """ def __init__(self, did): Domain.__init__(self, did) def build(self, n=2, m=3, f=2): # K(n,m) in bipartite graph l_nsw=[] l_msw=[] # create n spine switches for sw in range(n): l_nsw.append(self.addSwitch('swn%s%s' % (self.getId(), sw+1), cls=UserSwitch)) # create connection point to optical core (a leaf switch) tsw = self.addSwitch('swm%s01' % self.getId(), cls=UserSwitch) self.addTether(tsw, 'sw000%s' % self.getId(), '0000ffffffff000%s' % self.getId()) l_msw.append(tsw) # attach f hosts to last m-1 leaves for sw in range(1, m): msw = self.addSwitch('swm%s0%s' % (self.getId(), sw+1), cls=UserSwitch) l_msw.append(msw) for h in range(f): host = self.addHost('h%s%s' % (self.getId(), sw * f+h+1), cls=IpHost, ip='10.0.%s.%s/24' % ((self.getId()+sw+1), (f+1)), gateway='10.0.%s.254' % (self.getId()+sw+1)) self.addLink(host, msw) # link up spines and leaves for nsw in l_nsw: for msw in l_msw: self.addLink(nsw, msw) def addTether(self, name, tname, tdpid): """ add an OVS with name 'tname' and dpid 'tdpid' for connecting fabric domains to the core. name: the UserSwitch to connect the OVS to. """ self.__tether = self.addSwitch(tname, dpid=tdpid) self.addLink(tname, name, port1=1) def getTether(self): """ get connection point of this fabric to the core """ return self.__tether class IpHost(Host): def __init__(self, name, gateway, *args, **kwargs): super(IpHost, self).__init__(name, *args, **kwargs) self.gateway = gateway def config(self, **kwargs): Host.config(self, **kwargs) mtu = "ifconfig "+self.name+"-eth0 mtu 1490" self.cmd(mtu) self.cmd('ip route add default via %s' % self.gateway) # fixed port numbers for attachment points (APs) between CORD and metro domains OVS_AP=2 OE_AP=10 def setup(argv): domains = [] ctlsets = sys.argv[1:] # the controllers for the optical domain d0 = OpticalDomain() domains.append(d0) ctls = ctlsets[0].split(',') for i in range (len(ctls)): d0.addController('c0%s' % i, controller=RemoteController, ip=ctls[i]) # the fabric domains - position 1 for domain 1, 2 for 2 ... for i in range (1,len(ctlsets)): f = FabricDomain(i) domains.append(f) ctls = ctlsets[i].split(',') for j in range (len(ctls)): f.addController('c%s%s' % (i,j), controller=RemoteController, ip=ctls[j]) # make/setup Mininet object net = Mininet() for d in domains: d.build() d.injectInto(net) # connect COs to core - sort of hard-wired at this moment for i in range(1,len(domains)): an = { "bandwidth": 100000, "optical.type": "cross-connect", "durable": "true" } net.addLink(domains[i].getTether(), d0.getSwitches('OE%s' % i), port1=OVS_AP, port2=OE_AP, speed=10000, annotations=an, cls=LINCLink) # fire everything up net.build() map(lambda x: x.start(), domains) # create a minimal copy of the network for configuring LINC. cfgnet = Mininet() cfgnet.switches = net.switches cfgnet.links = net.links cfgnet.controllers = d0.getControllers() LINCSwitch.bootOE(cfgnet, d0.getSwitches()) CLI(net) net.stop() LINCSwitch.shutdownOE() if __name__ == '__main__': setLogLevel('info') import sys if len(sys.argv) < 5: print ("Usage: sudo -E ./metro.py ctl-set1 ... ctl-set4\n\n", "Where ctl-set are comma-separated controller IP's") else: setup(sys.argv)