✘✘ GRAYBYTE WORDPRESS FILE MANAGER ✘✘

�
��f�ec@sa
dZd
dl
Z
d
dlZd
dlmZmZ
d
dlZd
dlZd
dlm	Z	
dd�Z
Gdd�de�ZGd	d
�d
ej
�ZGdd�de�ZGd
d�de�ZGdd�de�ZGdd�de�ZGdd�de�ZGdd�de�ZGdd�de�ZGdd�de�ZGdd�de�ZdS(u/
Various tests for synchronization primitives.
iN(ustart_new_threaduTIMEOUT_MAX(
usupportcCstj
d
�

dS(Ng{�G�z�?(utimeusleep(((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu_waitsu_waitc

BsM|EeZ
dZd
Zddd�
Zdd�Zdd�Zdd	�Zd
S(uBunchu
    A bunch of threads.
    csk��
_|�
_
g�
_g�
_|�
_��
fd
d�}x!t|�
D]}t|f�
qPWdS(u�
        Construct a bunch of `n` threads running the same function `f`.
        If `wait_before_exit` is True, the threads won't terminate until
        do_finish() is called.
        c
sVtj
�}�
jj|�

z��
Wd�
jj|�

x�
jsPt�
q=WXdS(
N(u	threadingu	get_identustarteduappendufinishedu	_can_exitu_wait(
utid(u
fuself(u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutask!s





uBunch.__init__.<locals>.taskN(u
fu
nustartedufinishedu	_can_exiturangeustart_new_thread(uselfu
fu
nuwait_before_exitutasku
i((u
fuselfu4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu__init__s	
	
	
	


	
uBunch.__init__c

Cs*x#t|j
�
|jkr%t�
qWdS(
N(ulenustartedu
nu_wait(
uself((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyuwait_for_started-s

uBunch.wait_for_startedc

Cs*x#t|j
�
|jkr%t�
qWdS(
N(ulenufinishedu
nu_wait(
uself((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyuwait_for_finished1s

uBunch.wait_for_finishedc

Cs
d
|_
dS(NT(uTrueu	_can_exit(
uself((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu	do_finish5s
uBunch.do_finishNF(	u__name__u
__module__u__qualname__u__doc__uFalseu__init__uwait_for_starteduwait_for_finishedu	do_finish(
u
__locals__((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyuBunchs

uBunchc

Bs8|EeZ
dZd
d�Zdd�Zdd�ZdS(uBaseTestCasec

Cstj
�|_dS(
N(usupportuthreading_setupu_threads(
uself((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyusetUp:s
uBaseTestCase.setUpc

Cstj
|j�
tj�
dS(
N(usupportuthreading_cleanupu_threadsu
reap_children(
uself((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutearDown=s

uBaseTestCase.tearDowncCs,|j|
|d
�
|j
|
|d�
dS(Ng333333�?g$@(uassertGreaterEqualu
assertLess(uselfuactualuexpected((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu
assertTimeoutAsuBaseTestCase.assertTimeoutN(u__name__u
__module__u__qualname__usetUputearDownu
assertTimeout(
u
__locals__((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyuBaseTestCase9s
uBaseTestCasec

Bs�|EeZ
dZd
Zdd�Zdd�Zdd�Zdd	�Zd
d�Zdd
�Z	dd�Z
dd�Zdd�ZdS(u
BaseLockTestsu;
    Tests for both recursive and non-recursive locks.
    c

Cs|j�}
~
dS(
N(
ulocktype(uselfulock((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_constructorOs

uBaseLockTests.test_constructorc

Cs|j�}
|
j
�
~
dS(
N(ulocktypeuacquire(uselfulock((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_acquire_destroySs



u"BaseLockTests.test_acquire_destroyc

Cs'|j�}
|
j
�
|
j�
~
dS(
N(ulocktypeuacquireurelease(uselfulock((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_acquire_releaseXs





u"BaseLockTests.test_acquire_releasec
Cs0|j�}
|j
|
jd
�
�

|
j�
dS(NF(ulocktypeu
assertTrueuacquireuFalseurelease(uselfulock((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_try_acquire^s


uBaseLockTests.test_try_acquirec
sc|j���j
�
g�
��
fd
d�}
t|
d�j�
|j�
d�

�j�
dS(Ncs�
j�j
d
�
�

dS(NF(uappenduacquireuFalse((ulockuresult(u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu
fgs
u3BaseLockTests.test_try_acquire_contended.<locals>.fi
i(ulocktypeuacquireuBunchuwait_for_finisheduassertFalseurelease(uselfu
f((ulockuresultu4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_try_acquire_contendedcs






u(BaseLockTests.test_try_acquire_contendedc
s�|j���j
�
d
}
�f
dd�}t||
�}|j�
t�
|jt|j�
d�
�j�
|j	�
|jt|j�
|
�
dS(Nic
s�j�
�j
�
dS(
N(uacquireurelease((
ulock(u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu
fqs


u/BaseLockTests.test_acquire_contended.<locals>.fi(
ulocktypeuacquireuBunchuwait_for_startedu_waituassertEqualulenufinishedureleaseuwait_for_finished(uselfu
Nu
fu
b((
ulocku4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_acquire_contendedms













u$BaseLockTests.test_acquire_contendedc
sw|j���f
d
d�}
d�f
dd�
}|�
t|
d�j�
|jt|t�
t|
d�j�
dS(Nc
s�j�
�j
�
dS(
N(uacquireurelease((
ulock(u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu
fs


u"BaseLockTests.test_with.<locals>.fc

	s&��
|dk	r|�
nWdQXdS(
N(
uNone(
uerr(
ulock(u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu_with�s


u&BaseLockTests.test_with.<locals>._withi
(ulocktypeuNoneuBunchuwait_for_finisheduassertRaisesu	TypeError(uselfu
fu_with((
ulocku4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu	test_with}s


uBaseLockTests.test_withc
s�|j���f
d
d�}
t
tj��
}t|
d�j�
t
tj��
|kr�tjd�

|j|t
tj��
�
ndS(Nc
s�j�
�j
�
dS(
N(uacquireurelease((
ulock(u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu
f�s


u)BaseLockTests.test_thread_leak.<locals>.fig�������?(	ulocktypeulenu	threadingu	enumerateuBunchuwait_for_finishedutimeusleepuassertEqual(uselfu
fu
n((
ulocku4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_thread_leak�s



uBaseLockTests.test_thread_leakc
s*
|j��|j
t�jd
d�
|j
t�jdd
�

|j
t�jdd�

|j
t�jdtd�

�jdt�

�j�
tj�}
|j�jdd�
�

tj�}|j	||
d�
g�
��
fdd�}t
|d�j�
|j�
d
�

|j
�
dd	�
dS(Nii
utimeoutidg}Ô%�I�TicsFtj�}�
j
�jd
d�
�

tj�}
�
j
|
|�

dS(Nutimeoutg�?(utimeuappenduacquire(ut1ut2(ulockuresults(u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu
f�s



u%BaseLockTests.test_timeout.<locals>.fg�?i����(ulocktypeuassertRaisesu
ValueErroruacquireu
OverflowErroruTIMEOUT_MAXureleaseutimeu
assertTrueu
assertLessuBunchuwait_for_finisheduassertFalseu
assertTimeout(uselfut1ut2u
f((ulockuresultsu4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_timeout�s 











uBaseLockTests.test_timeoutN(
u__name__u
__module__u__qualname__u__doc__utest_constructorutest_acquire_destroyutest_acquire_releaseutest_try_acquireutest_try_acquire_contendedutest_acquire_contendedu	test_withutest_thread_leakutest_timeout(
u
__locals__((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu
BaseLockTestsJs
u
BaseLockTestsc

Bs>|EeZ
dZd
Zdd�Zdd�Zdd�ZdS(	u	LockTestsun
    Tests for non-recursive, weak locks
    (which can be acquired and released from different threads).
    c
s�|j��g�
��
fd
d�}
t
|
f�
xt�
�
dkrSt�
q7Wt�
|jt�
�
d�
�j�
xt�
�
dkr�t�
q~W|jt�
�
d�
dS(Ncs2�j�
�
j
d�

�j�
�
j
d�

dS(
N(uacquireuappenduNone((ulockuphase(u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu
f�s






u#LockTests.test_reacquire.<locals>.fii
i(ulocktypeustart_new_threadulenu_waituassertEqualurelease(uselfu
f((ulockuphaseu4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_reacquire�s











uLockTests.test_reacquirec
sY|j���j
�
�f
d
d�}
t|
d�}|j�
�j
�
�j�
dS(Nc
s�j�
dS(
N(
urelease((
ulock(u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu
f�s
u*LockTests.test_different_thread.<locals>.fi
(ulocktypeuacquireuBunchuwait_for_finishedurelease(uselfu
fu
b((
ulocku4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_different_thread�s







uLockTests.test_different_threadc
Csi|j�}
|
j
�
|j|
j
d
d�
�

|
j�
|j|
j��

|j|
j
dd�
�

dS(Nutimeoutg{�G�z�?ublockingF(ulocktypeuacquireuassertFalseureleaseulockedu
assertTrueuFalse(uselfulock((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_state_after_timeout�s






u"LockTests.test_state_after_timeoutN(u__name__u
__module__u__qualname__u__doc__utest_reacquireutest_different_threadutest_state_after_timeout(
u
__locals__((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu	LockTests�s
u	LockTestsc

BsV|EeZ
dZd
Zdd�Zdd�Zdd�Zdd	�Zd
d�ZdS(
u
RLockTestsu$
    Tests for recursive locks.
    c

CsL|j�}
|
j
�
|
j
�
|
j�
|
j
�
|
j�
|
j�
dS(
N(ulocktypeuacquireurelease(uselfulock((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_reacquire�s











uRLockTests.test_reacquirec
Csr|j�}
|j
t|
j�
|
j�
|
j�
|
j�
|
j�
|
j�
|
j�
|j
t|
j�
dS(
N(ulocktypeuassertRaisesuRuntimeErrorureleaseuacquire(uselfulock((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_release_unacquired�s













u"RLockTests.test_release_unacquiredc
Csr|j�}
|j
t|
j�
|
j�
|
j�
|
j�
|
j�
|
j�
|
j�
|j
t|
j�
dS(
N(ulocktypeuassertRaisesuRuntimeErroru
_release_saveuacquireurelease(uselfulock((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_release_save_unacquired
s













u'RLockTests.test_release_save_unacquiredc

sY|j���f
d
d�}
t
|
dd�}z|jt�j�
Wd|j�
XdS(Nc
s�j�
dS(
N(
uacquire((
ulock(u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu
f
s
u+RLockTests.test_different_thread.<locals>.fi
T(ulocktypeuBunchuTrueuassertRaisesuRuntimeErrorureleaseu	do_finish(uselfu
fu
b((
ulocku4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_different_thread
s


u RLockTests.test_different_threadc
s�|j��|j
�j��

�j�
|j�j��

�j�
|j�j��

g�
��
fd
d�}
t|
d�j�
|j
�
d�

�j�
|j�j��

�j�
|j
�j��

dS(Ncs�
j�j
��

dS(
N(uappendu	_is_owned((ulockuresult(u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu
f!
s
u$RLockTests.test__is_owned.<locals>.fi
i(ulocktypeuassertFalseu	_is_owneduacquireu
assertTrueuBunchuwait_for_finishedurelease(uselfu
f((ulockuresultu4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest__is_owned
s
















uRLockTests.test__is_ownedN(	u__name__u
__module__u__qualname__u__doc__utest_reacquireutest_release_unacquiredutest_release_save_unacquiredutest_different_threadutest__is_owned(
u
__locals__((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu
RLockTests�s
	u
RLockTestsc

BsV|EeZ
dZd
Zdd�Zdd�Zdd�Zdd	�Zd
d�ZdS(
u
EventTestsu"
    Tests for Event objects.
    c
Cs�|j�}
|j
|
j��

|
j�
|j|
j��

|
j�
|j|
j��

|
j�
|j
|
j��

|
j�
|j
|
j��

dS(
N(u	eventtypeuassertFalseuis_setusetu
assertTrueuclear(uselfuevt((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_is_set0
s













uEventTests.test_is_setcs�d
}g�
g���
�fdd�}t||�}|j
�
t�
|jt�
�
d�
�j�
|j�
|j�
dg
|�
|j�dg
|�
dS(Nics*�
j�j
��

�j�j
��

dS(
N(uappenduwait((uevturesults1uresults2(u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu
fA
s

u#EventTests._check_notify.<locals>.fiT(uBunchuwait_for_startedu_waituassertEqualulenusetuwait_for_finisheduTrue(uselfuevtu
Nu
fu
b((uevturesults1uresults2u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu
_check_notify<
s












uEventTests._check_notifyc
Cs>|j�}
|j
|
�

|
j�
|
j�
|j
|
�

dS(
N(u	eventtypeu
_check_notifyusetuclear(uselfuevt((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_notifyM
s







uEventTests.test_notifyc
s�|j��g�
g�d
}
��
�fdd�}t
||
�j�
|j�
dg
|
�
x1�D])\}}|j|�

|j|d�
qgWg�
g��j�
t
||
�j�
|j�
dg
|
�
x!�D]\}}|j	|�

q�WdS(NicsX�
j�j
d
�
�

tj�}�j
d�
}
tj�}�j|
||f�

dS(Ngg�?(uappenduwaitutime(ut1u
rut2(uevturesults1uresults2(u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu
fZ
s





u"EventTests.test_timeout.<locals>.fg�?FT(
u	eventtypeuBunchuwait_for_finisheduassertEqualuFalseuassertFalseu
assertTimeoutusetuTrueu
assertTrue(uselfu
Nu
fu
rudt((uevturesults1uresults2u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_timeoutU
s"
















uEventTests.test_timeoutc
s�|j��g�
d
}
��
fdd�}t
||
�}|j�
tjd�

�j�
�j�
|j�
|j�
dg
|
�
dS(Nics�
j�j
d
�
�

dS(Ni
(uappenduwait((uevturesults(u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu
ft
s
u(EventTests.test_set_and_clear.<locals>.fg�?T(
u	eventtypeuBunchuwait_for_startedutimeusleepusetuclearuwait_for_finisheduassertEqualuTrue(uselfu
Nu
fu
b((uevturesultsu4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_set_and_clearn
s













uEventTests.test_set_and_clearN(	u__name__u
__module__u__qualname__u__doc__utest_is_setu
_check_notifyutest_notifyutest_timeoututest_set_and_clear(
u
__locals__((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu
EventTests+
su
EventTestsc

Bsz|EeZ
dZd
Zdd�Zdd�Zdd�Zdd	�Zd
d�Zdd
�Z	dd�Z
dd�ZdS(uConditionTestsu(
    Tests for condition variables.
    c

Cs�|j�}
|
j
�
|
j
�
|
j�
|
j�
tj�}|j|�
}
|
j
�
|j|j
d
�
�

|
j�
|j|j
d
�
�

|j|
j
d
�
�

|j�
|
�
|j|j
d
�
�

WdQXdS(NF(ucondtypeuacquireureleaseu	threadinguLockuassertFalseuFalseu
assertTrue(uselfucondulock((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_acquire�
s




















uConditionTests.test_acquirec
Cs#|j�}
|j
t|
j�
dS(
N(ucondtypeuassertRaisesuRuntimeErroruwait(uselfucond((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_unacquired_wait�
s

u#ConditionTests.test_unacquired_waitc
Cs#|j�}
|j
t|
j�
dS(
N(ucondtypeuassertRaisesuRuntimeErrorunotify(uselfucond((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_unacquired_notify�
s

u%ConditionTests.test_unacquired_notifycsd
}g�g�d�
��
��fdd�}t||�}|j
�
t�
|j�g�
�j�
�jd�

t�
d�
�j�
xt��
dkr�t�
q�W|j�d
g
d�
|j�g�
�j�
�jd
�

t�
d�
�j�
x't��
t��
dkr/
t�
q	
W|j�dg
ddg
d�
|j�d
g
d�
�j�
�j	�
t�
d�
�j�
xt��
d
kr�
t�
q�
W|j�dg
ddg
d�
|j�dg
ddg
d�
|j
�
dS(Niic
sj�j�
�j
�}�j�
�j|�
f�

�j�
�j
�}�j�
�j|�
f�

dS(
N(uacquireuwaitureleaseuappend(
uresult(ucondu	phase_numuresults1uresults2(u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu
f�
s











u'ConditionTests._check_notify.<locals>.fii
iiT(Ti
(Ti
(Ti(Ti(Ti
(Ti(Ti(Ti(uBunchuwait_for_startedu_waituassertEqualuacquireunotifyureleaseulenuTrueu
notify_alluwait_for_finished(uselfucondu
Nu
fu
b((ucondu	phase_numuresults1uresults2u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu
_check_notify�
sJ




	
























"










"
"
uConditionTests._check_notifyc
Cs*|j�}
|j
|
�

|j
|
�

dS(
N(ucondtypeu
_check_notify(uselfucond((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_notify�
s


uConditionTests.test_notifyc
s�|j��g�
d
}
��
fdd�}t
||
�j�
|jt�
�
|
�
x1�
D])\}}|j|d�
|j|�

q]WdS(NicsV�j�
t
j
�}�jd
�
}
t
j
�}�j�
�
j|||
f�

dS(Ng�?(uacquireutimeuwaitureleaseuappend(ut1uresultut2(uconduresults(u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu
f�
s







u&ConditionTests.test_timeout.<locals>.fg�?(ucondtypeuBunchuwait_for_finisheduassertEqualulenu
assertTimeoutuassertFalse(uselfu
Nu
fudturesult((uconduresultsu4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_timeout�
s






uConditionTests.test_timeoutc

s��
j��d
���
�fdd�}
t
|
d�}|j�
xBtd�
D]4}tjd�

��
�d7��j�
WdQXqPW|j�
dS(Nic
sI��=
�j�f
d
d��
}�
j
|�

�
j�d�
WdQXdS(Ncs
�d
kS(Ni(((
ustate(u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu<lambda>�
su8ConditionTests.test_waitfor.<locals>.f.<locals>.<lambda>i(uwait_foru
assertTrueuassertEqual(
uresult(uconduselfustate(u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu
f�
s




u&ConditionTests.test_waitfor.<locals>.fi
ig{�G�z�?(ucondtypeuBunchuwait_for_startedurangeutimeusleepunotifyuwait_for_finished(uselfu
fu
bu
i((uconduselfustateu4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_waitfor�
s












uConditionTests.test_waitforc

s��
j��d
�g���
��fdd�}
t
|
d�}|j�
xBtd�
D]4}tjd�

��
�d7��j�
WdQXqYW|j�
�
jt	��
d�
dS(Nicsx��l
tj�}�j
�f
d
d�dd�

}
tj�|}�
j|
�

�
j|d�
�jd�

WdQXdS(Ncs
�d
kS(Ni(((
ustate(u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu<lambda>su@ConditionTests.test_waitfor_timeout.<locals>.f.<locals>.<lambda>utimeoutg�������?(utimeuwait_foruassertFalseu
assertTimeoutuappenduNone(udturesult(uconduselfustateusuccess(u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu
fs


!




u.ConditionTests.test_waitfor_timeout.<locals>.fi
ig{�G�z�?(
ucondtypeuBunchuwait_for_startedurangeutimeusleepunotifyuwait_for_finisheduassertEqualulen(uselfu
fu
bu
i((uconduselfustateusuccessu4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_waitfor_timeout�
s














u#ConditionTests.test_waitfor_timeoutN(u__name__u
__module__u__qualname__u__doc__utest_acquireutest_unacquired_waitutest_unacquired_notifyu
_check_notifyutest_notifyutest_timeoututest_waitforutest_waitfor_timeout(
u
__locals__((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyuConditionTests
s2uConditionTestsc

Bs�|EeZ
dZd
Zdd�Zdd�Zdd�Zdd	�Zd
d�Zdd
�Z	dd�Z
dd�Zdd�ZdS(uBaseSemaphoreTestsuB
    Common tests for {bounded, unbounded} semaphore objects.
    c

Cs:|jt
|jd
d�

|jt
|jd
tj�

dS(Nuvaluei
i����(uassertRaisesu
ValueErrorusemtypeusysumaxsize(
uself((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_constructors

u#BaseSemaphoreTests.test_constructorc
Cs^|jd
�
}
|
j
�
|
j�
|jd�
}
|
j
�
|
j
�
|
j�
|
j�
dS(Ni
i(usemtypeuacquireurelease(uselfusem((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_acquires












uBaseSemaphoreTests.test_acquirec

Cs|j�}
|
j
�
~
dS(
N(usemtypeuacquire(uselfusem((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_acquire_destroy)s



u'BaseSemaphoreTests.test_acquire_destroyc
s�
|jd
�
��j
�
d}
g�
g�d���
��fdd�}t|d�}|j�
x't�
�
t��
dkr�t�
qhW|j�
�dg
d�
d�xtd
�
D]}�j�
q�Wx't�
�
t��
dkr�t�
q�W|jt	�
��
dg
ddg
d
�
d	�xtd�
D]}�j�
q:
Wx't�
�
t��
d
krw
t�
qQ
W|jt	�
��
dg
ddg
d
d	g
d�
|j
�j
d�
�

�j�
|j�
dS(Nii
ics2�j�
�
j
��

�j�
�j
��

dS(
N(uacquireuappend((u	phase_numuresults1uresults2usem(u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu
f5s






u4BaseSemaphoreTests.test_acquire_contended.<locals>.fii
i
iiF(
usemtypeuacquireuBunchuwait_for_startedulenu_waituassertEqualurangeureleaseusorteduassertFalseuFalseuwait_for_finished(uselfu
Nu
fu
bu
i((u	phase_numuresults1uresults2usemu4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_acquire_contended.s6


















,





7

u)BaseSemaphoreTests.test_acquire_contendedc
Csu|jd
�
}
|j
|
jd�
�

|j
|
jd�
�

|j|
jd�
�

|
j�
|j
|
jd�
�

dS(NiF(usemtypeu
assertTrueuacquireuFalseuassertFalseurelease(uselfusem((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_try_acquireQs






u#BaseSemaphoreTests.test_try_acquirec
ss|jd
�
�
�
j
�
g���
fdd�}
t|
d�j�
|jt��
dg
ddg
d�
dS(	Nics0�j�
j
d
�
�

�j�
j
d
�
�

dS(NF(uappenduacquireuFalse((uresultsusem(u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu
f]s

u8BaseSemaphoreTests.test_try_acquire_contended.<locals>.fiiiFT(usemtypeuacquireuBunchuwait_for_finisheduassertEqualusorteduFalseuTrue(uselfu
f((uresultsusemu4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_try_acquire_contendedYs




u-BaseSemaphoreTests.test_try_acquire_contendedc
Cs�|jd
�
}
|j
t|
jddd�

|j|
jdd�
�

|j|
jdd�
�

|j|
jdd�
�

|
j�
|j|
jdd�
�

tj�}|j|
jdd�
�

tj�|}|j	|d�
dS(Niutimeoutg�?g{�G�zt?g�?F(
usemtypeuassertRaisesu
ValueErroruacquireuFalseu
assertTrueuassertFalseureleaseutimeu
assertTimeout(uselfusemu
tudt((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_acquire_timeoutfs











u'BaseSemaphoreTests.test_acquire_timeoutc
sp|j���j
�
�f
d
d�}
t|
d�}|j�
t�
|j|j�

�j�
|j�
dS(Nc
s�j�
�j
�
dS(
N(uacquireurelease((
usem(u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu
fws


u0BaseSemaphoreTests.test_default_value.<locals>.fi
(	usemtypeuacquireuBunchuwait_for_startedu_waituassertFalseufinishedureleaseuwait_for_finished(uselfu
fu
b((
usemu4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_default_valuess









u%BaseSemaphoreTests.test_default_valuec
s��jd
�
�
d��
fdd�
}
|
�
�j�
jd�
�

�
j�
�jt|
t�
�j�
jd�
�

�
j�
dS(Nic

sc�
�W
�j�
j
d
�
�

�
j�
�
�*
�j�
j
d
�
�

|rS|�
nWdQXWdQXdS(NF(u
assertTrueuacquireuFalseureleaseuassertFalse(
uerr(uselfusem(u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu_with�s







u+BaseSemaphoreTests.test_with.<locals>._withF(usemtypeuNoneu
assertTrueuacquireuFalseureleaseuassertRaisesu	TypeError(uselfu_with((uselfusemu4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu	test_with�s







uBaseSemaphoreTests.test_withN(
u__name__u
__module__u__qualname__u__doc__utest_constructorutest_acquireutest_acquire_destroyutest_acquire_contendedutest_try_acquireutest_try_acquire_contendedutest_acquire_timeoututest_default_valueu	test_with(
u
__locals__((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyuBaseSemaphoreTestss
#

uBaseSemaphoreTestsc

Bs&|EeZ
dZd
Zdd�ZdS(uSemaphoreTestsu)
    Tests for unbounded semaphores.
    c
Cs;|jd
�
}
|
j
�
|
j�
|
j�
|
j
�
dS(Ni
(usemtypeureleaseuacquire(uselfusem((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_release_unacquired�s







u&SemaphoreTests.test_release_unacquiredN(u__name__u
__module__u__qualname__u__doc__utest_release_unacquired(
u
__locals__((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyuSemaphoreTests�suSemaphoreTestsc

Bs&|EeZ
dZd
Zdd�ZdS(uBoundedSemaphoreTestsu'
    Tests for bounded semaphores.
    c
CsJ|j�}
|j
t|
j�
|
j�
|
j�
|j
t|
j�
dS(
N(usemtypeuassertRaisesu
ValueErrorureleaseuacquire(uselfusem((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_release_unacquired�s






u-BoundedSemaphoreTests.test_release_unacquiredN(u__name__u
__module__u__qualname__u__doc__utest_release_unacquired(
u
__locals__((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyuBoundedSemaphoreTests�suBoundedSemaphoreTestsc

Bs�|EeZ
dZd
ZdZdZdd�Zdd�Zdd	�Zd
d�Z	dd
d�
Z
dd�Zdd�Zdd�Z
dd�Zdd�Zdd�Zdd�Zdd�Zdd �Zd!S("uBarrierTestsu$
    Tests for Barrier objects.
    ig@c

Cs"|j|j
d
|j�

|_dS(Nutimeout(ubarriertypeu
NudefaultTimeoutubarrier(
uself((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyusetUp�s
uBarrierTests.setUpc


Cs|jj
�
dS(
N(ubarrieruabort(
uself((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutearDown�s
uBarrierTests.tearDowncCs+t|
|j
d
�}|
�
|j�
dS(Ni
(uBunchu
Nuwait_for_finished(uselfu
fu
b((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyurun_threads�s


uBarrierTests.run_threadscCs�|jj
}|j||j�
x�t|�
D]�}|
d
jd�

|jt|
d�
||�
|jj�
|
djd�

|jt|
d
�
|d|�
|jj�
q,W|j|jj	d
�
|j
|jj�

dS(Nii
T(ubarrierupartiesuassertEqualu
NurangeuappenduTrueulenuwaitu	n_waitinguassertFalseubroken(uselfuresultsu
nu
mu
i((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu	multipass�s








"


uBarrierTests.multipassi
cs5ggg�
��
�fd
d�}�j|�

dS(u;
        Test that a barrier is passed in lockstep
        cs�j�
��
dS(
N(
u	multipass((upassesuresultsuself(u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu
f�s
u$BarrierTests.test_barrier.<locals>.fN(
urun_threads(uselfupassesu
f((upassesuresultsuselfu4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_barrier�s
uBarrierTests.test_barrierc

Cs
|jd
�
S(uC
        Test that a barrier works for 10 consecutive runs
        i
(
utest_barrier(
uself((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_barrier_10�suBarrierTests.test_barrier_10c
sQg���
fd
d�}
�
j|
�

�
j
t��
tt�
j�
�
�
dS(u9
        test the return value from barrier.wait
        c
s �
jj
�}�j|�

dS(
N(ubarrieruwaituappend(
u
r(uresultsuself(u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu
f�s

u(BarrierTests.test_wait_return.<locals>.fN(urun_threadsuassertEqualusumurangeu
N(uselfu
f((uresultsuselfu4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_wait_return�s


uBarrierTests.test_wait_returnc
sVg�
�
f
d
d�}
�j�j
|
����
�fdd�}�j|�

dS(u,
        Test the 'action' callback
        cs�jd
�

dS(NT(uappenduTrue((
uresults(u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyuaction�s
u(BarrierTests.test_action.<locals>.actioncs$�j�
�j
t�
�
d
�
dS(Ni
(uwaituassertEqualulen((ubarrieruresultsuself(u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu
f�s


u#BarrierTests.test_action.<locals>.fN(ubarriertypeu
Nurun_threads(uselfuactionu
f((ubarrieruresultsuselfu4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_action�s


uBarrierTests.test_actionc
s{g�g�
��
�fd
d�}
�j|
�

�j
t��
d�
�j
t�
�
�jd�
�j�jj�

dS(uK
        Test that an abort will put the barrier in a broken state
        c
s�yI�jj
�}|�jd
kr.t�
n�jj
�
�jd�

Wn@tjk
rm


�
jd�

Yntk
r�


�jj�
Yn
XdS(NiT(	ubarrieruwaitu
NuRuntimeErroruappenduTrueu	threadinguBrokenBarrierErroruabort(
u
i(uresults1uresults2uself(u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu
f�s



	









u"BarrierTests.test_abort.<locals>.fii
N(urun_threadsuassertEqualulenu
Nu
assertTrueubarrierubroken(uselfu
f((uresults1uresults2uselfu4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu
test_abort�s






uBarrierTests.test_abortc
s�g�g�
g���
��fd
d�}
�j|
�

�j
t��
d�
�j
t�
�
�jd�
�j
t��
�j�
dS(uL
        Test that a 'reset' on a barrier frees the waiting threads
        c
s��jj
�}|�jd
kr_x*�jj�jdkrNtjd�

q%W�jj�
nCy�jj
�
�jd�

Wn"t	j
k
r�


�
jd�

Yn
X�jj
�
�jd�

dS(Nii
g����MbP?T(ubarrieruwaitu
Nu	n_waitingutimeusleepuresetuappenduTrueu	threadinguBrokenBarrierError(
u
i(uresults1uresults2uresults3uself(u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu
fs










u"BarrierTests.test_reset.<locals>.fii
N(urun_threadsuassertEqualulenu
N(uselfu
f((uresults1uresults2uresults3uselfu4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu
test_reset
s






uBarrierTests.test_resetc
s�g�
g�g��j�j
�
���
���fd
d�}
�j|
�

�jt�
�
d�
�jt��
�j
d�
�jt��
�j
�
dS(uF
        Test that a barrier can be reset after being broken.
        c
s�yI�jj
�}|�jd
kr.t�
n�jj
�
�
jd�

Wn@tjk
rm


�jd�

Yntk
r�


�jj�
Yn
X�j
��jd
kr��jj	�
n�j
�
�jj
�
�jd�

dS(NiT(
ubarrieruwaitu
NuRuntimeErroruappenduTrueu	threadinguBrokenBarrierErroruabortureset(
u
i(ubarrier2uresults1uresults2uresults3uself(u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu
f3s 



	















u,BarrierTests.test_abort_and_reset.<locals>.fii
N(ubarriertypeu
Nurun_threadsuassertEqualulen(uselfu
f((ubarrier2uresults1uresults2uresults3uselfu4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_abort_and_reset+s







u!BarrierTests.test_abort_and_resetc
s#�f
d
d�}
�j|
�

dS(u$
        Test wait(timeout)
        c
sR�jj
�}|�jd
kr2tjd�

n�jtj�jj
d�
dS(Nig�?g�?(ubarrieruwaitu
NutimeusleepuassertRaisesu	threadinguBrokenBarrierError(
u
i(
uself(u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu
fQs



u$BarrierTests.test_timeout.<locals>.fN(
urun_threads(uselfu
f((
uselfu4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_timeoutMsuBarrierTests.test_timeoutc
s>�
j�
j
d
d�

���
fdd�}
�
j|
�

dS(u4
        Test the barrier's default timeout
        utimeoutg333333�?c
sI�j�}|�
j
d
kr/tjd�

n�
jtj�j�
dS(Nig�?(uwaitu
NutimeusleepuassertRaisesu	threadinguBrokenBarrierError(
u
i(ubarrieruself(u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu
fas


u,BarrierTests.test_default_timeout.<locals>.fN(ubarriertypeu
Nurun_threads(uselfu
f((ubarrieruselfu4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_default_timeout[s
u!BarrierTests.test_default_timeoutc
Cs'|jd
�
}
|
j
�
|
j
�
dS(Ni
(ubarriertypeuwait(uselfu
b((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyutest_single_threadis



uBarrierTests.test_single_threadN(u__name__u
__module__u__qualname__u__doc__u
NudefaultTimeoutusetUputearDownurun_threadsu	multipassutest_barrierutest_barrier_10utest_wait_returnutest_actionu
test_abortu
test_resetutest_abort_and_resetutest_timeoututest_default_timeoututest_single_thread(
u
__locals__((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyuBarrierTests�s"


	"uBarrierTests(u__doc__usysutimeu_threadustart_new_threaduTIMEOUT_MAXu	threadinguunittestutestusupportu_waituobjectuBunchuTestCaseuBaseTestCaseu
BaseLockTestsu	LockTestsu
RLockTestsu
EventTestsuConditionTestsuBaseSemaphoreTestsuSemaphoreTestsuBoundedSemaphoreTestsuBarrierTests(((u4/opt/alt/python33/lib64/python3.3/test/lock_tests.pyu<module>s$



'q.BT�|