File: //opt/alt/python37/lib/python3.7/site-packages/pyroute2/ipdb/__pycache__/interfaces.cpython-37.pyc
B
��f�� � @ s� d dl Z d dlZd dlZd dlmZmZ d dlmZ d dlmZm Z d dl
m Z d dl m
Z
mZmZmZ d dlmZ d dlmZmZmZ d d lmZ d d
lmZmZm Z d d l m Z d d l m Z d d
l!m"Z"m#Z# da$e j%e j&B e j'B e j(B Z)dd� Z*dd� Z+G dd� de�Z,G dd� de
�Z-G dd� de.�Z/G dd� de.�Z0de-i d �d edd d � d �d �d!edd"d � d �d �d#e/i d �d$e0i d �gZ1dS )%� N)�AF_INET�AF_INET6)�error)� inet_ntop� inet_pton)�config)�Dotkeys�View�
basestring�dqn2int)� AF_BRIDGE)�CommitException�CreateException�PartialCommitException)� LinkedSet)� SYNC_TIMEOUT�
Transactional�with_transaction)�rtnl)� NetlinkError)�IFF_MASK�ifinfmsg)
�bridgeZbondZtuntap�vxlanZgreZgretapZip6greZ ip6gretapZmacvlanZmacvtapZipvlanZvrfZvtic sj g } x`t D ]X}tjj�|�� � d k r
t� dd �d k rN| � fdd�� jD �7 } q
| dd� � jD �7 } q
W | S )N�prefixc s g | ]}� � |d ��qS )r )�nla2name)�.0�i)�msg� �I/opt/alt/python37/lib/python3.7/site-packages/pyroute2/ipdb/interfaces.py�
<listcomp>: s z$_get_data_fields.<locals>.<listcomp>c S s g | ]}t �|d ��qS )r )r r )r r r r r r! < s )�supported_kindsr �ifinfoZdata_map�get�getattr�nla_map)�ret�datar )r r �_get_data_fields2 s
r) c C s t | | �dk S )N� )�abs)�x�yr r r �_br_time_check@ s r. c s� e Zd ZdZdd� eeeeeeeeed�
Zddddd d
d d gZd
d� ejD �Z x.dD ]&Z
e ej e
�Z
e �dd� e
jD �� qTW e �d� e �d� e �d� e �d� e �d� e �d� e �d� e �d� e �d� e �e� � e �e� dPdd �Zd d � Zed d � �Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd)d*� Zd+d,� Zd-d.� Ze dQd/d0��Z e dRd1d2��Z e dSd3d4��Z e d5d6� �Z e d7d8� �Z!e d9d:� �Z"d;d<� Z#� fd=d>�Z$d?d@� Z%dAdB� Z&dTdFdG�Z'dHdI� Z(dJdK� Z)dLdM� Z*dNdO� Z+� Z,S )U� Interfacea�
Objects of this class represent network interface and
all related objects:
* addresses
* (todo) neighbours
* (todo) routes
Interfaces provide transactional model and can act as
context managers. Any attribute change implicitly
starts a transaction. The transaction can be managed
with three methods:
* review() -- review changes
* rollback() -- drop all the changes
* commit() -- try to apply changes
If anything will go wrong during transaction commit,
it will be rolled back authomatically and an
exception will be raised. Failed transaction review
will be attached to the exception.
c C s | |@ t @ |t @ kS )N)r )r, r- r r r �<lambda>[ � zInterface.<lambda>)
�flagsZ
br_hello_timeZ
br_max_ageZbr_ageing_timeZbr_forward_delayZbr_mcast_membership_intvlZbr_mcast_querier_intvlZbr_mcast_query_intvlZ br_mcast_query_response_intvlZ br_mcast_startup_query_intvl�
ipdb_scope�
ipdb_priority�vlans�ipaddr�ports�
vlan_flags� net_ns_fd�
net_ns_pidc C s g | ]}t �|d ��qS )r )r r )r r r r r r! p s zInterface.<listcomp>)Zbridge_slave_datac C s g | ]}t �|d ��qS )r )r r )r r r r r r! s s �indexr2 �mask�change�kind�peer�vlan_id�
vlan_protocol� bond_modeNc C s� t �| ||� d| _d| _d| _d| _g | _d| _d| _d| _ d| _
| j � d� | j � d� | j � d� d| _
t� | _t� | _| j�D xdD ]
}| |= q�W | j�� | d< t� | d< t� | d< d| d < W dQ R X dS )
zc
Parameters:
* ipdb -- ipdb() reference
* mode -- transaction mode
) �header�linkinfo�protinfoZaf_spec�attrs�event�map�statsZstats64r= Z__alignNFr6 r7 r5 )r= r< r r4 )r �__init__�cleanupZingressZegress�nlmsg�errors�partial�
_exception�_deferred_linkZ_tbZ _linked_sets�add�_freeze�set�_delay_add_port�_delay_del_port�
_direct_state�ipdb� _ipaddr_setr )�selfrW �mode�parent�uidr r r r rJ � s.
zInterface.__init__c C s | d S )Nr; r )rY r r r �__hash__� s zInterface.__hash__c C s | � dd�S )zI
[property] Link to the parent interface -- if it exists
�masterN)r$ )rY r r r � if_master� s zInterface.if_masterc C s | j j�| d | d | j� | S )N�ifnamer; )rW �
interfaces�_detachrL )rY r r r �detach� s zInterface.detachc s: �j d k rtd����� � � �fdd�}�j�|��_ �S )Nz the interface is frozen alreadyc sB |� dd�� d kr>y�j� ddd� W n tk
r< Y nX d S )Nr; ���� )� transaction� commit_phase� commit_mask)r$ �commit� Exception)rW r �action)�dumprY r r �cb� s z Interface.freeze.<locals>.cb)rR � RuntimeError�pickrW Zregister_callback)rY rm r )rl rY r �freeze� s
zInterface.freezec C s | j �| j� d | _| S )N)rW Zunregister_callbackrR )rY r r r �unfreeze� s zInterface.unfreezec C s �x|D �]}|| dkr q|dkrnx| d D ]}| j |� q.W x�|| D ] }t|t�r^|f}| j|� qJW q|dkr�x| d D ]}| �|� q�W x~|| D ]}| �|� q�W q|dkr�x| d D ]}| �|� q�W x<|| D ]}|dkr�| �|� q�W q|dk�rq|| | |< qW | S )a�
Load the data from a dictionary to an existing
transaction. Requires `commit()` call, or must be
called from within a `with` statement.
Sample::
data = json.loads(...)
with ipdb.interfaces['dummy1'] as i:
i.load(data)
Sample, mode `explicit::
data = json.loads(...)
i = ipdb.interfaces['dummy1']
i.begin()
i.load(data)
i.commit()
Nr6 r7 r5 � )�
neighbours�family)�del_ip�
isinstancer
�add_ip�del_port�add_port�del_vlan�add_vlan)rY r( �key�addr�port�vlanr r r �load� s2
zInterface.loadc C s | j � | �|� W dQ R X dS )z�
Update the interface info from a dictionary.
This call always bypasses open transactions, loading
changes directly into the interface data.
N)rV r� )rY r( r r r � load_dict s zInterface.load_dictc C s� | j ��� | d dkrdS | d dkrV|d d dkr:dS tjd dk rV|�d �sVdS x |�� D ]\}}|| |< q`W x4|d
D ](}t�|d �}|| jkr~|d | |< q~W |�d �}|dk �rn|�d
�}|dk �rn|| d< |dk�r"|�d�}|�d�| d< |�d�| d< |�di ��dd�| d< |t k�rn|�d��p:i }x0|�d
g �D ] } t�| d �}| d | |< �qJW |d t
k�rR|�d �}
|
dk �r|
� d�} i } x| D ]}
|
| |
d < �q�W t | �
� �}x | d | D ]}| �|� �q�W x$|| d D ]}| �| | � �q�W |�d �}|dk �rRx.|d
D ]"\}}|d d� �� }|| |< �q,W | jdk �r�| jj| d | d < | jj| d | d < x | jD ]}|| k�r�| |= �q�W | �d!d�| d k�r�d| d!< d"| d< W dQ R X dS )#z�
Update the interface info from RTM_NEWLINK message.
This call always bypasses open transactions, loading
changes directly into the interface data.
r3 �lockedN)�shadow�createrC Zsequence_numberr � Z IFLA_AF_SPECrF rr Z
IFLA_LINKINFOZIFLA_INFO_KINDr> r ZIFLA_INFO_DATAZ IFLA_VLAN_IDr@ ZIFLA_VLAN_PROTOCOLrA ZIFLA_VLAN_FLAGSr2 r8 rt ZIFLA_BRIDGE_VLAN_INFO�vidr5 Z
IFLA_PROTINFOr* r; r6 rs r^ �system)rV r �kernel�get_attr�itemsr r rK r$ r" r � get_attrsrS �keysrz r{ �lowerrW r6 rs )rY �dev�name�value�cellZnormrD r> r( Znla�specr5 Zvmapr Zvidsr� rE �attr�itemr r r � load_netlink sv
zInterface.load_netlinkc O s | d j ||�S )Nr6 )�wait_ip)rY �argv�kwargr r r r� l s zInterface.wait_ipc C s� d}|dkr|� d�\}}|�d�dkr>t}tttt|��}nt}t|t�rryt|d�}W n t ||�}Y nX | d �
||f� i }|dk r�||d< |dk r�||d< |dk r�||d < | d j ||f|d
� dS ) a�
Add IP address to an interface
Address formats:
with ipdb.interfaces.eth0 as i:
i.add_ip('192.168.0.1', 24)
i.add_ip('192.168.0.2/24')
i.add_ip('192.168.0.3/255.255.255.0')
i.add_ip('192.168.0.4/24',
broadcast='192.168.0.255',
scope=254)
r N�/�:rd r6 � broadcast�anycast�scope)�raw) �split�findr r r r rv r
�intr �unlinkrQ )rY �ipr< r� r� r� rt �requestr r r rw o s*
zInterface.add_ipc C s� |dkr8|� d�\}}|�d�dkr.t|�}n
t|d�}|�d�dkrVtttt|��}||f| d kr�| d �||f� | d �||f� dS )z5
Delete IP address from an interface
Nr� �.rd r r� r6 ) r� r� r r� r r r r� �remove)rY r� r< r r r ru � s
zInterface.del_ipc C sJ t |t�r|d }n|}|dd�}| d �|� | d j|||fd� d S )Nr� r )r� r2 r5 )r� )rv �dictr� rQ )rY r r2 r� r r r r{ � s
zInterface.add_vlanc C s, || d kr(| d � |� | d �|� d S )Nr5 )r� r� )rY r r r r rz � s zInterface.del_vlanc C s< | � |�}|s | j�|� n | d �|� | d �|� dS )z1
Add port to a bridge or bonding
r7 N)�
_resolve_portrT rQ r� )rY r~ �ifindexr r r ry � s
zInterface.add_portc C s< | � |�}|s | j�|� n | d �|� | d �|� dS )z6
Remove port from a bridge or bonding
r7 N)r� rU rQ r� r� )rY r~ r� r r r rx � s
zInterface.del_portc C sJ d}x@|rD| j �| d �}|r0| �|d � P q|d8 }t�d� qW | S )z.
Reload interface information
r� r; r rr )�nl� get_linksr� �time�sleep)rY � countdown�linksr r r �reload� s zInterface.reloadc s� t t| ��� }| j}| d dkrV|d |d< |d |d< |d |d< |d= |d= |d= |jr�td d
� |jD ��}d|kr�|d |O < n||d< |jr�td d
� |jD ��}d |kr�|d |O < n||d < |S )
Nr3 r� r6 z+ipaddrr7 z+portsr5 z+vlansc S s g | ] }d | �qS )z*%sr )r r, r r r r! � s z$Interface.review.<locals>.<listcomp>c S s g | ] }d | �qS )z*%sr )r r, r r r r! � s z-ports)�superr/ �review�
current_txrT rS rU )rY r' �lastr7 )� __class__r r r� � s( zInterface.reviewc
O sL y
|||�S t k
rF } z | jr2| j�|� g S |�W d d }~X Y nX d S )N)rj rN rM �append)rY �cmdr� r� r r r r �_run� s
zInterface._runc C s. t |t�r|d S | jj�|i ��dd �S d S )Nr; )rv r/ rW ra r$ )rY r~ r r r r� s
zInterface._resolve_portrr � Fc -
sV ||@ s �S d}d}d}�j j} d}
d} dddd�} |s<�r@d}
|rP�j| �n
�pX�j��jrfg �_�j��� �d dk�r"�d dkr��d dkr���� �S d}��dd� �y�j rڈj \}
}��
|��|
< d�_ �d d
k�r
�j � d�d < d�d < W dQ R X �� � } yh�fd d
�t
dd� ��D ��x8dD ]0}|�k�r6�j � d�|< �|= W dQ R X �q6W �jjd`�� W nH tk
�r� } z(|jtjk�r��d dk�r�|}n� W dd}~X Y nX W nZ tk
�r } z:�j�r��j�|� t� �n| �r|
�r���j� � W dd}~X Y nX W dQ R X �d dk�r�|dk�r��d �r��j jd�d d�}�j � d�d< W dQ R X �jjd�d d� |�� ���� �S |�rX|dk�r��� d��s�| �r�|
�rڈ��j� ��� t |t��r�|�nt � �x(�j j �d D ]}�d � |� �q W y ��!�jjda��d � W n tk
�rV Y nX �� � }|dk�r�t"�j d ��r�g �_#xR�j j#�
d �d i�D ]8}t$|d! d"d�d#k�r��j#�|d$ |d$ � � f� �q�W d%d&� }|��j%�j&�| �o�|
� |��j'�j(�| �o
|
� �
y |� \}}�j)}�j}|d' �s>|d' �r2�d' ��d' � x4|d' D ](}||j*d(�d �d' | d d)� �qZW x�|d' D ]v}�d' | d }�d' | d }�d |d)�} |d*k�r�|| d+< �j � ��+|d, � W dQ R X ||j*df| � �q�W �d' j,�t-� �d' j,�.� �s2t/d-��|d. �sF|d. �rh�d. ��d. � x`|d. D ]T}|�j j0k�r��j j0| �d/d��1d/d0� ||jd1|d d2� n�j�t2|�� �qbW xh|d. D ]\}|�j j0k�r�j j0| �d/�d ��1d/d0� ||jd1|�d d2� n�j�t2|�� �q�W �d. j,�t-� �d. j,�.� �rnx0�jj3�d d�D ]} ��!| � �qXW nt/d3��x�t4|d. �t4|d. � D ]�}�j j0| } | j5d/ } | �t-� | j� | j5d/= | j5d0= W dQ R X | �.� �s�t/d4��||d. k�r| j6�d k�r(t/d5��n| j6�d k�r(t/d6���d d7k�r��d8 | d8 k�r���d8| d8 � �� d8� �q�W i �i � i ��d �d< �d � d< d} x�|�7� D ]�\}}!|!dk �r�|�j8k�r�|dk�r�|dd9� d:k�r�|| � |< n\|dd;� d<k�r
|| �|d;d� < n4|d k�r2|| dk �r2|| �9� �|< || �|< �q�W d�d< d� d< �d d7k�r�t:� fd=d>�� D ���r��d � d< �d � d< t;� d?< d} ||jd@f� � t:�fdAd>��D ��� r,�d �d< �d �d< ��<d d�d
k� r��=d � ��=d d� d} ||jd1f�� dB�k� r,��>� t:�fdCd>��D ��� r`�d �d< ||j?d@f�� | � rv�j� sv��@� |�<d+�dk � r�||jd@fdD�d |d+ dE�� �x�tAd9�D �]n}"�d �d }#�d �d }$|#� s�|$� s�P �d ��d � tB|$�fdFd�ddG�}%x�|%D ]�}y$||jCd�d |d |d dH� W n� tk
�
rp } z|jtjDk�
r`� W dd}~X Y nN tEk
�
r� } z.t |jFd tG��
r�|jFd �HdI��
r��
w� W dd}~X Y nX �
qW x�|#D ]�}y"tIdJd>� �d | �7� D ��}&W n t2k
� r
d}&Y nX yB|&� pi }&�d |&d< |d |&d < |d |&dK< ||jCdf|&� W n4 tk
� r� } z|jtjk� rr� W dd}~X Y nX �
q�W �dL d@ � r�t"�j jdM�� r�x&t4�d jJ�D ]}�d �K|� � q�W x,�jjL�d tMdN�D ]}�j j �N|� � q�W �d j,�t-� �d j,�.� � r�P � q�W t/dO��x(�jOD ] }'|'��P� |�P� ��P� � � q6W dP|k� sldQ|k�
r8i �x$dD ] }||k� rv|| �|< � qvW �d �d< ||jd1f�� dR}(x�|(�
r6y�j�Q�d � W nL tk
�
r } z|jtjRk� r�P � W dd}~X Y n tk
�
r � Y nX |(d8 }(tS�TdS� � q�W |�<d�dTk�
r��j jd�d d�}�j � d�d< W dQ R X �jjd�d d� |�� �j � dU�d< W dQ R X |dk�
rj �UdV� |�<d�dk�
r�j j0�Vd�d d� |
�
r����j� �S |dk�r�j �UdV� d} W �n@ tk
�r\ } �z |}tW�X� | dW< �| dX< d| dY< |dk�r�|�rfd} y �jY|�rv| n|dZ||d[� W n2 tk
�r� }) z|)| dY< tZ� }W dd})~)X Y nX nt�j�Q� }*x |*D ]}+�j j0�N|+� �q�W �j�3� }*x |*D ]}+�j j0�N|+� �q�W x"�j�L� D ]}�j j �N|� �qW xd\D ]}�| �[� �q6W W dd}~X Y nX �j�rv�j�rvtd]�}| �r�|
�r����j� |dk �r�| |_\|�|dZk�r@x��j#D ]�},|,d j � d^|,d d< W dQ R X y |,d jY|,d dZdZd_� W nB tZk
�r8 } z"t |j]t��r(|j]jtjk�r(W dd}~X Y nX �q�W tS�Tt^j_� g �_�S )bzz
Commit transaction. In the case of exception all
changes applied during commit will be reverted.
NT)� tracebackrf �
next_stageFr3 r� r� r� �addressz00:00:00:00:00:00r� c s" i | ]}� | d k r� | |�qS )Nr )r r| )rf r r �
<dictcomp>O s z$Interface.commit.<locals>.<dictcomp>c S s0 | d d� dko.| d d� dko.| d d� dkS )Nr* Zbond_� �brport_r� �br_r )r, r r r r0 R s z"Interface.commit.<locals>.<lambda>)r9 r: rQ r> )r r rr r; � RTM_DELLINKr` )r` r� �delete)r; r6 r$ r �routesZoifr| �tabler� �routec
S s� dd� }xtt |�D ]h}|�|�}|sV| jr<| j�||�� qz|rL|�| j� ||��q|�|� | j� ||� W d Q R X qW d S )Nc S s t d| �S )Nzcan not resolve port %s)�KeyError)r, r r r r � s z6Interface.commit.<locals>.resolve_ports.<locals>.error) �tupler� rN rM r� �dropr\ r� rV )rf r7 �callbackrY r� r r~ r� r r r �
resolve_ports� s
z'Interface.commit.<locals>.resolve_portsr5 �del)r; Z vlan_inforY r8 r� zvlans target is not setr7 r^ �link�update)r; r^ zports target is not setzmaster target failedzmaster set failedzmaster unset failedr Zmtur� r� r� r� c s g | ]}� | d k �qS )Nr )r r� )�brequestr r r! e s z$Interface.commit.<locals>.<listcomp>rt rS c s g | ]}� | d k �qS )Nr )r r� )r� r r r! m s Zifaliasc s g | ]}� | d k �qS )Nr )r r� )�prequestr r r! z s r )r> r; r8 c s � d | d S )Nr6 r2 r )r, )rY r r r0 � r1 )r| �reverse)r; r� � prefixlenz
illegal IPc S s g | ]}|d dkr|�qS )r )r� r� r� r )r �kr r r r! � s r� r2 Znetns)r; rt zipaddr target is not setr9 r: �
g�������?)r� r� r� �runr� rf r� re )rf rg rh �newif)r6 r7 r5 zpartial commit error�restore)rf rg rh )rQ )r$ )`rW ZtxdropZ global_txr� rN rM Z _write_lockZ
invalidateZ
set_targetrP r� rV ro �filterr� r� r �code�errno�EEXISTrj r� r r� r\ Zwatchdog�waitr� Z wait_targetrv r r6 rQ r� �hasattrr� r% rT ry rU rx r� Z vlan_filterr{ �targetr �is_setr
ra Z
mirror_targetr� � get_vlans�listZ_local_targetsr_ r� �_virtual_fieldsr� �anyr r$ �popr� ZbrportZwait_all_targets�range�sortedr} Z
EADDRNOTAVAIL� socket_error�argsr
�
startswithr� Zipv6r� �get_addrr �_newZ
_commit_hooksrl r� ZENODEVr� r� Zensurerb r� �
format_excri rn Z clear_target�debug�causer Zcommit_barrier)-rY �tidrf rg rh r� r �added�removedr� Znotx�initr� Zlink_keyZlink_objr| r, �e�wdr} �snapshot�recordr� r� r� r Zvinfor2 �reqr r~ r� Zwait_allr� �_Zip2addZ ip2removeZripr� �chr� Zi_er� r� r� r )r� r� r� rY rf r ri
s�
$
zInterface.commitc C s d| d< | S )z?
Shortcut: change the interface state to 'up'.
�up�stater )rY r r r r� � s z Interface.upc C s d| d< | S )zA
Shortcut: change the interface state to 'down'.
�downr� r )rY r r r r� � s zInterface.downc C s d| d< | S )z0
Mark the interface for removal
r� r3 r )rY r r r r� � s zInterface.removec C s d| d< | S )a�
Remove the interface from the OS, but leave it in the
database. When one will try to re-create interface with
the same name, all the old saved attributes will apply
to the new interface, incl. MAC-address and even the
interface index. Please be aware, that the interface
index can be reused by OS while the interface is "in the
shadow state", in this case re-creation will fail.
r� r3 r )rY r r r r� � s
zInterface.shadow)NNN)NNNN)N)N)NNrr r� F)-�__name__�
__module__� __qualname__�__doc__r. Z _fields_cmpr� r r& �_fieldsr� r% r# r( �extendr� r) rJ r] �propertyr_ rc rp rq r� r� r� r� r rw ru r{ rz ry rx r� r� r� r� ri r� r� r� r� �
__classcell__r r )r� r r/ D s�
- 0
^ +
{r/ c @ sB e Zd Zdd� Zdd� Zddd�Zdd � Zdd
d �Zdd
d�Zd S )�InterfacesDictc C s || _ | j| jd�| _d S )N)Z RTM_NEWLINKr� )rW r� �_del�
_event_map)rY rW r r r rJ � s zInterfacesDict.__init__c C sh | j j�� }x|D ]}| j|dd� qW x|D ]}| �|� q.W | j j�� }x|D ]}| �|� qRW d S )NT)� skip_master)rW r� r� r� r� )rY r� r� r r r � _register� s
zInterfacesDict._registerFc
K s� | j j��z || kr�| | d dks(|rv| | }||d< |�|� | | d dkrl|j� d|d< W dQ R X |�� n td| ��n�t| j dd� }| |< xf|D ]^}|d d� d
kr�t|| t�r�|| �d �p�|| �d �||< t|| t �s�||| f|_
q�W | j j |_ |j�V ||d< |�d d
�|d < ||d < d|d< x&dD ] }||k�rB|�
|�||< �qBW W dQ R X |�� |�|� W dQ R X |S )z.
Create new network interface
r3 r� r> r� Nzinterface %s existsr� )rW rZ ���r� r; r` r )r? r\ �gidZifrrZ rB r� )rW � exclusiver� rV �beginr r/ rv r$ r� rP rZ �_moder� r� )rY r> r` Zreuser� �devicer| r� r r r rQ � sD
zInterfacesDict.addc C s� | � |d �}|d krd S |d tkrX|j�& x t|d �D ]}|�|� q<W W d Q R X t|dd �r�|j� d|d< W d Q R X d S |� d�dkr�d S | �d |d |� d S )Nr; rt r5 rR r� r3 )r� r� )r$ r rV r� rz r% rb )rY r r� r r r r r � s zInterfacesDict._delc C s* |� dd �}|�dd �}d }d }|| krN|| krNt| jd� } | |< | |< n�|| kr�|| kr�| | d }| | }| |< || kr�|}|| jjkr�| jj| | jj|< | jj|= || jjkr�| jj| | jj|< | jj|= n(| | d }||kr�|}| | }| |< || jjk�r$| j�� | jj|< || jjk�r@t� | jj|< |� dd �} |�d�}
| |
k�r�| | k�r�| | j�& || | d k�r�| | � |� W d Q R X |
| k�r�|
|k�r�| |
j� | |
�
|� W d Q R X |d k �r�| |= |�r�|� d� |� |� |
d k�r&|j� d |d< W d Q R X d S )Nr; Z IFLA_IFNAME)rW r` r^ Z IFLA_MASTERr7 )
r$ r� r/ rW r6 rs rX r rV rx ry �stripr� ) rY r r r; r` r rK Z old_indexZold_nameZ
old_masterZ
new_masterr r r r� sV
zInterfacesDict._newNc
C s | j j�� |d k r.|d dkr.|d dkr.d S |d ks>|dk rP| | }|d }n| | }|d }|�dd �}|| kr�|d | | d kr�| | j� | | �|� W d Q R X | �|d � | �|d � | j j�|d � | j j�|d � |j� d
|d < W d Q R X W d Q R X d S ) NrG r� r= l �� rr r; r` r^ r7 Zdetachedr3 )rW r r$ rV rx r� r6 rs )rY r� �idxr r� r^ r r r rb Q s(
zInterfacesDict._detach)F)F)N) r� r� r� rJ r rQ r r� rb r r r r r � s
5
Hr c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd S ) �
AddressesDictc C s || _ | j| jd�| _d S )N)Z RTM_NEWADDRZ RTM_DELADDR)rW r� r r )rY rW r r r rJ m s zAddressesDict.__init__c C s$ x | j j�� D ]}| �|� qW d S )N)rW r� r� r� )rY r r r r r q s zAddressesDict._registerc
C s� x | � � D ]}| j�� | |< q
W x | jj�� D ]}| �|� q.W x:| � � D ].}| jj| }|j� | | |d< W d Q R X qJW d S )Nr6 )r� rW rX r� r� r� ra rV )rY r� r r Ziffr r r r� u s zAddressesDict.reloadc C s� |d t kr|�d�}n*|d tkr>|�d�}|sB|�d�}nd S |�d�|�d�|�d�|�d�pl|�d�|d |d |�d�d �}y"| |d
j||d f|d � W n Y nX d S ) Nrt � IFA_LOCAL� IFA_ADDRESSZ
IFA_BROADCASTZ IFA_FLAGSr2 r� Z
IFA_CACHEINFO)�localr� r� r2 r� rt Z cacheinfor; )r| r� )r r� r r$ rQ )rY r r} r� r r r r� � s$
"zAddressesDict._newc C sd |d t kr|�d�}n |d tkr0|�d�}nd S y | |d �||d f� W n Y nX d S )Nrt r r r; r� )r r� r r� )rY r r} r r r r � s zAddressesDict._delN)r� r� r� rJ r r� r� r r r r r r l s
r c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S )
�NeighboursDictc C s || _ | j| jd�| _d S )N)Z RTM_NEWNEIGHZ RTM_DELNEIGH)rW r� r r )rY rW r r r rJ � s zNeighboursDict.__init__c C s$ x | j j�� D ]}| �|� qW d S )N)rW r� Zget_neighboursr� )rY r r r r r � s zNeighboursDict._registerc C sL |d t krd S y*| |d j|�d�d|�d�id� W n Y nX d S )Nrt r� �NDA_DSTZlladdrZ
NDA_LLADDR)r| r� )r rQ r� )rY r r r r r� � s zNeighboursDict._newc C s> |d t krd S y | |d �|�d�� W n Y nX d S )Nrt r� r )r r� r� )rY r r r r r � s zNeighboursDict._delN)r� r� r� rJ r r� r r r r r r � s r ra )r� �classr� Zby_namec C s
t | t�S )N)rv r
)r� �vr r r r0 � r1 r0 )�path�
constraintZby_indexc C s
t | t�S )N)rv r� )r� r r r r r0 � r1 r6 rs )2r� r� r� �socketr r r r� r r Zpyroute2r Zpyroute2.commonr r r
r Zpyroute2.configr Zpyroute2.ipdb.exceptionsr
r r Zpyroute2.ipdb.linkedsetr Zpyroute2.ipdb.transactionalr r r Zpyroute2.netlinkr Zpyroute2.netlink.exceptionsr Z pyroute2.netlink.rtnl.ifinfmsgr r r" Z RTMGRP_LINKZ RTMGRP_NEIGHZRTMGRP_IPV4_IFADDRZRTMGRP_IPV6_IFADDR�groupsr) r. r/ r r� r r r� r r r r �<module> sT q @9$