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
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
|
# Copyright (c) 2016-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.
from __future__ import absolute_import
import logging
from yardstick.network_services.vnf_generic.vnf.sample_vnf import SampleVNF
from yardstick.network_services.vnf_generic.vnf.sample_vnf import DpdkVnfSetupEnvHelper
from yardstick.network_services.vnf_generic.vnf.sample_vnf import ClientResourceHelper
LOG = logging.getLogger(__name__)
# UDP_Replay should work the same on all systems, we can provide the binary
REPLAY_PIPELINE_COMMAND = (
"""sudo {tool_path} -c {cpu_mask_hex} -n 4 -w {whitelist} -- """
"""{hw_csum} -p {ports_len_hex} --config='{config}'"""
)
# {tool_path} -p {ports_len_hex} -f {cfg_file} -s {script}'
class UdpReplaySetupEnvHelper(DpdkVnfSetupEnvHelper):
APP_NAME = "UDP_Replay"
class UdpReplayResourceHelper(ClientResourceHelper):
pass
class UdpReplayApproxVnf(SampleVNF):
APP_NAME = "UDP_Replay"
APP_WORD = "UDP_Replay"
VNF_PROMPT = 'Replay>'
VNF_TYPE = 'UdpReplay'
HW_OFFLOADING_NFVI_TYPES = {'baremetal', 'sriov'}
PIPELINE_COMMAND = REPLAY_PIPELINE_COMMAND
def __init__(self, name, vnfd, setup_env_helper_type=None, resource_helper_type=None):
if resource_helper_type is None:
resource_helper_type = UdpReplayResourceHelper
if setup_env_helper_type is None:
setup_env_helper_type = UdpReplaySetupEnvHelper
super(UdpReplayApproxVnf, self).__init__(name, vnfd, setup_env_helper_type,
resource_helper_type)
def _start_server(self):
super(UdpReplayApproxVnf, self)._start_server()
self.resource_helper.start()
def scale(self, flavor=""):
""" scale vnfbased on flavor input """
raise NotImplementedError
def _deploy(self):
self.generate_port_pairs()
super(UdpReplayApproxVnf, self)._deploy()
def _build_pipeline_kwargs(self):
all_ports = [i for i, _ in enumerate(self.vnfd_helper.interfaces)]
number_of_ports = len(all_ports)
tool_path = self.ssh_helper.provision_tool(tool_file=self.APP_NAME)
ports_mask = 2 ** number_of_ports - 1
ports_mask_hex = hex(ports_mask)
cpu_mask_hex = hex(2 ** (number_of_ports + 1) - 1)
hw_csum = ""
if (not self.scenario_helper.options.get('hw_csum', False) or
self.nfvi_context.attrs.get('nfvi_type') not in self.HW_OFFLOADING_NFVI_TYPES):
hw_csum = '--no-hw-csum'
config_value = "".join(str((port, 0, port + 1)) for port in all_ports)
whitelist = " -w ".join(self.setup_helper.bound_pci)
self.pipeline_kwargs = {
'ports_len_hex': ports_mask_hex,
'tool_path': tool_path,
'hw_csum': hw_csum,
'whitelist': whitelist,
'cpu_mask_hex': cpu_mask_hex,
'config': config_value,
}
def _build_config(self):
self._build_pipeline_kwargs()
return self.PIPELINE_COMMAND.format(**self.pipeline_kwargs)
def collect_kpi(self):
def get_sum(offset):
return sum(int(i) for i in split_stats[offset::5])
number_of_ports = len(self.vnfd_helper.interfaces)
stats = self.get_stats()
stats_words = stats.split()
split_stats = stats_words[stats_words.index('0'):][:number_of_ports * 5]
result = {
"packets_in": get_sum(1),
"packets_fwd": get_sum(2),
"packets_dropped": get_sum(3) + get_sum(4),
"collect_stats": {},
}
LOG.debug("UDP Replay collect KPIs %s", result)
return result
def get_stats(self):
"""
Method for checking the statistics
:return:
UDP Replay statistics
"""
cmd = 'UDP_Replay stats'
out = self.vnf_execute(cmd)
return out
|
