Bob Lantz
ee15ce2243
Although we could use print() from __future__, this messes up scripts which use examples as modules. The simple, if not nicest for 2.7, solution is to use info(), output() and other mininet.log functions. The disadvantage is that we may have to adjust things if we change info() to add automatic newlines, but we can burn that bridge in Mininet 3.x.
126 lines
3.9 KiB
Python
Executable File
126 lines
3.9 KiB
Python
Executable File
#!/usr/bin/python
|
|
|
|
"""
|
|
Test bandwidth (using iperf) on linear networks of varying size,
|
|
using both kernel and user datapaths.
|
|
|
|
We construct a network of N hosts and N-1 switches, connected as follows:
|
|
|
|
h1 <-> s1 <-> s2 .. sN-1
|
|
| | |
|
|
h2 h3 hN
|
|
|
|
WARNING: by default, the reference controller only supports 16
|
|
switches, so this test WILL NOT WORK unless you have recompiled
|
|
your controller to support 100 switches (or more.)
|
|
|
|
In addition to testing the bandwidth across varying numbers
|
|
of switches, this example demonstrates:
|
|
|
|
- creating a custom topology, LinearTestTopo
|
|
- using the ping() and iperf() tests from Mininet()
|
|
- testing both the kernel and user switches
|
|
|
|
"""
|
|
|
|
|
|
from mininet.net import Mininet
|
|
from mininet.node import UserSwitch, OVSKernelSwitch, Controller
|
|
from mininet.topo import Topo
|
|
from mininet.log import lg, info
|
|
from mininet.util import irange, quietRun
|
|
from mininet.link import TCLink
|
|
from functools import partial
|
|
|
|
import sys
|
|
flush = sys.stdout.flush
|
|
|
|
class LinearTestTopo( Topo ):
|
|
"Topology for a string of N hosts and N-1 switches."
|
|
|
|
def __init__( self, N, **params ):
|
|
|
|
# Initialize topology
|
|
Topo.__init__( self, **params )
|
|
|
|
# Create switches and hosts
|
|
hosts = [ self.addHost( 'h%s' % h )
|
|
for h in irange( 1, N ) ]
|
|
switches = [ self.addSwitch( 's%s' % s )
|
|
for s in irange( 1, N - 1 ) ]
|
|
|
|
# Wire up switches
|
|
last = None
|
|
for switch in switches:
|
|
if last:
|
|
self.addLink( last, switch )
|
|
last = switch
|
|
|
|
# Wire up hosts
|
|
self.addLink( hosts[ 0 ], switches[ 0 ] )
|
|
for host, switch in zip( hosts[ 1: ], switches ):
|
|
self.addLink( host, switch )
|
|
|
|
|
|
def linearBandwidthTest( lengths ):
|
|
|
|
"Check bandwidth at various lengths along a switch chain."
|
|
|
|
results = {}
|
|
switchCount = max( lengths )
|
|
hostCount = switchCount + 1
|
|
|
|
switches = { 'reference user': UserSwitch,
|
|
'Open vSwitch kernel': OVSKernelSwitch }
|
|
|
|
# UserSwitch is horribly slow with recent kernels.
|
|
# We can reinstate it once its performance is fixed
|
|
del switches[ 'reference user' ]
|
|
|
|
topo = LinearTestTopo( hostCount )
|
|
|
|
# Select TCP Reno
|
|
output = quietRun( 'sysctl -w net.ipv4.tcp_congestion_control=reno' )
|
|
assert 'reno' in output
|
|
|
|
for datapath in switches.keys():
|
|
info( "*** testing", datapath, "datapath\n" )
|
|
Switch = switches[ datapath ]
|
|
results[ datapath ] = []
|
|
link = partial( TCLink, delay='1ms' )
|
|
net = Mininet( topo=topo, switch=Switch,
|
|
controller=Controller, waitConnected=True,
|
|
link=link )
|
|
net.start()
|
|
info( "*** testing basic connectivity\n" )
|
|
for n in lengths:
|
|
net.ping( [ net.hosts[ 0 ], net.hosts[ n ] ] )
|
|
info( "*** testing bandwidth\n" )
|
|
for n in lengths:
|
|
src, dst = net.hosts[ 0 ], net.hosts[ n ]
|
|
# Try to prime the pump to reduce PACKET_INs during test
|
|
# since the reference controller is reactive
|
|
src.cmd( 'telnet', dst.IP(), '5001' )
|
|
info( "testing", src.name, "<->", dst.name, '\n' )
|
|
bandwidth = net.iperf( [ src, dst ], seconds=10 )
|
|
info( bandwidth, '\n' )
|
|
flush()
|
|
results[ datapath ] += [ ( n, bandwidth ) ]
|
|
net.stop()
|
|
|
|
for datapath in switches.keys():
|
|
info( "\n*** Linear network results for", datapath, "datapath:\n" )
|
|
result = results[ datapath ]
|
|
info( "SwitchCount\tiperf Results\n" )
|
|
for switchCount, bandwidth in result:
|
|
info( switchCount, '\t\t' )
|
|
info( bandwidth[ 0 ], 'server, ', bandwidth[ 1 ], 'client\n' )
|
|
info( '\n')
|
|
info( '\n' )
|
|
|
|
if __name__ == '__main__':
|
|
lg.setLogLevel( 'info' )
|
|
sizes = [ 1, 10, 20, 40, 60, 80 ]
|
|
info( "*** Running linearBandwidthTest", sizes, '\n' )
|
|
linearBandwidthTest( sizes )
|