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.
17 from yardstick.network_services.traffic_profile.trex_traffic_profile import \
20 LOG = logging.getLogger(__name__)
23 class IXIARFC2544Profile(TrexProfile):
28 def __init__(self, yaml_data):
29 super(IXIARFC2544Profile, self).__init__(yaml_data)
30 self.rate = self.config.frame_rate
32 def _get_ixia_traffic_profile(self, profile_data, mac=None):
37 for traffickey, values in profile_data.items():
38 if not traffickey.startswith((self.UPLINK, self.DOWNLINK)):
42 # values should be single-item dict, so just grab the first item
44 key, value = next(iter(values.items()))
46 result[traffickey] = {}
49 port_id = value.get('id', 1)
50 port_index = port_id - 1
52 ip = value['outer_l3v6']
54 ip = value['outer_l3v4']
55 src_key, dst_key = 'srcip4', 'dstip4'
57 src_key, dst_key = 'srcip6', 'dstip6'
59 result[traffickey] = {
64 'framesize': value['outer_l2']['framesize'],
65 'framesPerSecond': True,
66 'srcmac': mac['src_mac_{}'.format(port_index)],
67 'dstmac': mac['dst_mac_{}'.format(port_index)],
73 src_key: ip[src_key].split("-")[0],
74 dst_key: ip[dst_key].split("-")[0],
78 'outer_l4': value['outer_l4'],
85 def _ixia_traffic_generate(self, traffic, ixia_obj):
86 for key, value in traffic.items():
87 if key.startswith((self.UPLINK, self.DOWNLINK)):
88 value['iload'] = str(self.rate)
89 ixia_obj.update_frame(traffic)
90 ixia_obj.update_ip_packet(traffic)
91 ixia_obj.start_traffic()
93 def update_traffic_profile(self, traffic_generator):
95 for vld_id, intfs in sorted(traffic_generator.networks.items()):
96 if not vld_id.startswith((self.UPLINK, self.DOWNLINK)):
98 profile_data = self.params.get(vld_id)
101 self.profile_data = profile_data
102 self.full_profile.update({vld_id: self.profile_data})
104 yield traffic_generator.vnfd_helper.port_num(intf)
106 self.ports = [port for port in port_generator()]
108 def execute_traffic(self, traffic_generator, ixia_obj=None, mac=None):
109 mac = {} if mac is None else mac
110 first_run = self.first_run
112 self.first_run = False
113 self.full_profile = {}
115 self.update_traffic_profile(traffic_generator)
116 self.max_rate = self.rate
119 self.rate = round(float(self.max_rate + self.min_rate) / 2.0, 2)
121 traffic = self._get_ixia_traffic_profile(self.full_profile, mac)
122 self._ixia_traffic_generate(traffic, ixia_obj)
125 def get_drop_percentage(self, samples, tol_min, tolerance, duration=30.0,
129 num_ifaces = len(samples)
130 in_packets_sum = sum(
131 [samples[iface]['in_packets'] for iface in samples])
132 out_packets_sum = sum(
133 [samples[iface]['out_packets'] for iface in samples])
135 [samples[iface]['RxThroughput'] for iface in samples])
136 rx_throughput = round(float(rx_throughput), 2)
138 [samples[iface]['TxThroughput'] for iface in samples])
139 tx_throughput = round(float(tx_throughput), 2)
140 packet_drop = abs(out_packets_sum - in_packets_sum)
143 drop_percent = round(
144 (packet_drop / float(out_packets_sum)) * 100, 2)
145 except ZeroDivisionError:
146 LOG.info('No traffic is flowing')
148 samples['TxThroughput'] = tx_throughput
149 samples['RxThroughput'] = rx_throughput
150 samples['DropPercentage'] = drop_percent
153 self.rate = out_packets_sum / duration / num_ifaces
154 completed = True if drop_percent <= tolerance else False
156 if drop_percent > tolerance:
157 self.max_rate = self.rate
158 elif drop_percent < tol_min:
159 self.min_rate = self.rate
163 return completed, samples