Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/pyroute2/ndb/__pycache__/view.cpython-39.pyc
Ðазад
a ]�hB � @ s" d Z ddlZddlZddlZddlZddlZddlZddlmZ ddl m Z ddl m Z m Z ddlmZ ddlmZ dd lmZ dd lmZ dd lmZmZ dd lmZmZ dd l m Z ddl m Z ddl m!Z! ddl"m#Z#m$Z$ ddl%m&Z&m'Z' G dd� d�Z(G dd� de)�Z*G dd� de*�Z+dS )a� Accessing objects ================= NDB objects are grouped into "views": * interfaces * addresses * routes * neighbours * rules * netns * ... Views are dictionary-like objects that accept strings or dict selectors:: # access eth0 ndb.interfaces["eth0"] # access eth0 in the netns test01 ndb.sources.add(netns="test01") ndb.interfaces[{"target": "test01", "ifname": "eth0"}] # access a route to 10.4.0.0/24 ndb.routes["10.4.0.0/24"] # same with a dict selector ndb.routes[{"dst": "10.4.0.0", "dst_len": 24}] Objects cache ============= NDB create objects on demand, it doesn't create thousands of route objects for thousands of routes by default. The object is being created only when accessed for the first time, and stays in the cache as long as it has any not committed changes. To inspect cached objects, use views' `.cache`:: >>> ndb.interfaces.cache.keys() [(('target', u'localhost'), ('tflags', 0), ('index', 1)), # lo (('target', u'localhost'), ('tflags', 0), ('index', 5))] # eth3 There is no asynchronous cache invalidation, the cache is being cleaned up every time when an object is accessed. API === � N)� OrderedDict)�partial)�cli�config)� basestring� )� check_auth)� RSLV_DELETE)�Address)� Interface�Vlan)� FDBRecord� Neighbour)�NetNS)�Route)�Rule)�Record� RecordSet)�Source� SourceProxyc @ s$ e Zd Zdd� Zdd� Zdd� ZdS )� TmpHandlerc C s || _ || _|| _d S �N)�ndb�event�handler)�selfr r r � r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/pyroute2/ndb/view.py�__init__L s zTmpHandler.__init__c C s" | j j�| j jj| j | j� | S r )r � task_managerZregister_handler�schema�classesr r �r r r r � __enter__Q s �zTmpHandler.__enter__c C s" | j j�| j jj| j | j� d S r )r r Zunregister_handlerr r! r r �r �exc_type� exc_value� tracebackr r r �__exit__W s �zTmpHandler.__exit__N)�__name__� __module__� __qualname__r r# r( r r r r r K s r c @ s� e Zd ZdZdBdd�Zdd� Zdd� Zed d � �Zed d � �Z dCd d�Z dDdd�Z e j ed�dEdd���ZdFdd�Ze j ed�dd� ��Ze j ed�dd� ��Ze j ed�dd � ��Zed�d d � �Zed�dGd d ��Zed�dHd!d"��ZdId#d$�Zd%d&� Zd'd(� Zd)d*� Zd+d,� Zed-�d.d/� �Z ed-�d0d1� �Z ed-�d2d3� �Z e j d4d5� �Z d6d7� Z!d8d9� Z"d:d;� Z#e j ed-�d<d=� ��Z$e j ed-�d>d?� ��Z%d@dA� Z&dS )J�Viewz� The View() object returns RTNL objects on demand:: ifobj1 = ndb.interfaces['eth0'] ifobj2 = ndb.interfaces['eth0'] # ifobj1 != ifobj2 Nc C s� || _ |j�d| �| _|| _|| _|| _i | _|d u r<g }|rJ||j7 }|| _i | _t � | _ t | j d< t | j d< t | j d< t| j d< t| j d< t| j d< t| j d< t| j d < d S ) Nzview.%sZ interfaces� addressesZ neighboursZ af_bridge_fdbZroutes�rules�netnsZaf_bridge_vlans)r �logZchannel�tabler �chain�cache� auth_managers� constraintsr r! r r r r r r r r )r r r1 r2 r4 r r r r f s* z View.__init__c C s | S r r r" r r r r# } s zView.__enter__c C s d S r r r$ r r r r( � s z View.__exit__c C s | j dkr| jjS | jjS d S )Nr/ )r1 r Z nsmanager� localhostr" r r r �default_target� s zView.default_targetc C s | j d ur| j jS i S d S r )r2 �contextr" r r r r8 � s z View.contextc C s | j j�|p| j|�S r )r r Zdb_getr1 )r �specr1 r r r �getmany� s z View.getmanyc C s | � ||�D ] }| S d S r )r: )r r9 r1 �objr r r �getone� s z View.getonezobj:readc K s0 |p|}z| � ||�W S ty* Y d S 0 d S r )� __getitem__�KeyError)r r9 r1 �kwargr r r �get� s zView.getc C sJ | j r| j j}ni }| j|p | j }|�||| j�}|| |d| j | jd�S )NF)�loadZmasterr4 )r2 r8 r! r1 �new_specr7 r4 )r �keyr1 r8 �iclassr9 r r r �template� s �z View.templatez obj:modifyc O sX | j | j }| jr | jj}ni }|�|p.|d || j�}| jrH| j|d< d|d< | | S )Nr Z ndb_chainT�create)r! r1 r2 r8 rB r7 )r �argspec�kwspecrD r8 r9 r r r rF � s � z View.createc O sV z| j f i |��}W n" ty6 | jf i |��}Y n0 |�� D ]\}}|||< q@|S r )�locater> rF �items)r rG rH r; rC �valuer r r �ensure� s z View.ensurec O s | j �d� | j|i |��S )Na� The name add() will be removed in future releases, use create() instead. If you believe that the idea to rename is wrong, please file your opinion to the project's bugtracker. The reason behind the rename is not to confuse interfaces.add() with bridge and bond port operations, that don't create any new interfaces but work on existing ones. )r0 �warningrF )r rG rH r r r �add� s � zView.addc K s� d }|� dd�}|� dd�}t�� }tjdd�}dd� }t| j| jt||���� | �|�}|rf|dksv|d u r�|d kr�|W d � S z|jd d �\}} W n tj y� Y n0 |dkrP|| t�� k rPt � �qPW d � n1 s�0 Y d S ) N�timeout����actionrN �d )�maxsizec S s, z| � ||f� W n tjy& Y n0 d S r )� put_nowait�queue�Full)�evq�targetr r r r r � s zView.wait.<locals>.handler�remover )rO ) �pop�timerU �Queuer r r r r@ �Empty� TimeoutError) r r9 �retrO rQ �ctimerW r rX �msgr r r �wait� s* ��z View.waitc K s� t |t�r|�� }|p|}|s&td��|p.| j}| j| }|�|�}| jjj | d }| jjj | d }i }|D ]H}|� |�}||v r�|| ||< qp||v rp|| } | |v rp|| || < qp|s�t d��| | S )a� This method works like `__getitem__()`, but the important difference is that it uses only key fields to locate the object in the DB, ignoring all other keys. It is useful to locate objects that may change attributes during request, like an interface may come up/down, or an address may become primary/secondary, so plain `__getitem__()` will not match while the object still exists. zgot an empty specZnorm_idx�lookup_fallbackszgot an empty key) � isinstancer Z_as_dict� TypeErrorr1 r! rB r r �compiledZnla2namer> ) r r9 r1 r? rD Zkspecrc �request�name�fallbackr r r rI s, z View.locatec C s� | � ||�}t|j�� �}t�� }t| j�D ]`}||kr:q,|| j| j tjkr,| j| j r,t � | j| �r,| j � d|f � | j�|d � q,|| jv r�| j � d|f � ~| j| }||_|S | �|�r�|�� | j � d|f � || j|< |�� |S )Nz cache del %sz cache hit %sz cache add %s)rE �tuplerC rJ r[ r3 �atimer Z cache_expire�clean�gcZ get_referrersr0 �debugrZ �existsZload_sql�register)r rC r1 r_ � cache_keyZrtimeZckeyr r r r= ' s4 � �� zView.__getitem__c C sF | j r| j j}ni }| j| j }|�||| j�}|j| ||jtd� |pL| j}| j j }| j j }|j | j d }| j �d||f � g }g } |�� D ]h\} } |�| �} | |v r�| } | dur�| |v r�|�d| |jf � t| ttttf�r�t�| �} | �| � q�|�d| jd�|�f | �} | du�r2| j �d� d S | j �d � d S dS ) z� Check if the specified object exists in the database:: ndb.interfaces.exists('eth0') ndb.interfaces.exists({'ifname': 'eth0', 'target': 'localhost'}) ndb.addresses.exists('127.0.0.1/8') )�viewr9 �fields�policyZ all_namesz&check if the key %s exists in table %sNz f_%s = %szSELECT * FROM %s WHERE %sz AND ro Tz not existsF) r2 r8 r! r1 rB r7 �resolveZresolve_fieldsr r r r rf r0 rn rJ Zname2nla�appendZplchrd �dict�listrj �set�json�dumpsZ db_fetchone�join)r rC r1 r8 rD r r �names�keys�valuesrh rK Znla_namer9 r r r ro Y sH � � z View.existsc C s t � �d S r ��NotImplementedError)r rC rK r r r � __setitem__� s zView.__setitem__c C s t � �d S r r� �r rC r r r � __delitem__� s zView.__delitem__c C s | � � S r �r~ r" r r r �__iter__� s z View.__iter__c C s || � � v S r ��dumpr� r r r � __contains__� s zView.__contains__�obj:listc c s | � � D ] }|V qd S r r� )r �recordr r r r~ � s z View.keysc c s | � � D ]}| | V qd S r r� r� r r r r � s z View.valuesc c s | � � D ]}|| | fV qd S r r� r� r r r rJ � s z View.itemsc C s | j | j �| �d S )Nr )r! r1 �_countr" r r r �count� s z View.countc C s | � � S r )r� r" r r r �__len__� s z View.__len__c C s" ddg| j jj|jp|j d S )NrX Ztflagsr} )r r rf rr r1 �r rD r r r �_keys� s ��z View._keysc c s, t |�}|D ]}t||| j| j �V q d S r )�nextr r! r1 )r r� �fnamesr� r r r �_native� s z View._nativec C s4 | j | j }t| �|�| ��d| jj�dd�id�S �NZrecordset_pipe�false)r )r! r1 r r� r� r r r@ r� r r r r� � s ���z View.dumpc C s4 | j | j }t| �|�| ��d| jj�dd�id�S r� )r! r1 r r� �summaryr r r@ r� r r r r� � s ���z View.summaryc C sB | j r"d| j v r"| j d � d�}nd}d|� | j� d| �� � d�S )NZifname�/� z NDB view for z Number of objects: z� to list objects use .summary() or .dump() -> RecordSet (generator) -> Record key: Union[Record, dict, spec] to get objects use ...[key] / .__getitem__(key) -> RTNL_Object )r2 r1 r� )r �parentr r r �__repr__� s ���z View.__repr__)NN)N)N)NN)N)NN)N)N)'r) r* r+ �__doc__r r# r( �propertyr7 r8 r: r< r Zchange_pointerr r@ rE rF rL rN rb rI r= ro r� r� r� r� r~ r rJ Z show_resultr� r� r� r� r� r� r� r r r r r, ] sh % % 1 3 r, c sp e Zd Zd� fdd� Zdd� Zdd� Zejdfd d �Ze d �d d � �Z dd� Z dd� Z dd� Z ddd�Z� ZS )� SourcesViewNc sH t t| ��|d� t| jd< i | _i | _t�� | _ |d u r>g }|| _ d S )N�sources) �superr� r r r! r3 �proxy� threading�Lock�lockr4 )r r r4 �� __class__r r r � s zSourcesView.__init__c K s< t t�|��}t| jfi |���� | j|d < | j|d S �NrX )rw r �defaultsr �startr3 �r r9 r r r � async_add� s zSourcesView.async_addc K s� t t�|��}|d }|| v r.td|� d���d|vrHd}t�� |d< nd}t| jfi |���� | j|d < |r�| j|d j � � | j|d S )NrX �source z existsr TF) rw r r� r> r� �Eventr r� r3 r rb )r r9 rX �syncr r r rN � s zSourcesView.addTc C s~ || vrt d|� d���| j�L || jv r\| j| }|j||d� | j�|�W d � S W d � n1 sp0 Y d S )Nr� z does not exist)�coder� )r> r� r3 �closerZ )r rX r� r� �sourcer r r rY s zSourcesView.remover� c c s | j D ] }|V qd S r )r3 r� r r r r~ s zSourcesView.keysc C s ddgS )NrX �kindr r� r r r r� s zSourcesView._keysc K s t � �d S r r� r� r r r rb s zSourcesView.waitc O s | j |i |��S r )�_dump)r �argvr? r r r �_summary s zSourcesView._summaryc C s| t |t�r|}n&t |t�r0d|�� v r0|d }nt� �|| jv rJ| j| S || jv r^| j| S t| j|�}|| j|< |S d S r� ) rd r rw r~ r> r3 r� r r )r rC r1 rX r� r r r r= s zSourcesView.__getitem__)N)N)r) r* r+ r r� rN �errno� ECONNRESETrY r r~ r� rb r� r= � __classcell__r r r� r r� � s r� ),r� r� rm rz rU r� r[ � collectionsr � functoolsr Zpyroute2r r Zpyroute2.commonr Z auth_managerr �objectsr Zobjects.addressr Zobjects.interfacer r Zobjects.neighbourr r Z objects.netnsr Z objects.router Z objects.ruler �reportr r r� r r r rw r, r� r r r r �<module> s4 0
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка