Ñò
4äKc @ s] d Z d d k Z d d k Z d d k Z d d k Z d d k Z d d k Z d d k l Z d d k l
Z
d d k l Z d d k
l Z d d k l Z e ƒ Z d „ Z d f d
„ ƒ YZ d e f d „ ƒ YZ d
e f d „ ƒ YZ d „ Z d „ Z d „ Z d e f d „ ƒ YZ d f d „ ƒ YZ d f d „ ƒ YZ d f d „ ƒ YZ d S( s±
Transaction objects manage resources for an individual activity.
Compatibility issues
--------------------
The implementation of Transaction objects involves two layers of
backwards compatibility, because this version of transaction supports
both ZODB 3 and ZODB 4. Zope is evolving towards the ZODB4
interfaces.
Transaction has two methods for a resource manager to call to
participate in a transaction -- register() and join(). join() takes a
resource manager and adds it to the list of resources. register() is
for backwards compatibility. It takes a persistent object and
registers its _p_jar attribute. TODO: explain adapter
Two-phase commit
----------------
A transaction commit involves an interaction between the transaction
object and one or more resource managers. The transaction manager
calls the following four methods on each resource manager; it calls
tpc_begin() on each resource manager before calling commit() on any of
them.
1. tpc_begin(txn)
2. commit(txn)
3. tpc_vote(txn)
4. tpc_finish(txn)
Before-commit hook
------------------
Sometimes, applications want to execute some code when a transaction is
committed. For example, one might want to delay object indexing until a
transaction commits, rather than indexing every time an object is changed.
Or someone might want to check invariants only after a set of operations. A
pre-commit hook is available for such use cases: use addBeforeCommitHook(),
passing it a callable and arguments. The callable will be called with its
arguments at the start of the commit (but not for substransaction commits).
After-commit hook
------------------
Sometimes, applications want to execute code after a transaction is
committed or aborted. For example, one might want to launch non
transactional code after a successful commit. Or still someone might
want to launch asynchronous code after. A post-commit hook is
available for such use cases: use addAfterCommitHook(), passing it a
callable and arguments. The callable will be called with a Boolean
value representing the status of the commit operation as first
argument (true if successfull or false iff aborted) preceding its
arguments at the start of the commit (but not for substransaction
commits).
Error handling
--------------
When errors occur during two-phase commit, the transaction manager
aborts all the resource managers. The specific methods it calls
depend on whether the error occurs before or after the call to
tpc_vote() on that transaction manager.
If the resource manager has not voted, then the resource manager will
have one or more uncommitted objects. There are two cases that lead
to this state; either the transaction manager has not called commit()
for any objects on this resource manager or the call that failed was a
commit() for one of the objects of this resource manager. For each
uncommitted object, including the object that failed in its commit(),
call abort().
Once uncommitted objects are aborted, tpc_abort() or abort_sub() is
called on each resource manager.
Synchronization
---------------
You can register sychronization objects (synchronizers) with the
tranasction manager. The synchronizer must implement
beforeCompletion() and afterCompletion() methods. The transaction
manager calls beforeCompletion() when it starts a top-level two-phase
commit. It calls afterCompletion() when a top-level transaction is
committed or aborted. The methods are passed the current Transaction
as their only argument.
iÿÿÿÿN( t StringIO( t interface( t WeakSet( t TransactionFailedError( t
interfacesc C s t | | t ƒ t j S( N( t getattrt _marker( t objt attr( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyt myhasattrv s t Statusc B s& e Z d Z d Z d Z d Z d Z RS( t Activet
Committingt Committedt Doomeds
Commit failed( t __name__t
__module__t ACTIVEt
COMMITTINGt COMMITTEDt DOOMEDt COMMITFAILED( ( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyR
y s
t Transactionc B s) e Z e i e i e i ƒ d Z d Z d Z
d Z d d d „ Z d „ Z
d „ Z d „ Z d „ Z e d „ Z d „ Z d „ Z d
„ Z d „ Z d „ Z d
„ Z d „ Z d d d „ Z d „ Z d „ Z d d d „ Z e d „ Z d „ Z d „ Z! d „ Z" d „ Z# d d „ Z$ d „ Z% RS( i t c C s§ t i | _ g | _ | d j o
t ƒ } n | | _ | | _ h | _ h | _ h | _
t i d t
i ƒ ƒ | _ | i i d ƒ d | _ g | _ g | _ d S( Ns txn.%ds new transaction( R
R t statust
_resourcest NoneR t _synchronizerst _managert _adapterst _votedt
_extensiont loggingt getLoggert threadt get_identt logt debugt _failure_tracebackt _before_committ
_after_commit( t selft
synchronizerst manager( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyt __init__š s
c C s | i t i j S( N( R R
R ( R) ( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyt isDoomed¿ s c C sG | i t i j o0 | i t i j o
t ƒ ‚ n t i | _ n d S( N( R R
R R t AssertionError( R) ( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyt doom s
c C s t d | i i ƒ ƒ ‚ d S( Ns3 An operation previously failed, with traceback:
%s( R R& t getvalue( R) ( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyt _prior_operation_failedÍ s c C sè | i t i j o | i ƒ n | i t i j o9 | i t i j o& t d t i t i | i f ƒ ‚ n t | d ƒ o t | ƒ } n | i i
| ƒ | i o= t | | ƒ } x+ | i i
ƒ D] } | i i
| ƒ qÆ Wn d S( Ns) expected txn status %r or %r, but it's %rt prepare( R R
R R1 R R t
ValueErrorR t DataManagerAdapterR t appendt _savepoint2indext AbortSavepointt keyst _savepoints( R) t resourcet datamanager_savepointt transaction_savepoint( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyt joinÓ s
c C s¤ | i t i j o | i ƒ n y t | | | i Œ } Wn! | i | i ƒ | i ƒ n X| i d j o t
i ƒ | _ n | i d 7_ | i | i | <| S( Ni (
R R
R R1 t SavepointR t _cleanupt _saveAndRaiseCommitishErrorR6 R t weakreft WeakKeyDictionaryt _savepoint_index( R) t
optimistict savepoint( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyRE õ s c C sU | i } | | } x; | i ƒ D]- \ } } | | j o d | _ | | =q q Wd S( N( R6 t itemsR t transaction( R) RE t savepoint2indext indext i( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyt _remove_and_invalidate_after s
c C s4 x | i i ƒ D] } d | _ q W| i i ƒ d S( N( R6 R8 R RG t clear( R) RE ( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyt _invalidate_all_savepoints s
c C sœ t | d | ƒ } | d j o t d ƒ ‚ n | i i | ƒ } | d j o: t | ƒ } | i i | ƒ | | i | <| i | ƒ n | i i | ƒ d S( Nt _p_jars Register with no manager( R R R3 R t gett MultiObjectResourceAdaptert objectsR5 R= ( R) R R+ t adapter( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyt register s
c s; ˆ i t i j o t i ƒ ‚ n ˆ i o ˆ i ƒ n ˆ i t i j o ˆ i ƒ n ˆ i ƒ ˆ i
i ‡ f d † ƒ t i ˆ _ y ˆ i
ƒ t i ˆ _ Wn8 ˆ i ƒ \ } } } ˆ i d t ƒ | | | ‚ nH Xˆ i o ˆ i i ˆ ƒ n ˆ i
i ‡ f d † ƒ ˆ i d t ƒ ˆ i i d ƒ d S( Nc s
| i ˆ ƒ S( ( t beforeCompletion( t s( R) ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyt > s R c s
| i ˆ ƒ S( ( t afterCompletion( RU ( R) ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyRV K s t commit( R R
R R t DoomedTransactionR6 RM R R1 t _callBeforeCommitHooksR t mapR t _commitResourcesR t _saveAndGetCommitishErrort _callAfterCommitHookst FalseR t freet TrueR$ R% ( R) t tt vt tb( ( R) s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyRX 2 s*
c C s† t i | _ t ƒ } | _ t i ƒ \ } } } t i t i d ƒ d | ƒ t i | d | ƒ | i t i
| | ƒ ƒ | | | f S( Ni ( R
R R R R& t syst exc_infot tracebackt print_stackt _getframeR t print_tbt
writelinest format_exception_only( R) t ftRb Rc Rd ( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyR] O s c C s% | i ƒ \ } } } | | | ‚ d S( N( R] ( R) Rb Rc Rd ( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyR@ \ s c C s
t | i ƒ S( N( t iterR' ( R) ( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyt getBeforeCommitHooks` s c C s: | d j o
h } n | i i | t | ƒ | f ƒ d S( N( R R' R5 t tuple( R) t hookt argst kws( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyt addBeforeCommitHookc s
c C s7 x' | i D] \ } } } | | | Ž q
Wg | _ d S( N( R' ( R) Rq Rr Rs ( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyRZ h s
c C s
t | i ƒ S( N( Rn R( ( R) ( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyt getAfterCommitHooksq s c C s: | d j o
h } n | i i | t | ƒ | f ƒ d S( N( R R( R5 Rp ( R) Rq Rr Rs ( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyt addAfterCommitHookt s
c C sÍ | i p d SxW | i D]L \ } } } y | | | | Ž Wq | i i d | d t i ƒ ƒq Xq WxK | i D]@ } y | i | ƒ Wqs | i i d | d t i ƒ ƒqs Xqs Wg | _ g | _ d S( Ns& Error in after commit hook exec in %s Rf s Error in abort() on manager %s( R( R$ t errorRe Rf R t abortR' ( R) R Rq Rr Rs t rm( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyR^ y s$
c s= t ˆ i ƒ } | i t ƒ yÄ x | D] } | i ˆ ƒ q& Wx/ | D]' } | i ˆ ƒ ˆ i i d | ƒ qD Wx. | D]& } | i ˆ ƒ t ˆ i
t | ƒ ( t __class__R R+ R ( R) ( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyt __repr__ s c C s
| i i ƒ S( N( R+ t sortKey( R) ( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyR˜ s c C s | i i | ƒ d S( N( R+ R} ( R) t txn( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyR} s c C s | i i | ƒ d S( N( R+ R€ ( R) R™ ( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyR€ s c C s | i i | ƒ d S( N( R+ R„ ( R) R™ ( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyR„ s c C s: x3 | i D]( } | i i | | ƒ | i d 7_ q
Wd S( Ni ( RQ R+ RX R” ( R) R™ t o( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyRX s
c C s | i i | ƒ d S( N( R+ R~ ( R) R™ ( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyR~ s c C s§ d } x} | i D]r } y | i i | | ƒ Wq | d j o t i ƒ \ } } } n | i i d t | ƒ d t i ƒ ƒq Xq W| d j o | | | ‚ n d S( Ns Failed to abort object: %sRf ( R RQ R+ Rx Re Rf R$ Rw t object_hint( R) R™ Rd Rš Rb Rc ( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyRx s
!
( R R t __doc__R, R— R˜ R} R€ R„ RX R~ Rx ( ( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyRP ô s c C s t | i ƒ | i ƒ ƒ S( N( t cmpR˜ ( t rm1t rm2( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyR| ( s c C sI | i i } t | d t ƒ } | t j o t | ƒ } n d | | f S( s[ Return a string describing the object.
This function does not raise an exception.
t _p_oids %s oid=%s( R– R R R t oid_repr( Rš t klasst oid( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyR› + s
c C s… t | t ƒ og t | ƒ d j oT t | ƒ i d ƒ } t | ƒ d @o d | } n | d j o
d } n d | St | ƒ Sd S( Ni t 0i R t 00t 0x( t
isinstancet strt lent hexlifyt lstript repr( R£ t as_hex( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyR¡ 9 s #
R4 c B sV e Z d Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z
RS( s‹ Adapt zodb 4-style data managers to zodb3 style
Adapt transaction.interfaces.IDataManager to
ZODB.interfaces.IPureDatamanager
c C s
| | _ d S( N( t _datamanager( R) t datamanager( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyR, S s c C s d S( N( ( R) RG ( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyRX X s c C s | i i | ƒ d S( N( R® Rx ( R) RG ( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyRx ] s c C s d S( N( ( R) RG ( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyR} ` s c C s | i i | ƒ d S( N( R® Rx ( R) RG ( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyR„ e s c C s | i i | ƒ d S( N( R® RX ( R) RG ( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyR€ h s c C s | i i | ƒ d S( N( R® R2 ( R) RG ( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyR~ k s c C s
| i i ƒ S( N( R® R˜ ( R) ( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyR˜ n s ( R R Rœ R, RX Rx R} R„ R€ R~ R˜ ( ( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyR4 G s R> c B s? e Z d Z e i e i ƒ e d „ ƒ Z d „ Z d „ Z
RS( sƒ Transaction savepoint.
Transaction savepoints coordinate savepoints for data managers
participating in a transaction.
c C s
| i d j S( N( RG R ( R) ( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyRV y s c G sŠ | | _ g | _ } xm | D]e } y
| i } Wn9 t j
o- | p t d | ƒ ‚ n t | ƒ } n X| ƒ } | i | ƒ q Wd S( Ns Savepoints unsupported( RG R9 RE t AttributeErrort TypeErrort NoRollbackSavepointR5 ( R) RG RD t resourcest
savepointsR¯ RE ( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyR, { s
c C sj | i } | d j o
t i ‚ n | i | ƒ y" x | i D] } | i ƒ q= WWn | i ƒ n Xd S( N( RG R R t InvalidSavepointRollbackErrorRK R9 t rollbackR@ ( R) RG RE ( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyR¶ ‹ s
( R R Rœ R R‘ R t
ISavepointt propertyt validR, R¶ ( ( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyR> q s
R7 c B s e Z d „ Z d „ Z RS( c C s | | _ | | _ d S( N( R¯ RG ( R) R¯ RG ( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyR, š s c C s | i i | i ƒ d S( N( R¯ Rx RG ( R) ( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyR¶ ž s ( R R R, R¶ ( ( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyR7 ˜ s R² c B s e Z d „ Z d „ Z RS( c C s
| | _ d S( N( R¯ ( R) R¯ ( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyR, £ s c C s t d | i ƒ ‚ d S( Ns Savepoints unsupported( R± R¯ ( R) ( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyR¶ ¦ s ( R R R, R¶ ( ( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyR² ¡ s ( Rœ R Re R" t warningsRA Rg t cStringIOR t zopeR t transaction.weaksetR t transaction.interfacesR RG R t objectR R R
R RP R| R› R¡ R4 R> R7 R² ( ( ( s< /usr/lib/python2.6/site-packages/transaction/_transaction.pyt b s0
ÿ o4 *'