J,SSKrSSKrSSKrSSKJr SSKrSSKrSSKJr Sr Sr "SS\ 5r \RS5rS rg!\ a SrSrN3f=f) N)_utils)patcherch^U4SjnT(dU(dU$[U5S:Xa U"US5$U$)a(Acquires & releases a read lock around call into decorated method. NOTE(harlowja): if no attribute name is provided then by default the attribute named '_lock' is looked for (this attribute is expected to be a :py:class:`.ReaderWriterLock`) in the instance object this decorator is attached to. cp>^^TRSS5m[R"T5UU4Sj5nU$)Nlock_lockc>[UT5nUR5 T"U/UQ70UD6sSSS5 $!,(df  g=fN)getattr read_lockselfargskwargsrw_lock attr_namefs !lib/third_party/fasteners/lock.pywrapper/read_locked..decorator..wrapper2s9dI.G""$///%$$ 4 Agetsixwrapsrrrrs` @r decoratorread_locked..decorator/4JJvw/ 1 0  0 rlenrrrs ` r read_lockedr%&5 T t9>T!W% % r ch^U4SjnT(dU(dU$[U5S:Xa U"US5$U$)a0Acquires & releases a write lock around call into decorated method. NOTE(harlowja): if no attribute name is provided then by default the attribute named '_lock' is looked for (this attribute is expected to be a :py:class:`.ReaderWriterLock` object) in the instance object this decorator is attached to. cp>^^TRSS5m[R"T5UU4Sj5nU$)Nrrc>[UT5nUR5 T"U/UQ70UD6sSSS5 $!,(df  g=fr )r write_lockr s rr0write_locked..decorator..wrapperQs9dI.G##%///&%%rrrs` @rrwrite_locked..decoratorNrr r!rr"r$s ` r write_lockedr-Er&r c\rSrSrSrSrSr\S5r\ RS4Sjr \ S5r SS jr\ S 5rS r\R$S 5r\R$S 5rSrg)ReaderWriterLockdaA reader/writer lock. This lock allows for simultaneous readers to exist but only one writer to exist for use-cases where it is useful to have such types of locks. Currently a reader can not escalate its read lock to a write lock and a writer can not acquire a read lock while it is waiting on the write lock. In the future these restrictions may be relaxed. This can be eventually removed if http://bugs.python.org/issue8800 ever gets accepted into the python standard threading library... wrc[b2[b+[R"S5(a[R$[R $)Nthread)eventleteventlet_patcheris_monkey_patched getcurrent threadingcurrent_threadr r_fetch_current_thread_functor.ReaderWriterLock._fetch_current_thread_functorzs9  $4$@11(;;***'''r NcSUl[R"5Ul0UlU"5UlUcUR 5nX lgr )_writer collectionsdeque_pending_writers_readers_condr<_current_thread)r condition_clscurrent_thread_functors r__init__ReaderWriterLock.__init__sG + 1 1 3 "_ ! )%)%G%G%I "5r c,[UR5$)z@Returns if there are writers waiting to become the *one* writer.)boolrBrs rhas_pending_writers$ReaderWriterLock.has_pending_writerssD))**r cpUR5nURU:XagU(aX R;$g)z?Returns if the caller is the active writer or a pending writer.TF)rEr?rB)r check_pendingmes r is_writerReaderWriterLock.is_writers4  ! ! # <<2  ... .r cpURb UR$UR(a UR$g)z9Returns whether the lock is locked by a writer or reader.N)r?WRITERrCREADERrLs rownerReaderWriterLock.owners, << #;;  ==;; r c>UR5nXR;$)z,Returns if the caller is one of the readers.)rErC)rrQs r is_readerReaderWriterLock.is_readers  ! ! #]]""r c## UR5nXR;a[SU-5eUR URbURU:Xa!UR US-UR U'OURR5 MZSSS5 Uv UR UR UnUS:aUS- UR U'OUR RU5 URR5 SSS5 g![ a SUR U'Nf=f!,(df  N=f![ a N_f=f!,(df  g=f!UR UR UnUS:aUS- UR U'O,UR RU5 O![ a Of=fURR5 SSS5 f!,(df  f=f=f7f)zContext manager that grants a read lock. Will wait until no active or pending writers. Raises a ``RuntimeError`` if a pending writer tries to acquire a read lock. zFWriter %s can not acquire a read lock while waiting for the write lockNr!) rErB RuntimeErrorrDr?rCKeyErrorwaitpop notify_all)rrQ me_instancess rr ReaderWriterLock.read_locks ! ! # && & C!# $% %ZZ<<'4<<2+=.,0MM",=,A b) ! (J #'==#4L#a',81,< b) ))"- %%'$.,- b).Z4 #'==#4L#a',81,< b) ))"- %%'s:HD9D;D9H!E+% H1E3'E EE 6E HD63D95D66D99 EH EEEE E($H+ H8G1:'F>!G1"F>=G1> G G1 G G1( H1 G? ;HHc#T# UR5nURSS9nUR5(aU(d[SU-5eU(aUv gUR UR R U5 [UR5S:Xa@URc3UR SU:Xa UR R5Ul OURR5 MuSSS5 Uv UR SUl URR5 SSS5 g!,(df  NJ=f!,(df  g=f!UR SUl URR5 SSS5 f!,(df  f=f=f7f)zContext manager that grants a write lock. Will wait until no active readers. Blocks readers after acquiring. Raises a ``RuntimeError`` if an active reader attempts to acquire a lock. F)rPz4Reader %s to writer privilege escalation not allowedrN) rErRrZr]rDrBappendr#rCr?popleftr_ra)rrQ i_am_writers rr*ReaderWriterLock.write_locks7 ! ! #nn5n9 >>  K 9;= >? ? J%%,,R04==)Q.4<<3G003r9+/+@+@+H+H+JDL!JJOO%  , ZZ#'DLJJ))+ Z ZTZZ#'DLJJ))+ ZZsgA"F($BD:6F(?E F("E 1 F(: EF( EF( F%)"F F% F" F%%F()rDrErBrCr?)T)__name__ __module__ __qualname____firstlineno____doc__rUrV staticmethodr<r9 ConditionrHpropertyrMrRrWrZ contextlibcontextmanagerr r*__static_attributes__r;r rr/r/ds  FF ( ( )22(, 6++# )()(V,,r r/c## URS5nUv U(aUR5 gg!U(aUR5 ff=f7f)zDAttempts to acquire a lock, and auto releases if acquired (on exit).FN)acquirerelease)r was_lockeds rtry_lockrxsBe$J  LLN : LLN sA2AA  Ach^U4SjnT(dU(dU$[U5S:Xa U"US5$U$)aA locking **method** decorator. It will look for a provided attribute (typically a lock or a list of locks) on the first argument of the function decorated (typically this is the 'self' object) and before executing the decorated function it activates the given lock or list of locks as a context manager, automatically releasing that lock on exit. NOTE(harlowja): if no attribute name is provided then by default the attribute named '_lock' is looked for (this attribute is expected to be the lock/list of locks object/s) in the instance object this decorator is attached to. NOTE(harlowja): a custom logger (which will be used if lock release failures happen) can be provided by passing a logger instance for keyword argument ``logger``. c>^^^TRSS5mTRS5m[R"T5UUU4Sj5nU$)Nrrloggerc>[UT5n[U[[45(ap[R "T S9n[ U5H7upVURU5(aM[R"SUS--5e T"U/UQ70UD6sSSS5 $UnU T"U/UQ70UD6sSSS5 $!,(df  g=f!,(df  g=f)N)r{zUnable to acquire lock %sr!) r isinstancetuplelistr LockStack enumerate acquire_lockr9 ThreadError) rrr attr_valuestackirrrr{s rr*locked..decorator..wrapper%s y1J*udm44%%V4#,Z#8$11$77"+"7"79CFG!e9M#NN$9T3D3F3 54"T3D3F3T54Ts%B3&)B3 C3 C Cr)rrrr{rs` @@rrlocked..decorator!sBJJvw/ H% 1 4  4r r!rr"r$s ` rlockedrs5&.T t9>T!W% % r )r@rqr9 fastenersrrr5rr6 ImportErrorr%r-objectr/rrrxrr;r rrsx( 4 >>W,vW,t   0[Hs A AA