�

�;f��.�dd
lm
Z

Gd�de��ZdS)�
)
�	RecordSetc�>�eZ
dZd	d�
Zd
d�
Zdd�
Zdd�
Zdd�
Zdd�
ZdS)�Query�rawc�"�|
|_||_
dS�
N)�_schema�_fmt)�self�schema�fmts   �E/opt/alt/python311/lib/python3.11/site-packages/pyroute2/ndb/query.py�__init__zQuery.__init__s�������	�	�	�Nc#�h
K
�|p|j}|d
kro|rd�
|�
�
V�

|
D]Q}|r||�
�
}t|ttf��r"d�
d�|D���
�
V�

�M|V�

�RdS|dkr|r|V�

|
D]}|r||�
�
}|V�

�dStd�
�
�
)N�csv�
,c
�,�g|]}
t
|
�
�
��S�)
�str)�.0�
xs  r�
<listcomp>z$Query._formatter.<locals>.<listcomp>s��#;�#;�#;�q�C�
�F�F�#;�#;�#;rrzformat not supported)r
�join�
isinstance�list�tuple�	TypeError)r�cursorr
�header�	transform�records      r�
_formatterzQuery._formatter	s
������T�Y���%�<�<��

'��h�h�v�&�&�&�&�&� �
!�
!���
/�&�Y�v�.�.�F��f�t�U�m�4�4�!��(�(�#;�#;�F�#;�#;�#;�<�<�<�<�<�<� �L�L�L�L�

!�
!��E�\�\��

����� �
�
���
/�&�Y�v�.�.�F������
�
�
�2�3�3�3rc�~�d
}t
|�
|j�d�
�
|
|���
�
S)z8
        List all the nodes within the cluster.
        )
�nodenamezJ
            SELECT DISTINCT f_target
            FROM interfaces
        �rr#r	�fetch�rr
r s   r�nodeszQuery.nodes sN������O�O���"�"������	
�	
�
�
�	
rc�~�d
}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
        r&r(s   r�	p2p_edgeszQuery.p2p_edges2sN��
-����O�O���"�"��
�
���
�
�
�
�	
rc�~�d
}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.
        )r+�left_ifname�left_lladdrr,�right_ifname�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
        r&r(s   r�l2_edgeszQuery.l2_edgesJsP��
����O�O���"�"����0��5
�
�
�
�	
rc�~�d
}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.
        )�source_node�gateway_node�gateway_address�dst�dst_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)
        r&r(s   r�l3_edgeszQuery.l3_edgessP��
����O�O���"�"����*��/
�
�
�
�	
r)
r)NNNr)	�__name__�
__module__�__qualname__rr#r)r-r3r:rrrrrs�����������4�4�4�4�.
�
�
�
�$
�
�
�
�03
�3
�3
�3
�j
+
�+
�+
�+
�+
�+
rrN)�reportr�objectrrrr�<module>r@
sU�


�������f

�f

�f

�f

�f

�F�f

�f

�f

�f

�f

r