Ñò
PhEc @ s| d d d d g Z d d k Z d d k Z d d k Z d d k Z d d k Z d d k Ty d d k Z d d k Z
Wn+ e j
o d d k Z d d k
Z
n Xy e i ƒ e Z Wn9 y d d k Z e Z Wqò e j
o
e Z qò Xn Xd d d „ ƒ YZ e ƒ Z d e d e d „ Z d d d
„ ƒ YZ d e f d „ ƒ YZ d
e f d „ ƒ YZ d e f d „ ƒ YZ d S( t Synchronizert NameLockt
_threadingt _threadiÿÿÿÿN( t *c B sW e Z d Z e ƒ Z d d d „ ƒ YZ d e d „ Z e d „ Z
d „ Z d „ Z RS( sß a proxy for an RLock object that is stored in a name
based registry.
Multiple threads can get a reference to the same RLock based on
the name alone, and synchronize operations related to that name.
t NLContainerc B s e Z d Z d „ Z d „ Z RS( s cant put Lock as a weakrefc C s- | o t i ƒ | _ n t i ƒ | _ d S( N( R t RLockt lockt Lock( t selft reentrant( ( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyt __init__. s c C s | i S( N( R ( R ( ( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyt __call__3 s ( t __name__t
__module__t __doc__R R ( ( ( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyR , s c C s | i | | ƒ | _ d S( N( t _get_lockR ( R t
identifierR
( ( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyR 6 s c C s | i ƒ i | ƒ S( N( R t acquire( R t wait( ( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyR 9 s c C s | i ƒ i ƒ d S( N( R t release( R ( ( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyR < s c s7 | d j o t i ˆ ƒ St i i | ‡ f d † ƒ S( Nc s
t i ˆ ƒ S( ( R R ( ( R
( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyt D s ( t NoneR R t lockst get( R R R
( ( R
s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyR ? s
( N(
R
R R t WeakValuedRegistryR R R t FalseR t TrueR R R ( ( ( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyR " s
c si t p
t } n | o0 t i d ˆ t i ƒ f ‡ ‡ ‡ f d † ƒ St i d ˆ ‡ f d † ƒ Sd S( sY
returns an object that synchronizes a block against many simultaneous
read operations and several synchronized write operations.
Write operations
are assumed to be much less frequent than read operations,
and receive precedence when they request a write lock.
uses strategies to determine if locking is performed via threading objects
or file objects.
the identifier identifies a name this Synchronizer is synchronizing against.
All synchronizers of the same identifier will lock against each other, within
the effective thread/process scope.
use_files determines if this synchronizer will lock against thread mutexes
or file locks. this sets the effective scope of the synchronizer, i.e.
it will lock against other synchronizers in the same process, or against
other synchronizers referencing the same filesystem referenced by lock_dir.
the acquire/relase methods support nested/reentrant operation within a single
thread via a recursion counter, so that only the outermost call to
acquire/release has any effect.
s
file_%s_%sc s t ˆ ˆ ˆ ƒ S( ( t FileSynchronizer( ( t digest_filenamesR t lock_dir( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyR j s s condition_%sc s
t ˆ ƒ S( ( t ConditionSynchronizer( ( R ( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyR m s N( t has_flockR t
synchronizerst sync_getR t get_ident( R t use_filesR R ( ( R R R s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyR K s
0t SyncStatec B s e Z d Z d „ Z RS( s\ used to track the current thread's reading/writing state as well as reentrant block countingc C s d | _ t | _ t | _ d S( Ni ( t reentrantcountR t writingt reading( R ( ( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyR s s ( R
R R R ( ( ( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyR% p s t SynchronizerImplc B se e Z d Z d „ Z d „ Z e d „ Z d „ Z e d „ Z d „ Z d „ Z
d „ Z d „ Z RS(
sº base for the synchronizer implementations. the acquire/release methods keep track of re-entrant
calls within the current thread, and delegate to the do_XXX methods when appropriate.c O s d S( N( ( R t argst params( ( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyR | s c C sk | i } | i o
d ‚ n | i p
d ‚ n | i d j o | i ƒ t | _ n | i d 8_ d S( Ns lock is in writing states lock is not in reading statei ( t stateR' R( R& t do_release_read_lockR ( R R, ( ( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyt release_read_lock s
c C s | i } | i o
d ‚ n | i d j o> | i | ƒ } | p | o | i d 7_ t | _ n | S| i o | i d 7_ t Sd S( Ns lock is in writing statei i ( R, R' R& t do_acquire_read_lockR R( ( R R R, t x( ( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyt acquire_read_lock‹ s
c C sk | i } | i o
d ‚ n | i p
d ‚ n | i d j o | i ƒ t | _ n | i d 8_ d S( Ns lock is in reading states lock is not in writing statei ( R, R( R' R& t do_release_write_lockR ( R R, ( ( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyt release_write_lockš s
c C s | i } | i o
d ‚ n | i d j o> | i | ƒ } | p | o | i d 7_ t | _ n | S| i o | i d 7_ t Sd S( Ns lock is in reading statei i ( R, R( R& t do_acquire_write_lockR R' ( R R R, R0 ( ( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyt acquire_write_lock¦ s
c C s
t ƒ ‚ d S( N( t NotImplementedError( ( ( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyR- µ s c C s
t ƒ ‚ d S( N( R6 ( ( ( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyR/ ¶ s c C s
t ƒ ‚ d S( N( R6 ( ( ( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyR2 · s c C s
t ƒ ‚ d S( N( R6 ( ( ( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyR4 ¸ s (
R
R R R R. R R1 R3 R5 R- R/ R2 R4 ( ( ( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyR) x s R 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÷ a synchronizer using lock files. as it relies upon flock(), which
is not safe to use with the same file descriptor among multiple threads (one file descriptor
per thread is OK),
a separate FileSynchronizer must exist in each thread.c C su t ƒ | _ | d j o t i ƒ } n | } t | | g d d d | ƒ| _ | i i | _ t | _
d | _ d S( Nt extensions .lockt digest( R% R, R t tempfilet
gettempdirt EncodedPatht encpatht patht filenameR t openedt filedesc( R R R R ( ( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyR À s
! c C st | i pf y t i | i | ƒ | _ Wn: t j
o. } | i i ƒ t i | i | ƒ | _ n Xt | _ n d S( N( R? t ost openR> R@ t OSErrorR< t verify_directoryR ( R t modet e( ( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyt _openÎ s
c C s„ | i t i t i Bƒ | pH y' t i | i t i t i Bƒ t } Wn t
j
o
t } n X| St i | i t i ƒ t Sd S( N( RG RA t O_CREATt O_RDONLYt fcntlt flockR@ t LOCK_SHt LOCK_NBR t IOErrorR ( R R t ret( ( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyR/ × s
c C s„ | i t i t i Bƒ | pH y' t i | i t i t i Bƒ t } Wn t
j
o
t } n X| St i | i t i ƒ t Sd S( N( RG RA RH t O_WRONLYRJ RK R@ t LOCK_EXRM R RN R ( R R RO ( ( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyR4 ç s
c C s | i ƒ d S( N( t release_all_locks( R ( ( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyR- ö s c C s | i ƒ d S( N( RR ( R ( ( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyR2 ù s c C sA | i o3 t i | i t i ƒ t i | i ƒ t | _ n d S( N( R? RJ RK R@ t LOCK_UNRA t closeR ( R ( ( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyRR ü s
c C sK t i | i t i ƒ o. y t i | i ƒ WqG t j
o qG Xn d S( N( RA t accessR> t F_OKt removeRC ( R ( ( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyt __del__ s
( R
R R R RG R/ R4 R- R2 RR RX ( ( ( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyR º s R c B sP e Z d Z d „ Z e d „ ƒ Z e d „ Z d „ Z e d „ Z d „ Z
RS( s‰ a synchronizer using a Condition. this synchronizer is based on threading.Lock() objects and
therefore must be shared among threads.c C sC t d d „ ƒ | _ d | _ d | _ t i t i ƒ ƒ | _ d S( Nt creatorc S s t ƒ S( ( R% ( ( ( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyR s i ( t ThreadLocalt tlocalstatet asyncR t current_sync_operationR t ConditionR t condition( R R ( ( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyR s c C s
| i ƒ S( ( R[ ( R ( ( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyR s c C s‹ | i i ƒ | o) xH | i d j o | i i ƒ q Wn# | i d j o | i i ƒ t S| i d 7_ | i i ƒ | p t Sd S( Ni ( R_ R R] R R R R R\ R ( R R ( ( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyR/ s
c C s| | i i ƒ | i d 8_ | i d j o% | i d j o | i i ƒ qk n | i d j o
d ‚ n | i i ƒ d S( Ni i s7 Synchronizer error - too many release_read_locks called( R_ R R\ R] R t notifyAllR ( R ( ( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyR- 1 s
c C sÑ | i i ƒ | o) xH | i d j o | i i ƒ q Wn# | i d j o | i i ƒ t St i ƒ | _ | i d j o6 | o | i i ƒ q´ d | _ | i i ƒ t Sn | i i ƒ | p t
Sd S( Ni ( R_ R R] R R R R R t
currentThreadR\ R ( R R ( ( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyR4 C s$
c C sT | i i ƒ | i t i ƒ j o
d ‚ n d | _ | i i ƒ | i i ƒ d S( Ns> Synchronizer error - current thread doesnt have the write lock( R_ R R] R Ra R R` R ( R ( ( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyR2 h s
( R
R R R t propertyR, R R/ R- R4 R2 ( ( ( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyR s %( ( ( t __all__RA t weakrefR9 t ret syst myghty.utilt threadR t threadingR t ImportErrort dummy_threadt dummy_threadingt getwindowsversionR R RJ R R R R! R R R% t objectR) R R ( ( ( s: /usr/lib/python2.6/site-packages/myghty/synchronization.pyt s0 <
& %BQ