commit a5875da1feaa1fc29433c221266b31937d637c0d
author suibin zhang <suibin@onlab.us> Sat Apr 02 20:54:50 2016 -0700
committer suibin zhang <suibin@onlab.us> Sat Apr 02 20:54:50 2016 -0700
tree f2f5c2e3452974ee5b39764fa4a54b076808955b
parent 37e4aa900ebeec9ed46d913147fdafe2d4991de2

add multi-threaded REST load generator

Change-Id: Ia73fe2ba3eaf50846041f73038460270c9802f4e

TestON/drivers/common/api/controller/onosrestdriver.py

diff --git a/TestON/drivers/common/api/controller/onosrestdriver.py b/TestON/drivers/common/api/controller/onosrestdriver.py
index ed7786c..2a62276 100644
--- a/TestON/drivers/common/api/controller/onosrestdriver.py
+++ b/TestON/drivers/common/api/controller/onosrestdriver.py
@@ -21,6 +21,7 @@
 import requests
 import types
 import sys
+from Queue import Queue
 
 from drivers.common.api.controllerdriver import Controller
 
@@ -1715,6 +1716,12 @@
             main.cleanup()
             main.exit()
 
+    def sendFlowBatchQueue(self, q=Queue(), ip="DEFAULT", port="DEFAULT", debug=False):
+        while True:
+            item = q.get()
+            self.sendFlowBatch(batch = item)
+            q.task_done()
+
     def removeFlowBatch( self, batch={},
                        ip="DEFAULT", port="DEFAULT" ):
         """