3

x?ag��@s�dZd
dl
mZ
d
dl
mZ
d
dl
mZ
d
dl
mZ
d
dlmZ
d
dlZd
dl	Z	d
dl
Z
ejd�

e	jdkrvd
d�Z
ned�

Gd
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�cCs|j|�
�
dS)
N)
�with_traceback)�ex�val�tb�r
�!/usr/lib/python3.6/Transaction.py�reraise'srz:def reraise(ex, val, tb):
    raise type(ex), val, tb
    csVeZ
dZd
ZiZedd��
Zdd�Zddd�
Z�f
d	d
�Z	edd��
Z
d
d�Z�ZS)rz%Client-visible transaction object.
  c

Cs|j�dS)z<Returns the current transaction for the current thread.
    �
���)
�_threadTransactionList)
�clsr
r
r�transaction;szTransaction.transactioncCs|jj
|
�

d
S)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�addUndoStageBszTransaction.addUndoStageNc
Cst�
d
S)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�
setMessageLszTransaction.setMessagec

stt
|�j�
g|_dS)
N)�superr�__init__r)
r)
�	__class__r
rrbs

zTransaction.__init__c
CsDd
}
tj
�j}y|j|}
Wn"tk
r>


g}
|
|j|<YnX|
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)rZtransactionListZthreadIdr
r
rris







z"Transaction._threadTransactionListc


Cs|jS)
zgReturns the list of undo stages for the transaction.

       Returns:
         list of undo stages
    )
r)
rr
r
r�_undoStages{szTransaction._undoStages)
N)
�__name__�
__module__�__qualname__�__doc__r"�classmethodrrrrrr$�
__classcell__r
r
)
r rr0s

c
s.G�f
d
d�dt��t
�
�
��
fdd��
}
|
S)zGMethod decorator providing transactional capabilities to the method.
  csLeZ
dZd
Zedd��
Zedd��
Zdd�Z�
�fdd	�Zd
dd�
Z	�Z
S)z#transactional.<locals>._TransactionzYDecorator-local transaction object providing actual transaction
       capabilities.
    c

Ss|j�j
|��

|j�S)
z`Adds, and returns, a transaction to the transaction list for the
         current thread.
      )rrr)
rr
r
r�addTransaction�s
z2transactional.<locals>._Transaction.addTransactionc


Ss|j�j
�
d
S)zBRemoves the current transaction for for the current thread.
      N)r�pop)
rr
r
r�removeTransaction�sz5transactional.<locals>._Transaction.removeTransactioncSs�|jd
k	r@|j
d
k	r2|jtd�
j|j
t|
�
��

n|jt|
�
�

|j�d
d
�}|j�
x,|D]$}y
|�
Wq^tk
r�


Yq^Xq^Wd
S)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)rZ	exceptionZ
undoStagesrr
r
r�undo�s	












z(transactional.<locals>._Transaction.undoc

st�|�j
�
d|_d|_dS)
N)rrr.r/)
r)�_Transactionr r
rr�s


z,transactional.<locals>._Transaction.__init__NcSs"|
|_|jdkrd|_
n||_
dS)
N)r.r/)rrrr
r
rr�s



z.transactional.<locals>._Transaction.setMessage)
N)r%r&r'r(r)r+r-r5rrr*r
)
r6)
r rr6�s	r6csp�j�}d
}zTy�
||
�
}Wn@t
k
r\
}
z$|j|�

t||tj�d�
WYd
d
}~XnXWd
�j�
X|S)zDWrapper method providing transactional processing capabilities.
    N�)r+r4r5r�sys�exc_infor-)�args�kwargsr�resultr
)r6�funcr
r�wrap�s





*
ztransactional.<locals>.wrap)rr)r=r>r
)r6r=r�
transactional�sJr?)rr
)r(Z
__future__rrrr�	functoolsr�gettextr8r!Zinstall�version_infor�exec�objectrr?r
r
r
r�<module>s











X