Merge "Addition of IRQ Mode to NSB NFVI (PROX)"

7 files changed, 1212 insertions, 1 deletions

diff --git a/yardstick/network_services/traffic_profile/__init__.py b/yardstick/network_services/traffic_profile/__init__.py
index 91d8a665f..72a61b6b4 100644
--- a/yardstick/network_services/traffic_profile/__init__.py
+++ b/yardstick/network_services/traffic_profile/__init__.py
@@ -23,6 +23,7 @@ def register_modules():
         'yardstick.network_services.traffic_profile.http_ixload',
         'yardstick.network_services.traffic_profile.ixia_rfc2544',
         'yardstick.network_services.traffic_profile.prox_ACL',
+        'yardstick.network_services.traffic_profile.prox_irq',
         'yardstick.network_services.traffic_profile.prox_binsearch',
         'yardstick.network_services.traffic_profile.prox_profile',
         'yardstick.network_services.traffic_profile.prox_ramp',
diff --git a/yardstick/network_services/traffic_profile/prox_irq.py b/yardstick/network_services/traffic_profile/prox_irq.py
new file mode 100644
index 000000000..0ea294914
--- /dev/null
+++ b/yardstick/network_services/traffic_profile/prox_irq.py
@@ -0,0 +1,48 @@
+# Copyright (c) 2016-2018 Intel Corporation
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+""" Fixed traffic profile definitions """
+
+import logging
+import time
+
+from yardstick.network_services.traffic_profile.prox_profile import ProxProfile
+
+LOG = logging.getLogger(__name__)
+
+
+class ProxIrqProfile(ProxProfile):
+    """
+    This profile adds a single stream at the beginning of the traffic session
+    """
+
+    def __init__(self, tp_config):
+        super(ProxIrqProfile, self).__init__(tp_config)
+
+    def init(self, queue):
+        self.queue = queue
+        self.queue.cancel_join_thread()
+
+    def execute_traffic(self, traffic_generator):
+        LOG.debug("Prox_IRQ Execute Traffic....")
+        time.sleep(5)
+
+    def is_ended(self):
+        return False
+
+    def run_test(self):
+        """Run the test
+        """
+
+        LOG.info("Prox_IRQ ....")
diff --git a/yardstick/network_services/vnf_generic/vnf/prox_helpers.py b/yardstick/network_services/vnf_generic/vnf/prox_helpers.py
index e9d83623b..5d980037a 100644
--- a/yardstick/network_services/vnf_generic/vnf/prox_helpers.py
+++ b/yardstick/network_services/vnf_generic/vnf/prox_helpers.py
@@ -561,6 +561,41 @@ class ProxSocketHelper(object):
             tsc = int(ret[3])
         return rx, tx, drop, tsc
 
+    def irq_core_stats(self, cores_tasks):
+        """ get IRQ stats per core"""
+
+        stat = {}
+        core = 0
+        task = 0
+        for core, task in cores_tasks:
+            self.put_command("stats task.core({}).task({}).max_irq,task.core({}).task({}).irq(0),"
+                             "task.core({}).task({}).irq(1),task.core({}).task({}).irq(2),"
+                             "task.core({}).task({}).irq(3),task.core({}).task({}).irq(4),"
+                             "task.core({}).task({}).irq(5),task.core({}).task({}).irq(6),"
+                             "task.core({}).task({}).irq(7),task.core({}).task({}).irq(8),"
+                             "task.core({}).task({}).irq(9),task.core({}).task({}).irq(10),"
+                             "task.core({}).task({}).irq(11),task.core({}).task({}).irq(12)"
+                             "\n".format(core, task, core, task, core, task, core, task,
+                                         core, task, core, task, core, task, core, task,
+                                         core, task, core, task, core, task, core, task,
+                                         core, task, core, task))
+            in_data_str = self.get_data().split(",")
+            ret = [try_int(s, 0) for s in in_data_str]
+            key = "core_" + str(core)
+            try:
+                stat[key] = {"cpu": core, "max_irq": ret[0], "bucket_0" : ret[1],
+                             "bucket_1" : ret[2], "bucket_2" : ret[3],
+                             "bucket_3" : ret[4], "bucket_4" : ret[5],
+                             "bucket_5" : ret[6], "bucket_6" : ret[7],
+                             "bucket_7" : ret[8], "bucket_8" : ret[9],
+                             "bucket_9" : ret[10], "bucket_10" : ret[11],
+                             "bucket_11" : ret[12], "bucket_12" : ret[13],
+                             "overflow": ret[10] + ret[11] + ret[12] + ret[13]}
+            except (KeyError, IndexError):
+                LOG.error("Corrupted PACKET %s", in_data_str)
+
+        return stat
+
     def multi_port_stats(self, ports):
         """get counter values from all  ports at once"""
 
@@ -754,7 +789,6 @@ class ProxSocketHelper(object):
         self.put_command("quit_force\n")
         time.sleep(3)
 
-
 _LOCAL_OBJECT = object()
 
 
@@ -2067,3 +2101,15 @@ class ProxlwAFTRProfileHelper(ProxProfileHelper):
                 data_helper.latency = self.get_latency()
 
         return data_helper.result_tuple, data_helper.samples
+
+
+class ProxIrqProfileHelper(ProxProfileHelper):
+
+    __prox_profile_type__ = "IRQ Query"
+
+    def __init__(self, resource_helper):
+        super(ProxIrqProfileHelper, self).__init__(resource_helper)
+        self._cores_tuple = None
+        self._ports_tuple = None
+        self.step_delta = 5
+        self.step_time = 0.5
diff --git a/yardstick/network_services/vnf_generic/vnf/prox_irq.py b/yardstick/network_services/vnf_generic/vnf/prox_irq.py
new file mode 100644
index 000000000..dda26b0fe
--- /dev/null
+++ b/yardstick/network_services/vnf_generic/vnf/prox_irq.py
@@ -0,0 +1,200 @@
+# Copyright (c) 2018 Intel Corporation
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+import errno
+import logging
+import copy
+import time
+
+from yardstick.common.process import check_if_process_failed
+from yardstick.network_services.utils import get_nsb_option
+from yardstick.network_services.vnf_generic.vnf.prox_vnf import ProxApproxVnf
+from yardstick.network_services.vnf_generic.vnf.sample_vnf import SampleVNFTrafficGen
+from yardstick.benchmark.contexts.base import Context
+from yardstick.network_services.vnf_generic.vnf.prox_helpers import CoreSocketTuple
+LOG = logging.getLogger(__name__)
+
+
+class ProxIrq(SampleVNFTrafficGen):
+
+    def __init__(self, name, vnfd, task_id, setup_env_helper_type=None,
+                 resource_helper_type=None):
+        vnfd_cpy = copy.deepcopy(vnfd)
+        super(ProxIrq, self).__init__(name, vnfd_cpy, task_id)
+
+        self._vnf_wrapper = ProxApproxVnf(
+            name, vnfd, task_id, setup_env_helper_type, resource_helper_type)
+        self.bin_path = get_nsb_option('bin_path', '')
+        self.name = self._vnf_wrapper.name
+        self.ssh_helper = self._vnf_wrapper.ssh_helper
+        self.setup_helper = self._vnf_wrapper.setup_helper
+        self.resource_helper = self._vnf_wrapper.resource_helper
+        self.scenario_helper = self._vnf_wrapper.scenario_helper
+        self.irq_cores = None
+
+    def terminate(self):
+        self._vnf_wrapper.terminate()
+        super(ProxIrq, self).terminate()
+
+    def instantiate(self, scenario_cfg, context_cfg):
+        self._vnf_wrapper.instantiate(scenario_cfg, context_cfg)
+        self._tg_process = self._vnf_wrapper._vnf_process
+
+    def wait_for_instantiate(self):
+        self._vnf_wrapper.wait_for_instantiate()
+
+    def get_irq_cores(self):
+        cores = []
+        mode = "irq"
+
+        for section_name, section in self.setup_helper.prox_config_data:
+            if not section_name.startswith("core"):
+                continue
+            irq_mode = task_present = False
+            task_present_task = 0
+            for key, value in section:
+                if key == "mode" and value == mode:
+                    irq_mode = True
+                if key == "task":
+                    task_present = True
+                    task_present_task = int(value)
+
+            if irq_mode:
+                if not task_present:
+                    task_present_task = 0
+                core_tuple = CoreSocketTuple(section_name)
+                core = core_tuple.core_id
+                cores.append((core, task_present_task))
+
+        return cores
+
+class ProxIrqVNF(ProxIrq, SampleVNFTrafficGen):
+
+    APP_NAME = 'ProxIrqVNF'
+
+    def __init__(self, name, vnfd, task_id, setup_env_helper_type=None,
+                 resource_helper_type=None):
+        ProxIrq.__init__(self, name, vnfd, task_id, setup_env_helper_type,
+                        resource_helper_type)
+
+        self.start_test_time = None
+        self.end_test_time = None
+
+    def vnf_execute(self, cmd, *args, **kwargs):
+        ignore_errors = kwargs.pop("_ignore_errors", False)
+        try:
+            return self.resource_helper.execute(cmd, *args, **kwargs)
+        except OSError as e:
+            if e.errno in {errno.EPIPE, errno.ESHUTDOWN, errno.ECONNRESET}:
+                if ignore_errors:
+                    LOG.debug("ignoring vnf_execute exception %s for command %s", e, cmd)
+                else:
+                    raise
+            else:
+                raise
+
+    def collect_kpi(self):
+        # check if the tg processes have exited
+        physical_node = Context.get_physical_node_from_server(
+            self.scenario_helper.nodes[self.name])
+
+        result = {"physical_node": physical_node}
+        for proc in (self._tg_process, self._traffic_process):
+            check_if_process_failed(proc)
+
+        if self.resource_helper is None:
+            return result
+
+        if self.irq_cores is None:
+            self.setup_helper.build_config_file()
+            self.irq_cores = self.get_irq_cores()
+
+        data = self.vnf_execute('irq_core_stats', self.irq_cores)
+        new_data = copy.deepcopy(data)
+
+        self.end_test_time = time.time()
+        self.vnf_execute('reset_stats')
+
+        if self.start_test_time is None:
+            new_data = {}
+        else:
+            test_time = self.end_test_time - self.start_test_time
+            for index, item in data.items():
+                for counter, value in item.items():
+                    if counter.startswith("bucket_")or \
+                            counter.startswith("overflow"):
+                        if value is 0:
+                            del new_data[index][counter]
+                        else:
+                            new_data[index][counter] = float(value) / test_time
+
+        self.start_test_time = time.time()
+
+        result["collect_stats"] = new_data
+        LOG.debug("%s collect KPIs %s", self.APP_NAME, result)
+
+        return result
+
+class ProxIrqGen(ProxIrq, SampleVNFTrafficGen):
+
+    APP_NAME = 'ProxIrqGen'
+
+    def __init__(self, name, vnfd, task_id, setup_env_helper_type=None,
+                 resource_helper_type=None):
+        ProxIrq.__init__(self, name, vnfd, task_id, setup_env_helper_type,
+                                      resource_helper_type)
+        self.start_test_time = None
+        self.end_test_time = None
+
+    def collect_kpi(self):
+        # check if the tg processes have exited
+        physical_node = Context.get_physical_node_from_server(
+            self.scenario_helper.nodes[self.name])
+
+        result = {"physical_node": physical_node}
+        for proc in (self._tg_process, self._traffic_process):
+            check_if_process_failed(proc)
+
+        if self.resource_helper is None:
+            return result
+
+        if self.irq_cores is None:
+            self.setup_helper.build_config_file()
+            self.irq_cores = self.get_irq_cores()
+
+        data = self.resource_helper.sut.irq_core_stats(self.irq_cores)
+        new_data = copy.deepcopy(data)
+
+        self.end_test_time = time.time()
+        self.resource_helper.sut.reset_stats()
+
+        if self.start_test_time is None:
+            new_data = {}
+        else:
+            test_time = self.end_test_time - self.start_test_time
+            for index, item in data.items():
+                for counter, value in item.items():
+                    if counter.startswith("bucket_") or \
+                            counter.startswith("overflow"):
+                        if value is 0:
+                            del new_data[index][counter]
+                        else:
+                            new_data[index][counter] = float(value) / test_time
+
+        self.start_test_time = time.time()
+
+        result["collect_stats"] = new_data
+        LOG.debug("%s collect KPIs %s", self.APP_NAME, result)
+
+        return result
diff --git a/yardstick/tests/unit/network_services/traffic_profile/test_prox_irq.py b/yardstick/tests/unit/network_services/traffic_profile/test_prox_irq.py
new file mode 100644
index 000000000..59f37befa
--- /dev/null
+++ b/yardstick/tests/unit/network_services/traffic_profile/test_prox_irq.py
@@ -0,0 +1,55 @@
+# Copyright (c) 2018 Intel Corporation
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+import unittest
+import mock
+
+from yardstick.network_services.traffic_profile import prox_irq
+
+
+class TestProxIrqProfile(unittest.TestCase):
+
+    def setUp(self):
+        self._mock_log_info = mock.patch.object(prox_irq.LOG, 'info')
+        self.mock_log_info = self._mock_log_info.start()
+        self.addCleanup(self._stop_mocks)
+
+    def _stop_mocks(self):
+        self._mock_log_info.stop()
+
+    def test_execute_1(self):
+        tp_config = {
+            'traffic_profile': {
+            },
+        }
+
+        traffic_generator = mock.MagicMock()
+        attrs1 = {'get.return_value' : 10}
+        traffic_generator.scenario_helper.all_options.configure_mock(**attrs1)
+
+        attrs2 = {'__getitem__.return_value' : 10, 'get.return_value': 10}
+        traffic_generator.scenario_helper.scenario_cfg["runner"].configure_mock(**attrs2)
+
+        profile_helper = mock.MagicMock()
+
+        profile = prox_irq.ProxIrqProfile(tp_config)
+        profile.init(mock.MagicMock())
+        profile._profile_helper = profile_helper
+
+        profile.execute_traffic(traffic_generator)
+        profile.run_test()
+        is_ended_flag = profile.is_ended()
+
+        self.assertFalse(is_ended_flag)
+        self.assertEqual(profile.lower_bound, 10.0)
diff --git a/yardstick/tests/unit/network_services/vnf_generic/vnf/test_prox_helpers.py b/yardstick/tests/unit/network_services/vnf_generic/vnf/test_prox_helpers.py
index 6d1d8c6a1..31f08da3e 100644
--- a/yardstick/tests/unit/network_services/vnf_generic/vnf/test_prox_helpers.py
+++ b/yardstick/tests/unit/network_services/vnf_generic/vnf/test_prox_helpers.py
@@ -590,6 +590,27 @@ class TestProxSocketHelper(unittest.TestCase):
         self.assertEqual(result, expected)
 
     @mock.patch.object(prox_helpers.LOG, 'error')
