File: //opt/alt/python37/lib/python3.7/site-packages/exabgp/netlink/__pycache__/old.cpython-37.pyc
B
RP�e�a � @ s\ d dl Z d dlZd dlmZ d dlmZ d dlmZ d dlmZ d dlm Z ye
ed� W n e k
rv e d��Y nX G d d
� d
e
�ZG d d � d e�ZG d
d� de�ZG dd� de�ZG dd� de
�ZG dd� de�ZG dd� de
�ZG dd� de
�ZG dd� de�ZG dd � d e�ZG d d � d e�ZG d d � d e�ZG d!d"� d"e�Z G d#d$� d$e�Z dS )%� N)�pack)�unpack)�calcsize)�
namedtuple)�concat_bytes_i�
AF_NETLINKz;This module only works on unix version with netlink supportc " @ sT e Zd Zddddddddd d
d d d
ddddddddddddddd d d d d d!d"�!Zd#S )$�NetMaskz255.255.255.255z255.255.255.254z255.255.255.252z255.255.255.248z255.255.255.240z255.255.255.224z255.255.255.192z255.255.255.128z
255.255.255.0z
255.255.254.0z
255.255.252.0z
255.255.248.0z
255.255.240.0z
255.255.224.0z
255.255.192.0z
255.255.128.0z 255.255.0.0z 255.254.0.0z 255.252.0.0z 255.248.0.0z 255.240.0.0z 255.224.0.0z 255.192.0.0z 255.128.0.0z 255.0.0.0z 254.0.0.0z 252.0.0.0z 248.0.0.0z 240.0.0.0z 224.0.0.0z 192.0.0.0z 128.0.0.0z0.0.0.0)!� � � � � � � � � � � � � � � � � � � �
� � �
� � � � � � � � � r N)�__name__�
__module__� __qualname__ZCIDR� r, r, �C/opt/alt/python37/lib/python3.7/site-packages/exabgp/netlink/old.pyr sB r c @ s e Zd ZdS )� GlobalErrorN)r) r* r+ r, r, r, r- r. > s r. c @ s e Zd ZdS )� NetLinkErrorN)r) r* r+ r, r, r, r- r/ B s r/ c @ s e Zd Ze� Zdd� ZdS )�Sequencec C s" | j �dd�d | j d< | j d S )N�nextr r( )� _instance�get)�clsr, r, r- �__new__I s zSequence.__new__N)r) r* r+ �dictr2 r5 r, r, r, r- r0 F s r0 c @ s� e Zd ZdZdZedd�Ze�� Z e
�
e
j e
j e�Z
G dd� de�ZG dd� de�ZG d d
� d
e�Zejd ejd iZed
d� �Zedd� �Zee
jfdd��ZdS )� NetLinkRouteTr �Messageztype flags seq pid datac @ s e Zd ZdZee�ZdS )zNetLinkRoute.HeaderZIHHIIN)r) r* r+ �PACKr �LENr, r, r, r- �HeaderW s r; c @ s e Zd ZdZdZdZdZdS )zNetLinkRoute.Commandr( r' r& r% N)r) r* r+ Z
NLMSG_NOOP� NLMSG_ERROR�
NLMSG_DONE�
NLMSG_OVERRUNr, r, r, r- �Command\ s r? c @ s@ e Zd ZdZdZdZdZdZdZeeB Z dZ
dZ dZ dZ
dZd S )
zNetLinkRoute.Flagsr( r' r% r! � i i i N)r) r* r+ �
NLM_F_REQUESTZ NLM_F_MULTIZ NLM_F_ACKZ
NLM_F_ECHOZ
NLM_F_ROOTZ NLM_F_MATCH�
NLM_F_DUMPZ NLM_F_ATOMICZ
NLM_F_REPLACE�
NLM_F_EXCL� NLM_F_CREATEZ NLM_F_APPENDr, r, r, r- �Flagsb s rE z
netlink errorznetlink overrunc C sB t �|�}| jjt|� t|� }t| jj||||| j�| | S )N)�
Attributes�encoder; r: �lenr r9 �pid)r4 �dtype�seq�flags�body�
attributes�attrs�lengthr, r, r- rG y s
zNetLinkRoute.encodec c sr xl|rlt | jj|d | jj� �\}}}}}t|�|k r>td��| �|||||| jj|� �V ||d � }qW d S )NzBuffer underrun)r r; r9 r: rH r/ �format)r4 �datarP ZntyperL rK rI r, r, r- �decode s $ zNetLinkRoute.decodec c s� t � }| �|||td|�i �}| j�|� xz| j�d�}xh| �|�D ]Z\}}} }
}| |krj| jrbqDtd��|t j
j kr~t � �qD|| j
kr�t| j
| ��qD|V qDW q,W d S )NZBxxxi � znetlink seq mismatch)r0 rG r �netlink�send�recvrS �_IGNORE_SEQ_FAULTSr/ r7 r? r= �
StopIteration�errors) r4 rJ Zhflags�family�sequence�messagerR �mtyperL rK rI r, r, r- rU � s
zNetLinkRoute.sendN)r) r* r+ rW �
NETLINK_ROUTEr rQ �os�getpidrI �socketr �SOCK_RAWrT �objectr; r? rE r< r> rY � classmethodrG rS � AF_UNSPECrU r, r, r, r- r7 N s
r7 c @ s e Zd ZdS )�AttributesErrorN)r) r* r+ r, r, r, r- rf � s rf c @ sD e Zd ZG dd� de�ZG dd� de�Zedd� �Zedd� �Zd S )
rF c @ s e Zd ZdZee�ZdS )zAttributes.HeaderZHHN)r) r* r+ r9 r r: r, r, r, r- r; � s r; c @ s, e Zd ZdZdZdZdZdZdZdZ dZ
d S )
zAttributes.Typer r( r' r& r% r$ r# r" N) r) r* r+ Z
IFA_UNSPECZ IFA_ADDRESSZ IFA_LOCALZ IFA_LABELZ
IFA_BROADCASTZ IFA_ANYCASTZ
IFA_CACHEINFOZ
IFA_MULTICASTr, r, r, r- �Type� s rg c c s� x||r|t | jj|d | jj� �\}}t|�|k rDtdt|�|f ��|| jj|� }||fV |t|d d �d d � }qW d S )NzBuffer underrun %d < %dr& r% )r r; r9 r: rH rf �int)r4 rR rP �atype�payloadr, r, r- rS � s
zAttributes.decodec s& �fdd�� t � fdd�|�� D ��S )Nc sR ddd�}� j jt|� }t� j j|| �| }||�t|� }|rN|d| 7 }|S )Nr% c S s | | d |d @ S )Nr( r, )rP �tor, r, r- �pad� s z/Attributes.encode.<locals>._encode.<locals>.pad� )r% )r; r: rH r r9 )ri rj rl rP �raw)r4 r, r- �_encode� s
z"Attributes.encode.<locals>._encodec 3 s | ]\}}� ||�V qd S )Nr, )�.0�k�v)ro r, r- � <genexpr>� s z$Attributes.encode.<locals>.<genexpr>)r �items)r4 rN r, )ro r4 r- rG � s zAttributes.encodeN) r) r* r+ rc r; rg rd rS rG r, r, r, r- rF � s
rF c @ sR e Zd Zedd�ZG dd� de�Zdd� Zdd� Ze j
j e j
j B e
jfd d
�Zd S ) �_MessageZParentzto be subclassedc @ s e Zd ZdZdZdS )z_Message.Header� r N)r) r* r+ r9 r: r, r, r, r- r; � s r; c C s
|| _ d S )N)�route)�selfrw r, r, r- �__init__� s z_Message.__init__c C sL t t| jj|d | jj� ��}t�|| jjd � �}|�t|�� | j |� S )N)
�listr r; r9 r: rF rS �appendr6 rQ )rx rR Z extractedrN r, r, r- rS � s z_Message.decodec c s* x$| j �|||�D ]}| �|�V qW d S )N)rw rU rS )rx ri rL rZ rR r, r, r- �extract� s z_Message.extractN)r) r* r+ r rQ rc r; ry rS r7 rE rA rB ra re r| r, r, r, r- ru � s
ru c @ sN e Zd ZG dd� de�Zedd�ZG dd� de�ZG dd� de�Zd d
� Z d S ) �Linkc @ s e Zd ZdZee�ZdS )z Link.HeaderZBxHiIIN)r) r* r+ r9 r r: r, r, r, r- r; � s r; ZInfoz)family type index flags change attributesc @ s e Zd ZdZdZdZdZdS )z Link.Commandr r r r N)r) r* r+ Z RTM_NEWLINKZ RTM_DELLINK� RTM_GETLINKZ RTM_SETLINKr, r, r, r- r? � s r? c @ s< e Zd ZG dd� de�ZG dd� de�ZG dd� de�ZdS )z Link.Typec @ s e Zd ZejZejZdS )zLink.Type.FamilyN)r) r* r+ ra �AF_INET�AF_INET6r, r, r, r- �Family s r� c @ sX e Zd ZdZdZdZdZdZdZdZ dZ
d Z d
Z d Z
d Zd
ZdZdZdZdZdZdZdS )zLink.Type.Devicer( r' r% r! r r �@ � r@ i i i i i i @ i � i i i N)r) r* r+ ZIFF_UPZ
IFF_BROADCASTZ IFF_DEBUGZ IFF_LOOPBACKZIFF_POINTOPOINTZIFF_NOTRAILERSZ IFF_RUNNINGZ IFF_NOARPZ IFF_PROMISCZ IFF_ALLMULTIZ
IFF_MASTERZ IFF_SLAVEZ
IFF_MULTICASTZ IFF_PORTSELZ
IFF_AUTOMEDIAZ IFF_DYNAMICZ IFF_LOWER_UPZ IFF_DORMANTZIFF_ECHOr, r, r, r- �Device
s& r� c @ s, e Zd ZdZdZdZdZdZdZdZ dZ
d S )
zLink.Type.Attributer r( r' r& r% r$ r# r" N) r) r* r+ � IFLA_UNSPEC� IFLA_ADDRESS�IFLA_BROADCAST� IFLA_IFNAME�IFLA_MTU� IFLA_LINK�
IFLA_QDISC�
IFLA_STATSr, r, r, r- � Attribute! s r� N)r) r* r+ rc r� r� r� r, r, r, r- rg s rg c C s | � tjj�S )N)r| r} r? r~ )rx r, r, r- �getLinks+ s z
Link.getLinksN)
r) r* r+ rc r; r rQ r? rg r� r, r, r, r- r} � s
&r} c @ sN e Zd ZG dd� de�Zed d�ZG dd� de�ZG dd� de�Zdd � Z d
S ) �Addressc @ s e Zd ZdZee�ZdS )zAddress.HeaderZ4BiN)r) r* r+ r9 r r: r, r, r, r- r; 9 s r; z-family prefixlen flags scope index attributesc @ s e Zd ZdZdZdZdS )zAddress.Commandr r r N)r) r* r+ Z RTM_NEWADDRZ RTM_DELADDR� RTM_GETADDRr, r, r, r- r? ? s r? c @ sL e Zd ZG dd� de�ZG dd� de�ZG dd� de�ZG dd� de�Zd S )
z Address.Typec @ s e Zd ZejZejZdS )zAddress.Type.FamilyN)r) r* r+ ra r r� r, r, r, r- r� E s r� c @ s e Zd ZdZdZdZdZdS )zAddress.Type.Flagr N)r) r* r+ ZIFA_F_SECONDARYZIFA_F_PERMANENTZIFA_F_DEPRECATEDZIFA_F_TENTATIVEr, r, r, r- �FlagI s r� c @ s e Zd ZdZdZdZdZdZdS )zAddress.Type.Scoper N)r) r* r+ �RT_SCOPE_UNIVERSE�
RT_SCOPE_SITE�
RT_SCOPE_LINK�
RT_SCOPE_HOST�RT_SCOPE_NOWHEREr, r, r, r- �ScopeQ s
r� c @ st e Zd ZdZdZdZdZdZdZdZ dZ
d Z d
Z d Z
d Zd
ZdZdZdZdZdZdZdZdZdZdZdZdZdZ dS ) zAddress.Type.Attributer r( r' r& r% r$ r# r" r! r r r r r r r r r r r r r r r r r N) r) r* r+ r� r� r� r� r� r� r� r� Z IFLA_COSTZ
IFLA_PRIORITYZ IFLA_MASTERZ
IFLA_WIRELESSZ
IFLA_PROTINFOZ IFLA_TXQLENZIFLA_MAPZ IFLA_WEIGHTZIFLA_OPERSTATEZ
IFLA_LINKMODEZ
IFLA_LINKINFOZIFLA_NET_NS_PIDZ IFLA_IFALIASZ IFLA_NUM_VFZIFLA_VFINFO_LISTZ IFLA_STATS64Z
IFLA_VF_PORTSZIFLA_PORT_SELFr, r, r, r- r� X s4 r� N)r) r* r+ rc r� r� r� r� r, r, r, r- rg D s rg c C s | � tjj�S )N)r| r� r? r� )rx r, r, r- � getAddressest s zAddress.getAddressesN)
r) r* r+ rc r; r rQ r? rg r� r, r, r, r- r� 8 s
0r� c @ sN e Zd ZG dd� de�Zed d�ZG dd� de�ZG dd� de�Zdd � Z d
S ) �Neighborc @ s e Zd ZdZee�ZdS )zNeighbor.HeaderZBxxxiHBBN)r) r* r+ r9 r r: r, r, r, r- r; � s r; z(family index state flags type attributesc @ s e Zd ZdZdZdZdS )zNeighbor.Commandr
r r N)r) r* r+ Z RTM_NEWNEIGHZ RTM_DELNEIGH� RTM_GETNEIGHr, r, r, r- r? � s r? c @ sL e Zd ZG dd� de�ZG dd� de�ZG dd� de�ZG dd� de�Zd S )
z
Neighbor.Typec @ s e Zd ZejZejZdS )zNeighbor.Type.FamilyN)r) r* r+ ra r r� r, r, r, r- r� � s r� c @ s0 e Zd ZdZdZdZdZdZdZdZ dZ
d Z d
S ) zNeighbor.Type.Stater( r' r% r! r r r� r� r N) r) r* r+ ZNUD_INCOMPLETEZ
NUD_REACHABLEZ NUD_STALEZ NUD_DELAYZ NUD_PROBEZ
NUD_FAILEDZ NUD_NOARPZ
NUD_PERMANENTZNUD_NONEr, r, r, r- �State� s r� c @ s e Zd ZdZdZdZdS )zNeighbor.Type.Flagr( r! r� N)r) r* r+ ZNTF_USEZ NTF_PROXYZ
NTF_ROUTERr, r, r, r- r� � s r� c @ s e Zd ZdZdZdZdZdZdS )zNeighbor.Type.Attributer r( r' r& r% N)r) r* r+ Z
NDA_UNSPECZNDA_DSTZ
NDA_LLADDRZ
NDA_CACHEINFOZ
NDA_PROBESr, r, r, r- r� � s
r� N)r) r* r+ rc r� r� r� r� r, r, r, r- rg � s rg c C s | � tjj�S )N)r| r� r? r� )rx r, r, r- � getNeighbors� s zNeighbor.getNeighborsN)
r) r* r+ rc r; r rQ r? rg r� r, r, r, r- r� � s
r� c @ s^ e Zd ZG dd� de�Zedd�ZG dd� de�ZG dd� de�Zd d
� Z d d � Z
d
d� Z dS )�Networkc @ s e Zd ZdZee�ZdS )zNetwork.HeaderZ8BIN)r) r* r+ r9 r r: r, r, r, r- r; � s r; r� zBfamily src_len dst_len tos table proto scope type flags attributesc @ s e Zd ZdZdZdZdS )zNetwork.Commandr r r N)r) r* r+ � RTM_NEWROUTE� RTM_DELROUTE� RTM_GETROUTEr, r, r, r- r? � s r? c @ sl e Zd ZG dd� de�ZG dd� de�ZG dd� de�ZG dd� de�ZG d d
� d
e�ZG d d � d e�Z d
S )z Network.Typec @ s e Zd ZdZdZdZdZdS )zNetwork.Type.Tabler � � � N)r) r* r+ ZRT_TABLE_UNSPECZRT_TABLE_DEFAULT�
RT_TABLE_MAINZRT_TABLE_LOCALr, r, r, r- �Table� s r� c @ sH e Zd ZdZdZdZdZdZdZdZ dZ
d Z d
Z d Z
d Zd
ZdZdZdS )zNetwork.Type.Protocolr r( r' r& r% r! r r r r r r r r r N)r) r* r+ Z
RTPROT_UNSPECZRTPROT_REDIRECTZ
RTPROT_KERNELZ RTPROT_BOOTZ
RTPROT_STATICZ RTPROT_GATEDZ RTPROT_RAZ
RTPROT_MRTZ RTPROT_ZEBRAZ RTPROT_BIRDZRTPROT_DNROUTEDZ RTPROT_XORPZ
RTPROT_NTKZ RTPROT_DHCP�
RTPROT_EXABGPr, r, r, r- �Protocol� s r� c @ s e Zd ZdZdZdZdZdZdS )zNetwork.Type.Scoper �� r� r� r� N)r) r* r+ r� r� r� r� r� r, r, r, r- r� � s
r� c @ s< e Zd ZdZdZdZdZdZdZdZ dZ
d Z d
Z d Z
d Zd
S )zNetwork.Type.Typer r( r' r& r% r$ r# r" r! r r r N)r) r* r+ Z
RTN_UNSPECZ RTN_UNICASTZ RTN_LOCALZ
RTN_BROADCASTZ RTN_ANYCASTZ
RTN_MULTICASTZ
RTN_BLACKHOLEZRTN_UNREACHABLEZ RTN_PROHIBITZ RTN_THROWZRTN_NATZ RTN_XRESOLVEr, r, r, r- rg � s rg c @ s e Zd ZdZdZdZdZdS )zNetwork.Type.Flagr@ i i i N)r) r* r+ Z RTM_F_NOTIFYZ RTM_F_CLONEDZRTM_F_EQUALIZE� RTM_F_PREFIXr, r, r, r- r� � s r� c @ s@ e Zd ZdZdZdZdZdZdZdZ dZ
d Z d
Z d Z
d Zd
ZdS )zNetwork.Type.Attributer r( r' r& r% r$ r# r" r! r r r r N)r) r* r+ Z
RTA_UNSPECZRTA_DSTZRTA_SRCZRTA_IIFZRTA_OIFZ RTA_GATEWAYZ RTA_PRIORITYZ RTA_PREFSRCZ RTA_METRICSZ
RTA_MULTIPATHZRTA_FLOWZ
RTA_CACHEINFOZ RTA_TABLEr, r, r, r- r� s r� N)
r) r* r+ rc r� r� r� rg r� r� r, r, r, r- rg � s rg c C s | � tjj�S )N)r| r� r? r� )rx r, r, r- � getRoutes s zNetwork.getRoutesc c s� t jj}|t jjO }|t jjO }tj}t� }| �|dddt j
j j t j
j
jt j
jjdt j
jj|�
}x | �t jj||�D ]
}|V qtW d S )Nr r )r7 rE rA rD rC ra r rF rQ r� rg r� r� r� r� r� r� r� r� r| r? r� )rx Z
network_flagsrZ rN Zneighbor�_r, r, r- �newRoute s$ zNetwork.newRoutec C s | � tjj�S )N)r| r� r? r� )rx r, r, r- �delRoute9 s zNetwork.delRouteN) r) r* r+ rc r; r rQ r? rg r� r� r� r, r, r, r- r� � s
J r� c @ s< e Zd ZG dd� de�ZG dd� de�ZG dd� de�ZdS )�TCc @ s e Zd ZdZee�ZdS )z TC.HeaderZBxxxiIIIN)r) r* r+ r9 r r: r, r, r, r- r; M s r; c @ s e Zd ZdZdZdZdS )z
TC.Command�$ �% �& N)r) r* r+ Z RTM_NEWQDISCZ RTM_DELQDISCZ RTM_GETQDISCr, r, r, r- r? Q s r? c @ s e Zd ZG dd� de�ZdS )zTC.Typec @ s, e Zd ZdZdZdZdZdZdZdZ dZ
d S )
zTC.Type.Attributer r( r' r& r% r$ r# r" N) r) r* r+ Z
TCA_UNSPECZTCA_KINDZ TCA_OPTIONSZ TCA_STATSZ
TCA_XSTATSZTCA_RATEZTCA_FCNTZ
TCA_STATS2r, r, r, r- r� W s r� N)r) r* r+ rc r� r, r, r, r- rg V s rg N)r) r* r+ rc r; r? rg r, r, r, r- r� L s r� c @ s, e Zd ZG dd� de�ZG dd� de�ZdS )�Firewallc @ s e Zd ZdZee�ZdS )zFirewall.HeaderZBxxxIN)r) r* r+ r9 r r: r, r, r, r- r; � s r; c @ s e Zd ZG dd� de�ZdS )zFirewall.Packetc @ s e Zd ZdZee�ZdS )zFirewall.Packet.HeaderZ
IIIIIIIHHHHIIN)r) r* r+ r9 r r: r, r, r, r- r; � s r; N)r) r* r+ rc r; r, r, r, r- �Packet� s r� N)r) r* r+ rc r; r� r, r, r, r- r� � s r� ) r_ ra �structr r r � collectionsr Z exabgp.utilr �getattr�AttributeError� ImportErrorrc r � Exceptionr. r/ rh r0 r7 rf rF ru r} r� r� r� r� r� r, r, r, r- �<module> s2 &U)&BK: <