24b170aac5
When VPP has an interface whose address is also applied to a TAP interface on the host, then VPP's TAP interface will be unnumbered to the 'real' interface and do proxy ARP from the host. the curious aspect of this setup is that ARP requests from the host will come from the VPP's own address. Change-Id: Ia238790e1034ba3cd3facdab29387b65a31525f2 Signed-off-by: Neale Ranns <nranns@cisco.com>
375 lines
13 KiB
Python
375 lines
13 KiB
Python
from abc import abstractmethod, ABCMeta
|
|
import socket
|
|
|
|
from util import Host, mk_ll_addr
|
|
from vpp_neighbor import VppNeighbor
|
|
|
|
|
|
class VppInterface(object):
|
|
"""Generic VPP interface."""
|
|
__metaclass__ = ABCMeta
|
|
|
|
@property
|
|
def sw_if_index(self):
|
|
"""Interface index assigned by VPP."""
|
|
return self._sw_if_index
|
|
|
|
@property
|
|
def remote_mac(self):
|
|
"""MAC-address of the remote interface "connected" to this interface"""
|
|
return self._remote_hosts[0].mac
|
|
|
|
@property
|
|
def local_mac(self):
|
|
"""MAC-address of the VPP interface."""
|
|
return self._local_mac
|
|
|
|
@property
|
|
def local_ip4(self):
|
|
"""Local IPv4 address on VPP interface (string)."""
|
|
return self._local_ip4
|
|
|
|
@property
|
|
def local_ip4n(self):
|
|
"""Local IPv4 address - raw, suitable as API parameter."""
|
|
return socket.inet_pton(socket.AF_INET, self._local_ip4)
|
|
|
|
@property
|
|
def remote_ip4(self):
|
|
"""IPv4 address of remote peer "connected" to this interface."""
|
|
return self._remote_hosts[0].ip4
|
|
|
|
@property
|
|
def remote_ip4n(self):
|
|
"""IPv4 address of remote peer - raw, suitable as API parameter."""
|
|
return socket.inet_pton(socket.AF_INET, self.remote_ip4)
|
|
|
|
@property
|
|
def local_ip6(self):
|
|
"""Local IPv6 address on VPP interface (string)."""
|
|
return self._local_ip6
|
|
|
|
@property
|
|
def local_ip6n(self):
|
|
"""Local IPv6 address - raw, suitable as API parameter."""
|
|
return socket.inet_pton(socket.AF_INET6, self.local_ip6)
|
|
|
|
@property
|
|
def local_ip6_ll(self):
|
|
"""Local IPv6 linnk-local address on VPP interface (string)."""
|
|
return self._local_ip6_ll
|
|
|
|
@property
|
|
def local_ip6n_ll(self):
|
|
"""Local IPv6 link-local address - raw, suitable as API parameter."""
|
|
return self.local_ip6n_ll
|
|
|
|
@property
|
|
def remote_ip6(self):
|
|
"""IPv6 address of remote peer "connected" to this interface."""
|
|
return self._remote_hosts[0].ip6
|
|
|
|
@property
|
|
def remote_ip6n(self):
|
|
"""IPv6 address of remote peer - raw, suitable as API parameter"""
|
|
return socket.inet_pton(socket.AF_INET6, self.remote_ip6)
|
|
|
|
@property
|
|
def name(self):
|
|
"""Name of the interface."""
|
|
return self._name
|
|
|
|
@property
|
|
def dump(self):
|
|
"""RAW result of sw_interface_dump for this interface."""
|
|
return self._dump
|
|
|
|
@property
|
|
def test(self):
|
|
"""Test case creating this interface."""
|
|
return self._test
|
|
|
|
@property
|
|
def remote_hosts(self):
|
|
"""Remote hosts list"""
|
|
return self._remote_hosts
|
|
|
|
@remote_hosts.setter
|
|
def remote_hosts(self, value):
|
|
"""
|
|
:param list value: List of remote hosts.
|
|
"""
|
|
self._remote_hosts = value
|
|
self._hosts_by_mac = {}
|
|
self._hosts_by_ip4 = {}
|
|
self._hosts_by_ip6 = {}
|
|
for host in self._remote_hosts:
|
|
self._hosts_by_mac[host.mac] = host
|
|
self._hosts_by_ip4[host.ip4] = host
|
|
self._hosts_by_ip6[host.ip6] = host
|
|
|
|
def host_by_mac(self, mac):
|
|
"""
|
|
:param mac: MAC address to find host by.
|
|
:return: Host object assigned to interface.
|
|
"""
|
|
return self._hosts_by_mac[mac]
|
|
|
|
def host_by_ip4(self, ip):
|
|
"""
|
|
:param ip: IPv4 address to find host by.
|
|
:return: Host object assigned to interface.
|
|
"""
|
|
return self._hosts_by_ip4[ip]
|
|
|
|
def host_by_ip6(self, ip):
|
|
"""
|
|
:param ip: IPv6 address to find host by.
|
|
:return: Host object assigned to interface.
|
|
"""
|
|
return self._hosts_by_ip6[ip]
|
|
|
|
def generate_remote_hosts(self, count=1):
|
|
"""Generate and add remote hosts for the interface.
|
|
|
|
:param int count: Number of generated remote hosts.
|
|
"""
|
|
self._remote_hosts = []
|
|
self._hosts_by_mac = {}
|
|
self._hosts_by_ip4 = {}
|
|
self._hosts_by_ip6 = {}
|
|
for i in range(
|
|
2, count + 2): # 0: network address, 1: local vpp address
|
|
mac = "02:%02x:00:00:ff:%02x" % (self.sw_if_index, i)
|
|
ip4 = "172.16.%u.%u" % (self.sw_if_index, i)
|
|
ip6 = "fd01:%x::%x" % (self.sw_if_index, i)
|
|
ip6_ll = mk_ll_addr(mac)
|
|
host = Host(mac, ip4, ip6, ip6_ll)
|
|
self._remote_hosts.append(host)
|
|
self._hosts_by_mac[mac] = host
|
|
self._hosts_by_ip4[ip4] = host
|
|
self._hosts_by_ip6[ip6] = host
|
|
|
|
@abstractmethod
|
|
def __init__(self, test):
|
|
self._test = test
|
|
|
|
self._remote_hosts = []
|
|
self._hosts_by_mac = {}
|
|
self._hosts_by_ip4 = {}
|
|
self._hosts_by_ip6 = {}
|
|
|
|
self.generate_remote_hosts()
|
|
|
|
self._local_ip4 = "172.16.%u.1" % self.sw_if_index
|
|
self._local_ip4n = socket.inet_pton(socket.AF_INET, self.local_ip4)
|
|
self._local_ip4_subnet = "172.16.%u.0" % self.sw_if_index
|
|
self._local_ip4n_subnet = socket.inet_pton(socket.AF_INET,
|
|
self._local_ip4_subnet)
|
|
self._local_ip4_bcast = "172.16.%u.255" % self.sw_if_index
|
|
self._local_ip4n_bcast = socket.inet_pton(socket.AF_INET,
|
|
self._local_ip4_bcast)
|
|
self.local_ip4_prefix_len = 24
|
|
self.has_ip4_config = False
|
|
self.ip4_table_id = 0
|
|
|
|
self._local_ip6 = "fd01:%x::1" % self.sw_if_index
|
|
self._local_ip6n = socket.inet_pton(socket.AF_INET6, self.local_ip6)
|
|
self.local_ip6_prefix_len = 64
|
|
self.has_ip6_config = False
|
|
self.ip6_table_id = 0
|
|
|
|
r = self.test.vapi.sw_interface_dump()
|
|
for intf in r:
|
|
if intf.sw_if_index == self.sw_if_index:
|
|
self._name = intf.interface_name.split(b'\0', 1)[0]
|
|
self._local_mac = \
|
|
':'.join(intf.l2_address.encode('hex')[i:i + 2]
|
|
for i in range(0, 12, 2))
|
|
self._dump = intf
|
|
break
|
|
else:
|
|
raise Exception(
|
|
"Could not find interface with sw_if_index %d "
|
|
"in interface dump %s" %
|
|
(self.sw_if_index, repr(r)))
|
|
self._local_ip6_ll = mk_ll_addr(self.local_mac)
|
|
self._local_ip6n_ll = socket.inet_pton(socket.AF_INET6,
|
|
self.local_ip6_ll)
|
|
|
|
def config_ip4(self):
|
|
"""Configure IPv4 address on the VPP interface."""
|
|
self.test.vapi.sw_interface_add_del_address(
|
|
self.sw_if_index, self.local_ip4n, self.local_ip4_prefix_len)
|
|
self.has_ip4_config = True
|
|
|
|
def unconfig_ip4(self):
|
|
"""Remove IPv4 address on the VPP interface."""
|
|
try:
|
|
if self.has_ip4_config:
|
|
self.test.vapi.sw_interface_add_del_address(
|
|
self.sw_if_index,
|
|
self.local_ip4n,
|
|
self.local_ip4_prefix_len,
|
|
is_add=0)
|
|
except AttributeError:
|
|
self.has_ip4_config = False
|
|
self.has_ip4_config = False
|
|
|
|
def configure_ipv4_neighbors(self):
|
|
"""For every remote host assign neighbor's MAC to IPv4 addresses.
|
|
|
|
:param vrf_id: The FIB table / VRF ID. (Default value = 0)
|
|
"""
|
|
for host in self._remote_hosts:
|
|
macn = host.mac.replace(":", "").decode('hex')
|
|
ipn = host.ip4n
|
|
self.test.vapi.ip_neighbor_add_del(
|
|
self.sw_if_index, macn, ipn)
|
|
|
|
def config_ip6(self):
|
|
"""Configure IPv6 address on the VPP interface."""
|
|
self.test.vapi.sw_interface_add_del_address(
|
|
self.sw_if_index, self._local_ip6n, self.local_ip6_prefix_len,
|
|
is_ipv6=1)
|
|
self.has_ip6_config = True
|
|
|
|
def unconfig_ip6(self):
|
|
"""Remove IPv6 address on the VPP interface."""
|
|
try:
|
|
if self.has_ip6_config:
|
|
self.test.vapi.sw_interface_add_del_address(
|
|
self.sw_if_index,
|
|
self.local_ip6n,
|
|
self.local_ip6_prefix_len,
|
|
is_ipv6=1, is_add=0)
|
|
except AttributeError:
|
|
self.has_ip6_config = False
|
|
self.has_ip6_config = False
|
|
|
|
def configure_ipv6_neighbors(self):
|
|
"""For every remote host assign neighbor's MAC to IPv6 addresses.
|
|
|
|
:param vrf_id: The FIB table / VRF ID. (Default value = 0)
|
|
"""
|
|
for host in self._remote_hosts:
|
|
macn = host.mac.replace(":", "").decode('hex')
|
|
ipn = host.ip6n
|
|
self.test.vapi.ip_neighbor_add_del(
|
|
self.sw_if_index, macn, ipn, is_ipv6=1)
|
|
|
|
def unconfig(self):
|
|
"""Unconfigure IPv6 and IPv4 address on the VPP interface."""
|
|
self.unconfig_ip4()
|
|
self.unconfig_ip6()
|
|
|
|
def set_table_ip4(self, table_id):
|
|
"""Set the interface in a IPv4 Table.
|
|
|
|
.. note:: Must be called before configuring IP4 addresses.
|
|
"""
|
|
self.ip4_table_id = table_id
|
|
self.test.vapi.sw_interface_set_table(
|
|
self.sw_if_index, 0, self.ip4_table_id)
|
|
|
|
def set_table_ip6(self, table_id):
|
|
"""Set the interface in a IPv6 Table.
|
|
|
|
.. note:: Must be called before configuring IP6 addresses.
|
|
"""
|
|
self.ip6_table_id = table_id
|
|
self.test.vapi.sw_interface_set_table(
|
|
self.sw_if_index, 1, self.ip6_table_id)
|
|
|
|
def disable_ipv6_ra(self):
|
|
"""Configure IPv6 RA suppress on the VPP interface."""
|
|
self.test.vapi.sw_interface_ra_suppress(self.sw_if_index)
|
|
|
|
def ip6_ra_config(self, no=0, suppress=0, send_unicast=0):
|
|
"""Configure IPv6 RA suppress on the VPP interface."""
|
|
self.test.vapi.ip6_sw_interface_ra_config(self.sw_if_index,
|
|
no,
|
|
suppress,
|
|
send_unicast)
|
|
|
|
def ip6_ra_prefix(self, address, address_length, is_no=0,
|
|
off_link=0, no_autoconfig=0, use_default=0):
|
|
"""Configure IPv6 RA suppress on the VPP interface."""
|
|
self.test.vapi.ip6_sw_interface_ra_prefix(self.sw_if_index,
|
|
address,
|
|
address_length,
|
|
is_no=is_no,
|
|
off_link=off_link,
|
|
no_autoconfig=no_autoconfig,
|
|
use_default=use_default)
|
|
|
|
def admin_up(self):
|
|
"""Put interface ADMIN-UP."""
|
|
self.test.vapi.sw_interface_set_flags(self.sw_if_index,
|
|
admin_up_down=1)
|
|
|
|
def admin_down(self):
|
|
"""Put interface ADMIN-down."""
|
|
self.test.vapi.sw_interface_set_flags(self.sw_if_index,
|
|
admin_up_down=0)
|
|
|
|
def ip6_enable(self):
|
|
"""IPv6 Enable interface"""
|
|
self.test.vapi.ip6_sw_interface_enable_disable(self.sw_if_index,
|
|
enable=1)
|
|
|
|
def ip6_disable(self):
|
|
"""Put interface ADMIN-DOWN."""
|
|
self.test.vapi.ip6_sw_interface_enable_disable(self.sw_if_index,
|
|
enable=0)
|
|
|
|
def add_sub_if(self, sub_if):
|
|
"""Register a sub-interface with this interface.
|
|
|
|
:param sub_if: sub-interface
|
|
"""
|
|
if not hasattr(self, 'sub_if'):
|
|
self.sub_if = sub_if
|
|
else:
|
|
if isinstance(self.sub_if, list):
|
|
self.sub_if.append(sub_if)
|
|
else:
|
|
self.sub_if = sub_if
|
|
|
|
def enable_mpls(self):
|
|
"""Enable MPLS on the VPP interface."""
|
|
self.test.vapi.sw_interface_enable_disable_mpls(
|
|
self.sw_if_index)
|
|
|
|
def disable_mpls(self):
|
|
"""Enable MPLS on the VPP interface."""
|
|
self.test.vapi.sw_interface_enable_disable_mpls(
|
|
self.sw_if_index, 0)
|
|
|
|
def is_ip4_entry_in_fib_dump(self, dump):
|
|
for i in dump:
|
|
if i.address == self.local_ip4n and \
|
|
i.address_length == self.local_ip4_prefix_len and \
|
|
i.table_id == self.ip4_table_id:
|
|
return True
|
|
return False
|
|
|
|
def set_unnumbered(self, ip_sw_if_index):
|
|
""" Set the interface to unnumbered via ip_sw_if_index """
|
|
self.test.vapi.sw_interface_set_unnumbered(
|
|
self.sw_if_index,
|
|
ip_sw_if_index)
|
|
|
|
def unset_unnumbered(self, ip_sw_if_index):
|
|
""" Unset the interface to unnumbered via ip_sw_if_index """
|
|
self.test.vapi.sw_interface_set_unnumbered(
|
|
self.sw_if_index,
|
|
ip_sw_if_index,
|
|
is_add=0)
|
|
|
|
def set_proxy_arp(self, enable=1):
|
|
""" Set the interface to enable/disable Proxy ARP """
|
|
self.test.vapi.proxy_arp_intfc_enable_disable(
|
|
self.sw_if_index,
|
|
enable)
|