python (3.11.7)
Browse
Usage
Versions
e( d Z ddlZddlZddlZddlZddlmZ ddlZddl Z ej
dd dk r ej dej
z ej Z
ej Zej j dk oej j dk Zd Zd
Zd Z ej ej eed d
G d dej Zd Z e dk r ej dS dS )z6PyUnit testing that threads honor our signal semantics N)threading_helper winzCan't test signal on %spthreadz
mutex+condc t j t j | }t j t j | }t j t j | }|||fS N)signalSIGUSR1SIGUSR2SIGALRM)for_usr1for_usr2for_alrmusr1usr2alrms K/BuggyBox/python/3.11.7/bootstrap/lib/python3.11/test/test_threadsignals.pyregisterSignalsr sH = 2 2D = 2 2D = 2 2D t c ~ t | dxx dz
cc< t j t | d< d S )Ntripped
tripped_by)signal_blackboardthread get_ident)sigframes r handle_signalsr sB c9%%%*%%%+1+;+=+=c<(((r c t j t t j t j t t j t d S r )oskill process_pidr r
r
signalled_allrelease r r send_signalsr' " sB GK (((GK (((r alarmztest requires signal.alarmc L e Zd Zd Zd Zd Z ej ed ej e j
d o e j j
d ej e j
d d d Z ej ed ej e j
d o e j j
d ej e j
d d d
Zd Zd Zd
Zd ZdS )
ThreadSignalsc t j 5 t | t d d d n # 1 swxY w Y t
t j d dk s!t
t j d dk rV t
j d t
j
t
j d n# t
j d w xY w| t
t j d d | t
t j d t j
| t
t j d d | t
t j d t j
t d S )Nr r r r )r wait_threads_exitr$ acquirespawnSignallingThreadr r r
r r( pause assertEqualr r r% selfs r test_signalszThreadSignals.test_signals, s
/
1
1 $ $
! ! # # # & & ( ( ( ! ! # # # $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ V^ ,Y 71 < < / :a??
Q Q Q +FN;IFJJJ +FN;LI!+-- / / / +FN;IFJJJ +FN;LI!+-- / / / s AA''A+.A+5'C1 1Dc : t j t d d S )Nr& )r start_new_threadr' r1 s r r. z#ThreadSignals.spawnSignallingThreadL s b11111r c t r )KeyboardInterrupt)r2 r r s r alarm_interruptz ThreadSignals.alarm_interruptO s r z/POSIX condition variables cannot be interruptedlinuxzBIssue 34004: musl does not allow interruption of locks by signals.openbsdz%lock cannot be interrupted on OpenBSDc ^ t j t j | j } t j }| t j d t j }| t |j d t j |z
}| |d t j d t j t j | d S # t j d t j t j | w xY w)Nr timeout @r ) r r r8 r
allocate_lockr- r( time monotonic assertRaisesr7
assertLess)r2 oldalrmlockt1dts r test_lock_acquire_interruptionz,ThreadSignals.test_lock_acquire_interruptionR s -0DEE 3'))D LLNNN LOOO !!B / q I I I !!B&B
OOB $ $ $ LOOO M&.' 2 2 2 2 2
LOOO M&.' 2 2 2 2s B C7 75D,c j t j t j | j } t j fd}t j 5 t j |d d r> t j d d >t j d t j
}| t j d t j
|z
}| |d d d d n # 1 swxY w Y t j d
t j t j | d S # t j d
t j t j | w xY w) Nc 0 d S r )r- )rlocks r other_threadzCThreadSignals.test_rlock_acquire_interruption.<locals>.other_thread s
r r& Fblocking{Gz?r r< r= r? r )r r r8 r RLockr r, r5 r- r% rA sleepr( rB rC r7 rD )r2 rE rM rG rH rL s @r test_rlock_acquire_interruptionz-ThreadSignals.test_rlock_acquire_interruptionq s -0DEE 3LNNE
"355
)
)' b999mmUm33 %MMOOOJt$$$ mmUm33 % Q^%%!!"3U]A!NNN^%%*C(((
)
)
)
)
)
)
)
)
)
)
)
)
)
)
)
LOOO M&.' 2 2 2 2 2
LOOO M&.' 2 2 2 2s0 +E= C D=1 E= =EE= EE= =5F2c d _ fd}t j t j | } fd}t j 5 t j |d d r> t j
d d > } j | d d d n # 1 swxY w Y t j t j | d S # t j t j | w xY w)NFc d_ d S )NT) sig_recvd)r r r2 s r
my_handlerz9ThreadSignals.acquire_retries_on_intr.<locals>.my_handler s !DNNNr c t j d t j t
t j t j d d S )N ?) r- rA rR r! r" r# r r
r% )rF s r rM z;ThreadSignals.acquire_retries_on_intr.<locals>.other_thread sU
3 V^444
3 r r& rN rP ) rV r r
r r, r r5 r- r% rA rR
assertTrue)r2 rF rW old_handlerrM results `` r acquire_retries_on_intrz%ThreadSignals.acquire_retries_on_intr s " " " " " mFNJ?? 7
"355
(
(' b999llEl22 %LLNNNJt$$$ llEl22 % ///'''
(
(
(
(
(
(
(
(
(
(
(
(
(
(
(
M&.+ 6 6 6 6 6FM&.+ 6 6 6 6s0 D, B-D 4 D, DD, DD, ,!E
c R | t j d S r )r] r r@ r1 s r !test_lock_acquire_retries_on_intrz/ThreadSignals.test_lock_acquire_retries_on_intr s% $$V%9%;%;<<<<<r c R | t j d S r )r] r rQ r1 s r "test_rlock_acquire_retries_on_intrz0ThreadSignals.test_rlock_acquire_retries_on_intr s" $$V\^^44444r c 6 d _ d _ d _ t j t j fd}t
j t j | } fd}fd}t j 5 t j
|d | j j z
d j j z
d j d d d d n # 1 swxY w Y t
j t j | d S # t
j t j | w xY w)Nr c ( xj dz
c_ d S )Nr )
sigs_recvd)signumr r2 s r rW z@ThreadSignals.test_interrupted_timed_acquire.<locals>.my_handler s OOq OOOOr c t j _ d t j _ d S )NrY r= )rA rB startr- end)rF r2 s r
timed_acquirezCThreadSignals.test_interrupted_timed_acquire.<locals>.timed_acquire s9 !^ - -
S ))) >++r c t d D ]:} t j d t j t
t j ; d S )N( g{Gz?) rangerA rR r! r" r# r r
r% )_dones r r' zBThreadSignals.test_interrupted_timed_acquire.<locals>.send_signals sP r 9 9AJt$$$GK 8888 r r& g @g333333?)
rg rh rd r r@ r- r r
r r, r5 rD
assertGreater)r2 rW r[ ri r' rn rF s ` @@r test_interrupted_timed_acquirez,ThreadSignals.test_interrupted_timed_acquire s
#%% #%% ! ! ! ! ! mFNJ?? 7
,
,
,
,
,
,
"355
7
7 ' b999
4: 5s;;;""48dj#8#>>> ""4?A666
7
7
7
7
7
7
7
7
7
7
7
7
7
7
7
M&.+ 6 6 6 6 6FM&.+ 6 6 6 6s1 E7 *BE ? E7 EE7 EE7 7!FN)__name__
__module__ __qualname__r3 r. r8 unittestskipIfUSING_PTHREAD_CONDsysplatform
startswith thread_infoversionrI rS r] r_ ra rp r& r r r* r* ( s @2 2 2 X_'FH HX_S\,,W55 1 00#$ $
X_S\,,Y77<> >3 3> > $ $H H3, X_'FH HX_S\,,W55 1 00#$ $
X_S\,,Y77<> >3 3> > $ $H H3: 7 7 7@= = =5 5 5,7 ,7 ,7 ,7 ,7r r* c t j dddt j dddt j dddiat t t t } t j t
g| R d S )Nr )r r ) r r
r r r r r rt addModuleCleanup)oldsigss r setUpModuler sl !.q+K+K .q+K+K .q+K+KN nnnMMG o8888888r __main__) __doc__rt r r! rw test.supportr _threadr rA rx SkipTestgetpidr# r@ r$ rz namerF rv r r r' requires_working_threading
skipUnlesshasattrTestCaser* r rq mainr& r r <module>r s < <
) ) ) ) ) ) L!
(
5 D
E
EEbikk "f"$$
o*i7 ? /.,> > > >
-,..WWVW--/KLL7 7 7 7 7H% 7 7 ML /.7D9 9 9 zHMOOOOO r