python (3.12.0)
Browse
Usage
Versions
Αe( " d dl Z d dlZd dlZd dlZd dlmZ d dlZd dlZej dd dk( r e j dej z ej Z ej Zej j dk( xr ej j" dk( Zd Zd Zd
Z ej, e j. eed d G d
de j2 Zd Ze dk( r e j: yy) 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.12.0/bootstrap/lib/python3.12/test/test_threadsignals.pyregisterSignalsr sK == 2D == 2D == 2D t c h t | dxx dz
cc< t j t | d< y )Ntripped
tripped_by)signal_blackboardthread get_ident)sigframes r handle_signalsr s0 c9%*%+1+;+;+=c<(r c t j t t j t j t t j
t j y r )oskill process_pidr r
r
signalled_allrelease r r send_signalsr' " s2 GGK (GGK (r alarmztest requires signal.alarmc v e Zd Zd Zd Zd Z ej ed ej e j j d xr e j j d ej e j j d d d Z ej ed ej e j j d xr e j j d ej e j j d d d
Zd Zd Zd
Zd Zy)
ThreadSignalsc t j 5 t j | j t j d d d t
t j d dk( s t
t j d dk( r? t
j d t
j t
j d | j t
t j d d | j t
t j d t j | j t
t j d d | j t
t j d t j t j y # 1 sw Y dxY w# t
j d w xY w)Nr r r r )r wait_threads_exitr$ acquirespawnSignallingThreadr r r
r r( pause assertEqualr r r% selfs r test_signalszThreadSignals.test_signals, sI
/
/
1 $
! ! # & & ( ! ! # $ V^^ ,Y 71 < / :a?
Q Q +FNN;IFJ +FNN;LI!++- / +FNN;IFJ +FNN;LI!++- / ; $ $* Qs 9F0)F= 0F:=Gc 8 t j t d y )Nr& )r start_new_threadr' r1 s r r. z#ThreadSignals.spawnSignallingThreadL s b1r 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 }|j t j d t j }| j t |j
d t j |z
}| j |d t j d t j t j | y # 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 --0D0DE 3'')D LLN LLO !B / q I !B&B
OOB $ LLO MM&..' 2
LLO MM&..' 2s BD ;D=c ~ t j t j | j } t j fd}t j 5 t j |d j d r8j t j d j d r8t j d t j }| j t j d t j |z
}| j! |d d d d t j d
t j t j | y # 1 sw Y CxY w# t j d
t j t j | w xY w) Nc & j y 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+ --0D0DE 3LLNE
"335
)'' b9mmUm3MMOJJt$ mmUm3 Q^^%!!"3U]]A!N^^%*C(
)
LLO MM&..' 2
)
)
LLO MM&..' 2s+ -F A E5?A4E53F 5E>:F ;F<c d _ fd}t j t j | } fd}t j 5 t j |d j d r8j t j d j d r8j } j j j | d d d t j t j | y # 1 sw Y .xY w# t j t j | w xY w)NFc d_ y )NT) sig_recvd)r r r2 s r
my_handlerz9ThreadSignals.acquire_retries_on_intr.<locals>.my_handler s
!DNr c j t j d t j t
t j t j d j y )N ?) r- rA rR r! r" r# r r
r% )rF s r rM z;ThreadSignals.acquire_retries_on_intr.<locals>.other_thread sC
3 V^^4
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 " mmFNNJ? 7
"335
('' b9llEl2LLNJJt$ llEl2 /'
(
MM&..+ 6
(
(
MM&..+ 6s* D#
A D.<D*D# D D# #&E c J | j t j y r )r] r r@ r1 s r !test_lock_acquire_retries_on_intrz/ThreadSignals.test_lock_acquire_retries_on_intr s $$V%9%9%;<r c J | j t j y r )r] r rQ r1 s r "test_rlock_acquire_retries_on_intrz0ThreadSignals.test_rlock_acquire_retries_on_intr s $$V\\^4r c P d _ d _ d _ t j j t j j fd}t
j t j | } fd}fd}t j 5 t j |d | j j j j z
d j j j z
d j j d d d d t
j t j | y # 1 sw Y .xY w# t
j t j | w xY w)Nr c 0 xj dz
c_ y )Nr )
sigs_recvd)signumr r2 s r rW z@ThreadSignals.test_interrupted_timed_acquire.<locals>.my_handler s OOq Or c t j _ j d t j _ y )NrY r= )rA rB startr- end)rF r2 s r
timed_acquirezCThreadSignals.test_interrupted_timed_acquire.<locals>.timed_acquire s- !^^ -
S ) >>+r c t d D ]? } t j d t j t
t j A j y )N( g{Gz?) rangerA rR r! r" r# r r
r% )_dones r r' zBThreadSignals.test_interrupted_timed_acquire.<locals>.send_signals s? r 9AJJt$GGK 89 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*
##% ##% ! mmFNNJ? 7
,
"335
7 '' b9 4:: 5s;""488djj#8#> ""4??A6
7
MM&..+ 6
7
7
MM&..+ 6s% E? *B E3E? 3E<8E? ?&F%N)__name__
__module__ __qualname__r3 r. r8 unittestskipIfUSING_PTHREAD_CONDsysplatform
startswith thread_infoversionrI rS r] r_ ra rp r& r r r* r* ( sC @2 X__'FHX__S\\,,W5 1 000#$
X__S\\,,Y7<>3> $H3, X__'FHX__S\\,,W5 1 000#$
X__S\\,,Y7<>3> $H3: 7@=5,7r r* c t j dddt j dddt j dddiat t t t } t j t
g| y )Nr )r r ) r r
r r r r r rt addModuleCleanup)oldsigss r setUpModuler sZ !..q+K ..q+K ..q+KN nnnMG o88r __main__) 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 <
) LL!
(
5 D
EEbiik "f""$
oo**i7 ? //..,> >
-,,.WVW-/KL7H%% 7 M /7D9 zHMMO r