WiMAX/30/07: gec13-tut03.rb

defProperty('res1', "node1-1.outdoor.orbit-lab.org", "ID of node 1")
defProperty('res2', "node1-2.outdoor.orbit-lab.org", "ID of node 2")

defProperty('firstMCS', "http://cons-wm-01:5052/wimaxrf/mcsProfile?dl=13","Set MCS to profile 13 - QPSK (CTC) 1/2 ")
defProperty('secondMCS',"http://cons-wm-01:5052/wimaxrf/mcsProfile?dl=16","Set MCS to profile 16 - 16-QAM (CTC) 1/2")
defProperty('thirdMCS', "http://cons-wm-01:5052/wimaxrf/mcsProfile?dl=21","Set MCS to profile 21 - 64-QAM (CTC) 5/6")

defGroup('first_node', property.res1) do |node|
  node.net.x0.profile = '51'
  node.net.x0.ip      = "10.41.14.%y%"
  node.net.x0.netmask = "255.255.0.0"

  node.addApplication("test:app:wimaxcu_app") do |app|
    app.measure('status_link')
  end
  node.addApplication("test:app:iperf") do |app|
    app.setProperty('udp', true)
    app.setProperty('server', true)
    app.setProperty('port', 23456) 
    app.setProperty('interval', "1")
    app.setProperty('bind', "10.41.14.%y%")
    app.measure('UDP_Rich_Info', :samples =>1)
  end
end       

defGroup('second_node', property.res2) do |node|
  node.net.x0.profile = '51'
  node.net.x0.ip      = "10.41.14.%y%"
  node.net.x0.netmask = "255.255.0.0"

  node.addApplication("test:app:wimaxcu_app") do |app|
    app.measure('status_link')
  end
  node.addApplication("test:app:iperf") do |app|
    app.setProperty('udp', true)
    app.setProperty('server', true)
    app.setProperty('port', 23456)
    app.setProperty('interval', "1")
    app.setProperty('bind', "10.41.14.%y%")
    app.measure('UDP_Rich_Info', :samples =>1)
  end
end       


onEvent(:ALL_UP_AND_INSTALLED) do |event|
  wait 10
  system("/usr/bin/wget -qO- #{property.firstMCS}")
  wait 10
  allGroups.startApplications
  wait 50
  system("/usr/bin/wget -qO- #{property.secondMCS}")
  wait 50
  system("/usr/bin/wget -qO- #{property.thirdMCS}")
  wait 50
  system("/usr/bin/wget -qO- #{property.firstMCS}")
  wait 5
  allGroups.stopApplications
  Experiment.done
end

addTab(:defaults)
addTab(:graph2) do |tab|
  opts = { :postfix => %{This graph shows the Received Signal Strength (RSSI) on the WiMAX link.}, :updateEvery => 1 }
  tab.addGraph("WiMAX Downlink RSSI (dBm)", opts) do |g|
    data = Hash.new
    index = 1
    mpIn = ms('status_link')
    mpIn.project(:oml_ts_server, :oml_sender_id, :rssi).each do |sample|
      time, src, rssi = sample.tuple
      if data[src].nil? 
        data[src] = [index,[]] 
        index += 1
      end
      data[src][1] << [time, rssi] 
    end
    data.each do |src,value|
      g.addLine(value[1], :label => "#{value[0]}") 
    end
  end
  opts = { :postfix => %{This graph shows the Carrier-to-Interference+Noise Ratio (CINR) on the WiMAX link.}, :updateEvery => 1 }
  tab.addGraph("WiMAX Downlink CINR (dB)", opts) do |g|
    data = Hash.new
    index = 1
    mpIn = ms('status_link')
    mpIn.project(:oml_ts_server, :oml_sender_id, :cinr).each do |sample|
      time, src, rssi = sample.tuple
      if data[src].nil?
        data[src] = [index,[]]
        index += 1
      end
      data[src][1] << [time, rssi]
    end
    data.each do |src,value|
      g.addLine(value[1], :label => "#{value[0]}")
    end
  end
  opts = { :postfix => %{This graph shows the UDP Packet Loss Ratio measured by iperf.}, :updateEvery => 1 }
  tab.addGraph("UDP packet loss (%)", opts) do |g|
    data = Hash.new
    index = 1
    mpIn = ms('UDP_Rich_Info')
    mpIn.project(:oml_ts_server, :oml_sender_id, :PLR).each do |sample|
      time, src, plr = sample.tuple
        if plr > 100
          plr = 0
        end
        if data[src].nil?
          data[src] = [index,[]]
          index += 1
        end
        data[src][1] << [time, plr]
      end
      data.each do |src,value|
      g.addLine(value[1], :label => "#{value[0]}")
    end
  end
  opts = { :postfix => %{This graph shows throughput  measured by iperf.}, :updateEvery => 1 }
  tab.addGraph("UDP throughput (bytes)", opts) do |g|
    data = Hash.new
    index = 1
    mpIn = ms('UDP_Rich_Info')
    mpIn.project(:oml_ts_server, :oml_sender_id, :Bandwidth).each do |sample|
      time, src, bw = sample.tuple
      if data[src].nil?
        data[src] = [index,[]]
        index += 1
      end
      data[src][1] << [time, bw]
    end
    data.each do |src,value|
      g.addLine(value[1], :label => "#{value[0]}")
    end
  end
end