python (3.11.7)
Browse
Usage
Versions
e d Z ddlZddlZddlZddlZddlmZmZ ddlZddl Z ddl
Z
ddl m Z ddl
mZ e j e j d Zd Z G d d e Z G d
d e j 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 ) z/
Various tests for synchronization primitives.
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 2 e Zd ZdZd dZd Zd Zd Zd ZdS )
Bunchz
A bunch of threads.
Fc j || _ || _ g | _ g | _ g | _ | | _ d| _ dS )z
Construct a bunch of `nthread` threads running the same function `func`.
If `wait_before_exit` is True, the threads won't terminate until
do_finish() is called.
N)funcr startedfinished
exceptions _can_exit _wait_thread)selfr r wait_before_exits r __init__zBunch.__init__! s?
-- 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 wN) 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____doc__r r& r* r. r6 r( r r r r sn ! ! ! ! "
-
-
- 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@ rD rJ r( r r r< r< ` sA ; ; ; 1 1 1 1 1r r< c f e Zd ZdZd Zd Zd Zd Zd Zd Z d Z
d Z d
Z d Z
d Zd
Zd Zd ZdS )
BaseLockTestsz;
Tests for both recursive and non-recursive locks.
c t j t j D ]}t | |k r n| t | | d S r )r r! r" r, assertEqual)r phaserI 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 .*>)rR assertRegexreprrS s r test_reprzBaseLockTests.test_repr s3 }} d%FGGG DDr c | }| | t | d ~d S )Nz <locked .* object (.*)?at .*>)rR acquirerW rX rS s r test_locked_reprz BaseLockTests.test_locked_repr s@ }} d%DEEE DDr c X | }| ~d S r )rR r[ rS s r test_acquire_destroyz"BaseLockTests.test_acquire_destroy s# }} DDr c | }| | ~d S r rR r[ releaserS s r test_acquire_releasez"BaseLockTests.test_acquire_release s0 }} DDr c | }| | d | d S NF)rR
assertTruer[ ra rS 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 rd r r[ rT results r fz3BaseLockTests.test_try_acquire_contended.<locals>.f s' MM$,,u-- . . . . .r r )rR r[ r assertFalsera r rl rT rk 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 r[ ra rT s r rl z/BaseLockTests.test_acquire_contended.<locals>.f ! LLNNN LLNNNNNr r )rR r[ r r
rN r, r ra )r rl NbunchrT 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 rs rt s r rl z"BaseLockTests.test_with.<locals>.f ru r c H 5 | | d d d d S # 1 swxY w Y d S r r( )errrT s r with_lockz*BaseLockTests.test_with.<locals>.with_lock s|
? I #
s rm r )rR r assertRaises TypeError)r rl r~ rT 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 rs rt s r rl z)BaseLockTests.test_thread_leak.<locals>.f ru r )rR r r rl rT 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 )
NFrm itimeoutg}Ô%ITrv c t j } d t j } || z
d S )N ?r )r monotonicr r[ )t1t2rT resultss r rl z%BaseLockTests.test_timeout.<locals>.f sY !!B NN4<<<44 5 5 5 !!B NN27 # # # # #r r r )rR r
ValueErrorr[
OverflowErrorr ra r r re rG r rn rJ )r r r rl rT 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 )rR weakrefrefassertIsNotNoner rT r s r test_weakref_existsz!BaseLockTests.test_weakref_exists s> }}k$ SSUU#####r c | }t j | }~t j | | d S r )rR r r gccollect assertIsNoner s r test_weakref_deletedz"BaseLockTests.test_weakref_deleted sL }}k$
##%% r N)r7 r8 r9 r: rP rU rY r\ r^ rb rf rp ry r r r r r r( r r rL rL q s / / /
1 1 1$ : , , ,6$ $ $
! ! ! ! !r rL c : e Zd ZdZd Zd Zd Zed ZdS ) LockTestszn
Tests for non-recursive, weak locks
(which can be acquired and released from different threads).
c : | 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 r[ r )rT rO s r rl z#LockTests.test_reacquire.<locals>.f sG LLNNN LL LLNNN LL r r( rm )rR r r) r rP ra r rl rT rO 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 )ra rt s r rl z*LockTests.test_different_thread.<locals>.f' LLNNNNNr rm )rR r[ r ra r s @r test_different_threadz LockTests.test_different_thread# s }}
1a[[ s A
AAc p | }| | | d | | | | | d d S )Nr r F)blocking)rR r[ rn ra lockedre rS 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 rs rt s r use_lockz/LockTests.test_at_fork_reinit.<locals>.use_lock: s"
LLNNN LLNNNNNr )rR _at_fork_reinitr[ )r r rT lock2s r test_at_fork_reinitz LockTests.test_at_fork_reinit8 s~ }}
r N) r7 r8 r9 r: r r r
requires_forkr r( r r r r
sf & & &( 6 6 6 ] r r c 6 e Zd ZdZd Zd Zd Zd Zd Zd Z dS )
RLockTestsz$
Tests for recursive locks.
c | }| | | | | | d S r r` rS s r r zRLockTests.test_reacquireP sa }} r c | }| t |j | | | | | | | t |j d S r )rR r RuntimeErrorra r[ rS s r test_release_unacquiredz"RLockTests.test_release_unacquiredY s }} , 555 , 55555r c | }| t |j | | | | | | | t |j d S r )rR r r
_release_saver[ ra rS 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 rm r c d d d d S )Nr )r[ r rP ra )rT rO r s r rl z*RLockTests.test_recursion_count.<locals>.f s[ LLNNN LL OOE1 % % % LLNNN LL r r( )
rR rN _recursion_countr[ ra r r) r rP 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 )r[ rt s r rl z+RLockTests.test_different_thread.<locals>.f r r rm T)rR r r r ra r6 )r rl rx rT 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_ownedrj s r rl z$RLockTests.test__is_owned.<locals>.f s% MM$..** + + + + +r rm r )rR rn r r[ re r ra ro 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 r L sy
6
6
6
<
<
<!9 !9 !9F
"
"
"+ + + + +r r c L e Zd ZdZd Zd Zd Zd Zd Ze d Z
d Z d S )
EventTestsz"
Tests for Event objects.
c T | }| | | | | | | | | | | | | | d S r ) eventtypern is_setsetre 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 )Nrv c d S r )r wait)r results1results2s r rl z#EventTests._check_notify.<locals>.f s= OOCHHJJ ' ' ' OOCHHJJ ' ' ' ' 'r r T)r r
rN r, r )r r rw rl 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 )Nrv c d t j } d }t j } ||| z
f d S )Ng r )r r r r )r rr r r r s r rl z"EventTests.test_timeout.<locals>.f sh OOCHHSMM * * * !!B
A !!B OOQRL ) ) ) ) )r Fr T)r r rN rn rJ r re )r rw rl 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 rl z(EventTests.test_set_and_clear.<locals>.f s* NN5::g&:;; < < < < <r rv T)r r r
r r rN )r rl rw 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 rd )r _condrn r[ 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 rW rX r r s r rY zEventTests.test_repr s^ nn c$@AAA c$>?????r N) r7 r8 r9 r: r r r r r r r rY r( r r r r s
'
'
'/ / /( >. . .& 7 7 ]7@ @ @ @ @r r c B e Zd ZdZd Zd Zd Zd Zd Zd Z d Z
d Z d
S ) ConditionTestsz(
Tests for condition variables.
c | }| | | | t j }| | }| | | d | | | d | | d | |5 | | d d d d d S # 1 swxY w Y d S rd )condtyper[ ra r Lockrn re )r condrT 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 )r[ r r ra )rk r phase_numreadyr r s r rl 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 rv r rm )Trm r )Tr )Tr ) r r r! r" r, r rN r[ r r
ra
notify_all) r r rl rw 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 )r[ r r r ra r )r rk r r r r s r rl z&ConditionTests.test_timeout.<locals>.f si LLNNN !!BYYw''F !!B LLNNN NNBGV, - - - - -r rv )r r rN r, rJ rn )r rl rw r rk 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_forre rN )rk r r r s r rl z&ConditionTests.test_waitfor.<locals>.f s
+
+ '9'9'9'9::''' ***
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+s AAA Arm r r )r r r+ r r
r )r rl 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 rn rJ r )r rk r r r successs r rl z.ConditionTests.test_waitfor_timeout.<locals>.f s
%
%^%% '8'8'8'8# FF^%%* (((""2s+++t$$$
%
%
%
%
%
%
%
%
%
%
%
%
%
%
%
%
%
%s BBB Brm r r )r r r+ r r
r rN r, )r rl 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 r # s 2 2 2&3 3 35 5 5`T `T `TD! ! ! % % %4" " " * * * * *r r c N e Zd ZdZd Zd Zd Zd Zd Zd Z d Z
d Z d
Z d Z
d S )
BaseSemaphoreTestszB
Common tests for {bounded, unbounded} semaphore objects.
c | t | j d | t | j t j d S )N)value)r r semtypesysmaxsizer5 s r rU z#BaseSemaphoreTests.test_constructor sF *dlB??? *dlS[LIIIIIr c J | d }| | | d }| | | | d S )Nrm r )r r[ ra r sems r r z BaseSemaphoreTests.test_acquire sr ll1oo
ll1oo
r c X | }| ~d S r )r r[ 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 ri )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
rm r FT)r r[ r rN r+ ra sortedrn )r sem_valuer r# rw r r r count3count4r r r r r s @@@@@r ry 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% rm r F)r r[ r rN ra r& rn ) 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 re r[ rn ra r s r rf 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 rd ri )r r s r rl z8BaseSemaphoreTests.test_try_acquire_contended.<locals>.fx sE NN3;;u-- . . . NN3;;u-- . . . . .r rv Fr Tr )r r[ r rN r& )r rl r r s @@r rp 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 r[ re rn ra r r rJ )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 rs )r s r rl z0BaseSemaphoreTests.test_default_value.<locals>.f s! KKMMM KKMMMMMr rm )r r[ r r
rn r ra )r rl rx 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 rd )re r[ ra rn )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 re r[ ra r r )r r9 r s ` @r r z BaseSemaphoreTests.test_with s ll1oo " " " " " " " E**+++
)UI666 E**+++
r N)r7 r8 r9 r: rU r r^ ry r- rf rp r3 r6 r r( r r r r s J J J
6G 6G 6Gp- - -^, , , F F F $ $ $ r r c e Zd ZdZd Zd ZdS )SemaphoreTestsz)
Tests for unbounded semaphores.
c | d }| | | | d S Nrm )r ra r[ 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 rW rX r[ ra r s r rY zSemaphoreTests.test_repr s ll1oo c$FGGG
c$FGGG
c$FGGGGGr Nr7 r8 r9 r: r rY r( r r r; r; sA H H H H Hr r; c e Zd ZdZd Zd ZdS )BoundedSemaphoreTestsz'
Tests for bounded semaphores.
c | }| t |j | | | t |j d S r )r r r ra r[ 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 rW rX r[ r s r rY z BoundedSemaphoreTests.test_repr s^ ll1oo c$OPPP
c$OPPPPPr Nr? r( r r rA rA sA 3 3 3Q Q Q Q Qr rA c v e Zd ZdZdZdZd Zd Zd Zd Z dd Z
d
Z d Z d Z
d
Zd Zd Zd Zd Zd Zd ZdS ) BarrierTestsz$
Tests for Barrier objects.
rv g @c R | | j | j | _ d S )Nr ) barriertyperw defaultTimeoutbarrierr5 s r r@ zBarrierTests.setUp s% ''8K'LL r c 8 | j d S r )rI abortr5 s r rD zBarrierTests.tearDown s r c d t || j 5 d d d d S # 1 swxY w Y d S r )r rw r rl 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 Trm ) rI partiesrN rw r+ r r, r n_waitingrn 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 rm c L g g g fd} | dS )z;
Test that a barrier is passed in lockstep
c 4 d S r )rU )passesr r s r rl z$BarrierTests.test_barrier.<locals>.f s NN7F + + + + +r NrN )r rX rl r s `` @r test_barrierzBarrierTests.test_barrier sM b' , , , , , , , r c , | d S )zC
Test that a barrier works for 10 consecutive runs
r% )rZ r5 s r test_barrier_10z BarrierTests.test_barrier_10 s $$$r c g fd} | t t t j dS )z9
test the return value from barrier.wait
c d j } | d S r )rI r r )r r r s r rl z(BarrierTests.test_wait_return.<locals>.f
s. !!##A NN1 r N)rN rN sumr+ rw )r rl r s ` @r test_wait_returnz BarrierTests.test_wait_return sq
W s5=='9'9:::::r c g fd} j | fd} | dS )z,
Test the 'action' callback
c 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 rN r, )rI r r s r rl z#BarrierTests.test_action.<locals>.f s2 LLNNN S\\1 - - - - -r N)rG rw rN )r rc rl rI r s ` @@r test_actionzBarrierTests.test_action s{ ! ! ! ! !""46622 . . . . . . .
r c & g g fd} | t d t j dz
j j dS )zK
Test that an abort will put the barrier in a broken state
c 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)rI r rw r r r BrokenBarrierErrorrK )r r r r s r rl z"BarrierTests.test_abort.<locals>.f( s
L%%'' >>&& !!###%%%%% /
&
&
&%%%%%%
""$$$
s A A! !$B."B.-B.r rm N)rN rN r, rw re rI rR )r rl r r s ` @@r
test_abortzBarrierTests.test_abort" s
X *** X q111 +,,,,,r c @ g g g fd} | t d t j dz
t j dS )zL
Test that a 'reset' on a barrier frees the waiting threads
c 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 rm T) rI r rw r r! r" rQ resetr r ri )r r% r r results3r s r rl z"BarrierTests.test_reset.<locals>.fA s !!##ADFAI~~ /0EFF A|-$&1*== > ""$$$$*L%%''' OOD)))) 3 * * * OOD)))))*
L OOD ! ! ! ! !s ?.B. .$CCr rm N)rN rN r, rw )r rl r r rn s ` @@@r
test_resetzBarrierTests.test_reset: s " " " " " " " "$
X *** X q111 X /////r c x g g g j fd} | t d t j dz
t j dS )zF
Test that a barrier can be reset after being broken.
c 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 rh ) rI r rw r r r ri rK rm )r barrier2r r rn r s r rl z,BarrierTests.test_abort_and_reset.<locals>.fa s"
L%%'' >>&& !!###%%%% /
&
&
&%%%%%
""$$$
}}$&!)++ ""$$$ MMOOO L OOD ! ! ! ! !s A A $B+"B+*B+r rm N)rG rw rN rN r, )r rl rr r r rn s ` @@@@r test_abort_and_resetz!BarrierTests.test_abort_and_resetY s ##DF++ " " " " " " " " "*
X *** X q111 X /////r c < fd} | dS )z$
Test wait(timeout)
c j } | j dz k r t j j dz t j j j j dz d S )Nr r ) rI r rw r r
rH r r ri )r r s r rl z$BarrierTests.test_timeout.<locals>.f s} !!##ADFaK
4.2333 i : "l /1Dq1H
J
J
J
J
Jr NrY rM s ` r r zBarrierTests.test_timeout{ s= J J J J J
r c d} d| fd}t j }t |d 5 ddd n # 1 swxY w Y t j |z
} || dS )z4
Test the barrier's default timeout
r r r c R t j j d S r )r r ri r )rI r s r rl z,BarrierTests.test_default_timeout.<locals>.f s/ i : %l
,
,
,
,
,r rm N)rG r r r rF )r r rl
start_timer rI s ` @r test_default_timeoutz!BarrierTests.test_default_timeout s ""1g"66 , , , , , , ^%%
1a[[
^
* G,,,,,s AAAc | d }| | d S r= )rG 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 )rI r s r rl z!BarrierTests.test_repr.<locals>.f s LL ! ! ! ! !r r z!<\w+\.Barrier at .*: waiters=2/3>z <\w+\.Barrier at .*: broken>) rG r r rW rX r r! r" rQ r rK )r rl rw r% rI r s @@r rY zBarrierTests.test_repr s ""1%%& g (LMMM " " " " " "
1a[[ " " +G,ABB
$))E * T']] A
C
C
C
LL ! ! ! " " " " " " " " " " " " " " "
g = ? ? ?
g 8 : : : : :s A'CCCN)rm )r7 r8 r9 r: rw rH r@ rD rN rU rZ r\ r` re rj ro rs r ry r| rY r( r r rE rE s
ANM M M . . . % % %
;
;
; - - -0 0 0 0> 0 0 0D - - -
: : : : :r rE ) r: osr r r _threadr r r unittestr testr test.supportr
skipUnlesshas_fork_supportr r
objectr TestCaser< rL r r r r r r; rA rE 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