Changes between Version 30 and Version 31 of GIMIv1.1Tutorial/Orchestrate


Ignore:
Timestamp:
10/18/12 14:16:20 (12 years ago)
Author:
Cong
Comment:

--

Legend:

Unmodified
Added
Removed
Modified

  • GIMIv1.1Tutorial/Orchestrate

    v30 v31  
    120120
    121121{{{
    122 
     122 INFO NodeHandler: OMF Experiment Controller 5.4 (git e0eefcf)
     123 INFO NodeHandler: Slice ID: gimi20
     124 INFO NodeHandler: Experiment ID: gimi20-2012-10-18t14.14.10-04.00
     125 INFO NodeHandler: Message authentication is disabled
     126 WARN NodeHandler: AM support disabled - any service calls will fail!
     127 INFO Experiment: load system:exp:stdlib
     128 INFO property.resetDelay: resetDelay = 210 (Fixnum)
     129 INFO property.resetTries: resetTries = 1 (Fixnum)
     130 INFO Experiment: load system:exp:eventlib
     131 INFO Experiment: load routing.rb
     132 INFO Topology: Loading topology 'nodeA'.
     133 INFO Topology: Loading topology 'nodeB'.
     134 INFO Topology: Loading topology 'nodeC'.
     135 INFO Topology: Loading topology 'nodeD'.
     136 INFO Topology: Loading topology 'nodeE'.
     137 INFO Experiment: Switching ON resources which are OFF
     138 INFO ALL_UP: Event triggered. Starting the associated tasks.
     139 INFO exp: Request from Experiment Script: Wait for 1s....
     140 INFO exp: Changing routing setup
     141 INFO exp: Routing setup finished
     142 INFO exp: Request from Experiment Script: Wait for 5s....
     143 INFO exp: Stopping applications
     144 INFO exp: Request from Experiment Script: Wait for 1s....
     145 INFO EXPERIMENT_DONE: Event triggered. Starting the associated tasks.
     146 INFO NodeHandler:
     147 INFO NodeHandler: Shutting down experiment, please wait...
     148 INFO NodeHandler:
     149 INFO run: Experiment gimi20-2012-10-18t14.14.10-04.00 finished after 0:16
    123150}}}
    124151
    … …  
    293320
    294321{{{
    295 
     322 INFO NodeHandler: OMF Experiment Controller 5.4 (git e0eefcf)
     323 INFO NodeHandler: Slice ID: gimi20
     324 INFO NodeHandler: Experiment ID: gimi20-2012-10-18t14.03.42-04.00
     325 INFO NodeHandler: Message authentication is disabled
     326 WARN NodeHandler: AM support disabled - any service calls will fail!
     327 INFO Experiment: load system:exp:stdlib
     328 INFO property.resetDelay: resetDelay = 210 (Fixnum)
     329 INFO property.resetTries: resetTries = 1 (Fixnum)
     330 INFO Experiment: load system:exp:eventlib
     331 INFO Experiment: load ping_all.rb
     332 INFO property.source1: source1 = "nodeA" (String)
     333 INFO property.source2: source2 = "nodeB" (String)
     334 INFO property.source3: source3 = "nodeC" (String)
     335 INFO property.source4: source4 = "nodeD" (String)
     336 INFO property.source5: source5 = "nodeE" (String)
     337 INFO property.sinkaddr11: sinkaddr11 = "192.168.4.10" (String)
     338 INFO property.sinkaddr12: sinkaddr12 = "192.168.5.12" (String)
     339 INFO property.sinkaddr21: sinkaddr21 = "192.168.4.11" (String)
     340 INFO property.sinkaddr22: sinkaddr22 = "192.168.2.12" (String)
     341 INFO property.sinkaddr23: sinkaddr23 = "192.168.1.13" (String)
     342 INFO property.sinkaddr31: sinkaddr31 = "192.168.5.11" (String)
     343 INFO property.sinkaddr32: sinkaddr32 = "192.168.2.10" (String)
     344 INFO property.sinkaddr33: sinkaddr33 = "192.168.3.13" (String)
     345 INFO property.sinkaddr34: sinkaddr34 = "192.168.6.14" (String)
     346 INFO property.sinkaddr41: sinkaddr41 = "192.168.1.10" (String)
     347 INFO property.sinkaddr42: sinkaddr42 = "192.168.3.12" (String)
     348 INFO property.sinkaddr51: sinkaddr51 = "192.168.6.12" (String)
     349 INFO Topology: Loading topology 'nodeA'.
     350 INFO Topology: Loading topology 'nodeB'.
     351 INFO Topology: Loading topology 'nodeC'.
     352 INFO Topology: Loading topology 'nodeD'.
     353 INFO Topology: Loading topology 'nodeE'.
     354 INFO Experiment: Switching ON resources which are OFF
     355 INFO ALL_UP_AND_INSTALLED: Event triggered. Starting the associated tasks.
     356 INFO exp: Starting the ping
     357 INFO exp: Request from Experiment Script: Wait for 5s....
     358 INFO exp: Stopping the ping
     359 INFO EXPERIMENT_DONE: Event triggered. Starting the associated tasks.
     360 INFO NodeHandler:
     361 INFO NodeHandler: Shutting down experiment, please wait...
     362 INFO NodeHandler:
     363 INFO run: Experiment gimi20-2012-10-18t14.03.42-04.00 finished after 0:16
    296364}}}
    297365
    … …  
    302370The one we use for this tutorial is shown below.
    303371{{{
    304 
    305 }}}
    306 
    307 You should see the following output after executing the omf command.
    308 
    309 {{{
    310 
     372defProperty('theSender','nodeB','ID of sender node')
     373defProperty('theReceiver1', 'nodeE', "ID of receiver node")
     374defProperty('theReceiver2', 'nodeA', "ID of receiver node")
     375defProperty('theReceiver3', 'nodeD', "ID of receiver node")
     376defProperty('packetsize', 128, "Packet size (byte) from the sender node")
     377defProperty('bitrate', 2048, "Bitrate (bit/s) from the sender node")
     378defProperty('runtime', 40, "Time in second for the experiment is to run")
     379
     380defGroup('Sender',property.theSender) do |node|
     381    options = { 'sample-interval' => 2 }
     382    node.addPrototype("system_monitor", options)
     383    node.addApplication("test:app:otg2") do |app|
     384        app.setProperty('udp:local_host', '192.168.2.10')
     385        app.setProperty('udp:dst_host', '192.168.6.14')
     386        app.setProperty('udp:dst_port', 3000)
     387        app.setProperty('cbr:size', property.packetsize)
     388        app.setProperty('cbr:rate', property.bitrate * 2)
     389        app.measure('udp_out', :samples => 1)
     390    end
     391   
     392    node.addApplication("test:app:otg2") do |app|
     393        app.setProperty('udp:local_host', '192.168.4.10')
     394        app.setProperty('udp:dst_host', '192.168.4.11')
     395        app.setProperty('udp:dst_port', 3000)
     396        app.setProperty('cbr:size', property.packetsize)
     397        app.setProperty('cbr:rate', property.bitrate * 2)
     398        app.measure('udp_out', :samples => 1)
     399    end
     400   
     401    node.addApplication("test:app:otg2") do |app|
     402        app.setProperty('udp:local_host', '192.168.1.10')
     403        app.setProperty('udp:dst_host', '192.168.1.13')
     404        app.setProperty('udp:dst_port', 3000)                                   
     405        app.setProperty('cbr:size', property.packetsize)                                           
     406        app.setProperty('cbr:rate', property.bitrate * 2)                                                   
     407        app.measure('udp_out', :samples => 1)                                                       
     408    end
     409end
     410
     411defGroup('Receiver1',property.theReceiver1) do |node|
     412    options = { 'sample-interval' => 2 }
     413    node.addPrototype("system_monitor", options)
     414
     415    node.addApplication("test:app:otr2") do |app|
     416        app.setProperty('udp:local_host', '192.168.6.14')
     417        app.setProperty('udp:local_port', 3000)
     418        app.measure('udp_in', :samples => 1)
     419    end
     420end
     421
     422defGroup('Receiver2',property.theReceiver2) do |node|
     423    options = { 'sample-interval' => 2 }
     424    node.addPrototype("system_monitor", options)
     425    node.addApplication("test:app:otr2") do |app|
     426        app.setProperty('udp:local_host', '192.168.4.11')
     427        app.setProperty('udp:local_port', 3000)
     428        app.measure('udp_in', :samples => 1)
     429    end
     430end
     431
     432defGroup('Receiver3',property.theReceiver3) do |node|     
     433    options = { 'sample-interval' => 2 }
     434    node.addPrototype("system_monitor", options)
     435    node.addApplication("test:app:otr2") do |app|                   
     436        app.setProperty('udp:local_host', '192.168.1.13')
     437        app.setProperty('udp:local_port', 3000)                               
     438        app.measure('udp_in', :samples => 1)                                   
     439    end
     440end
     441
     442onEvent(:ALL_UP_AND_INSTALLED) do |event|
     443    info "starting"
     444    wait 5
     445    allGroups.exec("ln -s /usr/local/bin/otr2 /usr/bin/otr2")
     446    allGroups.exec("ln -s /usr/local/bin/otg2 /usr/bin/otg2")
     447    allGroups.exec("ln -s /usr/local/bin/oml2-nmetrics /usr/bin/oml2-nmetrics")
     448    allGroups.startApplications
     449    info "All applications started..."
     450    wait property.runtime / 4
     451    property.packetsize = 256
     452    wait property.runtime / 4
     453    property.packetsize = 512
     454    wait property.runtime / 4
     455    property.packetsize = 1024
     456    wait property.runtime / 4
     457    allGroups.stopApplications
     458    info "All applications stopped."
     459    Experiment.done
     460end
     461}}}
     462
     463You should see the following output (or similar) after executing the omf command.
     464
     465{{{
     466 INFO NodeHandler: OMF Experiment Controller 5.4 (git e0eefcf)
     467 INFO NodeHandler: Slice ID: gimi20
     468 INFO NodeHandler: Experiment ID: gimi20-2012-10-18t13.51.41-04.00
     469 INFO NodeHandler: Message authentication is disabled
     470 WARN NodeHandler: AM support disabled - any service calls will fail!
     471 INFO Experiment: load system:exp:stdlib
     472 INFO property.resetDelay: resetDelay = 210 (Fixnum)
     473 INFO property.resetTries: resetTries = 1 (Fixnum)
     474 INFO Experiment: load system:exp:eventlib
     475 INFO Experiment: load otg_nmetrics.rb
     476 INFO property.theSender: theSender = "nodeB" (String)
     477 INFO property.theReceiver1: theReceiver1 = "nodeE" (String)
     478 INFO property.theReceiver2: theReceiver2 = "nodeA" (String)
     479 INFO property.theReceiver3: theReceiver3 = "nodeD" (String)
     480 INFO property.packetsize: packetsize = 128 (Fixnum)
     481 INFO property.bitrate: bitrate = 2048 (Fixnum)
     482 INFO property.runtime: runtime = 40 (Fixnum)
     483 INFO Topology: Loading topology 'nodeB'.
     484 INFO Topology: Loading topology 'nodeE'.
     485 INFO Topology: Loading topology 'nodeA'.
     486 INFO Topology: Loading topology 'nodeD'.
     487 INFO Experiment: Switching ON resources which are OFF
     488 INFO ALL_UP_AND_INSTALLED: Event triggered. Starting the associated tasks.
     489 INFO exp: starting
     490 INFO exp: Request from Experiment Script: Wait for 5s....
     491 INFO exp: All applications started...
     492 INFO exp: Request from Experiment Script: Wait for 10s....
     493 INFO property.packetsize: packetsize = 256 (Fixnum)
     494 INFO exp: Request from Experiment Script: Wait for 10s....
     495 INFO property.packetsize: packetsize = 512 (Fixnum)
     496 INFO exp: Request from Experiment Script: Wait for 10s....
     497 INFO property.packetsize: packetsize = 1024 (Fixnum)
     498 INFO exp: Request from Experiment Script: Wait for 10s....
     499 INFO exp: All applications stopped.
     500 INFO EXPERIMENT_DONE: Event triggered. Starting the associated tasks.
     501 INFO NodeHandler:
     502 INFO NodeHandler: Shutting down experiment, please wait...
     503 INFO NodeHandler:
     504 INFO run: Experiment gimi20-2012-10-18t13.51.41-04.00 finished after 0:56
    311505}}}
    312506----