Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/pyroute2/ndb/objects/__pycache__/route.cpython-39.pyc
Ðазад
a ]�h�p � @ sz d Z ddlZddlZddlZddlZddlmZ ddlmZ ddl m Z m Z ddl m Z mZ ddlmZmZmZ ddlmZ dd lmZ d d lmZ d d lmZ d d lm Z dd� e� � D �dd� Z dd� e� � D �dd� Z dZ d Z!dZ"dd� Z#dd� Z$dCdd�Z%e� � �&dd��&d d ��&d d ��'d d d!d"d#d$d%d&d'd(d)� �(d*d+d,��(d*d-d,�Z)e� � �&dd.��&d/d ��'dd/��(d0d1d1��(d*d2d,�Z*ej+� � �&dd.��'d��(d0d1d1�Z,ej-� � �&dd.��'d��(d0d1d1�Z.d0e)gd3e*gd4e,gd5e.ggd0egd3egd4ej+gd5ej-ggee$gid6�Z/G d7d8� d8e�Z0G d9d:� d:e�Z1G d;d<� d<�Z2G d=d>� d>e2e�Z3G d?d@� d@e2e4�Z5G dAdB� dBe2e�Z6dS )Da� .. testsetup:: from pyroute2 import NDB from pyroute2 import config config.mock_iproute = True ndb = NDB() .. testsetup:: tables from pyroute2 import NDB from pyroute2 import config config.mock_iproute = True ndb = NDB() ndb.routes.create( dst='1.1.1.1/32', gateway='127.0.0.10', oif=1, table=101 ).commit() ndb.routes.create( dst='1.1.1.2/32', gateway='127.0.0.10', oif=1, table=5001 ).commit() ndb.routes.create( dst='1.1.1.3/32', gateway='127.0.0.10', oif=1, table=5002 ).commit() .. testsetup:: metrics from pyroute2 import NDB from pyroute2 import config config.mock_iproute = True ndb = NDB() ndb.routes.create( dst='10.0.0.0/24', gateway='127.0.0.10' ).commit() Simple routes ============= Ordinary routes management is really simple: .. testcode:: # create a route ndb.routes.create( dst='10.0.0.0/24', gateway='192.168.122.1' ).commit() # retrieve a route and change it with ndb.routes['10.0.0.0/24'] as route: route.set(gateway='192.168.122.10') # remove a route with ndb.routes['10.0.0.0/24'] as route: route.remove() Multiple routing tables ======================= But Linux systems have more than one routing table: .. doctest:: tables >>> set((x.table for x in ndb.routes.summary())) {101, 5001, 5002, 254, 255} The main routing table is 254. All the routes people mostly work with are in that table. To address routes in other routing tables, you can use dict specs: .. testcode:: ndb.routes.create( dst='10.0.0.0/24', gateway='192.168.122.1', table=101 ).commit() with ndb.routes[{'table': 101, 'dst': '10.0.0.0/24'}] as route: route.set('gateway', '192.168.122.10') route.set('priority', 500) with ndb.routes[{'table': 101, 'dst': '10.0.0.0/24'}] as route: route.remove() Route metrics ============= `route['metrics']` attribute provides a dictionary-like object that reflects route metrics like hop limit, mtu etc: .. testcode:: metrics # set up all metrics from a dictionary with ndb.routes['10.0.0.0/24'] as route: route.set('metrics', {'mtu': 1500, 'hoplimit': 20}) # fix individual metrics with ndb.routes['10.0.0.0/24']['metrics'] as metrics: metrics.set('mtu', 1500) metrics.set('hoplimit', 20) MPLS routes =========== See here: :ref:`mpls` � N)� OrderedDict)�partial)�AF_INET� inet_pton)�AF_MPLS� basestring)�LWTUNNEL_ENCAP_MPLS�nh�rtmsg�� MPLSTarget)�RouteFieldFilter� )� check_auth)� RTNL_Object)�Recordc C s g | ]}d |d �qS )z main.f_%sr � ��.0�xr r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/pyroute2/ndb/objects/route.py� <listcomp>� � r ���c C s g | ]}d |d �qS )znh.f_%sr r r r r r r � r � � c C s� d| j g}|g}| jd D ]2}|�d|| j f � |�|�|�pJ|�|�� q dd�|� }d| }| �||��� D ]}|d d S tt � � �S )Nz f_target = %s�routes� f_%s = %szWHERE %s� AND z SELECT f_route_id FROM routes %sr ) �plch�indices�append�get�get_attr�join�executeZfetchall�str�uuid�uuid4) �schema�target�event�keys�values�key�specZs_req�route_idr r r � get_route_id� s r1 c C sv d }g }|� dd�}|dkr0|d �ddg� n�|� d�dkr�|d dkr�|d dkr�|d tkr�|d d }z&t| |||d r�tt�� �nd � W nH ty� } z0| j�d |f � | j�d |f � W Y d }~n d }~0 0 |d d d �s@d|d< |� d�}|�r~|�pt | ||�}t t |��D ]V} i || d < ||| d< | || d< |�t | j d||| d�� |d tO < �q&|� d�} |� d�} | tk�r�|�p�t | ||�}i | d < || d< |�t | j d|| d�� |d tO < |� d�} | �r@|�pt | ||�}i | d < || d< |�t | j d|| d�� |d tO < |d u�rR||d< | � d||� |D ] } | � �qdd S )N� RTA_TABLE����attrs� �protor �scope� �family�header�type�gc_mark event: %sz gc_mark: %sr �depsZ RTA_MULTIPATHr0 �nh_idr r Z RTA_ENCAPZRTA_ENCAP_TYPE�enc_mplsZ RTA_METRICS�metrics)r# r! r � rtmsg_gc_mark�int�time� Exception�log�errorr1 �range�lenr Z load_netlink�F_RTA_MULTIPATHr � F_RTA_ENCAP� F_RTA_METRICS)r) r* r+ r0 �postZ rta_tableZevt�e�mp�idx�encap� encap_typer@ Z procedurer r r � load_rtmsg� s� � � � � �( �� �� �� rR c sZ |d u rd}nd}d� dd� � jd D ��}d� � fdd�� jd D ��}� �d |� j� j|f ||�d �f��� }|�d �}t�d tt |��d dd|d > @ } |D ]�} | d } zRt�d tt | ��d | @ } | | k�r� �d� j� j|f ||f| d d� � W q� t �yR } z2� j � d|f � � j � d| | f � W Y d } ~ q�d } ~ 0 0 q�d S )Nz AND f_gc_mark IS NOT NULL� �,c S s g | ] }d | �qS )zf_%sr r r r r r r z!rtmsg_gc_mark.<locals>.<listcomp>r r c s g | ]}d |� j f �qS )r )r r �r) r r r r z� SELECT %s,f_RTA_GATEWAY FROM routes WHERE f_target = %s AND f_RTA_OIF = %s AND f_RTA_GATEWAY IS NOT NULL %s AND f_family = 2 �RTA_OIF�RTA_DSTz>Ir l �� � �dst_lenr3 z;UPDATE routes SET f_gc_mark = %s WHERE f_target = %s AND %sr< zgc_mark: %s : %s) r$ r r% r r# Z fetchmany�struct�unpackr r rD rE rF )r) r* r+ �gc_markZ gc_clauseZ key_fieldsZ key_queryr �addr�net�routeZgwZgwnetrM r rU r rA s@ �� � � ���rA r0 z TEXT UNIQUEr\ ZINTEGERr= r9 rY Ztosr7 r; rW rV Z RTA_PRIORITYr2 ZRTA_VIAZ RTA_NEWDSTZ interfaces)�f_target�f_tflagsZ f_RTA_OIF)r` ra Zf_index)r` ra Z f_RTA_IIFZTEXTr> r )Z f_route_id)r` ra Zf_oifr r@ r? )�specs�classes� event_mapc s. e Zd Zd� fdd� Zdd� Zdd� Z� ZS ) �ViaNc sP t t| ��� |d u r i }nt|t�s,t� �|�dt�| d< |�dd�| d< d S �Nr9 r] z0.0.0.0)�superr �__init__� isinstance�dict� TypeErrorr" r )�self�prime�� __class__r r rh � s z Via.__init__c C s2 t |t�o0| d |�dt�ko0| d |�dd�kS rf )ri rj r" r �rl �rightr r r �__eq__� s ��z Via.__eq__c C s t t| ��S �N)�reprrj �rl r r r �__repr__� s z Via.__repr__)N)�__name__� __module__� __qualname__rh rr rv � __classcell__r r rn r re � s re c s e Zd ZdZeZdgZdZeZ dZ e dd� �Z e dd� �Z e d d � �Ze d d � �Ze d d� �Ze dd� �Zdd� Zdd� Zdd� Zeed�eed�eed�eed�Zdd � Z� fd d �Z� fd d �Ze� fd!d"��Zd#d$� Z e d%�� fd&d'��Z e d%�d/� fd+d,� �Z � fd-d.�Z � Z!S )0�Router r0 r_ Tc 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_RTA_OIF = %s�indexzSELECT count(*) FROM %s)�chain�ndb� task_managerZ db_fetchone�tabler) r )�cls�viewr r r �_count� s � ��z Route._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_RTA_OIF = %s r* r| rS )r} r~ r) r )r� r� r �wherer- r r r � _dump_where� s ��zRoute._dump_wherec c s< d}dV | � |�\}}|jj�|| |�D ] }|V q,d S )Na� WITH main AS (SELECT nr.f_target, nr.f_tflags, nr.f_RTA_TABLE, nr.f_RTA_DST, nr.f_dst_len, CASE WHEN nh.f_oif > nr.f_RTA_OIF THEN nh.f_oif ELSE nr.f_RTA_OIF END AS f_RTA_OIF, CASE WHEN nh.f_RTA_GATEWAY IS NOT NULL THEN nh.f_RTA_GATEWAY ELSE nr.f_RTA_GATEWAY END AS f_RTA_GATEWAY FROM routes AS nr LEFT JOIN nh ON nr.f_route_id = nh.f_route_id AND nr.f_target = nh.f_target) SELECT main.f_target, main.f_tflags, main.f_RTA_TABLE, intf.f_IFLA_IFNAME, main.f_RTA_DST, main.f_dst_len, main.f_RTA_GATEWAY FROM main INNER JOIN interfaces AS intf ON main.f_rta_oif = intf.f_index AND main.f_target = intf.f_target )r* �tflagsr� Zifname�dstrY �gateway)r� r~ r �db_fetch)r� r� �reqr� r- �recordr r r �summary� s z Route.summaryc c s� dd� dd� tt dg D �� }ddgdd� tD � d d� tD � d d g }|V |jjj}| �|�\}}|jj�|| |�D � ]�}|d }t |d d � �}|d u�rnt |jj�d |f |f��} | �r"i } |jjj d d } t | | d �D ] \} } | d ur�| dvr�| | | < q�|� t�| �� n |� d � t |jj�d|f |f��}|�rb|� |d d � n |� d � n |�d� |V q�d S )Nz� SELECT main.f_target,main.f_tflags,%s FROM routes AS main LEFT JOIN nh AS nh ON main.f_route_id = nh.f_route_id AND main.f_target = nh.f_target rT c S s g | ] }d | �qS )z%sr r r r r r � r z Route.dump.<locals>.<listcomp>zmain.f_route_idr* r� c S s g | ]}t �|d d� ��qS )� N)r �nla2namer r r r r � r c S s" g | ]}d t �|dd� � �qS )znh_%s� N)r r� r r r r r � r r@ rP r3 zQ SELECT * FROM metrics WHERE f_route_id = %s Z norm_namesr )r* r0 r� zR SELECT * FROM enc_mpls WHERE f_route_id = %s r )NN)r$ �_dump_rt�_dump_nhr~ r) r r� r r� �list�tuple�compiled�zipr! �json�dumps�extend)r� r� r� r: r r� r- r� r0 r@ �ret�names�k�vr? r r r �dump� sb �� � ��� ��� ��� z Route.dumpc C s t |t�r||d< |S )Nr� )ri r )r� � processedr/ r r r �spec_normalize. s zRoute.spec_normalizec C s( t |t�r$||d � d|d � �kS d S )Nr� �/rY )ri r& )rl �leftrq r r r �compare_record4 s zRoute.compare_recordc C s0 dd� t �|�D �}tdd� t|| |�D ��S )Nc S s g | ] }t |��qS r r r r r r r : r z%Route._cmp_target.<locals>.<listcomp>c S s g | ]}|d |d k�qS �r r r r r r r r ; r )r� �loads�allr� )r. rl rq r r r � _cmp_target9 s zRoute._cmp_targetc C s | d t t�|��kS )N�via)re r� r� rp r r r �_cmp_via= s zRoute._cmp_viac C s t dd� t| �dg �|�D ��S )Nc S s g | ]}|d |d k�qS r� r r r r r r A r z$Route._cmp_encap.<locals>.<listcomp>rP )r� r� r" rp r r r � _cmp_encap@ s zRoute._cmp_encapr� �src�newdst)r� r� r� rP r� c C s8 | j jfd }| j �d| || d | d | d f� d S �Nr a UPDATE interfaces SET f_tflags = %s WHERE (f_index = %s OR f_index = %s) AND f_target = %s ZiifZoifr* )r) r r% �rl �markr r r r � mark_tflagsK s ��zRoute.mark_tflagsc sZ t |d< t di| _t�| dg � t�| dt| �� t�| dd� tt| �j|i |�� d S )N�iclassZ load_rtnlmsg� multipathr@ r= r )r rd rj � __setitem__� MetricsStubrg r{ rh )rl �argv�kwargrn r r rh Y s zRoute.__init__c s> i }t |t�r||d< n>t |tttf�r8tt| ��|�S t |t�rN|� |� nt d��d|vrj| j j |d< t |� d�t�r�t|d �|d< t |� d�t�r�|� d�dkr�d|d< d|d< n&d|d v r�|d �d�\|d< |d< |� d d�tk�r.d D ]6}|� ||� |d ��}t |tttf�r�t�|�||< q�tt| ��|�S ) Nr� zunsupported key typer* rY �defaultrS r r� r9 )r� r� r� r� )ri r r r� r� rg r{ � complete_keyrj �updaterk r~ � localhostr" rB �splitr r� r� )rl r. Zret_key�field�valuern r r r� a s0 zRoute.complete_keyc sL d}| d ft | d � D ] }t|d�r|t|j�dkM }q|tt| �j@ S )NTr@ r� �changedr )r� �hasattrrH r� rg r{ �clean)rl r� �srn r r r� � s z Route.cleanc C s� t |�}| jD ]}| | ||< q| d r4| d |d< | d rH| d |d< | �d�rr| �d�rr| d | d d�|d< | �d�r�| d |d< |S )Nr� r@ rP rQ )r; �labelsr� )rj r� r" )rl rm r� r. r r r �make_req� s � zRoute.make_reqz obj:modifyc s� |dkrt d���n�|dkr�tt| ��dg � |D ]R}t|�}| jdkrPd|d< t| | j|| jd�}|j� | j� � � | d � |� q2|| j v r�| j � |� �n|dk�rt|�}t| d t�s�d|d< t| | j|| jd�}|j� | j� � � tt| ��d|� || j v �r�| j � |� n�| � d d �tk�r�|d v �r�t|ttf��rL|g}g }d }|D ] }t|�}d |d < |� |� �qXd |d < tt| ��||� ntt| ��||� d S )Nr0 zroute_id is read onlyr� �invalidT�create�� auth_managersr@ r9 r )r� r� r� Zbosr )� ValueErrorrg r{ r� rj �state�NextHopr� r� �setr" r! r� �removeri �Metricsr rB r )rl r. r� rN �obj�nar* �labelrn r r r� � sL � � zRoute.__setitem__FN�applyc sr | � d�dkr.| � d�dkr.| � d�dkr.| S | � dt�tkrZ| � d�sZt�| dt� g� tt| ��|||�S d S )Nr� � r9 � r6 r r� ) r" r r rj r� r rg r{ r� �rl �rollbackZ req_filter�modern r r r� � s � � �z Route.applyc s� t t| �j|i |�� | �dd�tkr�dD ]X}| �|d �}t|t�r*|dkr*|dkr`t�|�}ndd� t�|�D �}t � | ||� q*| d t @ �rt d �D ]b}t | j�d | jjf | d f��}|r�d d� t�|d d �D �}| �d|� �qt�d� q�| j�d| d f � | j�� �s$d S | d t@ �r�t d �D ]^}t | j�d| jjf | d f��}|�r�t| | jd | d i| j d�| d< �q�t�d� �q:| j�d| d f � d| v�r�| �d �d u�r�| j�d| jjf | d f�} d} d} t | d �D ]�} t| t ��sd} | �szz t | �} W n t �y: d} Y n0 t | j!| �D ]0\}}|| v �rj|d u �rj�qHn | �||� �qH| �r�| d �"| � �q�| d7 } �q�| D ]6} | d | d d �}| d �#t | | j|| j d�� �q�d S ) Nr9 r )r� r� r� r� rS r� c S s g | ] }t |��qS r r r r r r r � r z"Route.load_sql.<locals>.<listcomp>r= r� z,SELECT * FROM enc_mpls WHERE f_route_id = %sr0 c S s g | ] }t |��qS r r r r r r r r r rP g�������?zno encap loaded for %sz+SELECT * FROM metrics WHERE f_route_id = %sr� r@ zno metrics loaded for %sr> z&SELECT * FROM nh WHERE f_route_id = %sFr� Tr r3 )r0 r> )$rg r{ �load_sqlr" r ri r r� r� rj r� rJ rG r� r r� r) r Z load_valuerC �sleeprE rF Z load_event�is_setrK r� r� r� r� �next� StopIterationr� r� �popr! )rl r� r� r� r� r� �_�encr@ Znhs�flushrO Znexthopr/ r. rn r r r� � s� ��� ��� � � � ���zRoute.load_sql)FNr� )"rw rx ry r� r � msg_class� hidden_fields�apir Z field_filterZ_replace_on_key_change� classmethodr� r� r� r� r� r� r� r� r� r Z fields_cmpr� rh r� �propertyr� r� r r� r� r� rz r r rn r r{ � sL , B � 2- r{ c @ s6 e Zd Zddd�Zdd� Zdd � Zd d � Zd d � ZdS )�RouteSubFNr� c C s | j �|||�S rs )r_ r� r� r r r r� P s zRouteSub.applyc C s | j �� S rs )r_ �commitru r r r r� S s zRouteSub.commitc C s || |< d S rs r �rl r. r� r r r r� V s z RouteSub.setc C s | S rs r ru r r r � __enter__Y s zRouteSub.__enter__c C s | � � d S rs )r� )rl �exc_type� exc_value� tracebackr r r �__exit__\ s zRouteSub.__exit__)FNr� )rw rx ry r� r� r� r� r� r r r r r� O s r� c s0 e Zd ZeZdZdZdd� Z� fdd�Z� Z S )r� r �r0 r* c C s> | j jfd }| j �d| || jd | jd | jd f� d S r� �r) r r% r_ r� r r r r� e s � �zNextHop.mark_tflagsc s0 || _ t|d< d|d< tt| �j|i |�� d S �Nr� F�check)r_ r rg r� rh �rl r_ r� r� rn r r rh s s zNextHop.__init__) rw rx ry r r� r� r� r� rh rz r r rn r r� ` s r� c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )r� c C s || _ d S rs �r_ )rl r_ r r r rh { s zMetricsStub.__init__c C s ||i| j d< d S )Nr@ r� r� r r r r� ~ s zMetricsStub.__setitem__c C s t d��d S )Nz&metrics not initialized for this route)�KeyError)rl r. r r r � __getitem__� s zMetricsStub.__getitem__N)rw rx ry rh r� r� r r r r r� z s r� c s2 e Zd ZejZdZdZdd� Z� fdd�Z � Z S )r� r@ r� c C s> | j jfd }| j �d| || jd | jd | jd f� d S r� r� r� r r r r� � s � �zMetrics.mark_tflagsc s2 || _ tj|d< d|d< tt| �j|i |�� d S r� )r_ r r@ rg r� rh r� rn r r rh � s zMetrics.__init__) rw rx ry r r@ r� r� r� r� rh rz r r rn r r� � s r� )N)7�__doc__r� rZ rC r' � collectionsr � functoolsr �socketr r Zpyroute2.commonr r Zpyroute2.netlink.rtnl.rtmsgr r r Zpyroute2.requests.commonr Zpyroute2.requests.router Z auth_managerr �objectsr �reportr Z sql_schemar� r� rI rJ rK r1 rR rA �pushZ unique_indexZ foreign_keyZ rt_schemaZ nh_schemar@ Zmetrics_schemaZmpls_encap_infoZmpls_enc_schema�initre r{ r� r� rj r� r� r r r r �<module> s� n f 6������� ������ ���� ���� ��� <
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка