Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/pyroute2/ndb/__pycache__/transaction.cpython-39.pyc
Ðазад
a ]�h2, � @ s� d Z ddlZddlZddlZddlZddlZe�e�ZG dd� de �Z G dd� d�Z G dd� de �Z G d d � d �Z G d d � d �ZdS ) a� One object ---------- All the changes done using one object are applied in the order defined by the corresponding object class. .. code-block:: python eth0 = ndb.interfaces["eth0"] eth0.add_ip(address="10.0.0.1", prefixlen=24) eth0.set(state="up") eth0.set(mtu=1400) eth0.commit() In the example above first the interface attributes like state, mtu, ifname etc. will be applied, and only then IP addresses, bridge ports and like that, regardless the order they are referenced before the `commit()` call. The order is ok for most of cases. But if not, one can control it by calling `commit()` in the required places, breaking one transaction into several sequential transactions. And since RTNL object methods return the object itself, it is possible to write chains with multiple `commit()`: .. code-block:: python ( ndb.interfaces .create(ifname="test", kind="dummy") .add_ip(address="10.0.0.1", prefixlen=24) .commit() .set(state="up") .commit() ) Here the order is forced by explicit commits. Multiple objects ---------------- An important functionality of NDB are rollbacks. And there is a way to batch changes on multiple objects so one failure will trigger rollback of all the changes on all the objects. .. code-block:: python ctx = ndb.begin() ctx.push( # first set up a bridge ( ndb.interfaces .create(ifname="br0", kind="bridge") .add_port("eth0") .add_port("eth1") .set(state="up") .add_ip("10.0.0.2/24") ), # and only then create a route ( ndb.routes .create( dst="192.168.0.0", dst_len=24, gateway="10.0.0.1" ) ) ) ctx.commit() # if something goes wrong, the whole batch will be reverted Ping a remote host ------------------ The simplest usecase for external checks is to test if a remote IP is still reachable after the changes are applied: .. code-block:: python from pyroute2.ndb.transaction import PingAddress ctx = ndb.begin() ctx.push( ndb.routes.create(dst="10.0.0.0", dst_len=24, gateway="172.16.0.1"), PingAddress("10.0.0.1") ) ctx.commit() # the route will be removed if ping fails Or on the contrary, don't run transaction if a remote IP is reachable: .. code-block:: python from pyroute2.ndb.transaction import Not, PingAddress ctx = ndb.begin() ctx.push( Not(PingAddress("10.0.0.1")), ndb.routes.create(dst="10.0.0.0", dst_len=24, gateway="172.16.0.1") ) try: ctx.commit() except CheckProcessException: pass In this example, the route will be added only if `10.0.0.1` is not reachable. The default ping timeout is set to 1, but it is possible to customize it: .. code-block:: python PingAddress("10.0.0.1", timeout=10) Check an external processes --------------------------- A more generic type of check is CheckProcess: .. code-block:: python from pyroute2.ndb.transaction import CheckProcess with ndb.begin() as ctx: ctx.push(ndb.routes.create( dst="10.0.0.0", dst_len=24, gateway="172.16.0.1" )) ctx.push(CheckProcess('/path/to/script.sh')) # # --> <-- the route will be removed if the script fails `CheckProcess` is `subprocess.Popen` based, is not a shell call, thus no pipes or other shell syntax are allowed. `CheckProcess` also accepts `timeout` argument: .. code-block:: python CheckProcess('/path/to/script.sh', timeout=10).commit() If the subprocess doens't finish within the timeout, it will be terminated with SIGTERM. SIGKILL is not used. Logging and debug ----------------- `CheckProcess` and `PingAddress` accept log as an argument: .. code-block:: python PingAddress("10.0.0.1", log=ndb.log.channel("util")).commit() CheckProcess("/path/to/script.sh", log=ndb.log.channel("util")).commit() The check objects are thread safe and reusable, it is possible to run `commit()` on them multiple times. The subprocess' stdout and stderr will be both logged and saved: .. code-block:: python check = CheckProcess("/path/to/script.sh") while True: check.commit() # periodic check, the loop breaks on failure print(f'stdout: {check.out}') print(f'stderr: {check.err}') print(f'return code: {check.return_code}') time.sleep(10) Check negation -------------- It is possible to negate the check for `CheckProcess` and child classes .. code-block:: python from pyroute2.ndb.transaction import Not, CheckProcess check = Not(CheckProcess('/path/to/script.sh')) check.commit() API --- � Nc @ s e Zd ZdS )�CheckProcessExceptionN)�__name__� __module__� __qualname__� 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/transaction.pyr � s r c @ s2 e Zd ZdZd dd�Zdd� Zdd� Zd d � ZdS ) � CheckProcessz� Run an external process on `commit()` and raise `CheckProcessException` if the return code is not 0. Objects of this class are thread safe and reusable. Nc C sh t |t�std��t|�dks&td��|p,t| _|| _t�|�| _ || _ d | _ d | _ d | _ t�� | _d S )Nz"command must be a non empty stringr )� isinstance�str� TypeError�len� global_log�log�command�shlex�split�args�timeout� return_code�out�err� threading�Lock�lock)�selfr r r r r r �__init__� s zCheckProcess.__init__c C s2 | j �� t�| jd �| jd< | jd d u r4t� �tj| jtjtjd�}z�zV| j� d| j� �� |j | j d�\| _ | _ | j� d| j � �� | j� d| j � �� W n< tjy� | j� d� |�� |j�� |j�� Y n0 W |�� | _n |�� | _0 | jdk�rtd��W d � n1 �s$0 Y d S ) Nr )�stdout�stderrzprocess check )r zprocess output: zprocess stderr: zprocess timeout expiredzCheckProcess failed)r �shutil�whichr �FileNotFoundError� subprocess�Popen�PIPEr �debug� communicater r r �TimeoutExpired� terminater �closer �waitr r )r �processr r r �commit� s( � zCheckProcess.commitc C s d S �Nr �r r r r �rollback� s zCheckProcess.rollbackc C s d| j � d�S )N�[�])r r- r r r �__repr__� s zCheckProcess.__repr__)NN)r r r �__doc__r r+ r. r1 r r r r r � s r c s e Zd Zd� fdd� Z� ZS )� PingAddressN� c s$ t t| �jd|� d|� �|d� d S )Nz ping -c 1 -W � )r )�superr3 r )r �addressr r �� __class__r r r � s �zPingAddress.__init__)Nr4 )r r r r � __classcell__r r r8 r r3 � s r3 c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) �Notz� Negate the `CheckProcess` results. If `CheckProcess.commit()` succeeds, raise CheckProcessException, and vice versa, if `CheckProcess.commit()` fails, return success. c C s || _ d S r, )�tx)r Z transactionr r r r s z Not.__init__c C sB d}z| j �� W n ty( d}Y n0 |r>t| j � d���d S )NTFz succeeded)r< r+ � Exceptionr )r �successr r r r+ s z Not.commitc C s d S r, r r- r r r r. s z Not.rollbackN)r r r r2 r r+ r. r r r r r; s r; c @ sn e Zd ZdZddd�Zdd� Zdd� Zd d � Zd d � Zddd�Z dd� Z dd� Z d dd�Z dd� Z dd� ZdS ) � Transactiona� `Transaction` class is an independent utility class. Being designed to be used with NDB object transactions, it may be used with any object implementing commit/rollback protocol, see `commit()` method. The class supports the context manager protocol and `Transaction` objects may be used in `with` statements: .. code-block:: python with Transaction() as tx: tx.push(obj0) # enqueue objects tx.push(obj1) # --> <-- run commit() for every object in self.queue # # if any commit() fails, run rollback() for every # executed commit() in the reverse order NDB provides a utility method to create `Transaction` objects: .. code-block:: python with ndb.begin() as tx: tx.push(ndb.interfaces["eth0"].set(state="up")) tx.push(ndb.interfaces["eth1"].set(state="up")) Nc C s4 g | _ t�� | _| j�� tp || _| j�d� d S )Nzbegin transaction)�queuer �Event�event�clearr r r$ )r r r r r r 6 s zTransaction.__init__c C s | S r, r r- r r r � __enter__= s zTransaction.__enter__c C s |d u r| � � d S r, )r+ )r �exc_type� exc_value� tracebackr r r �__exit__@ s zTransaction.__exit__c G s. |D ]$}| j �dt|� � | j�|� q| S )z� Push objects to the transaction queue. One may use any number of positional arguments: .. code-block:: python tx.push(obj0) tx.push(obj0, obj1, obj2) tx.push(*[obj0, obj1, obj2]) �queue %s)r r$ �typer@ �append)r �argv�objr r r �pushD s zTransaction.pushc C s" | j �dt|� � | �|� | S )z1 Append one object to the queue. rI )r r$ rJ rN )r rM r r r rK T s zTransaction.append���c C s | j �d| � | j�|� | S )zz Pop an object from the queue. If an index is not specified, pop the last (the rightmost) object. zpop %s)r r$ r@ �pop)r �indexr r r rP \ s zTransaction.popc C s* | j �d|t|�f � | j�||� | S )zR Insert an object into the queue. The position index is required. z insert %i %s)r r$ rJ r@ �insert)r rQ rM r r r rR e s zTransaction.insertc C s | j �d� g | _| S )z= Cancel the transaction and empty the queue. zcancel transaction)r r$ r@ r- r r r �cancelm s zTransaction.cancelc C s | j �|�S )zJ Wait until the transaction to be successfully committed. )rB r) )r r r r r r) u s zTransaction.waitc C s | j �� S )z1 Check if the done event is set. )rB �is_setr- r r r �done{ s zTransaction.donec C s� | j �d� g }| jD ]�}|�|� z |�� W q ty� t|�D ]F}z |�� W qF ty� } z | j �d| � W Y d}~qFd}~0 0 qF� Y q0 q| j � � | S )a[ Execute `commit()` for every queued object. If an execution fails, execute `rollback()` for every executed commit. All objects in the queue that follows the failed one will remain intact. Raises the original exception of the failed `commit()`. All the `rollback()` exceptions are ignored. r+ z ignore rollback exception: %sN) r r$ r@ rK r+ r= �reversedr. �warningrB �set)r Z rollbacksrM �rb�er r r r+ � s ( zTransaction.commit)N)rO )N)r r r r2 r rD rH rN rK rP rR rS r) rU r+ r r r r r? s r? )r2 �loggingr r r! r � getLoggerr r r= r r r3 r; r? r r r r �<module> s ; 4
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка