X-Git-Url: https://gerrit.fd.io/r/gitweb?a=blobdiff_plain;f=resources%2Flibraries%2Fpython%2FLispSetup.py;h=5fee5db87dbd089235468ef0d1c05e1734f34ddc;hb=e7a8aec57027b1791178bccacd58facacc322f6a;hp=13d0501abb2de858489143a1278e2b7fdc599428;hpb=721f39743c31003ccbdad3c27ffcc3145bfccf90;p=csit.git diff --git a/resources/libraries/python/LispSetup.py b/resources/libraries/python/LispSetup.py index 13d0501abb..5fee5db87d 100644 --- a/resources/libraries/python/LispSetup.py +++ b/resources/libraries/python/LispSetup.py @@ -1,4 +1,4 @@ -# Copyright (c) 2016 Cisco and/or its affiliates. +# Copyright (c) 2016-2019 Cisco and/or its affiliates. # 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: @@ -13,9 +13,11 @@ """Library to set up Lisp in topology.""" -from resources.libraries.python.topology import NodeType -from resources.libraries.python.VatExecutor import VatExecutor +from ipaddress import ip_address +from resources.libraries.python.topology import NodeType +from resources.libraries.python.PapiExecutor import PapiSocketExecutor +from resources.libraries.python.L2Util import L2Util class LispStatus(object): """Class for lisp API.""" @@ -33,10 +35,14 @@ class LispStatus(object): :type state: str """ - VatExecutor.cmd_from_template(node, - 'lisp/lisp_status.vat', - state=state) + args = dict(is_en=0 if state == 'disable' else 1) + + cmd = 'lisp_enable_disable' + err_msg = "Failed to set LISP status on host {host}".format( + host=node['host']) + with PapiSocketExecutor(node) as papi_exec: + papi_exec.add(cmd, **args).get_reply(err_msg) class LispRemoteMapping(object): """Class for lisp remote mapping API.""" @@ -46,16 +52,17 @@ class LispRemoteMapping(object): @staticmethod def vpp_add_lisp_remote_mapping(node, vni, deid, deid_prefix, seid, - seid_prefix, rloc): + seid_prefix, rloc, is_mac=False): """Add lisp remote mapping on the VPP node in topology. :param node: VPP node. :param vni: Vni. :param deid: Destination eid address. - :param deid_predix: Destination eid address prefix_len. + :param deid_prefix: Destination eid address prefix_len. :param seid: Source eid address. :param seid_prefix: Source eid address prefix_len. :param rloc: Receiver locator. + :param is_mac: Set to True if the deid/seid is MAC address. :type node: dict :type vni: int :type deid: str @@ -63,16 +70,42 @@ class LispRemoteMapping(object): :type seid: str :type seid_prefix: int :type rloc: str + :type is_mac: bool """ - VatExecutor.cmd_from_template(node, - 'lisp/add_lisp_remote_mapping.vat', - vni=vni, - deid=deid, - deid_prefix=deid_prefix, - seid=seid, - seid_prefix=seid_prefix, - rloc=rloc) + if not is_mac: + eid_type = 0 if ip_address(unicode(deid)).version == 4 else 1 + eid_packed = ip_address(unicode(deid)).packed + seid_packed = ip_address(unicode(seid)).packed + eid_len = deid_prefix + seid_len = seid_prefix + else: + eid_type = 2 + eid_packed = L2Util.mac_to_bin(deid) + seid_packed = L2Util.mac_to_bin(seid) + eid_len = 0 + seid_len = 0 + + rlocs = [dict(is_ip4=1 if ip_address(unicode(rloc)).version == 4 else 0, + addr=ip_address(unicode(rloc)).packed)] + + args = dict(is_add=1, + is_src_dst=1, + vni=int(vni), + eid_type=eid_type, + eid=eid_packed, + eid_len=eid_len, + seid=seid_packed, + seid_len=seid_len, + rloc_num=1, + rlocs=rlocs) + + cmd = 'lisp_add_del_remote_mapping' + err_msg = "Failed to add remote mapping on host {host}".format( + host=node['host']) + + with PapiSocketExecutor(node) as papi_exec: + papi_exec.add(cmd, **args).get_reply(err_msg) @staticmethod def vpp_del_lisp_remote_mapping(node, vni, deid, deid_prefix, seid, @@ -82,7 +115,7 @@ class LispRemoteMapping(object): :param node: VPP node. :param vni: Vni. :param deid: Destination eid address. - :param deid_predix: Destination eid address prefix_len. + :param deid_prefix: Destination eid address prefix_len. :param seid: Source eid address. :param seid_prefix: Source eid address prefix_len. :param rloc: Receiver locator. @@ -95,14 +128,43 @@ class LispRemoteMapping(object): :type rloc: str """ - VatExecutor.cmd_from_template(node, - 'lisp/del_lisp_remote_mapping.vat', - vni=vni, - deid=deid, - deid_predix=deid_prefix, - seid=seid, - seid_prefix=seid_prefix, - rloc=rloc) + # used only with IPs + is_mac = False + + if not is_mac: + eid_type = 0 if ip_address(unicode(deid)).version == 4 else 1 + eid_packed = ip_address(unicode(deid)).packed + seid_packed = ip_address(unicode(seid)).packed + eid_len = deid_prefix + seid_len = seid_prefix + else: + eid_type = 2 + eid_packed = L2Util.mac_to_bin(deid) + seid_packed = L2Util.mac_to_bin(seid) + eid_len = 0 + seid_len = 0 + + rlocs = [dict(is_ip4=1 if ip_address(unicode(rloc)).version == 4 else 0, + addr=ip_address(unicode(rloc)).packed)] + + args = dict(is_add=0, + is_src_dst=1, + vni=int(vni), + eid_type=eid_type, + eid=eid_packed, + eid_len=eid_len, + seid=seid_packed, + seid_len=seid_len, + rloc_num=1, + rlocs=rlocs) + + cmd = 'lisp_add_del_remote_mapping' + err_msg = "Failed to delete remote mapping on host {host}".format( + host=node['host']) + + with PapiSocketExecutor(node) as papi_exec: + papi_exec.add(cmd, **args).get_reply(err_msg) + class LispAdjacency(object): """Class for lisp adjacency API.""" @@ -111,30 +173,52 @@ class LispAdjacency(object): @staticmethod def vpp_add_lisp_adjacency(node, vni, deid, deid_prefix, seid, - seid_prefix): + seid_prefix, is_mac=False): """Add lisp adjacency on the VPP node in topology. :param node: VPP node. :param vni: Vni. :param deid: Destination eid address. - :param deid_predix: Destination eid address prefix_len. + :param deid_prefix: Destination eid address prefix_len. :param seid: Source eid address. :param seid_prefix: Source eid address prefix_len. + :param is_mac: Set to True if the deid/seid is MAC address. :type node: dict :type vni: int :type deid: str :type deid_prefix: int :type seid: str :type seid_prefix: int + :type is_mac: bool """ - VatExecutor.cmd_from_template(node, - 'lisp/add_lisp_adjacency.vat', - vni=vni, - deid=deid, - deid_prefix=deid_prefix, - seid=seid, - seid_prefix=seid_prefix) + if not is_mac: + eid_type = 0 if ip_address(unicode(deid)).version == 4 else 1 + reid = ip_address(unicode(deid)).packed + leid = ip_address(unicode(seid)).packed + reid_len = deid_prefix + leid_len = seid_prefix + else: + eid_type = 2 + reid = L2Util.mac_to_bin(deid) + leid = L2Util.mac_to_bin(seid) + reid_len = 0 + leid_len = 0 + + args = dict(is_add=1, + vni=int(vni), + eid_type=eid_type, + reid=reid, + reid_len=reid_len, + leid=leid, + leid_len=leid_len) + + cmd = 'lisp_add_del_adjacency' + err_msg = "Failed to add lisp adjacency on host {host}".format( + host=node['host']) + + with PapiSocketExecutor(node) as papi_exec: + papi_exec.add(cmd, **args).get_reply(err_msg) @staticmethod def vpp_del_lisp_adjacency(node, vni, deid, deid_prefix, seid, @@ -144,7 +228,7 @@ class LispAdjacency(object): :param node: VPP node. :param vni: Vni. :param deid: Destination eid address. - :param deid_predix: Destination eid address prefix_len. + :param deid_prefix: Destination eid address prefix_len. :param seid: Source eid address. :param seid_prefix: Source eid address prefix_len. :type node: dict @@ -155,34 +239,83 @@ class LispAdjacency(object): :type seid_prefix: int """ - VatExecutor.cmd_from_template(node, - 'lisp/del_lisp_adjacency.vat', - vni=vni, - deid=deid, - deid_predix=deid_prefix, - seid=seid, - seid_prefix=seid_prefix) - + # used only with IPs + is_mac = False -class LispGpeIface(object): - """Class for Lisp gpe interface API.""" + if not is_mac: + eid_type = 0 if ip_address(unicode(deid)).version == 4 else 1 + reid = ip_address(unicode(deid)).packed + leid = ip_address(unicode(seid)).packed + reid_len = deid_prefix + leid_len = seid_prefix + else: + eid_type = 2 + reid = L2Util.mac_to_bin(deid) + leid = L2Util.mac_to_bin(seid) + reid_len = 0 + leid_len = 0 + + args = dict(is_add=0, + vni=int(vni), + eid_type=eid_type, + reid=reid, + reid_len=reid_len, + leid=leid, + leid_len=leid_len) + + cmd = 'lisp_add_del_adjacency' + err_msg = "Failed to delete lisp adjacency on host {host}".format( + host=node['host']) + + with PapiSocketExecutor(node) as papi_exec: + papi_exec.add(cmd, **args).get_reply(err_msg) + +class LispGpeStatus(object): + """Clas for LISP GPE status manipulation.""" def __init__(self): pass @staticmethod - def vpp_lisp_gpe_iface(node, state): - """Set lisp gpe interface up or down on the VPP node in topology. + def vpp_lisp_gpe_enable_disable(node, state): + """Change the state of LISP GPE - enable or disable. :param node: VPP node. - :param state: State of the gpe iface, up or down. + :param state: Requested state - enable or disable. :type node: dict :type state: str """ - VatExecutor.cmd_from_template(node, - 'lisp/lisp_gpe_iface.vat', - state=state) + args = dict(is_en=0 if state == 'disable' else 1) + + cmd = 'gpe_enable_disable' + err_msg = "Failed to set LISP GPE status on host {host}".format( + host=node['host']) + + with PapiSocketExecutor(node) as papi_exec: + papi_exec.add(cmd, **args).get_reply(err_msg) + +class LispGpeForwardEntry(object): + """The functionality needed for these methods is not implemented in VPP + (VAT). Bug https://jira.fd.io/browse/VPP-334 was open to cover this issue. + + TODO: Implement when VPP-334 is fixed. + """ + + def __init__(self): + pass + + @staticmethod + def add_lisp_gpe_forward_entry(node, *args): + """Not implemented""" + # TODO: Implement when VPP-334 is fixed. + pass + + @staticmethod + def del_lisp_gpe_forward_entry(node, *args): + """Not implemented""" + # TODO: Implement when VPP-334 is fixed. + pass class LispMapResolver(object): @@ -201,9 +334,17 @@ class LispMapResolver(object): :type map_resolver_ip: str """ - VatExecutor.cmd_from_template(node, - 'lisp/add_lisp_map_resolver.vat', - address=map_resolver_ip) + args = dict(is_add=1, + is_ipv6=0 if ip_address(unicode(map_resolver_ip)).version \ + == 4 else 1, + ip_address=ip_address(unicode(map_resolver_ip)).packed) + + cmd = 'lisp_add_del_map_resolver' + err_msg = "Failed to add map resolver on host {host}".format( + host=node['host']) + + with PapiSocketExecutor(node) as papi_exec: + papi_exec.add(cmd, **args).get_reply(err_msg) @staticmethod def vpp_del_map_resolver(node, map_resolver_ip): @@ -215,10 +356,17 @@ class LispMapResolver(object): :type map_resolver_ip: str """ - VatExecutor.cmd_from_template(node, - 'lisp/del_lisp_map_resolver.vat', - address=map_resolver_ip) + args = dict(is_add=0, + is_ipv6=0 if ip_address(unicode(map_resolver_ip)).version \ + == 4 else 1, + ip_address=ip_address(unicode(map_resolver_ip)).packed) + + cmd = 'lisp_add_del_map_resolver' + err_msg = "Failed to delete map resolver on host {host}".format( + host=node['host']) + with PapiSocketExecutor(node) as papi_exec: + papi_exec.add(cmd, **args).get_reply(err_msg) class LispLocalEid(object): """Class for Lisp local eid API.""" @@ -243,19 +391,26 @@ class LispLocalEid(object): :type prefix_len: int """ - if prefix_len is not None: - VatExecutor.cmd_from_template(node, - 'lisp/add_lisp_local_eid.vat', - vni=vni, - eid=eid, - eid_prefix=prefix_len, - locator_name=locator_set_name) + if prefix_len: + eid_type = 0 if ip_address(unicode(eid)).version == 4 else 1 + eid_packed = ip_address(unicode(eid)).packed else: - VatExecutor.cmd_from_template(node, - 'lisp/add_lisp_local_eid_mac.vat', - vni=vni, - eid=eid, - locator_name=locator_set_name) + eid_type = 2 + eid_packed = L2Util.mac_to_bin(eid) + + args = dict(is_add=1, + eid_type=eid_type, + eid=eid_packed, + prefix_len=prefix_len, + locator_set_name=locator_set_name, + vni=int(vni)) + + cmd = 'lisp_add_del_local_eid' + err_msg = "Failed to add local eid on host {host}".format( + host=node['host']) + + with PapiSocketExecutor(node) as papi_exec: + papi_exec.add(cmd, **args).get_reply(err_msg) @staticmethod def vpp_del_lisp_local_eid(node, locator_set_name, vni, eid, @@ -274,20 +429,26 @@ class LispLocalEid(object): :type prefix_len: int """ - if prefix_len is not None: - VatExecutor.cmd_from_template(node, - 'lisp/del_lisp_local_eid.vat', - vni=vni, - eid=eid, - eid_prefix=prefix_len, - locator_name=locator_set_name) + if prefix_len: + eid_type = 0 if ip_address(unicode(eid)).version == 4 else 1 + eid_packed = ip_address(unicode(eid)).packed else: - VatExecutor.cmd_from_template(node, - 'lisp/del_lisp_local_eid_mac.vat', - vni=vni, - eid=eid, - locator_name=locator_set_name) + eid_type = 2 + eid_packed = L2Util.mac_to_bin(eid) + + args = dict(is_add=0, + eid_type=eid_type, + eid=eid_packed, + prefix_len=prefix_len, + locator_set_name=locator_set_name, + vni=int(vni)) + cmd = 'lisp_add_del_local_eid' + err_msg = "Failed to delete local eid on host {host}".format( + host=node['host']) + + with PapiSocketExecutor(node) as papi_exec: + papi_exec.add(cmd, **args).get_reply(err_msg) class LispLocator(object): """Class for the Lisp Locator API.""" @@ -311,12 +472,18 @@ class LispLocator(object): :type weight: int """ - VatExecutor.cmd_from_template(node, - 'lisp/add_lisp_locator.vat', - lisp_name=locator_name, - sw_if_index=sw_if_index, - priority=priority, - weight=weight) + args = dict(is_add=1, + locator_set_name=locator_name, + sw_if_index=sw_if_index, + priority=priority, + weight=weight) + + cmd = 'lisp_add_del_locator' + err_msg = "Failed to add locator on host {host}".format( + host=node['host']) + + with PapiSocketExecutor(node) as papi_exec: + papi_exec.add(cmd, **args).get_reply(err_msg) @staticmethod def vpp_del_lisp_locator(node, locator_name, sw_if_index, priority, weight): @@ -334,13 +501,18 @@ class LispLocator(object): :type weight: int """ - VatExecutor.cmd_from_template(node, - 'lisp/del_lisp_locator.vat', - lisp_name=locator_name, - sw_if_index=sw_if_index, - priority=priority, - weight=weight) + args = dict(is_add=0, + locator_set_name=locator_name, + sw_if_index=sw_if_index, + priority=priority, + weight=weight) + + cmd = 'lisp_add_del_locator' + err_msg = "Failed to delete locator on host {host}".format( + host=node['host']) + with PapiSocketExecutor(node) as papi_exec: + papi_exec.add(cmd, **args).get_reply(err_msg) class LispLocatorSet(object): """Class for Lisp Locator Set API.""" @@ -358,9 +530,17 @@ class LispLocatorSet(object): :type name: str """ - VatExecutor.cmd_from_template(node, - 'lisp/add_lisp_locator_set.vat', - lisp_name=name) + args = dict(is_add=1, + locator_set_name=name, + locator_num=0, + locators=[]) + + cmd = 'lisp_add_del_locator_set' + err_msg = "Failed to add locator set on host {host}".format( + host=node['host']) + + with PapiSocketExecutor(node) as papi_exec: + papi_exec.add(cmd, **args).get_reply(err_msg) @staticmethod def vpp_del_lisp_locator_set(node, name): @@ -372,10 +552,17 @@ class LispLocatorSet(object): :type name: str """ - VatExecutor.cmd_from_template(node, - 'lisp/del_lisp_locator_set.vat', - lisp_name=name) + args = dict(is_add=0, + locator_set_name=name, + locator_num=0, + locators=[]) + + cmd = 'lisp_add_del_locator_set' + err_msg = "Failed to delete locator set on host {host}".format( + host=node['host']) + with PapiSocketExecutor(node) as papi_exec: + papi_exec.add(cmd, **args).get_reply(err_msg) class LispSetup(object): """Lisp setup in topology.""" @@ -532,15 +719,48 @@ class LispSetup(object): for map_ip in map_resolver: lisp_map_res.vpp_del_map_resolver(node, map_ip.get('map resolver')) +class LispEidTableMap(object): + """ + Class for EID table map. + """ + @staticmethod - def vpp_lisp_gpe_interface_status(node, state): - """Set lisp gpe interface status on VPP node in topology. + def vpp_lisp_eid_table_mapping(node, vni, bd_id=None, vrf=None): + """ + Map LISP VNI to either bridge domain ID, or VRF ID. :param node: VPP node. - :param state: State of the gpe iface, up or down + :param vni: Lisp VNI. + :param bd_id: Bridge domain ID. + :param vrf: VRF id. :type node: dict - :type state: str + :type vni: int + :type bd_id: int + :type vrf: int """ - lgi = LispGpeIface() - lgi.vpp_lisp_gpe_iface(node, state) + # adding default mapping vni=0, vrf=0 needs to be skipped + skip = False + + if bd_id: + is_l2 = 1 + dp_table = bd_id + else: + is_l2 = 0 + dp_table = vrf + # skip adding default mapping + if (int(vrf) == 0) and (int(vni) == 0): + skip = True + + args = dict(is_add=1, + vni=int(vni), + dp_table=int(dp_table), + is_l2=is_l2) + + cmd = 'lisp_eid_table_add_del_map' + err_msg = "Failed to add eid table map on host {host}".format( + host=node['host']) + + if not skip: + with PapiSocketExecutor(node) as papi_exec: + papi_exec.add(cmd, **args).get_reply(err_msg)