Modify POSCA code into PEP8 style

JIRA: BOTTLENECK-102

Modify all the code in the testcase POSCA into PEP8 style.
Using more standard way to realize our function.

Change-Id: Ic014678db454b8a36b36395c32b4769f6cf700be
Signed-off-by: liyin <liyin11@huawei.com>

7 files changed, 450 insertions, 299 deletions

diff --git a/testsuites/posca/run_posca.py b/testsuites/posca/run_posca.py
index 9f90b3c7..48376b54 100755
--- a/testsuites/posca/run_posca.py
+++ b/testsuites/posca/run_posca.py
@@ -8,32 +8,36 @@
 # http://www.apache.org/licenses/LICENSE-2.0

 ##############################################################################

 

-import os

 import sys

 import subprocess

 

 INTERPRETER = "/usr/bin/python"

-#------------------------------------------------------

+# ------------------------------------------------------

 # run posca testcase

 # ------------------------------------------------------

+

+

 def posca_run(arg):

-    print "========== run posca ==========="

+    print("========== run posca ==========")

     if(arg == "factor_system_bandwidth"):

-        print "========== run posca_system_bandwidth ==========="

-        cmd = '/home/opnfv/bottlenecks/testsuites/posca/testcase_script/posca_factor_system_bandwidth.py'

-        pargs = [INTERPRETER,cmd]

+        print("========== run posca_system_bandwidth ===========")

+        cmd = '/home/opnfv/bottlenecks/testsuites/posca/testcase_script/\

+                posca_factor_system_bandwidth.py'

+        pargs = [INTERPRETER, cmd]

         sub_result = subprocess.Popen(pargs)

         sub_result.wait()

 

+

 def posca_env_check():

-    print "========== posca env check ==========="

+    print("========== posca env check ===========")

+

 

 def main():

-    para_testname = sys.argv[0]

+    # para_testname = sys.argv[0]

     para_test_arg = sys.argv[1]

     posca_env_check()

     posca_run(para_test_arg)

     sys.exit(0)

 

-if __name__=='__main__':

+if __name__ == '__main__':

     main()

diff --git a/testsuites/posca/testcase_script/posca_factor_cpu_burden.py b/testsuites/posca/testcase_script/posca_factor_cpu_burden.py
index 0b3b2319..8a51a3d2 100644
--- a/testsuites/posca/testcase_script/posca_factor_cpu_burden.py
+++ b/testsuites/posca/testcase_script/posca_factor_cpu_burden.py
@@ -15,103 +15,121 @@ import logging
 import ConfigParser
 import json
 
-#------------------------------------------------------
+# ------------------------------------------------------
 # parser for configuration files in each test case
 # ------------------------------------------------------
 parser = argparse.ArgumentParser()
 parser.add_argument("-c", "--conf",
-                    help="configuration files for the testcase, in yaml format",
-                    default="/home/opnfv/bottlenecks/testsuites/posca/testcase_cfg/posca_factor_cpu_burden.yaml")
+                    help="configuration files for the testcase,\
+                        in yaml format",
+                    default="/home/opnfv/bottlenecks/testsuites/posca/\
+                        testcase_cfg/posca_factor_tx_pkt_size.yaml")
 args = parser.parse_args()
-
-cmd="curl -i"
-order_arg="-H \"Content-Type: application/json\" -X POST -d \'{\"cmd\": \"start\", \"opts\":{\"output-file\": \"/tem/yardstick.out\"}, \"args\": \"../samples/netperf.yaml\"}'"
-
-#--------------------------------------------------
+# --------------------------------------------------
 # logging configuration
-#--------------------------------------------------
+# --------------------------------------------------
 logger = logging.getLogger(__name__)
+cmd = "curl -i"
+order_arg = "-H \"Content-Type: application/json\" -X POST -d \'{\"cmd\": \
+            \"start\", \"opts\":{\"output-file\": \"/tem/yardstick.out\"}, \
+            \"args\": \"../samples/netperf.yaml\"}'"
+
 
 def posca_env_check():
-    print "========== posca system bandwidth env check ==========="
-    if os.path.exists(r'/home/opnfv/bottlenecks/testsuites/posca/test_result/'):
+    print("========== posca system bandwidth env check ===========")
+    filepath = r"/home/opnfv/bottlenecks/testsuites/posca/test_result/"
+    if os.path.exists(filepath):
         return True
     else:
         os.mkdirs(r'/home/opnfv/bottlenecks/testsuites/posca/test_result/')
 
-def posca_output_result(time_new,input_1,input_2,input_3,input_4,input_5,input_6):
-    save_dic={}
-    save_dic['tx_pkt_size']=input_1
-    save_dic['rx_cache_size']=input_2
-    save_dic['tx_cache_size']=input_3
-    save_dic['throughput ']=input_4
-    save_dic['latency']=input_5
-    save_dic['cpu_load']=input_6
-    with open("/home/opnfv/bottlenecks/testsuites/posca/test_result/factor_cpu_burden_%s.json"%(time_new),"a") as f:
-        f.write(json.dumps(save_dic,f))
+
+def posca_output_result(time_new, input_1, input_2, input_3,
+                        input_4, input_5, input_6):
+    save_dic = {}
+    save_dic['tx_pkt_size'] = input_1
+    save_dic['rx_cache_size'] = input_2
+    save_dic['tx_cache_size'] = input_3
+    save_dic['throughput '] = input_4
+    save_dic['latency'] = input_5
+    save_dic['cpu_load'] = input_6
+    with open("/home/opnfv/bottlenecks/testsuites/posca/test_result/\
+            factor_tx_cache_size_%s.json" % (time_new), "a") as f:
+        f.write(json.dumps(save_dic, f))
         f.write("\n")
 
+
 def posca_config_read(config_str):
-    print "========== posca system bandwidth config read ==========="
+    print("========== posca system bandwidth config read ===========")
 
     con_dic = {}
     config = ConfigParser.ConfigParser()
-    with open(config_str,"rd") as cfgfile:
+    with open(config_str, "rd") as cfgfile:
         config.readfp(cfgfile)
-        con_dic['test_ip']=config.get("config","test_ip")
-        con_dic['test_throughput']=config.get("config","throughput")
-        con_dic['test_tool']=config.get("config","tool")
-        con_dic['test_time']=config.get("config","test_time")
-        con_dic['test_protocol']=config.get("config","protocol")
-        con_dic['test_pkt_s']=config.get("config","pkt sizes")
-        con_dic['test_tx_cache_s']=config.get("config","tx cache sizes")
-        con_dic['test_rx_cache_s']=config.get("config","rx cache sizes")
-        con_dic['test_cpu_load']=config.get("config","cpu load")
-        con_dic['test_latency']=config.get("config","latency")
-
-        con_dic['test_rx_flavor']=config.get("flavor_config","rx_flavor")
-        con_dic['test_tx_flavor']=config.get("flavor_config","tx_flavor")
+        con_dic['test_ip'] = config.get("config", "test_ip")
+        con_dic['test_throughput'] = config.get("config", "throughput")
+        con_dic['test_tool'] = config.get("config", "tool")
+        con_dic['test_time'] = config.get("config", "test_time")
+        con_dic['test_protocol'] = config.get("config", "protocol")
+        con_dic['test_pkt_s'] = config.get("config", "pkt sizes")
+        con_dic['test_tx_cache_s'] = config.get("config", "tx cache sizes")
+        con_dic['test_rx_cache_s'] = config.get("config", "rx cache sizes")
+        con_dic['test_cpu_load'] = config.get("config", "cpu load")
+        con_dic['test_latency'] = config.get("config", "latency")
+        con_dic['test_rx_flavor'] = config.get("flavor_config", "rx_flavor")
+        con_dic['test_tx_flavor'] = config.get("flavor_config", "tx_flavor")
     return con_dic
 
+
 def posca_run(con_dic):
-    print "========== run posca system bandwidth ==========="
+    print("========== run posca system bandwidth ===========")
 
     test_pkt_s_a = con_dic['test_pkt_s'].split(',')
-    time_new = time.strftime('%H_%M',time.localtime(time.time()))
+    test_rx_cache_s_e = con_dic['test_rx_cache_s'].split(',')
+    test_tx_cache_s_e = con_dic['test_tx_cache_s'].split(',')
+    time_new = time.strftime('%H_%M', time.localtime(time.time()))
 
     for test_pkt_s_e in test_pkt_s_a:
-        print "Package size %s"%(test_pkt_s_e)
-        order_excute = os.popen("%s %s http://%s/api/v3/yardstick/tasks/task %s %s %s %s"%(cmd,order_arg,con_dic['test_ip'],con_dic['test_rx_flavor'],con_dic['test_tx_flavor'],test_pkt_s_e,test_pkt_s_e))
+        print("Package size %s") % (test_pkt_s_e)
+        order_excute = os.popen("%s %s http://%s/api/v3/yardstick/\
+                    tasks/task %s %s %s" % (cmd, order_arg, con_dic['test_ip'],
+                                            test_pkt_s_e, test_rx_cache_s_e,
+                                            test_tx_cache_s_e))
         order_result = order_excute.read()
-        test_id = order_result.find("task_id")
+        task_id = order_result.find("task_id")
         time.sleep(con_dic['test_time'])
-        cmd_excute = os.popen( "%s http://%s/api/v3/yardstick/testresults?task_id=%s"%(cmd,con_dic['test_ip'],test_id))
+        cmd_excute = os.popen("%s http://%s/api/v3/yardstick/testre\
+            sults?task_id=%s" % (cmd, con_dic['test_ip'], task_id))
         test_result = cmd_excute.read()
         bandwidth = test_result.find("bandwidth")
         cpu_load = test_result.find("cpu_load")
         latency = test_result.find("latency")
-        posca_output_result(time_new,test_pkt_s_e,con_dic['test_rx_cache_s'],con_dic['test_tx_cache_s'])
-        if (bandwidth < con_dic['test_throughput']) and (latency < con_dic['test_latency']):
+        posca_output_result(time_new, test_pkt_s_e, con_dic['test_rx_cache_s'],
+                            con_dic['test_tx_cache_s'])
+        if (bandwidth < con_dic['test_throughput\
+             ']) and (latency < con_dic['test_latency']):
             if cpu_load > con_dic['test_cpu_load']:
                 return True
             else:
-                print "%s,%s,%s"%(bandwidth,latency,cpu_load)
+                print("%s,%s,%s") % (bandwidth, latency, cpu_load)
         else:
-            print "%s,%s,%s"%(bandwidth,latency,cpu_load)
+            print("%s,%s,%s") % (bandwidth, latency, cpu_load)
             return False
 
+
 def main():
     if not (args.conf):
-       logger.error("Configuration files do not exist for the specified testcases")
-       exit(-1)
+        logger.error("Configuration files do not exist for \
+                    the specified testcases")
+        os.exit(-1)
     else:
-       testcase_cfg = args.conf
+        testcase_cfg = args.conf
 
-    con_dic=posca_config_read(testcase_cfg)
+    con_dic = posca_config_read(testcase_cfg)
     posca_env_check()
     posca_run(con_dic)
 
     time.sleep(5)
 
-if __name__=='__main__':
+if __name__ == '__main__':
     main()
diff --git a/testsuites/posca/testcase_script/posca_factor_rx_cache_size.py b/testsuites/posca/testcase_script/posca_factor_rx_cache_size.py
index e049ad26..cfbd278e 100644
--- a/testsuites/posca/testcase_script/posca_factor_rx_cache_size.py
+++ b/testsuites/posca/testcase_script/posca_factor_rx_cache_size.py
@@ -15,103 +15,123 @@ import logging
 import ConfigParser
 import json
 
-#------------------------------------------------------
+# ------------------------------------------------------
 # parser for configuration files in each test case
 # ------------------------------------------------------
 parser = argparse.ArgumentParser()
 parser.add_argument("-c", "--conf",
-                    help="configuration files for the testcase, in yaml format",
-                    default="/home/opnfv/bottlenecks/testsuites/posca/testcase_cfg/posca_factor_rx_cache_size.yaml")
+                    help="configuration files for the testcase,\
+                        in yaml format",
+                    default="/home/opnfv/bottlenecks/testsuites/posca/\
+                        testcase_cfg/posca_factor_tx_pkt_size.yaml")
 args = parser.parse_args()
 
-cmd="curl -i"
-order_arg="-H \"Content-Type: application/json\" -X POST -d \'{\"cmd\": \"start\", \"opts\":{\"output-file\": \"/tem/yardstick.out\"}, \"args\": \"../samples/netperf.yaml\"}'"
+cmd = "curl -i"
+order_arg = "-H \"Content-Type: application/json\" -X POST -d \'{\"cmd\": \
+            \"start\", \"opts\":{\"output-file\": \"/tem/yardstick.out\"}, \
+            \"args\": \"../samples/netperf.yaml\"}'"
 
-#--------------------------------------------------
+# --------------------------------------------------
 # logging configuration
-#--------------------------------------------------
+# --------------------------------------------------
 logger = logging.getLogger(__name__)
 
+
 def posca_env_check():
-    print "========== posca system bandwidth env check ==========="
-    if os.path.exists(r'/home/opnfv/bottlenecks/testsuites/posca/test_result/'):
+    print("========== posca system bandwidth env check ===========")
+    filepath = r"/home/opnfv/bottlenecks/testsuites/posca/test_result/"
+    if os.path.exists(filepath):
         return True
     else:
         os.mkdirs(r'/home/opnfv/bottlenecks/testsuites/posca/test_result/')
 
-def posca_output_result(time_new,input_1,input_2,input_3,input_4,input_5):
-    save_dic={}
-    save_dic['tx_pkt_size']=input_1
-    save_dic['tx_cache_size']=input_2
-    save_dic['throughput ']=input_3
-    save_dic['latency']=input_4
-    save_dic['cpu_load']=input_5
-    with open("/home/opnfv/bottlenecks/testsuites/posca/test_result/factor_rx_cache_size_%s.json"%(time_new),"a") as f:
-        f.write(json.dumps(save_dic,f))
+
+def posca_output_result(time_new, input_1, input_2,
+                        input_3, input_4, input_5):
+    save_dic = {}
+    save_dic['tx_pkt_size'] = input_1
+    save_dic['tx_cache_size'] = input_2
+    save_dic['throughput '] = input_3
+    save_dic['latency'] = input_4
+    save_dic['cpu_load'] = input_5
+    with open("/home/opnfv/bottlenecks/testsuites/posca/test_result/\
+            factor_tx_cache_size_%s.json" % (time_new), "a") as f:
+        f.write(json.dumps(save_dic, f))
         f.write("\n")
 
+
 def posca_config_read(config_str):
-    print "========== posca system bandwidth config read ==========="
+    print("========== posca system bandwidth config read ===========")
 
     con_dic = {}
     config = ConfigParser.ConfigParser()
-    with open(config_str,"rd") as cfgfile:
+    with open(config_str, "rd") as cfgfile:
         config.readfp(cfgfile)
