Changes between Version 31 and Version 32 of Tutorials/a0Basic/Tutorial2

Timestamp:

Feb 12, 2013, 11:57:58 PM (11 years ago)

Author:

ssugrim

Comment:

—

Tutorials/a0Basic/Tutorial2

@@ -28 +28 @@
 {{{
 #
-# A)  Define the 'sender' group, which has the unique node [1,1]
-#     Nodes in this group will execute the application 'test:proto:sender'
-#
-defGroup('sender', [1,1]) {|node|
-
-  node.prototype("test:proto:sender", {
-    'destinationHost' => '192.168.1.2',
-    'packetSize' => 1024,
-    'rate' => 300,
-    'protocol' => 'udp'    
-  })
-
-  node.net.w0.mode = "managed"
-}
-
-#
-# B)  Define the 'receiver' group, which has the unique node [1,2]
-#     Nodes in this group will execute the application 'test:proto:receiver'
-#
-defGroup('receiver', [1,2]) {|node|
-
-  node.prototype("test:proto:receiver" , {
-    'protocol' => 'udp'
-  })
-
-  node.net.w0.mode = "master"
-}
-
-# 
-# C)  Configure the wireless interfaces of all the nodes involved in 
-#     this experiment
-#
-allGroups.net.w0 { |w|
-  w.type = 'b'
-  w.channel = "6"
-  w.essid = "helloworld"
-  w.ip = "%192.168.%x.%y"
-}
-
-#
-# D)  When all the nodes are turned On and the all the applications
-#     are installed and ready, we can start to perform the experiment
-#
-whenAllInstalled() {|node|
-
-  wait 30 
-
+# Tutorial experiment
+#
+defProperty('duration', 60, "Duration of the experiment")
+defProperty('graph', false, "Display graph or not")
+
+baseTopo = Topology['system:topo:imaged']
+
+st = defTopology("sender") do |t|
+  t.addNode(baseTopo.getNodeByIndex(0))
+end
+
+rt = defTopology("receiver") do |t|
+  t.addNode(baseTopo.getNodeByIndex(1))
+end
+ 
+defGroup('Sender', "sender") do |node|
+  node.addApplication("test:app:otg2") do |app|
+    app.setProperty('udp:local_host', '192.168.0.2')
+    app.setProperty('udp:dst_host', '192.168.0.3')
+    app.setProperty('udp:dst_port', 3000)
+    app.measure('udp_out', :samples => 1)
+  end
+  node.net.w1.mode = "adhoc"
+  node.net.w1.type = 'g'
+  node.net.w1.channel = "6"
+  node.net.w1.essid = "helloworld"
+  node.net.w1.ip = "192.168.0.2"
+end
+
+defGroup('Receiver', "receiver") do |node|
+  node.addApplication("test:app:otr2") do |app|
+    app.setProperty('udp:local_host', '192.168.0.3')
+    app.setProperty('udp:local_port', 3000)
+    app.measure('udp_in', :samples => 1)
+  end
+  node.net.w1.mode = "adhoc"
+  node.net.w1.type = 'g'
+  node.net.w1.channel = "6"
+  node.net.w1.essid = "helloworld"
+  node.net.w1.ip = "192.168.0.3"
+end
+
+onEvent(:ALL_UP_AND_INSTALLED) do |event|
+  info "This is my first OMF experiment"
+  wait 15
   allGroups.startApplications
-  wait 40
-
+  info "All my Applications are started now..."
+  wait property.duration
+  allGroups.stopApplications
+  info "All my Applications are stopped now."
   Experiment.done
-}
+end
+
+if property.graph.value 
+  addTab(:defaults)
+  addTab(:graph2) do |tab|
+    opts = { :postfix => %{This graph shows the Sequence Number from the UDP traffic.}, :updateEvery => 1 }
+    tab.addGraph("Sequence_Number", opts) do |g|
+      dataOut = Array.new
+      dataIn = Array.new
+      mpOut = ms('udp_out')
+      mpIn = ms('udp_in')
+      mpOut.project(:oml_ts_server, :seq_no).each do |sample|
+        dataOut << sample.tuple
+      end
+      mpIn.project(:oml_ts_server, :seq_no).each do |sample|
+        dataIn << sample.tuple
+      end
+      g.addLine(dataOut, :label => "Sender (outgoing UDP)")
+      g.addLine(dataIn, :label => "Receiver (incoming UDP)")
+    end
+  end
+end
 }}}