Changes between Version 32 and Version 33 of GEC17Agenda/GettingStartedWithGENI_III_GIMI/Procedure/Execute

Timestamp:

08/25/14 14:52:35 (10 years ago)

Author:

dbhat@bbn.com

Comment:

--

GEC17Agenda/GettingStartedWithGENI_III_GIMI/Procedure/Execute

@@ -164 +164 @@
 
 {{{
-defProperty('source1', "nodeA", "ID of a resource")
-defProperty('source2', "nodeB", "ID of a resource")
-defProperty('source3', "nodeC", "ID of a resource")
-defProperty('source4', "nodeD", "ID of a resource")
-defProperty('source5', "nodeE", "ID of a resource")
-
-#defProperty('sink1', "nodeA", "ID of a sink")
-#defProperty('sink2', "nodeB", "ID of a sink")
-#defProperty('sink3', "nodeC", "ID of a sink")
-#defProperty('sink4', "nodeD", "ID of a sink")
-#defProperty('sink5', "nodeE", "ID of a sink")
+
+defProperty('resource1', "nodeA", "ID of a resource")
+defProperty('resource2', "nodeB", "ID of a resource")
+defProperty('resource3', "nodeC", "ID of a resource")
+defProperty('resource4', "nodeD", "ID of a resource")
+defProperty('resource5', "nodeE", "ID of a resource")
+
 
 defProperty('sinkaddr11', '192.168.4.10', "Ping destination address")
@@ -193 +189 @@
 defProperty('sinkaddr51', '192.168.6.12', "Ping destination address")
 
-defApplication('ping_app', 'pingmonitor') do |a|
-    a.path = "/root/pingWrap.rb" 
-    a.version(1, 2, 0)
-    a.shortDescription = "Wrapper around ping" 
-    a.description = "ping application"
-    a.defProperty('dest_addr', 'Address to ping', '-a', {:type => :string, :dynamic => false})
-    a.defProperty('count', 'Number of times to ping', '-c', {:type => :integer, :dynamic => false}) 
-    a.defProperty('interval', 'Interval between pings in s', '-i', {:type => :integer, :dynamic => false})
-
-    a.defMeasurement('myping') do |m|
-     m.defMetric('dest_addr',:string) 
-     m.defMetric('ttl',:int)
-     m.defMetric('rtt',:float)
-     m.defMetric('rtt_unit',:string)
-   end
-end
-
-defGroup('Source1', property.source1) do |node|
-  node.addApplication("ping_app") do |app|
-    app.setProperty('dest_addr', property.sinkaddr11)
-    app.setProperty('count', 30)
-    app.setProperty('interval', 1)
-    app.measure('myping', :samples => 1)
-  end
-
-  node.addApplication("ping_app") do |app|
-    app.setProperty('dest_addr', property.sinkaddr12)
-    app.setProperty('count', 30)
-    app.setProperty('interval', 1)
-    app.measure('myping', :samples => 1)
-  end
-end
-
-defGroup('Source2', property.source2) do |node|
-  node.addApplication("ping_app") do |app|
-    app.setProperty('dest_addr', property.sinkaddr21)
-    app.setProperty('count', 30)
-    app.setProperty('interval', 1)
-    app.measure('myping', :samples => 1)
-  end
-
-  node.addApplication("ping_app") do |app|
-    app.setProperty('dest_addr', property.sinkaddr22)
-    app.setProperty('count', 30)
-    app.setProperty('interval', 1)
-    app.measure('myping', :samples => 1)
-  end
-
-  node.addApplication("ping_app") do |app|
-    app.setProperty('dest_addr', property.sinkaddr23)
-    app.setProperty('count', 30)
-    app.setProperty('interval', 1)
-    app.measure('myping', :samples => 1)
-  end
-end
-
-defGroup('Source3', property.source3) do |node|
-  node.addApplication("ping_app") do |app|
-    app.setProperty('dest_addr', property.sinkaddr31)
-    app.setProperty('count', 30)
-    app.setProperty('interval', 1)
-    app.measure('myping', :samples => 1)
-  end
-
-  node.addApplication("ping_app") do |app|
-    app.setProperty('dest_addr', property.sinkaddr32)
-    app.setProperty('count', 30)
-    app.setProperty('interval', 1)
-    app.measure('myping', :samples => 1)
-  end
-
-  node.addApplication("ping_app") do |app|
-    app.setProperty('dest_addr', property.sinkaddr33)
-    app.setProperty('count', 30)
-    app.setProperty('interval', 1)
-    app.measure('myping', :samples => 1)
-  end
-
-  node.addApplication("ping_app") do |app|
-    app.setProperty('dest_addr', property.sinkaddr34)
-    app.setProperty('count', 30)
-    app.setProperty('interval', 1)
-    app.measure('myping', :samples => 1)
-  end
-end
-
-defGroup('Source4', property.source4) do |node|
-
-  node.addApplication("ping_app") do |app|
-    app.setProperty('dest_addr', property.sinkaddr41)
-    app.setProperty('count', 30)
-    app.setProperty('interval', 1)
-    app.measure('myping', :samples => 1)
-  end
-
-  node.addApplication("ping_app") do |app|
-    app.setProperty('dest_addr', property.sinkaddr42)
-    app.setProperty('count', 30)
-    app.setProperty('interval', 1)
-    app.measure('myping', :samples => 1)
-  end
-end
-
-defGroup('Source5', property.source5) do |node|
-  node.addApplication("ping_app") do |app|
-    app.setProperty('dest_addr', property.sinkaddr51)
-    app.setProperty('count', 30)
-    app.setProperty('interval', 1)
-    app.measure('myping', :samples => 1)
+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.resource1) do |node|
+  node.addApplication("ping") do |app|
+    app.setProperty('target', property.sinkaddr11)
+    app.setProperty('count', 30)
+    app.measure('ping', :samples => 1)
+  end
+
+  node.addApplication("ping") do |app|
+    app.setProperty('target', property.sinkaddr12)
+    app.setProperty('count', 30)
+    app.measure('ping', :samples => 1)
+  end
+end
+
+defGroup('Source2', property.resource2) do |node|
+  node.addApplication("ping") do |app|
+    app.setProperty('target', property.sinkaddr21)
+    app.setProperty('count', 30)
+    app.measure('ping', :samples => 1)
+  end
+
+  node.addApplication("ping") do |app|
+    app.setProperty('target', property.sinkaddr22)
+    app.setProperty('count', 30)
+    app.measure('ping', :samples => 1)
+  end
+
+  node.addApplication("ping") do |app|
+    app.setProperty('target', property.sinkaddr23)
+    app.setProperty('count', 30)
+    app.measure('ping', :samples => 1)
+  end
+end
+
+defGroup('Source3', property.resource3) do |node|
+  node.addApplication("ping") do |app|
+    app.setProperty('target', property.sinkaddr31)
+    app.setProperty('count', 30)
+    app.measure('ping', :samples => 1)
+  end
+
+  node.addApplication("ping") do |app|
+    app.setProperty('target', property.sinkaddr32)
+    app.setProperty('count', 30)
+    app.measure('ping', :samples => 1)
+  end
+
+  node.addApplication("ping") do |app|
+    app.setProperty('target', property.sinkaddr33)
+    app.setProperty('count', 30)
+    app.measure('ping', :samples => 1)
+  end
+
+  node.addApplication("ping") do |app|
+    app.setProperty('target', property.sinkaddr34)
+    app.setProperty('count', 30)
+    app.measure('ping', :samples => 1)
+  end
+end
+
+defGroup('Source4', property.resource4) do |node|
+
+  node.addApplication("ping") do |app|
+    app.setProperty('target', property.sinkaddr41)
+    app.setProperty('count', 30)
+    app.measure('ping', :samples => 1)
+  end
+
+  node.addApplication("ping") do |app|
+    app.setProperty('target', property.sinkaddr42)
+    app.setProperty('count', 30)
+    app.measure('ping', :samples => 1)
+  end
+end
+
+defGroup('Source5', property.resource5) do |node|
+  node.addApplication("ping") do |app|
+    app.setProperty('target', property.sinkaddr51)
+    app.setProperty('count', 30)
+    app.measure('ping', :samples => 1)
   end
 end
@@ -312 +300 @@
   allGroups.stopApplications
   Experiment.done
+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
 }}}