-        con_dic['test_ip']=config.get("config","test_ip")
-        con_dic['test_throughput']=config.get("config","throughput")
-        con_dic['test_tool']=config.get("config","tool")
-        con_dic['test_time']=config.get("config","test_time")
-        con_dic['test_protocol']=config.get("config","protocol")
-        con_dic['test_pkt_s']=config.get("config","pkt sizes")
-        con_dic['test_tx_cache_s']=config.get("config","tx cache sizes")
-        con_dic['test_rx_cache_s']=config.get("config","rx cache sizes")
-        con_dic['test_cpu_load']=config.get("config","cpu load")
-        con_dic['test_latency']=config.get("config","latency")
+        con_dic['test_ip'] = config.get("config", "test_ip")
+        con_dic['test_throughput'] = config.get("config", "throughput")
+        con_dic['test_tool'] = config.get("config", "tool")
+        con_dic['test_time'] = config.get("config", "test_time")
+        con_dic['test_protocol'] = config.get("config", "protocol")
+        con_dic['test_pkt_s'] = config.get("config", "pkt sizes")
+        con_dic['test_tx_cache_s'] = config.get("config", "tx cache sizes")
+        con_dic['test_rx_cache_s'] = config.get("config", "rx cache sizes")
+        con_dic['test_cpu_load'] = config.get("config", "cpu load")
+        con_dic['test_latency'] = config.get("config", "latency")
 
     return con_dic
 
+
 def posca_run(con_dic):
-    print "========== run posca system bandwidth ==========="
+    print("========== run posca system bandwidth ===========")
 
     test_pkt_s_a = con_dic['test_pkt_s'].split(',')
     test_tx_cache_s_a = con_dic['test_tx_cache_s'].split(',')
-    time_new = time.strftime('%H_%M',time.localtime(time.time()))
+    test_rx_cache_s_a = con_dic['test_rx_cache_s'].split(',')
+    time_new = time.strftime('%H_%M', time.localtime(time.time()))
     bandwidth_tmp = 1
 
     for test_pkt_s_e in test_pkt_s_a:
         for test_tx_cache_s_e in test_tx_cache_s_a:
-            print "Package size %s"%(test_pkt_s_e)
-            order_excute = os.popen("%s %s http://%s/api/v3/yardstick/tasks/task %s %s %s %s"%(cmd,order_arg,con_dic['test_ip'],test_pkt_s_e,test_pkt_s_e,test_tx_cache_s_e,con_dic['test_rx_cache_s']))
+            print("Package size %s") % (test_pkt_s_e)
+            order_excute = os.popen("%s %s http://%s/api/v3/yardstick/\
+                    tasks/task %s %s %s" % (cmd, order_arg, con_dic['test_ip'],
+                                            test_pkt_s_e, test_rx_cache_s_a,
+                                            test_tx_cache_s_e))
             order_result = order_excute.read()
             task_id = order_result.find("task_id")
             time.sleep(con_dic['test_time'])
-            cmd_excute = os.popen( "%s http://%s/api/v3/yardstick/testresults?task_id=%s"%(cmd,con_dic['test_ip'],task_id))
+            cmd_excute = os.popen("%s http://%s/api/v3/yardstick/testre\
+                    sults?task_id=%s" % (cmd, con_dic['test_ip'], task_id))
             test_result = cmd_excute.read()
             bandwidth = test_result.find("bandwidth")
             cpu_load = test_result.find("cpu_load")
             latency = test_result.find("latency")
-            posca_output_result(time_new,test_pkt_s_e,test_tx_cache_s_e,bandwidth,latency,cpu_load)
-            if (abs(bandwidth-con_dic['test_throughput'])/con_dic['test_throughput'] >0.05) and (latency < con_dic['test_latency']) and (cpu_load < con_dic['test_cpu_load']):
-                if abs(bandwidth_tmp-bandwidth)/bandwidth <0.05:
+            posca_output_result(time_new, test_pkt_s_e, test_rx_cache_s_a,
+                                bandwidth, latency, cpu_load)
+            if (cpu_load < con_dic['test_cpu_load\
+            ']) and (latency < con_dic['test_latency']):
+                if (abs(bandwidth_tmp-bandwidth)/bandwidth < 0.05):
                     return True
                 else:
-                    print "%s,%s"%(bandwidth,test_tx_cache_s_e)
+                    print("%s,%s") % (bandwidth, test_tx_cache_s_e)
             else:
-                print "%s,%s"%(bandwidth,test_tx_cache_s_e)
+                print("%s,%s") % (bandwidth, test_tx_cache_s_e)
                 return False
 
+
 def main():
     if not (args.conf):
-       logger.error("Configuration files do not exist for the specified testcases")
-       exit(-1)
+        logger.error("Configuration files do not exist \
+                    for the specified testcases")
+        os.exit(-1)
     else:
-       testcase_cfg = args.conf
+        testcase_cfg = args.conf
 
-    con_dic=posca_config_read(testcase_cfg)
+    con_dic = posca_config_read(testcase_cfg)
     posca_env_check()
     posca_run(con_dic)
 
     time.sleep(5)
 
-if __name__=='__main__':
+if __name__ == '__main__':
     main()
diff --git a/testsuites/posca/testcase_script/posca_factor_rx_pkt_size.py b/testsuites/posca/testcase_script/posca_factor_rx_pkt_size.py
index 61da136a..5de25949 100644
--- a/testsuites/posca/testcase_script/posca_factor_rx_pkt_size.py
+++ b/testsuites/posca/testcase_script/posca_factor_rx_pkt_size.py
@@ -15,108 +15,139 @@ import logging
 import ConfigParser
 import json
 
-#------------------------------------------------------
+# ------------------------------------------------------
 # parser for configuration files in each test case
 # ------------------------------------------------------
 parser = argparse.ArgumentParser()
 parser.add_argument("-c", "--conf",
-                    help="configuration files for the testcase, in yaml format",
-                    default="/home/opnfv/bottlenecks/testsuites/posca/testcase_cfg/posca_factor_rx_pkt_size.yaml")
+                    help="configuration files for the testcase,\
+                        in yaml format",
+                    default="/home/opnfv/bottlenecks/testsuites/posca/\
+                        testcase_cfg/posca_factor_tx_pkt_size.yaml")
 args = parser.parse_args()
 
-cmd="curl -i"
-order_arg="-H \"Content-Type: application/json\" -X POST -d \'{\"cmd\": \"start\", \"opts\":{\"output-file\": \"/tem/yardstick.out\"}, \"args\": \"../samples/netperf.yaml\"}'"
+cmd = "curl -i"
+order_arg = "-H \"Content-Type: application/json\" -X POST -d \'{\"cmd\": \
+            \"start\", \"opts\":{\"output-file\": \"/tem/yardstick.out\"}, \
+            \"args\": \"../samples/netperf.yaml\"}'"
 
-#--------------------------------------------------
+# --------------------------------------------------
 # logging configuration
-#--------------------------------------------------
+# --------------------------------------------------
 logger = logging.getLogger(__name__)
 
+
 def posca_env_check():
-    print "========== posca system bandwidth env check ==========="
-    if os.path.exists(r'/home/opnfv/bottlenecks/testsuites/posca/test_result/'):
+    print("========== posca system bandwidth env check ===========")
+    filepath = r"/home/opnfv/bottlenecks/testsuites/posca/test_result/"
+    if os.path.exists(filepath):
         return True
     else:
         os.mkdirs(r'/home/opnfv/bottlenecks/testsuites/posca/test_result/')
 
