B

��f�@s dd
lm
Z

Gdd�de�ZdS)�
)
�	RecordSetc@sHeZ
dZddd�
Zddd�
Zddd�
Zdd	d
�
Zddd�
Zdd
d�
ZdS)�Query�rawcCs|
|_||_
dS)
N)�_schema�_fmt)�selfZschema�fmt�r	�C/opt/alt/python37/lib/python3.7/site-packages/pyroute2/ndb/query.py�__init__s

zQuery.__init__Nccs�|p|j}|d
krj|r"d�
|�
V
x�|
D]<}|r8||�
}t|ttf�r^d�
dd�|D�
�
V
q(|V
q(Wn<|dkr�|r||V
x(|
D]}|r�||�
}|V
q�Wntd�
�
dS)N�csv�
,c
Ssg|]}
t|
�
�qSr	)
�str)�.0�
xr	r	r
�
<listcomp>sz$Query._formatter.<locals>.<listcomp>rzformat not supported)r�join�
isinstance�list�tuple�	TypeError)r�cursorr�headerZ	transform�recordr	r	r
�
_formatter	s$

















zQuery._formattercCsd
}t|�
|j�d�
|
|��
S)z8
        List all the nodes within the cluster.
        )
�nodenamezJ
            SELECT DISTINCT f_target
            FROM interfaces
        )rrr�fetch)rrrr	r	r
�nodes s



zQuery.nodescCsd
}t|�
|j�d�
|
|��
S)zc
        List point to point edges within the cluster, like
        GRE or PPP interfaces.
        )�	left_node�
right_nodez�
            SELECT DISTINCT
                l.f_target, r.f_target
            FROM p2p AS l
            INNER JOIN p2p AS r
            ON
                l.f_p2p_local = r.f_p2p_remote
                AND l.f_target != r.f_target
        )rrrr)rrrr	r	r
�	p2p_edges2s


	
zQuery.p2p_edgescCsd
}t|�
|j�d�
|
|��
S)a�

        List l2 links within the cluster, reconstructed
        from the ARP caches on the nodes. Works as follows:

        1. for every node take the ARP cache
        2. for every record in the cache reconstruct two triplets:

        * the interface index -> the local interface name
        * the neighbour lladdr -> the remote node and interface name

        Issues: does not filter out fake lladdr, so CARP interfaces
        produce fake l2 edges within the cluster.
        )rZleft_ifnameZleft_lladdrrZright_ifnameZright_lladdra�
        SELECT DISTINCT
            j.f_target, j.f_IFLA_IFNAME, j.f_IFLA_ADDRESS,
            d.f_target, d.f_IFLA_IFNAME, j.f_NDA_LLADDR
        FROM
            (SELECT
                n.f_target, i.f_IFLA_IFNAME,
                i.f_IFLA_ADDRESS, n.f_NDA_LLADDR
             FROM
                neighbours AS n
             INNER JOIN
                interfaces AS i
             ON
                n.f_target = i.f_target
                AND i.f_IFLA_ADDRESS != '00:00:00:00:00:00'
                AND n.f_ifindex = i.f_index) AS j
        INNER JOIN
            interfaces AS d
        ON
            j.f_NDA_LLADDR = d.f_IFLA_ADDRESS
            AND j.f_target != d.f_target
        )rrrr)rrrr	r	r
�l2_edgesJs


zQuery.l2_edgescCsd
}t|�
|j�d�
|
|��
S)aG

        List l3 edges. For every address on every node look
        if it is used as a gateway on remote nodes. Such cases
        are reported as l3 edges.

        Issues: does not report routes (edges) via point to point
        connections like GRE where local addresses are used as
        gateways. To be fixed.
        )Zsource_nodeZgateway_nodeZgateway_address�dstZdst_lena
            SELECT DISTINCT
                r.f_target, a.f_target, a.f_IFA_ADDRESS,
                r.f_RTA_DST, r.f_dst_len
            FROM
                addresses AS a
            INNER JOIN
                routes AS r
            ON
                r.f_target != a.f_target
                AND r.f_RTA_GATEWAY = a.f_IFA_ADDRESS
                AND r.f_RTA_GATEWAY NOT IN
            (SELECT
                f_IFA_ADDRESS
             FROM
                addresses
             WHERE
                f_target = r.f_target)
        )rrrr)rrrr	r	r
�l3_edgess


zQuery.l3_edges)
r)NNN)
N)
N)
N)
N)	�__name__�
__module__�__qualname__rrrr r!r#r	r	r	r
rs





5rN)�reportr�objectrr	r	r	r
�<module>
s