��Qc@s�dZd
dl
Z
d
dlZd
dlmZmZmZmZmZm	Z	
er�d
dl
mZ
d
dlZej
ddkr�d
dl
mZ
q�d
dl
mZ
nd	ejf
d
��YZd�Zedkr�jd
d�

ndS(s/
TestCases for testing the locking sub-system.
i�N(tdbttest_supporttverbosethave_threadstget_new_environment_pathtget_new_database_path(
tThreadii(
t
currentThread(
tcurrent_threadtLockingTestCasec
Bs>eZ
d�Zd
�Zd�Zd�Zd�Zd�ZRS(c

CsMt�|_
tj�|_|jj|j
tjtjBtjBtj	B�
dS(
N(
RthomeDirRtDBEnvtenvtopent	DB_THREADt
DB_INIT_MPOOLtDB_INIT_LOCKt	DB_CREATE(
tself((s*/sys/lib/python2.7/bsddb/test/test_lock.pytsetUps



c

Cs!|jj
�
tj|j�
dS(
N(RtcloseR
trmtreeR
(
R((s*/sys/lib/python2.7/bsddb/test/test_lock.pyttearDowns


c
Cs�tr%d
GddGHd|j
jGHn|jj�}
trFd|
GHn|jj|
dtj�}trsd|GHn|jj|�
tr�d|GHn|jj	|
�
dS(	Ns

s-=isRunning %s.test01_simple...s
locker ID: %sssome locked thingsAquired lock: %ssReleased lock: %s(
Rt	__class__t__name__Rtlock_idtlock_getRt
DB_LOCK_WRITEtlock_puttlock_id_free(RtanIDtlock((s*/sys/lib/python2.7/bsddb/test/test_lock.pyt
test01_simple"s












c
Cs�tr%d
GddGHd|j
jGHng}
|
jtd|jdtjf
��
|
jtd|jdtjf
��
|
jtd|jdtjf
��
|
jtd|jdtjf
��
|
jtd|jdtjf
��
|
jtd|jdtjf
��
|
jtd|jdtjf
��
|
jtd|jdtjf
��
|
jtd|jdtjf
��
xP|
D]H}ddl	}|j
dd	kr�|jt�
n	t|_
|j�
q
Wx|
D]}|j�
q�Wd
�}dS(Ns

s-=isRunning %s.test02_threaded...ttargettargsi�iic

Ss�|jj
d
tj�
|j|jjtj�d
�
|jj
d
tj�
|j|jjtj�d
�
|jj
dtj�
|j|jjtj�d�
|jj
dtj�
|j|jjtj�d�
dS(Nii@�i�x(Rtset_timeoutRtDB_SET_LOCK_TIMEOUTtassertEqualtget_timeouttDB_SET_TXN_TIMEOUT(
R((s*/sys/lib/python2.7/bsddb/test/test_lock.pyttest03_lock_timeoutVs







(RRRtappendRt	theThreadRRtDB_LOCK_READtsystversion_infot	setDaemontTruetdaemontstarttjoin(Rtthreadst
tR,R(((s*/sys/lib/python2.7/bsddb/test/test_lock.pyttest02_threaded3s>

























	



c
s��jj
d
tj�
�jj
d
tj�
�jj
dtj�
�jj
dtj�
��fd��t�_d
�_td��
}
ddl	}|j
d
dkr�|
jt�
n	t|
_
|
j�
�jj
dtj�
�jj�}�jj�}�j||�
�jj|d	tj�}tj�}�jtj�jj|d	tj�
tj�}t�_�j||d
k�
�jj|�
|
j�
�jj|�
�jj|�
tj�d
kr�
j�jd
k�
ndS(Nii@�i�xcsVxO�jsQ�j
jtj��_�jrAx
�js<q0WPntjd
�
qWdS(Ngz��?(tendRtlock_detectRtDB_LOCK_EXPIREtcountttimetsleep((tdeadlock_detectionR(s*/sys/lib/python2.7/bsddb/test/test_lock.pyR<fs

	



R!i�ii�
sshared lockg���?ii(ii(RR#RR$R'tFalseR6R9RR,R-R.R/R0R1RtassertNotEqualRRR:tassertRaisestDBLockNotGrantedErrorR+t
assertTrueRR2Rtversion(RR4R,RtanID2Rt
start_timetend_time((R<Rs*/sys/lib/python2.7/bsddb/test/test_lock.pyttest04_lock_timeout2`s<




	
	



	











	




cCs
d
dl}|j
ddkr1t�j�}nt�j}|
tjkrUd}nd}|jj�}t	r�d||fGHnxrt
d�D]d}|jj|d|
�}t	r�d	|||fGHn|jj|�
t	r�d
|||fGHq�q�W|jj
|�
dS(Ni�iitwritetreads%s: locker ID: %si�ssome locked things%s: Aquired %s lock: %ss%s: Released %s lock: %s(R,R-RtgetNametnameRRRRRtxrangeRRR(RtlockTypeR,RJtltRt
iR((s*/sys/lib/python2.7/bsddb/test/test_lock.pyR*�s$



	






(Rt
__module__RRR R5RFR*(((s*/sys/lib/python2.7/bsddb/test/test_lock.pyR	s
				-	.c
CsHtj
�}tr+|jtjt��
n|jtjtd
��
|S(Nttest01(tunittestt	TestSuiteRtaddTestt	makeSuiteR	(
tsuite((s*/sys/lib/python2.7/bsddb/test/test_lock.pyt
test_suite�s


t__main__tdefaultTestRV(t__doc__R:RQttest_allRR
RRRRt	threadingRR,R-RRtTestCaseR	RVRtmain(((s*/sys/lib/python2.7/bsddb/test/test_lock.pyt<module>s
.