-def posca_output_result(time_new,input_1,input_2,input_3,input_4,input_5,input_6):
-    save_dic={}
-    save_dic['tx_pkt_size']=input_1
-    save_dic['rx_cache_size']=input_2
-    save_dic['tx_cache_size']=input_3
-    save_dic['throughput']=input_4
-    save_dic['latency']=input_5
-    save_dic['cpu_load']=input_6
-    with open("/home/opnfv/bottlenecks/testsuites/posca/test_result/factor_rx_pkt_size_%s.json"%(time_new),"a") as f:
-        f.write(json.dumps(save_dic,f))
+
+def posca_output_result(time_new, input_1, input_2, input_3,
+                        input_4, input_5, input_6):
+    save_dic = {}
+    save_dic['tx_pkt_size'] = input_1
+    save_dic['rx_cache_size'] = input_2
+    save_dic['tx_cache_size'] = input_3
+    save_dic['throughput'] = input_4
+    save_dic['latency'] = input_5
+    save_dic['cpu_load'] = input_6
+    with open("/home/opnfv/bottlenecks/testsuites/posca/test_result/\
+            factor_tx_cache_size_%s.json" % (time_new), "a") as f:
+        f.write(json.dumps(save_dic, f))
         f.write("\n")
 
+
 def posca_config_read(config_str):
-    print "========== posca system bandwidth config read ==========="
+    print("========== posca system bandwidth config read ===========")
 
     con_dic = {}
     config = ConfigParser.ConfigParser()
-    with open(config_str,"rd") as cfgfile:
+    with open(config_str, "rd") as cfgfile:
         config.readfp(cfgfile)
-        con_dic['test_ip']=config.get("config","test_ip")
-        con_dic['test_tool']=config.get("config","tool")
-        con_dic['test_time']=config.get("config","test_time")
-        con_dic['test_protocol']=config.get("config","protocol")
-        con_dic['test_tx_pkt_s']=config.get("config","tx pkt sizes")
-        con_dic['test_rx_pkt_s']=config.get("config","rx pkt sizes")
-        con_dic['test_tx_cache_s']=config.get("config","tx cache sizes")
-        con_dic['test_rx_cache_s']=config.get("config","rx cache sizes")
-        con_dic['test_cpu_load']=config.get("config","cpu load")
-        con_dic['test_latency']=config.get("config","latency")
+        con_dic['test_ip'] = config.get("config", "test_ip")
+        con_dic['test_tool'] = config.get("config", "tool")
+        con_dic['test_time'] = config.get("config", "test_time")
+        con_dic['test_protocol'] = config.get("config", "protocol")
+        con_dic['test_tx_pkt_s'] = config.get("config", "tx pkt sizes")
+        con_dic['test_rx_pkt_s'] = config.get("config", "rx pkt sizes")
+        con_dic['test_tx_cache_s'] = config.get("config", "tx cache sizes")
+        con_dic['test_rx_cache_s'] = config.get("config", "rx cache sizes")
+        con_dic['test_cpu_load'] = config.get("config", "cpu load")
+        con_dic['test_latency'] = config.get("config", "latency")
 
     return con_dic
 
+
 def posca_run(con_dic):
-    print "========== run posca system bandwidth ==========="
+    print("========== run posca system bandwidth ===========")
 
     test_tx_pkt_s_a = con_dic['test_tx_pkt_s'].split(',')
+    test_rx_pkt_s_e = con_dic['test_rx_pkt_s'].split(',')
     test_tx_cache_s_a = con_dic['test_tx_cache_s'].split(',')
     test_rx_cache_s_a = con_dic['test_rx_cache_s'].split(',')
-    time_new = time.strftime('%H_%M',time.localtime(time.time()))
+    time_new = time.strftime('%H_%M', time.localtime(time.time()))
     bandwidth_tmp = 1
 
     for test_rx_cache_s_e in test_rx_cache_s_a:
         for test_tx_cache_s_e in test_tx_cache_s_a:
             for test_tx_pkt_s_e in test_tx_pkt_s_a:
-                print "%s,%s,%s"%(test_tx_pkt_s_e,test_tx_cache_s_e,test_rx_cache_s_e)
-                order_excute = os.popen("%s %s http://%s/api/v3/yardstick/tasks/task %s %s %s"%(cmd,order_arg,con_dic['test_ip'],test_tx_pkt_s_e,test_rx_cache_s_e,test_tx_cache_s_e))
+                print("%s,%s,%s") % (test_tx_pkt_s_e, test_rx_cache_s_e,
+                                     test_tx_cache_s_e)
+                order_excute = os.popen("%s %s http://%s/api/v3/yardstick/\
+                    tasks/task %s %s %s" % (cmd, order_arg, con_dic['test_ip'],
+                                            test_rx_pkt_s_e, test_rx_cache_s_e,
+                                            test_tx_cache_s_e))
                 order_result = order_excute.read()
                 task_id = order_result.find("task_id")
                 time.sleep(con_dic['test_time'])
-                cmd_excute = os.popen( "%s http://%s/api/v3/yardstick/testresults?task_id=%s"%(cmd,con_dic['test_ip'],task_id))
+                cmd_excute = os.popen("%s http://%s/api/v3/yardstick/testre\
+                    sults?task_id=%s" % (cmd, con_dic['test_ip'], task_id))
                 test_result = cmd_excute.read()
                 bandwidth = test_result.find("bandwidth")
                 cpu_load = test_result.find("cpu_load")
                 latency = test_result.find("latency")
-                posca_output_result(time_new,test_tx_pkt_s_e,test_rx_cache_s_e,test_tx_cache_s_e,bandwidth,latency,cpu_load)
-                if (abs(bandwidth-con_dic['test_throughput'])/con_dic['test_throughput'] >0.05) and (latency < con_dic['test_latency']) and (cpu_load < con_dic['test_cpu_load']):
-                    if (abs(bandwidth_tmp-bandwidth)/bandwidth <0.05):
-                        print "%s,%s,%s,%s,%s,%s"%(test_tx_pkt_s_e,test_rx_cache_s_e,test_tx_cache_s_e,bandwidth,latency,cpu_load)
+                posca_output_result(time_new, test_rx_pkt_s_e,
+                                    test_rx_cache_s_e,
+                                    bandwidth, latency, cpu_load)
+                if (cpu_load < con_dic['test_cpu_load\
+                        ']) and (latency < con_dic['test_latency']):
+                    if (abs(bandwidth_tmp-bandwidth)/bandwidth < 0.05):
+                        print("%s,%s,%s,%s,%s,%s") % (test_rx_pkt_s_e,
+                                                      test_rx_cache_s_e,
+                                                      test_tx_cache_s_e,
+                                                      bandwidth,
+                                                      latency,
+                                                      cpu_load)
                         return True
                     else:
                         bandwidth_tmp = bandwidth
                 else:
-                    print "%s,%s,%s,%s,%s,%s"%(test_tx_pkt_s_e,test_rx_cache_s_e,test_tx_cache_s_e,bandwidth,latency,cpu_load)
+                    print("%s,%s,%s,%s,%s,%s") % (test_rx_pkt_s_e,
+                                                  test_rx_cache_s_e,
+                                                  test_tx_cache_s_e,
+                                                  bandwidth,
+                                                  latency,
+                                                  cpu_load)
                     return False
 
 
 def main():
     if not (args.conf):
-       logger.error("Configuration files do not exist for the specified testcases")
-       exit(-1)
+        logger.error("Configuration files do not exist \
+                    for the specified testcases")
+        os.exit(-1)
     else:
-       testcase_cfg = args.conf
+        testcase_cfg = args.conf
 
