Changes between Version 18 and Version 19 of GEC17Agenda/AdvancedOpenFlow/Procedure/Execute

Timestamp:

11/21/13 16:45:39 (10 years ago)

Author:

divyashri.bhat@gmail.com

Comment:

--

GEC17Agenda/AdvancedOpenFlow/Procedure/Execute

@@ -40 +40 @@
   
 === 2.2. Configure !LabWiki to orchestrate and monitor your experiment ===
-   - '''2.2.1''' Log on to !LabWiki on http://emmy9.casa.umass.edu:4000 , on the `Prepare` Column, type "gec17" and choose `gec17-advOF-script.rb` file.
+   - '''2.2.1''' Log on to !LabWiki on http://emmy9.casa.umass.edu:4000 , on the `Prepare` Column, create a new Ruby script by clicking on the '+' at the top of the column. Add the script below to the new file, e.g 
+{{{
+
+
+defApplication('oml:app:trace', 'trace') do |app|
+
+  app.version(2, 10, 0)
+  app.shortDescription = 'Packet capture'
+  app.description = %{'trace' uses libtrace to capture packets matching the
+BPFilter, and report various header (IP, TCP, UDP, Radiotap,...) fields through
+OML.
+
+Note The pktid field in all MPs can be used to link information about the
+multiple protocols encapsulated in the same packet, even in cases where multiple
+packets have been received at the same time, which renders the timestamp field
+useless as an identifier.
+  }
+  app.path = "/usr/bin/trace"
+
+  app.defProperty('filter', 'Filter expression BPFEXP', '-f',
+                  :type => :string, :mnemonic => 'f')
+  app.defProperty('snaplen', 'Snarf Bytes of data from each  packet', '-s',
+                  :type => :int, :unit => 'Bytes', :mnemonic => 's')
+  app.defProperty('promisc', 'Put  the  interface into promiscuous mode', '-p',
+                  :type => 'boolean', :mnemonic => 'p')
+  app.defProperty('interface', 'Interface to trace', '-i',
+                  :type => :string, :mnemonic => 'i', :default => '"eth0"')
+  app.defProperty('radiotap', 'Enable radiotap', '-r',
+                  :type => 'boolean', :mnemonic => 'r')
+  app.defProperty('config', 'config file to follow', '--oml-config',
+                  :type => :string, :default => '"/tmp/monitor/conf.xml"')
+
+
+  app.defMeasurement("ip") do |m|
+    m.defMetric('pktid',    :int, ' internal packet ID to link MPs')
+    m.defMetric('ip_tos',   :int, ' Type of Service')
+    m.defMetric('ip_len',   :int, ' Total Length')
+    m.defMetric('ip_id',    :int,  ' Identification')
+    m.defMetric('ip_off',   :int, ' IP Fragment offset (and flags)')
+    m.defMetric('ip_ttl',   :int, ' Time to Live')
+    m.defMetric('ip_proto', :int, ' Protocol')
+    m.defMetric('ip_sum',   :int, ' Checksum')
+    m.defMetric('ip_src',   :string, ' Source Address')
+    m.defMetric('ip_dst',   :string, ' Destination Address')
+    m.defMetric('ip_sizeofpacket', :int, ' Size of the Packet')
+    m.defMetric('ip_ts',    :float, ' timestamp of the measurement')
+  end
+  
+  app.defMeasurement("tcp") do |m|
+    m.defMetric('pktid',        :int, ' internal packet ID to link MPs')
+    m.defMetric('tcp_source',   :int, ' Source Port')
+    m.defMetric('tcp_dest',     :int, ' Destination Port')
+    m.defMetric('tcp_seq',      :int, ' TCP sequence Number')
+    m.defMetric('tcp_ack_seq',  :int, ' Acknowledgment Number')
+    m.defMetric('tcp_window',   :int, ' Window Size')
+    m.defMetric('tcp_checksum', :int, ' Checksum')
+    m.defMetric('tcp_urgptr',   :int, ' Urgent Pointer')
+    m.defMetric('tcp_packet_size', :int, ' Size of the Packet')
+    m.defMetric('tcp_ts',       :float, ' timestamp of the measurement')
+  end
+  
+end
+
+
+
+defApplication('nmetrics_app', 'nmetrics') do |app|
+
+  app.version(2, 10, 0)
+  app.shortDescription = 'Monitoring node statistcs'
+  app.description = %{'nmetrics' is monitoring various node specific statistics,
+such as CPU, memory and network usage and reports them through OML.
+  }
+  app.path = "/usr/bin/nmetrics"
+
+  app.defProperty('interface', 'Report usage for the specified network interface (can be used multiple times)', '-i',
+          :type => :string, :mnemonic => 'i',
+          :default => '"eth0"', :var_name => 'if_name')
+  app.defProperty('sample-interval', 'Time between consecutive measurements', '-s',
+          :type => :int, :unit => 'seconds', :mnemonic => 's',
+          :var_name => 'sample_interval')
+
+  app.defMeasurement("network") do |m|
+    m.defMetric('name', :string)
+    m.defMetric('rx_packets', :int)
+    m.defMetric('rx_bytes', :int)
+    m.defMetric('rx_errors', :int)
+    m.defMetric('rx_dropped', :int)
+    m.defMetric('rx_overruns', :int)
+    m.defMetric('rx_frame', :int)
+    m.defMetric('tx_packets', :int)
+    m.defMetric('tx_bytes', :int)
+    m.defMetric('tx_errors', :int)
+    m.defMetric('tx_dropped', :int)
+    m.defMetric('tx_overruns', :int)
+    m.defMetric('tx_collisions', :int)
+    m.defMetric('tx_carrier', :int)
+    m.defMetric('speed', :int)
+  end
+
+  app.defMeasurement("procs") do |m|
+    m.defMetric('cpu_id', :int)
+    m.defMetric('total', :int)
+    m.defMetric('sleeping', :int)
+    m.defMetric('running', :int)
+    m.defMetric('zombie', :int)
+    m.defMetric('stopped', :int)
+    m.defMetric('idle', :int)
+    m.defMetric('threads', :int)
+  end
+
+  app.defMeasurement("proc") do |m|
+    m.defMetric('pid', :int)
+    m.defMetric('start_time', :int)
+    m.defMetric('user', :int)
+    m.defMetric('sys', :int)
+    m.defMetric('total', :int)
+  end
+end
+#COMMENT
+defPrototype("system_monitor") do |p|
+  p.name = "System Monitor"
+  p.description = "A monitor that reports stats on the system's resource usage"
+  p.defProperty('monitor_interface', 'Monitor the interface usage', 'eth1')
+  p.defProperty('sample-interval', 'sample-interval', '1')
+
+  p.addApplication("nmetrics_app") do |a|
+    a.bindProperty('interface', 'monitor_interface')
+    a.bindProperty('sample-interval', 'sample-interval')
+    a.measure('network', :samples => 1)
+  end
+end
+
+
+
+
+
+###### Change the following to the correct interfaces ######
+left = 'eth1'
+right = 'eth2'
+###### Change the above to the correct interfaces ######
+
+##definition of Sender, Receiver and Monitors
+defProperty('source','outside','ID of sender node')
+defProperty('sink', 'inside', "ID of receiver node")
+defProperty ('balancer', 'switch', "ID of the load balancer")
+defProperty('graph', true, "Display graph or not")
+
+defGroup('Sender', property.source) do |node|
+end
+
+defGroup('Receiver', property.sink) do |node|
+end
+#measure the total bytes sent out and the total throughput on left path
+defGroup('Monitor', property.balancer) do |node|
+  node.addApplication("oml:app:trace") do |app|
+    app.setProperty("interface", left)
+    app.setProperty("config", "/tmp/monitor/conf.xml")
+    app.measure("tcp", :samples => 1)
+  end
+  options = { 'sample-interval' => 1, 'monitor_interface' => left }
+  node.addPrototype("system_monitor", options)
+end
+#measure the total bytes sent out and the total throughput on right path
+defGroup('Monitor1', property.balancer) do |node|
+  node.addApplication("oml:app:trace") do |app|
+    app.setProperty("interface", right)
+    app.setProperty("config", "/tmp/monitor/conf.xml")
+    app.measure("tcp", :samples => 1)
+  end
+  options = { 'sample-interval' => 1, 'monitor_interface' => right }
+  node.addPrototype("system_monitor", options)
+end
+
+
+
+##experiment starts here##
+onEvent(:ALL_UP_AND_INSTALLED) do |event|
+  info "starting the monitor"
+  group('Monitor').startApplications 
+  group('Monitor1').startApplications 
+  
+  info "Starting the Receiver"
+  group('Receiver').exec("iperf -s")
+  wait 2
+
+  #--------------------------------------------------------------------
+  #info "***********starting Load Balancer************"
+  #group('Monitor').exec("/opt/trema-trema-f995284/trema run /root/load-balancer.rb > /tmp/lb.tmp")
+  #wait 2
+  #info "connecting switch to load balancer controller"
+  #group('Monitor').exec("ovs-vsctl set-controller br0 tcp:127.0.0.1 ptcp:6634:127.0.0.1")
+  #wait 5
+  
+  $i = 1
+  $exp_time = 100
+  $interval = 5
+  $total = $exp_time / $interval
+  while $i <= $total do
+    info "Starting Sender " + $i.to_s
+    group('Sender').exec("iperf -c 10.10.10.2 -t "+ ($exp_time-$i*$interval).to_s)
+    wait $interval
+    $i += 1
+  end
+    
+  info "All applications started..."
+    wait $interval
+
+  #info "************stoping Load Balancer***************"
+  #group('Monitor').exec("killall ruby")
+  #group('Monitor').exec("rm /opt/trema-trema-f995284/tmp/pid/LoadBalancer.pid")
+  #info "remove switch-to-controller connection"
+  #group('Monitor').exec("ovs-vsctl del-controller br0")
+    
+  info "All applications stopped."   
+  allGroups.stopApplications
+  Experiment.done
+end
+
+  
+##define the graphs that we want to display##
+defGraph 'Cumulated number of Bytes' do |g|
+  g.ms('network').select(:oml_ts_server, :tx_bytes, :oml_sender_id)
+  g.caption "Total Bytes"
+  g.type 'line_chart3'
+  g.mapping :x_axis => :oml_ts_server, :y_axis => :tx_bytes, :group_by => :oml_sender_id
+  g.xaxis :legend => 'timestamp', :ticks => {:format => 's'}
+  g.yaxis :legend => 'sent Bytes', :ticks => {:format => 'Byte'}
+end
+  
+defGraph 'TCP Throughput Bytes-per-Second' do |g|
+  g.ms('tcp').select(:oml_ts_server, :tcp_throughput_sum, :oml_sender_id)
+  g.caption "TCP throughput"
+  g.type 'line_chart3'
+  g.mapping :x_axis => :oml_ts_server, :y_axis => :tcp_throughput_sum, :group_by => :oml_sender_id
+  g.xaxis :legend => 'timestamp', :ticks => {:format => 's'}
+  g.yaxis :legend => 'throughput', :ticks => {:format => 'Bytes/s'}
+end  
+
+}}}
    - '''2.2.2''' On the terminal where you are logged in on node "Switch", rerun "ifconfig" to see the IP addresses on each interface. 
     [[BR]][[Image(GENIExperimenter/Tutorials/Graphics:warning-icon-hi.png,5%)]] You may not be able to see all interfaces up immediately when node "Switch" is ready; wait for some more time (about 1 min) then try "ifconfig" again.