1 # Copyright (c) 2016-2017 Intel Corporation
3 # Licensed under the Apache License, Version 2.0 (the "License");
4 # you may not use this file except in compliance with the License.
5 # You may obtain a copy of the License at
7 # http://www.apache.org/licenses/LICENSE-2.0
9 # Unless required by applicable law or agreed to in writing, software
10 # distributed under the License is distributed on an "AS IS" BASIS,
11 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12 # See the License for the specific language governing permissions and
13 # limitations under the License.
20 from yardstick.common import exceptions
21 from yardstick.network_services.vnf_generic.vnf.sample_vnf import SampleVNFTrafficGen
22 from yardstick.network_services.vnf_generic.vnf.sample_vnf import ClientResourceHelper
23 from yardstick.network_services.vnf_generic.vnf.sample_vnf import Rfc2544ResourceHelper
26 LOG = logging.getLogger(__name__)
28 WAIT_AFTER_CFG_LOAD = 10
30 IXIA_LIB = os.path.dirname(os.path.realpath(__file__))
31 IXNET_LIB = os.path.join(IXIA_LIB, "../../libs/ixia_libs/IxNet")
32 sys.path.append(IXNET_LIB)
35 from IxNet import IxNextgen
37 IxNextgen = exceptions.ErrorClass
40 class IxiaRfc2544Helper(Rfc2544ResourceHelper):
43 return self.latency and self.iteration.value > 10
46 class IxiaResourceHelper(ClientResourceHelper):
48 LATENCY_TIME_SLEEP = 120
50 def __init__(self, setup_helper, rfc_helper_type=None):
51 super(IxiaResourceHelper, self).__init__(setup_helper)
52 self.scenario_helper = setup_helper.scenario_helper
54 self.client = IxNextgen()
56 if rfc_helper_type is None:
57 rfc_helper_type = IxiaRfc2544Helper
59 self.rfc_helper = rfc_helper_type(self.scenario_helper)
60 self.uplink_ports = None
61 self.downlink_ports = None
64 def _connect(self, client=None):
65 self.client.connect(self.vnfd_helper)
67 def get_stats(self, *args, **kwargs):
68 return self.client.get_statistics()
70 def stop_collect(self):
71 self._terminated.value = 1
73 self.client.ix_stop_traffic()
75 def generate_samples(self, ports, key=None, default=None):
76 stats = self.get_stats()
79 # this is not DPDK port num, but this is whatever number we gave
80 # when we selected ports and programmed the profile
81 for port_num in ports:
83 # reverse lookup port name from port_num so the stats dict is descriptive
84 intf = self.vnfd_helper.find_interface_by_port(port_num)
85 port_name = intf["name"]
86 samples[port_name] = {
87 "rx_throughput_kps": float(stats["Rx_Rate_Kbps"][port_num]),
88 "tx_throughput_kps": float(stats["Tx_Rate_Kbps"][port_num]),
89 "rx_throughput_mbps": float(stats["Rx_Rate_Mbps"][port_num]),
90 "tx_throughput_mbps": float(stats["Tx_Rate_Mbps"][port_num]),
91 "in_packets": int(stats["Valid_Frames_Rx"][port_num]),
92 "out_packets": int(stats["Frames_Tx"][port_num]),
93 # NOTE(ralonsoh): we need to make the traffic injection
95 "RxThroughput": int(stats["Valid_Frames_Rx"][port_num]) / 30,
96 "TxThroughput": int(stats["Frames_Tx"][port_num]) / 30,
99 avg_latency = stats["Store-Forward_Avg_latency_ns"][port_num]
100 min_latency = stats["Store-Forward_Min_latency_ns"][port_num]
101 max_latency = stats["Store-Forward_Max_latency_ns"][port_num]
102 samples[port_name][key] = \
103 {"Store-Forward_Avg_latency_ns": avg_latency,
104 "Store-Forward_Min_latency_ns": min_latency,
105 "Store-Forward_Max_latency_ns": max_latency}
111 def _initialize_client(self):
112 """Initialize the IXIA IxNetwork client and configure the server"""
113 self.client.clear_config()
114 self.client.assign_ports()
115 self.client.create_traffic_model()
117 def run_traffic(self, traffic_profile):
118 if self._terminated.value:
121 min_tol = self.rfc_helper.tolerance_low
122 max_tol = self.rfc_helper.tolerance_high
123 default = "00:00:00:00:00:00"
126 self._initialize_client()
129 for port_name in self.vnfd_helper.port_pairs.all_ports:
130 intf = self.vnfd_helper.find_interface(name=port_name)
131 virt_intf = intf["virtual-interface"]
132 # we only know static traffic id by reading the json
133 # this is used by _get_ixia_trafficrofile
134 port_num = self.vnfd_helper.port_num(intf)
135 mac["src_mac_{}".format(port_num)] = virt_intf.get("local_mac", default)
136 mac["dst_mac_{}".format(port_num)] = virt_intf.get("dst_mac", default)
139 # Generate ixia traffic config...
141 while not self._terminated.value:
142 traffic_profile.execute_traffic(self, self.client, mac)
143 self.client_started.value = 1
144 time.sleep(WAIT_FOR_TRAFFIC)
145 self.client.ix_stop_traffic()
146 samples = self.generate_samples(traffic_profile.ports)
147 self._queue.put(samples)
148 status, samples = traffic_profile.get_drop_percentage(samples, min_tol,
149 max_tol, self.client, mac)
151 current = samples['CurrentDropPercentage']
152 if min_tol <= current <= max_tol or status == 'Completed':
153 self._terminated.value = 1
155 self.client.ix_stop_traffic()
156 self._queue.put(samples)
158 if not self.rfc_helper.is_done():
159 self._terminated.value = 1
162 traffic_profile.execute_traffic(self, self.client, mac)
164 time.sleep(self.LATENCY_TIME_SLEEP)
165 self.client.ix_stop_traffic()
166 samples = self.generate_samples(traffic_profile.ports, 'latency', {})
167 self._queue.put(samples)
168 traffic_profile.start_ixia_latency(self, self.client, mac)
169 if self._terminated.value:
172 self.client.ix_stop_traffic()
173 except Exception: # pylint: disable=broad-except
174 LOG.exception("Run Traffic terminated")
176 self._terminated.value = 1
178 def collect_kpi(self):
179 self.rfc_helper.iteration.value += 1
180 return super(IxiaResourceHelper, self).collect_kpi()
183 class IxiaTrafficGen(SampleVNFTrafficGen):
187 def __init__(self, name, vnfd, setup_env_helper_type=None, resource_helper_type=None):
188 if resource_helper_type is None:
189 resource_helper_type = IxiaResourceHelper
191 super(IxiaTrafficGen, self).__init__(name, vnfd, setup_env_helper_type,
192 resource_helper_type)
193 self._ixia_traffic_gen = None
194 self.ixia_file_name = ''
195 self.vnf_port_pairs = []
197 def _check_status(self):
201 self.resource_helper.stop_collect()
202 super(IxiaTrafficGen, self).terminate()