-    con_dic=posca_config_read(testcase_cfg)
+    con_dic = posca_config_read(testcase_cfg)
     posca_env_check()
     posca_run(con_dic)
 
     time.sleep(5)
 
-if __name__=='__main__':
+if __name__ == '__main__':
     main()
diff --git a/testsuites/posca/testcase_script/posca_factor_system_bandwidth.py b/testsuites/posca/testcase_script/posca_factor_system_bandwidth.py
index 878fa2d4..f3e950b6 100644
--- a/testsuites/posca/testcase_script/posca_factor_system_bandwidth.py
+++ b/testsuites/posca/testcase_script/posca_factor_system_bandwidth.py
@@ -15,109 +15,137 @@ import logging
 import ConfigParser
 import json
 
-#------------------------------------------------------
+# ------------------------------------------------------
 # parser for configuration files in each test case
 # ------------------------------------------------------
 parser = argparse.ArgumentParser()
 parser.add_argument("-c", "--conf",
-                    help="configuration files for the testcase, in yaml format",
-                    default="/home/opnfv/bottlenecks/testsuites/posca/testcase_cfg/posca_factor_system_bandwidth.yaml")
+                    help="configuration files for the testcase,\
+                        in yaml format",
+                    default="/home/opnfv/bottlenecks/testsuites/posca/\
+                        testcase_cfg/posca_factor_tx_pkt_size.yaml")
 args = parser.parse_args()
 
-cmd="curl -i"
-order_arg="-H \"Content-Type: application/json\" -X POST -d \'{\"cmd\": \"start\", \"opts\":{\"output-file\": \"/tem/yardstick.out\"}, \"args\": \"../samples/netperf.yaml\"}'"
+cmd = "curl -i"
+order_arg = "-H \"Content-Type: application/json\" -X POST -d \'{\"cmd\": \
+            \"start\", \"opts\":{\"output-file\": \"/tem/yardstick.out\"}, \
+            \"args\": \"../samples/netperf.yaml\"}'"
 
-#--------------------------------------------------
+# --------------------------------------------------
 # logging configuration
-#--------------------------------------------------
+# --------------------------------------------------
 logger = logging.getLogger(__name__)
 
+
 def posca_env_check():
-    print "========== posca system bandwidth env check ==========="
-    if os.path.exists(r'/home/opnfv/bottlenecks/testsuites/posca/test_result/'):
+    print("========== posca system bandwidth env check ===========")
+    filepath = r"/home/opnfv/bottlenecks/testsuites/posca/test_result/"
+    if os.path.exists(filepath):
         return True
     else:
         os.mkdirs(r'/home/opnfv/bottlenecks/testsuites/posca/test_result/')
 
-def posca_output_result(time_new,input_1,input_2,input_3,input_4,input_5,input_6):
-    save_dic={}
-    save_dic['tx_pkt_size']=input_1
-    save_dic['rx_cache_size']=input_2
-    save_dic['tx_cache_size']=input_3
-    save_dic['throughput ']=input_4
-    save_dic['latency']=input_5
-    save_dic['cpu_load']=input_6
-    with open("/home/opnfv/bottlenecks/testsuites/posca/test_result/factor_system_bandwidth_%s.json"%(time_new),"a") as f:
-        f.write(json.dumps(save_dic,f))
+
+def posca_output_result(time_new, input_1, input_2, input_3,
+                        input_4, input_5, input_6):
+    save_dic = {}
+    save_dic['tx_pkt_size'] = input_1
+    save_dic['rx_cache_size'] = input_2
+    save_dic['tx_cache_size'] = input_3
+    save_dic['throughput '] = input_4
+    save_dic['latency'] = input_5
+    save_dic['cpu_load'] = input_6
+    with open("/home/opnfv/bottlenecks/testsuites/posca/test_result/\
+            factor_tx_cache_size_%s.json" % (time_new), "a") as f:
+        f.write(json.dumps(save_dic, f))
         f.write("\n")
 
-def posca_config_read(config_str):
-    print "========== posca system bandwidth config read ==========="
 
+def posca_config_read(config_str):
+    print("========== posca system bandwidth config read ===========")
     con_dic = {}
     config = ConfigParser.ConfigParser()
-    with open(config_str,"rd") as cfgfile:
+    with open(config_str, "rd") as cfgfile:
         config.readfp(cfgfile)
-        con_dic['test_ip']=config.get("config","test_ip")
-        con_dic['test_tool']=config.get("config","tool")
-        con_dic['test_time']=config.get("config","test_time")
-        con_dic['test_protocol']=config.get("config","protocol")
-        con_dic['test_tx_pkt_s']=config.get("config","tx pkt sizes")
-        con_dic['test_rx_pkt_s']=config.get("config","rx pkt sizes")
-        con_dic['test_tx_cache_s']=config.get("config","tx cache sizes")
-        con_dic['test_rx_cache_s']=config.get("config","rx cache sizes")
-        con_dic['test_cpu_load']=config.get("config","cpu load")
-        con_dic['test_latency']=config.get("config","latency")
+        con_dic['test_ip'] = config.get("config", "test_ip")
+        con_dic['test_tool'] = config.get("config", "tool")
+        con_dic['test_time'] = config.get("config", "test_time")
+        con_dic['test_protocol'] = config.get("config", "protocol")
+        con_dic['test_tx_pkt_s'] = config.get("config", "tx pkt sizes")
+        con_dic['test_rx_pkt_s'] = config.get("config", "rx pkt sizes")
+        con_dic['test_tx_cache_s'] = config.get("config", "tx cache sizes")
+        con_dic['test_rx_cache_s'] = config.get("config", "rx cache sizes")
+        con_dic['test_cpu_load'] = config.get("config", "cpu load")
+        con_dic['test_latency'] = config.get("config", "latency")
 
     return con_dic
 
+
 def posca_run(con_dic):
-    print "========== run posca system bandwidth ==========="
+    print("========== run posca system bandwidth ===========")
 
+    test_rx_pkt_s_e = 87380
     test_tx_pkt_s_a = con_dic['test_tx_pkt_s'].split(',')
- #   test_rx_pkt_s_a = con_dic['test_rx_pkt_s'].split(',')
     test_tx_cache_s_a = con_dic['test_tx_cache_s'].split(',')
     test_rx_cache_s_a = con_dic['test_rx_cache_s'].split(',')
-    time_new = time.strftime('%H_%M',time.localtime(time.time()))
+    time_new = time.strftime('%H_%M', time.localtime(time.time()))
     bandwidth_tmp = 1
 
     for test_rx_cache_s_e in test_rx_cache_s_a:
         for test_tx_cache_s_e in test_tx_cache_s_a:
             for test_tx_pkt_s_e in test_tx_pkt_s_a:
-                print "%s,%s,%s"%(test_tx_pkt_s_e,test_rx_cache_s_e,test_tx_cache_s_e)
-                order_excute = os.popen("%s %s http://%s/api/v3/yardstick/tasks/task %s %s %s"%(cmd,order_arg,con_dic['test_ip'],test_tx_pkt_s_e,test_rx_cache_s_e,test_tx_cache_s_e))
+                print("%s,%s,%s") % (test_tx_pkt_s_e, test_rx_cache_s_e,
+                                     test_tx_cache_s_e)
+                order_excute = os.popen("%s %s http://%s/api/v3/yardstick/\
+                    tasks/task %s %s %s" % (cmd, order_arg, con_dic['test_ip'],
+                                            test_rx_pkt_s_e, test_rx_cache_s_e,
+                                            test_tx_cache_s_e))
                 order_result = order_excute.read()
