�
^��Jc@sv
dZd
dl
Z
d
dlZd
dlZyd
dlZWnek
rY


d
dlZn
Xyej�
e	Z
Wn7


yd
dlZeZ
Wq�ek
r�


e	Z
q�Xn
Xd
dl
mZ
d
dlmZ
ddddd	gZdef
d
��YZej�Zd�Zd�Zd
�Zdef
d��YZdef
d��YZdef
d��YZdef
d��YZdS(s�Synchronization functions.

File- and mutex-based mutual exclusion synchronizers are provided,
as well as a name-based mutex which locks within an application
based on a string name.

i����N(
tutil(
t	LockErrortfile_synchronizertmutex_synchronizertnull_synchronizertNameLockt
_threadingcBsTeZ
dZej�Zd
ef
d��YZde	d�Z
ed�
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.

    tNLContainerc
BseZ
d�Zd
�ZRS(cCs+|
rtj
�|_ntj�|_dS(
N(RtRLocktlocktLock(tselft	reentrant((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyt__init__/s

c


Cs|jS(
N(
R	(
R((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyt__call__4s
(t__name__t
__module__R
R(((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyR.s
	cCsC|
dkr!t
j|�
|_nt
jj|
t
j|�|_dS(
N(tNoneRRt_locktlockstget(Rt
identifierR((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyR
7s


cCs|j�j
|
�
S(
N(Rtacquire(Rtwait((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyR>s
c


Cs|j�j
�
dS(
N(Rtrelease(
R((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyRAs
N(RRt__doc__RtWeakValuedRegistryRtobjectRRtFalseR
tTrueRR(((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyR$s
	cKstj
||
f|
||�S(
N(t_synchronizerstsync_get(Rtclstkwargs((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyt
_synchronizerFs
c
Ks1tsd
|
krt
|�
St|t|
�SdS(Ntlock_dir(t	has_flockRR"tFileSynchronizer(RR!((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyRJs


c
Kst|t
|
�S(
N(R"tConditionSynchronizer(RR!((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyRQs
cBs;eZ
ed�
Zd
�Zd�Zd�ZeZeZRS(c
CstS(
N(
R(RR((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pytacquire_write_lockVs
c


CsdS(
N((
R((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pytacquire_read_lockXs
c


CsdS(
N((
R((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pytrelease_write_lockZs
c


CsdS(
N((
R((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pytrelease_read_lock\s
(	RRRR'R(R)R*RR(((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyRUs
			
tSynchronizerImplcBs�eZ
d�Zd
ef
d��YZd�Zee�
Zd�Zed�
Z	d�Z
e
Zed�
ZeZ
d�Zd	�Zd
�Zd�ZRS(c

Cstj
�|_dS(
N(RtThreadLocalt_state(
R((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyR
cs
t	SyncStatecBseZ
dZd�ZRS(treentrantcounttwritingtreadingc

Csd
|_t
|_t
|_dS(Ni(R/RR0R1(
R((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyR
is
	
	
(sreentrantcountswritingsreading(RRt	__slots__R
(((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyR.fs
c
Cs@|jj
�s/tj�}
|jj|
�

|
S|jj�SdS(
N(R-thasR+R.tputR(Rtstate((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyR5ns




c
Csq|j}
|
j
r!td
�
�
n|
js9td�
�
n|
jdkr^|j�
t|
_n|
jd8_dS(Nslock is in writing stateslock is not in reading statei
(R5R0R
R1R/tdo_release_read_lockR(RR5((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyR*ws
		

	



cCs�|j}|j
r!td
�
�
n|jdkrj|j|
�
}|
sK|rf|jd7_t|_n|S|jr�|jd7_tSdS(Nslock is in writing stateii
(R5R0R
R/tdo_acquire_read_lockRR1(RRR5t
x((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyR(�s
		






	

c
Csq|j}
|
j
r!td
�
�
n|
js9td�
�
n|
jdkr^|j�
t|
_n|
jd8_dS(Nslock is in reading stateslock is not in writing statei
(R5R1R
R0R/tdo_release_write_lockR(RR5((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyR)�s
		

	



cCs�|j}|j
r!td
�
�
n|jdkrj|j|
�
}|
sK|rf|jd7_t|_n|S|jr�|jd7_tSdS(Nslock is in reading stateii
(R5R1R
R/tdo_acquire_write_lockRR0(RRR5R8((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyR'�s
		






	

c


Cs
t��
dS(
N(
tNotImplementedError(
R((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyR6�s
c


Cs
t��
dS(
N(
R;(
R((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyR7�s
c


Cs
t��
dS(
N(
R;(
R((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyR9�s
c


Cs
t��
dS(
N(
R;(
R((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyR:�s
(RRR
RR.R5tpropertyR*RR(R)RR'RR6R7R9R:(((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyR+bs
							R%cBsbeZ
dZd
�Zd�Zee�
Zd�Zd�Zd�Zd�Z	d�Z
d�ZRS(	sa synchronizer which locks using flock().

    Adapted for Python/multithreads from Apache::Session::Lock::File,
    http://search.cpan.org/src/CWEST/Apache-Session-1.81/Session/Lock/File.pm
    
    This module does not unlink temporary files, 
    because it interferes with proper locking.  This can cause 
    problems on certain systems (Linux) whose file systems (ext2) do not 
    perform well with lots of files in one directory.  To prevent this
    you should use a script to clean out old files from your lock directory.
    
    cCsett
|�j�
tj�|_|dkr=tj�}n|}tj	||
g
d
d�
|_
dS(Nt	extensions.lock(tsuperR%R
RR,t_filedescriptorRttempfilet
gettempdirtencoded_pathtfilename(RRR#((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyR
�s




	
c


Cs
|jj
�S(
N(R?R(
R((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyt	_filedesc�s
cCsA|j}|dkr=tj|j|
�}|jj|�

n|S(
N(RDRtostopenRCR?R4(Rtmodetfiledescriptor((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyt_open�s

	



cCs�|jt
jt
jB�
}|
ssy"tj|tjtjB�
tSWq�t	k
ro


t
j
|�

|jj�
t
SXntj|tj�
tSdS(
N(RIREtO_CREATtO_RDONLYtfcntltflocktLOCK_SHtLOCK_NBRtIOErrortcloseR?tremoveR(RRRH((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyR7�s












cCs�|jt
jt
jB�
}|
ssy"tj|tjtjB�
tSWq�t	k
ro


t
j
|�

|jj�
t
SXntj|tj�
tSdS(
N(RIRERJtO_WRONLYRLRMtLOCK_EXRORRPRQR?RRR(RRRH((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyR:�s












c


Cs|j�
dS(
N(
t_release_all_locks(
R((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyR6
s
c


Cs|j�
dS(
N(
RU(
R((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyR9

s
c
CsI|j}
|
dk	rEtj|
tj�
tj|
�

|jj�
ndS(
N(	RDRRLRMtLOCK_UNRERQR?RR(RRH((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyRU

s

	




(RRRR
RDR<RIR7R:R6R9RU(((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyR%�s
							R&cBsAeZ
dZd
�Zed�
Zd�Zed�
Zd�ZRS(s!a synchronizer using a Condition.cCsAtt
|�j�
d
|_d|_tjtj��
|_	dS(Ni(
R>R&R
tasyncRtcurrent_sync_operationRt	ConditionR
t	condition(RR((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyR

s
		cCs~|jj
�
zR|
r<x6|jdk	r8|jj�
qWn|jdk	rOtS|jd
7_Wd|jj�
X|
sztSdS(Ni
(	RZRRXRRRRWRR(RR((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyR7$
s






c

Cs�|jj
�
zb|jd
8_|jdkrP|jdk	rn|jj�
qnn|jdkrntd�
�
nWd|jj�
XdS(Ni
is7Synchronizer error - too many release_read_locks called(RZRRWRXRt	notifyAllR
R(
R((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyR68
s






cCs�|jj
�
z�|
r<x6|jdk	r8|jj�
qWn|jdk	rOtStj�|_|jd
kr�|
r�|jj�
q�d|_tSnWd|jj	�
X|
s�t
SdS(Ni(RZRRXRRRRt
currentThreadRWRR(RR((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyR:J
s 





	

c

Cs`|jj
�
z>|jtj�k	r4td
�
�
nd|_|jj�
Wd|jj�
XdS(Ns>Synchronizer error - current thread doesnt have the write lock(	RZRRXRR\R
RR[R(
R((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyR9n
s




	(	RRRR
RR7R6R:R9(((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyR&
s
		$(RREtsysR@t	threadingRtImportErrortdummy_threadingtgetwindowsversionRR$RLRtbeakerRtbeaker.exceptionsR
t__all__RRRRR"RRRR+R%R&(((sG/opt/alt/python27/lib/python2.7/site-packages/beaker/synchronization.pyt<module>s:


















	
!
			
bQ