Hello everyone,

I hope you all are doing well. Apologies for the long post.

I am Rinkal, currently writing my masters thesis. I have a query related to
traffic generation using iperf3 in Mininet. This might not be entirely
related to iperf but i am in need of a solution as I am not able to
understand what actually is the problem.

For the background:
I have a custom mininet topology (the code is given below) which is running
with ryu controller and I need to send traffic from all hosts to a single
server to analyze the throughput and delay parameters.

I am running ryu controller using command : ryu-manager
ryu.app.simple_switch_stp_13 ryu.app.ofctl_rest
and mininet custom topology using command : sudo mn --custom ./ryu/topo.py
--topo=mytopo --mac --link=tc --switch ovs,protocols=OpenFlow13
--controller remote

Everything is pinging and running fine. Using xterm I have tried to send
traffic to the server host in the topology from all the hosts(mobile
stations) at the same time using iperf3 in mininet but unfortunately I am
not able to do it as the second host does not send the traffic when the
first one is sending. I did try it without giving any bandwidth on the
links but it is still the same.

If someone can help me through this it would be a great help in my thesis.
I will be extremely grateful. Please find the code below.

Best Regards
Rinkal Poriya


Mininet Custom Topology Code :

from mininet.net import Mininet
from mininet.topo import Topo
from mininet.link import TCLink
from mininet.node import Controller, OVSSwitch, UserSwitch, RemoteController
from mininet.log import setLogLevel, info

class MyTopo( Topo ):

    def __init__( self ):

        Topo.__init__( self )

        H1 = self.addHost( 'MS1', ip="10.0.0.1", mac='00:00:00:00:00:aa')
        H2 = self.addHost( 'MS2', ip="10.0.0.2", mac='00:00:00:00:00:bb')
        H3 = self.addHost( 'MS3', ip="10.0.0.3", mac='00:00:00:00:00:cc')
        H4 = self.addHost( 'MS4', ip="10.0.0.4", mac='00:00:00:00:00:dd')
        H5 = self.addHost( 'MS5', ip="10.0.0.5", mac='00:00:00:00:00:ee')
        H6 = self.addHost( 'MS6', ip="10.0.0.6", mac='00:00:00:00:00:ff')
        H7 = self.addHost( 'MS7', ip="10.0.0.7", mac='00:00:00:00:00:gg')
        H8 = self.addHost( 'MS8', ip="10.0.0.8", mac='00:00:00:00:00:hh')
        H9 = self.addHost( 'MS9', ip="10.0.0.9", mac='00:00:00:00:00:ii')
        H10 = self.addHost('MS10', ip="10.0.0.10", mac='00:00:00:00:00:jj')

        server = self.addHost('server', ip="10.0.0.100",
mac='00:00:00:00:00:kk')

        b1 = self.addSwitch( 'bts1', cls=OVSSwitch, mac='00:00:00:00:00:01')
        b2 = self.addSwitch( 'bts2', cls=OVSSwitch, mac='00:00:00:00:00:02')
        b3 = self.addSwitch( 'bts3', cls=OVSSwitch, mac='00:00:00:00:00:03')
        b4 = self.addSwitch( 'bts4', cls=OVSSwitch, mac='00:00:00:00:00:04')
        b5 = self.addSwitch( 'bts5', cls=OVSSwitch, mac='00:00:00:00:00:05')


        s1 = self.addSwitch('s1', dpid='6001', cls=OVSSwitch,
mac='00:00:00:00:00:06')
        s2 = self.addSwitch('s2', dpid='7001', cls=OVSSwitch,
mac='00:00:00:00:00:07')
        s3 = self.addSwitch('s3', dpid='8001', cls=OVSSwitch,
mac='00:00:00:00:00:08')
        s4 = self.addSwitch('s4', dpid='9001', cls=OVSSwitch,
mac='00:00:00:00:00:09')
        s5 = self.addSwitch('s5', dpid='1010', cls=OVSSwitch,
mac='00:00:00:00:00:10')

        s0 = self.addSwitch('s0', dpid='1111', cls=OVSSwitch,
mac='00:00:00:00:00:11')
        s6 = self.addSwitch('s6', dpid='1212', cls=OVSSwitch,
mac='00:00:00:00:00:12')


        self.addLink( H1, b1, cls=TCLink, bw=15)
        self.addLink( H2, b1, cls=TCLink, bw=15)
        self.addLink( H3, b2, cls=TCLink, bw=15)
        self.addLink( H4, b2, cls=TCLink, bw=15)
        self.addLink( H5, b3, cls=TCLink, bw=15)
        self.addLink( H6, b3, cls=TCLink, bw=15)
        self.addLink( H7, b4, cls=TCLink, bw=15)
        self.addLink( H8, b4, cls=TCLink, bw=15)
        self.addLink( H9, b5, cls=TCLink, bw=15)
        self.addLink( H10, b5, cls=TCLink, bw=15)

        self.addLink( b1, b2, cls=TCLink, bw=20)
        self.addLink( b2, b3, cls=TCLink, bw=20)
        self.addLink( b3, b4, cls=TCLink, bw=20)
        self.addLink( b4, b5, cls=TCLink, bw=20)
        self.addLink( b5, b1, cls=TCLink, bw=20)

        self.addLink(b1, s1, cls=TCLink, bw=40)
        self.addLink(b2, s2, cls=TCLink, bw=40)
        self.addLink(b3, s3, cls=TCLink, bw=40)
        self.addLink(b4, s4, cls=TCLink, bw=40)
        self.addLink(b5, s5, cls=TCLink, bw=40)

        self.addLink(s1, s0, cls=TCLink, bw=50)
        self.addLink(s2, s0, cls=TCLink, bw=50)
        self.addLink(s3, s0, cls=TCLink, bw=50)
        self.addLink(s4, s0, cls=TCLink, bw=50)
        self.addLink(s5, s0, cls=TCLink, bw=50)

        self.addLink(s0, s6, cls=TCLink, bw=50)
        self.addLink(s6, server, cls=TCLink, bw=100)


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

if __name__ == '__main__':
    setLogLevel('info')



However, I am not able to send
_______________________________________________
Iperf-users mailing list
Iperf-users@lists.sourceforge.net
https://lists.sourceforge.net/lists/listinfo/iperf-users

Reply via email to