-                test_id = order_result.find("task_id")
+                task_id = order_result.find("task_id")
                 time.sleep(con_dic['test_time'])
-                cmd_excute = os.popen( "%s http://%s/api/v3/yardstick/testresults?task_id=%s"%(cmd,con_dic['test_ip'],test_id))
-                test_result = cmd_excute.read()
-                bandwidth = test_result.find("bandwidth")
-                cpu_load = test_result.find("cpu_load")
-                latency = test_result.find("latency")
-                posca_output_result(time_new,test_tx_pkt_s_e,test_rx_cache_s_e,test_tx_cache_s_e,bandwidth,latency,cpu_load)
-                if (cpu_load < con_dic['test_cpu_load']) and (latency < con_dic['test_latency']):
-                    if (abs(bandwidth_tmp-bandwidth)/bandwidth <0.05):
-                        print "%s,%s,%s,%s,%s,%s"%(test_tx_pkt_s_e,test_rx_cache_s_e,test_tx_cache_s_e,bandwidth,latency,cpu_load)
+                cmd_excute = os.popen("%s http://%s/api/v3/yardstick/testre\
+                    sults?task_id=%s" % (cmd, con_dic['test_ip'], task_id))
+                bandwidth = cmd_excute.find("bandwidth")
+                cpu_load = cmd_excute.find("cpu_load")
+                latency = cmd_excute.find("latency")
+                posca_output_result(time_new, test_rx_pkt_s_e,
+                                    test_rx_cache_s_e,
+                                    bandwidth, latency, cpu_load)
+                if (cpu_load < con_dic['test_cpu_load\
+                        ']) and (latency < con_dic['test_latency']):
+                    if (abs(bandwidth_tmp-bandwidth)/bandwidth < 0.05):
+                        print("%s,%s,%s,%s,%s,%s") % (test_rx_pkt_s_e,
+                                                      test_rx_cache_s_e,
+                                                      test_tx_cache_s_e,
+                                                      bandwidth,
+                                                      latency,
+                                                      cpu_load)
                         return True
                     else:
                         bandwidth_tmp = bandwidth
                 else:
-                    print "%s,%s,%s,%s,%s,%s"%(test_tx_pkt_s_e,test_rx_cache_s_e,test_tx_cache_s_e,bandwidth,latency,cpu_load)
+                    print("%s,%s,%s,%s,%s,%s") % (test_rx_pkt_s_e,
+                                                  test_rx_cache_s_e,
+                                                  test_tx_cache_s_e,
+                                                  bandwidth,
+                                                  latency,
+                                                  cpu_load)
                     return True
 
 
 def main():
     if not (args.conf):
-       logger.error("Configuration files do not exist for the specified testcases")
-       exit(-1)
+        logger.error("Configuration files do not exist for \
+                    the specified testcases")
+        os.exit(-1)
     else:
-       testcase_cfg = args.conf
+        testcase_cfg = args.conf
 
-    con_dic=posca_config_read(testcase_cfg)
+    con_dic = posca_config_read(testcase_cfg)
     posca_env_check()
     posca_run(con_dic)
 
     time.sleep(5)
 
-if __name__=='__main__':
+if __name__ == '__main__':
     main()
diff --git a/testsuites/posca/testcase_script/posca_factor_tx_cache_size.py b/testsuites/posca/testcase_script/posca_factor_tx_cache_size.py
index 525f91de..a8d1a485 100644
--- a/testsuites/posca/testcase_script/posca_factor_tx_cache_size.py
+++ b/testsuites/posca/testcase_script/posca_factor_tx_cache_size.py
@@ -15,103 +15,122 @@ import logging
 import ConfigParser
 import json
 
-#------------------------------------------------------
+# ------------------------------------------------------
 # parser for configuration files in each test case
 # ------------------------------------------------------
 parser = argparse.ArgumentParser()
 parser.add_argument("-c", "--conf",
-                    help="configuration files for the testcase, in yaml format",
-                    default="/home/opnfv/bottlenecks/testsuites/posca/testcase_cfg/posca_factor_tx_cache_size.yaml")
+                    help="configuration files for the testcase,\
+                        in yaml format",
+                    default="/home/opnfv/bottlenecks/testsuites/posca/\
+                        testcase_cfg/posca_factor_tx_pkt_size.yaml")
 args = parser.parse_args()
 
-cmd="curl -i"
-order_arg="-H \"Content-Type: application/json\" -X POST -d \'{\"cmd\": \"start\", \"opts\":{\"output-file\": \"/tem/yardstick.out\"}, \"args\": \"../samples/netperf.yaml\"}'"
+cmd = "curl -i"
+order_arg = "-H \"Content-Type: application/json\" -X POST -d \'{\"cmd\": \
+            \"start\", \"opts\":{\"output-file\": \"/tem/yardstick.out\"}, \
+            \"args\": \"../samples/netperf.yaml\"}'"
 
-#--------------------------------------------------
+# --------------------------------------------------
 # logging configuration
-#--------------------------------------------------
+# --------------------------------------------------
 logger = logging.getLogger(__name__)
 
+
 def posca_env_check():
-    print "========== posca system bandwidth env check ==========="
-    if os.path.exists(r'/home/opnfv/bottlenecks/testsuites/posca/test_result/'):
+    print("========== posca system bandwidth env check ===========")
+    filepath = r"/home/opnfv/bottlenecks/testsuites/posca/test_result/"
+    if os.path.exists(filepath):
         return True
     else:
         os.mkdirs(r'/home/opnfv/bottlenecks/testsuites/posca/test_result/')
 
-def posca_output_result(time_new,input_1,input_2,input_3,input_4,input_5):
-    save_dic={}
-    save_dic['tx_pkt_size']=input_1
-    save_dic['rx_cache_size']=input_2
-    save_dic['throughput ']=input_3
-    save_dic['latency']=input_4
-    save_dic['cpu_load']=input_5
-    with open("/home/opnfv/bottlenecks/testsuites/posca/test_result/factor_tx_cache_size_%s.json"%(time_new),"a") as f:
-        f.write(json.dumps(save_dic,f))
+
+def posca_output_result(time_new, input_1, input_2, input_3, input_4, input_5):
+    save_dic = {}
+    save_dic['tx_pkt_size'] = input_1
+    save_dic['rx_cache_size'] = input_2
+    save_dic['throughput '] = input_3
+    save_dic['latency'] = input_4
+    save_dic['cpu_load'] = input_5
+    with open("/home/opnfv/bottlenecks/testsuites/posca/test_result/\
+            factor_tx_cache_size_%s.json" % (time_new), "a") as f:
+        f.write(json.dumps(save_dic, f))
         f.write("\n")
 
-def posca_config_read(config_str):
-    print "========== posca system bandwidth config read ==========="
 
+def posca_config_read(config_str):
+    print("========== posca system bandwidth config read ===========")
     con_dic = {}
     config = ConfigParser.ConfigParser()
-    with open(config_str,"rd") as cfgfile:
+    with open(config_str, "rd") as cfgfile:
         config.readfp(cfgfile)
