summaryrefslogtreecommitdiffstats
path: root/test/vpp_neighbor.py
blob: ffe87d93b586655ae8f6cf851767f43a01feba65 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
"""
  Neighbour Entries

  object abstractions for ARP and ND
"""

from ipaddress import ip_address
from vpp_object import VppObject
from vpp_papi import mac_pton, VppEnum
try:
    text_type = unicode
except NameError:
    text_type = str


def find_nbr(test, sw_if_index, nbr_addr, is_static=0, mac=None):
    ip_addr = ip_address(text_type(nbr_addr))
    e = VppEnum.vl_api_ip_neighbor_flags_t
    nbrs = test.vapi.ip_neighbor_dump(sw_if_index=sw_if_index,
                                      af=ip_addr.vapi_af)

    for n in nbrs:
        if ip_addr == n.neighbor.ip_address and \
           is_static == (n.neighbor.flags & e.IP_API_NEIGHBOR_FLAG_STATIC):
            if mac:
                if mac == str(n.neighbor.mac_address):
                    return True
            else:
                return True
    return False


class VppNeighbor(VppObject):
    """
    ARP Entry
    """

    def __init__(self, test, sw_if_index, mac_addr, nbr_addr,
                 is_static=False, is_no_fib_entry=False):
        self._test = test
        self.sw_if_index = sw_if_index
        self.mac_addr = mac_addr
        self.nbr_addr = nbr_addr

        e = VppEnum.vl_api_ip_neighbor_flags_t
        self.flags = e.IP_API_NEIGHBOR_FLAG_NONE
        if is_static:
            self.flags |= e.IP_API_NEIGHBOR_FLAG_STATIC
        if is_no_fib_entry:
            self.flags |= e.IP_API_NEIGHBOR_FLAG_NO_FIB_ENTRY

    def add_vpp_config(self):
        r = self._test.vapi.ip_neighbor_add_del(
            self.sw_if_index,
            self.mac_addr,
            self.nbr_addr,
            is_add=1,
            flags=self.flags)
        self.stats_index = r.stats_index
        self._test.registry.register(self, self._test.logger)
        return self

    def remove_vpp_config(self):
        self._test.vapi.ip_neighbor_add_del(
            self.sw_if_index,
            self.mac_addr,
            self.nbr_addr,
            is_add=0,
            flags=self.flags)

    def is_static(self):
        e = VppEnum.vl_api_ip_neighbor_flags_t
        return (self.flags & e.IP_API_NEIGHBOR_FLAG_STATIC)

    def query_vpp_config(self):
        return find_nbr(self._test,
                        self.sw_if_index,
                        self.nbr_addr,
                        self.is_static())

    def object_id(self):
        return ("%d:%s" % (self.sw_if_index, self.nbr_addr))

    def get_stats(self):
        c = self._test.statistics.get_counter("/net/adjacency")
        return c[0][self.stats_index]
(EBADE, "Invalid exchange") _ (EBADR, "Invalid request descriptor") _ (EXFULL, "Exchange full") _ (ENOANO, "No anode") _ (EBADRQC, "Invalid request code") _ (EBADSLT, "Invalid slot") _ (EBFONT, "Bad font file format") _ (ENOSTR, "Device not a stream") _ (ENODATA, "No data available") _ (ETIME, "Timer expired") _ (ENOSR, "Out of streams resources") _ (ENONET, "Machine is not on the network") _ (ENOPKG, "Package not installed") _ (EREMOTE, "Object is remote") _ (ENOLINK, "Link has been severed") _ (EADV, "Advertise error") _ (ESRMNT, "Srmount error") _ (ECOMM, "Communication error on send") _ (EPROTO, "Protocol error") _ (EMULTIHOP, "Multihop attempted") _ (EDOTDOT, "RFS specific error") _ (EBADMSG, "Not a data message") _ (EOVERFLOW, "Value too large for defined data type") _ (ENOTUNIQ, "Name not unique on network") _ (EBADFD, "File descriptor in bad state") _ (EREMCHG, "Remote address changed") _ (ELIBACC, "Can not access a needed shared library") _ (ELIBBAD, "Accessing a corrupted shared library") _ (ELIBSCN, "lib section in a.out corrupted") _ (ELIBMAX, "Attempting to link in too many shared libraries") _ (ELIBEXEC, "Cannot exec a shared library directly") _ (EILSEQ, "Illegal byte sequence") _ (ERESTART, "Interrupted system call should be restarted") _ (ESTRPIPE, "Streams pipe error") _ (EUSERS, "Too many users") _ (ENOTSOCK, "Socket operation on non-socket") _ (EDESTADDRREQ, "Destination address required") _ (EMSGSIZE, "Message too long") _ (EPROTOTYPE, "Protocol wrong type for socket") _ (ENOPROTOOPT, "Protocol not available") _ (EPROTONOSUPPORT, "Protocol not supported") _ (ESOCKTNOSUPPORT, "Socket type not supported") _ (EOPNOTSUPP, "Operation not supported on transport endpoint") _ (EPFNOSUPPORT, "Protocol family not supported") _ (EAFNOSUPPORT, "Address family not supported by protocol") _ (EADDRINUSE, "Address already in use") _ (EADDRNOTAVAIL, "Cannot assign requested address") _ (ENETDOWN, "Network is down") _ (ENETUNREACH, "Network is unreachable") _ (ENETRESET, "Network dropped connection because of reset") _ (ECONNABORTED, "Software caused connection abort") _ (ECONNRESET, "Connection reset by peer") _ (ENOBUFS, "No buffer space available") _ (EISCONN, "Transport endpoint is already connected") _ (ENOTCONN, "Transport endpoint is not connected") _ (ESHUTDOWN, "Cannot send after transport endpoint shutdown") _ (ETOOMANYREFS, "Too many references: cannot splice") _ (ETIMEDOUT, "Connection timed out") _ (ECONNREFUSED, "Connection refused") _ (EHOSTDOWN, "Host is down") _ (EHOSTUNREACH, "No route to host") _ (EALREADY, "Operation already in progress") _ (EINPROGRESS, "Operation now in progress") _ (ESTALE, "Stale NFS file handle") _ (EUCLEAN, "Structure needs cleaning") _ (ENOTNAM, "Not a XENIX named type file") _ (ENAVAIL, "No XENIX semaphores available") _ (EISNAM, "Is a named type file") _ (EREMOTEIO, "Remote I/O error") _ (EDQUOT, "Quota exceeded") _ (ENOMEDIUM, "No medium found") _ (EMEDIUMTYPE, "Wrong medium type")