WiMAX/30/07: gec13-tut02.rb

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

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.1")
    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.2")
    app.measure('UDP_Rich_Info', :samples =>1)
  end
end       

onEvent(:ALL_UP_AND_INSTALLED) do |event|
  wait 10
  allGroups.startApplications
  wait 50
  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