lab/mininet
1
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

Add seconds option to iperf()

Browse Source
This commit is contained in:
Bob Lantz
2014-11-10 12:37:54 -08:00
parent 481cbea10c
commit d3377bf911
1 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
mininet/net.py
+8 -4
View File
@@ -697,11 +697,15 @@ class Mininet( object ):
# XXX This should be cleaned up # XXX This should be cleaned up
def iperf( self, hosts=None, l4Type='TCP', udpBw='10M', format=None ): def iperf( self, hosts=None, l4Type='TCP', udpBw='10M', format=None,
seconds=5):
"""Run iperf between two hosts. """Run iperf between two hosts.
hosts: list of hosts; if None, uses opposite hosts hosts: list of hosts; if None, uses opposite hosts
l4Type: string, one of [ TCP, UDP ] l4Type: string, one of [ TCP, UDP ]
returns: results two-element array of [ server, client ] speeds udpBw: bandwidth target for UDP test
format: iperf format argument if any
seconds: iperf time to transmit
returns: two-element array of [ server, client ] speeds
note: send() is buffered, so client rate can be much higher than note: send() is buffered, so client rate can be much higher than
the actual transmission rate; on an unloaded system, server the actual transmission rate; on an unloaded system, server
rate should be much closer to the actual receive rate""" rate should be much closer to the actual receive rate"""
@@ -734,8 +738,8 @@ class Mininet( object ):
'sh -c "echo A | telnet -e A %s 5001"' % server.IP()): 'sh -c "echo A | telnet -e A %s 5001"' % server.IP()):
info( 'Waiting for iperf to start up...' ) info( 'Waiting for iperf to start up...' )
sleep(.5) sleep(.5)
cliout = client.cmd( iperfArgs + '-t 5 -c ' + server.IP() + ' ' + cliout = client.cmd( iperfArgs + '-t %d -c ' % seconds +
bwArgs ) server.IP() + ' ' + bwArgs )
debug( 'Client output: %s\n' % cliout ) debug( 'Client output: %s\n' % cliout )
server.sendInt() server.sendInt()
servout += server.waitOutput() servout += server.waitOutput()