Changes between Version 2 and Version 3 of GENIFIRE/Labwiki/Part0/DesignSetup

Timestamp:

07/07/14 04:42:08 (10 years ago)

Author:

divyashri.bhat@gmail.com

Comment:

--

GENIFIRE/Labwiki/Part0/DesignSetup

@@ -34 +34 @@
 
 
+=== 2.5 Complete OEDL script ===
+
+{{{
+defProperty('source1', "client-lwtest6", "ID of a resource")
+defProperty('thelistener', "server-lwtest6", "ID of a resource")
+defProperty('thesender', "client-lwtest6", "ID of a resource")
+defProperty('thesender2', "client-lwtest6", "ID of a resource")
+defProperty('interfaceServer', "eth3", 'server interface to modify')
+defProperty('capacity', 10000000, 'in bits per second')
+
+defProperty('sinkaddr11', '10.0.5.102', "Ping destination address")
+defProperty('sinkaddr12', '10.0.5.101', "Ping destination address")
+
+defApplication('iperf') do |app| 
+  app.description = 'Iperf traffic generator and bandwidth measurement tool'
+  app.binary_path = "/usr/bin/iperf-oml2"
+
+  app.defProperty('server', 'run in server mode', '-s',
+                  :type => :boolean)
+
+  app.defProperty('client', 'run in client mode, connecting to <host>', '-c',
+                  :type => :string,
+                  :order => 1)
+
+  app.defMeasurement("transfer"){ |m|
+    m.defMetric('pid', :integer, 'Main process identifier')
+    m.defMetric('connection_id', :integer, 'Connection identifier (socket)')
+    m.defMetric('begin_interval', :double, 'Start of the averaging interval (Iperf timestamp)')
+    m.defMetric('end_interval', :double, 'End of the averaging interval (Iperf timestamp)')
+    m.defMetric('size', :uint64, 'Amount of transmitted data [Bytes]')
+  }
+   app.defMeasurement("connection"){ |m|
+    m.defMetric('pid', :integer, 'Main process identifier')
+    m.defMetric('connection_id', :integer, 'Connection identifier (socket)')
+    m.defMetric('local_address', :string, 'Local network address')
+    m.defMetric('local_port', :integer, 'Local port')
+    m.defMetric('remote_address', :string, 'Remote network address')
+    m.defMetric('remote_port', :integer, 'Remote port')
+  }
+
+end
+
+
+defApplication('ping') do |app|
+  app.description = 'Simple Definition for the ping-oml2 application'
+  # Define the path to the binary executable for this application
+  app.binary_path = '/usr/local/bin/ping-oml2'
+  # Define the configurable parameters for this application
+  # For example if target is set to foo.com and count is set to 2, then the 
+  # application will be started with the command line:
+  # /usr/bin/ping-oml2 -a foo.com -c 2
+  app.defProperty('target', 'Address to ping', '-a', {:type => :string})
+  app.defProperty('count', 'Number of times to ping', '-c', {:type => :integer})
+  # Define the OML2 measurement point that this application provides.
+  # Here we have only one measurement point (MP) named 'ping'. Each measurement
+  # sample from this MP will be composed of a 4-tuples (addr,ttl,rtt,rtt_unit)
+  app.defMeasurement('ping') do |m|
+    m.defMetric('dest_addr',:string)
+    m.defMetric('ttl',:uint32)
+    m.defMetric('rtt',:double)
+    m.defMetric('rtt_unit',:string)
+  end
+end
+defGroup('Source1', property.source1) do |node|
+  node.addApplication("ping") do |app|
+    app.setProperty('target', property.sinkaddr12)
+    app.setProperty('count', 40)
+    #app.setProperty('interval', 1)
+    app.measure('ping', :samples => 1)
+  end
+end
+defGroup('theReceiver', property.thelistener) do |node|
+  node.addApplication("iperf") do |app|
+    app.setProperty('server', true)
+    app.measure('transfer', :samples => 1)
+    app.measure('connection', :samples => 1)
+  end
+end
+
+defGroup('theSender', property.thesender) do |node|
+  node.addApplication("iperf") do |app|
+    app.setProperty('client', property.sinkaddr12)
+    #app.measure('transfer', :samples => 1)
+  end
+end
+defGroup('theSender2', property.thesender2) do |node|
+  node.addApplication("iperf") do |app|
+    app.setProperty('client', property.sinkaddr12)
+    #app.measure('transfer', :samples => 1)
+  end
+end
+
+
+
+onEvent(:ALL_UP_AND_INSTALLED) do |event|
+  info(" ------ Setup Traffic Shaping")
+  group("theReceiver").exec("/sbin/modprobe sch_netem")
+  group("theReceiver").exec("/sbin/modprobe ifb numifbs=10")
+  group("theReceiver").exec("/sbin/sysctl -w net.core.rmem_max=8388608") 
+  group("theReceiver").exec("/sbin/sysctl -w net.core.wmem_max=8388608") 
+  group("theReceiver").exec("/sbin/sysctl -w net.core.netdev_max_backlog=2048") 
+  #group("theReceiver").exec("/sbin/ifconfig #{prop.interfaceServer} txqueuelen") 
+  group("theReceiver").exec("/sbin/tc qdisc del dev #{prop.interfaceServer} root") 
+  group("theReceiver").exec("/sbin/tc qdisc del dev #{prop.interfaceServer} ingress") 
+  group("theReceiver").exec("/sbin/tc qdisc add dev #{prop.interfaceServer} handle 130 root htb default 1") 
+  group("theReceiver").exec("/sbin/tc class add dev #{prop.interfaceServer} classid 130:1 parent 130 htb rate #{prop.capacity.to_s} ceil #{prop.capacity.to_s}") 
+  group("theReceiver").exec("/sbin/tc qdisc add dev #{prop.interfaceServer} handle 120 parent 130:1 netem drop 0 delay 0us")
+  after 2 do 
+    group('theReceiver').startApplications
+  end
+  after 5 do
+    group('theSender').startApplications
+     info "Starting the ping"
+    group('Source1').startApplications
+  end
+  after 15 do 
+    group('theSender2').startApplications
+  end
+  after 70 do
+    info "Stopping the ping"
+    group('theSender').stopApplications
+  end
+  after 72 do
+    allGroups.stopApplications
+    Experiment.done
+  end
+end
+
+defGraph 'RTT' do |g|
+  g.ms('ping').select(:oml_seq, :dest_addr, :rtt) 
+  g.caption "RTT of received packets."
+  g.type 'line_chart3'
+  g.mapping :x_axis => :oml_seq, :y_axis => :rtt, :group_by => :dest_addr
+  g.xaxis :legend => 'oml_seq'
+  g.yaxis :legend => 'rtt', :ticks => {:format => 's'}
+end
+defGraph 'Iperf' do |g|
+  g.ms('transfer').select(:oml_seq, :size, :connection_id) 
+  g.caption "Size of received packets."
+  g.type 'line_chart3'
+  g.mapping :x_axis => :oml_seq, :y_axis => :size, :group_by => :connection_id
+  g.xaxis :legend => 'oml_ts [s]'
+  g.yaxis :legend => 'size [Bytes]', :ticks => {:format => 's'}
+end
+
+
+}}}
+
 
 = [wiki:GENIFIRE/Labwiki/Part0/Introduction Part 0 Introduction] =