1aab1816f258614c671f12b6690f84af8ee8ae6f
[csit.git] / resources / libraries / python / IPv6Util.py
1 # Copyright (c) 2016 Cisco and/or its affiliates.
2 # Licensed under the Apache License, Version 2.0 (the "License");
3 # you may not use this file except in compliance with the License.
4 # You may obtain a copy of the License at:
5 #
6 #     http://www.apache.org/licenses/LICENSE-2.0
7 #
8 # Unless required by applicable law or agreed to in writing, software
9 # distributed under the License is distributed on an "AS IS" BASIS,
10 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
11 # See the License for the specific language governing permissions and
12 # limitations under the License.
13
14 """IPv6 utilities library."""
15
16 import re
17
18 from resources.libraries.python.ssh import SSH
19 from resources.libraries.python.VatExecutor import VatTerminal
20 from resources.libraries.python.topology import Topology
21
22
23 class IPv6Util(object):
24     """IPv6 utilities"""
25
26     @staticmethod
27     def ipv6_ping(src_node, dst_addr, count=3, data_size=56, timeout=1):
28         """IPv6 ping.
29
30         :param src_node: Node where ping run.
31         :param dst_addr: Destination IPv6 address.
32         :param count: Number of echo requests. (Optional)
33         :param data_size: Number of the data bytes. (Optional)
34         :param timeout: Time to wait for a response, in seconds. (Optional)
35         :type src_node: dict
36         :type dst_addr: str
37         :type count: int
38         :type data_size: int
39         :type timeout: int
40         :return: Number of lost packets.
41         :rtype: int
42         """
43         ssh = SSH()
44         ssh.connect(src_node)
45
46         cmd = "ping6 -c {c} -s {s} -W {W} {dst}".format(c=count, s=data_size,
47                                                         W=timeout,
48                                                         dst=dst_addr)
49         (_, stdout, _) = ssh.exec_command(cmd)
50
51         regex = re.compile(r'(\d+) packets transmitted, (\d+) received')
52         match = regex.search(stdout)
53         sent, received = match.groups()
54         packet_lost = int(sent) - int(received)
55
56         return packet_lost
57
58     @staticmethod
59     def ipv6_ping_port(nodes_ip, src_node, dst_node, port, cnt=3,
60                        size=56, timeout=1):
61         """Send IPv6 ping to the node port.
62
63         :param nodes_ip: Nodes IPv6 addresses.
64         :param src_node: Node where ping run.
65         :param dst_node: Destination node.
66         :param port: Port on the destination node.
67         :param cnt: Number of echo requests. (Optional)
68         :param size: Number of the data bytes. (Optional)
69         :param timeout: Time to wait for a response, in seconds. (Optional)
70         :type nodes_ip: dict
71         :type src_node: dict
72         :type dst_node: dict
73         :type port: str
74         :type cnt: int
75         :type size: int
76         :type timeout: int
77         :return: Number of lost packets.
78         :rtype: int
79         """
80         dst_ip = IPv6Util.get_node_port_ipv6_address(dst_node, port, nodes_ip)
81         return IPv6Util.ipv6_ping(src_node, dst_ip, cnt, size, timeout)
82
83     @staticmethod
84     def get_node_port_ipv6_address(node, iface_key, nodes_addr):
85         """Return IPv6 address of the node port.
86
87         :param node: Node in the topology.
88         :param iface_key: Interface key of the node.
89         :param nodes_addr: Nodes IPv6 addresses.
90         :type node: dict
91         :type iface_key: str
92         :type nodes_addr: dict
93         :return: IPv6 address string.
94         :rtype: str
95         """
96         interface = Topology.get_interface_name(node, iface_key)
97         for net in nodes_addr.values():
98             for port in net['ports'].values():
99                 host = port.get('node')
100                 dev = port.get('if')
101                 if host == node['host'] and dev == interface:
102                     ip_addr = port.get('addr')
103                     if ip_addr is not None:
104                         return ip_addr
105                     else:
106                         raise Exception(
107                             'Node {n} port {p} IPv6 address is not set'.format(
108                                 n=node['host'], p=interface))
109
110         raise Exception('Node {n} port {p} IPv6 address not found.'.format(
111             n=node['host'], p=interface))
112
113     @staticmethod
114     def add_ip_neighbor(node, interface, ip_address, mac_address):
115         """Add IP neighbor.
116
117         :param node: VPP node to add ip neighbor.
118         :param interface: Interface name or sw_if_index.
119         :param ip_address: IP address.
120         :param mac_address: MAC address.
121         :type node: dict
122         :type interface: str or int
123         :type ip_address: str
124         :type mac_address: str
125         """
126         if isinstance(interface, basestring):
127             sw_if_index = Topology.get_interface_sw_index(node, interface)
128         else:
129             sw_if_index = interface
130
131         with VatTerminal(node) as vat:
132             vat.vat_terminal_exec_cmd_from_template("add_ip_neighbor.vat",
133                                                     sw_if_index=sw_if_index,
134                                                     ip_address=ip_address,
135                                                     mac_address=mac_address)

©2016 FD.io a Linux Foundation Collaborative Project. All Rights Reserved.
Linux Foundation is a registered trademark of The Linux Foundation. Linux is a registered trademark of Linus Torvalds.
Please see our privacy policy and terms of use.