Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/pyroute2/ndb/objects/__pycache__/interface.cpython-39.pyc
Ðазад
a ]�h�� � @ s� d Z ddlZddlZddlZddlmZ ddlmZ ddlm Z ddl m Z ddl m Z ddlmZ d d lmZmZ d d lmZ d d � ZdZe �� �dd��d�Ze �� �d��ddd�Z e �� �d��ddd�Z e j j �� �dd��dd��ddd�Z degdegde gde ggde gde gde gde j j gde gge egid�Z!d Z"d d � e"D �Z#e#�$� D ]V\Z%Z&d e% Z%e!d �'e%e&g� e&�� �dd!��d��ddd�Z(e!d" �'e%e(g� �q^d#d$� Z)G d%d&� d&e�Z*G d'd(� d(e�Z+dS ))a .. testsetup:: from pyroute2 import IPMock as IPRoute from pyroute2 import NDB from pyroute2 import config config.mock_iproute = True .. testsetup:: preset_1 from pyroute2 import NDB from pyroute2 import config config.mock_iproute = True ndb = NDB( sources=[ {'target': 'localhost', 'kind': 'IPMock'}, {'target': 'worker1.sample.com', 'kind': 'IPMock'}, {'target': 'worker2.sample.com', 'kind': 'IPMock'}, ] ) .. testsetup:: preset_br0_1 from pyroute2 import NDB from pyroute2 import config config.mock_iproute = True ndb = NDB() ndb.interfaces.create(ifname='eth1', kind='dummy').commit() ndb.interfaces.create(ifname='br0', kind='bridge').commit() ndb.interfaces.create(ifname='bond0', kind='bond').commit() .. testsetup:: preset_br0_2 from pyroute2 import NDB from pyroute2 import config config.mock_iproute = True ndb = NDB() ndb.interfaces.create(ifname='br0', kind='bridge').commit() ndb.interfaces['br0'].add_port('eth0').commit() List interfaces =============== List interface keys: .. testcode:: with NDB(log='on') as ndb: for key in ndb.interfaces: print(key) .. testoutput:: :hide: ('localhost', 0, 0, 772, 1, 1, 0, '00:00:00:00:00:00', '00:00:00:00:00:00', 'lo', 65536, None, 'noqueue', None, 1000, 'UNKNOWN', 0, None, None, None, 0, None, 0, 1, 1, 1, 0, None, None, 0, 65535, 65536, None, None, None, 0, 0, None, None, None, None, None, None, 65536, None, None, 'up', None, None, None, None, None, None, None, None, '[]') ('localhost', 0, 0, 772, 2, 1, 0, '52:54:00:72:58:b2', 'ff:ff:ff:ff:ff:ff', 'eth0', 1500, None, 'fq_codel', None, 1000, 'UNKNOWN', 0, None, None, None, 0, None, 0, 1, 1, 1, 0, None, None, 0, 65535, 65536, None, None, None, 0, 0, None, None, None, None, None, None, 65536, None, None, 'up', None, None, None, None, None, None, None, None, '[]') NDB views support some dict methods: `items()`, `values()`, `keys()`: .. testcode:: with NDB(log='on') as ndb: for key, nic in ndb.interfaces.items(): nic.set('state', 'up') nic.commit() Get interface objects ===================== The keys may be used as selectors to get interface objects: .. testcode:: with NDB() as ndb: for key in ndb.interfaces: print(ndb.interfaces[key]) .. testoutput:: :hide: :options: +ELLIPSIS ... Also possible selector formats are `dict()` and simple string. The latter means the interface name: .. testcode:: preset_1 eth0 = ndb.interfaces['eth0'] Dict selectors are necessary to get interfaces by other properties: .. testcode:: preset_1 wrk1_eth0 = ndb.interfaces[{'target': 'worker1.sample.com', 'ifname': 'eth0'}] wrk2_eth0 = ndb.interfaces[{'target': 'worker2.sample.com', 'address': '52:54:00:72:58:b2'}] Change nic properties ===================== Changing MTU and MAC address: .. testcode:: preset_1 with ndb.interfaces['eth0'] as eth0: eth0['mtu'] = 1248 eth0['address'] = '00:11:22:33:44:55' # --> <-- eth0.commit() is called by the context manager One can change a property either using the assignment statement, or using the `.set()` routine: .. testcode:: preset_1 # same code with ndb.interfaces['eth0'] as eth0: eth0.set('mtu', 1248) eth0.set('address', '00:11:22:33:44:55') Create virtual interfaces ========================= Create a bridge and add a port, `eth0`: .. testcode:: preset_1 with ndb.interfaces.create(ifname='br0', kind='bridge') as br0: br0.add_port('eth0') Bridge and bond ports ===================== Add bridge and bond ports one can use specific API: .. testcode:: preset_br0_1 with ndb.interfaces['br0'] as br0: br0.add_port('eth0') br0.add_port('eth1') br0.set('br_max_age', 1024) br0.set('br_forward_delay', 1500) with ndb.interfaces['bond0'] as bond0: bond0.add_port('eth0') bond0.add_port('eth1') To remove a port: .. testcode:: preset_br0_2 with ndb.interfaces['br0'] as br0: br0.del_port('eth0') Or by setting the master property on a port, in the same way as with `IPRoute`: .. testcode:: preset_br0_1 index = ndb.interfaces['br0']['index'] # add a port to a bridge with ndb.interfaces['eth0'] as eth0: eth0.set('master', index) # remove a port from a bridge with ndb.interfaces['eth0'] as eth0: eth0.set('master', 0) � N)� basestring)� AF_BRIDGE)� NetlinkError)�ifinfmsg)�p2pmsg)�LinkFieldFilter� )� AuthManager� check_auth)� RTNL_Objectc C s� |d d@ s6| � d| j| j| jf ||d |d f� |�d�rDd S |�d�}g |d< |d urz|�� D ]}|d �|� qf|d tk�r | �d ||� z|�d ��d �}W n t y� Y d S 0 | � d | j| jf ||d f� |D ]2}|d |d< d |d d i|d< | �d||� q�d S | �d||� |d �d d�d �s�|�d�}|d u�r�|�d�}d| } |dk�r�|�d�} | �d�} | �d�} t � } |d | d< d| d< d| fd| fg| d < | �d || � n�|d k�r�|�d �}|�d �}|�s�|f| � d!�v �r�| j � d"|d � z6| j| jd#d$|d d%�}t|�d }| �d||�W S t�y� } z,|jtjk�r~| j � d&|� �� W Y d }~n d }~0 0 | | jv �r�|�d�} | d u�r�i | d< |d | d< | �| || � d S )'N�flags� zKDELETE FROM routes WHERE f_target = %s AND f_RTA_OIF = %s OR f_RTA_IIF = %s�indexZ IFLA_WIRELESSZIFLA_PROP_LIST�alt_ifname_list�family� af_bridge_ifsZ IFLA_AF_SPECZIFLA_BRIDGE_VLAN_INFOz� DELETE FROM af_bridge_vlans WHERE f_target = %s AND f_index = %s �type�header�af_bridge_vlans� interfacesr r Z IFLA_LINKINFOZIFLA_INFO_KIND� ifinfo_%s�greZIFLA_INFO_DATAZIFLA_GRE_LOCALZIFLA_GRE_REMOTEZ P2P_LOCALZ P2P_REMOTE�attrs�p2p�veth� IFLA_LINK� IFLA_IFNAMEz SELECT f_target FROM SOURCESzreload veth %s�link�get�r zinterface has gone: )�execute�plchZget_attrr Zaltnames�appendr Z load_netlinkZ get_attrs�AttributeErrorr �fetch�log�debug�sources�api�tupler �code�errnoZENODEV�spec)�schema�target�eventZ prop_list�ifname�vlans�vZlinkinfoZiftype�tableZifdata�local�remoter r �update�e� r8 ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/pyroute2/ndb/objects/interface.py� load_ifinfmsg� s� �� � � � � � �( r: )r �gretap�ip6gre� ip6gretap�ip6tnl�sit�ipipr ZTEXTr Z interface)Zf_targetZf_tflagsZf_indexr ZINTEGER�vidr r r r1 )�specs�classes� event_map)�bridgeZbond�vlan�vxlanr r; r< r= r> r@ Zipvlanr? ZmacvlanZmacvtap�tunZvrfZvtiZvti6c C s i | ]}|t jj| �qS r8 )r ZifinfoZdata_map��.0�xr8 r8 r9 � <dictcomp>� � rL r rC ZBIGINTrB c C s: | d |krdS | d dkr6|d u r6t �| dd � dS dS )N�masterTr F)�dict� __setitem__)�self�valuer8 r8 r9 � _cmp_master� s rS c sl e Zd ZdZejjZdZe dd� �Z e dd� �Z e dd� �Z e d d � �Z� fd d �Zd d� Zdd� Z� ZS )�Vlanr Z vlan_filterc C sF |j r.|jj�d|j|jjjf |j d g�S |jj�d|j �S d S )Nz*SELECT count(*) FROM %s WHERE f_index = %sr �SELECT count(*) FROM %s��chain�ndb� task_manager� db_fetchoner3 r- r! ��cls�viewr8 r8 r9 �_count� s � ��z Vlan._countc C sB |j r2|jjj}d||f }|j d |j d g}nd}g }||fS )Nz� WHERE main.f_target = %s AND main.f_index = %s r. r � �rW rX r- r! �r\ r] r! �where�valuesr8 r8 r9 � _dump_where� s ��zVlan._dump_wherec c s< d}dV | � |�\}}|jj�|| |�D ] }|V q,d S )Nas SELECT main.f_target, main.f_tflags, main.f_vid, intf.f_IFLA_IFNAME FROM af_bridge_vlans AS main INNER JOIN interfaces AS intf ON main.f_index = intf.f_index AND main.f_target = intf.f_target )r. �tflagsrA r0 �rd rX rY Zdb_fetch�r\ r] �reqrb rc �recordr8 r8 r9 �summary� s z Vlan.summaryc C s t |t�r|| d kS d S )NrA )� isinstance�int)�left�rightr8 r8 r9 �compare_record� s zVlan.compare_recordc sp t jj|d< d|vs |d d u r(g |d< |d jj�d�}|d �tdddd�|�� tt | �j |i |�� d S )N�iclass� auth_managersr z vlan authTF)zobj:readzobj:list� obj:modify) r �af_spec_bridge� vlan_inforX r% Zchannelr" r �superrT �__init__)rQ �argv�kwargr% �� __class__r8 r9 rv � s ��z Vlan.__init__c C sD i }d| v r| d |d< d| d i|d< d| v r@| d |d d< |S )Nr rA rt r r8 )rQ �prime�retr8 r8 r9 �make_req� s z Vlan.make_reqc C s | � |�S �N)r} )rQ r{ r8 r8 r9 � make_idx_req� s zVlan.make_idx_req)�__name__� __module__� __qualname__r3 r rs rt � msg_classr( � classmethodr^ rd rj � staticmethodro rv r} r � __classcell__r8 r8 ry r9 rT � s rT c sV e Zd ZdZeZdZdgZg d�Zde iZ ddd� iZ e Z ed d � �Zed d � �Zed d� �Zdd� Z� fdd�Zedd� �Zedd� �Zedd� �Zedd� �Zedd � �Zed d � �Zed d � �Ze d!�d"d#� �Z e d!�d$d%� �Z e d!�d&d'� �Z e d!�d[d)d*��Z e d!�d\d+d,��Z!e d!�d]d-d.��Z"e d!�d^d/d0��Z#e d!�d_d1d2��Z$e d!�d`d3d4��Z%e d!�d5d6� �Z&e d!�d7d8� �Z'e d!�d9d:� �Z(e d!�d;d<� �Z)e d!�� fd=d>��Z*ed?d@� �Z+� fdAdB�Z,dCdD� Z-dEdF� Z.da� fdGdH� Z/� fdIdJ�Z0e d!�dKdL� �Z1e d!�db� fdOdP� �Z2dQdR� Z3dSdT� Z4� fdUdV�Z5� fdWdX�Z6dYdZ� Z7� Z8S )c� Interfacer r r )� vxlan_linkr rN rN r c C s t t�| p d��S )Nz[])�list�json�loads�rK r8 r8 r9 �<lambda>� rM zInterface.<lambda>c C sF |j r.|jj�d|j|jjjf |j d g�S |jj�d|j �S d S )Nz0SELECT count(*) FROM %s WHERE f_IFLA_MASTER = %sr rU rV r[ r8 r8 r9 r^ � s � ��zInterface._countc C sB |j r2|jjj}d||f }|j d |j d g}nd}g }||fS )Nz� WHERE f_target = %s AND f_IFLA_MASTER = %s r. r zWHERE f_index != 0r` ra r8 r8 r9 rd s ��zInterface._dump_wherec c s< d}dV | � |�\}}|jj�|| |�D ] }|V q,d S )Nz� SELECT f_target, f_tflags, f_index, f_IFLA_IFNAME, f_IFLA_ADDRESS, f_flags, f_IFLA_INFO_KIND FROM interfaces )r. re r r0 �addressr �kindrf rg r8 r8 r9 rj s zInterface.summaryc C s2 | j jfd }| j �d| || d | d f� d S )N� z� UPDATE interfaces SET f_tflags = %s WHERE f_index = %s AND f_target = %s r r. )r- r! r )rQ �markr! r8 r8 r9 � mark_tflags4 s ��zInterface.mark_tflagsc s� t |d< t di| _t� | _t�| dt� � t�| dd� g }t|d t��rRd|d v rl|�d� |d d= |d � d �r�d |d vr�t d ��|d � d �d k�rR|�d� d|d d < |d � d�dkr�d|d d< n(|d � d�dkr�d|d d< nt d��|d d= d|d v �r.|d � d�|d d< d|d v �rR|d � d�|d d< t t| �j|i |�� |D ]}| j�|� �qld S )Nrp � load_rtnlmsgr �state�unknownr Zreusez$ignore IPDB-specific `reuse` keyword�creater0 zspecify at least ifnamer� Ztuntapz+translated tuntap ifinfo into tun, no flagsrH �modeZtun_type�tapr ztun type error�uidZ tun_owner�gid)r rD �setZ_alt_ifname_origrO rP r� rk r" r � Exception� TypeError�popru r� rv r% �warning)rQ rw rx �warnings�linery r8 r9 rv @ s8 zInterface.__init__c C s | j jjd| d�S )N� addresses�rW �r] rX Z _get_view�rQ r8 r8 r9 �ipaddra s zInterface.ipaddrc C s | j jjd| d�S )Nr r� r� r� r8 r8 r9 �portse s zInterface.portsc C s | j jjd| d�S )N�routesr� r� r� r8 r8 r9 r� i s zInterface.routesc C s | j jjd| d�S )N� neighboursr� r� r� r8 r8 r9 r� m s zInterface.neighboursc C s | j jjd| d�S )Nr r� r� r� r8 r8 r9 r1 q s zInterface.vlansc C s4 i }| � d�r| d |d< | � d�r0| d |d< |S )Nr. r �r )rQ �ctxr8 r8 r9 �contextu s zInterface.contextc C s& t |t�r"||d kp ||d kS d S )Nr0 r� )rk r )rQ rm rn r8 r8 r9 ro ~ s zInterface.compare_recordrr c C s dd� }| j �|d|if� | S )Nc S sV z t | j�|�|�}|� gW S tyP } z t�� |_|gW Y d }~S d }~0 0 d S r~ )�getattrrF r� r� � traceback� format_stack�trace�rQ r� r, �method�e_sr8 r8 r9 � do_add_vlan� s z'Interface.add_vlan.<locals>.do_add_vlanr, �� _apply_scriptr" )rQ r, r� r8 r8 r9 �add_vlan� s zInterface.add_vlanc C s dd� }| j �|d|if� | S )Nc S sj z t | j�|�|�}|� gW S ty2 g Y S tyd } z t�� |_|gW Y d }~S d }~0 0 d S r~ )r� rF r� �KeyErrorr� r� r� r� r� r8 r8 r9 �do_ensure_vlan� s z-Interface.ensure_vlan.<locals>.do_ensure_vlanr, r� )rQ r, r� r8 r8 r9 � ensure_vlan� s zInterface.ensure_vlanc C s dd� }| j �|d|if� | S )Nc S sX z t | j| �� |�}|� gW S tyR } z t�� |_|gW Y d }~S d }~0 0 d S r~ )r� rF �remover� r� r� r� r� r8 r8 r9 � do_del_vlan� s z'Interface.del_vlan.<locals>.do_del_vlanr, r� )rQ r, r� r8 r8 r9 �del_vlan� s zInterface.del_vlanNc K s( |p|}dd� }| j �|d|if� | S )Nc S sV z t | j�|�|�}|� gW S tyP } z t�� |_|gW Y d }~S d }~0 0 d S r~ )r� r� r� r� r� r� r� r� r8 r8 r9 �do_add_neighbour� s z1Interface.add_neighbour.<locals>.do_add_neighbourr, r� )rQ r, rx r� r8 r8 r9 � add_neighbour� s zInterface.add_neighbourc K s( |p|}dd� }| j �|d|if� | S )Nc S sj z t | j�|�|�}|� gW S ty2 g Y S tyd } z t�� |_|gW Y d }~S d }~0 0 d S r~ )r� r� r� r� r� r� r� r� r� r8 r8 r9 �do_ensure_neighbour� s z7Interface.ensure_neighbour.<locals>.do_ensure_neighbourr, r� )rQ r, rx r� r8 r8 r9 �ensure_neighbour� s zInterface.ensure_neighbourc K s, |p t |�}dd� }| j�|d|if� | S )Nc S s� g }t |t�r|g}n8t|�r4| j�� }|�|� n| j�� }|jf i |�� |D ]t}z&t| j�|�� � |�}|� |� � W qR t y� Y qR t y� } z t �� |_|� |� W Y d }~qRd }~0 0 qR|s�t d�}|S )Nz no neighbour records matched)rk r �callabler� �dump�select_recordsr� r� �locater� r" r� r� r� r� r� �rQ r� r, r| rB �spr� r� r8 r8 r9 �do_del_neighbour� s( "z1Interface.del_neighbour.<locals>.do_del_neighbourr, )rO r� r" )rQ r, rx r� r8 r8 r9 � del_neighbour� s zInterface.del_neighbourc K s( |p|}dd� }| j �|d|if� | S )Nc S sV z t | j�|�|�}|� gW S tyP } z t�� |_|gW Y d }~S d }~0 0 d S r~ )r� r� r� r� r� r� r� r� r8 r8 r9 � do_add_ip� s z#Interface.add_ip.<locals>.do_add_ipr, r� )rQ r, rx r� r8 r8 r9 �add_ip� s zInterface.add_ipc K s( |p|}dd� }| j �|d|if� | S )Nc S sj z t | j�|�|�}|� gW S ty2 g Y S tyd } z t�� |_|gW Y d }~S d }~0 0 d S r~ )r� r� r� r� r� r� r� r� r� r8 r8 r9 � do_ensure_ip� s z)Interface.ensure_ip.<locals>.do_ensure_ipr, r� )rQ r, rx r� r8 r8 r9 � ensure_ip� s zInterface.ensure_ipc K s( |p|}dd� }| j �|d|if� | S )Nc S s� g }t |t�r|g}n8t|�r4| j�� }|�|� n| j�� }|jf i |�� |D ]t}z&t| j�|��� |�}|� |� � W qR t y� Y qR t y� } z t � � |_|� |� W Y d }~qRd }~0 0 qR|s�t d�}|S )Nzno address records matched)rk r r� r� r� r� r� r� r� r" r� r� r� r� r� r� r8 r8 r9 � do_del_ip s( "z#Interface.del_ip.<locals>.do_del_ipr, r� )rQ r, rx r� r8 r8 r9 �del_ip s zInterface.del_ipc C s dd� }| j �|d|if� | S )Nc S s| zB| j | }|d | d kr$td��| d |d< t||�� |gW S tyv } z t�� |_|gW Y d }~S d }~0 0 d S )Nr. �target must be the samer rN �r] � ValueErrorr� r� r� r� r� �rQ r� r, �portr� r8 r8 r9 � do_add_port+ s z'Interface.add_port.<locals>.do_add_portr, r� )rQ r, r� r8 r8 r9 �add_port) s zInterface.add_portc C s dd� }| j �|d|if� | S )Nc S s� zV| j | }|d | d kr$td��|d | d kr<td��d|d< t||�� |gW S ty� } z t�� |_|gW Y d }~S d }~0 0 d S )NrN r zwrong port master indexr. r� r r� r� r8 r8 r9 � do_del_port< s z'Interface.del_port.<locals>.do_del_portr, r� )rQ r, r� r8 r8 r9 �del_port: s zInterface.del_portc C s& t | d �}|�|� t|�| d< d S �Nr )r� �addr� �rQ r0 Znew_listr8 r8 r9 � add_altnameM s zInterface.add_altnamec C s& t | d �}|�|� t|�| d< d S r� )r� r� r� r� r8 r8 r9 � del_altnameS s zInterface.del_altnamec s� |dkrt �| ||� n�|dkr:| jdkr:t �| ||� nf|dkr\| jdkr\t �| d|� nD|dkr�| �d�r�| d |kr�tt| ��d|� ntt| ��||� d S )N�peerr. �invalid� net_ns_fd)rO rP r� r ru r� )rQ �keyrR ry r8 r9 rP Y s �� �zInterface.__setitem__c C s* t |t�r||d< nt |t�r&||d< |S )z� Interface key normalization:: { ... } -> { ... } "eth0" -> {"ifname": "eth0", ...} 1 -> {"index": 1, ...} r0 r )rk r rl )r\ � processedr, r8 r8 r9 �spec_normalizeh s zInterface.spec_normalizec sR t |t�r|}n d| jji}t |t�r0||d< nt |t�rB||d< tt| ��|�S )Nr. r0 r ) rk rO rX � localhostr rl ru r� � complete_key)rQ r� Zret_keyry r8 r9 r� x s zInterface.complete_keyc C s� |d dkr,|d | d ko*|d | d kS |d dkrX|d | d koV|d | d kS |d | d krtdkr�n nz|� d�}|| d kr�d S |� d �}|d ur�| j| d }|j|d }|jd |�d �|d�}|d |kS | d |d kS d S )z:Evaluate whether the given interface "points at" this one.r� rF r. r r rG r� r FZ link_netnsidNZ get_netnsidZget_pid)�pidZ target_nsidZ current_nsid)r r' r( )rQ �otherZ other_linkZother_link_netnsidZ self_sourceZ other_source�infor8 r8 r9 �is_peer� s. � � � zInterface.is_peerc C s$ | j | d jdd| d |d� d S )Nr. r r� r )r Zxdp_fd)r' r( )rQ �fdr8 r8 r9 � set_xdp_fd� s �zInterface.set_xdp_fdc s� t t| �j|d�}| jj�d| d i�D ].}t| �| j|| jd�}|j � ||�� f� q(| jj�d| d i�D ]B}t| �| j|| jd�}| � |�rn|� | �sn|j � ||�� f� qn|S )N)�ctxidZ IFLA_MASTERr )rq r ) ru r� �snapshotrX r Zgetmanyr r] rq Z snapshot_depsr" r� )rQ r� Zsnpr, r ry r8 r9 r� � s � � �zInterface.snapshotc sx t t| ��|�}| jdkrt| d |d< | d }|tv rt||d< | D ]0}|�|� d��rB||vrB| | rB| | ||< qB|S )N�systemrN r� �_)ru r� r} r� � ip_tunnels� startswith)rQ r{ rh r� r� ry r8 r9 r} � s ���zInterface.make_reqc C s� t | d �| }|t | d � }|D ]$}| j| d jdd| d |d� q$|D ]$}| j| d jdd| d |d� qN| �� | jdd � t | d �|kr�td ��d S ) Nr r. r Z property_delr )r ZaltnameZ property_addF)Z set_statezcould not setup alt ifnames)r� r' r( �load_from_system�load_sqlr� )rQ �alt_ifname_setupZalt_ifname_removeZalt_ifname_addr0 r8 r8 r9 �apply_altnames� s � � zInterface.apply_altnamesF�applyc s� dD ]2}|| v rt | | t�r| jj| | d | |< q| j�� dk}| j�� dk}t| d �}d| jv rv| j�d� z`t t | �� |||� |r�| � d| d � t �| dd � | �� }|r�| j�d� |s�| �|� W n� t�y� } z�| jd k�rF| �d �d u�rF| �d �d k�rF| jd k�rFd d� }| � |||� | � |d |� nF| jd k�r�| �d�d u�r�| �d�d k�r�dd� }| � |||� n� W Y d } ~ n d } ~ 0 0 d| �di �v �r�| d d | jjjv �r�| jj| d d | d d dd� | S )N)r rN r �setnsr� r r. r� r� �_ rN r r� c S s t dd� | �� D ��S )Nc S s g | ]}|d � d�s|�qS )r rN �r� rI r8 r8 r9 � <listcomp> s ��7Interface.apply.<locals>.req_filter.<locals>.<listcomp>�rO �items�rh r8 r8 r9 � req_filter s ��z#Interface.apply.<locals>.req_filterZbr_vlan_filteringc S s t dd� | �� D ��S )Nc S s g | ]}|d � d�s|�qS )r Zbr_vlan_r� rI r8 r8 r9 r� s �r� r� r� r8 r8 r9 r� s ��r� r0 � )r. r0 �timeout)rk r rX r r� r r� �changedr� ru r� r� Z load_valuerO rP r� r� r r* r] r' �wait) rQ �rollbackr� r� r� r� r� r� r, r7 ry r8 r9 r� � s` � � �� � � � � �zInterface.applyc K s |dkr�| d dkrxt dd� | j�}|r�| d dtd�}|D ]}| | ||< q<| j| d j| j|fi |�� | �� n | d tv r�| d d kr�| �� nl|d k�r| d d k�r| �� | j� d � d| vr�t t j ��| j| d j| jd| d d�}| j j�|� d S )Nr� r� rE c S s | � d�S )NZbr_r� r� r8 r8 r9 r� 5 rM z&Interface.hook_apply.<locals>.<lambda>r )r r� r r. r� Zdownr� rH g�������?r r )�filterr r r' r( r� r� r� Z load_eventr r r+ �EAGAINrX � _event_queue�put)rQ r� r, �keysrh r� r6 r8 r8 r9 � hook_apply2 s0 � �zInterface.hook_applyc C s. | j j�| j| d j| jd| d d�� d S )Nr. r r r )rX r r r' r( r� r8 r8 r9 r� O s ���zInterface.load_from_systemc s� t t| �j|i |��}|r|d| d }|| jjv r|| jj| d }| jj�d|| jjf | d f�}|r|| � t t ||��� |S )Nr r� Z norm_namesz#SELECT * from %s WHERE f_index = %sr ) ru r� r� r- �compiledrX rY rZ r! r6 rO �zip)rQ rw rx r, Ztname�namesry r8 r9 r� X s ��zInterface.load_sqlc s t t| �j|i |�� d S r~ )ru r� r� )rQ rw rx ry r8 r9 r� g s zInterface.load_rtnlmsgc C s$ d| � dd�| � d| � dd��f S )Nz%s/%sr. r_ r0 r r� r� r8 r8 r9 �key_reprj s �zInterface.key_repr)N)N)N)N)N)N)N)FNr� )9r� r� r� r3 r r� r( Zkey_extra_fieldsZresolve_fieldsrS Z fields_cmpZfields_load_transformr Z field_filterr� r^ rd rj r� rv �propertyr� r� r� r� r1 r� ro r r� r� r� r� r� r� r� r� r� r� r� r� r� rP r� r� r� r� r� r} r� r� r r� r� r� r r� r8 r8 ry r9 r� � s� � ! ! M r� ),�__doc__r+ r� r� Zpyroute2.commonr Zpyroute2.configr Zpyroute2.netlink.exceptionsr Z pyroute2.netlink.rtnl.ifinfmsgr Z pyroute2.netlink.rtnl.p2pmsgr Zpyroute2.requests.linkr Z auth_managerr r �objectsr r: r� Z sql_schema�pushZ unique_indexZschema_ifinfmsgZ foreign_keyZschema_brinfmsgZ schema_p2pmsgrs rt Zschema_af_bridge_vlans�initZ ifinfo_namesZsupported_ifinfor� �name�datar" r- rS rT r� r8 r8 r8 r9 �<module> s� = j���� ��� ���� � ������ U
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка