Changes between Version 4 and Version 5 of GEC21Agenda/LabWiki/ModuleA/Execute

Timestamp:

03/09/15 13:41:23 (10 years ago)

Author:

eswer18@gmail.com

Comment:

--

GEC21Agenda/LabWiki/ModuleA/Execute

@@ -24 +24 @@
 #!ruby
 
-defProperty('resource1', "nodea", "ID of a resource")
-defProperty('resource2', "switch", "ID of a resource")
+defProperty('source1', "nodea-learningswitch", "ID of a resource")
+defProperty('source2', "switch-learningswitch", "ID of a resource")
 
 
@@ -32 +32 @@
 
 defProperty('sinkaddr21', '192.168.1.9', "Ping destination address")
-
+defProperty('sinkaddr11', '192.168.1.6', "Ping destination address")
+peak_list = []
 
 defApplication('ping') do |app|
@@ -59 +60 @@
   app.binary_path = '/bin/sh /root/ovs-setup2.sh'
 end
-defGroup('Source2', property.resource2) do |node|
+defGroup('Source2', property.source2) do |node|
   node.addApplication("trema")
 end
-defGroup('Source1', property.resource1) do |node|
+defGroup('Source1', property.source1) do |node|
   node.addApplication("ping") do |app|
     app.setProperty('target', property.sinkaddr12)
@@ -83 +84 @@
 end
 
+defGroup('Source3', property.source1) do |node|
+  node.addApplication("ping") do |app|
+    app.setProperty('target', property.sinkaddr11)
+    app.setProperty('count', 30)
+    #app.setProperty('interval', 1)
+    app.measure('ping', :samples => 1)
+  end
+end
+
+defEvent(:MY_EVENT, every: 0.5) do
+# Query for some measurements...
+  # returns an array where each element is a hash representing a row from the DB
+  query = ms('ping').select { [ :remote] }
+  data = defQuery(query)
+  # Alternatively the above line could also be:
+  # data = defQuery('select oml_ts_client, value from signalgen_sin')
+  #
+  # Also if you want to rename 'oml_ts_client' to 'ts'
+  # query = ms('sin').select { [ oml_ts_client.as(:ts), :value ] } 
+  # data = defQuery('select oml_ts_client as ts, value from signalgen_sin')
+
+  triggered = false
+  if !data.nil? && !(last_row = data.pop).nil? # Make sure we have some data
+    next if peak_list.include?(last_row[:remote]) # Do nothing if we have seen this sample before
+    if !peak_list.include?(last_row[:remote])
+      peak_list << last_row[:remote] # record that sample, so we dont trigger on it again
+    end
+    if peak_list.include?('192.168.1.9')&&peak_list.include?('192.168.1.7')&&peak_list.include?('192.168.1.8')
+      
+      triggered = true
+    end
+  end
+  triggered
+end
+onEvent :MY_EVENT do
+  #group('switch').exec("ping www.google.com")
+  group('Source3').startApplications
+end
 
 onEvent(:ALL_UP_AND_INSTALLED) do |event|
@@ -107 +146 @@
   g.yaxis :legend => 'rtt', :ticks => {:format => 's'}
 end
+
 
 }}}