Added small multicast topology
diff --git a/mcast.py b/mcast.py
new file mode 100755
index 0000000..bc5c7a6
--- /dev/null
+++ b/mcast.py
@@ -0,0 +1,100 @@
+#!/usr/bin/python
+
+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, OVSSwitch, UserSwitch
+from mininet.nodelib import NAT
+from routinglib import QuaggaRouter
+from routinglib import BgpProtocol, OspfProtocol
+from routinglib import RoutedNetwork, RoutedHost, Router
+from ipaddress import ip_network
+from routinglib import PimProtocol
+
+#onosIps = ['192.168.56.11']
+
+cordOnos = '192.168.56.12'
+fabricOnos = '192.168.56.11'
+
+c0 = RemoteController( 'c0', ip=fabricOnos )
+c1 = RemoteController( 'c1', ip=cordOnos )
+
+cmap = { 's1': c0, 's2': c1 }
+
+class MultiSwitch( UserSwitch ):
+ "Custom Switch() subclass that connects to different controllers"
+ def start( self, controllers ):
+ return UserSwitch.start( self, [ cmap[ self.name ] ] )
+
+class MulticastTopo( Topo ):
+ """Topology for testing multicast in CORD.
+ Contains two switches:
+ (1) stand-in for the OLT, where the IGMP snooping will happen
+ (2) vRouter/fabric leaf where the PIM to upstream happens"""
+
+ def __init__( self, *args, **kwargs ):
+ Topo.__init__( self, *args, **kwargs )
+
+ QuaggaRouter.binDir='/home/jono/shared/quagga/build/bin'
+
+ # vRouter switch
+ s1 = self.addSwitch('s1', dpid='1')
+ # IGMP switch
+ s2 = self.addSwitch('s2', dpid='2')
+
+ eth0 = { 'ipAddrs' : ['10.0.3.1/24'] }
+ eth1 = { 'ipAddrs' : ['10.0.2.254/24']}
+ intfs = {'r1-eth0' : eth0,
+ 'r1-eth1' : eth1}
+
+ pim = PimProtocol(configFile='configs/pim.conf')
+ #bgp = BgpProtocol(asNum=65001, neighbors=[{'address' : '10.0.3.2', 'as' : 65000}], routes=['10.0.2.0/24'])
+ ospf = OspfProtocol()
+ r1 = self.addHost('r1', interfaces=intfs, cls=QuaggaRouter,
+ protocols=[pim, ospf])
+
+ self.addLink(r1, s1)
+
+ RoutedNetwork.build(self, r1, 'h1', [ip_network(u'10.0.2.0/24')])
+
+
+ cpintfs = {'cp1-eth0' : { 'mac' : '00:00:00:00:00:01', 'ipAddrs' : ['10.0.3.2/24', '10.0.1.100/24'] },
+ 'cp1-eth1' : { 'ipAddrs' : ['1.1.1.1/24']} }
+ #bgp = BgpProtocol(asNum=65000, neighbors=[{'address' : '10.0.3.1', 'as': 65001}])
+ ospf = OspfProtocol()
+ cp1 = self.addHost('cp1', cls=QuaggaRouter, interfaces=cpintfs, protocols=[ospf],
+ fpm=fabricOnos, defaultRoute='1.1.1.254')
+ #cp1 = self.addHost('cp1', cls=Router, ips=['10.0.3.2/24'], mac='00:00:00:00:00:01')
+
+ nat = self.addHost('nat', cls=NAT,
+ ip='1.1.1.254/24',
+ subnet='1.1.1.0/24', inNamespace=False);
+ self.addLink(cp1, s1)
+ self.addLink(cp1, nat)
+
+ h2 = self.addHost('h2', ip="10.0.1.1/24", defaultRoute="via 10.0.1.254", mac="00:00:00:00:00:02", inNamespace=True)
+ self.addLink(h2, s2)
+ self.addLink(s2, s1)
+
+if __name__ == "__main__":
+ setLogLevel('debug')
+ topo = MulticastTopo()
+
+ net = Mininet(topo=topo, switch=MultiSwitch, controller=None)
+
+ net.addController(c0)
+ net.addController(c1)
+
+ h2 = net.get('h2')
+ h2.cmd('ethtool --offload h2-eth0 tx off')
+ r1 = net.get('r1')
+ r1.cmd('ethtool --offload r1-eth0 tx off')
+ cp1 = net.get('cp1')
+ cp1.cmd('ethtool --offload cp1-eth0 tx off')
+
+ net.start()
+
+ CLI(net)
+
+ net.stop()