Changes between Version 5 and Version 6 of GEC22Agenda/LabWiki/ModuleA/Execute

Timestamp:

03/09/15 15:46:49 (9 years ago)

Author:

eswer18@gmail.com

Comment:

--

GEC22Agenda/LabWiki/ModuleA/Execute

@@ -190 +190 @@
 * Students can be asked to implement a particular functionality of the OpenFlow controller. A template should be given to them. [[BR]]
 * !LabWiki has a new feature that enables the instructor to auto-grade the students' experiments. LabWiki allows graders to write a user-defined event, which is triggered when an  
-experiment-generated measurement reaches a specific value. In the above script, an event will be triggered when Node A is able to ping all the other nodes in the topology. It will then trigger a ping event to itself on Node A. If a ping with the IP address of Node A is also seen on the graph, the experiment ran successfully.
+experiment-generated measurement reaches a specific value. In the script below, MY_EVENT is the user-defined event. The function will be called every 0.5 seconds. It queries the specified stats and checks if Node A is able to ping all other nodes. The event will be triggered once that condition is satisfied. Then, ping application to itself is started on Node A. If a ping with the IP address of Node A is also seen on the graph, the experiment ran successfully.
+
+{{{
+#!ruby
+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
+
+}}}
 
 = [wiki:GEC22Agenda/LabWiki/ModuleA/Finish Next: Finish] =