Merge "Use Chart.js for graphs in HTML reports"

[yardstick.git] / yardstick / benchmark / runners / dynamictp.py

diff --git a/yardstick/benchmark/runners/dynamictp.py b/yardstick/benchmark/runners/dynamictp.py
index 01e76c6..88d3c57 100755 (executable)
--- a/yardstick/benchmark/runners/dynamictp.py
+++ b/yardstick/benchmark/runners/dynamictp.py
@@ -19,13 +19,15 @@
 """A runner that searches for the max throughput with binary search
 """
 
 """A runner that searches for the max throughput with binary search
 """
 

-import os
-import multiprocessing

 import logging
 import logging

-import traceback
+import multiprocessing

 import time
 import time

+import traceback
+
+import os

 
 from yardstick.benchmark.runners import base
 
 from yardstick.benchmark.runners import base

+from yardstick.common import exceptions as y_exc

 
 LOG = logging.getLogger(__name__)
 
 
 LOG = logging.getLogger(__name__)
 


@@ -65,8 +67,7 @@ def _worker_process(queue, cls, method_name, scenario_cfg,
             max_throuput_found = False
             sequence = 0
 
             max_throuput_found = False
             sequence = 0
 

-            last_min_data = {}
-            last_min_data['packets_per_second'] = 0
+            last_min_data = {'packets_per_second': 0}

 
             while True:
                 sequence += 1
 
             while True:
                 sequence += 1


@@ -80,10 +81,10 @@ def _worker_process(queue, cls, method_name, scenario_cfg,
 
                 try:
                     method(data)
 
                 try:
                     method(data)

-                except AssertionError as assertion:
-                    LOG.warning("SLA validation failed: %s" % assertion.args)
+                except y_exc.SLAValidationError as error:
+                    LOG.warning("SLA validation failed: %s", error.args)

                     too_high = True
                     too_high = True

-                except Exception as e:
+                except Exception as e:  # pylint: disable=broad-except

                     errors = traceback.format_exc()
                     LOG.exception(e)
 
                     errors = traceback.format_exc()
                     LOG.exception(e)
 


@@ -125,7 +126,7 @@ def _worker_process(queue, cls, method_name, scenario_cfg,
                     queue.put(record)
                     max_throuput_found = True
 
                     queue.put(record)
                     max_throuput_found = True
 

-                if (errors) or aborted.is_set() or max_throuput_found:
+                if errors or aborted.is_set() or max_throuput_found:

                     LOG.info("worker END")
                     break
 
                     LOG.info("worker END")
                     break
 


@@ -155,7 +156,7 @@ def _worker_process(queue, cls, method_name, scenario_cfg,
 
 
 class IterationRunner(base.Runner):
 
 
 class IterationRunner(base.Runner):

-    '''Run a scenario to find the max throughput
+    """Run a scenario to find the max throughput

 
 If the scenario ends before the time has elapsed, it will be started again.
 
 
 If the scenario ends before the time has elapsed, it will be started again.
 


@@ -168,11 +169,13 @@ If the scenario ends before the time has elapsed, it will be started again.
         type:   int
         unit:   pps
         default: 1000 pps
         type:   int
         unit:   pps
         default: 1000 pps

-    '''
+    """

     __execution_type__ = 'Dynamictp'
 
     def _run_benchmark(self, cls, method, scenario_cfg, context_cfg):
     __execution_type__ = 'Dynamictp'
 
     def _run_benchmark(self, cls, method, scenario_cfg, context_cfg):

+        name = "{}-{}-{}".format(self.__execution_type__, scenario_cfg.get("type"), os.getpid())

         self.process = multiprocessing.Process(
         self.process = multiprocessing.Process(

+            name=name,

             target=_worker_process,
             args=(self.result_queue, cls, method, scenario_cfg,
                   context_cfg, self.aborted))
             target=_worker_process,
             args=(self.result_queue, cls, method, scenario_cfg,
                   context_cfg, self.aborted))