How can I run custom topology mininet enabled sflow-rt ?

[최홍준]

Hi All,

I just read a article about how to enabling sflow-rt on mininet. ( http://blog.sflow.com/2016/05/mininet-flow-analytics.html )

In this guide, there is a sample python script named "sflow.py" 

But I want to run my own custom topology on mininet with sflow-rt. So I add my topo dictionary code to sflow.py

I works, and pingings inter-switchs are fine. (mn> s1 ping s2 )

But pingings host to other device (including switch and host both) are fails. (mn > h1 ping s2 )

How can I fix it?

How can I run custom topology mininet enabled sflow-rt ?

Here is my python script with custom topology. 

thank you so much.

from mininet.net import Mininet

from mininet.util import quietRun

from requests import put

from json import dumps

from subprocess import call, check_output

from os import listdir

import re

import socket

#-=======================================\\\\\\\\\\\

from mininet.topo import Topo

from mininet.net import Mininet

from mininet.util import irange,dumpNodeConnections

from mininet.log import setLogLevel

class SingleTopo(Topo):

  def __init__(self, **opts):

    super(SingleTopo, self).__init__(**opts)

    # Create Swtichs

    '''

    switch_list = []

    for i in range(1,4+1):

      switch = self.addSwitch('s%s' % i)

      switch_list.append(switch)

      print switch_list

    '''

    switch1 = self.addSwitch('s1')

    switch2 = self.addSwitch('s2')

    switch3 = self.addSwitch('s3')

    switch4 = self.addSwitch('s4')

    switch_list = [switch1,switch2,switch3,switch4]

    # And inter-switch links 

    self.addLink(switch_list[0],switch_list[1])

    self.addLink(switch_list[0],switch_list[2])

    self.addLink(switch_list[3],switch_list[1])

    self.addLink(switch_list[3],switch_list[2])

    # Create Hosts and links

    host1 = self.addHost('h1')

    self.addLink(host1, switch1)

    host2 = self.addHost('h2')

    self.addLink(host2, switch4)

    print "singleTopo Done"

  def run(self):

    net = Mininet(self)

    net.start()

topos = { 'mytopo': ( lambda: SingleTopo() ) }

#-=======================================////////

collector = '127.0.0.1'

sampling = 10

polling = 10

def getIfInfo(ip):

  s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

  s.connect((ip, 0))

  ip = s.getsockname()[0]

  ifconfig = check_output(['ifconfig'])

  ifs = re.findall(r'^(\S+).*?inet addr:(\S+).*?', ifconfig, re.S|re.M)

  for entry in ifs:

    if entry[1] == ip:

      return entry

def configSFlow(net,collector,ifname):

  print "*** Enabling sFlow:"

  sflow = 'ovs-vsctl -- --id=@sflow create sflow agent=%s target=%s sampling=%s polling=%s --' % (ifname,collector,sampling,polling)

  for s in net.switches:

    sflow += ' -- set bridge %s sflow=@sflow' % s

  print ' '.join([s.name for s in net.switches])

  quietRun(sflow)

def sendTopology(net,agent,collector):

  print "*** Sending topology"

  topo = {'nodes':{}, 'links':{}}

  for s in net.switches:

    topo['nodes'][s.name] = {'agent':agent, 'ports':{}}

  path = '/sys/devices/virtual/net/'

  for child in listdir(path):

    parts = re.match('(^s[0-9]+)-(.*)', child)

    if parts == None: continue

    ifindex = open(path+child+'/ifindex').read().split('\n',1)[0]

    topo['nodes'][parts.group(1)]['ports'][child] = {'ifindex': ifindex}

  i = 0

  for s1 in net.switches:

    j = 0

    for s2 in net.switches:

      if j > i:

        intfs = s1.connectionsTo(s2)

        for intf in intfs:

          s1ifIdx = topo['nodes'][s1.name]['ports'][intf[0].name]['ifindex']

          s2ifIdx = topo['nodes'][s2.name]['ports'][intf[1].name]['ifindex']

          linkName = '%s-%s' % (s1.name, s2.name)

          topo['links'][linkName] = {'node1': s1.name, 'port1': intf[0].name, 'node2': s2.name, 'port2': intf[1].name}

      j += 1

    i += 1

  put('http://'+collector+':8008/topology/json',data=dumps(topo))

def wrapper(fn,collector):

  def result( *args, **kwargs):

    res = fn( *args, **kwargs)

    net = args[0]

    (ifname, agent) = getIfInfo(collector)

    configSFlow(net,collector,ifname)

    sendTopology(net,agent,collector) 

    return res

  return result

setattr(Mininet, 'start', wrapper(Mininet.__dict__['start'], collector))

  

 

[Peter Phaal]

Does your custom topology work as expected if you don't include the
sflow.py code? If not, this is a Mininet question and you are more
likely to get an answer on the Mininet mailing list.

What version of Mininet are you using? Version 2.2 allows multiple
comma separated files to be included on the custom line, e.g.

sudo mn --custom mytopo.py,extras/sflow.py --link tc,bw=10 --topo mytopo

> --
> You received this message because you are subscribed to the Google Groups
> "sFlow-RT" group.
> To unsubscribe from this group and stop receiving emails from it, send an
> email to sflow-rt+u...@googlegroups.com.
> For more options, visit https://groups.google.com/d/optout.