commit 4b4c8af9f059ef1075251dfe4afb6482febe838e
author Paul Greyson <someone.named.paul@gmail.com> Thu Apr 04 09:02:09 2013 -0700
committer Paul Greyson <someone.named.paul@gmail.com> Thu Apr 04 09:02:09 2013 -0700
tree 10425e31a3eff8925134a9b66a7601572dddfb62
parent 280a27564500fb64b0d903bb822464025f335db9

setting up iperf session

web/topology_rest.py

diff --git a/web/topology_rest.py b/web/topology_rest.py
index e7e1d83..4ed3ae5 100755
--- a/web/topology_rest.py
+++ b/web/topology_rest.py
@@ -153,6 +153,34 @@
 
   resp = Response(result, status=200, mimetype='application/json')
   return resp
+
+@app.route("/proxy/gui/iperf/start/<flow_id>/<duration>/<samples>")
+def proxy_iperf_start(flow_id,duration,samples):
+  try:
+    command = "curl -s %s/gui/iperf/start/%s/%s/%s" % (ONOS_GUI3_CONTROL_HOST, flow_id, duration, samples)
+    print command
+    result = os.popen(command).read()
+  except:
+    print "REST IF has issue"
+    exit
+
+  resp = Response(result, status=200, mimetype='application/json')
+  return resp
+
+@app.route("/proxy/gui/iperf/rate/<flow_id>")
+def proxy_iperf_rate(flow_id):
+  try:
+    command = "curl -s %s/gui/iperf/rate/%s" % (ONOS_GUI3_CONTROL_HOST, flow_id)
+    print command
+    result = os.popen(command).read()
+  except:
+    print "REST IF has issue"
+    exit
+
+  resp = Response(result, status=200, mimetype='application/json')
+  return resp
+
+
 @app.route("/wm/core/topology/switches/all/json")
 def switches():
   if request.args.get('proxy') == None:
@@ -204,7 +232,7 @@
     print "REST IF has issue"
     exit
 
-    
+
   resp = Response(result, status=200, mimetype='application/json')
   return resp
 
@@ -858,7 +886,7 @@
   print cmd_string
   os.popen(cmd_string)
 
-  return 
+  return
 
 #* Get Iperf Throughput
 #http://localhost:9000/gui/iperf/rate/<flow_id>