python (3.11.7)
Browse
Usage
Versions
e d dl Z d dlZd dlZd dlZd dlmZmZ d dlZd dlZd dl Z d 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 dS ) N)start_new_thread TIMEOUT_MAX)support)threading_helperz9platform doesn't support fork (no _at_fork_reinit method)c 4 t j d| z d S )N{Gz?)timesleep)nthreads C/BuggyBox/python/3.11.7/bootstrap/lib/python3.11/test/lock_tests.pywait_threads_blockedr
s Juw c 0 e Zd Z ddZd Zd Zd Zd ZdS ) BunchFc l || _ || _ g | _ g | _ g | _ | | _ d | _ d S N)funcr startedfinished
exceptions _can_exit _wait_thread)selfr r wait_before_exits r __init__zBunch.__init__! sD
-- r c
t j }| j | | n1# t
$ r$}| j | Y d }~nd }~ww xY w| j | t j t j
D ] }| j r d S
d S # | j | t j t j
D ] }| j r w w xY wr ) threading get_identr appendr
BaseExceptionr r r sleeping_retry
SHORT_TIMEOUTr )r tidexc_s r taskz
Bunch.task/ s% !## C IIKKKK ( ( ( O " "3 ' ' ' ' ' ' ' ' (
M % % % +G,ABB
> EE
M % % % +G,ABB
> E
s0 A B<
A2A-(B< -A22B< <ADc t t j t j | _ | j t
| j D ]}t | j d n
# d| _
xY wt j t j D ]!}t | j
| j k r n"| S )N T)r wait_threads_exitr r" r __enter__ranger r r& r r! lenr )r r% s r r* zBunch.__enter__< s , >w?T U U ##%%% 4<((
0
0 B////
0 !DN '(=>> A4< DL00 1 s ,A+ +
A5c t j t j D ]!}t | j | j k r n"| j d d d | j }d | _ |rt | j
d| d S )Nz threads raised exceptions) r r! r" r, r r r __exit__r ExceptionGroupr )r exc_type exc_value tracebackr% r s r r. zBunch.__exit__M s '(=>> A4=!!T\11 2
""4t444 _
- DI!I!I!I!+- -
- - -r c d| _ d S NT)r r s r do_finishzBunch.do_finish\ s
r N)F)__name__
__module__ __qualname__r r& r* r. r6 r( r r r r si ! ! ! ! "
-
-
- r r c e Zd Zd Zd Zd ZdS ) BaseTestCasec 6 t j | _ d S r )r threading_setup_threadsr5 s r setUpzBaseTestCase.setUpa s (8::
r c R t j | j t j d S r )r threading_cleanupr> r
reap_childrenr5 s r tearDownzBaseTestCase.tearDownd s' *DM:: r c j | ||dz | ||dz d S )Ng333333?g $@)assertGreaterEqual
assertLess)r actualexpecteds r
assertTimeoutzBaseTestCase.assertTimeouth s<
3777 400000r N)r7 r8 r9 r? rC rI r( r r r; r; ` sA ; ; ; 1 1 1 1 1r r; c d e Zd Z d Zd Zd Zd Zd Zd Zd Z d Z
d Z d
Z d Z
d Zd
Zd ZdS )
BaseLockTestsc t j t j D ]}t | |k r n| t | | d S r )r r! r" r, assertEqual)r phaserH r% s r
wait_phasezBaseLockTests.wait_phasev s\ '(=>> A5zzX%% & UX.....r c 0 | }~d S r )locktyper locks r test_constructorz BaseLockTests.test_constructor| s }} DDr c v | }| t | d ~d S )Nz <unlocked .* object (.*)?at .*>)rQ assertRegexreprrR s r test_reprzBaseLockTests.test_repr s3 }} d%FGGG DDr c | }| | t | d ~d S )Nz <locked .* object (.*)?at .*>)rQ acquirerV rW rR s r test_locked_reprz BaseLockTests.test_locked_repr s@ }} d%DEEE DDr c X | }| ~d S r )rQ rZ rR s r test_acquire_destroyz"BaseLockTests.test_acquire_destroy s# }} DDr c | }| | ~d S r rQ rZ releaserR s r test_acquire_releasez"BaseLockTests.test_acquire_release s0 }} DDr c | }| | d | d S NF)rQ
assertTruerZ r` rR s r test_try_acquirez BaseLockTests.test_try_acquire s> }} U++,,, r c | g fd}t |d 5 d d d n # 1 swxY w Y | d d S )Nc X d d S rc r rZ rS results r fz3BaseLockTests.test_try_acquire_contended.<locals>.f s' MM$,,u-- . . . . .r r )rQ rZ r assertFalser` r rk rS rj s @@r test_try_acquire_contendedz(BaseLockTests.test_try_acquire_contended s }} / / / / / /
1a[[ ### s AAAc | fd}d}t || 5 }t | | t |j d d d d n # 1 swxY w Y | t |j | d S )Nc X d S r rZ r` rS s r rk z/BaseLockTests.test_acquire_contended.<locals>.f ! LLNNN LLNNNNNr r )rQ rZ r r
rM r, r r` )r rk NbunchrS s @r test_acquire_contendedz$BaseLockTests.test_acquire_contended s }}
1a[[ E # # # S 0 0! 4 4 4
LLNNN
U^,,a00000s A BB B c | fd}dfd }5 d d d n # 1 swxY w Y t |d 5 d d d n # 1 swxY w Y | t 5 5 t # 1 swxY w Y d d d n # 1 swxY w Y t |d 5 d d d d S # 1 swxY w Y d S )Nc X d S r rr rs s r rk z"BaseLockTests.test_with.<locals>.f rt r c H 5 | | d d d d S # 1 swxY w Y d S r r( )errrS s r with_lockz*BaseLockTests.test_with.<locals>.with_lock s|
? I #
s rl r )rQ r assertRaises TypeError)r rk r} rS s @r test_withzBaseLockTests.test_with s3 }} 1a[[
y
)
)
1a[[ s` 155 AA !A ?B"B
B B"B B""B&)B&=C CCc | fd}t |d 5 d d d d S # 1 swxY w Y d S )Nc X d S r rr rs s r rk z)BaseLockTests.test_thread_leak.<locals>.f rt r )rQ r r rk rS s @r test_thread_leakz BaseLockTests.test_thread_leak s }} 1b\\ s
:>>c P | | t j dd | t j d | t j d | t j t
dz t
t j }| d t j }|
||z
d g fd}t |d 5 d d d n # 1 swxY w Y | d |
d d d S )
NFrl itimeoutg}Ô%ITru c t j } d t j } || z
d S )N ?r )r monotonicr rZ )t1t2rS resultss r rk z%BaseLockTests.test_timeout.<locals>.f sY !!B NN4<<<44 5 5 5 !!B NN27 # # # # #r r r )rQ r~
ValueErrorrZ
OverflowErrorr r` r r rd rF r rm rI )r r r rk rS r s @@r test_timeoutzBaseLockTests.test_timeout s }} *dlE1=== *dlDAAA - uEEE - {QOOO [ )))
^
Q //000
^
R### $ $ $ $ $ $
1a[[ $$$ 71:s+++++s E$$E(+E(c | }t j | }| | d S r )rQ weakrefrefassertIsNotNoner rS r s r test_weakref_existsz!BaseLockTests.test_weakref_exists s> }}k$ SSUU#####r c | }t j | }~t j | | d S r )rQ r r gccollect assertIsNoner s r test_weakref_deletedz"BaseLockTests.test_weakref_deleted sL }}k$
##%% r N)r7 r8 r9 rO rT rX r[ r] ra re ro rx r r r r r r( r r rK rK q s / / /
1 1 1$ : , , ,6$ $ $
! ! ! ! !r rK c 8 e Zd Z d Zd Zd Zed ZdS ) LockTestsc : | g fd}t j 5 t |d | d | d d d d d S # 1 swxY w Y d S )Nc d d d S r rZ r )rS rN s r rk z#LockTests.test_reacquire.<locals>.f sG LLNNN LL LLNNN LL r r( rl )rQ r r) r rO r` r rk rS rN s @@r test_reacquirezLockTests.test_reacquire s }}
/
1
1 & & Q # # # OOE1 % % %
LLNNN OOE1 % % % & & & & & & & & & & & & & & & & & &s ABBBc | fd}t |d 5 d d d n # 1 swxY w Y d S )Nc 0 d S r )r` rs s r rk z*LockTests.test_different_thread.<locals>.f' LLNNNNNr rl )rQ rZ r r` r s @r test_different_threadz LockTests.test_different_thread# s }}
1a[[ s A
AAc p | }| | | d | | | | | d d S )Nr r F)blocking)rQ rZ rm r` lockedrd rR s r test_state_after_timeoutz"LockTests.test_state_after_timeout. s }} d 33444 ''' e 4455555r c d }| }| || | }| | || d S )Nc V | | d S r rr rs s r use_lockz/LockTests.test_at_fork_reinit.<locals>.use_lock: s"
LLNNN LLNNNNNr )rQ _at_fork_reinitrZ )r r rS lock2s r test_at_fork_reinitz LockTests.test_at_fork_reinit8 s~ }}
r N)r7 r8 r9 r r r
requires_forkr r( r r r r
sa & & &( 6 6 6 ] r r c 4 e Zd Z d Zd Zd Zd Zd Zd ZdS )
RLockTestsc | }| | | | | | d S r r_ rR s r r zRLockTests.test_reacquireP sa }} r c | }| t |j | | | | | | | t |j d S r )rQ r~ RuntimeErrorr` rZ rR s r test_release_unacquiredz"RLockTests.test_release_unacquiredY s }} , 555 , 55555r c | }| t |j | | | | | | | t |j d S r )rQ r~ r
_release_saverZ r` rR s r test_release_save_unacquiredz'RLockTests.test_release_save_unacquirede s }} ,(:;;; ,(:;;;;;r c ` d d d d d g fd}t j 5 t |d d d d d d d d d d S # 1 swxY w Y d S )Nr rl r c d d d d S )Nr )rZ r rO r` )rS rN r s r rk z*RLockTests.test_recursion_count.<locals>.f s[ LLNNN LL OOE1 % % % LLNNN LL r r( )
rQ rM _recursion_countrZ r` r r) r rO r r s ` @@r test_recursion_countz RLockTests.test_recursion_countq s7 }} D 1 1 3 3444 D 1 1 3 3444 D 1 1 3 3444 D 1 1 3 3444 D 1 1 3 3444
/
1
1 9 9 Q # # # OOE1 % % % Q 5 5 7 7 8 8 8
LL OOE1 % % % Q 5 5 7 7 8 8 8 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9s 4B"H##H'*H'c . | fd}t |dd 5 } | t j | n# | w xY w d d d d S # 1 swxY w Y d S )Nc 0 d S r )rZ rs s r rk z+RLockTests.test_different_thread.<locals>.f r r rl T)rQ r r~ r r` r6 )r rk rw rS s @r r z RLockTests.test_different_thread s }} 1a
"%
"!!, ===!!!!!!!!! " " " " " " " " " " " " " " " " " "s( B
A#B
#A99B
BBc | | | | g fd}t |d 5 d d d n # 1 swxY w Y | d | | d S )Nc V d S r )r _is_ownedri s r rk z$RLockTests.test__is_owned.<locals>.f s% MM$..** + + + + +r rl r )rQ rm r rZ rd r r` rn s @@r test__is_ownedzRLockTests.test__is_owned s| }} ))*** (())) (())) , , , , , ,
1a[[ ### (())) ))*****s CC !C N) r7 r8 r9 r r r r r r r( r r r r L st
6
6
6
<
<
<!9 !9 !9F
"
"
"+ + + + +r r c J e Zd Z d Zd Zd Zd Zd Zed Z d Z
dS )
EventTestsc T | }| | | | | | | | | | | | | | d S r ) eventtyperm is_setsetrd clearr evts r test_is_setzEventTests.test_is_set s nn &&&
%%%
%%% &&& &&&&&r c j d}g g fd}t || 5 t | | t d d d d n # 1 swxY w Y | dg|z | dg|z d S )Nru c d S r )r wait)r results1results2s r rk z#EventTests._check_notify.<locals>.f s= OOCHHJJ ' ' ' OOCHHJJ ' ' ' ' 'r r T)r r
rM r, r )r r rv rk r r s ` @@r
_check_notifyzEventTests._check_notify s
( ( ( ( ( ( ( 1a[[ # # # S]]A . . .
GGIII
D6A:... D6A:.....s AA44A8;A8c | }| | | | | | d S r )r r r r r s r test_notifyzEventTests.test_notify sY nn 3 3 r c * | g g d}fd}t || 5 d d d n # 1 swxY w Y | dg|z D ]0\ }}| | | |d 1g g t || 5 d d d n # 1 swxY w Y | dg|z D ]\ }}| | d S )Nru c d t j } d }t j } ||| z
f d S )Ng r )r r r r )r rr r r r s r rk z"EventTests.test_timeout.<locals>.f sh OOCHHSMM * * * !!B
A !!B OOQRL ) ) ) ) )r Fr T)r r rM rm rI r rd )r rv rk r dtr r r s @@@r r zEventTests.test_timeout s nn
* * * * * * * 1a[[
E7Q;/// ( (EAr Q r3 ' ' ' '
1a[[
D6A:... EAr OOA s# AA
ACCCc 8 | g fd}d}t || 5 t | d d d n # 1 swxY w Y | dg|z d S )Nc l t j d S r )r r r LONG_TIMEOUT)eventr s r rk z(EventTests.test_set_and_clear.<locals>.f s* NN5::g&:;; < < < < <r ru T)r r r
r r rM )r rk rv r r s @@r test_set_and_clearz EventTests.test_set_and_clear s = = = = = =
1a[[ # # #
IIKKK KKMMM
4&1*-----s 8A55A9<A9c | }|j 5 | |j d d d d n # 1 swxY w Y | |j 5 | |j d d d d d S # 1 swxY w Y d S rc )r _condrm rZ r r s r r z EventTests.test_at_fork_reinit s6 nn
Y 7 7 SY . .u 5 5 6 6 6 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7
Y 7 7 SY . .u 5 5 6 6 6 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7s# .AA A<.B77B;>B;c | }| t | d | | t | d d S )Nz<\w+\.Event at .*: unset>z<\w+\.Event at .*: set>)r rV rW r r s r rX zEventTests.test_repr s^ nn c$@AAA c$>?????r N) r7 r8 r9 r r r r r r r rX r( r r r r s
'
'
'/ / /( >. . .& 7 7 ]7@ @ @ @ @r r c @ e Zd Z d Zd Zd Zd Zd Zd Zd Z d Z
d S )
ConditionTestsc | }| | | | t j }| | }| | | d | | | d | | d | |5 | | d d d d d S # 1 swxY w Y d S rc )condtyperZ r` r Lockrm rd )r condrS s r test_acquirezConditionTests.test_acquire( sr }}
~ }}T"" e,,--- U++,,, e,,---
2 2 T\\% 0 0 1 1 1 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2s )E99E= E=c n | }| t |j d S r )r r~ r r r r s r test_unacquired_waitz#ConditionTests.test_unacquired_wait; s- }} , 22222r c n | }| t |j d S r )r r~ r notifyr s r test_unacquired_notifyz%ConditionTests.test_unacquired_notify? s- }} , 44444r c
g g g
d
fd}d}t || 5 t j t j D ]}t |k r n | g d} | t | d
t j t j D ]}t |k r n| dg|z |
g t j t j D ]}t |k r n d t | d
t j t j D ]*}t t
z ||z k r n+||z
}| dg|z dg|z z |
dg|z t j t j D ]}t |k r n t | d
t j t j D ]}t
|k r n| dg|z dg|z z |
dg|z d g|z z d d d d S # 1 swxY w Y d S )
Nr c } | f } | f d S r )rZ r r r` )rj r phase_numreadyr r s r rk z'ConditionTests._check_notify.<locals>.fS s LLNNN LL # # #YY[[F LLNNN OOVY / 0 0 0 LLNNN LL # # #YY[[F LLNNN OOVY / 0 0 0 0 0r ru r rl )Trl r )Tr )Tr ) r r r! r" r, r rM rZ r r
r`
notify_all) r r rk rv r% count1count2r r r r s ` @@@@r r z ConditionTests._check_notifyC s
1
1
1
1
1
1
1
1
1
1a[[ @ T @ T +G,ABB
u::??E #
KKMMM Xr * * * F LLNNN KK ( ( ( I LLNNN +G,ABB
x==F**E +
X {V'; < < < Xr * * * +G,ABB
u::''E (
LLNNN KKNNN # # # I LLNNN +G,ABB
x==3x==0QZ@@E A ZF X {V';ykF>R'R S S S X {V'; < < < +G,ABB
u::??E #
LLNNN OO # # # I LLNNN +G,ABB
x==A%%E & X {V';ykF>R'R S S S X {V';ykF>R'R S S SA@ T @ T @ T @ T @ T @ T @ T @ T @ T @ T @ T @ T @ T @ T @ T @ T @ T @ Ts L MM Mc | }| | | | d S r )r r r s r r zConditionTests.test_notify s= }} 4 4 r c L | dg fd}d}t || 5 d d d n # 1 swxY w Y | t | D ]0\ }}| | | | 1d S )Nr c t j } }t j } || z
|f d S r )rZ r r r r` r )r rj r r r r s r rk z&ConditionTests.test_timeout.<locals>.f si LLNNN !!BYYw''F !!B LLNNN NNBGV, - - - - -r ru )r r rM r, rI rm )r rk rv r rj r r r s @@@r r zConditionTests.test_timeout s }} . . . . . . .
1a[[ W q)))! % %JB r7 + + +
V $ $ $ $ % %s AA
Ac L d fd}t |d 5 t d D ]I}t j d 5 dz
d d d n # 1 swxY w Y J d d d d S # 1 swxY w Y d S )Nr c 5 fd } | d d d d d S # 1 swxY w Y d S )Nc dk S N r( states r <lambda>z8ConditionTests.test_waitfor.<locals>.f.<locals>.<lambda> s uz r r )wait_forrd rM )rj r r r s r rk z&ConditionTests.test_waitfor.<locals>.f s
+
+ '9'9'9'9::''' ***
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+s AAA Arl r r )r r r+ r r
r )r rk ir r s ` @@r test_waitforzConditionTests.test_waitfor sJ }} + + + + + + + 1a[[ " "1XX
"
"
5!!! " "QJEKKMMM" " " " " " " " " " " " " " "
" " " " " " " " " " " " " " " " " " "s5 (BA?3 B?B BB BB B c dg fd}t |d 5 t d D ]I}t j d 5 dz
d d d n # 1 swxY w Y J d d d n # 1 swxY w Y t d d S )Nr c D 5 t j } fdd }t j | z
} | | d d d d d d S # 1 swxY w Y d S )Nc dk S r r( r s r r z@ConditionTests.test_waitfor_timeout.<locals>.f.<locals>.<lambda> s q r 皙?r )r r r rm rI r )r rj r r r successs r rk z.ConditionTests.test_waitfor_timeout.<locals>.f s
%
%^%% '8'8'8'8# FF^%%* (((""2s+++t$$$
%
%
%
%
%
%
%
%
%
%
%
%
%
%
%
%
%
%s BBB Brl r r )r r r+ r r
r rM r, )r rk r r r r s ` @@@r test_waitfor_timeoutz#ConditionTests.test_waitfor_timeout sj }} % % % % % % % % 1a[[ " "1XX
"
"
5!!! " "QJEKKMMM" " " " " " " " " " " " " " "
" " " " " " " " " " " " " " " "
W q)))))s5 (B B7 B B B
B B B #B N) r7 r8 r9 r r r r r r r r
r( r r r r # s 2 2 2&3 3 35 5 5`T `T `TD! ! ! % % %4" " " * * * * *r r c L e Zd Z d Zd Zd Zd Zd Zd Zd Z d Z
d Z d
Z d S ) BaseSemaphoreTestsc | t | j d | t | j t j d S )N)value)r~ r semtypesysmaxsizer5 s r rT z#BaseSemaphoreTests.test_constructor sF *dlB??? *dlS[LIIIIIr c J | d }| | | d }| | | | d S )Nrl r )r rZ r` r sems r r z BaseSemaphoreTests.test_acquire sr ll1oo
ll1oo
r c X | }| ~d S r )r rZ r s r r] z'BaseSemaphoreTests.test_acquire_destroy s# llnn
CCr c
d}| |
g g g d
fd} fd}d}t || 5 |dz
} || | z dg|z d
t | D ]}
|} |||z | t
z dg|z dg|z z d
|dz
}t | D ]}
|||z |z | t
z dg|z dg|z z dg|z z |
d d}
d d d n # 1 swxY w Y | d g||z |z | z z d S )
N r c d S r rh )r r r r sem_resultss r r z7BaseSemaphoreTests.test_acquire_contended.<locals>.func se s{{}} - - - OOI & & & s{{}} - - - OOI & & & & &r c t j t j D ](}t t z | k r d S )d S r r r! r" r, countr% r r s r
wait_countz=BaseSemaphoreTests.test_acquire_contended.<locals>.wait_count R +G,ABB
x==3x==0E99EE :
r
rl r FT)r rZ r rM r+ r` sortedrm )r sem_valuer r" rv r r r count3count4r r r r r s @@@@@r rx z)BaseSemaphoreTests.test_acquire_contended s ll9%%
' ' ' ' ' ' ' ' '
4^^ ]F Jv X 01#, ? ? ? I9%%
F Jv ' ' ' VHx$7 8 8 S6\QC&L 8
:
:
: I !mF6]]
Jv/ 0 0 0 VHx$7 8 8 S6\QC&L 8A3< G
I
I
I
S[[ / / 0 0 0 F KKMMM9 <
6F?V#;f#DE G G G G Gs E F11F58F5c *
d}| |
g g d
fd} fd}t |d 5 |dz
} || | z dg|z d|}
| |||z | t z dg|z dg|z z d|dz
}
| |||z |z | t z dg|z dg|z z dg|z z |
d
d d d d S # 1 swxY w Y d S ) Nr r c d S r r )r r r r s r r z2BaseSemaphoreTests.test_multirelease.<locals>.funcE sG KKMMM OOI & & & KKMMM OOI & & & & &r c t j t j D ](}t t z | k r d S )d S r r r s r r" z8BaseSemaphoreTests.test_multirelease.<locals>.wait_countL r# r r$ rl r F)r rZ r rM r` r% rm ) r r& r r" r r r' r r r r s @@@@r test_multireleasez$BaseSemaphoreTests.test_multirelease= sN ll9%%
' ' ' ' ' ' ' '
4__ ]F Jv X 01#, ? ? ? I F KK Jv ' ' ' VHx$7 8 8 S6\QC&L 8
:
:
: I ]F KK Jv/ 0 0 0 VHx$7 8 8 S6\QC&L 8A3< G
I
I
I
S[[ / / 0 0 0
KKMMM3 s D'FF F c | d }| | d | | d | | d | | | d d S )Nr F)r rd rZ rm r` r s r re z#BaseSemaphoreTests.test_try_acquirel s ll1oo E**+++ E**+++ U++,,,
E**+++++r c | d g fd}t |d 5 d d d n # 1 swxY w Y | t dgdz dgdz z d S )Nr c d d d S rc rh )r r s r rk z8BaseSemaphoreTests.test_try_acquire_contended.<locals>.fx sE NN3;;u-- . . . NN3;;u-- . . . . .r ru Fr Tr )r rZ r rM r% )r rk r r s @@r ro z-BaseSemaphoreTests.test_try_acquire_contendedt s ll1oo
/ / / / / / 1a[[
5'A+! *CEEEEEs AAAc | d }| t |j dd | | d | | d | | d | | | d t j }| | d t j |z
}| |d d S )Nr Fg ?r g{Gzt?r )
r r~ r rZ rd rm r` r r rI )r r tr s r test_acquire_timeoutz'BaseSemaphoreTests.test_acquire_timeout s ll1oo *ck5#FFF E 22333 E 22333 U33444
E 22333 N S11222
^
! 2s#####r c . | fd}t |d 5 }t d | |j d d d d S # 1 swxY w Y d S )Nc X d S r rr )r s r rk z0BaseSemaphoreTests.test_default_value.<locals>.f s! KKMMM KKMMMMMr rl )r rZ r r
rm r r` )r rk rw r s @r test_default_valuez%BaseSemaphoreTests.test_default_value s llnn
1a[[ E # # # U^ , , ,
KKMMM
s >B
BBc d d fd } | d t
|t
d d S )Nr c D 5 d 5 d | r| d d d n # 1 swxY w Y d d d d S # 1 swxY w Y d S rc )rd rZ r` rm )r| r r s r _withz+BaseSemaphoreTests.test_with.<locals>._with s%
"
" E 2 2333
" "$$S[[%7%7888 " ! "" " " " " " " " " " " " " " "
"
"
"
"
"
"
"
"
"
"
"
"
"
"
"
"
"
"s5 ?B-A=1 B=B BB BB BFr )r rd rZ r` r~ r )r r8 r s ` @r r z BaseSemaphoreTests.test_with s ll1oo " " " " " " " E**+++
)UI666 E**+++
r N)
r7 r8 r9 rT r r] rx r, re ro r2 r5 r r( r r r r s J J J
6G 6G 6Gp- - -^, , , F F F $ $ $ r r c e Zd Z d Zd ZdS )SemaphoreTestsc | d }| | | | d S Nrl )r r` rZ r s r r z&SemaphoreTests.test_release_unacquired sI ll1oo
r c z | d }| t | d | | t | d | | | t | d d S )Nr z <\w+\.Semaphore at .*: value=3>z <\w+\.Semaphore at .*: value=2>z <\w+\.Semaphore at .*: value=4>)r rV rW rZ r` r s r rX zSemaphoreTests.test_repr s ll1oo c$FGGG
c$FGGG
c$FGGGGGr Nr7 r8 r9 r rX r( r r r: r: s< H H H H Hr r: c e Zd Z d Zd ZdS )BoundedSemaphoreTestsc | }| t |j | | | t |j d S r )r r~ r r` rZ r s r r z-BoundedSemaphoreTests.test_release_unacquired s_ llnn *ck222
*ck22222r c | d }| t | d | | t | d d S )Nr z(<\w+\.BoundedSemaphore at .*: value=3/3>z(<\w+\.BoundedSemaphore at .*: value=2/3>)r rV rW rZ r s r rX z BoundedSemaphoreTests.test_repr s^ ll1oo c$OPPP
c$OPPPPPr Nr> r( r r r@ r@ s< 3 3 3Q Q Q Q Qr r@ c t e Zd Z dZdZd Zd Zd Zd ZddZ d Z
d
Z d Z d Z
d
Zd Zd Zd Zd Zd ZdS ) BarrierTestsru g @c R | | j | j | _ d S )Nr ) barriertyperv defaultTimeoutbarrierr5 s r r? zBarrierTests.setUp s% ''8K'LL r c 8 | j d S r )rH abortr5 s r rC zBarrierTests.tearDown s r c d t || j 5 d d d d S # 1 swxY w Y d S r )r rv r rk s r run_threadszBarrierTests.run_threads s{
1df
s %))c | | j j }| || j t | D ]}|d d | t
|d ||z | j |d d | t
|d |dz |z | j | | j j d | | j j
d S )Nr Trl ) rH partiesrM rv r+ r r, r n_waitingrm broken)r r nmr s r multipasszBarrierTests.multipass s L DF###q A AJ d # # # S__a!e 4 4 4 L AJ d # # # S__q1uk : : : L /333 ,-----r rl c N g g g fd} | d S )Nc 4 d S r )rT )passesr r s r rk z$BarrierTests.test_barrier.<locals>.f s NN7F + + + + +r rM )r rW rk r s `` @r test_barrierzBarrierTests.test_barrier sR b' , , , , , , , r c . | d S )Nr$ )rY r5 s r test_barrier_10z BarrierTests.test_barrier_10 s $$$r c g fd} | t t t j d S )Nc d j } | d S r )rH r r )r r r s r rk z(BarrierTests.test_wait_return.<locals>.f
s. !!##A NN1 r )rM rM sumr+ rv )r rk r s ` @r test_wait_returnz BarrierTests.test_wait_return sv
W s5=='9'9:::::r c g fd} j | fd} | d S )Nc 2 d d S r4 )r )r s r actionz(BarrierTests.test_action.<locals>.action s NN4 r c v t d d S r< )r rM r, )rH r r s r rk z#BarrierTests.test_action.<locals>.f s2 LLNNN S\\1 - - - - -r )rF rv rM )r rb rk rH r s ` @@r test_actionzBarrierTests.test_action s ! ! ! ! !""46622 . . . . . . .
r c ( g g fd} | t d t j dz
j j d S )Nc b j } | j dz k rt j d d S # t
j $ r d Y d S t $ r j Y d S w xY wNr T)rH r rv r r r BrokenBarrierErrorrJ )r r r r s r rk z"BarrierTests.test_abort.<locals>.f( s
L%%'' >>&& !!###%%%%% /
&
&
&%%%%%%
""$$$
s A A! !$B."B.-B.r rl )rM rM r, rv rd rH rQ )r rk r r s ` @@r
test_abortzBarrierTests.test_abort" s
X *** X q111 +,,,,,r c B g g g fd} | t d t j dz
t j d S )Nc j } | j dz k rUt j t j D ] }j j j dz
k r n j nZ j d n*# t j
$ r d Y nw xY wj d d S )Nr rl T) rH r rv r r! r" rP resetr r rh )r r% r r results3r s r rk z"BarrierTests.test_reset.<locals>.fA s !!##ADFAI~~ /0EFF A|-$&1*== > ""$$$$*L%%''' OOD)))) 3 * * * OOD)))))*
L OOD ! ! ! ! !s ?.B. .$CCr rl )rM rM r, rv )r rk r r rm s ` @@@r
test_resetzBarrierTests.test_reset: s " " " " " " " "$
X *** X q111 X /////r c z g g g j fd} | t d t j dz
t j d S )Nc V j } | j dz k rt j d nN# t
j $ r d Y n(t $ r j Y nw xY w j dz k rj j d d S rg ) rH r rv r r r rh rJ rl )r barrier2r r rm r s r rk z,BarrierTests.test_abort_and_reset.<locals>.fa s"
L%%'' >>&& !!###%%%% /
&
&
&%%%%%
""$$$
}}$&!)++ ""$$$ MMOOO L OOD ! ! ! ! !s A A $B+"B+*B+r rl )rF rv rM rM r, )r rk rq r r rm s ` @@@@r test_abort_and_resetz!BarrierTests.test_abort_and_resetY s ##DF++ " " " " " " " " "*
X *** X q111 X /////r c > fd} | d S )Nc j } | j dz k r t j j dz t j j j j dz d S )Nr r ) rH r rv r r
rG r~ r rh )r r s r rk z$BarrierTests.test_timeout.<locals>.f s} !!##ADFaK
4.2333 i : "l /1Dq1H
J
J
J
J
Jr rX rL s ` r r zBarrierTests.test_timeout{ sB J J J J J
r c d} d| fd}t j }t |d 5 d d d n # 1 swxY w Y t j |z
} || d S )Nr r r c R t j j d S r )r~ r rh r )rH r s r rk z,BarrierTests.test_default_timeout.<locals>.f s/ i : %l
,
,
,
,
,r rl )rF r r r rE )r r rk
start_timer rH s ` @r test_default_timeoutz!BarrierTests.test_default_timeout s ""1g"66 , , , , , , ^%%
1a[[
^
* G,,,,,s AAAc | d }| | d S r< )rF r )r bs r test_single_threadz BarrierTests.test_single_thread s3 Q r c r | d t j | t d fd}d}t || 5 t j t j D ]}j |k r n| t d d d d n # 1 swxY w Y | t d
| t d d S )Nr z!<\w+\.Barrier at .*: waiters=0/3>c 2 d S r )r )rH r s r rk z!BarrierTests.test_repr.<locals>.f s LL ! ! ! ! !r r z!<\w+\.Barrier at .*: waiters=2/3>z <\w+\.Barrier at .*: broken>) rF r r rV rW r r! r" rP r rJ )r rk rv r% rH r s @@r rX zBarrierTests.test_repr s ""1%%& g (LMMM " " " " " "
1a[[ " " +G,ABB
$))E * T']] A
C
C
C
LL ! ! ! " " " " " " " " " " " " " " "
g = ? ? ?
g 8 : : : : :s A'CCCN)rl )r7 r8 r9 rv rG r? rC rM rT rY r[ r_ rd ri rn rr r rx r{ rX r( r r rD rD s
ANM M M . . . % % %
;
;
; - - -0 0 0 0> 0 0 0D - - -
: : : : :r rD ) osr r r _threadr r r unittestr testr test.supportr
skipUnlesshas_fork_supportr r
objectr TestCaser; rK r r r r r r: r@ rD r( r r <module>r s
1 1 1 1 1 1 1 1 ) ) ) ) ) ) $#G$<%CD D
@ @ @ @ @ F @ @ @ F1 1 1 1 18$ 1 1 1"V! V! V! V! V!L V! V! V!r? ? ? ? ?
? ? ?Dd+ d+ d+ d+ d+ d+ d+ d+Nm@ m@ m@ m@ m@ m@ m@ m@`G* G* G* G* G*\ G* G* G*TA A A A A A A AFH H H H H' H H H.Q Q Q Q Q . Q Q Q(\: \: \: \: \:< \: \: \: \: \:r