defProperty('server_node','omf.ufg.node8',"ID of server node")
defProperty('client_node','omf.ufg.node1',"ID of client node")
defProperty('runtime', 60, "Time in second for the experiment is to run")
defProperty('iperf_server_address', '192.168.137.2', "Iperf server IP address")
defProperty('iperf_client_address', '192.168.137.1', "Iperf client IP address")
defProperty('iperf_port', 2000, "Iperf port")
defProperty('iperf_interval', '1', "Iperf interval")
defProperty('iperf_isUDP', 'false', "Set Iperf UDP")
defProperty('iperf_bandwidth', '15M', 'Iperf bandwidth')

# Define the resources group 'Server'
defGroup('Server', property.server_node) do |node|
  node.addApplication("tutorials:iperf", :id => 'iperf_server') do |app|
    app.setProperty('server', true)
    app.setProperty('port', property.iperf_port)
    app.setProperty('interval', property.iperf_interval)
    app.setProperty('udp', (property.iperf_isUDP.value == 'true' ? true : false))
    app.setProperty('reportstyle', 'o')
    app.setProperty('oml-id', 'server')
    app.setProperty('oml-domain', 'wireless_experiment_iperf')
    app.setProperty('oml-collect', 'tcp:10.137.11.200:3004')
  end

  node.addApplication("tutorials:utils:wlanconfig", :id => 'server_wlanconfig') do |app|
    app.setProperty('wlan', 'wlan0')
    app.setProperty('mode', 'adhoc')
    app.setProperty('type', 'g')
    app.setProperty('channel', 6)
    app.setProperty('essid', 'omf_we')
    app.setProperty('ip_address', property.iperf_server_address)
    app.setProperty('duration', (property.runtime + 20))
  end
end

# Define the resources group 'Client'
defGroup('Client', property.client_node) do |node|
  node.addApplication("tutorials:iperf", :id => 'iperf_client') do |app|
    app.setProperty('client', property.iperf_server_address)
    app.setProperty('port', property.iperf_port)
    app.setProperty('interval', property.iperf_interval)
    app.setProperty('time', property.runtime)
    app.setProperty('udp', (property.iperf_isUDP.value == 'true' ? true : false))
    if property.iperf_isUDP.value == 'true'
      app.setProperty('bandwidth', property.iperf_bandwidth)
    end
    app.setProperty('reportstyle', 'o')
    app.setProperty('oml-id', 'client')
    app.setProperty('oml-domain', 'wireless_experiment_iperf')
    app.setProperty('oml-collect', 'tcp:10.137.11.200:3004')
  end

  node.addApplication("tutorials:utils:wlanconfig", :id => 'client_wlanconfig') do |app|
    app.setProperty('wlan', 'wlan0')
    app.setProperty('mode', 'adhoc')
    app.setProperty('type', 'g')
    app.setProperty('channel', 6)
    app.setProperty('essid', 'omf_we')
    app.setProperty('ip_address', property.iperf_client_address)
    app.setProperty('duration', (property.runtime + 20))
  end
end

onEvent(:ALL_UP_AND_INSTALLED) do |event|
  info "Running tutorial 1: Wireless experiment..."
  wait 10
  info "Configuring wireless network between nodes..."
  group("Server").startApplication('server_wlanconfig')
  group("Client").startApplication('client_wlanconfig')
  wait 5
  info "Starting iperf server..."
  group("Server").startApplication('iperf_server')
  wait 5
  info "Starting iperf client..."
  group("Client").startApplication('iperf_client')
  info "Iperf server and client started..."
  wait property.runtime
  info "Stopping iperf server and client..."
  wait 5
  allGroups.stopApplications
  info "Iperf server and client stopped..."
  Experiment.done
end

/**
 * Wireless experiment Controller
 */
public function wireless_experiment() {
    if(count($_POST) > 0) {
        $experimentProperties = array(
            "iperf_isUDP" => ($_POST['iperf_type'] == 'udp') ? 'true' : 'false'
        );

        if($_POST['iperf_type'] == 'udp') {
            $iperfSize = (is_numeric($_POST['iperf_bandwidth_size']) && $_POST['iperf_bandwidth_size'] > 0 && $_POST['iperf_bandwidth_size'] < 100) ?
                $_POST['iperf_bandwidth_size'] : 15;
            $experimentProperties['iperf_bandwidth'] = $iperfSize . 'M';
        }

        $experimentParams = array(
            "username" => $_SESSION[SECURITY_SESSION]['username'],
            "experiment" => "wireless_experiment",
            "properties" => $experimentProperties
        );
        $executeExperiment = api_call("execute_experiment", $experimentParams);
        $this->setExperimentMessageStatus($executeExperiment['method_result']['status']);
    }

    $methodParams = array(
        "experiment" => "wireless_experiment"
    );
    $isExperimentExecuting = api_call("is_experiment_executing", $methodParams);
    $isUserExecutingExperiment = $isExperimentExecuting['method_result'] == $_SESSION[SECURITY_SESSION]['username'];
    $isExperimentExecuting = $isExperimentExecuting['method_result'] != false;

    $experimentScript = api_call("getExperimentScript", $methodParams);
    $experimentScript = ($experimentScript["method_result"] !== false) ? $experimentScript["method_result"] : "";

    $this->setVariable("is_executing", $isExperimentExecuting);
    $this->setVariable("is_executing_by_user", $isUserExecutingExperiment);
    $this->setVariable("experiment_script", $experimentScript);
}

<head>
   <!--[if lte IE 8]>
   <script language="javascript" type="text/javascript" src="js/flot/excanvas.min.js"></script>
   <![endif]-->

   <script language="javascript" type="text/javascript" src="js/jquery/jquery.syntaxhighlighter.js"></script>
   <script language="javascript" type="text/javascript" src="js/flot/jquery.flot.js"></script>
   <script language="javascript" type="text/javascript" src="js/flot/jquery.flot.time.js"></script>
   <script language="javascript" type="text/javascript" src="js/flot/jquery.flot.resize.min.js"></script>
   <script language="javascript" type="text/javascript" src="js/flot/jquery.flot.selection.js"></script>
    <script language="javascript" type="text/javascript" src="js/tutorials/flot/statistics.common.js"></script>
    <script language="javascript" type="text/javascript" src="js/tutorials/flot/statistics.wireless_experiment.js"></script>
    <script language="javascript" type="text/javascript" src="js/tutorials/wireless_experiment.js"></script>
</head>

<?php
   $iperf_type = isset($_POST['iperf_type']) ? $_POST['iperf_type'] : "";
   $iperf_bandwidth_size = isset($_POST['iperf_bandwidth_size']) ? $_POST['iperf_bandwidth_size'] : "15";
?>

<div id='text'>
   <div class='title'>
      <a href='index.php'>Home</a> »
      <a href='index.php?controller=tutorials'>Tutorials</a> »
      Wireless experiment
   </div>
</div>

<form method='POST' action=''>
   <div class="box">
      <div class="box_header">
         Experiment description
      </div>
      
      <div class="box_body">
         <p>This experiment consists in an instrumented iperf (server/client) running on two icarus nodes through a wireless network. The proccess of the experiment is below:</p>
         <p>1. Automated nodes reservation.</p>
         <p>2. Since the nodes are reserved, we can use the nodes as we want. Now we will run an iperf server on the first node and an iperf client on the other one.</p>
         <p>3. The iperf is instrumented to collect and send the data periodically (every second) to the OML server.</p>
         <p>4. Since we have the iperf output data, we can plot the results in the chart below.</p>
         <p>5. You can set the experiment configuration to use TCP or UDP.</p>
      </div>
   </div>

   <div class="box">
      <div class="box_header">
         Experiment architecture
      </div>
      
      <div class="box_body">
         <p>Describes the experiment architecture</p>
      </div>
   </div>

    <div class="box">
        <div class="box_header">
            Experiment script
            <input type="button" value="Show" name="experiment_script" />
        </div>

        <div class="box_body highlight-box hidden">
            <pre class="highlight">
                <?= (!empty($experiment_script)) ? $experiment_script : "Experiment script not found!" ?>
            </pre>
        </div>
    </div>

   <div class="box">
      <div class="box_header">
         Experiment configuration
      </div>
      
      <div class="box_body">
         <table>
            <tr>
               <td>Iperf type:</td>
               <td colspan="3">
                  <select name="iperf_type">
                     <option value="tcp" <?= ($iperf_type == 'tcp') ? 'selected' : '' ?>>TCP</option>
                     <option value="udp" <?= ($iperf_type == 'udp') ? 'selected' : '' ?>>UDP</option>
                  </select>
               </td>
            </tr>
            <tr class="udp_field" style="display: none;">
               <td>Iperf bandwidth size (Mbits):</td>
               <td>
                  <input type="number" name="iperf_bandwidth_size" value="<?= $iperf_bandwidth_size ?>" min="1" />
               </td>
            </tr>
         </table>
      </div>
   </div>
   
   <div class="box">
      <div class="box_header">
         Experiment execution
         <input type="submit" value="Run" <?php if($is_executing) { echo "disabled"; } ?> />
      </div>
      
      <div class="box_body">
         <?php if($is_executing): ?>
            <center class="hide-when-done"><b>This tutorial experiment is already running...</b></center>
         <?php endif; ?>
         
         <div class="box">
            <div class="box-header with-border">
               <h3 class="box-title">Experiment throughput monitoring</h3>
               <div class="box-tools pull-right">
                  Real time
                  <div class="btn-group realtime" data-toggle="btn-toggle">
                    <button type="button" class="btn btn-default btn-xs" data-toggle="on">On</button>
                    <button type="button" class="btn btn-default btn-xs" data-toggle="off">Off</button>
                  </div>
                  <button type="button" class="btn btn-default btn-xs btn-zoom-out">Zoom out</button>
               </div>
            </div>
            <div class="box-body">
               <div id="throughput-graph" style="height: 300px;"></div>
            </div>
            <div class="box-footer clearfix">
               <div id="throughput-legend" class="legend"></div> 
            </div>
         </div>
      </div>
   </div>
   
   <?php if($is_executing_by_user): ?>
   <div class="box">
      <div class="box_header">
         Experiment console output
      </div>
      
      <div class="box_body">
         <div id="experimentOutput" style="color: white; background: black; width: calc(100% - 10px); height: 300px; overflow-y: scroll; padding: 5px;"></div>
      </div>
   </div>
   <?php endif; ?>
</form>

<div class="box">
   <div class="box-header with-border">
      <h3 class="box-title">Experiment throughput monitoring</h3>
      <div class="box-tools pull-right">
         Real time
         <div class="btn-group realtime" data-toggle="btn-toggle">
           <button type="button" class="btn btn-default btn-xs" data-toggle="on">On</button>
           <button type="button" class="btn btn-default btn-xs" data-toggle="off">Off</button>
         </div>
         <button type="button" class="btn btn-default btn-xs btn-zoom-out">Zoom out</button>
      </div>
   </div>
   <div class="box-body">
      <div id="throughput-graph" style="height: 300px;"></div>
   </div>
   <div class="box-footer clearfix">
      <div id="throughput-legend" class="legend"></div> 
   </div>
</div>

