EVOLUTION-MANAGER
Edit File: Transaction.cpython-36.pyc
3 x?ag� � @ s� d Z ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlZddl Z ddl Z ej d� e j dkrvd d � Z ned � G d d� de�Zdd� ZdS )z} Transaction - provides transactional support $Id: //eng/vdo-releases/aluminum/src/python/vdo/utils/Transaction.py#1 $ � )�absolute_import)�division)�print_function)�unicode_literals)�wrapsN� Transaction� c C s | j |��d S )N)�with_traceback)�ex�val�tb� r �!/usr/lib/python3.6/Transaction.py�reraise' s r z:def reraise(ex, val, tb): raise type(ex), val, tb c sV e Zd ZdZi Zedd� �Zdd� Zddd�Z� fd d �Z ed d � �Z d d� Z � Z S )r z%Client-visible transaction object. c C s | j � d S )z<Returns the current transaction for the current thread. � ���)�_threadTransactionList)�clsr r r � transaction; s zTransaction.transactionc C s | j j|� dS )z�Adds callable undoStage to transaction stages. Arguments: undoStage (callable) - callable to execute as part of transaction roll-back N)�_Transaction__undoStages�append)�self� undoStager r r � addUndoStageB s zTransaction.addUndoStageNc C s t �dS )a+ Sets the message to handle if there is an exception. If message is specified and an exception occurs the exception will be appended to the message using "; {0}" where "{0}" represents the exception. If message is not specified, the exception will be coerced to a string and passed to handleMessage. Specifying handleMessage as None will clear both handleMessage and message. Arguments: handleMessage (callable) - method to handle message message (string) - message N)�NotImplementedError)r � handleMessage�messager r r � setMessageL s zTransaction.setMessagec s t t| �j� g | _d S )N)�superr �__init__r )r )� __class__r r r b s zTransaction.__init__c C sD d}t j� j}y| j| }W n" tk r> g }|| j|< Y nX |S )z�Returns the transaction list for the current thread, creating it if need be. Returns: list of Transactions N)� threadingZ currentThreadZident� _Transaction__transactionLists�KeyError)r ZtransactionListZthreadIdr r r r i s z"Transaction._threadTransactionListc C s | j S )zgReturns the list of undo stages for the transaction. Returns: list of undo stages )r )r r r r � _undoStages{ s zTransaction._undoStages)N) �__name__� __module__� __qualname__�__doc__r" � classmethodr r r r r r$ � __classcell__r r )r r r 0 s c s. G � fdd�dt �� t��� �fdd��}|S )zGMethod decorator providing transactional capabilities to the method. c sL e Zd ZdZedd� �Zedd� �Zdd� Z�� fdd �Zd d d �Z � Z S )z#transactional.<locals>._TransactionzYDecorator-local transaction object providing actual transaction capabilities. c S s | j � j| � � | j� S )z`Adds, and returns, a transaction to the transaction list for the current thread. )r r r )r r r r �addTransaction� s z2transactional.<locals>._Transaction.addTransactionc S s | j � j� dS )zBRemoves the current transaction for for the current thread. N)r �pop)r r r r �removeTransaction� s z5transactional.<locals>._Transaction.removeTransactionc S s� | j dk r@| jdk r2| j td�j| jt|��� n| j t|�� | j� dd� }|j� x,|D ]$}y |� W q^ tk r� Y q^X q^W dS )z�Performs the undo processing of the transaction. Exceptions from the undo stages are ignored. Arguments: exception - the exception which resulted in undo being called Nz{0}; {1})�_Transaction__handleMessage�_Transaction__message�_�format�strr$ �reverse� Exception)r Z exceptionZ undoStagesr r r r �undo� s z(transactional.<locals>._Transaction.undoc s t � | �j� d | _d | _d S )N)r r r. r/ )r )� _Transactionr r r r � s z,transactional.<locals>._Transaction.__init__Nc S s" || _ | j d krd | _n|| _d S )N)r. r/ )r r r r r r r � s z.transactional.<locals>._Transaction.setMessage)N) r% r& r' r( r) r+ r- r5 r r r* r )r6 )r r r6 � s r6 c sp � j � }d}zTy�| |�}W n@ tk r\ } z$|j|� t||tj� d � W Y dd}~X nX W d� j� X |S )zDWrapper method providing transactional processing capabilities. N� )r+ r4 r5 r �sys�exc_infor- )�args�kwargsr �resultr )r6 �funcr r �wrap� s * ztransactional.<locals>.wrap)r r )r= r> r )r6 r= r � transactional� s Jr? )r r )r( Z __future__r r r r � functoolsr �gettextr8 r! Zinstall� version_infor �exec�objectr r? r r r r �<module> s X