yardstick/network_services/vnf_generic/vnf/prox_helpers.py


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

@media only all and (prefers-color-scheme: dark) {
.highlight .hll { background-color: #49483e }
.highlight .c { color: #75715e } /* Comment */
.highlight .err { color: #960050; background-color: #1e0010 } /* Error */
.highlight .k { color: #66d9ef } /* Keyword */
.highlight .l { color: #ae81ff } /* Literal */
.highlight .n { color: #f8f8f2 } /* Name */
.highlight .o { color: #f92672 } /* Operator */
.highlight .p { color: #f8f8f2 } /* Punctuation */
.highlight .ch { color: #75715e } /* Comment.Hashbang */
.highlight .cm { color: #75715e } /* Comment.Multiline */
.highlight .cp { color: #75715e } /* Comment.Preproc */
.highlight .cpf { color: #75715e } /* Comment.PreprocFile */
.highlight .c1 { color: #75715e } /* Comment.Single */
.highlight .cs { color: #75715e } /* Comment.Special */
.highlight .gd { color: #f92672 } /* Generic.Deleted */
.highlight .ge { font-style: italic } /* Generic.Emph */
.highlight .gi { color: #a6e22e } /* Generic.Inserted */
.highlight .gs { font-weight: bold } /* Generic.Strong */
.highlight .gu { color: #75715e } /* Generic.Subheading */
.highlight .kc { color: #66d9ef } /* Keyword.Constant */
.highlight .kd { color: #66d9ef } /* Keyword.Declaration */
.highlight .kn { color: #f92672 } /* Keyword.Namespace */
.highlight .kp { color: #66d9ef } /* Keyword.Pseudo */
.highlight .kr { color: #66d9ef } /* Keyword.Reserved */
.highlight .kt { color: #66d9ef } /* Keyword.Type */
.highlight .ld { color: #e6db74 } /* Literal.Date */
.highlight .m { color: #ae81ff } /* Literal.Number */
.highlight .s { color: #e6db74 } /* Literal.String */
.highlight .na { color: #a6e22e } /* Name.Attribute */
.highlight .nb { color: #f8f8f2 } /* Name.Builtin */
.highlight .nc { color: #a6e22e } /* Name.Class */
.highlight .no { color: #66d9ef } /* Name.Constant */
.highlight .nd { color: #a6e22e } /* Name.Decorator */
.highlight .ni { color: #f8f8f2 } /* Name.Entity */
.highlight .ne { color: #a6e22e } /* Name.Exception */
.highlight .nf { color: #a6e22e } /* Name.Function */
.highlight .nl { color: #f8f8f2 } /* Name.Label */
.highlight .nn { color: #f8f8f2 } /* Name.Namespace */
.highlight .nx { color: #a6e22e } /* Name.Other */
.highlight .py { color: #f8f8f2 } /* Name.Property */
.highlight .nt { color: #f92672 } /* Name.Tag */
.highlight .nv { color: #f8f8f2 } /* Name.Variable */
.highlight .ow { color: #f92672 } /* Operator.Word */
.highlight .w { color: #f8f8f2 } /* Text.Whitespace */
.highlight .mb { color: #ae81ff } /* Literal.Number.Bin */
.highlight .mf { color: #ae81ff } /* Literal.Number.Float */
.highlight .mh { color: #ae81ff } /* Literal.Number.Hex */
.highlight .mi { color: #ae81ff } /* Literal.Number.Integer */
.highlight .mo { color: #ae81ff } /* Literal.Number.Oct */
.highlight .sa { color: #e6db74 } /* Literal.String.Affix */
.highlight .sb { color: #e6db74 } /* Literal.String.Backtick */
.highlight .sc { color: #e6db74 } /* Literal.String.Char */
.highlight .dl { color: #e6db74 } /* Literal.String.Delimiter */
.highlight .sd { color: #e6db74 } /* Literal.String.Doc */
.highlight .s2 { color: #e6db74 } /* Literal.String.Double */
.highlight .se { color: #ae81ff } /* Literal.String.Escape */
.highlight .sh { color: #e6db74 } /* Literal.String.Heredoc */
.highlight .si { color: #e6db74 } /* Literal.String.Interpol */
.highlight .sx { color: #e6db74 } /* Literal.String.Other */
.highlight .sr { color: #e6db74 } /* Literal.String.Regex */
.highlight .s1 { color: #e6db74 } /* Literal.String.Single */
.highlight .ss { color: #e6db74 } /* Literal.String.Symbol */
.highlight .bp { color: #f8f8f2 } /* Name.Builtin.Pseudo */
.highlight .fm { color: #a6e22e } /* Name.Function.Magic */
.highlight .vc { color: #f8f8f2 } /* Name.Variable.Class */
.highlight .vg { color: #f8f8f2 } /* Name.Variable.Global */
.highlight .vi { color: #f8f8f2 } /* Name.Variable.Instance */
.highlight .vm { color: #f8f8f2 } /* Name.Variable.Magic */
.highlight .il { color: #ae81ff } /* Literal.Number.Integer.Long */
}
@media (prefers-color-scheme: light) {
.highlight .hll { background-color: #ffffcc }
.highlight .c { color: #888888 } /* Comment */
.highlight .err { color: #a61717; background-color: #e3d2d2 } /* Error */
.highlight .k { color: #008800; font-weight: bold } /* Keyword */
.highlight .ch { color: #888888 } /* Comment.Hashbang */
.highlight .cm { color: #888888 } /* Comment.Multiline */
.highlight .cp { color: #cc0000; font-weight: bold } /* Comment.Preproc */
.highlight .cpf { color: #888888 } /* Comment.PreprocFile */
.highlight .c1 { color: #888888 } /* Comment.Single */
.highlight .cs { color: #cc0000; font-weight: bold; background-color: #fff0f0 } /* Comment.Special */
.highlight .gd { color: #000000; background-color: #ffdddd } /* Generic.Deleted */
.highlight .ge { font-style: italic } /* Generic.Emph */
.highlight .gr { color: #aa0000 } /* Generic.Error */
.highlight .gh { color: #333333 } /* Generic.Heading */
.highlight .gi { color: #000000; background-color: #ddffdd } /* Generic.Inserted */
.highlight .go { color: #888888 } /* Generic.Output */
.highlight .gp { color: #555555 } /* Generic.Prompt */
.highlight .gs { font-weight: bold } /* Generic.Strong */
.highlight .gu { color: #666666 } /* Generic.Subheading */
.highlight .gt { color: #aa0000 } /* Generic.Traceback */
.highlight .kc { color: #008800; font-weight: bold } /* Keyword.Constant */
.highlight .kd { color: #008800; font-weight: bold } /* Keyword.Declaration */
.highlight .kn { color: #008800; font-weight: bold } /* Keyword.Namespace */
.highlight .kp { color: #008800 } /* Keyword.Pseudo */
.highlight .kr { color: #008800; font-weight: bold } /* Keyword.Reserved */
.highlight .kt { color: #888888; font-weight: bold } /* Keyword.Type */
.highlight .m { color: #0000DD; font-weight: bold } /* Literal.Number */
.highlight .s { color: #dd2200; background-color: #fff0f0 } /* Literal.String */
.highlight .na { color: #336699 } /* Name.Attribute */
.highlight .nb { color: #003388 } /* Name.Builtin */
.highlight .nc { color: #bb0066; font-weight: bold } /* Name.Class */
.highlight .no { color: #003366; font-weight: bold } /* Name.Constant */
.highlight .nd { color: #555555 } /* Name.Decorator */
.highlight .ne { color: #bb0066; font-weight: bold } /* Name.Exception */
.highlight .nf { color: #0066bb; font-weight: bold } /* Name.Function */
.highlight .nl { color: #336699; font-style: italic } /* Name.Label */
.highlight .nn { color: #bb0066; font-weight: bold } /* Name.Namespace */
.highlight .py { color: #336699; font-weight: bold } /* Name.Property */
.highlight .nt { color: #bb0066; font-weight: bold } /* Name.Tag */
.highlight .nv { color: #336699 } /* Name.Variable */
.highlight .ow { color: #008800 } /* Operator.Word */
.highlight .w { color: #bbbbbb } /* Text.Whitespace */
.highlight .mb { color: #0000DD; font-weight: bold } /* Literal.Number.Bin */
.highlight .mf { color: #0000DD; font-weight: bold } /* Literal.Number.Float */
.highlight .mh { color: #0000DD; font-weight: bold } /* Literal.Number.Hex */
.highlight .mi { color: #0000DD; font-weight: bold } /* Literal.Number.Integer */
.highlight .mo { color: #0000DD; font-weight: bold } /* Literal.Number.Oct */
.highlight .sa { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Affix */
.highlight .sb { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Backtick */
.highlight .sc { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Char */
.highlight .dl { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Delimiter */
.highlight .sd { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Doc */
.highlight .s2 { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Double */
.highlight .se { color: #0044dd; background-color: #fff0f0 } /* Literal.String.Escape */
.highlight .sh { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Heredoc */
.highlight .si { color: #3333bb; background-color: #fff0f0 } /* Literal.String.Interpol */
.highlight .sx { color: #22bb22; background-color: #f0fff0 } /* Literal.String.Other */
.highlight .sr { color: #008800; background-color: #fff0ff } /* Literal.String.Regex */
.highlight .s1 { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Single */
.highlight .ss { color: #aa6600; background-color: #fff0f0 } /* Literal.String.Symbol */
.highlight .bp { color: #003388 } /* Name.Builtin.Pseudo */
.highlight .fm { color: #0066bb; font-weight: bold } /* Name.Function.Magic */
.highlight .vc { color: #336699 } /* Name.Variable.Class */
.highlight .vg { color: #dd7700 } /* Name.Variable.Global */
.highlight .vi { color: #3333bb } /* Name.Variable.Instance */
.highlight .vm { color: #336699 } /* Name.Variable.Magic */
.highlight .il { color: #0000DD; font-weight: bold } /* Literal.Number.Integer.Long */
}
---

- name: Perform a Neutron DB online upgrade
  command: |
    /openstack/venvs/neutron-{{ os_ver }}/bin/neutron-db-manage
                      --config-file /etc/neutron/neutron.conf
                      --config-file /etc/neutron/plugins/ml2/ml2_conf.ini
                      upgrade --expand
  become: "yes"
  become_user: "neutron"

- name: Perform a Neutron DB offline upgrade
  command: |
    /openstack/venvs/neutron-{{ os_ver }}/bin/neutron-db-manage
                      --config-file /etc/neutron/neutron.conf
                      --config-file /etc/neutron/plugins/ml2/ml2_conf.ini
                      upgrade --contract
  become: "yes"
  become_user: "neutron"

- name: SFC DB upgrade
  command: |
    /openstack/venvs/neutron-{{ os_ver }}/bin/neutron-db-manage
                      --subproject networking-sfc
                      upgrade head
  become: "yes"
  become_user: "neutron"
  when: odl_sfc == "Enable"
# Copyright (c) 2017 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 array
import io
import logging
import operator
import os
import re
import select
import socket
import time
from collections import OrderedDict, namedtuple
from contextlib import contextmanager
from itertools import repeat, chain
from multiprocessing import Queue

import six
from six.moves import cStringIO
from six.moves import zip, StringIO

from yardstick.benchmark.scenarios.networking.vnf_generic import find_relative_file
from yardstick.common import utils
from yardstick.common.utils import SocketTopology, join_non_strings, try_int
from yardstick.network_services.helpers.iniparser import ConfigParser
from yardstick.network_services.vnf_generic.vnf.sample_vnf import ClientResourceHelper
from yardstick.network_services.vnf_generic.vnf.sample_vnf import DpdkVnfSetupEnvHelper

PROX_PORT = 8474

SECTION_NAME = 0
SECTION_CONTENTS = 1

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

TEN_GIGABIT = 1e10
BITS_PER_BYTE = 8
RETRY_SECONDS = 60
RETRY_INTERVAL = 1

CONFIGURATION_OPTIONS = (
    # dict key           section     key               default value
    ('pktSizes', 'general', 'pkt_sizes', '64,128,256,512,1024,1280,1518'),
    ('testDuration', 'general', 'test_duration', 5.0),
    ('testPrecision', 'general', 'test_precision', 1.0),
    ('tests', 'general', 'tests', None),
    ('toleratedLoss', 'general', 'tolerated_loss', 0.0),

    ('logFile', 'logging', 'file', 'dats.log'),
    ('logDateFormat', 'logging', 'datefmt', None),
    ('logLevel', 'logging', 'level', 'INFO'),
    ('logOverwrite', 'logging', 'overwrite', 1),

    ('testerIp', 'tester', 'ip', None),
    ('testerUser', 'tester', 'user', 'root'),
    ('testerDpdkDir', 'tester', 'rte_sdk', '/root/dpdk'),
    ('testerDpdkTgt', 'tester', 'rte_target', 'x86_64-native-linuxapp-gcc'),
    ('testerProxDir', 'tester', 'prox_dir', '/root/prox'),
    ('testerSocketId', 'tester', 'socket_id', 0),

    ('sutIp', 'sut', 'ip', None),
    ('sutUser', 'sut', 'user', 'root'),
    ('sutDpdkDir', 'sut', 'rte_sdk', '/root/dpdk'),
    ('sutDpdkTgt', 'sut', 'rte_target', 'x86_64-native-linuxapp-gcc'),
    ('sutProxDir', 'sut', 'prox_dir', '/root/prox'),
    ('sutSocketId', 'sut', 'socket_id', 0),
)


class CoreSocketTuple(namedtuple('CoreTuple', 'core_id, socket_id, hyperthread')):
    CORE_RE = re.compile(r"core\s+(\d+)(?:s(\d+))?(h)?$")

    def __new__(cls, *args):
        try:
            matches = cls.CORE_RE.search(str(args[0]))
            if matches:
                args = matches.groups()

            return super(CoreSocketTuple, cls).__new__(cls, int(args[0]), try_int(args[1], 0),
                                                       'h' if args[2] else '')

        except (AttributeError, TypeError, IndexError, ValueError):
            raise ValueError('Invalid core spec {}'.format(args))

    def is_hyperthread(self):
        return self.hyperthread == 'h'

    @property
    def index(self):
        return int(self.is_hyperthread())

    def find_in_topology(self, cpu_topology):
        try:
            socket_core_match = cpu_topology[self.socket_id][self.core_id]
            sorted_match = sorted(socket_core_match.values())
            return sorted_match[self.index][0]
        except (KeyError, IndexError):
            template = "Core {}{} on socket {} does not exist"
            raise ValueError(template.format(self.core_id, self.hyperthread, self.socket_id))


class TotStatsTuple(namedtuple('TotStats', 'rx,tx,tsc,hz')):
    def __new__(cls, *args):
        try:
            assert args[0] is not str(args[0])
            args = tuple(args[0])
        except (AssertionError, IndexError, TypeError):
            pass

        return super(TotStatsTuple, cls).__new__(cls, *args)


class ProxTestDataTuple(namedtuple('ProxTestDataTuple', 'tolerated,tsc_hz,delta_rx,'
                                                        'delta_tx,delta_tsc,'
                                                        'latency,rx_total,tx_total,pps')):
    @property
    def pkt_loss(self):
        try:
            return 1e2 * self.drop_total / float(self.tx_total)
        except ZeroDivisionError:
            return 100.0

    @property
    def mpps(self):
        # calculate the effective throughput in Mpps
        return float(self.delta_tx) * self.tsc_hz / self.delta_tsc / 1e6

    @property
    def can_be_lost(self):
        return int(self.tx_total * self.tolerated / 1e2)

    @property
    def drop_total(self):
        return self.tx_total - self.rx_total

    @property
    def success(self):
        return self.drop_total <= self.can_be_lost

    def get_samples(self, pkt_size, pkt_loss=None, port_samples=None):
        if pkt_loss is None:
            pkt_loss = self.pkt_loss

        if port_samples is None:
            port_samples = {}

        latency_keys = [
            "LatencyMin",
            "LatencyMax",
            "LatencyAvg",
        ]

        samples = {
            "Throughput": self.mpps,
            "DropPackets": pkt_loss,
            "CurrentDropPackets": pkt_loss,
            "TxThroughput": self.pps / 1e6,
            "RxThroughput": self.mpps,
            "PktSize": pkt_size,
        }
        if port_samples:
            samples.update(port_samples)

        samples.update((key, value) for key, value in zip(latency_keys, self.latency))
        return samples

    def log_data(self, logger=None):
        if logger is None:
            logger = LOG

        template = "RX: %d; TX: %d; dropped: %d (tolerated: %d)"
        logger.debug(template, self.rx_total, self.tx_total, self.drop_total, self.can_be_lost)
        logger.debug("Mpps configured: %f; Mpps effective %f", self.pps / 1e6, self.mpps)


class PacketDump(object):
    @staticmethod
    def assert_func(func, value1, value2, template=None):
        assert func(value1, value2), template.format(value1, value2)

    def __init__(self, port_id, data_len, payload):
        template = "Packet dump has specified length {}, but payload is {} bytes long"
        self.assert_func(operator.eq, data_len, len(payload), template)
        self._port_id = port_id
        self._data_len = data_len
        self._payload = payload

    @property
    def port_id(self):
        """Get the port id of the packet dump"""
        return self._port_id

    @property
    def data_len(self):
        """Get the length of the data received"""
        return self._data_len

    def __str__(self):
        return '<PacketDump port: {} payload: {}>'.format(self._port_id, self._payload)

    def payload(self, start=None, end=None):
        """Get part of the payload as a list of ordinals.

        Returns a list of byte values, matching the contents of the packet dump.
        Optional start and end parameters can be specified to retrieve only a
        part of the packet contents.

        The number of elements in the list is equal to end - start + 1, so end
        is the offset of the last character.

        Args:
            start (pos. int): the starting offset in the payload. If it is not
                specified or None, offset 0 is assumed.
            end (pos. int): the ending offset of the payload. If it is not
                specified or None, the contents until the end of the packet are
                returned.

        Returns:
            [int, int, ...]. Each int represents the ordinal value of a byte in
            the packet payload.
        """
        if start is None:
            start = 0

        if end is None:
            end = self.data_len - 1

        # Bounds checking on offsets
        template = "Start offset must be non-negative"
        self.assert_func(operator.ge, start, 0, template)

        template = "End offset must be less than {1}"
        self.assert_func(operator.lt, end, self.data_len, template)

        # Adjust for splice operation: end offset must be 1 more than the offset
        # of the last desired character.
        end += 1

        return self._payload[start:end]


class ProxSocketHelper(object):

    def __init__(self, sock=None):
        """ creates new prox instance """
        super(ProxSocketHelper, self).__init__()

        if sock is None:
            sock = socket.socket()

        self._sock = sock
        self._pkt_dumps = []
        self.master_stats = None

    def connect(self, ip, port):
        """Connect to the prox instance on the remote system"""
        self._sock.connect((ip, port))

    def get_socket(self):
        """ get the socket connected to the remote instance """
        return self._sock

    def _parse_socket_data(self, decoded_data, pkt_dump_only):
        def get_newline_index():
            return decoded_data.find('\n', index)

        ret_str = ''
        index = 0
        for newline_index in iter(get_newline_index, -1):
            ret_str = decoded_data[index:newline_index]

            try:
                mode, port_id, data_len = ret_str.split(',', 2)
            except ValueError:
                mode, port_id, data_len = None, None, None

            if mode != 'pktdump':
                # Regular 1-line message. Stop reading from the socket.
                LOG.debug("Regular response read")
                return ret_str

            LOG.debug("Packet dump header read: [%s]", ret_str)

            # The line is a packet dump header. Parse it, read the
            # packet payload, store the dump for later retrieval.
            # Skip over the packet dump and continue processing: a
            # 1-line response may follow the packet dump.

            data_len = int(data_len)
            data_start = newline_index + 1  # + 1 to skip over \n
            data_end = data_start + data_len
            sub_data = decoded_data[data_start:data_end]
            pkt_payload = array.array('B', (ord(v) for v in sub_data))
            pkt_dump = PacketDump(int(port_id), data_len, pkt_payload)
            self._pkt_dumps.append(pkt_dump)

            if pkt_dump_only:
                # Return boolean instead of string to signal
                # successful reception of the packet dump.
                LOG.debug("Packet dump stored, returning")
                return True

            index = data_end + 1

        return ret_str

    def get_data(self, pkt_dump_only=False, timeout=1):
        """ read data from the socket """

        # This method behaves slightly differently depending on whether it is
        # called to read the response to a command (pkt_dump_only = 0) or if
        # it is called specifically to read a packet dump (pkt_dump_only = 1).
        #
        # Packet dumps look like:
        #   pktdump,<port_id>,<data_len>\n
        #   <packet contents as byte array>\n
        # This means the total packet dump message consists of 2 lines instead
        # of 1 line.
        #
        # - Response for a command (pkt_dump_only = 0):
        #   1) Read response from the socket until \n (end of message)
        #   2a) If the response is a packet dump header (starts with "pktdump,"):
        #     - Read the packet payload and store the packet dump for later
        #       retrieval.
        #     - Reset the state and restart from 1). Eventually state 2b) will
        #       be reached and the function will return.
        #   2b) If the response is not a packet dump:
        #     - Return the received message as a string
        #
        # - Explicit request to read a packet dump (pkt_dump_only = 1):
        #   - Read the dump header and payload
        #   - Store the packet dump for later retrieval
        #   - Return True to signify a packet dump was successfully read

        def is_ready():
            # recv() is blocking, so avoid calling it when no data is waiting.
            ready = select.select([self._sock], [], [], timeout)
            return bool(ready[0])

        status = False
        ret_str = ""
        for status in iter(is_ready, False):
            decoded_data = self._sock.recv(256).decode('utf-8')
            ret_str = self._parse_socket_data(decoded_data, pkt_dump_only)

        LOG.debug("Received data from socket: [%s]", ret_str)
        return ret_str if status else ''

    def put_command(self, to_send):
        """ send data to the remote instance """
        LOG.debug("Sending data to socket: [%s]", to_send.rstrip('\n'))
        try:
            # NOTE: sendall will block, we need a timeout
            self._sock.sendall(to_send.encode('utf-8'))
        except:  # pylint: disable=bare-except
            pass

    def get_packet_dump(self):
        """ get the next packet dump """
        if self._pkt_dumps:
            return self._pkt_dumps.pop(0)
        return None

    def stop_all_reset(self):
        """ stop the remote instance and reset stats """
        LOG.debug("Stop all and reset stats")
        self.stop_all()
        self.reset_stats()

    def stop_all(self):
        """ stop all cores on the remote instance """
        LOG.debug("Stop all")
        self.put_command("stop all\n")
        time.sleep(3)

    def stop(self, cores, task=''):
        """ stop specific cores on the remote instance """
        LOG.debug("Stopping cores %s", cores)
        self.put_command("stop {} {}\n".format(join_non_strings(',', cores), task))
        time.sleep(3)

    def start_all(self):
        """ start all cores on the remote instance """
        LOG.debug("Start all")
        self.put_command("start all\n")

    def start(self, cores):
        """ start specific cores on the remote instance """
        LOG.debug("Starting cores %s", cores)
        self.put_command("start {}\n".format(join_non_strings(',', cores)))
        time.sleep(3)

    def reset_stats(self):
        """ reset the statistics on the remote instance """
        LOG.debug("Reset stats")
        self.put_command("reset stats\n")
        time.sleep(1)

    def _run_template_over_cores(self, template, cores, *args):
        for core in cores:
            self.put_command(template.format(core, *args))

    def set_pkt_size(self, cores, pkt_size):
        """ set the packet size to generate on the remote instance """
        LOG.debug("Set packet size for core(s) %s to %d", cores, pkt_size)
        pkt_size -= 4
        self._run_template_over_cores("pkt_size {} 0 {}\n", cores, pkt_size)
        time.sleep(1)

    def set_value(self, cores, offset, value, length):
        """ set value on the remote instance """
        msg = "Set value for core(s) %s to '%s' (length %d), offset %d"
        LOG.debug(msg, cores, value, length, offset)
        template = "set value {} 0 {} {} {}\n"
        self._run_template_over_cores(template, cores, offset, value, length)

    def reset_values(self, cores):
        """ reset values on the remote instance """
        LOG.debug("Set value for core(s) %s", cores)
        self._run_template_over_cores("reset values {} 0\n", cores)

    def set_speed(self, cores, speed, tasks=None):
        """ set speed on the remote instance """
        if tasks is None:
            tasks = [0] * len(cores)
        elif len(tasks) != len(cores):
            LOG.error("set_speed: cores and tasks must have the same len")
        LOG.debug("Set speed for core(s)/tasks(s) %s to %g", list(zip(cores, tasks)), speed)
        for (core, task) in list(zip(cores, tasks)):
            self.put_command("speed {} {} {}\n".format(core, task, speed))

    def slope_speed(self, cores_speed, duration, n_steps=0):
        """will start to increase speed from 0 to N where N is taken from
        a['speed'] for each a in cores_speed"""
        # by default, each step will take 0.5 sec
        if n_steps == 0:
            n_steps = duration * 2

        private_core_data = []
        step_duration = float(duration) / n_steps
        for core_data in cores_speed:
            target = float(core_data['speed'])
            private_core_data.append({
                'cores': core_data['cores'],
                'zero': 0,
                'delta': target / n_steps,
                'current': 0,
                'speed': target,
            })

        deltas_keys_iter = repeat(('current', 'delta'), n_steps - 1)
        for key1, key2 in chain(deltas_keys_iter, [('zero', 'speed')]):
            time.sleep(step_duration)
            for core_data in private_core_data:
                core_data['current'] = core_data[key1] + core_data[key2]
                self.set_speed(core_data['cores'], core_data['current'])

    def set_pps(self, cores, pps, pkt_size):
        """ set packets per second for specific cores on the remote instance """
        msg = "Set packets per sec for core(s) %s to %g%% of line rate (packet size: %d)"
        LOG.debug(msg, cores, pps, pkt_size)

        # speed in percent of line-rate
        speed = float(pps) * (pkt_size + 20) / TEN_GIGABIT / BITS_PER_BYTE
        self._run_template_over_cores("speed {} 0 {}\n", cores, speed)

    def lat_stats(self, cores, task=0):
        """Get the latency statistics from the remote system"""
        # 1-based index, if max core is 4, then 0, 1, 2, 3, 4  len = 5
        lat_min = {}
        lat_max = {}
        lat_avg = {}
        for core in cores:
            self.put_command("lat stats {} {} \n".format(core, task))
            ret = self.get_data()

            try:
                lat_min[core], lat_max[core], lat_avg[core] = \
                    tuple(int(n) for n in ret.split(",")[:3])

            except (AttributeError, ValueError, TypeError):
                pass

        return lat_min, lat_max, lat_avg

    def get_all_tot_stats(self):
        self.put_command("tot stats\n")
        all_stats_str = self.get_data().split(",")
        if len(all_stats_str) != 4:
            all_stats = [0] * 4
            return all_stats
        all_stats = TotStatsTuple(int(v) for v in all_stats_str)
        self.master_stats = all_stats
        return all_stats

    def hz(self):
        return self.get_all_tot_stats()[3]

    def core_stats(self, cores, task=0):
        """Get the receive statistics from the remote system"""
        rx = tx = drop = tsc = 0
        for core in cores:
            self.put_command("core stats {} {}\n".format(core, task))
            ret = self.get_data().split(",")
            rx += int(ret[0])
            tx += int(ret[1])
            drop += int(ret[2])
            tsc = int(ret[3])
        return rx, tx, drop, tsc

    def port_stats(self, ports):
        """get counter values from a specific port"""
        tot_result = [0] * 12
        for port in ports:
            self.put_command("port_stats {}\n".format(port))
            ret = [try_int(s, 0) for s in self.get_data().split(",")]
            tot_result = [sum(x) for x in zip(tot_result, ret)]
        return tot_result

    @contextmanager
    def measure_tot_stats(self):
        start = self.get_all_tot_stats()
        container = {'start_tot': start}
        try:
            yield container
        finally:
            container['end_tot'] = end = self.get_all_tot_stats()

        container['delta'] = TotStatsTuple(e - s for s, e in zip(start, end))

    def tot_stats(self):
        """Get the total statistics from the remote system"""
        stats = self.get_all_tot_stats()
        return stats[:3]

    def tot_ierrors(self):
        """Get the total ierrors from the remote system"""
        self.put_command("tot ierrors tot\n")
        recv = self.get_data().split(',')
        tot_ierrors = int(recv[0])
        tsc = int(recv[0])
        return tot_ierrors, tsc

    def set_count(self, count, cores):
        """Set the number of packets to send on the specified core"""
        self._run_template_over_cores("count {} 0 {}\n", cores, count)

    def dump_rx(self, core_id, task_id=0, count=1):
        """Activate dump on rx on the specified core"""
        LOG.debug("Activating dump on RX for core %d, task %d, count %d", core_id, task_id, count)
        self.put_command("dump_rx {} {} {}\n".format(core_id, task_id, count))
        time.sleep(1.5)  # Give PROX time to set up packet dumping

    def quit(self):
        self.stop_all()
        self._quit()
        self.force_quit()

    def _quit(self):
        """ stop all cores on the remote instance """
        LOG.debug("Quit prox")
        self.put_command("quit\n")
        time.sleep(3)

    def force_quit(self):
        """ stop all cores on the remote instance """
        LOG.debug("Force Quit prox")
        self.put_command("quit_force\n")
        time.sleep(3)


_LOCAL_OBJECT = object()


class ProxDpdkVnfSetupEnvHelper(DpdkVnfSetupEnvHelper):
    # the actual app is lowercase
    APP_NAME = 'prox'
    # not used for Prox but added for consistency
    VNF_TYPE = "PROX"

    LUA_PARAMETER_NAME = ""
    LUA_PARAMETER_PEER = {
        "gen": "sut",
        "sut": "gen",
    }

    CONFIG_QUEUE_TIMEOUT = 120

    def __init__(self, vnfd_helper, ssh_helper, scenario_helper):
        self.remote_path = None
        super(ProxDpdkVnfSetupEnvHelper, self).__init__(vnfd_helper, ssh_helper, scenario_helper)
        self.remote_prox_file_name = None
        self._prox_config_data = None
        self.additional_files = {}
        self.config_queue = Queue()
        # allow_exit_without_flush
        self.config_queue.cancel_join_thread()
        self._global_section = None

    @property
    def prox_config_data(self):
        if self._prox_config_data is None:
            # this will block, but it needs too
            self._prox_config_data = self.config_queue.get(True, self.CONFIG_QUEUE_TIMEOUT)
        return self._prox_config_data

    @property
    def global_section(self):
        if self._global_section is None and self.prox_config_data:
            self._global_section = self.find_section("global")
        return self._global_section

    def find_section(self, name, default=_LOCAL_OBJECT):
        result = next((value for key, value in self.prox_config_data if key == name), default)
        if result is _LOCAL_OBJECT:
            raise KeyError('{} not found in Prox config'.format(name))
        return result

    def find_in_section(self, section_name, section_key, default=_LOCAL_OBJECT):
        section = self.find_section(section_name, [])
        result = next((value for key, value in section if key == section_key), default)
        if result is _LOCAL_OBJECT:
            template = '{} not found in {} section of Prox config'
            raise KeyError(template.format(section_key, section_name))
        return result

    def copy_to_target(self, config_file_path, prox_file):
        remote_path = os.path.join("/tmp", prox_file)
        self.ssh_helper.put(config_file_path, remote_path)
        return remote_path

    @staticmethod
    def _get_tx_port(section, sections):
        iface_port = [-1]
        for item in sections[section]:
            if item[0] == "tx port":
                iface_port = re.findall(r'\d+', item[1])
                # do we want the last one?
                #   if yes, then can we reverse?
        return int(iface_port[0])

    @staticmethod
    def _replace_quoted_with_value(quoted, value, count=1):
        new_string = re.sub('"[^"]*"', '"{}"'.format(value), quoted, count)
        return new_string

    def _insert_additional_file(self, value):
        file_str = value.split('"')
        base_name = os.path.basename(file_str[1])
        file_str[1] = self.additional_files[base_name]
        return '"'.join(file_str)

    def generate_prox_config_file(self, config_path):
        sections = []
        prox_config = ConfigParser(config_path, sections)
        prox_config.parse()

        # Ensure MAC is set "hardware"
        all_ports = self.vnfd_helper.port_pairs.all_ports
        # use dpdk port number
        for port_name in all_ports:
            port_num = self.vnfd_helper.port_num(port_name)
            port_section_name = "port {}".format(port_num)
            for section_name, section in sections:
                if port_section_name != section_name:
                    continue

                for section_data in section:
                    if section_data[0] == "mac":
                        section_data[1] = "hardware"

        # search for dst mac
        for _, section in sections:
            for section_data in section:
                item_key, item_val = section_data
                if item_val.startswith("@@dst_mac"):
                    tx_port_iter = re.finditer(r'\d+', item_val)
                    tx_port_no = int(next(tx_port_iter).group(0))
                    intf = self.vnfd_helper.find_interface_by_port(tx_port_no)
                    mac = intf["virtual-interface"]["dst_mac"]
                    section_data[1] = mac.replace(":", " ", 6)

                if item_key == "dst mac" and item_val.startswith("@@"):
                    tx_port_iter = re.finditer(r'\d+', item_val)
                    tx_port_no = int(next(tx_port_iter).group(0))
                    intf = self.vnfd_helper.find_interface_by_port(tx_port_no)
                    mac = intf["virtual-interface"]["dst_mac"]
                    section_data[1] = mac

        # if addition file specified in prox config
        if not self.additional_files:
            return sections

        for section_name, section in sections:
            for section_data in section:
                try:
                    if section_data[0].startswith("dofile"):
                        section_data[0] = self._insert_additional_file(section_data[0])

                    if section_data[1].startswith("dofile"):
                        section_data[1] = self._insert_additional_file(section_data[1])
                except:  # pylint: disable=bare-except
                    pass

        return sections

    @staticmethod
    def write_prox_lua(lua_config):
        """
        Write an .ini-format config file for PROX (parameters.lua)
        PROX does not allow a space before/after the =, so we need
        a custom method
        """
        out = []
        for key in lua_config:
            value = '"' + lua_config[key] + '"'
            if key == "__name__":
                continue
            if value is not None and value != '@':
                key = "=".join((key, str(value).replace('\n', '\n\t')))
                out.append(key)
            else:
                key = str(key).replace('\n', '\n\t')
                out.append(key)
        return os.linesep.join(out)

    @staticmethod
    def write_prox_config(prox_config):
        """
        Write an .ini-format config file for PROX
        PROX does not allow a space before/after the =, so we need
        a custom method
        """
        out = []
        for (section_name, section) in prox_config:
            out.append("[{}]".format(section_name))
            for item in section:
                key, value = item
                if key == "__name__":
                    continue
                if value is not None and value != '@':
                    key = "=".join((key, str(value).replace('\n', '\n\t')))
                    out.append(key)
                else:
                    key = str(key).replace('\n', '\n\t')
                    out.append(key)
        return os.linesep.join(out)

    def put_string_to_file(self, s, remote_path):
        file_obj = cStringIO(s)
        self.ssh_helper.put_file_obj(file_obj, remote_path)
        return remote_path

    def generate_prox_lua_file(self):
        p = OrderedDict()
        all_ports = self.vnfd_helper.port_pairs.all_ports
        for port_name in all_ports:
            port_num = self.vnfd_helper.port_num(port_name)
            intf = self.vnfd_helper.find_interface(name=port_name)
            vintf = intf['virtual-interface']
            p["tester_mac{0}".format(port_num)] = vintf["dst_mac"]
            p["src_mac{0}".format(port_num)] = vintf["local_mac"]

        return p

    def upload_prox_lua(self, config_file, lua_data):
        # prox can't handle spaces around ' = ' so use custom method
        out = StringIO(self.write_prox_lua(lua_data))
        out.seek(0)
        remote_path = os.path.join("/tmp", config_file)
        self.ssh_helper.put_file_obj(out, remote_path)

        return remote_path

    def upload_prox_config(self, config_file, prox_config_data):
        # prox can't handle spaces around ' = ' so use custom method
        out = StringIO(self.write_prox_config(prox_config_data))
        out.seek(0)
        remote_path = os.path.join("/tmp", config_file)
        self.ssh_helper.put_file_obj(out, remote_path)

        return remote_path

    def build_config_file(self):
        task_path = self.scenario_helper.task_path
        options = self.scenario_helper.options
        config_path = options['prox_config']
        config_file = os.path.basename(config_path)
        config_path = find_relative_file(config_path, task_path)
        self.additional_files = {}

        try:
            if options['prox_generate_parameter']:
                self.lua = []
                self.lua = self.generate_prox_lua_file()
                if len(self.lua) > 0:
                    self.upload_prox_lua("parameters.lua", self.lua)
        except:  # pylint: disable=bare-except
            pass

        prox_files = options.get('prox_files', [])
        if isinstance(prox_files, six.string_types):
            prox_files = [prox_files]
        for key_prox_file in prox_files:
            base_prox_file = os.path.basename(key_prox_file)
            key_prox_path = find_relative_file(key_prox_file, task_path)
            remote_prox_file = self.copy_to_target(key_prox_path, base_prox_file)
            self.additional_files[base_prox_file] = remote_prox_file

        self._prox_config_data = self.generate_prox_config_file(config_path)
        # copy config to queue so we can read it from traffic_runner process
        self.config_queue.put(self._prox_config_data)
        self.remote_path = self.upload_prox_config(config_file, self._prox_config_data)

    def build_config(self):
        self.build_config_file()

        options = self.scenario_helper.options
        prox_args = options['prox_args']
        tool_path = self.ssh_helper.join_bin_path(self.APP_NAME)

        self.pipeline_kwargs = {
            'tool_path': tool_path,
            'tool_dir': os.path.dirname(tool_path),
            'cfg_file': self.remote_path,
            'args': ' '.join(' '.join([str(k), str(v) if v else ''])
                             for k, v in prox_args.items())
        }

        cmd_template = ("sudo bash -c 'cd {tool_dir}; {tool_path} -o cli "
                        "{args} -f {cfg_file} '")
        return cmd_template.format(**self.pipeline_kwargs)


# this might be bad, sometimes we want regular ResourceHelper methods, like collect_kpi
class ProxResourceHelper(ClientResourceHelper):

    RESOURCE_WORD = 'prox'

    PROX_MODE = ""

    WAIT_TIME = 3

    @staticmethod
    def find_pci(pci, bound_pci):
        # we have to substring match PCI bus address from the end
        return any(b.endswith(pci) for b in bound_pci)

    def __init__(self, setup_helper):
        super(ProxResourceHelper, self).__init__(setup_helper)
        self.mgmt_interface = self.vnfd_helper.mgmt_interface
        self._user = self.mgmt_interface["user"]
        self._ip = self.mgmt_interface["ip"]

        self.done = False
        self._vpci_to_if_name_map = None
        self.additional_file = {}
        self.remote_prox_file_name = None
        self.lower = None
        self.upper = None
        self.step_delta = 1
        self.step_time = 0.5
        self._test_type = None

    @property
    def sut(self):
        if not self.client:
            self.client = self._connect()
        return self.client

    @property
    def test_type(self):
        if self._test_type is None:
            self._test_type = self.setup_helper.find_in_section('global', 'name', None)
        return self._test_type

    def run_traffic(self, traffic_profile):
        self._queue.cancel_join_thread()
        self.lower = 0.0
        self.upper = 100.0

        traffic_profile.init(self._queue)
        # this frees up the run_traffic loop
        self.client_started.value = 1

        while not self._terminated.value:
            # move it all to traffic_profile
            self._run_traffic_once(traffic_profile)

    def _run_traffic_once(self, traffic_profile):
        traffic_profile.execute_traffic(self)
        if traffic_profile.done:
            self._queue.put({'done': True})
            LOG.debug("tg_prox done")
            self._terminated.value = 1

    # For VNF use ResourceHelper method to collect KPIs directly.
    # for TG leave the superclass ClientResourceHelper collect_kpi_method intact
    def collect_collectd_kpi(self):
        return self._collect_resource_kpi()

    def collect_kpi(self):
        result = super(ProxResourceHelper, self).collect_kpi()
        # add in collectd kpis manually
        if result:
            result['collect_stats'] = self._collect_resource_kpi()
        return result

    def terminate(self):
        # should not be called, use VNF terminate
        raise NotImplementedError()

    def up_post(self):
        return self.sut  # force connection

    def execute(self, cmd, *args, **kwargs):
        func = getattr(self.sut, cmd, None)
        if func:
            return func(*args, **kwargs)

    def _connect(self, client=None):
        """Run and connect to prox on the remote system """
        # De-allocating a large amount of hugepages takes some time. If a new
        # PROX instance is started immediately after killing the previous one,
        # it might not be able to allocate hugepages, because they are still
        # being freed. Hence the -w switch.
        # self.connection.execute("sudo killall -w Prox 2>/dev/null")
        # prox_cmd = "export TERM=xterm; cd "+ self.bin_path +"; ./Prox -t
        # -f ./handle_none-4.cfg"
        # prox_cmd = "export TERM=xterm; export RTE_SDK=" + self._dpdk_dir +
        #  "; " \
        #    + "export RTE_TARGET=" + self._dpdk_target + ";" \
        #    + " cd " + self._prox_dir + "; make HW_DIRECT_STATS=y -j50;
        # sudo " \
        #    + "./build/Prox " + prox_args
        # log.debug("Starting PROX with command [%s]", prox_cmd)
        # thread.start_new_thread(self.ssh_check_quit, (self, self._user,
        # self._ip, prox_cmd))
        if client is None:
            client = ProxSocketHelper()

        # try connecting to Prox for 60s
        for _ in range(RETRY_SECONDS):
            time.sleep(RETRY_INTERVAL)
            try:
                client.connect(self._ip, PROX_PORT)
            except (socket.gaierror, socket.error):
                continue
            else:
                return client

        msg = "Failed to connect to prox, please check if system {} accepts connections on port {}"
        raise Exception(msg.format(self._ip, PROX_PORT))


class ProxDataHelper(object):

    def __init__(self, vnfd_helper, sut, pkt_size, value, tolerated_loss):
        super(ProxDataHelper, self).__init__()
        self.vnfd_helper = vnfd_helper
        self.sut = sut
        self.pkt_size = pkt_size
        self.value = value
        self.tolerated_loss = tolerated_loss
        self.port_count = len(self.vnfd_helper.port_pairs.all_ports)
        self.tsc_hz = None
        self.measured_stats = None
        self.latency = None
        self._totals_and_pps = None
        self.result_tuple = None

    @property
    def totals_and_pps(self):
        if self._totals_and_pps is None:
            rx_total, tx_total = self.sut.port_stats(range(self.port_count))[6:8]
            pps = self.value / 100.0 * self.line_rate_to_pps()
            self._totals_and_pps = rx_total, tx_total, pps
        return self._totals_and_pps

    @property
    def rx_total(self):
        return self.totals_and_pps[0]

    @property
    def tx_total(self):
        return self.totals_and_pps[1]

    @property
    def pps(self):
        return self.totals_and_pps[2]

    @property
    def samples(self):
        samples = {}
        for port_name, port_num in self.vnfd_helper.ports_iter():
            port_rx_total, port_tx_total = self.sut.port_stats([port_num])[6:8]
            samples[port_name] = {
                "in_packets": port_rx_total,
                "out_packets": port_tx_total,
            }
        return samples

    def __enter__(self):
        self.check_interface_count()
        return self

    def __exit__(self, exc_type, exc_val, exc_tb):
        self.make_tuple()

    def make_tuple(self):
        if self.result_tuple:
            return

        self.result_tuple = ProxTestDataTuple(
            self.tolerated_loss,
            self.tsc_hz,
            self.measured_stats['delta'].rx,
            self.measured_stats['delta'].tx,
            self.measured_stats['delta'].tsc,
            self.latency,
            self.rx_total,
            self.tx_total,
            self.pps,
        )
        self.result_tuple.log_data()

    @contextmanager
    def measure_tot_stats(self):
        with self.sut.measure_tot_stats() as self.measured_stats:
            yield

    def check_interface_count(self):
        # do this assert in init?  unless we expect interface count to
        # change from one run to another run...
        assert self.port_count in {1, 2, 4}, \
            "Invalid number of ports: 1, 2 or 4 ports only supported at this time"

    def capture_tsc_hz(self):
        self.tsc_hz = float(self.sut.hz())

    def line_rate_to_pps(self):
        # NOTE: to fix, don't hardcode 10Gb/s
        return self.port_count * TEN_GIGABIT / BITS_PER_BYTE / (self.pkt_size + 20)


class ProxProfileHelper(object):

    __prox_profile_type__ = "Generic"

    PROX_CORE_GEN_MODE = "gen"
    PROX_CORE_LAT_MODE = "lat"

    @classmethod
    def get_cls(cls, helper_type):
        """Return class of specified type."""
        if not helper_type:
            return ProxProfileHelper

        for profile_helper_class in utils.itersubclasses(cls):
            if helper_type == profile_helper_class.__prox_profile_type__:
                return profile_helper_class

        return ProxProfileHelper

    @classmethod
    def make_profile_helper(cls, resource_helper):
        return cls.get_cls(resource_helper.test_type)(resource_helper)

    def __init__(self, resource_helper):
        super(ProxProfileHelper, self).__init__()
        self.resource_helper = resource_helper
        self._cpu_topology = None
        self._test_cores = None
        self._latency_cores = None

    @property
    def cpu_topology(self):
        if not self._cpu_topology:
            stdout = io.BytesIO()
            self.ssh_helper.get_file_obj("/proc/cpuinfo", stdout)
            self._cpu_topology = SocketTopology.parse_cpuinfo(stdout.getvalue().decode('utf-8'))
        return self._cpu_topology

    @property
    def test_cores(self):
        if not self._test_cores:
            self._test_cores = self.get_cores(self.PROX_CORE_GEN_MODE)
        return self._test_cores

    @property
    def latency_cores(self):
        if not self._latency_cores:
            self._latency_cores = self.get_cores(self.PROX_CORE_LAT_MODE)
        return self._latency_cores

    @contextmanager
    def traffic_context(self, pkt_size, value):
        self.sut.stop_all()
        self.sut.reset_stats()
        try:
            self.sut.set_pkt_size(self.test_cores, pkt_size)
            self.sut.set_speed(self.test_cores, value)
            self.sut.start_all()
            yield
        finally:
            self.sut.stop_all()

    def get_cores(self, mode):
        cores = []

        for section_name, section in self.setup_helper.prox_config_data:
            if not section_name.startswith("core"):
                continue

            for key, value in section:
                if key == "mode" and value == mode:
                    core_tuple = CoreSocketTuple(section_name)
                    core = core_tuple.find_in_topology(self.cpu_topology)
                    cores.append(core)

        return cores

    def run_test(self, pkt_size, duration, value, tolerated_loss=0.0):
        data_helper = ProxDataHelper(self.vnfd_helper, self.sut, pkt_size, value, tolerated_loss)

        with data_helper, self.traffic_context(pkt_size, value):
            with data_helper.measure_tot_stats():
                time.sleep(duration)
                # Getting statistics to calculate PPS at right speed....
                data_helper.capture_tsc_hz()
                data_helper.latency = self.get_latency()

        return data_helper.result_tuple, data_helper.samples

    def get_latency(self):
        """
        :return: return lat_min, lat_max, lat_avg
        :rtype: list
        """
        if self._latency_cores:
            return self.sut.lat_stats(self._latency_cores)
        return []

    def terminate(self):
        pass

    def __getattr__(self, item):
        return getattr(self.resource_helper, item)


class ProxMplsProfileHelper(ProxProfileHelper):

    __prox_profile_type__ = "MPLS tag/untag"

    def __init__(self, resource_helper):
        super(ProxMplsProfileHelper, self).__init__(resource_helper)
        self._cores_tuple = None

    @property
    def mpls_cores(self):
        if not self._cores_tuple:
            self._cores_tuple = self.get_cores_mpls()
        return self._cores_tuple

    @property
    def tagged_cores(self):
        return self.mpls_cores[0]

    @property
    def plain_cores(self):
        return self.mpls_cores[1]

    def get_cores_mpls(self):
        cores_tagged = []
        cores_plain = []
        for section_name, section in self.resource_helper.setup_helper.prox_config_data:
            if not section_name.startswith("core"):
                continue

            if all(key != "mode" or value != self.PROX_CORE_GEN_MODE for key, value in section):
                continue

            for item_key, item_value in section:
                if item_key != 'name':
                    continue

                if item_value.startswith("tag"):
                    core_tuple = CoreSocketTuple(section_name)
                    core_tag = core_tuple.find_in_topology(self.cpu_topology)
                    cores_tagged.append(core_tag)

                elif item_value.startswith("udp"):
                    core_tuple = CoreSocketTuple(section_name)
                    core_udp = core_tuple.find_in_topology(self.cpu_topology)
                    cores_plain.append(core_udp)

        return cores_tagged, cores_plain

    @contextmanager
    def traffic_context(self, pkt_size, value):
        self.sut.stop_all()
        self.sut.reset_stats()
        try:
            self.sut.set_pkt_size(self.tagged_cores, pkt_size)
            self.sut.set_pkt_size(self.plain_cores, pkt_size - 4)
            self.sut.set_speed(self.tagged_cores, value)
            ratio = 1.0 * (pkt_size - 4 + 20) / (pkt_size + 20)
            self.sut.set_speed(self.plain_cores, value * ratio)
            self.sut.start_all()
            yield
        finally:
            self.sut.stop_all()


class ProxBngProfileHelper(ProxProfileHelper):

    __prox_profile_type__ = "BNG gen"

    def __init__(self, resource_helper):
        super(ProxBngProfileHelper, self).__init__(resource_helper)
        self._cores_tuple = None

    @property
    def bng_cores(self):
        if not self._cores_tuple:
            self._cores_tuple = self.get_cores_gen_bng_qos()
        return self._cores_tuple

    @property
    def cpe_cores(self):
        return self.bng_cores[0]

    @property
    def inet_cores(self):
        return self.bng_cores[1]

    @property
    def arp_cores(self):
        return self.bng_cores[2]

    @property
    def arp_task_cores(self):
        return self.bng_cores[3]

    @property
    def all_rx_cores(self):
        return self.latency_cores

    def get_cores_gen_bng_qos(self):
        cpe_cores = []
        inet_cores = []
        arp_cores = []
        arp_tasks_core = [0]
        for section_name, section in self.resource_helper.setup_helper.prox_config_data:
            if not section_name.startswith("core"):
                continue

            if all(key != "mode" or value != self.PROX_CORE_GEN_MODE for key, value in section):
                continue

            for item_key, item_value in section:
                if item_key != 'name':
                    continue

                if item_value.startswith("cpe"):
                    core_tuple = CoreSocketTuple(section_name)
                    cpe_core = core_tuple.find_in_topology(self.cpu_topology)
                    cpe_cores.append(cpe_core)

                elif item_value.startswith("inet"):
                    core_tuple = CoreSocketTuple(section_name)
                    inet_core = core_tuple.find_in_topology(self.cpu_topology)
                    inet_cores.append(inet_core)

                elif item_value.startswith("arp"):
                    core_tuple = CoreSocketTuple(section_name)
                    arp_core = core_tuple.find_in_topology(self.cpu_topology)
                    arp_cores.append(arp_core)

                # We check the tasks/core separately
                if item_value.startswith("arp_task"):
                    core_tuple = CoreSocketTuple(section_name)
                    arp_task_core = core_tuple.find_in_topology(self.cpu_topology)
                    arp_tasks_core.append(arp_task_core)

        return cpe_cores, inet_cores, arp_cores, arp_tasks_core

    @contextmanager
    def traffic_context(self, pkt_size, value):
        # Tester is sending packets at the required speed already after
        # setup_test(). Just get the current statistics, sleep the required
        # amount of time and calculate packet loss.
        inet_pkt_size = pkt_size
        cpe_pkt_size = pkt_size - 24
        ratio = 1.0 * (cpe_pkt_size + 20) / (inet_pkt_size + 20)

        curr_up_speed = curr_down_speed = 0
        max_up_speed = max_down_speed = value
        if ratio < 1:
            max_down_speed = value * ratio
        else:
            max_up_speed = value / ratio

        # Initialize cores
        self.sut.stop_all()
        time.sleep(0.5)

        # Flush any packets in the NIC RX buffers, otherwise the stats will be
        # wrong.
        self.sut.start(self.all_rx_cores)
        time.sleep(0.5)
        self.sut.stop(self.all_rx_cores)
        time.sleep(0.5)
        self.sut.reset_stats()

        self.sut.set_pkt_size(self.inet_cores, inet_pkt_size)
        self.sut.set_pkt_size(self.cpe_cores, cpe_pkt_size)

        self.sut.reset_values(self.cpe_cores)
        self.sut.reset_values(self.inet_cores)

        # Set correct IP and UDP lengths in packet headers
        # CPE
        # IP length (byte 24): 26 for MAC(12), EthType(2), QinQ(8), CRC(4)
        self.sut.set_value(self.cpe_cores, 24, cpe_pkt_size - 26, 2)
        # UDP length (byte 46): 46 for MAC(12), EthType(2), QinQ(8), IP(20), CRC(4)
        self.sut.set_value(self.cpe_cores, 46, cpe_pkt_size - 46, 2)

        # INET
        # IP length (byte 20): 22 for MAC(12), EthType(2), MPLS(4), CRC(4)
        self.sut.set_value(self.inet_cores, 20, inet_pkt_size - 22, 2)
        # IP length (byte 48): 50 for MAC(12), EthType(2), MPLS(4), IP(20), GRE(8), CRC(4)
        self.sut.set_value(self.inet_cores, 48, inet_pkt_size - 50, 2)
        # UDP length (byte 70): 70 for MAC(12), EthType(2), MPLS(4), IP(20), GRE(8), IP(20), CRC(4)
        self.sut.set_value(self.inet_cores, 70, inet_pkt_size - 70, 2)

        # Sending ARP to initialize tables - need a few seconds of generation
        # to make sure all CPEs are initialized
        LOG.info("Initializing SUT: sending ARP packets")
        self.sut.set_speed(self.arp_cores, 1, self.arp_task_cores)
        self.sut.set_speed(self.inet_cores, curr_up_speed)
        self.sut.set_speed(self.cpe_cores, curr_down_speed)
        self.sut.start(self.arp_cores)
        time.sleep(4)

        # Ramp up the transmission speed. First go to the common speed, then
        # increase steps for the faster one.
        self.sut.start(self.cpe_cores + self.inet_cores + self.latency_cores)

        LOG.info("Ramping up speed to %s up, %s down", max_up_speed, max_down_speed)

        while (curr_up_speed < max_up_speed) or (curr_down_speed < max_down_speed):
            # The min(..., ...) takes care of 1) floating point rounding errors
            # that could make curr_*_speed to be slightly greater than
            # max_*_speed and 2) max_*_speed not being an exact multiple of
            # self._step_delta.
            if curr_up_speed < max_up_speed:
                curr_up_speed = min(curr_up_speed + self.step_delta, max_up_speed)
            if curr_down_speed < max_down_speed:
                curr_down_speed = min(curr_down_speed + self.step_delta, max_down_speed)

            self.sut.set_speed(self.inet_cores, curr_up_speed)
            self.sut.set_speed(self.cpe_cores, curr_down_speed)
            time.sleep(self.step_time)

        LOG.info("Target speeds reached. Starting real test.")

        yield

        self.sut.stop(self.arp_cores + self.cpe_cores + self.inet_cores)
        LOG.info("Test ended. Flushing NIC buffers")
        self.sut.start(self.all_rx_cores)
        time.sleep(3)
        self.sut.stop(self.all_rx_cores)

    def run_test(self, pkt_size, duration, value, tolerated_loss=0.0):
        data_helper = ProxDataHelper(self.vnfd_helper, self.sut, pkt_size, value, tolerated_loss)

        with data_helper, self.traffic_context(pkt_size, value):
            with data_helper.measure_tot_stats():
                time.sleep(duration)
                # Getting statistics to calculate PPS at right speed....
                data_helper.capture_tsc_hz()
                data_helper.latency = self.get_latency()

        return data_helper.result_tuple, data_helper.samples


class ProxVpeProfileHelper(ProxProfileHelper):

    __prox_profile_type__ = "vPE gen"

    def __init__(self, resource_helper):
        super(ProxVpeProfileHelper, self).__init__(resource_helper)
        self._cores_tuple = None
        self._ports_tuple = None

    @property
    def vpe_cores(self):
        if not self._cores_tuple:
            self._cores_tuple = self.get_cores_gen_vpe()
        return self._cores_tuple

    @property
    def cpe_cores(self):
        return self.vpe_cores[0]

    @property
    def inet_cores(self):
        return self.vpe_cores[1]

    @property
    def all_rx_cores(self):
        return self.latency_cores

    @property
    def vpe_ports(self):
        if not self._ports_tuple:
            self._ports_tuple = self.get_ports_gen_vpe()
        return self._ports_tuple

    @property
    def cpe_ports(self):
        return self.vpe_ports[0]

    @property
    def inet_ports(self):
        return self.vpe_ports[1]

    def get_cores_gen_vpe(self):
        cpe_cores = []
        inet_cores = []
        for section_name, section in self.resource_helper.setup_helper.prox_config_data:
            if not section_name.startswith("core"):
                continue

            if all(key != "mode" or value != self.PROX_CORE_GEN_MODE for key, value in section):
                continue

            for item_key, item_value in section:
                if item_key != 'name':
                    continue

                if item_value.startswith("cpe"):
                    core_tuple = CoreSocketTuple(section_name)
                    core_tag = core_tuple.find_in_topology(self.cpu_topology)
                    cpe_cores.append(core_tag)

                elif item_value.startswith("inet"):
                    core_tuple = CoreSocketTuple(section_name)
                    inet_core = core_tuple.find_in_topology(self.cpu_topology)
                    inet_cores.append(inet_core)

        return cpe_cores, inet_cores

    def get_ports_gen_vpe(self):
        cpe_ports = []
        inet_ports = []

        for section_name, section in self.resource_helper.setup_helper.prox_config_data:
            if not section_name.startswith("port"):
                continue
            tx_port_iter = re.finditer(r'\d+', section_name)
            tx_port_no = int(next(tx_port_iter).group(0))

            for item_key, item_value in section:
                if item_key != 'name':
                    continue

                if item_value.startswith("cpe"):
                    cpe_ports.append(tx_port_no)

                elif item_value.startswith("inet"):
                    inet_ports.append(tx_port_no)

        return cpe_ports, inet_ports

    @contextmanager
    def traffic_context(self, pkt_size, value):
        # Calculate the target upload and download speed. The upload and
        # download packets have different packet sizes, so in order to get
        # equal bandwidth usage, the ratio of the speeds has to match the ratio
        # of the packet sizes.
        cpe_pkt_size = pkt_size
        inet_pkt_size = pkt_size - 4
        ratio = 1.0 * (cpe_pkt_size + 20) / (inet_pkt_size + 20)

        curr_up_speed = curr_down_speed = 0
        max_up_speed = max_down_speed = value
        if ratio < 1:
            max_down_speed = value * ratio
        else:
            max_up_speed = value / ratio

        # Adjust speed when multiple cores per port are used to generate traffic
        if len(self.cpe_ports) != len(self.cpe_cores):
            max_down_speed *= 1.0 * len(self.cpe_ports) / len(self.cpe_cores)
        if len(self.inet_ports) != len(self.inet_cores):
            max_up_speed *= 1.0 * len(self.inet_ports) / len(self.inet_cores)

        # Initialize cores
        self.sut.stop_all()
        time.sleep(2)

        # Flush any packets in the NIC RX buffers, otherwise the stats will be
        # wrong.
        self.sut.start(self.all_rx_cores)
        time.sleep(2)
        self.sut.stop(self.all_rx_cores)
        time.sleep(2)
        self.sut.reset_stats()

        self.sut.set_pkt_size(self.inet_cores, inet_pkt_size)
        self.sut.set_pkt_size(self.cpe_cores, cpe_pkt_size)

        self.sut.reset_values(self.cpe_cores)
        self.sut.reset_values(self.inet_cores)

        # Set correct IP and UDP lengths in packet headers
        # CPE: IP length (byte 24): 26 for MAC(12), EthType(2), QinQ(8), CRC(4)
        self.sut.set_value(self.cpe_cores, 24, cpe_pkt_size - 26, 2)
        # UDP length (byte 46): 46 for MAC(12), EthType(2), QinQ(8), IP(20), CRC(4)
        self.sut.set_value(self.cpe_cores, 46, cpe_pkt_size - 46, 2)

        # INET: IP length (byte 20): 22 for MAC(12), EthType(2), MPLS(4), CRC(4)
        self.sut.set_value(self.inet_cores, 20, inet_pkt_size - 22, 2)
        # UDP length (byte 42): 42 for MAC(12), EthType(2), MPLS(4), IP(20), CRC(4)
        self.sut.set_value(self.inet_cores, 42, inet_pkt_size - 42, 2)

        self.sut.set_speed(self.inet_cores, curr_up_speed)
        self.sut.set_speed(self.cpe_cores, curr_down_speed)

        # Ramp up the transmission speed. First go to the common speed, then
        # increase steps for the faster one.
        self.sut.start(self.cpe_cores + self.inet_cores + self.all_rx_cores)

        LOG.info("Ramping up speed to %s up, %s down", max_up_speed, max_down_speed)

        while (curr_up_speed < max_up_speed) or (curr_down_speed < max_down_speed):
            # The min(..., ...) takes care of 1) floating point rounding errors
            # that could make curr_*_speed to be slightly greater than
            # max_*_speed and 2) max_*_speed not being an exact multiple of
            # self._step_delta.
            if curr_up_speed < max_up_speed:
                curr_up_speed = min(curr_up_speed + self.step_delta, max_up_speed)
            if curr_down_speed < max_down_speed:
                curr_down_speed = min(curr_down_speed + self.step_delta, max_down_speed)

            self.sut.set_speed(self.inet_cores, curr_up_speed)
            self.sut.set_speed(self.cpe_cores, curr_down_speed)
            time.sleep(self.step_time)

        LOG.info("Target speeds reached. Starting real test.")

        yield

        self.sut.stop(self.cpe_cores + self.inet_cores)
        LOG.info("Test ended. Flushing NIC buffers")
        self.sut.start(self.all_rx_cores)
        time.sleep(3)
        self.sut.stop(self.all_rx_cores)

    def run_test(self, pkt_size, duration, value, tolerated_loss=0.0):
        data_helper = ProxDataHelper(self.vnfd_helper, self.sut, pkt_size, value, tolerated_loss)

        with data_helper, self.traffic_context(pkt_size, value):
            with data_helper.measure_tot_stats():
                time.sleep(duration)
                # Getting statistics to calculate PPS at right speed....
                data_helper.capture_tsc_hz()
                data_helper.latency = self.get_latency()

        return data_helper.result_tuple, data_helper.samples


class ProxlwAFTRProfileHelper(ProxProfileHelper):

    __prox_profile_type__ = "lwAFTR gen"

    def __init__(self, resource_helper):
        super(ProxlwAFTRProfileHelper, self).__init__(resource_helper)
        self._cores_tuple = None
        self._ports_tuple = None
        self.step_delta = 5
        self.step_time = 0.5

    @property
    def _lwaftr_cores(self):
        if not self._cores_tuple:
            self._cores_tuple = self._get_cores_gen_lwaftr()
        return self._cores_tuple

    @property
    def tun_cores(self):
        return self._lwaftr_cores[0]

    @property
    def inet_cores(self):
        return self._lwaftr_cores[1]

    @property
    def _lwaftr_ports(self):
        if not self._ports_tuple:
            self._ports_tuple = self._get_ports_gen_lw_aftr()
        return self._ports_tuple

    @property
    def tun_ports(self):
        return self._lwaftr_ports[0]

    @property
    def inet_ports(self):
        return self._lwaftr_ports[1]

    @property
    def all_rx_cores(self):
        return self.latency_cores

    def _get_cores_gen_lwaftr(self):
        tun_cores = []
        inet_cores = []
        for section_name, section in self.resource_helper.setup_helper.prox_config_data:
            if not section_name.startswith("core"):
                continue

            if all(key != "mode" or value != self.PROX_CORE_GEN_MODE for key, value in section):
                continue

            core_tuple = CoreSocketTuple(section_name)
            core_tag = core_tuple.find_in_topology(self.cpu_topology)
            for item_value in (v for k, v in section if k == 'name'):
                if item_value.startswith('tun'):
                    tun_cores.append(core_tag)
                elif item_value.startswith('inet'):
                    inet_cores.append(core_tag)

        return tun_cores, inet_cores

    def _get_ports_gen_lw_aftr(self):
        tun_ports = []
        inet_ports = []

        re_port = re.compile(r'port (\d+)')
        for section_name, section in self.resource_helper.setup_helper.prox_config_data:
            match = re_port.search(section_name)
            if not match:
                continue

            tx_port_no = int(match.group(1))
            for item_value in (v for k, v in section if k == 'name'):
                if item_value.startswith('lwB4'):
                    tun_ports.append(tx_port_no)
                elif item_value.startswith('inet'):
                    inet_ports.append(tx_port_no)

        return tun_ports, inet_ports

    @staticmethod
    def _resize(len1, len2):
        if len1 == len2:
            return 1.0
        return 1.0 * len1 / len2

    @contextmanager
    def traffic_context(self, pkt_size, value):
        # Tester is sending packets at the required speed already after
        # setup_test(). Just get the current statistics, sleep the required
        # amount of time and calculate packet loss.
        tun_pkt_size = pkt_size
        inet_pkt_size = pkt_size - 40
        ratio = 1.0 * (tun_pkt_size + 20) / (inet_pkt_size + 20)

        curr_up_speed = curr_down_speed = 0
        max_up_speed = max_down_speed = value

        max_up_speed = value / ratio

        # Adjust speed when multiple cores per port are used to generate traffic
        if len(self.tun_ports) != len(self.tun_cores):
            max_down_speed *= self._resize(len(self.tun_ports), len(self.tun_cores))
        if len(self.inet_ports) != len(self.inet_cores):
            max_up_speed *= self._resize(len(self.inet_ports), len(self.inet_cores))

        # Initialize cores
        self.sut.stop_all()
        time.sleep(0.5)

        # Flush any packets in the NIC RX buffers, otherwise the stats will be
        # wrong.
        self.sut.start(self.all_rx_cores)
        time.sleep(0.5)
        self.sut.stop(self.all_rx_cores)
        time.sleep(0.5)
        self.sut.reset_stats()

        self.sut.set_pkt_size(self.inet_cores, inet_pkt_size)
        self.sut.set_pkt_size(self.tun_cores, tun_pkt_size)

        self.sut.reset_values(self.tun_cores)
        self.sut.reset_values(self.inet_cores)

        # Set correct IP and UDP lengths in packet headers
        # tun
        # IPv6 length (byte 18): 58 for MAC(12), EthType(2), IPv6(40) , CRC(4)
        self.sut.set_value(self.tun_cores, 18, tun_pkt_size - 58, 2)
        # IP length (byte 56): 58 for MAC(12), EthType(2), CRC(4)
        self.sut.set_value(self.tun_cores, 56, tun_pkt_size - 58, 2)
        # UDP length (byte 78): 78 for MAC(12), EthType(2), IP(20), UDP(8), CRC(4)
        self.sut.set_value(self.tun_cores, 78, tun_pkt_size - 78, 2)

        # INET
        # IP length (byte 20): 22 for MAC(12), EthType(2), CRC(4)
        self.sut.set_value(self.inet_cores, 16, inet_pkt_size - 18, 2)
        # UDP length (byte 42): 42 for MAC(12), EthType(2), IP(20), UPD(8), CRC(4)
        self.sut.set_value(self.inet_cores, 38, inet_pkt_size - 38, 2)

        LOG.info("Initializing SUT: sending lwAFTR packets")
        self.sut.set_speed(self.inet_cores, curr_up_speed)
        self.sut.set_speed(self.tun_cores, curr_down_speed)
        time.sleep(4)

        # Ramp up the transmission speed. First go to the common speed, then
        # increase steps for the faster one.
        self.sut.start(self.tun_cores + self.inet_cores + self.latency_cores)

        LOG.info("Ramping up speed to %s up, %s down", max_up_speed, max_down_speed)

        while (curr_up_speed < max_up_speed) or (curr_down_speed < max_down_speed):
            # The min(..., ...) takes care of 1) floating point rounding errors
            # that could make curr_*_speed to be slightly greater than
            # max_*_speed and 2) max_*_speed not being an exact multiple of
            # self._step_delta.
            if curr_up_speed < max_up_speed:
                curr_up_speed = min(curr_up_speed + self.step_delta, max_up_speed)
            if curr_down_speed < max_down_speed:
                curr_down_speed = min(curr_down_speed + self.step_delta, max_down_speed)

            self.sut.set_speed(self.inet_cores, curr_up_speed)
            self.sut.set_speed(self.tun_cores, curr_down_speed)
            time.sleep(self.step_time)

        LOG.info("Target speeds reached. Starting real test.")

        yield

        self.sut.stop(self.tun_cores + self.inet_cores)
        LOG.info("Test ended. Flushing NIC buffers")
        self.sut.start(self.all_rx_cores)
        time.sleep(3)
        self.sut.stop(self.all_rx_cores)

    def run_test(self, pkt_size, duration, value, tolerated_loss=0.0):
        data_helper = ProxDataHelper(self.vnfd_helper, self.sut, pkt_size, value, tolerated_loss)

        with data_helper, self.traffic_context(pkt_size, value):
            with data_helper.measure_tot_stats():
                time.sleep(duration)
                # Getting statistics to calculate PPS at right speed....
                data_helper.capture_tsc_hz()
                data_helper.latency = self.get_latency()

        return data_helper.result_tuple, data_helper.samples