python (3.12.0)
Browse
Usage
Versions
͑e} d dl Z d dlZd dlZd dlmZmZ d dlZd dlZd dlZd dl m
Z
d dl m Z ej e
j d Zd Z G d de Z G d d
ej& Z G d d e Z G d
de Z G d de Z G d de Z G d de Z G d de Z G d de Z G d de Z G d d e Z y) N)start_new_thread TIMEOUT_MAX)support)threading_helperz9platform doesn't support fork (no _at_fork_reinit method)c . t j d y )N{Gz?)timesleep C/BuggyBox/python/3.12.0/bootstrap/lib/python3.12/test/lock_tests.py_waitr s JJtr c ( e Zd Z ddZd Zd Zd Zy)Bunchc _ | _ g _ g _ | _ t j _ j j fd} t | D ] }t |d y # d _ xY w)Nc z t j } j j | j j | j
st
j
sy y # j j | j
st
j
sw w xY wN) threading get_identstartedappendfinished _can_exitr )tidfselfs r
taskz Bunch.__init__.<locals>.task, s %%'C LL $
$$S) ..G ..
$$S) ..G ..s A9 9>B:8B:r T) r nr r r r wait_threads_exit wait_thread __enter__ranger )r r r wait_before_exitr is `` r
__init__zBunch.__init__ s
--+==? ""$ 1X
+ r*
+ !DN s " A? ?
B c t | j | j k r.t t | j | j k r-y y r )lenr r r r s r
wait_for_startedzBunch.wait_for_started= s3 $,, $&&( G $,, $&&(r c t | j | j k r-t t | j | j k r-| j j d d d y r )r' r r r r __exit__r( s r
wait_for_finishedzBunch.wait_for_finishedA sM $-- 466) G $-- 466)
!!$d3r c d| _ y NT)r r( s r
do_finishzBunch.do_finishG s r N)F)__name__
__module__ __qualname__r% r) r, r/ r r r
r r s >4 r r c e Zd Zd Zd Zd Zy) BaseTestCasec 6 t j | _ y r )r threading_setup_threadsr( s r
setUpzBaseTestCase.setUpL s (88:
r c d t j | j t j y r )r threading_cleanupr7 r
reap_childrenr( s r
tearDownzBaseTestCase.tearDownO s **DMM: r c X | j ||dz | j ||dz y )Ng333333?g $@)assertGreaterEqual
assertLess)r actualexpecteds r
assertTimeoutzBaseTestCase.assertTimeoutS s*
37 40r N)r0 r1 r2 r8 r< rB r r r
r4 r4 K s ; 1r r4 c \ e Zd Z d Zd Zd Zd Zd Zd Zd Z d Z
d Z d
Z d Z
d Zd
Zy)
BaseLockTestsc & | j }~y r )locktyper locks r
test_constructorz BaseLockTests.test_constructora s }} r c \ | j }| j t | d ~y )Nz <unlocked .* object (.*)?at .*>)rF assertRegexreprrG s r
test_reprzBaseLockTests.test_repre s% }} d%FG r c | | j }|j | j t | d ~y )Nz <locked .* object (.*)?at .*>)rF acquirerK rL rG s r
test_locked_reprz BaseLockTests.test_locked_reprj s. }} d%DE r c F | j }|j ~y r )rF rO rG s r
test_acquire_destroyz"BaseLockTests.test_acquire_destroyp s }} r c f | j }|j |j ~y r rF rO releaserG s r
test_acquire_releasez"BaseLockTests.test_acquire_releaseu s" }} r c | j }| j |j d |j y NF)rF
assertTruerO rU rG s r
test_try_acquirez BaseLockTests.test_try_acquire{ s+ }} U+, r c | j j g fd}t |d j | j d j y )Nc F j j d y rX r rO rH results r
r z3BaseLockTests.test_try_acquire_contended.<locals>.f s MM$,,u- .r r )rF rO r r, assertFalserU r r rH r_ s @@r
test_try_acquire_contendedz(BaseLockTests.test_try_acquire_contended sN }} /
a %%' # r c t | j j d}fd}t || }|j t | j t
|j d j |j | j t
|j | y )N c F j j y r rO rU rH s r
r z/BaseLockTests.test_acquire_contended.<locals>.f LLN LLNr r )
rF rO r r) r assertEqualr' r rU r, )r Nr brH s @r
test_acquire_contendedz$BaseLockTests.test_acquire_contended s }}
!QK
QZZ !, QZZ !,r c | j fd}dfd } | t |d j | j t |t t |d j y )Nc F j j y r rg rh s r
r z"BaseLockTests.test_with.<locals>.f ri r c > 5 | | d d d y # 1 sw Y y xY wr r )errrH s r
_withz&BaseLockTests.test_with.<locals>._with s*
? I #
s r` r )rF r r, assertRaises TypeError)r r rr rH s @r
test_withzBaseLockTests.test_with sU }}
a %%' )UI6
a %%'r c d | j fd}t t j }t |d j t t j |k7 rCt
j d | j |t t j y y )Nc F j j y r rg rh s r
r z)BaseLockTests.test_thread_leak.<locals>.f ri r g?) rF r' r enumerater r, r r
rj )r r r rH s @r
test_thread_leakz BaseLockTests.test_thread_leak s }}
##% & a &&( y""$ % *
JJsO QI$7$7$9 : ;
+r c | j | j t j dd | j t j d | j t j d | j t j t
dz j t
j
t j }| j j d t j }| j ||z
d g fd}t |d j | j d | j d d y )
NFr` itimeoutg}Ô%ITre c t j } j j d t j }j || z
y )N ?r| )r monotonicr rO )t1t2rH resultss r
r z%BaseLockTests.test_timeout.<locals>.f sB !B NN4<<<4 5 !B NN27 #r r r )rF rs
ValueErrorrO
OverflowErrorr rU r r rY r? r r, ra rB )r r r r rH r s @@r
test_timeoutzBaseLockTests.test_timeout s }} *dllE1= *dllDA - uE - {QO [ )
^^
Q /0
^^
R# $
a %%' $ 71:s+r c z | j }t j | }| j | y r )rF weakrefrefassertIsNotNoner rH r s r
test_weakref_existsz!BaseLockTests.test_weakref_exists s+ }}kk$ SU#r c | j }t j | }~t j | j | y r )rF r r gccollect assertIsNoner s r
test_weakref_deletedz"BaseLockTests.test_weakref_deleted s7 }}kk$
#% r N)r0 r1 r2 rI rM rP rR rV rZ rc rm ru rz r r r r r r
rD rD \ sH
- ( <&,4$
!r rD c 0 e Zd Z d Zd Zd Zed Zy) LockTestsc | j g fd}t j 5 t |d t dk( rt t dk( rt | j
t d j t dk( rt t dk( r| j
t d d d d y # 1 sw Y y xY w)Nc j j d j j d y r rO r )rH phases r
r z#LockTests.test_reacquire.<locals>.f s- LLN LL LLN LL r r r r` )rF r r r r' r rj rU )r r rH r s @@r
test_reacquirezLockTests.test_reacquire s }}
/
/
1 , Q #e*/ e*/ G SZ + LLNe*/ e*/ SZ + , , ,s 3C##AC#?C##C,c | j j fd}t |d }|j j j y )Nc & j y r )rU rh s r
r z*LockTests.test_different_thread.<locals>.f LLNr r` )rF rO r r, rU r r rl rH s @r
test_different_threadz LockTests.test_different_thread sE }} !QK r c & | j }|j | j |j d |j | j |j | j |j d y )Nr r| F)blocking)rF rO ra rU lockedrY rG s r
test_state_after_timeoutz"LockTests.test_state_after_timeout
se }} d 34 ' e 45r c d }| j }|j || | j }|j |j || y )Nc D | j | j y r rg rh s r
use_lockz/LockTests.test_at_fork_reinit.<locals>.use_lock s
LLN LLNr )rF _at_fork_reinitrO )r r rH lock2s r
test_at_fork_reinitz LockTests.test_at_fork_reinit sP }}
r N)r0 r1 r2 r r r
requires_forkr r r r
r r s* ,, 6 r r c , e Zd Z d Zd Zd Zd Zd Zy)
RLockTestsc | j }|j |j |j |j |j |j y r rT rG s r
r zRLockTests.test_reacquire, sC }} r c d | j }| j t |j |j |j |j |j |j |j | j t |j y r )rF rs RuntimeErrorrU rO rG s r
test_release_unacquiredz"RLockTests.test_release_unacquired5 sk }} , 5 , 5r c d | j }| j t |j |j |j |j |j |j |j | j t |j y r )rF rs r
_release_saverO rU rG s r
test_release_save_unacquiredz'RLockTests.test_release_save_unacquiredA so }} ,(:(:; ,(:(:;r c | j fd}t |dd } | j t j |j |j
y # |j w xY w)Nc & j y r )rO rh s r
r z+RLockTests.test_different_thread.<locals>.fP r r r` T)rF r rs r rU r/ r, r s @r
r z RLockTests.test_different_threadM s\ }} !Q lDLL 9
KKM
KKMs A& &A8c J | j | j j j | j j j | j j g fd}t |d j
| j d j | j j j | j j y )Nc D j j y r )r _is_ownedr^ s r
r z$RLockTests.test__is_owned.<locals>.fa s MM$..* +r r` r )rF ra r rO rY r r, rU rb s @@r
test__is_ownedzRLockTests.test__is_ownedY s }} )* () () ,
a %%' # () )*r N)r0 r1 r2 r r r r r r r r
r r ( s
6
<
+r r c B e Zd Z d Zd Zd Zd Zd Zed Z d Z
y)
EventTestsc | j }| j |j |j | j |j |j | j |j |j | j |j |j | j |j y r ) eventtypera is_setsetrY clearr evts r
test_is_setzEventTests.test_is_setp s nn &
%
% & &r c > d}g g fd}t || }|j t | j t d j |j
| j dg|z | j dg|z y )Nre c j j j j y r r wait)r results1results2s r
r z#EventTests._check_notify.<locals>.f s' OOCHHJ ' OOCHHJ 'r r T)r r) r rj r' r r, )r r rk r rl r r s ` @@r
_check_notifyzEventTests._check_notify| s
(
!QK
X * D6A:. D6A:.r c | j }| j | |j |j | j | y r )r r r r r s r
test_notifyzEventTests.test_notify s< nn 3 3 r c | j g g d}fd}t || j | j dg|z D ]( \ }}| j | | j |d * g g j
t || j | j dg|z D ] \ }}| j | y )Nre c j j d t j } j d }t j }j ||| z
f y )Ng r )r r r r )r rr r r r s r
r z"EventTests.test_timeout.<locals>.f sP OOCHHSM * !B
A !B OOQRL )r Fr T)r r r, rj ra rB r rY )r rk r r dtr r r s @@@r
r zEventTests.test_timeout s nn
* a %%' E7Q;/ (EAr Q r3 ' (
a %%' D6A:. EAr OOA r c 2 | j g dd}fd}t || }|j t j j j
|j | j dg|z y )Ng ?re c L j j dz y N r )r r r} s r
r z(EventTests.test_set_and_clear.<locals>.f s NN388GaK0 1r T) r r r) r r
r r r, rj )r rk r rl r r r} s @@@r
test_set_and_clearz EventTests.test_set_and_clear s| nn
2 !QK
7 4&1*-r c p | j }|j 5 | j |j j d d d d |j |j 5 | j |j j d d d d y # 1 sw Y YxY w# 1 sw Y y xY wrX )r _condra rO r r s r
r z EventTests.test_at_fork_reinit s nn
YY 7 SYY . .u 5 6 7
YY 7 SYY . .u 5 6 7 7 7 7 7 7s +B ,+B, B),B5c | j }| j t | d |j | j t | d y )Nz<\w+\.Event at .*: unset>z<\w+\.Event at .*: set>)r rK rL r r s r
rM zEventTests.test_repr sA nn c$@A c$>?r N) r0 r1 r2 r r r r r r r rM r r r
r r k s:
'/" 2." 7 7@r r c > e Zd Z d Zd Zd Zd Zd Zd Zd Z d Z
y )
ConditionTestsc | | j }|j |j |j |j t j }| j | }|j | j |j d |j | j
|j d | j |j d |j |5 | j |j d d d d y # 1 sw Y y xY wrX )condtyperO rU r Lockra rY )r condrH s r
test_acquirezConditionTests.test_acquire s }}
~~ }}T" e,- U+, e,-
2 T\\% 0 1 2 2 2s !D22D;c d | j }| j t |j y r )r rs r r r r s r
test_unacquired_waitz#ConditionTests.test_unacquired_wait s! }} , 2r c d | j }| j t |j y r )r rs r notifyr s r
test_unacquired_notifyz%ConditionTests.test_unacquired_notify s! }} , 4r c j d}g g g dfd}t || }|j t dk rt t dk rj | j g j
j d t dj t dk rt t dk r| j dgdz | j g t dk rt t dk rj
j d t dj t t z dk r%t t t z dk r%| j dgdz d gdz z | j d gdz t dk rt t dk rj
j t dj t dk rt t dk r| j dgdz d gdz z | j d gdz d
gdz z |j y ) Nre r c V j j j } j j | f j j j } j j | f y r )rO r r rU )r_ r phase_numreadyr r s r
r z'ConditionTests._check_notify.<locals>.f sw LLN LL #YY[F LLN OOVY / 0 LLN LL #YY[F LLN OOVY / 0r r` )Tr` r )Tr )Tr ) r r) r' r r rj rO r rU
notify_allr, ) r r rk r rl r r r r s ` @@@@r
r z ConditionTests._check_notify sE
1
1
!QK %j1n G %j1n
2& A
(ma G (ma I;?3 2&%j1n G %j1n
A
(mc(m+a/ G (mc(m+a/ I;?i[1_#DE I;?3%j1n G %j1n
(ma G (ma I;?hZ!^#CD I;?i[1_#DE r c h | j }| j | | j | y r )r r r s r
r zConditionTests.test_notify: s) }} 4 4 r c | j g d}fd}t || j | j t | D ]( \ }}| j |d | j
| * y )Nre c j t j } j d }t j }j j || z
|f y )Nr )rO r r r rU r )r r_ r r r s r
r z&ConditionTests.test_timeout.<locals>.fD sO LLN !BYYs^F !B LLN NNBGV, -r r )r r r, rj r' rB ra )r rk r r r_ r r s @@r
r zConditionTests.test_timeout@ sx }}
. a %%' W q)! %JB r3 '
V $ %r c 6 j d fd}t |d }|j t d D ]7 }t j
d 5 dz
j
d d d 9 |j y # 1 sw Y TxY w)Nr c 5 j fd } j | j d d d d y # 1 sw Y y xY w)Nc dk( S r r states r
<lambda>z8ConditionTests.test_waitfor.<locals>.f.<locals>.<lambda>[ q r r )wait_forrY rj )r_ r r r s r
r z&ConditionTests.test_waitfor.<locals>.fY sF
+ '89' *
+
+
+s 8AAr` r r )r r r) r" r r
r r, )r r rl r$ r r s ` @@r
test_waitforzConditionTests.test_waitforV s }} +
!QK q A JJt
s BB c t j dg fd}t |d }|j t d D ]7 }t j
d 5 dz
j
d d d 9 |j j t d y # 1 sw Y oxY w)Nr c 5 t j } j fdd }t j | z
} j | j | d j d d d d y # 1 sw Y y xY w)Nc dk( S r r r s r
r z@ConditionTests.test_waitfor_timeout.<locals>.f.<locals>.<lambda>n r r g?r| )r r r ra rB r )r r_ r r r successs r
r z.ConditionTests.test_waitfor_timeout.<locals>.fk su
%^^% '8# F^^%* (""2s+t$
%
%
%s A6BB r` r r )
r r r) r" r r
r r, rj r' )r r rl r$ r r r s ` @@@r
test_waitfor_timeoutz#ConditionTests.test_waitfor_timeoutg s }} %
!QK q A JJt
W q)
s "B..B7 N) r0 r1 r2 r r r r r r r r r r r
r r s1 2&35H T! %, "*r r c J e Zd Z d Zd Zd Zd Zd Zd Zd Z d Z
d Z d
Z y ) BaseSemaphoreTestsc | j t | j d | j t | j t j y )N)value)rs r semtypesysmaxsizer( s r
rI z#BaseSemaphoreTests.test_constructor s: *dllB? *dllS[[LIr c | j d }|j |j | j d }|j |j |j |j y )Nr` r )r rO rU r sems r
r z BaseSemaphoreTests.test_acquire sR ll1o
ll1o
r c F | j }|j ~y r )r rO r s r
rR z'BaseSemaphoreTests.test_acquire_destroy s lln
r c @ | j d j d}g g g d fd}t |d }|j t t z dk r%t t t z dk r%| j
z dgdz dt d D ] }j t t z dk r%t t t z dk r%| j
t z dgdz dgdz z dt d D ] }j t t z d k r%t t t z d k r%| j
t z dgdz dgdz z dgdz z | j j d
j |j | j
d gd z y )
N
r c j j j j j j y r r] )r r r r sem_resultss r
r z4BaseSemaphoreTests.test_acquire_contended.<locals>.f sC s{{} - OOI & s{{} - OOI &r r`
r FT ) r rO r r) r' r rj r" rU sortedra r, )
r rk r rl r$ r r r r r
s
@@@@@r
rm z)BaseSemaphoreTests.test_acquire_contended s ll1o
' '
!RL (mc(m+a/ G (mc(m+a/ H,qcAg6 q A KKM (mc(m+b0 G (mc(m+b0 8 34qcAga6GH q A KKM (mc(m+b0 G (mc(m+b0 8 34qcAga6G1#PQ'6QR U+,
tf
&>?r c | j d j g g dfd}t |d }|j t t z dk r%t t t z dk r%| j
z dgdz dj d t t z dk r%t t t z dk r%| j
t z dgdz dgdz z dj d t t z d k r%t t t z d k r%| j
t z dgdz dgdz z dgdz z | j j d
j |j y ) Nr
r c j j j j y r r )r r r r s r
r z/BaseSemaphoreTests.test_multirelease.<locals>.f s- KKM OOI & KKM OOI &r r r r` r r r F) r rO r r) r' r rj rU r ra r, )r r rl r r r r s @@@@r
test_multireleasez$BaseSemaphoreTests.test_multirelease s ll1o
'
!RL (mc(m+a/ G (mc(m+a/ H,qcAg6 A(mc(m+b0 G (mc(m+b0 8 34qcAga6GH A(mc(m+b0 G (mc(m+b0 8 34qcAga6G1#PQ'6QR U+,
r c F | j d }| j |j d | j |j d | j |j d |j | j |j d y )Nr F)r rY rO ra rU r s r
rZ z#BaseSemaphoreTests.test_try_acquire sn ll1o E*+ E*+ U+,
E*+r c | j d j g fd}t |d j | j t dgdz dgdz z y )Nr c j j d j j d y rX r] )r r s r
r z8BaseSemaphoreTests.test_try_acquire_contended.<locals>.f s- NN3;;u- . NN3;;u- .r re Fr
Tr )r rO r r, rj r )r r r r s @@r
rc z-BaseSemaphoreTests.test_try_acquire_contended s^ ll1o
/ a %%'
5'A+! *CEr c P | j d }| j t |j dd | j |j d | j |j d | j |j d |j
| j |j d t j }| j |j d t j |z
}| j |d y )Nr F ?r| g{Gzt?r )
r rs r rO rY ra rU r r rB )r r tr s r
test_acquire_timeoutz'BaseSemaphoreTests.test_acquire_timeout s ll1o *ckk5#F E 23 E 23 U34
E 23 NN S12
^^
! 2s#r c | j j fd}t |d }|j t | j |j j |j y )Nc F j j y r rg )r s r
r z0BaseSemaphoreTests.test_default_value.<locals>.f s KKM KKMr r` ) r rO r r) r ra r rU r, )r r rl r s @r
test_default_valuez%BaseSemaphoreTests.test_default_value sa lln
!QK
$
r c < j d d fd } | j j d j j t
|t
j j d j y )Nr c 5 j j d j 5 j j d | r| d d d d d d y # 1 sw Y xY w# 1 sw Y y xY wrX )rY rO rU ra )rq r r s r
rr z+BaseSemaphoreTests.test_with.<locals>._with sz
" E 23
"$$S[[%78 ! "
"
"" "
"
"s" 3A:%A. A:.A7 3A::BFr )r rY rO rU rs rt )r rr r s ` @r
ru z BaseSemaphoreTests.test_with sj ll1o " E*+
)UI6 E*+
r N)
r0 r1 r2 rI r rR rm r rZ rc r r ru r r r
r r s> J
#@J @, F $ r r c e Zd Z d Zd Zy)SemaphoreTestsc | j d }|j |j |j |j y Nr` )r rU rO r s r
r z&SemaphoreTests.test_release_unacquired" s3 ll1o
r c ( | j d }| j t | d |j | j t | d |j |j | j t | d y )Nr z <\w+\.Semaphore at .*: value=3>z <\w+\.Semaphore at .*: value=2>z <\w+\.Semaphore at .*: value=4>)r rK rL rO rU r s r
rM zSemaphoreTests.test_repr* si ll1o c$FG
c$FG
c$FGr Nr0 r1 r2 r rM r r r
r# r# s Hr r# c e Zd Z d Zd Zy)BoundedSemaphoreTestsc | j }| j t |j |j |j | j t |j y r )r rs r rU rO r s r
r z-BoundedSemaphoreTests.test_release_unacquired9 sG lln *ckk2
*ckk2r c | j d }| j t | d |j | j t | d y )Nr z(<\w+\.BoundedSemaphore at .*: value=3/3>z(<\w+\.BoundedSemaphore at .*: value=2/3>)r rK rL rO r s r
rM z BoundedSemaphoreTests.test_reprA sB ll1o c$OP
c$OPr Nr' r r r
r) r) 4 s 3Qr r) c r e Zd Z dZdZd Zd Zd Zd ZddZ d Z
d Z d
Z d Z
d Zd
Zd Zd Zd Zd Zy) BarrierTestsre g @c \ | j | j | j | _ y )Nr| ) barriertyperk defaultTimeoutbarrierr( s r
r8 zBarrierTests.setUpO s# ''8K8K'L r c 8 | j j y r )r1 abortr( s r
r< zBarrierTests.tearDownQ s r c d t || j dz
} | |j y r% )r rk r, )r r rl s r
run_threadszBarrierTests.run_threadsT s' !TVVAX r c ` | j j }| j || j t | D ] }|d j d | j t
|d ||z | j j |d j d | j t
|d |dz |z | j j | j | j j d | j | j j y )Nr Tr` ) r1 partiesrj rk r" r r' r n_waitingra broken)r r r mr$ s r
multipasszBarrierTests.multipassY s LL DFF#q A AJ d # S_a!e 4 LL AJ d # S_q1uk : LL
//3 ,,-r c D g g g fd} j | y )Nc * j y r )r; )passesr r s r
r z$BarrierTests.test_barrier.<locals>.fk s NN7F +r r5 )r r> r r s `` @r
test_barrierzBarrierTests.test_barrierf s& b' , r c & | j d S )Nr )r@ r( s r
test_barrier_10z BarrierTests.test_barrier_10o s $$r c g fd} j | j t t t j y )Nc \ j j } j | y r )r1 r r )r r r s r
r z(BarrierTests.test_wait_return.<locals>.fz s! !!#A NN1 r )r5 rj sumr" rk )r r r s ` @r
test_wait_returnz BarrierTests.test_wait_returnu sE
W s5='9:r c g fd} j j | fd} j | y )Nc ( j d y r. )r )r s r
actionz(BarrierTests.test_action.<locals>.action s NN4 r c \ j j t d y r% )r rj r' )r1 r r s r
r z#BarrierTests.test_action.<locals>.f s LLN S\1 -r r/ rk r5 )r rI r r1 r s ` @@r
test_actionzBarrierTests.test_action s? !""46662 .
r c g g fd} j | j t d j t j dz
j j
j y )Nc ^ j j } | j dz k( rt j j j d y # t
j $ r j d Y y t $ r j j Y y w xY wNr T)r1 r rk r r r BrokenBarrierErrorr3 )r$ r r r s r
r z"BarrierTests.test_abort.<locals>.f s
LL%%' >&& !!#% //
&%
""$
s A A! !$B,"B,+B,r r` )r5 rj r' rk rY r1 r9 )r r r r s ` @@r
test_abortzBarrierTests.test_abort so
X * X q1 ++,r c g g g fd} j | j t d j t j dz
j t j y )Nc Z j j } | j dz k( r}j j j dz
k r<t j
d j j j dz
k r<j j
n, j j j d j j j d y # t j $ r j d Y Rw xY w)Nr r` gMbP?T)
r1 r rk r8 r r
resetr r rP )r$ r r results3r s r
r z"BarrierTests.test_reset.<locals>.f s !!#ADFFAI~ll,,tvvax7JJu% ll,,tvvax7 ""$*LL%%' OOD)
LL OOD ! !33 * OOD)*s ,+D $D*)D*r r` )r5 rj r' rk )r r r r rU s ` @@@r
test_resetzBarrierTests.test_reset sv ""
X * X q1 X /r c V g g g j j fd} j | j t d j t j dz
j t j y )Nc H j j } | j dz k( rt j j j d j j dz k( rj j j j j j d y # t
j $ r j d Y t $ r j j Y w xY wrO ) r1 r rk r r r rP r3 rT )r$ barrier2r r rU r s r
r z,BarrierTests.test_abort_and_reset.<locals>.f s
LL%%' >&& !!#% }}$&&!)+ ""$ MMO LL OOD ! //
&%
""$
s A C $D!<"D! D!r r` )r/ rk r5 rj r' )r r rY r r rU s ` @@@@r
test_abort_and_resetz!BarrierTests.test_abort_and_reset s ##DFF+ " "*
X * X q1 X /r c 4 fd} j | y )Nc j j } | j dz k( rt j d j t j j j d y )Nr r r )r1 r rk r r
rs r rP )r$ r s r
r z$BarrierTests.test_timeout.<locals>.f sU !!#ADFFaK
3 i : : "ll / /
6r r? )r r s ` r
r zBarrierTests.test_timeout s 6
r c r j j d fd} j | y )Ng333333?r| c j } | j dz k( rt j d j t
j j y )Nr r )r rk r r
rs r rP )r$ r1 r s r
r z,BarrierTests.test_default_timeout.<locals>.f sC ADFFaK
3 i : :GLL Ir rK )r r r1 s ` @r
test_default_timeoutz!BarrierTests.test_default_timeout s9 ""4663"7 J
r c f | j d }|j |j y r% )r/ r )r rl s r
test_single_threadz BarrierTests.test_single_thread s$ Q r c | j d | j t d fd}t |d }|j t j d | j t d j d |j | j t d j | j t d y )Nr z!<\w+\.Barrier at .*: waiters=0/3>c ( j d y )Nr )r )rl s r
r z!BarrierTests.test_repr.<locals>.f s
FF1Ir r g?z!<\w+\.Barrier at .*: waiters=2/3>z <\w+\.Barrier at .*: broken>)
r/ rK rL r r) r r
r r, r3 )r r bunchrl s @r
rM zBarrierTests.test_repr s Q a"FG a
3 a"FG q
! a"FG a"ABr N)r` )r0 r1 r2 rk r0 r8 r< r5 r; r@ rB rF rL rQ rV rZ r r_ ra rM r r r
r- r- H sa
ANM
. %
; -00< 0D
Cr r- ) r r r _threadr r r unittestr testr test.supportr
skipUnlesshas_fork_supportr r objectr TestCaser4 rD r r r r r r# r) r- r r r
<module>rm s
1 ) $##G$<$<%CD
. F . b18$$ 1"E!L E!PA
AH@+ @+Fb@ b@Jl*\ l*^\ \|H' H.Q . Q(MC< MCr