Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/pyroute2/ipdb/__pycache__/transactional.cpython-39.pyc
Ðазад
a ]�h�@ � @ s~ d Z ddlZddlZddlmZmZ ddlmZ ddlm Z dZ e� e �Z G dd� de�Zd d � Zd d � ZG d d� de�ZdS )� � N)�Dotkeys�uuid32)�CommitException)� LinkedSet� c @ s> e Zd Zddd�Zdd� Zdd� Zdd � Zd d � Zd d � ZdS )�StateNc C s |p t �� | _d| _d S )Nr )� threading�Lock�lock�flag)�selfr � r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/pyroute2/ipdb/transactional.py�__init__ s zState.__init__c C s | j �� | jd7 _d S )N� )r �acquirer �r r r r r s z State.acquirec C s. | j dk rtd��| j d8 _ | j�� d S )Nr zrelease unlocked state)r � RuntimeErrorr �releaser r r r r s z State.releasec C s | j S �N)r r r r r �is_set s z State.is_setc C s | � � | S r )r r r r r � __enter__# s zState.__enter__c C s | � � d S r )r )r �exc_type� exc_value� tracebackr r r �__exit__' s zState.__exit__)N) �__name__� __module__� __qualname__r r r r r r r r r r r s r c s � fdd�}� j |_ |S )Nc s� | j dkrJ| j�( � | dg|�R i |��W d � S 1 s>0 Y n| j dkr\td��| j�r | j�� }|s�| j dkr�| js�| �� n"| j dkr�| js�td��ntd��� | |g|�R i |��W d � S 1 s�0 Y d S ) N�snapshotT�readonlyz can not change readonly object�implicit�explicit�start a transaction firstz transaction mode not supported)�_mode� _write_lockr � _direct_stater � current_tx�begin� TypeError)r �argv�kwarg�direct��fr r � decorated, s 8 zupdate.<locals>.decorated)�__doc__�r/ r0 r r. r �update+ s r3 c s � fdd�}t |�S )Nc s< |r � | g|�R i |�� n | j }� |g|�R i |�� | S r )r( )r r- r+ r, � transactionr. r r r0 J s z#with_transaction.<locals>.decorated)r3 r2 r r. r �with_transactionI s r5 c @ sl e Zd ZdZg Zg Zi Zg Zg ZdKdd�Z e dd� �Z dd� Z d d � Z dLd d �ZdMdd�Zdd� Zdd� Zdd� Zdd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� ZdNd'd(�Zd)d*� Z d+d,� Z d-d.� Z e e e �Z d/d0� Z e e �Z!d1d2� Z"dOd3d4�Z#dPd5d6�Z$dQd7d8�Z%e&d9d:� �Z'e&d;d<� �Z(d=d>� Z)d?d@� Z*dAdB� Z+e,fdCdD�Z-dEdF� Z.dGdH� Z/dIdJ� Z0dS )R� TransactionalzC Utility class that implements common transactional logic. Nc C s� |d ur|j | _ || _n d | _ d | _d | _|d urF|p:|j| _|| _n |d ur\|pV|j| _n |pbd| _d | _|ptt� | _d | _g | _ g | _ t � � | _ i | _i | _i | _i | _t �� | _t| j�| _| jp�t� | _| jD ]}t�| |d � q�d S )Nr" )�nl�ipdb�_parentr% �modeZnlmsgr �uid� last_error� _commit_hooks�_sidsr �local�_ts� _snapshots� global_tx�_targets�_local_targets�RLockr& r r' � _linked_sets�set�_fieldsr � __setitem__)r r8 r: �parentr; �ir r r r ` s6 zTransactional.__init__c C s | j ddd�S )NFT)�detachedr! )�pickr r r r �ro� s zTransactional.roc C s | j �|� dS �� N)r= �append)r �hookr r r �register_commit_hook� s z"Transactional.register_commit_hookc C sV | j �< t| j�D ] }||kr| j�| j�|�� qW d � n1 sH0 Y dS rO )r& �tupler= �pop�index)r rR �cbr r r �unregister_commit_hook� s z$Transactional.unregister_commit_hookTc C s� | j �� i }| D ]h}| | dur|d dkrt| | t�rL| | �� ||< qt| | t�rlt| | �||< q| | ||< q|W d � S 1 s�0 Y dS )rP Nr �_)r& � isinstancer6 �dumpr rT )r Znot_none�res�keyr r r r[ � s zTransactional.dumpFc C s� | j �� | j| jd||d�}| �� D ]*\}}| | dur$|| jv r$| | ||< q$| jD ]2}t| | �| | �||< |sV| | �|| � qV|r�d|_|W d � S 1 s�0 Y dS )aW Get a snapshot of the object. Can be of two types: * detached=True -- (default) "true" snapshot * detached=False -- keep ip addr set updated from OS Please note, that "updated" doesn't mean "in sync". The reason behind this logic is that snapshots can be used as transactions. r )r8 r: rJ r; Nr! ) r& � __class__r8 �itemsrH rF �type�connectr% )r rL r; rJ r! r\ r] �valuer r r rM � s � zTransactional.pickc C s2 | j dkr| S | j dvr td��| js.| �� | S )Nr! )r" r# z-context managers require a transactional mode)r% r* r( r) r r r r r � s zTransactional.__enter__c C sT | j dkrd S |d u rPz | �� W n, tyN } z|| _� W Y d }~n d }~0 0 d S )Nr! )r% �commit� Exceptionr< )r r r r �er r r r � s zTransactional.__exit__c C s2 i }t | �D ] }| | d ur | | ||< q |�� S r )rT �__repr__)r r\ rK r r r rf � s zTransactional.__repr__c C s� i }| j �H | D ]2}|| jv r||vs6| | || kr| | ||< qW d � n1 sX0 Y | jD ]8}t| | �| | || �}|r�|||< qht� ||< qh| jD ]}| | || ||< q�|S r )r' rH rF r` rG �_nested)r �vsr\ r] �diffr r r �__sub__� s , zTransactional.__sub__c C s� i }i }| j �� |j �� tt| �� �t|�� � �D ]d}| �|d �|�|d �krn| �|�||< |�|�||< q4|| vr�|| ||< q4||vr4| | ||< q4W d � n1 s�0 Y W d � n1 s�0 Y | jD ]p}t| | �| | || �}t|| �|| | | �}|�r(|||< n t� ||< |�rB|||< q�t� ||< q�| jD ]"}| | || \||< ||< �qT||fS r )r' rG rT �keys�getrF r` rg )r rh �left�rightr] ZldiffZrdiffr r r � __floordiv__� s2 J zTransactional.__floordiv__c C s d S r r r r r r �detach s zTransactional.detachc C s d S r r )r �datar r r �load s zTransactional.loadc O s d S r r )r �argsr, r r r rc s zTransactional.commitc C s | j d S )N���)r> r r r r �last_snapshot_id s z Transactional.last_snapshot_idc C s� | j j�j d | _| �� | j�0 t| �� �D ] }| |= q,d| d< W d � n1 sT0 Y d| _W d � n1 sx0 Y d S )N�invalid� ipdb_scope)r8 Z exclusiver7 rp r' rT rk r% )r rK r r r � invalidate s &zTransactional.invalidatec C s| | j �b || jv sJ �| j| | j|< | j| | j|< | j| | _| j�|� | j|= | W d � S 1 sn0 Y d S r )r& rA �local_txrB r( r> �remove)r �sidr r r �revert2 s zTransactional.revertc C s� | j rtd��| jdur(| jjr(td��| jd|d�}|| j|j< | j�|j� |� � D ] \}}t |t �rX|j |jd� qX|jS )z% Create new snapshot z(Can't init snapshot from a nested objectNz'Can't create snapshots on released IPDBT�rL r; )r{ ) r9 r r8 �_stoprM rA r; r> rQ r_ rZ r6 r )r r{ �tr] rb r r r r < s zTransactional.snapshotc C s | j std��| j| j d S )Nzcreate a snapshot firstrt )r> r* rA r r r r � last_snapshotL s zTransactional.last_snapshotc C s2 | j � || j_W d � n1 s$0 Y d S r )r& r@ �current)r �txr r r �_set_current_txS s z Transactional._set_current_txc C sF | j �, t| jd�s d| j_| jjW d � S 1 s80 Y dS )z? The current active transaction (thread-local) r� N)r& �hasattrr@ r� r r r r �_get_current_txW s z Transactional._get_current_txc C sF | j �, t| jd�s i | j_| jjW d � S 1 s80 Y d S )Nr� )r& r� r@ r� r r r r � _get_local_txd s zTransactional._get_local_txc C s" | j dur| j �� n| �� S dS )z' Start new transaction N)r9 r) �_beginr r r r r) n s zTransactional.beginc C s� | j d ur| j jrtd��| jd|d�}|| j|j< || j|j< | jd u rP|| _|�� D ]0\}}t |t �rX|j |jd� |j|j ||< qX|jS )Nz(Can't start transaction on released IPDBFr} )�tid) r8 r~ r rM ry r; rB r( r_ rZ r6 r� )r r� r r] rb r r r r� w s zTransactional._beginc C s� | j du rtd��|p | j j}| �d�dkrb| j dur>| j }nt�d� | }tdd� |�� D ��S | j�b | j | | }| | j | }| j D ]*}|| |d| < || |d | < ||= q�|W d � S 1 s�0 Y dS ) z~ Review the changes made in the transaction `tid` or in the current active transaction (thread-local) Nr$ rw �createz&the "create" scope without transactionc S s( g | ] }|d dur|d |d f�qS )r Nr r )�.0�xr r r � <listcomp>� � z(Transactional.review.<locals>.<listcomp>z-%sz+%s) r( r* r; rl �log�warning�dictr_ r& rB rF )r r� �prime�addedZremovedr] r r r �review� s& � zTransactional.reviewc C s� | j �� |du r(| j}|du r2td��n | j| }| j|krBd| _| jD ](}|| | | jv rH| | �|| � qH| �� D ]6\}}t|t �rzz|� |j � W qz t y� Y qz0 qz| j |j = | j|j = W d � n1 s�0 Y dS )z\ Drop a transaction. If tid is not specified, drop the current one. Nzno transaction)r& r( r* rB rF �linksZ disconnectr_ rZ r6 �dropr; �KeyErrorry )r r� r� r] rb r r r r� � s& zTransactional.dropc C s |s<| � |�|krd S | j}|||< |d ur�t�� |j|< n�t�| ||� | j�L || jv r�| j � |dd� �}||| j| j �r�| j| � � W d � n1 s�0 Y t | j �� �D ]@}||jv r�||v r�| j � |dd� �||| �r�|j| � � q�d S )Nc S s | |kS r r �r� �yr r r �<lambda>� r� z+Transactional.__setitem__.<locals>.<lambda>c S s | |kS r r r� r r r r� � r� )rl r( r �EventrC r rI r& rD � _fields_cmprb rG rT rB �values)r r- r] rb r4 �func�tnr r r rI � s& ,�zTransactional.__setitem__c C s2 d | |< |s"| j }||v r.||= n t�| |� d S r )r( r � __delitem__)r r- r] r4 r r r r� � s zTransactional.__delitem__c C s || |< | S r r �r r] rb r r r �option� s zTransactional.optionc C s | |= | S r r )r r] r r r �unset� s zTransactional.unsetc C s@ | j �� D ]0\}}|| jvr |�t� |�� s td| ��q d S )Nztarget %s is not set)rC r_ �_virtual_fields�wait� SYNC_TIMEOUTr r )r r] �targetr r r �wait_all_targets� s z Transactional.wait_all_targetsc C sJ | j | �t� | j� | j �|��� W d � S 1 s<0 Y d S r )rD r� r� r& rU r )r r] �timeoutr r r � wait_target� s zTransactional.wait_targetc C sd | j �J t�� | j|< || j| _| �|�|kr>| j| �� | W d � S 1 sV0 Y d S r )r& r r� rD rb rl rG r� r r r � set_target s zTransactional.set_targetc C s> | j �$ | j| | j|< | W d � S 1 s00 Y d S r )r& rD )r Zkey_fromZkey_tor r r � mirror_target s zTransactional.mirror_targetc C s || |< | S r r r� r r r rG s zTransactional.set)NNNN)T)TNNF)N)N)N)N)1r r r r1 rH r� r� rF rg r �propertyrN rS rX r[ rM r r rf rj ro rp rr rc ru rx r| r r� r� r� r( r� ry r) r� r� r� r3 rI r� r� r� r� r� r� r� r� rG r r r r r6 U s\ # r6 )r1 �loggingr Zpyroute2.commonr r Zpyroute2.ipdb.exceptionsr Zpyroute2.ipdb.linkedsetr r� � getLoggerr r� �objectr r3 r5 r6 r r r r �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка