lantz
88f14e946a
Including changes to mnexec -c to reduce the number of close() system calls, which may help with performance in containers on Ubuntu 22.04. Note that systemd-udevd also seems to be a cause of performance issues and should probably be disabled while running Mininet. Adding dbeug logging to test_simpleperf because it is failing intermittently. (Note with packet loss it can fail, but this is not how we should be testing it.)
68 lines
2.1 KiB
Python
Executable File
68 lines
2.1 KiB
Python
Executable File
#!/usr/bin/env python
|
|
|
|
"""
|
|
Simple example of setting network and CPU parameters
|
|
|
|
NOTE: link params limit BW, add latency, and loss.
|
|
There is a high chance that pings WILL fail and that
|
|
iperf will hang indefinitely if the TCP handshake fails
|
|
to complete.
|
|
"""
|
|
|
|
from sys import argv
|
|
|
|
from mininet.topo import Topo
|
|
from mininet.net import Mininet
|
|
from mininet.node import CPULimitedHost
|
|
from mininet.link import TCLink
|
|
from mininet.util import dumpNodeConnections
|
|
from mininet.log import setLogLevel, info
|
|
|
|
|
|
# It would be nice if we didn't have to do this:
|
|
# pylint: disable=arguments-differ
|
|
|
|
class SingleSwitchTopo( Topo ):
|
|
"Single switch connected to n hosts."
|
|
def build( self, n=2, lossy=True ):
|
|
switch = self.addSwitch('s1')
|
|
for h in range(n):
|
|
# Each host gets 50%/n of system CPU
|
|
host = self.addHost('h%s' % (h + 1),
|
|
cpu=.5 / n)
|
|
if lossy:
|
|
# 10 Mbps, 5ms delay, 10% packet loss
|
|
self.addLink(host, switch,
|
|
bw=10, delay='5ms', loss=10, use_htb=True)
|
|
else:
|
|
# 10 Mbps, 5ms delay, no packet loss
|
|
self.addLink(host, switch,
|
|
bw=10, delay='5ms', loss=0, use_htb=True)
|
|
|
|
|
|
def perfTest( lossy=True ):
|
|
"Create network and run simple performance test"
|
|
topo = SingleSwitchTopo( n=4, lossy=lossy )
|
|
net = Mininet( topo=topo,
|
|
host=CPULimitedHost, link=TCLink,
|
|
autoStaticArp=True )
|
|
net.start()
|
|
info( "Dumping host connections\n" )
|
|
dumpNodeConnections(net.hosts)
|
|
info( "Testing bandwidth between h1 and h4 (lossy=%s)\n" % lossy )
|
|
h1, h4 = net.getNodeByName('h1', 'h4')
|
|
net.iperf( ( h1, h4 ), l4Type='UDP' )
|
|
# Debugging
|
|
h1.cmd('jobs')
|
|
h4.cmd('jobs')
|
|
net.stop()
|
|
|
|
|
|
if __name__ == '__main__':
|
|
setLogLevel( 'info' )
|
|
# Debug for now
|
|
if 'testmode' in argv:
|
|
setLogLevel( 'debug' )
|
|
# Prevent test_simpleperf from failing due to packet loss
|
|
perfTest( lossy=( 'testmode' not in argv ) )
|