Changes between Initial Version and Version 1 of GEC17Agenda/GettingStartedWithGENI_III_GIMI/Procedure/Finish

Timestamp:

06/21/13 22:47:48 (11 years ago)

Author:

divyashri.bhat@gmail.com

Comment:

--

GEC17Agenda/GettingStartedWithGENI_III_GIMI/Procedure/Finish

@@ +1 @@
+=== C.1 Initial Setup ===
+
+=== C.1.1 Starting the OML Server (if needed) ===
+For this tutorial we have an OML server running on emmy9.casa.umass.edu, which collects the measurement data in an sqlite3 database and at the end of the experiment it pushes the data to IRODS.
+   * Here is how you would have to start an OML server if you wanted to run this on a different machine (OML2.8 is required.) 
+{{{
+#!html
+<span style="color:red">DO NOT perform this task in the tutorial.
+</span>
+}}}
+
+ This is explained the [OML installation file].
+
+{{{
+$ /usr/bin/oml2-server -l 3003 --logfile=/var/log/oml2-server-2.9.log --user=oml2 --group=oml2 -H /usr/share/oml2-server/oml2-server-hook.sh
+}}}
+
+The latest version of OML offers the capability of executing a script after the measurement has finished. In OML terminology this is called a "hook". The hook script we use is attached at the bottom of this wiki page [http://groups.geni.net/geni/attachment/wiki/GIMI-GEC16-Tutorials/GIMI-GEC16-TutorialB/Orchestrate/oml2-server-hook.sh (oml2-server-hook.sh)].
+
+{{{
+#!/bin/bash
+#
+# Example event hook for the OML server, copying an Sqlite database elsewhere
+# when the last client has exited.
+# Copyright 2012-2013 National ICT Australia (NICTA), Australia
+#
+# Permission is hereby granted, free of charge, to any person obtaining a copy
+# of this software and associated documentation files (the "Software"), to deal
+# in the Software without restriction, including without limitation the rights
+# to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+# copies of the Software, and to permit persons to whom the Software is
+# furnished to do so, subject to the following conditions:
+#
+# The above copyright notice and this permission notice shall be included in
+# all copies or substantial portions of the Software.
+#
+# THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+# IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+# FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.  IN NO EVENT SHALL THE
+# AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+# LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+# OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
+# THE SOFTWARE.
+#
+irodsUserName=rods
+irodsHost=emmy9.casa.umass.edu
+irodsPort=1247
+irodsZone=geniRenci
+HOME=/home/oml2
+export irodsUserName irodsHost irodsPort irodsZone HOME
+
+LOGFILE=/tmp/oml2-server-hook.log
+function log ()
+{
+        echo "$@" >&2
+        echo "$@" >> ${LOGFILE}
+}
+
+# XXX: You might need to initialise the iRODS password for the UNIX user
+# running tho oml2-server by running 'iinit' to create ~/.irods/.irodsA on its
+# behalf for iput to work
+IPUT=/usr/bin/iput
+SQLITE3=sqlite3
+PGDUMP=pg_dump
+
+echo "OML HOOK READY"
+log "OML HOOK READY"
+
+while read COMMAND ARGUMENTS; do
+        # One report line must be printed in each control path;
+        # this first one puts out a timestamp and a dump of the received command, but no newline
+        log -n "`date`: ${COMMAND} ${ARGUMENTS}: "
+        case "${COMMAND}" in
+                "DBCLOSED")
+                        case "${ARGUMENTS}" in
+                                file:*)
+                                        DBFILE=${ARGUMENTS/file:/}
+                                        log "${IPUT} ${OPTION} ${DBFILE}"
+                                        NAME=${DBFILE:14:6};
+                                        FILE=${DBFILE:14};
+                                        LENGTH=${#FILE}
+                                        SLICE=${FILE:0:$LENGTH-4}
+                                        DATE=`date`
+                                        log "b db ${DBFILE} closed, pushing to iRODS..."
+                                        ${IPUT} -f ${DBFILE} /geniRenci/home/$NAME/ #$FILE
+                                        log "an iRODS operation finished"
+                                        ;;
+                                postgresql://*)
+                                        # Separate the components of the URI by gradually eating them off the TMP variable
+                                        
+                                        DOMAIN=${ARGUMENTS//*\//}       # cut everything before the final '/'
+                                        USERNAME=${DOMAIN/-*/}          # get the first part before the '-'
+                                        REST=${DOMAIN/$USERNAME-/}      # remove the username from the rest
+                                        EXPNAME=${REST/-*/}             # same as for the username
+                                        TIMESTAMP=${REST//*-/}          # get the last part after the '-'
+
+                                                
+                                        TMP="${ARGUMENTS/postgresql:\/\//}"
+                                        USER=${TMP/@*/}
+                                        TMP=${TMP/${USER}@/}
+                                        HOST=${TMP/:*/}
+                                        TMP=${TMP/${HOST}:/}
+                                        PORT=${TMP/\/*/}
+                                        TMP=${TMP/${PORT}\//}
+                                        DBNAME=${TMP}
+                                        DBFILE=${DBNAME}.`date +%Y-%m-%d_%H:%M:%S%z`.pg.sql
+                                        log "PostgreSQL DB ${DBNAME} closed, dumping as ${DBFILE} and pushing to iRODS"
+                                        log "User ${USER} Host ${HOST} Port ${PORT} DBNAME ${DBNAME} Home ${HOME}"
+                                        ${PGDUMP} -U ${USER} -h ${HOST} -p ${PORT} ${DBNAME} > /tmp/${DBFILE}
+                                        log "Before IPUT"
+                                        log "${IPUT} -f /tmp/${DBFILE} /geniRenci/home/rods/"
+                                        log `${IPUT} -V -f /tmp/${DBFILE} /geniRenci/home/rods/ 2>&1`
+                                        # ${IPUT} -f /tmp/${DBFILE} /geniRenci/home/rods/
+                                        ${IPUT} -f /tmp/${DBFILE} /geniRenci/home/${USERNAME}/experiments/${EXPNAME}-${TIMESTAMP}/measurements.sql
+                                        log "After IPUT"
+                                        ;;
+                                *)
+                                        log "DB ${ARGUMENTS} closed, but don't know how to handle it"
+                                        ;;
+                        esac
+                        ;;
+                "EXIT")
+                        log "Exiting"
+                        exit 0
+                        ;;
+                *)
+                        log "Unknown command"
+                        ;;
+        esac
+done
+
+}}}
+
+At the [http://groups.geni.net/geni/wiki/GIMI-GEC16-Tutorials/GIMI-GEC16-TutorialB/OmlServer following page] we give the interested experimenter additional information on how they can run their own OML server independent of the one offered by GIMI.
+
+----
+
+=== C.1.2 Verification of Topology ===
+After establishing the slice on which the experiment will be executed, the experimenter will be most likely 
+be interested in verifying if the slice has been initiated correctly. In this tutorial, we use an [[http://emmy9.casa.umass.edu/GEC15-GIMI-Tutorial/step1-ping_all.rb OMF experiment script]] that executes pings between neighboring nodes.
+[[BR]]
+The following figure shows that a total of 12 (between each pair of nodes and in each direction) ping are performed.
+
+[[Image(ping.png)]]
+
+{{{
+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('sinkaddr11', '192.168.4.10', "Ping destination address")
+defProperty('sinkaddr12', '192.168.5.12', "Ping destination address")
+
+defProperty('sinkaddr21', '192.168.4.11', "Ping destination address")
+defProperty('sinkaddr22', '192.168.2.12', "Ping destination address")
+defProperty('sinkaddr23', '192.168.1.13', "Ping destination address")
+
+defProperty('sinkaddr31', '192.168.5.11', "Ping destination address")
+defProperty('sinkaddr32', '192.168.2.10', "Ping destination address")
+defProperty('sinkaddr33', '192.168.3.13', "Ping destination address")
+defProperty('sinkaddr34', '192.168.6.14', "Ping destination address")
+
+defProperty('sinkaddr41', '192.168.1.10', "Ping destination address")
+defProperty('sinkaddr42', '192.168.3.12', "Ping destination address")
+
+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)
+  end
+end
+
+onEvent(:ALL_UP_AND_INSTALLED) do |event|
+  info "Starting the ping"
+  allGroups.startApplications
+  wait 5
+  info "Stopping the ping"
+  allGroups.stopApplications
+  Experiment.done
+end
+}}}
+
+The script is executed from the user workspace as follows:
+
+{{{
+$ cd ~/Tutorials/GIMI/common/
+$ omf-5.4 exec --no-am -e gimiXX-ping_all -S gimiXX step1-ping_all.rb
+}}}
+
+Where gimiXX has to be replaced by the slice name you are using for your experiment.
+
+You should see the following output after executing the omf command.
+
+{{{
+ INFO NodeHandler: OMF Experiment Controller 5.4 (git e0eefcf)
+ INFO NodeHandler: Slice ID: gimi20 
+ INFO NodeHandler: Experiment ID: gimi20-2012-10-18t14.03.42-04.00
+ INFO NodeHandler: Message authentication is disabled
+ WARN NodeHandler: AM support disabled - any service calls will fail!
+ INFO Experiment: load system:exp:stdlib
+ INFO property.resetDelay: resetDelay = 210 (Fixnum)
+ INFO property.resetTries: resetTries = 1 (Fixnum)
+ INFO Experiment: load system:exp:eventlib
+ INFO Experiment: load ping_all.rb
+ INFO property.source1: source1 = "nodeA" (String)
+ INFO property.source2: source2 = "nodeB" (String)
+ INFO property.source3: source3 = "nodeC" (String)
+ INFO property.source4: source4 = "nodeD" (String)
+ INFO property.source5: source5 = "nodeE" (String)
+ INFO property.sinkaddr11: sinkaddr11 = "192.168.4.10" (String)
+ INFO property.sinkaddr12: sinkaddr12 = "192.168.5.12" (String)
+ INFO property.sinkaddr21: sinkaddr21 = "192.168.4.11" (String)
+ INFO property.sinkaddr22: sinkaddr22 = "192.168.2.12" (String)
+ INFO property.sinkaddr23: sinkaddr23 = "192.168.1.13" (String)
+ INFO property.sinkaddr31: sinkaddr31 = "192.168.5.11" (String)
+ INFO property.sinkaddr32: sinkaddr32 = "192.168.2.10" (String)
+ INFO property.sinkaddr33: sinkaddr33 = "192.168.3.13" (String)
+ INFO property.sinkaddr34: sinkaddr34 = "192.168.6.14" (String)
+ INFO property.sinkaddr41: sinkaddr41 = "192.168.1.10" (String)
+ INFO property.sinkaddr42: sinkaddr42 = "192.168.3.12" (String)
+ INFO property.sinkaddr51: sinkaddr51 = "192.168.6.12" (String)
+ INFO Topology: Loading topology 'nodeA'.
+ INFO Topology: Loading topology 'nodeB'.
+ INFO Topology: Loading topology 'nodeC'.
+ INFO Topology: Loading topology 'nodeD'.
+ INFO Topology: Loading topology 'nodeE'.
+ INFO Experiment: Switching ON resources which are OFF
+ INFO ALL_UP_AND_INSTALLED: Event triggered. Starting the associated tasks.
+ INFO exp: Starting the ping
+ INFO exp: Request from Experiment Script: Wait for 5s....
+ INFO exp: Stopping the ping
+ INFO EXPERIMENT_DONE: Event triggered. Starting the associated tasks.
+ INFO NodeHandler: 
+ INFO NodeHandler: Shutting down experiment, please wait...
+ INFO NodeHandler: 
+ INFO run: Experiment gimi20-2012-10-18t14.03.42-04.00 finished after 0:16
+}}}
+
+----
+
+=== C.1.3 Setup Routing in Experiment Topology ===
+In more complex topologies routing has to be set up. In our case, this is achieved with the aid of an [[http://emmy9.casa.umass.edu/GEC15-GIMI-Tutorial/step2-routing.rb OMF experiment script]]. The one we use for this tutorial is shown below.
+
+{{{
+defGroup('Node1', "nodeA")
+defGroup('Node2', "nodeB")
+defGroup('Node3', "nodeC")
+defGroup('Node4', "nodeD")
+defGroup('Node5', "nodeE")
+
+
+onEvent(:ALL_UP) do |event|
+  wait 1
+  info 'Changing routing setup'
+
+  group('Node1').exec("route add -net 192.168.1.0/24 gw 192.168.4.10")
+  group('Node1').exec("route add -net 192.168.2.0/24 gw 192.168.4.10")
+  group('Node1').exec("route add -net 192.168.3.0/24 gw 192.168.5.12")
+  group('Node1').exec("route add -net 192.168.6.0/24 gw 192.168.5.12")
+  group('Node1').exec("echo 1 >  /proc/sys/net/ipv4/ip_forward")
+
+  group('Node2').exec("route add -net 192.168.3.0/24 gw 192.168.1.13")
+  group('Node2').exec("route add -net 192.168.5.0/24 gw 192.168.4.11")
+  group('Node2').exec("route add -net 192.168.6.0/24 gw 192.168.2.12")
+  group('Node2').exec("echo 1 >  /proc/sys/net/ipv4/ip_forward")
+
+  group('Node3').exec("route add -net 192.168.1.0/24 gw 192.168.3.13")
+  group('Node3').exec("route add -net 192.168.4.0/24 gw 192.168.5.11")
+  group('Node3').exec("echo 1 >  /proc/sys/net/ipv4/ip_forward")
+
+  group('Node4').exec("route add -net 192.168.2.0/24 gw 192.168.3.12")
+  group('Node4').exec("route add -net 192.168.4.0/24 gw 192.168.1.10")
+  group('Node4').exec("route add -net 192.168.5.0/24 gw 192.168.3.12")
+  group('Node4').exec("route add -net 192.168.6.0/24 gw 192.168.3.12")
+  group('Node4').exec("echo 1 >  /proc/sys/net/ipv4/ip_forward")
+
+  group('Node5').exec("route add -net 192.168.2.0/24 gw 192.168.6.12")
+  group('Node5').exec("route add -net 192.168.1.0/24 gw 192.168.6.12")
+  group('Node5').exec("route add -net 192.168.3.0/24 gw 192.168.6.12")
+  group('Node5').exec("route add -net 192.168.4.0/24 gw 192.168.6.12")
+  group('Node5').exec("route add -net 192.168.5.0/24 gw 192.168.6.12")
+
+  info 'Routing setup finished'
+  wait 5
+  info 'Stopping applications'
+  allGroups.stopApplications
+  wait 1
+  Experiment.done
+end
+}}}
+
+This script can be easily adapted if the experimenter wishes to set up the routing between the nodes 
+differently.
+
+The script is executed from the user workspace as follows:
+
+{{{
+$ cd ~/Tutorials/GIMI/common/
+$ omf-5.4 exec --no-am -e gimiXX-routing -S gimiXX step2-routing.rb
+}}}
+
+Where gimiXX has to be replaced by the slice name you are using for your experiment.
+
+You should see the following output after executing the omf command.
+
+{{{
+ INFO NodeHandler: OMF Experiment Controller 5.4 (git e0eefcf)
+ INFO NodeHandler: Slice ID: gimi20 
+ INFO NodeHandler: Experiment ID: gimi20-2012-10-18t14.14.10-04.00
+ INFO NodeHandler: Message authentication is disabled
+ WARN NodeHandler: AM support disabled - any service calls will fail!
+ INFO Experiment: load system:exp:stdlib
+ INFO property.resetDelay: resetDelay = 210 (Fixnum)
+ INFO property.resetTries: resetTries = 1 (Fixnum)
+ INFO Experiment: load system:exp:eventlib
+ INFO Experiment: load routing.rb
+ INFO Topology: Loading topology 'nodeA'.
+ INFO Topology: Loading topology 'nodeB'.
+ INFO Topology: Loading topology 'nodeC'.
+ INFO Topology: Loading topology 'nodeD'.
+ INFO Topology: Loading topology 'nodeE'.
+ INFO Experiment: Switching ON resources which are OFF
+ INFO ALL_UP: Event triggered. Starting the associated tasks.
+ INFO exp: Request from Experiment Script: Wait for 1s....
+ INFO exp: Changing routing setup
+ INFO exp: Routing setup finished
+ INFO exp: Request from Experiment Script: Wait for 5s....
+ INFO exp: Stopping applications
+ INFO exp: Request from Experiment Script: Wait for 1s....
+ INFO EXPERIMENT_DONE: Event triggered. Starting the associated tasks.
+ INFO NodeHandler: 
+ INFO NodeHandler: Shutting down experiment, please wait...
+ INFO NodeHandler: 
+ INFO run: Experiment gimi20-2012-10-18t14.14.10-04.00 finished after 0:16
+}}}
+
+----
+
+=== C.1.4 Verification of Routing ===
+After establishing the routing, we use an [[http://emmy9.casa.umass.edu/GEC15-GIMI-Tutorial/step3-ping_e2e.rb OMF experiment script]] that executes pings between each pair of nodes that contains one hop, to verify the correctness of routing setup.
+
+[[Image(GIMIPing_e2e.png)]]
+
+{{{
+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('sinkaddr11', '192.168.1.13', "Ping destination address")
+defProperty('sinkaddr12', '192.168.3.13', "Ping destination address")
+defProperty('sinkaddr13', '192.168.6.14', "Ping destination address")
+
+defProperty('sinkaddr21', '192.168.6.14', "Ping destination address")
+
+defProperty('sinkaddr41', '192.168.4.11', "Ping destination address")
+defProperty('sinkaddr42', '192.168.5.11', "Ping destination address")
+defProperty('sinkaddr43', '192.168.6.14', "Ping destination address")
+
+defProperty('sinkaddr51', '192.168.5.11', "Ping destination address")
+defProperty('sinkaddr52', '192.168.2.10', "Ping destination address")
+defProperty('sinkaddr53', '192.168.3.13', "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
+
+      node.addApplication("ping_app") do |app|          
+          app.setProperty('dest_addr', property.sinkaddr13)
+          app.setProperty('count', 30)              
+          app.setProperty('interval', 1)                  
+          app.measure('myping', :samples => 1)
+      end
+end
+
+defGroup('Source2', property.source1) 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                
+end
+
+defGroup('Source4', property.source3) 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
+
+      node.addApplication("ping_app") do |app|
+          app.setProperty('dest_addr', property.sinkaddr43)
+          app.setProperty('count', 30)
+          app.setProperty('interval', 1)
+          app.measure('myping', :samples => 1)
+      end
+end
+
+defGroup('Source5', property.source3) 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)
+          end
+
+          node.addApplication("ping_app") do |app|
+              app.setProperty('dest_addr', property.sinkaddr52)
+              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.sinkaddr53)
+              app.setProperty('count', 30)
+              app.setProperty('interval', 1)
+              app.measure('myping', :samples => 1)
+          end
+end
+
+onEvent(:ALL_UP_AND_INSTALLED) do |event|
+      info "Starting the ping"
+      allGroups.startApplications
+      wait 5
+      info "Stopping the ping"
+      allGroups.stopApplications
+      Experiment.done
+end
+}}}
+
+The script is executed from the user workspace as follows:
+
+{{{
+$ cd ~/Tutorials/GIMI/common/
+$ omf-5.4 exec --no-am -e gimiXX-ping_e2e -S gimiXX step3-ping_e2e.rb
+}}}
+
+Where gimiXX has to be replaced by the slice name you are using for your experiment.
+
+You should see the following output after executing the omf command.
+
+{{{
+ INFO NodeHandler: OMF Experiment Controller 5.4 (git e0eefcf)
+ INFO NodeHandler: Slice ID: gimi20 
+ INFO NodeHandler: Experiment ID: gimi20-2012-10-18t14.03.42-04.00
+ INFO NodeHandler: Message authentication is disabled
+ WARN NodeHandler: AM support disabled - any service calls will fail!
+ INFO Experiment: load system:exp:stdlib
+ INFO property.resetDelay: resetDelay = 210 (Fixnum)
+ INFO property.resetTries: resetTries = 1 (Fixnum)
+ INFO Experiment: load system:exp:eventlib
+ INFO Experiment: load ping_all.rb
+ INFO property.source1: source1 = "nodeA" (String)
+ INFO property.source2: source2 = "nodeB" (String)
+ INFO property.source3: source3 = "nodeC" (String)
+ INFO property.source4: source4 = "nodeD" (String)
+ INFO property.source5: source5 = "nodeE" (String)
+ INFO property.sinkaddr11: sinkaddr11 = "192.168.4.10" (String)
+ INFO property.sinkaddr12: sinkaddr12 = "192.168.5.12" (String)
+ INFO property.sinkaddr21: sinkaddr21 = "192.168.4.11" (String)
+ INFO property.sinkaddr22: sinkaddr22 = "192.168.2.12" (String)
+ INFO property.sinkaddr23: sinkaddr23 = "192.168.1.13" (String)
+ INFO property.sinkaddr31: sinkaddr31 = "192.168.5.11" (String)
+ INFO property.sinkaddr32: sinkaddr32 = "192.168.2.10" (String)
+ INFO property.sinkaddr33: sinkaddr33 = "192.168.3.13" (String)
+ INFO property.sinkaddr34: sinkaddr34 = "192.168.6.14" (String)
+ INFO property.sinkaddr41: sinkaddr41 = "192.168.1.10" (String)
+ INFO property.sinkaddr42: sinkaddr42 = "192.168.3.12" (String)
+ INFO property.sinkaddr51: sinkaddr51 = "192.168.6.12" (String)
+ INFO Topology: Loading topology 'nodeA'.
+ INFO Topology: Loading topology 'nodeB'.
+ INFO Topology: Loading topology 'nodeC'.
+ INFO Topology: Loading topology 'nodeD'.
+ INFO Topology: Loading topology 'nodeE'.
+ INFO Experiment: Switching ON resources which are OFF
+ INFO ALL_UP_AND_INSTALLED: Event triggered. Starting the associated tasks.
+ INFO exp: Starting the ping
+ INFO exp: Request from Experiment Script: Wait for 5s....
+ INFO exp: Stopping the ping
+ INFO EXPERIMENT_DONE: Event triggered. Starting the associated tasks.
+ INFO NodeHandler: 
+ INFO NodeHandler: Shutting down experiment, please wait...
+ INFO NodeHandler: 
+ INFO run: Experiment gimi20-2012-10-18t14.03.42-04.00 finished after 0:16
+}}}
+
+----
+
+=== C.2 Running Actual Experiment ===
+
+We will use an [[http://emmy9.casa.umass.edu/GEC15-GIMI-Tutorial/step4-otg_nmetrics.rb OMF experiment script]] to execute oml enabled traffic generator and receiver (otg and otr) to simulate network traffic, and use oml enabled nmetrics to measure the system usage (e.g., CUP, memory) and network interface usage on each of the participated ExoGENI nodes. 
+
+[[Image(otg_nmetrics.png)]]
+
+
+
+The one we use for this tutorial is shown below.
+
+{{{
+defProperty('theSender','nodeB','ID of sender node')
+defProperty('theReceiver1', 'nodeE', "ID of receiver node")
+defProperty('theReceiver2', 'nodeA', "ID of receiver node")
+defProperty('theReceiver3', 'nodeD', "ID of receiver node")
+defProperty('packetsize', 128, "Packet size (byte) from the sender node")
+defProperty('bitrate', 2048, "Bitrate (bit/s) from the sender node")
+defProperty('runtime', 40, "Time in second for the experiment is to run")
+
+defGroup('Sender',property.theSender) do |node|
+    options = { 'sample-interval' => 2 }
+    node.addPrototype("system_monitor", options)
+    node.addApplication("test:app:otg2") do |app|
+        app.setProperty('udp:local_host', '192.168.2.10')
+        app.setProperty('udp:dst_host', '192.168.6.14')
+        app.setProperty('udp:dst_port', 3000)
+        app.setProperty('cbr:size', property.packetsize)
+        app.setProperty('cbr:rate', property.bitrate * 2)
+        app.measure('udp_out', :samples => 1)
+    end
+    
+    node.addApplication("test:app:otg2") do |app|
+        app.setProperty('udp:local_host', '192.168.4.10')
+        app.setProperty('udp:dst_host', '192.168.4.11')
+        app.setProperty('udp:dst_port', 3000)
+        app.setProperty('cbr:size', property.packetsize)
+        app.setProperty('cbr:rate', property.bitrate * 2)
+        app.measure('udp_out', :samples => 1)
+    end
+    
+    node.addApplication("test:app:otg2") do |app|
+        app.setProperty('udp:local_host', '192.168.1.10')
+        app.setProperty('udp:dst_host', '192.168.1.13')
+        app.setProperty('udp:dst_port', 3000)                                    
+        app.setProperty('cbr:size', property.packetsize)                                            
+        app.setProperty('cbr:rate', property.bitrate * 2)                                                    
+        app.measure('udp_out', :samples => 1)                                                        
+    end
+end
+
+defGroup('Receiver1',property.theReceiver1) do |node|
+    options = { 'sample-interval' => 2 }
+    node.addPrototype("system_monitor", options)
+
+    node.addApplication("test:app:otr2") do |app|
+        app.setProperty('udp:local_host', '192.168.6.14')
+        app.setProperty('udp:local_port', 3000)
+        app.measure('udp_in', :samples => 1)
+    end
+end
+
+defGroup('Receiver2',property.theReceiver2) do |node|
+    options = { 'sample-interval' => 2 }
+    node.addPrototype("system_monitor", options)
+    node.addApplication("test:app:otr2") do |app|
+        app.setProperty('udp:local_host', '192.168.4.11')
+        app.setProperty('udp:local_port', 3000)
+        app.measure('udp_in', :samples => 1)
+    end 
+end
+
+defGroup('Receiver3',property.theReceiver3) do |node|     
+    options = { 'sample-interval' => 2 }
+    node.addPrototype("system_monitor", options)
+    node.addApplication("test:app:otr2") do |app|                    
+        app.setProperty('udp:local_host', '192.168.1.13')
+        app.setProperty('udp:local_port', 3000)                                
+        app.measure('udp_in', :samples => 1)                                    
+    end
+end
+
+onEvent(:ALL_UP_AND_INSTALLED) do |event|
+    info "starting"
+    wait 5
+    allGroups.exec("ln -s /usr/local/bin/otr2 /usr/bin/otr2")
+    allGroups.exec("ln -s /usr/local/bin/otg2 /usr/bin/otg2")
+    allGroups.exec("ln -s /usr/local/bin/oml2-nmetrics /usr/bin/oml2-nmetrics")
+    allGroups.startApplications
+    info "All applications started..."
+    wait property.runtime / 4
+    property.packetsize = 256
+    wait property.runtime / 4
+    property.packetsize = 512
+    wait property.runtime / 4
+    property.packetsize = 1024
+    wait property.runtime / 4
+    allGroups.stopApplications
+    info "All applications stopped." 
+    Experiment.done
+end
+}}}
+
+The script is executed from the user workspace as follows:
+
+{{{
+$ cd ~/Tutorials/GIMI/common/
+$ omf-5.4 exec --no-am -e gimiXX-otg_nmetrics -S gimiXX step4-otg_nmetrics.rb
+}}}
+
+Where gimiXX has to be replaced by the slice name you are using for your experiment.
+
+You should see the following output (or similar) after executing the omf command.
+
+{{{
+ INFO NodeHandler: OMF Experiment Controller 5.4 (git e0eefcf)
+ INFO NodeHandler: Slice ID: gimi20 
+ INFO NodeHandler: Experiment ID: gimi20-2012-10-18t13.51.41-04.00
+ INFO NodeHandler: Message authentication is disabled
+ WARN NodeHandler: AM support disabled - any service calls will fail!
+ INFO Experiment: load system:exp:stdlib
+ INFO property.resetDelay: resetDelay = 210 (Fixnum)
+ INFO property.resetTries: resetTries = 1 (Fixnum)
+ INFO Experiment: load system:exp:eventlib
+ INFO Experiment: load otg_nmetrics.rb
+ INFO property.theSender: theSender = "nodeB" (String)
+ INFO property.theReceiver1: theReceiver1 = "nodeE" (String)
+ INFO property.theReceiver2: theReceiver2 = "nodeA" (String)
+ INFO property.theReceiver3: theReceiver3 = "nodeD" (String)
+ INFO property.packetsize: packetsize = 128 (Fixnum)
+ INFO property.bitrate: bitrate = 2048 (Fixnum)
+ INFO property.runtime: runtime = 40 (Fixnum)
+ INFO Topology: Loading topology 'nodeB'.
+ INFO Topology: Loading topology 'nodeE'.
+ INFO Topology: Loading topology 'nodeA'.
+ INFO Topology: Loading topology 'nodeD'.
+ INFO Experiment: Switching ON resources which are OFF
+ INFO ALL_UP_AND_INSTALLED: Event triggered. Starting the associated tasks.
+ INFO exp: starting
+ INFO exp: Request from Experiment Script: Wait for 5s....
+ INFO exp: All applications started...
+ INFO exp: Request from Experiment Script: Wait for 10s....
+ INFO property.packetsize: packetsize = 256 (Fixnum)
+ INFO exp: Request from Experiment Script: Wait for 10s....
+ INFO property.packetsize: packetsize = 512 (Fixnum)
+ INFO exp: Request from Experiment Script: Wait for 10s....
+ INFO property.packetsize: packetsize = 1024 (Fixnum)
+ INFO exp: Request from Experiment Script: Wait for 10s....
+ INFO exp: All applications stopped.
+ INFO EXPERIMENT_DONE: Event triggered. Starting the associated tasks.
+ INFO NodeHandler: 
+ INFO NodeHandler: Shutting down experiment, please wait...
+ INFO NodeHandler: 
+ INFO run: Experiment gimi20-2012-10-18t13.51.41-04.00 finished after 0:56
+}}}
+----
+
+[[BR]]
+[[BR]]