X-Git-Url: https://gerrit.fd.io/r/gitweb?p=csit.git;a=blobdiff_plain;f=resources%2Flibraries%2Fpython%2Ftopology.py;h=e2c069fc98ac54e0d9ead9bd026aea7c6fce2042;hp=103416078a1b21e032deefbac80d779114e5cddb;hb=1254d80a0b64985de2816eff5ef79e3e22cde972;hpb=84c4bb50e13685176751e90bd67ce02730061032 diff --git a/resources/libraries/python/topology.py b/resources/libraries/python/topology.py index 103416078a..e2c069fc98 100644 --- a/resources/libraries/python/topology.py +++ b/resources/libraries/python/topology.py @@ -26,7 +26,7 @@ __all__ = ["DICT__nodes", 'Topology'] def load_topo_from_yaml(): - """Loads topology from file defined in "${TOPOLOGY_PATH}" variable + """Load topology from file defined in "${TOPOLOGY_PATH}" variable :return: nodes from loaded topology """ @@ -43,12 +43,13 @@ class NodeType(object): # Traffic Generator (this node has traffic generator on it) TG = 'TG' + class NodeSubTypeTG(object): #T-Rex traffic generator TREX = 'TREX' # Moongen MOONGEN = 'MOONGEN' - #IxNetwork + # IxNetwork IXNET = 'IXNET' DICT__nodes = load_topo_from_yaml() @@ -61,9 +62,6 @@ class Topology(object): the used topology. """ - def __init__(self): - pass - @staticmethod def get_node_by_hostname(nodes, hostname): """Get node from nodes of the topology by hostname. @@ -102,7 +100,7 @@ class Topology(object): @staticmethod def _get_interface_by_key_value(node, key, value): - """ Return node interface name according to key and value + """Return node interface name according to key and value :param node: :param node: the node dictionary :param key: key by which to select the interface. @@ -184,7 +182,7 @@ class Topology(object): return list_mac def _extract_vpp_interface_by_mac(self, interfaces_list, mac_address): - """Returns interface dictionary from interface_list by mac address. + """Return interface dictionary from interface_list by mac address. Extracts interface dictionary from all of the interfaces in interfaces list parsed from json according to mac_address of the interface @@ -238,7 +236,7 @@ class Topology(object): return interface_name def _update_node_interface_data_from_json(self, node, interface_dump_json): - """ Update node vpp data in node__DICT from json interface dump. + """Update node vpp data in node__DICT from json interface dump. This method updates vpp interface names and sw indexexs according to interface mac addresses found in interface_dump_json @@ -318,7 +316,7 @@ class Topology(object): InterfaceSetup.tg_set_interfaces_udev_rules(node) def update_all_interface_data_on_all_nodes(self, nodes): - """ Update interface names on all nodes in DICT__nodes + """Update interface names on all nodes in DICT__nodes :param nodes: Nodes in the topology. :type nodes: dict @@ -407,7 +405,7 @@ class Topology(object): :rtype: (dict, dict) """ link_name = None - # get link name where the interface belongs to + # get link name where the interface belongs to for port_name, port_data in node['interfaces'].iteritems(): if port_name == 'mgmt': continue @@ -516,7 +514,7 @@ class Topology(object): @staticmethod def _get_node_active_link_names(node): - """Returns list of link names that are other than mgmt links + """Return list of link names that are other than mgmt links :param node: node topology dictionary :return: list of strings that represent link names occupied by the node @@ -532,7 +530,7 @@ class Topology(object): @keyword('Get active links connecting "${node1}" and "${node2}"') def get_active_connecting_links(self, node1, node2): - """Returns list of link names that connect together node1 and node2 + """Return list of link names that connect together node1 and node2 :param node1: node topology dictionary :param node2: node topology dictionary @@ -574,7 +572,7 @@ class Topology(object): :param node2: Second node. :type node1: dict :type node2: dict - :return: Engress interfaces. + :return: Egress interfaces. :rtype: list """ interfaces = [] @@ -602,25 +600,25 @@ class Topology(object): :param node2: Second node. :type node1: dict :type node2: dict - :return: Engress interface. + :return: Egress interface. :rtype: str """ interfaces = self.get_egress_interfaces_for_nodes(node1, node2) if not interfaces: - raise RuntimeError('No engress interface for nodes') + raise RuntimeError('No egress interface for nodes') return interfaces[0] @keyword('Get link data useful in circular topology test from tg "${tgen}"' ' dut1 "${dut1}" dut2 "${dut2}"') def get_links_dict_from_nodes(self, tgen, dut1, dut2): - """Returns link combinations used in tests in circular topology. + """Return link combinations used in tests in circular topology. For the time being it returns links from the Node path: TG->DUT1->DUT2->TG - :param tg: traffic generator node data + :param tgen: traffic generator node data :param dut1: DUT1 node data :param dut2: DUT2 node data - :type tg: dict + :type tgen: dict :type dut1: dict :type dut2: dict :return: dictionary of possible link combinations @@ -662,8 +660,10 @@ class Topology(object): @staticmethod def get_node_hostname(node): + """Return host (hostname/ip address) of the node. + + :param node: Node created from topology. + :type node: dict + :return: host as 'str' type """ - :param node: node dictionary - :return: host name as 'str' type - """ - return node['host'] \ No newline at end of file + return node['host']