$(function() {
   function getData(beforeTime, graph, zoomMode, nowGetTime) {
      var dataUrl = '/LS-Sched/?method=get_wireless_experiment_data' +
         '&before_time_size=' + ( beforeTime + 1 ) + '&now_get_time=' + nowGetTime;
      
      $.ajax({ 
         url: dataUrl,
         dataType: 'json',
         async: true,
         success: function(statistics) {
            var distance = getTimmerDistance(graph);
            
            updateData(statistics.method_result, graph);
            updateGraph(graph);
            
            if(zoomMode == false) {
               setTimeout(function(){ getData(distance, graph, false, null); }, 1000);
            }
            
            // Update console box
            try {
               var expOutput = statistics.method_result.output.replace(/\n/g, "<br />").replace("<br />", "").trim();
            } catch(e) {
               var expOutput = "";
            }
            
            try {
               if(expOutput) {
                  var experimentOutput = $("#experimentOutput");
                  if(experimentOutput.text() != expOutput.replace(/<br \/>/g, "")) {
                     var oldContent = experimentOutput.text().trim();
                     var isInBottom = ((experimentOutput.scrollTop() + experimentOutput.height() + 10) >= experimentOutput[0].scrollHeight);
                     
                     experimentOutput.html(expOutput);
                     
                     if(isInBottom || !oldContent) {
                        experimentOutput.scrollTop(experimentOutput[0].scrollHeight);
                     }
                  }
               }
            } catch(e) {}
            
            // Enable test run when its finished.
            try {
               if (expOutput.indexOf("INFO run: Experiment") >= 0) {
                  $("input[type=submit]").prop("disabled", false);
                  $(".hide-when-done").hide();
               }
            } catch(e) {}
         }
      });
   }
   
   function updateData( statistics, graph ) {
      if( graph.data.length == 0 ) { 
         graph.data.push({ 
            data: statistics.client,
            label: "Client output",
            name: "client"
         });
         
         graph.data.push({ 
            data: statistics.server,
            label: "Server input",
            name: "server"
         });
      } else {
         graph.data.forEach( function( graphData ) {
            switch( graphData.name ) {
               case "client":
                  var newData = statistics.client;
                  break;
               case "server":
                  var newData = statistics.server;
                  break;
            }
            graphData.data = graphData.data.concat(newData);
            graphData.data.sort( function(a, b){ return a[0] - b[0] } );
         });
      }
   }
   
   var pGraph = {
      type: "throughput",
      realTime: true,
      plot: {
         element: "#throughput-graph",
         graph: $.plot("#throughput-graph", [], getOptions("Mbps", [ "red", "blue" ], $("#throughput-legend")))
      },
      data: []
   };
   
   var zoomButton = $(pGraph.plot.element).parent().parent().find(".box-header .box-tools .btn-zoom-out");
   var realTimeButton = $(pGraph.plot.element).parent().parent().find(".box-header .box-tools .realtime .btn");
   
   // install select option
   $(pGraph.plot.element).bind("plotselected", function (event, ranges) {
      $(realTimeButton[1]).trigger("click");
      
      $.each(pGraph.plot.graph.getXAxes(), function(_, axis) {
         var opts = axis.options;
         opts.min = ranges.xaxis.from;
         opts.max = ranges.xaxis.to;
      });
      
      pGraph.plot.graph.setupGrid();
      pGraph.plot.graph.draw();
      pGraph.plot.graph.clearSelection();
   });
   
   // add zoom out button
   zoomButton.click(function (event) {
      event.preventDefault();
      $(realTimeButton[1]).trigger("click");
      
      $.each(pGraph.plot.graph.getXAxes(), function(_, axis) {
         var opts = axis.options;
         var distance = 0;
         var now = new Date().getTime() - 3000;
         if( opts.min != null ) {
            if( opts.max != null ) {
               distance = opts.max - opts.min;
            } else {
               distance = now- opts.min;
            }
            
            distance = distance / 2;
         }
         
         opts.min = opts.min - distance;
         if( opts.max == null ) {
            opts.max = now;
         } else {
            opts.max = opts.max + distance;
         }

         if( opts.max > now ) {
            opts.max = now;
         }
         
         if(pGraph.data.length > 0) {
            var firstDataTime = Math.floor(pGraph.data[0].data[0][0] / 1000);
            var optsTime = Math.floor(opts.min / 1000 );
            
            if( optsTime < firstDataTime ) {
               var beforeData = Math.round( ( firstDataTime -  optsTime ) );
               getData(beforeData, pGraph, true, firstDataTime);
               updateGraph(pGraph);
            }
         }
      });
      
      pGraph.plot.graph.setupGrid();
      pGraph.plot.graph.draw();
      pGraph.plot.graph.clearSelection();
   });
   
   // Configure real time buttons
   realTimeButton.click(function (event) {
      event.preventDefault();
      if ($(this).attr("data-toggle") === "on") {
         pGraph.plot.graph.clearSelection();
         updateRealTime( pGraph.plot.graph, 5 );
         
         pGraph.plot.graph.setupGrid();
         pGraph.plot.graph.draw();
         pGraph.realTime = true;
      } else {
         if(pGraph.realTime === true) {
            $.each( pGraph.plot.graph.getXAxes(), function(_, axis) {
               var opts = axis.options;
               opts.max = new Date().getTime() - 3000;
            });
         }
         pGraph.realTime = false;
      }
   });
   
   getData(1800, pGraph, false, null);
});

<div class="box">
   <div class="box_header">
      Experiment console output
   </div>
   
   <div class="box_body">
      <div id="experimentOutput" style="color: white; background: black; width: calc(100% - 10px); height: 300px; overflow-y: scroll; padding: 5px;"></div>
   </div>
</div>

// Update console box
try {
   var expOutput = statistics.method_result.output.replace(/\n/g, "<br />").replace("<br />", "").trim();
} catch(e) {
   var expOutput = "";
}

try {
   if(expOutput) {
      var experimentOutput = $("#experimentOutput");
      if(experimentOutput.text() != expOutput.replace(/<br \/>/g, "")) {
         var oldContent = experimentOutput.text().trim();
         var isInBottom = ((experimentOutput.scrollTop() + experimentOutput.height() + 10) >= experimentOutput[0].scrollHeight);
         
         experimentOutput.html(expOutput);
         
         if(isInBottom || !oldContent) {
            experimentOutput.scrollTop(experimentOutput[0].scrollHeight);
         }
      }
   }
} catch(e) {}

// Enable test run when its finished.
try {
   if (expOutput.indexOf("INFO run: Experiment") >= 0) {
      $("input[type=submit]").prop("disabled", false);
      $(".hide-when-done").hide();
   }
} catch(e) {}

/**
 * Gets the wireless experiment data.
 * @param array $parameters containing the treated call parameters.
 * @return array containing the wireless experiment data.
 */
public function getWirelessExperimentData($parameters)
{
    $beforeTimeSize = isset($parameters["before_time_size"]) ? $parameters["before_time_size"] : null;
    $nowGetTime = isset($parameters["now_get_time"]) ? $parameters["now_get_time"] : null;
    $experiment = "wireless_experiment";

    $return  = $this->Experiment->getIperfData($experiment . "_iperf", $nowGetTime, $beforeTimeSize);

    // Gets the experiment output
    $ownerExperiment = $this->Experiment->getExperimentSlice($experiment);
    if($ownerExperiment === false) {
        $return['output'] = "";
    } else {
        $return['output'] = $this->experimentService->getExperimentOutput($experiment,
            $ownerExperiment["username"], $ownerExperiment["slice"]);
    }

    return $return;
}

/**
 * Gets the obligatory and optional parameters to execute the api call method.
 * @return array containing the obligatory and the optional parameters to execute the api call method.
 */
public function getMethodParameters()
{
    $params = parent::getMethodParameters();

    $obParams = [];
    $opParams = [];
    switch($this->getApiCall()) {
        case "executeExperiment":
            $obParams = [
                'username' => 'string',
                'experiment' => 'string',
                'properties' => 'array'
            ];
            break;
        case "isExperimentExecuting":
        case "getExperimentScript":
            $obParams = [
                'experiment' => 'string'
            ];
            break;
        case "getWirelessExperimentData":
        case "getTcpBitrateExperimentData":
        case "getPowerControlExperimentData":
            $obParams = [
                'before_time_size' => 'numeric'
            ];
            $opParams = [
                'now_get_time' => 'numeric'
            ];
            break;
    }

    $params["obligatory"] = array_merge($params["obligatory"], $obParams);
    $params["optional"] = array_merge($params["optional"], $opParams);

    return $params;
}

/**
 * Method executed before execute the api call method
 * Verifies if is possible or not to execute the API call method.
 * @return bool True if the api call method can be executed or False if not.
 */
public function beforeFilter()
{
    $noAuthMethods = ['getWirelessExperimentData', 'getTcpBitrateExperimentData', 'getPowerControlExperimentData'];
    if(in_array($this->getApiCall(), $noAuthMethods)) {
        return true;
    }

    return parent::beforeFilter();
}