-        con_dic['test_ip']=config.get("config","test_ip")
-        con_dic['test_throughput']=config.get("config","throughput")
-        con_dic['test_tool']=config.get("config","tool")
-        con_dic['test_time']=config.get("config","test_time")
-        con_dic['test_protocol']=config.get("config","protocol")
-        con_dic['test_pkt_s']=config.get("config","pkt sizes")
-        con_dic['test_tx_cache_s']=config.get("config","tx cache sizes")
-        con_dic['test_rx_cache_s']=config.get("config","rx cache sizes")
-        con_dic['test_cpu_load']=config.get("config","cpu load")
-        con_dic['test_latency']=config.get("config","latency")
+        con_dic['test_ip'] = config.get("config", "test_ip")
+        con_dic['test_throughput'] = config.get("config", "throughput")
+        con_dic['test_tool'] = config.get("config", "tool")
+        con_dic['test_time'] = config.get("config", "test_time")
+        con_dic['test_protocol'] = config.get("config", "protocol")
+        con_dic['test_pkt_s'] = config.get("config", "pkt sizes")
+        con_dic['test_tx_cache_s'] = config.get("config", "tx cache sizes")
+        con_dic['test_rx_cache_s'] = config.get("config", "rx cache sizes")
+        con_dic['test_cpu_load'] = config.get("config", "cpu load")
+        con_dic['test_latency'] = config.get("config", "latency")
 
     return con_dic
 
+
 def posca_run(con_dic):
-    print "========== run posca system bandwidth ==========="
+    print("========== run posca system bandwidth ===========")
 
     test_pkt_s_a = con_dic['test_pkt_s'].split(',')
     test_rx_cache_s_a = con_dic['test_rx_cache_s'].split(',')
-    time_new = time.strftime('%H_%M',time.localtime(time.time()))
+    test_tx_cache_s_e = con_dic['test_tx_cache_s'].split(',')
+    time_new = time.strftime('%H_%M', time.localtime(time.time()))
     bandwidth_tmp = 1
 
     for test_pkt_s_e in test_pkt_s_a:
         for test_rx_cache_s_e in test_rx_cache_s_a:
-            print "Package size %s"%(test_pkt_s_e)
-            order_excute = os.popen("%s %s http://%s/api/v3/yardstick/tasks/task %s %s %s %s"%(cmd,order_arg,con_dic['test_ip'],test_pkt_s_e,test_pkt_s_e,con_dic['test_tx_cache_s'],test_rx_cache_s_e))
+            print("Package size %s") % (test_pkt_s_e)
+            order_excute = os.popen("%s %s http://%s/api/v3/yardstick/\
+                    tasks/task %s %s %s" % (cmd, order_arg, con_dic['test_ip'],
+                                            test_pkt_s_e, test_rx_cache_s_e,
+                                            test_tx_cache_s_e))
             order_result = order_excute.read()
-            test_id = order_result.find("task_id")
+            task_id = order_result.find("task_id")
             time.sleep(con_dic['test_time'])
-            cmd_excute = os.popen( "%s http://%s/api/v3/yardstick/testresults?task_id=%s"%(cmd,con_dic['test_ip'],test_id))
+            cmd_excute = os.popen("%s http://%s/api/v3/yardstick/testre\
+                    sults?task_id=%s" % (cmd, con_dic['test_ip'], task_id))
             test_result = cmd_excute.read()
             bandwidth = test_result.find("bandwidth")
             cpu_load = test_result.find("cpu_load")
             latency = test_result.find("latency")
-            posca_output_result(time_new,test_pkt_s_e,test_rx_cache_s_e,bandwidth,latency,cpu_load)
-            if (abs(bandwidth-con_dic['test_throughput'])/con_dic['test_throughput'] >0.05) and (latency < con_dic['test_latency']) and (cpu_load < con_dic['test_cpu_load']):
-                if abs(bandwidth_tmp-bandwidth)/bandwidth <0.05:
+            posca_output_result(time_new, test_pkt_s_e, test_rx_cache_s_e,
+                                bandwidth, latency, cpu_load)
+            if (abs(bandwidth-con_dic['test_throughput'])/con_dic['test_\
+                        throughput'] > 0.05) and (latency < con_dic['test_\
+                        latency']) and (cpu_load < con_dic['test_cpu_load']):
+                if (abs(bandwidth_tmp-bandwidth)/bandwidth < 0.05):
                     return True
                 else:
-                    print "%s,%s"%(bandwidth,test_rx_cache_s_e)
+                    print("%s,%s") % (bandwidth, test_rx_cache_s_e)
             else:
-                print "%s,%s"%(bandwidth,test_rx_cache_s_e)
+                print("%s,%s") % (bandwidth, test_rx_cache_s_e)
                 return False
 
+
 def main():
     if not (args.conf):
-       logger.error("Configuration files do not exist for the specified testcases")
-       exit(-1)
+        logger.error("Configuration files do not exist for\
+                    the specified testcases")
+        os.exit(-1)
     else:
-       testcase_cfg = args.conf
+        testcase_cfg = args.conf
 
-    con_dic=posca_config_read(testcase_cfg)
+    con_dic = posca_config_read(testcase_cfg)
     posca_env_check()
     posca_run(con_dic)
 
     time.sleep(5)
 
-if __name__=='__main__':
+if __name__ == '__main__':
     main()
diff --git a/testsuites/posca/testcase_script/posca_factor_tx_pkt_size.py b/testsuites/posca/testcase_script/posca_factor_tx_pkt_size.py
index 4b44c853..47cc5e75 100644
--- a/testsuites/posca/testcase_script/posca_factor_tx_pkt_size.py
+++ b/testsuites/posca/testcase_script/posca_factor_tx_pkt_size.py
@@ -15,108 +15,139 @@ import logging
 import ConfigParser
 import json
 
-#------------------------------------------------------
+# ------------------------------------------------------
 # parser for configuration files in each test case
 # ------------------------------------------------------
 parser = argparse.ArgumentParser()
-parser.add_argument("-c", "--conf",
-                    help="configuration files for the testcase, in yaml format",
-                    default="/home/opnfv/bottlenecks/testsuites/posca/testcase_cfg/posca_factor_tx_pkt_size.yaml")
+parser.add_argument("-c",
+                    "--conf",
+                    help="configuration files for the testcase,\
+                        in yaml format",
+                    default="/home/opnfv/bottlenecks/testsuites/posca/\
+                        testcase_cfg/posca_factor_tx_pkt_size.yaml")
 args = parser.parse_args()
 
-cmd="curl -i"
-order_arg="-H \"Content-Type: application/json\" -X POST -d \'{\"cmd\": \"start\", \"opts\":{\"output-file\": \"/tem/yardstick.out\"}, \"args\": \"../samples/netperf.yaml\"}'"
+cmd = "curl -i"
+order_arg = "-H \"Content-Type: application/json\" -X POST -d \'{\"cmd\": \
+            \"start\", \"opts\":{\"output-file\": \"/tem/yardstick.out\"}, \
+            \"args\": \"../samples/netperf.yaml\"}'"
 
-#--------------------------------------------------
+# --------------------------------------------------
 # logging configuration
-#--------------------------------------------------
+# --------------------------------------------------
 logger = logging.getLogger(__name__)
 
+
 def posca_env_check():
-    print "========== posca system bandwidth env check ==========="
-    if os.path.exists(r'/home/opnfv/bottlenecks/testsuites/posca/test_result/'):
+    print("========== posca system bandwidth env check ===========")
+    filepath = r"/home/opnfv/bottlenecks/testsuites/posca/test_result/"
+    if os.path.exists(filepath):
         return True
     else:
         os.mkdirs(r'/home/opnfv/bottlenecks/testsuites/posca/test_result/')
 