+    def test_irq_core_stats(self, *args):
+        mock_socket = mock.MagicMock()
+        prox = prox_helpers.ProxSocketHelper(mock_socket)
+        prox.get_data = mock.MagicMock(return_value=('0,1,2,3,4,5,0,1,2,3,4,5,0,1,2,3'))
+
+        data_0 = {"cpu": 0, 'bucket_0': 1, 'bucket_1': 2, 'bucket_2': 3, 'bucket_3': 4,
+                  'bucket_4': 5, 'bucket_5': 0, 'bucket_6': 1, 'bucket_7': 2, 'bucket_8': 3,
+                  'bucket_9': 4, 'bucket_10': 5, 'bucket_11': 0, 'bucket_12': 1,
+                  "max_irq": 0, "overflow": 10}
+
+        data_1 = {"cpu": 1, 'bucket_0': 1, 'bucket_1': 2, 'bucket_2': 3, 'bucket_3': 4,
+                  'bucket_4': 5, 'bucket_5': 0, 'bucket_6': 1, 'bucket_7': 2, 'bucket_8': 3,
+                  'bucket_9': 4, 'bucket_10': 5, 'bucket_11': 0, 'bucket_12': 1,
+                  "max_irq": 0, "overflow": 10}
+
+        expected = {"core_0": data_0, "core_1": data_1}
+
+        result = prox.irq_core_stats([[0, 1], [1, 0]])
+        self.assertDictEqual(result, expected)
+
+    @mock.patch.object(prox_helpers.LOG, 'error')
     def test_multi_port_stats(self, *args):
         mock_socket = mock.MagicMock()
         prox = prox_helpers.ProxSocketHelper(mock_socket)
@@ -2708,3 +2729,15 @@ class TestProxlwAFTRProfileHelper(unittest.TestCase):
         # negative pkt_size is the only way to make ratio > 1
         helper.run_test(pkt_size=-1000, duration=5, value=6.5, tolerated_loss=0.0,
                         line_speed=constants.NIC_GBPS_DEFAULT * constants.ONE_GIGABIT_IN_BITS)
+
+
+class TestProxIrqProfileHelper(unittest.TestCase):
+
+    def test_run_test(self, *args):
+        resource_helper = mock.MagicMock()
+        helper = prox_helpers.ProxIrqProfileHelper(resource_helper)
+        self.assertIsNone(helper._cores_tuple)
+        self.assertIsNone(helper._ports_tuple)
+        self.assertIsNone(helper._latency_cores)
+        self.assertIsNone(helper._test_cores)
+        self.assertIsNone(helper._cpu_topology)
diff --git a/yardstick/tests/unit/network_services/vnf_generic/vnf/test_prox_irq.py b/yardstick/tests/unit/network_services/vnf_generic/vnf/test_prox_irq.py
new file mode 100644
index 000000000..4eaa38c27
--- /dev/null
+++ b/yardstick/tests/unit/network_services/vnf_generic/vnf/test_prox_irq.py
@@ -0,0 +1,828 @@
+# Copyright (c) 2017-2018 Intel Corporation
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+import unittest
+import mock
+import errno
+
+from yardstick.tests import STL_MOCKS
+from yardstick.common import exceptions as y_exceptions
+from yardstick.network_services.vnf_generic.vnf.prox_irq import ProxIrqGen
+from yardstick.network_services.vnf_generic.vnf.prox_irq import ProxIrqVNF
+from yardstick.benchmark.contexts import base as ctx_base
+
+SSH_HELPER = 'yardstick.network_services.vnf_generic.vnf.sample_vnf.VnfSshHelper'
+
+STLClient = mock.MagicMock()
+stl_patch = mock.patch.dict("sys.modules", STL_MOCKS)
+stl_patch.start()
+
+if stl_patch:
+    from yardstick.network_services.vnf_generic.vnf import prox_vnf
+    from yardstick.tests.unit.network_services.vnf_generic.vnf.test_base import mock_ssh
+
+VNF_NAME = "vnf__1"
+
+class TestProxIrqVNF(unittest.TestCase):
+
+    SCENARIO_CFG = {
+        'task_path': "",
+        'nodes': {
+            'tg__1': 'trafficgen_1.yardstick',
+            'vnf__1': 'vnf.yardstick'},
+        'runner': {
+            'duration': 600, 'type': 'Duration'},
+        'topology': 'prox-tg-topology-2.yaml',
+        'traffic_profile': '../../traffic_profiles/prox_binsearch.yaml',
+        'type': 'NSPerf',
+        'options': {
+            'tg__1': {'prox_args': {'-e': '',
+                                    '-t': ''},
+                      'prox_config': 'configs/l3-gen-2.cfg',
+                      'prox_path':
+                          '/root/dppd-PROX-v035/build/prox'},
+            'vnf__1': {
+                'prox_args': {'-t': ''},
+                'prox_config': 'configs/l3-swap-2.cfg',
+                'prox_path': '/root/dppd-PROX-v035/build/prox'}}}
+
+    VNFD_0 = {
+        'short-name': 'VpeVnf',
+        'vdu': [
+            {
+                'routing_table': [
+                    {
+                        'network': '152.16.100.20',
+                        'netmask': '255.255.255.0',
+                        'gateway': '152.16.100.20',
+                        'if': 'xe0'
+                    },
+                    {
+                        'network': '152.16.40.20',
+                        'netmask': '255.255.255.0',
+                        'gateway': '152.16.40.20',
+                        'if': 'xe1'
+                    },
+                ],
+                'description': 'VPE approximation using DPDK',
+                'name': 'vpevnf-baremetal',
+                'nd_route_tbl': [
+                    {
+                        'network': '0064:ff9b:0:0:0:0:9810:6414',
+                        'netmask': '112',
+                        'gateway': '0064:ff9b:0:0:0:0:9810:6414',
+                        'if': 'xe0'
+                    },
+                    {
+                        'network': '0064:ff9b:0:0:0:0:9810:2814',
+                        'netmask': '112',
+                        'gateway': '0064:ff9b:0:0:0:0:9810:2814',
+                        'if': 'xe1'
+                    },
+                ],
+                'id': 'vpevnf-baremetal',
+                'external-interface': [
+                    {
+                        'virtual-interface': {
+                            'dst_mac': '00:00:00:00:00:03',
+                            'vpci': '0000:05:00.0',
+                            'local_ip': '152.16.100.19',
+                            'type': 'PCI-PASSTHROUGH',
+                            'netmask': '255.255.255.0',
+                            'dpdk_port_num': 0,
+                            'bandwidth': '10 Gbps',
+                            'dst_ip': '152.16.100.20',
+                            'local_mac': '00:00:00:00:00:01'
+                        },
+                        'vnfd-connection-point-ref': 'xe0',
+                        'name': 'xe0'
+                    },
+                    {
+                        'virtual-interface': {
+                            'dst_mac': '00:00:00:00:00:04',
+                            'vpci': '0000:05:00.1',
+                            'local_ip': '152.16.40.19',
+                            'type': 'PCI-PASSTHROUGH',
+                            'netmask': '255.255.255.0',
+                            'dpdk_port_num': 1,
+                            'bandwidth': '10 Gbps',
+                            'dst_ip': '152.16.40.20',
+                            'local_mac': '00:00:00:00:00:02'
+                        },
+                        'vnfd-connection-point-ref': 'xe1',
+                        'name': 'xe1'
+                    },
+                ],
+            },
+        ],
+        'description': 'Vpe approximation using DPDK',
+        'mgmt-interface': {
+            'vdu-id': 'vpevnf-baremetal',
+            'host': '1.1.1.1',
+            'password': 'r00t',
+            'user': 'root',
+            'ip': '1.1.1.1'
+        },
+        'benchmark': {
+            'kpi': [
+                'packets_in',
+                'packets_fwd',
+                'packets_dropped',
+            ],
+        },
+        'connection-point': [
+            {
+                'type': 'VPORT',
+                'name': 'xe0',
+            },
+            {
+                'type': 'VPORT',
+                'name': 'xe1',
+            },
+        ],
+        'id': 'VpeApproxVnf', 'name': 'VPEVnfSsh'
+    }
+
+    VNFD = {
+        'vnfd:vnfd-catalog': {
+            'vnfd': [
+                VNFD_0,
+            ]
+        }
+    }
+
+    TRAFFIC_PROFILE = {
+        "schema": "isb:traffic_profile:0.1",
+        "name": "fixed",
+        "description": "Fixed traffic profile to run UDP traffic",
+        "traffic_profile": {
+            "traffic_type": "FixedTraffic",
+            "frame_rate": 100,  # pps
+            "flow_number": 10,
+            "frame_size": 64,
+        },
+    }
+
+    CONTEXT_CFG = {
+        'nodes': {
+            'tg__2': {
+                'member-vnf-index': '3',
+                'role': 'TrafficGen',
+                'name': 'trafficgen_2.yardstick',
+                'vnfd-id-ref': 'tg__2',
+                'ip': '1.2.1.1',
+                'interfaces': {
+                    'xe0': {
+                        'local_iface_name': 'ens513f0',
+                        'vld_id': prox_vnf.ProxApproxVnf.DOWNLINK,
+                        'netmask': '255.255.255.0',
+                        'local_ip': '152.16.40.20',
+                        'dst_mac': '00:00:00:00:00:01',
+                        'local_mac': '00:00:00:00:00:03',
+                        'dst_ip': '152.16.40.19',
+                        'driver': 'ixgbe',
+                        'vpci': '0000:02:00.0',
+                        'dpdk_port_num': 0,
+                    },
+                    'xe1': {
+                        'local_iface_name': 'ens513f1',
+                        'netmask': '255.255.255.0',
+                        'network': '202.16.100.0',
+                        'local_ip': '202.16.100.20',
+                        'local_mac': '00:1e:67:d0:60:5d',
+                        'driver': 'ixgbe',
+                        'vpci': '0000:02:00.1',
+                        'dpdk_port_num': 1,
+                    },
+                },
+                'password': 'r00t',
+                'VNF model': 'l3fwd_vnf.yaml',
+                'user': 'root',
+            },
+            'tg__1': {
+                'member-vnf-index': '1',
+                'role': 'TrafficGen',
+                'name': 'trafficgen_1.yardstick',
+                'vnfd-id-ref': 'tg__1',
+                'ip': '1.2.1.1',
+                'interfaces': {
+                    'xe0': {
+                        'local_iface_name': 'ens785f0',
+                        'vld_id': prox_vnf.ProxApproxVnf.UPLINK,
+                        'netmask': '255.255.255.0',
+                        'local_ip': '152.16.100.20',
+                        'dst_mac': '00:00:00:00:00:02',
+                        'local_mac': '00:00:00:00:00:04',
+                        'dst_ip': '152.16.100.19',
+                        'driver': 'i40e',
+                        'vpci': '0000:05:00.0',
+                        'dpdk_port_num': 0,
+                    },
+                    'xe1': {
+                        'local_iface_name': 'ens785f1',
+                        'netmask': '255.255.255.0',
+                        'local_ip': '152.16.100.21',
+                        'local_mac': '00:00:00:00:00:01',
+                        'driver': 'i40e',
+                        'vpci': '0000:05:00.1',
+                        'dpdk_port_num': 1,
+                    },
+                },
+                'password': 'r00t',
+                'VNF model': 'tg_rfc2544_tpl.yaml',
+                'user': 'root',
+            },
+            'vnf__1': {
+                'name': 'vnf.yardstick',
+                'vnfd-id-ref': 'vnf__1',
+                'ip': '1.2.1.1',
+                'interfaces': {
+                    'xe0': {
+                        'local_iface_name': 'ens786f0',
+                        'vld_id': prox_vnf.ProxApproxVnf.UPLINK,
+                        'netmask': '255.255.255.0',
+                        'local_ip': '152.16.100.19',
+                        'dst_mac': '00:00:00:00:00:04',
+                        'local_mac': '00:00:00:00:00:02',
+                        'dst_ip': '152.16.100.20',
+                        'driver': 'i40e',
+                        'vpci': '0000:05:00.0',
+                        'dpdk_port_num': 0,
+                    },
+                    'xe1': {
+                        'local_iface_name': 'ens786f1',
+                        'vld_id': prox_vnf.ProxApproxVnf.DOWNLINK,
+                        'netmask': '255.255.255.0',
+                        'local_ip': '152.16.40.19',
+                        'dst_mac': '00:00:00:00:00:03',
+                        'local_mac': '00:00:00:00:00:01',
+                        'dst_ip': '152.16.40.20',
+                        'driver': 'i40e',
+                        'vpci': '0000:05:00.1',
+                        'dpdk_port_num': 1,
+                    },
+                },
+                'routing_table': [
+                    {
+                        'netmask': '255.255.255.0',
+                        'gateway': '152.16.100.20',
+                        'network': '152.16.100.20',
+                        'if': 'xe0',
+                    },
+                    {
+                        'netmask': '255.255.255.0',
+                        'gateway': '152.16.40.20',
+                        'network': '152.16.40.20',
+                        'if': 'xe1',
+                    },
+                ],
+                'member-vnf-index': '2',
+                'host': '1.2.1.1',
+                'role': 'vnf',
+                'user': 'root',
+                'nd_route_tbl': [
+                    {
+                        'netmask': '112',
+                        'gateway': '0064:ff9b:0:0:0:0:9810:6414',
+                        'network': '0064:ff9b:0:0:0:0:9810:6414',
+                        'if': 'xe0',
+                    },
+                    {
+                        'netmask': '112',
+                        'gateway': '0064:ff9b:0:0:0:0:9810:2814',
+                        'network': '0064:ff9b:0:0:0:0:9810:2814',
+                        'if': 'xe1',
+                    },
+                ],
+                'password': 'r00t',
+                'VNF model': 'prox_vnf.yaml',
+            },
+        },
+    }
+
+    def test___init__(self):
+        prox_irq_vnf = ProxIrqVNF('vnf1', self.VNFD_0, 'task_id')
+
+        self.assertEqual(prox_irq_vnf.name, 'vnf1')
+        self.assertDictEqual(prox_irq_vnf.vnfd_helper, self.VNFD_0)
+
+    @mock.patch.object(ctx_base.Context, 'get_physical_node_from_server', return_value='mock_node')
+    @mock.patch(SSH_HELPER)
+    def test_collect_kpi(self, ssh, *args):
+        mock_ssh(ssh)
+
+        vnfd = self.VNFD['vnfd:vnfd-catalog']['vnfd'][0]
+        resource_helper = mock.MagicMock()
+
+        resource_helper = mock.MagicMock()
+
+        core_1 = {'bucket_1': 1, 'bucket_2': 2, 'bucket_3': 3, 'bucket_4': 4, 'bucket_5': 5,
+                  'bucket_6': 6, 'bucket_7': 7, 'bucket_8': 8, 'bucket_9': 9, 'bucket_10': 10,
+                  'bucket_11': 11, 'bucket_12': 12, 'bucket_0': 100, 'cpu': 1, 'max_irq': 12,
+                  'overflow': 10}
+        core_2 = {'bucket_1': 1, 'bucket_2': 2, 'bucket_3': 3, 'bucket_4': 4, 'bucket_5': 5,
+                  'bucket_6': 0, 'bucket_7': 0, 'bucket_8': 0, 'bucket_9': 0, 'bucket_10': 0,
+                  'bucket_11': 0, 'bucket_12': 0, 'bucket_0': 100, 'cpu': 2, 'max_irq': 12,
+                  'overflow': 10}
+
+        irq_data = {'core_1': core_1, 'core_2': core_2}
+        resource_helper.execute.return_value = (irq_data)
+
+        build_config_file = mock.MagicMock()
+        build_config_file.return_value = None
+
+        prox_irq_vnf = ProxIrqVNF(VNF_NAME, vnfd, 'task_id')
+
+        startup = ["global", [["eal", "-4"]]]
+        master_0 = ["core 0", [["mode", "master"]]]
+        core_1 = ["core 1", [["mode", "irq"]]]
+        core_2 = ["core 2", [["mode", "irq"], ["task", "2"]]]
+
+        prox_irq_vnf.setup_helper._prox_config_data = \
+            [startup, master_0, core_1, core_2]
+
+        prox_irq_vnf.scenario_helper.scenario_cfg = self.SCENARIO_CFG
+        prox_irq_vnf.resource_helper = resource_helper
+        prox_irq_vnf.setup_helper.build_config_file = build_config_file
+
+        result = prox_irq_vnf.collect_kpi()
+        self.assertDictEqual(result["collect_stats"], {})
+
+        result = prox_irq_vnf.collect_kpi()
+        self.assertFalse('bucket_10' in result["collect_stats"]['core_2'])
+        self.assertFalse('bucket_11' in result["collect_stats"]['core_2'])
+        self.assertFalse('bucket_12' in result["collect_stats"]['core_2'])
+        self.assertEqual(result["collect_stats"]['core_2']['max_irq'], 12)
+
+
+    @mock.patch(SSH_HELPER)
+    def test_vnf_execute_oserror(self, ssh, *args):
+        mock_ssh(ssh)
+
+        vnfd = self.VNFD['vnfd:vnfd-catalog']['vnfd'][0]
+        prox_irq_vnf = ProxIrqVNF(VNF_NAME, vnfd, 'task_id')
+        prox_irq_vnf.resource_helper = resource_helper = mock.Mock()
+
+        resource_helper.execute.side_effect = OSError(errno.EPIPE, "")
+        prox_irq_vnf.vnf_execute("", _ignore_errors=True)
+
+        resource_helper.execute.side_effect = OSError(errno.ESHUTDOWN, "")
+        prox_irq_vnf.vnf_execute("", _ignore_errors=True)
+
+        resource_helper.execute.side_effect = OSError(errno.EADDRINUSE, "")
+        with self.assertRaises(OSError):
+            prox_irq_vnf.vnf_execute("", _ignore_errors=True)
+
+    @mock.patch('yardstick.network_services.vnf_generic.vnf.prox_helpers.socket')
+    @mock.patch(SSH_HELPER)
+    def test_terminate(self, ssh, *args):
+        mock_ssh(ssh)
+        vnfd = self.VNFD['vnfd:vnfd-catalog']['vnfd'][0]
+
+        mock_ssh(ssh, exec_result=(1, "", ""))
+        prox_irq_vnf = ProxIrqVNF(VNF_NAME, vnfd, 'task_id')
+
+        prox_irq_vnf._terminated = mock.MagicMock()
+        prox_irq_vnf._traffic_process = mock.MagicMock()
+        prox_irq_vnf._traffic_process.terminate = mock.Mock()
+        prox_irq_vnf.ssh_helper = mock.MagicMock()
+        prox_irq_vnf.setup_helper = mock.MagicMock()
+        prox_irq_vnf.resource_helper = mock.MagicMock()
+        prox_irq_vnf._vnf_wrapper.setup_helper = mock.MagicMock()
+        prox_irq_vnf._vnf_wrapper._vnf_process = mock.MagicMock(**{"is_alive.return_value": False})
+        prox_irq_vnf._vnf_wrapper.resource_helper = mock.MagicMock()
+
+        prox_irq_vnf._run_prox = mock.Mock(return_value=0)
+        prox_irq_vnf.q_in = mock.Mock()
+        prox_irq_vnf.q_out = mock.Mock()
+
+        self.assertIsNone(prox_irq_vnf.terminate())
+
+    @mock.patch(SSH_HELPER)
+    def test_wait_for_instantiate_panic(self, ssh, *args):
+        vnfd = self.VNFD['vnfd:vnfd-catalog']['vnfd'][0]
+
+        mock_ssh(ssh, exec_result=(1, "", ""))
+        prox_irq_vnf = ProxIrqVNF(VNF_NAME, vnfd, 'task_id')
+
+        prox_irq_vnf._terminated = mock.MagicMock()
+        prox_irq_vnf._traffic_process = mock.MagicMock()
+        prox_irq_vnf._traffic_process.terminate = mock.Mock()
+        prox_irq_vnf.ssh_helper = mock.MagicMock()
+        prox_irq_vnf.setup_helper = mock.MagicMock()
+        prox_irq_vnf.resource_helper = mock.MagicMock()
+        prox_irq_vnf._vnf_wrapper.setup_helper = mock.MagicMock()
+        prox_irq_vnf._vnf_wrapper._vnf_process = mock.MagicMock(**{"is_alive.return_value": False})
+        prox_irq_vnf._vnf_wrapper.resource_helper = mock.MagicMock()
+
+        prox_irq_vnf._run_prox = mock.Mock(return_value=0)
+        prox_irq_vnf.q_in = mock.Mock()
+        prox_irq_vnf.q_out = mock.Mock()
+        prox_irq_vnf.WAIT_TIME = 0
+        with self.assertRaises(RuntimeError):
+            prox_irq_vnf.wait_for_instantiate()
+
+class TestProxIrqGen(unittest.TestCase):
+
+    SCENARIO_CFG = {
+        'task_path': "",
+        'nodes': {
+            'tg__1': 'trafficgen_1.yardstick',
+            'vnf__1': 'vnf.yardstick'},
+        'runner': {
+            'duration': 600, 'type': 'Duration'},
+        'topology': 'prox-tg-topology-2.yaml',
+        'traffic_profile': '../../traffic_profiles/prox_binsearch.yaml',
+        'type': 'NSPerf',
+        'options': {
+            'tg__1': {'prox_args': {'-e': '',
+                                    '-t': ''},
+                      'prox_config': 'configs/l3-gen-2.cfg',
+                      'prox_path':
+                          '/root/dppd-PROX-v035/build/prox'},
+            'vnf__1': {
+                'prox_args': {'-t': ''},
+                'prox_config': 'configs/l3-swap-2.cfg',
+                'prox_path': '/root/dppd-PROX-v035/build/prox'}}}
+
+    VNFD_0 = {
+        'short-name': 'VpeVnf',
+        'vdu': [
+            {
+                'routing_table': [
+                    {
+                        'network': '152.16.100.20',
+                        'netmask': '255.255.255.0',
+                        'gateway': '152.16.100.20',
+                        'if': 'xe0'
+                    },
+                    {
+                        'network': '152.16.40.20',
+                        'netmask': '255.255.255.0',
+                        'gateway': '152.16.40.20',
+                        'if': 'xe1'
+                    },
+                ],
+                'description': 'VPE approximation using DPDK',
+                'name': 'vpevnf-baremetal',
+                'nd_route_tbl': [
+                    {
+                        'network': '0064:ff9b:0:0:0:0:9810:6414',
+                        'netmask': '112',
+                        'gateway': '0064:ff9b:0:0:0:0:9810:6414',
+                        'if': 'xe0'
+                    },
+                    {
+                        'network': '0064:ff9b:0:0:0:0:9810:2814',
+                        'netmask': '112',
+                        'gateway': '0064:ff9b:0:0:0:0:9810:2814',
+                        'if': 'xe1'
+                    },
+                ],
+                'id': 'vpevnf-baremetal',
+                'external-interface': [
+                    {
+                        'virtual-interface': {
+                            'dst_mac': '00:00:00:00:00:03',
+                            'vpci': '0000:05:00.0',
+                            'driver': 'i40e',
+                            'local_ip': '152.16.100.19',
+                            'type': 'PCI-PASSTHROUGH',
+                            'netmask': '255.255.255.0',
+                            'dpdk_port_num': 0,
+                            'bandwidth': '10 Gbps',
+                            'dst_ip': '152.16.100.20',
+                            'local_mac': '00:00:00:00:00:01'
+                        },
+                        'vnfd-connection-point-ref': 'xe0',
+                        'name': 'xe0'
+                    },
+                    {
+                        'virtual-interface': {
+                            'dst_mac': '00:00:00:00:00:04',
+                            'vpci': '0000:05:00.1',
+                            'driver': 'ixgbe',
+                            'local_ip': '152.16.40.19',
+                            'type': 'PCI-PASSTHROUGH',
+                            'netmask': '255.255.255.0',
+                            'dpdk_port_num': 1,
+                            'bandwidth': '10 Gbps',
+                            'dst_ip': '152.16.40.20',
+                            'local_mac': '00:00:00:00:00:02'
+                        },
+                        'vnfd-connection-point-ref': 'xe1',
+                        'name': 'xe1'
+                    },
+                ],
+            },
+        ],
+        'description': 'Vpe approximation using DPDK',
+        'mgmt-interface': {
+            'vdu-id': 'vpevnf-baremetal',
+            'host': '1.1.1.1',
+            'password': 'r00t',
+            'user': 'root',
+            'ip': '1.1.1.1'
+        },
+        'benchmark': {
+            'kpi': [
+                'packets_in',
+                'packets_fwd',
+                'packets_dropped',
+            ],
+        },
+        'connection-point': [
+            {
+                'type': 'VPORT',
+                'name': 'xe0',
+            },
+            {
+                'type': 'VPORT',
+                'name': 'xe1',
+            },
+        ],
+        'id': 'VpeApproxVnf', 'name': 'VPEVnfSsh'
+    }
+
+    VNFD = {
+        'vnfd:vnfd-catalog': {
+            'vnfd': [
+                VNFD_0,
+            ],
+        },
+    }
+
+    TRAFFIC_PROFILE = {
+        "schema": "isb:traffic_profile:0.1",
+        "name": "fixed",
+        "description": "Fixed traffic profile to run UDP traffic",
+        "traffic_profile": {
+            "traffic_type": "FixedTraffic",
+            "frame_rate": 100,  # pps
+            "flow_number": 10,
+            "frame_size": 64,
+        },
+    }
+
+    CONTEXT_CFG = {
+        'nodes': {
+            'tg__2': {
+                'member-vnf-index': '3',
+                'role': 'TrafficGen',
+                'name': 'trafficgen_2.yardstick',
+                'vnfd-id-ref': 'tg__2',
+                'ip': '1.2.1.1',
+                'interfaces': {
+                    'xe0': {
+                        'local_iface_name': 'ens513f0',
+                        'vld_id': prox_vnf.ProxApproxVnf.DOWNLINK,
+                        'netmask': '255.255.255.0',
+                        'local_ip': '152.16.40.20',
+                        'dst_mac': '00:00:00:00:00:01',
+                        'local_mac': '00:00:00:00:00:03',
+                        'dst_ip': '152.16.40.19',
+                        'driver': 'ixgbe',
+                        'vpci': '0000:02:00.0',
+                        'dpdk_port_num': 0,
+                    },
+                    'xe1': {
+                        'local_iface_name': 'ens513f1',
+                        'netmask': '255.255.255.0',
+                        'network': '202.16.100.0',
+                        'local_ip': '202.16.100.20',
+                        'local_mac': '00:1e:67:d0:60:5d',
+                        'driver': 'ixgbe',
+                        'vpci': '0000:02:00.1',
+                        'dpdk_port_num': 1,
+                    },
+                },
+                'password': 'r00t',
+                'VNF model': 'l3fwd_vnf.yaml',
+                'user': 'root',
+            },
+            'tg__1': {
+                'member-vnf-index': '1',
+                'role': 'TrafficGen',
+                'name': 'trafficgen_1.yardstick',
+                'vnfd-id-ref': 'tg__1',
+                'ip': '1.2.1.1',
+                'interfaces': {
+                    'xe0': {
+                        'local_iface_name': 'ens785f0',
+                        'vld_id': prox_vnf.ProxApproxVnf.UPLINK,
+                        'netmask': '255.255.255.0',
+                        'local_ip': '152.16.100.20',
+                        'dst_mac': '00:00:00:00:00:02',
+                        'local_mac': '00:00:00:00:00:04',
+                        'dst_ip': '152.16.100.19',
+                        'driver': 'i40e',
+                        'vpci': '0000:05:00.0',
+                        'dpdk_port_num': 0,
+                    },
+                    'xe1': {
+                        'local_iface_name': 'ens785f1',
+                        'netmask': '255.255.255.0',
+                        'local_ip': '152.16.100.21',
+                        'local_mac': '00:00:00:00:00:01',
+                        'driver': 'i40e',
+                        'vpci': '0000:05:00.1',
+                        'dpdk_port_num': 1,
+                    },
+                },
+                'password': 'r00t',
+                'VNF model': 'tg_rfc2544_tpl.yaml',
+                'user': 'root',
+            },
+            'vnf__1': {
+                'name': 'vnf.yardstick',
+                'vnfd-id-ref': 'vnf__1',
+                'ip': '1.2.1.1',
+                'interfaces': {
+                    'xe0': {
+                        'local_iface_name': 'ens786f0',
+                        'vld_id': prox_vnf.ProxApproxVnf.UPLINK,
+                        'netmask': '255.255.255.0',
+                        'local_ip': '152.16.100.19',
+                        'dst_mac': '00:00:00:00:00:04',
+                        'local_mac': '00:00:00:00:00:02',
+                        'dst_ip': '152.16.100.20',
+                        'driver': 'i40e',
+                        'vpci': '0000:05:00.0',
+                        'dpdk_port_num': 0,
+                    },
+                    'xe1': {
+                        'local_iface_name': 'ens786f1',
+                        'vld_id': prox_vnf.ProxApproxVnf.DOWNLINK,
+                        'netmask': '255.255.255.0',
+                        'local_ip': '152.16.40.19',
+                        'dst_mac': '00:00:00:00:00:03',
+                        'local_mac': '00:00:00:00:00:01',
+                        'dst_ip': '152.16.40.20',
+                        'driver': 'i40e',
+                        'vpci': '0000:05:00.1',
+                        'dpdk_port_num': 1,
+                    },
+                },
+                'routing_table': [
+                    {
+                        'netmask': '255.255.255.0',
+                        'gateway': '152.16.100.20',
+                        'network': '152.16.100.20',
+                        'if': 'xe0',
+                    },
+                    {
+                        'netmask': '255.255.255.0',
+                        'gateway': '152.16.40.20',
+                        'network': '152.16.40.20',
+                        'if': 'xe1',
+                    },
+                ],
+                'member-vnf-index': '2',
+                'host': '1.2.1.1',
+                'role': 'vnf',
+                'user': 'root',
+                'nd_route_tbl': [
+                    {
+                        'netmask': '112',
+                        'gateway': '0064:ff9b:0:0:0:0:9810:6414',
+                        'network': '0064:ff9b:0:0:0:0:9810:6414',
+                        'if': 'xe0',
+                    },
+                    {
+                        'netmask': '112',
+                        'gateway': '0064:ff9b:0:0:0:0:9810:2814',
+                        'network': '0064:ff9b:0:0:0:0:9810:2814',
+                        'if': 'xe1',
+                    },
+                ],
+                'password': 'r00t',
+                'VNF model': 'prox_vnf.yaml',
+            },
+        },
+    }
+
+
+    def test__check_status(self):
+        prox_irq_gen = ProxIrqGen('tg1', self.VNFD_0, 'task_id')
+
+        with self.assertRaises(NotImplementedError):
+            prox_irq_gen._check_status()
+
+    def test_listen_traffic(self):
+        prox_irq_gen = ProxIrqGen('tg1', self.VNFD_0, 'task_id')
+
+        prox_irq_gen.listen_traffic(mock.Mock())
+
+    def test_verify_traffic(self):
+        prox_irq_gen = ProxIrqGen('tg1', self.VNFD_0, 'task_id')
+
+        prox_irq_gen.verify_traffic(mock.Mock())
+
+    mock.patch('yardstick.network_services.vnf_generic.vnf.prox_helpers.socket')
+    @mock.patch(SSH_HELPER)
+    def test_terminate(self, ssh, *args):
+        mock_ssh(ssh)
+        vnfd = self.VNFD['vnfd:vnfd-catalog']['vnfd'][0]
+        prox_traffic_gen = ProxIrqGen(VNF_NAME, vnfd, 'task_id')
+        prox_traffic_gen._terminated = mock.MagicMock()
+        prox_traffic_gen._traffic_process = mock.MagicMock()
+        prox_traffic_gen._traffic_process.terminate = mock.Mock()
+        prox_traffic_gen.ssh_helper = mock.MagicMock()
+        prox_traffic_gen.setup_helper = mock.MagicMock()
+        prox_traffic_gen.resource_helper = mock.MagicMock()
+        prox_traffic_gen._vnf_wrapper.setup_helper = mock.MagicMock()
+        prox_traffic_gen._vnf_wrapper._vnf_process = mock.MagicMock()
+        prox_traffic_gen._vnf_wrapper.resource_helper = mock.MagicMock()
+        self.assertIsNone(prox_traffic_gen.terminate())
+
+    def test__wait_for_process(self):
+        prox_irq_gen = ProxIrqGen('tg1', self.VNFD_0, 'task_id')
+        with mock.patch.object(prox_irq_gen, '_check_status',
+                               return_value=0) as mock_status, \
+                mock.patch.object(prox_irq_gen, '_tg_process') as mock_proc:
+            mock_proc.is_alive.return_value = True
+            mock_proc.exitcode = 234
+            self.assertEqual(prox_irq_gen._wait_for_process(), 234)
+            mock_proc.is_alive.assert_called_once()
+            mock_status.assert_called_once()
+
+    def test__wait_for_process_not_alive(self):
+        prox_irq_gen = ProxIrqGen('tg1', self.VNFD_0, 'task_id')
+        with mock.patch.object(prox_irq_gen, '_tg_process') as mock_proc:
+            mock_proc.is_alive.return_value = False
+            self.assertRaises(RuntimeError, prox_irq_gen._wait_for_process)
+            mock_proc.is_alive.assert_called_once()
+
+    def test__wait_for_process_delayed(self):
+        prox_irq_gen = ProxIrqGen('tg1', self.VNFD_0, 'task_id')
+        with mock.patch.object(prox_irq_gen, '_check_status',
+                               side_effect=[1, 0]) as mock_status, \
+                mock.patch.object(prox_irq_gen,
+                                  '_tg_process') as mock_proc:
+            mock_proc.is_alive.return_value = True
+            mock_proc.exitcode = 234
+            self.assertEqual(prox_irq_gen._wait_for_process(), 234)
+            mock_proc.is_alive.assert_has_calls([mock.call(), mock.call()])
+            mock_status.assert_has_calls([mock.call(), mock.call()])
+
+    def test_scale(self):
+        prox_irq_gen = ProxIrqGen('tg1', self.VNFD_0, 'task_id')
+        self.assertRaises(y_exceptions.FunctionNotImplemented,
+                          prox_irq_gen.scale)
+
+    @mock.patch.object(ctx_base.Context, 'get_physical_node_from_server', return_value='mock_node')
+    @mock.patch(SSH_HELPER)
+    def test_collect_kpi(self, ssh, *args):
+        mock_ssh(ssh)
+
+        vnfd = self.VNFD['vnfd:vnfd-catalog']['vnfd'][0]
+        resource_helper = mock.MagicMock()
+
+        core_1 = {'bucket_1': 1, 'bucket_2': 2, 'bucket_3': 3, 'bucket_4': 4, 'bucket_5': 5,
+                  'bucket_6': 6, 'bucket_7': 7, 'bucket_8': 8, 'bucket_9': 9, 'bucket_10': 10,
+                  'bucket_11': 11, 'bucket_12': 12, 'bucket_0': 100, 'cpu': 1, 'max_irq': 12,
+                  'overflow': 10}
+        core_2 = {'bucket_1': 1, 'bucket_2': 2, 'bucket_3': 3, 'bucket_4': 4, 'bucket_5': 5,
+                  'bucket_6': 0, 'bucket_7': 0, 'bucket_8': 0, 'bucket_9': 0, 'bucket_10': 0,
+                  'bucket_11': 0, 'bucket_12': 0, 'bucket_0': 100, 'cpu': 2, 'max_irq': 12,
+                  'overflow': 10}
+
+        irq_data = {'core_1': core_1, 'core_2': core_2}
+        resource_helper.sut.irq_core_stats.return_value = (irq_data)
+
+        build_config_file = mock.MagicMock()
+        build_config_file.return_value = None
+
+        prox_irq_gen = ProxIrqGen(VNF_NAME, vnfd, 'task_id')
+
+        startup = ["global", [["eal", "-4"]]]
+        master_0 = ["core 0", [["mode", "master"]]]
+        core_1 = ["core 1", [["mode", "irq"]]]
+        core_2 = ["core 2", [["mode", "irq"], ["task", "2"]]]
+
+        prox_irq_gen.setup_helper._prox_config_data = \
+            [startup, master_0, core_1, core_2]
+
+        prox_irq_gen.scenario_helper.scenario_cfg = self.SCENARIO_CFG
+        prox_irq_gen.resource_helper = resource_helper
+        prox_irq_gen.setup_helper.build_config_file = build_config_file
+
+        result = prox_irq_gen.collect_kpi()
+        self.assertDictEqual(result["collect_stats"], {})
+
+        result = prox_irq_gen.collect_kpi()
+        self.assertFalse('bucket_10' in result["collect_stats"]['core_2'])
+        self.assertFalse('bucket_11' in result["collect_stats"]['core_2'])
+        self.assertFalse('bucket_12' in result["collect_stats"]['core_2'])
+        self.assertEqual(result["collect_stats"]['core_2']['max_irq'], 12)