commit dec01c52c2197f2e6a9d408cf0658c5c95aba430
author suibin zhang <suibin@onlab.us> Tue Mar 29 19:23:33 2016 -0700
committer suibin zhang <suibin@onlab.us> Tue Mar 29 19:23:33 2016 -0700
tree d64b5db0754c33bae1c39866e1a14b485ed8fcdb
parent 570cb4544ae579d017cc1c3c1185f5f07943c738

add rate cal

Change-Id: I6c5ee0a0dce6c1ea40f8febf88fd3b897030ebdb

TestON/tests/COMPflow/COMPflow.py

diff --git a/TestON/tests/COMPflow/COMPflow.py b/TestON/tests/COMPflow/COMPflow.py
index 90e8814..65431f2 100644
--- a/TestON/tests/COMPflow/COMPflow.py
+++ b/TestON/tests/COMPflow/COMPflow.py
@@ -267,16 +267,17 @@
             time.sleep(0.5)
         tAllAdded = time.time()
 
-        numFlows = int(main.params['CASE1000']['batches']) *\
+        main.numFlows = int(main.params['CASE1000']['batches']) *\
                                                     int(main.params['CASE1000']['batchSize'])
-        main.log.info("Total number of flows: " + str (numFlows) )
+        main.log.info("Total number of flows: " + str (main.numFlows) )
         main.log.info("Sum of each POST elapse time: " + str(numpy.sum(postTimes)) )
         main.log.info("Total POST elapse time: " + str(tLastPostEnd-tStartPost))
+        main.log.info("Rate of ADD Controller response: " + str(main.numFlows / (tLastPostEnd - tStartPost)))
 
         duration = tAllAdded - tLastPostEnd
         main.log.info("Elapse time from end of last REST POST to Flows in ADDED state: " +\
                       str(duration))
-        main.log.info("Rate of Batch Flow add is (flows/sec): " + str( numFlows / duration))
+        main.log.info("Rate of Batch Flow add is (flows/sec): " + str( main.numFlows / duration))
 
     def CASE2000(self, main):
         import time
@@ -310,9 +311,12 @@
                                                     int(main.params['CASE10']['numSw'])) )
         main.log.info("Sum of each DELETE elapse time: " + str(numpy.sum(rmTimes)) )
         main.log.info("Total DELETE elapse time: " + str(tLastRemoveEnd-tStartRemove))
+        main.log.info("Rate of ADD Controller response: " + str(main.numFlows / (tLastRemoveEnd - tStartRemove)))
 
-        main.log.info("Elapse time from end of last REST POST to Flows in DELETED state: " +\
-                      str(tAllRemoved - tLastRemoveEnd))
+        duration = tAllRemoved - tLastRemoveEnd
+        main.log.info("Elapse time from end of last REST POST to Flows in ADDED state: " +\
+                      str(duration))
+        main.log.info("Rate of Batch Flow add is (flows/sec): " + str( main.numFlows / duration))
 
     def CASE100(self,main):
         from pprint import pprint
@@ -320,7 +324,7 @@
         main.case( "Check to ensure onos flows." )
 
         resp = main.ONOSrest.checkFlowsState()
-        pprint(resp)
+        #pprint(resp)
 
 
     def CASE110( self, main ):