-def posca_output_result(time_new,input_1,input_2,input_3,input_4,input_5,input_6):
-    save_dic={}
-    save_dic['rx_pkt_size']=input_1
-    save_dic['tx_cache_size']=input_2
-    save_dic['tx_cache_size']=input_3
-    save_dic['throughput']=input_4
-    save_dic['latency']=input_5
-    save_dic['cpu_load']=input_6
-    with open("/home/opnfv/bottlenecks/testsuites/posca/test_result/factor_tx_pkt_size_%s.json"%(time_new),"a") as f:
-        f.write(json.dumps(save_dic,f))
+
+def posca_output_result(time_new, input_1, input_2, input_3,
+                        input_4, input_5, input_6):
+    save_dic = {}
+    save_dic['rx_pkt_size'] = input_1
+    save_dic['tx_cache_size'] = input_2
+    save_dic['tx_cache_size'] = input_3
+    save_dic['throughput'] = input_4
+    save_dic['latency'] = input_5
+    save_dic['cpu_load'] = input_6
+    with open("/home/opnfv/bottlenecks/testsuites/posca/\
+            test_result/factor_tx_pkt_size_%s.json" % (time_new), "a") as f:
+        f.write(json.dumps(save_dic, f))
         f.write("\n")
 
+
 def posca_config_read(config_str):
-    print "========== posca system bandwidth config read ==========="
+    print("========== posca system bandwidth config read ===========")
 
     con_dic = {}
     config = ConfigParser.ConfigParser()
-    with open(config_str,"rd") as cfgfile:
+    with open(config_str, "rd") as cfgfile:
         config.readfp(cfgfile)
-        con_dic['test_ip']=config.get("config","test_ip")
-        con_dic['test_tool']=config.get("config","tool")
-        con_dic['test_time']=config.get("config","test_time")
-        con_dic['test_protocol']=config.get("config","protocol")
-        con_dic['test_tx_pkt_s']=config.get("config","tx pkt sizes")
-        con_dic['test_rx_pkt_s']=config.get("config","rx pkt sizes")
-        con_dic['test_tx_cache_s']=config.get("config","tx cache sizes")
-        con_dic['test_rx_cache_s']=config.get("config","rx cache sizes")
-        con_dic['test_cpu_load']=config.get("config","cpu load")
-        con_dic['test_latency']=config.get("config","latency")
+        con_dic['test_ip'] = config.get("config", "test_ip")
+        con_dic['test_tool'] = config.get("config", "tool")
+        con_dic['test_time'] = config.get("config", "test_time")
+        con_dic['test_protocol'] = config.get("config", "protocol")
+        con_dic['test_tx_pkt_s'] = config.get("config", "tx pkt sizes")
+        con_dic['test_rx_pkt_s'] = config.get("config", "rx pkt sizes")
+        con_dic['test_tx_cache_s'] = config.get("config", "tx cache sizes")
+        con_dic['test_rx_cache_s'] = config.get("config", "rx cache sizes")
+        con_dic['test_cpu_load'] = config.get("config", "cpu load")
+        con_dic['test_latency'] = config.get("config", "latency")
 
     return con_dic
 
-def posca_run(con_dic):
-    print "========== run posca system bandwidth ==========="
 
+def posca_run(con_dic):
+    print("========== run posca system bandwidth ===========")
     test_rx_pkt_s_a = con_dic['test_rx_pkt_s'].split(',')
     test_tx_cache_s_a = con_dic['test_tx_cache_s'].split(',')
     test_rx_cache_s_a = con_dic['test_rx_cache_s'].split(',')
-    time_new = time.strftime('%H_%M',time.localtime(time.time()))
+    time_new = time.strftime('%H_%M', time.localtime(time.time()))
     bandwidth_tmp = 1
 
     for test_rx_cache_s_e in test_rx_cache_s_a:
         for test_tx_cache_s_e in test_tx_cache_s_a:
             for test_rx_pkt_s_e in test_rx_pkt_s_a:
-                print "%s,%s,%s"%(test_rx_pkt_s_e,test_tx_cache_s_e,test_rx_cache_s_e)
-                order_excute = os.popen("%s %s http://%s/api/v3/yardstick/tasks/task %s %s %s"%(cmd,order_arg,con_dic['test_ip'],test_rx_pkt_s_e,test_rx_cache_s_e,test_tx_cache_s_e))
+                print("%s,%s,%s") % (test_rx_pkt_s_e, test_tx_cache_s_e,
+                                     test_rx_cache_s_e)
+                order_excute = os.popen("%s %s http://%s/api/v3/yardstick/\
+                    tasks/task %s %s %s" % (cmd, order_arg, con_dic['test_ip'],
+                                            test_rx_pkt_s_e, test_rx_cache_s_e,
+                                            test_tx_cache_s_e))
                 order_result = order_excute.read()
                 task_id = order_result.find("task_id")
                 time.sleep(con_dic['test_time'])
-                cmd_excute = os.popen( "%s http://%s/api/v3/yardstick/testresults?task_id=%s"%(cmd,con_dic['test_ip'],task_id))
+                cmd_excute = os.popen("%s http://%s/api/v3/yardstick/test\
+                    results?task_id=%s" % (cmd, con_dic['test_ip'], task_id))
                 test_result = cmd_excute.read()
                 bandwidth = test_result.find("bandwidth")
                 cpu_load = test_result.find("cpu_load")
                 latency = test_result.find("latency")
-                posca_output_result(time_new,test_rx_pkt_s_e,test_rx_cache_s_e,test_tx_cache_s_e,bandwidth,latency,cpu_load)
-                if (abs(bandwidth-con_dic['test_throughput'])/con_dic['test_throughput'] >0.05) and (latency < con_dic['test_latency']) and (cpu_load < con_dic['test_cpu_load']):
-                    if (abs(bandwidth_tmp-bandwidth)/bandwidth <0.05):
-                        print "%s,%s,%s,%s,%s,%s"%(test_rx_pkt_s_e,test_rx_cache_s_e,test_tx_cache_s_e,bandwidth,latency,cpu_load)
+                posca_output_result(time_new, test_rx_pkt_s_e,
+                                    test_rx_cache_s_e, test_tx_cache_s_e,
+                                    bandwidth, latency, cpu_load)
+                if (abs(bandwidth-con_dic['test_throughput'])/con_dic['test_\
+                        throughput'] > 0.05) and (latency < con_dic['test_\
+                        latency']) and (cpu_load < con_dic['test_cpu_load']):
+                    if (abs(bandwidth_tmp-bandwidth)/bandwidth < 0.05):
+                        print("%s,%s,%s,%s,%s,%s") % (test_rx_pkt_s_e,
+                                                      test_rx_cache_s_e,
+                                                      test_tx_cache_s_e,
+                                                      bandwidth,
+                                                      latency,
+                                                      cpu_load)
                         return True
                     else:
                         bandwidth_tmp = bandwidth
                 else:
-                    print "%s,%s,%s,%s,%s,%s"%(test_rx_pkt_s_e,test_rx_cache_s_e,test_tx_cache_s_e,bandwidth,latency,cpu_load)
+                    print("%s,%s,%s,%s,%s,%s") % (test_rx_pkt_s_e,
+                                                  test_rx_cache_s_e,
+                                                  test_tx_cache_s_e,
+                                                  bandwidth,
+                                                  latency,
+                                                  cpu_load)
                     return False
 
 
 def main():
     if not (args.conf):
-       logger.error("Configuration files do not exist for the specified testcases")
-       exit(-1)
+        logger.error("Configuration files do not exist \
+                    for the specified testcases")
+        os.exit(-1)
     else:
-       testcase_cfg = args.conf
+        testcase_cfg = args.conf
 
-    con_dic=posca_config_read(testcase_cfg)
+    con_dic = posca_config_read(testcase_cfg)
     posca_env_check()
     posca_run(con_dic)
 
     time.sleep(5)
 
-if __name__=='__main__':
+if __name__ == '__main__':
     main()