ó
ìEYc@sÇdd
lZdd
l
Z
dd
lZddlmZ
dd
lZy dd
lZddlmZ
Wne	k
r


d
Zd
Zn
Xd„Zd„Zde
f
d„ƒYZe
jd„ƒ
Zd	„Zd
S(
iÿÿÿÿN(
t_utils(
tpatchercsH‡f
d
†}ˆs|r |St|ƒ
dkr@||dƒ
S|SdS(s<
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.
    c
s7ˆjd
dƒ‰t
jˆ
ƒ
‡‡
fd†ƒ
}
|
S(Ntlockt_lockc
s6t|ˆƒ}|j
ƒ
ˆ
||
|Ž
SWdQXdS(
N(tgetattrt	read_lock(tselftargstkwargstrw_lock(t	attr_namet
f(sC/home/tvault/.virtenv/lib/python2.7/site-packages/fasteners/lock.pytwrapper2s


(tgettsixtwraps(RR(
R(R
RsC/home/tvault/.virtenv/lib/python2.7/site-packages/fasteners/lock.pyt	decorator/s
!i
iN(
tlen(RRR((
RsC/home/tvault/.virtenv/lib/python2.7/site-packages/fasteners/lock.pytread_locked&s	



csH‡f
d
†}ˆs|r |St|ƒ
dkr@||dƒ
S|SdS(sD
Acquires & 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.
    c
s7ˆjd
dƒ‰t
jˆ
ƒ
‡‡
fd†ƒ
}
|
S(NRRc
s6t|ˆƒ}|j
ƒ
ˆ
||
|Ž
SWdQXdS(
N(Rt
write_lock(RRRR	(R
R(sC/home/tvault/.virtenv/lib/python2.7/site-packages/fasteners/lock.pyRQs


(R
RR(RR(
R(R
RsC/home/tvault/.virtenv/lib/python2.7/site-packages/fasteners/lock.pyRNs
!i
iN(
R(RRR((
RsC/home/tvault/.virtenv/lib/python2.7/site-packages/fasteners/lock.pytwrite_lockedEs	



tReaderWriterLockcBs’eZ
dZd
ZdZed„ƒ
Zejdd„Z
ed„ƒ
Ze
d„
Zed„ƒ
Zd„Zejd	„ƒ
Zejd
„ƒ
ZRS(sA 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...
    t
wt
rcCs8tdk	r1tdk	r1tjd
ƒ
r1tjSntjS(Ntthread(teventlettNoneteventlet_patchertis_monkey_patchedt
getcurrentt	threadingtcurrent_thread(((sC/home/tvault/.virtenv/lib/python2.7/site-packages/fasteners/lock.pyt_fetch_current_thread_functorzs



cCsUd|_
tjƒ|_i|_|
ƒ|_|dkrH|jƒ}n||_dS(
N(	Rt_writertcollectionstdequet_pending_writerst_readerst_condR t_current_thread(Rt
condition_clstcurrent_thread_functor((sC/home/tvault/.virtenv/lib/python2.7/site-packages/fasteners/lock.pyt__init__‡s	

	



c

Cs
t|j
ƒ
S(
s@Returns if there are writers waiting to become the *one* writer.(tboolR$(
R((sC/home/tvault/.virtenv/lib/python2.7/site-packages/fasteners/lock.pythas_pending_writers’scCs:|jƒ}|j
|krtS|
r2||jkStSd
S(s?Returns if the caller is the active writer or a pending writer.N(R'R!tTrueR$tFalse(Rt
check_pendingtme((sC/home/tvault/.virtenv/lib/python2.7/site-packages/fasteners/lock.pyt	is_writer—s




c

Cs*|jd
k	r|jS|jr&|jSd
S(s9Returns whether the lock is locked by a writer or reader.N(R!RtWRITERR%tREADER(
R((sC/home/tvault/.virtenv/lib/python2.7/site-packages/fasteners/lock.pytowner¡s


	

c
Cs|jƒ}
|
|j
kS(
s,Returns if the caller is one of the readers.(R'R%(RR0((sC/home/tvault/.virtenv/lib/python2.7/site-packages/fasteners/lock.pyt	is_readerªs
c

cs:
|jƒ}
|
|j
kr.td
|
ƒ
‚
n|j~
xvtr°|jdks_|j|
kr y|j|
d|j|
<Wntk
r›


d|j|
<n
XPn|jj	ƒ
q;WWdQXz	|V
Wd|jg
yA|j|
}|dkrý|d|j|
<n|jj
|
ƒ

Wntk
r!



n
X|jjƒ
WdQXXdS(sÅContext 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.
        sFWriter %s can not acquire a read lock while waiting for the write locki
N(R'R$tRuntimeErrorR&R-R!RR%tKeyErrortwaittpopt
notify_all(RR0tme_instances((sC/home/tvault/.virtenv/lib/python2.7/site-packages/fasteners/lock.pyR¯s0	





	







	









c
cs
|jƒ}
|j
d
tƒ
}|jƒrD|rDtd|
ƒ
‚
n|rR|V
n½|j
|jj|
ƒ

xgtrÕt	|j
ƒ
dkrÅ|jdkrÅ|jd|
krÅ|jj
ƒ|_PqÅn|jjƒ
qoWWdQXz	|V
Wd|j
d|_|jjƒ
WdQXXdS(sÙContext 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.
        R/s4Reader %s to writer privilege escalation not allowediN(R'R1R.R5R6R&R$tappendR-RR%R!RtpopleftR8R:(RR0ti_am_writer((sC/home/tvault/.virtenv/lib/python2.7/site-packages/fasteners/lock.pyRÛs(	








	$





	

	
N(t__name__t
__module__t__doc__R2R3tstaticmethodR Rt	ConditionRR*tpropertyR,R-R1R4R5t
contextlibtcontextmanagerRR(((sC/home/tvault/.virtenv/lib/python2.7/site-packages/fasteners/lock.pyRds
	
		,c
cs3|jt
ƒ
}
z	|
V
Wd
|
r.|jƒ
nXd
S(sDAttempts to acquire a lock, and auto releases if acquired (on exit).N(tacquireR.trelease(Rt
was_locked((sC/home/tvault/.virtenv/lib/python2.7/site-packages/fasteners/lock.pyttry_lockþs


	
csH‡f
d
†}ˆs|r |St|ƒ
dkr@||dƒ
S|SdS(sA 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
sIˆjd
dƒ‰ˆjdƒ
‰t
jˆ
ƒ
‡‡
‡fd†ƒ
}
|
S(NRRtloggerc
	s¿t|ˆƒ}t
|ttfƒr˜tjd
ˆƒ
]}xCt|ƒ
D]5\}}|j|ƒ
sFtj	d|dƒ
‚
qFqFWˆ
||
|Ž
SWdQXn#|}|
ˆ
||
|Ž
SWdQXdS(NRKsUnable to acquire lock %si
(
Rt
isinstancettupletlistRt	LockStackt	enumeratetacquire_lockRtThreadError(RRRt
attr_valuetstackt
iR(R
RRK(sC/home/tvault/.virtenv/lib/python2.7/site-packages/fasteners/lock.pyR%
s




	



(R
RR(RR(
R(R
RRKsC/home/tvault/.virtenv/lib/python2.7/site-packages/fasteners/lock.pyR!
s

$i
iN(
R(RRR((
RsC/home/tvault/.virtenv/lib/python2.7/site-packages/fasteners/lock.pytlocked
s


(R"RERt	fastenersRRRR
RtImportErrorRRRtobjectRRFRJRV(((sC/home/tvault/.virtenv/lib/python2.7/site-packages/fasteners/lock.pyt<module>s







		š