U
|
Z ±d@ ã @ s d dl Z d dlZd dlZddlmZ ddlmZ ddlmZm Z dd Z
|
dd Z d
|
d Z d d Z dd Zdd Zdd Zdd Zdd ZdS )é Né )Ú_core)Ú signal_raise)Úopen_signal_receiverÚ_signal_handlerc à s t t j¡} tt j¶}tt j tt j t ¡ I d H tt j t ¡ I d H |2 z 3 d H W }|t jkspt qxqV6 | ¡ dksttt j |2 z 3 d H W }|t jks°t q¸q6 | ¡ dksÈtW 5 Q R X t
|
t ¡ | ¡ I d H W 5 Q R X t t j¡| ks td S )Nr ) ÚsignalÚ getsignalÚSIGILLr r r Zwait_all_tasks_blockedÚAssertionErrorÚ_pending_signal_countÚpytestÚraisesÚ RuntimeErrorÚ __anext__)ÚorigÚreceiverÚsignum© r úNd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\trio/tests/test_signals.pyÚtest_open_signal_receiver s&
|
|
|
|
r c
|
à sR t t j¡} t t¡ tt jd W 5 Q R X W 5 Q R X t t j¡| ksNtd S )NiÖ )r r r r r Ú
|
ValueErrorr r
|
©r r r r Ú>test_open_signal_receiver_restore_handler_after_one_bad_signal# s
|
r c
|
à s0 t jtdd t W 5 Q R X W 5 Q R X d S )NzNo signals were provided)Úmatch)r r Ú TypeErrorr r r r r Ú$test_open_signal_receiver_empty_fail, s r c à s> t t j¡} tt jt j W 5 Q R X t t j¡| ks:td S ©N)r r r r r
|
r r r r Ú@test_open_signal_receiver_restore_handler_after_duplicate_signal2 s
|
r c à s8 dd } t t¡ tj tj| ¡I d H W 5 Q R X d S )Nc Ó s t tj W 5 Q R X d S r )r r ÚSIGINTr r r r Únaughty; s z0test_catch_signals_wrong_thread.<locals>.naughty)r r r ÚtrioZ to_threadZrun_syncÚrun)r r r r Ú test_catch_signals_wrong_thread: s r" c à sl t tj¡V ttj@} t ¡ 4 I d H }| | j ¡ | | j ¡ W 5 Q I d H R X W 5 Q R X W 5 Q R X d S r )
|
r r r ZBusyResourceErrorr r r Z open_nurseryZ
|
start_soonr )r Znurseryr r r Ú"test_open_signal_receiver_conflictC s
|
r# c à s2 t ¡ } t ¡ }|j| jdd | ¡ I d H d S )NT)Z
|
idempotent)r ÚEventr Zcurrent_trio_tokenZ run_sync_soonÚsetÚwait)ZevÚtokenr r r Ú+wait_run_sync_soon_idempotent_queue_barrierM s r( c à sè t tjtjÐ} z¬tt tj¡ d }tdD ]n}ttj ttj t I d H |d krj| ¡ I d H }q.| ¡ I d H }|tjtjfkst
|
||kst
|
|}q.| ¡ dkrº| ¡ I d H qW n dd l }| ¡ Y nX W 5 Q R X d S )Né
|
r )r r r ÚSIGFPEÚprintr Úranger r( r r
|
r Ú tracebackÚ print_exc)r ÚpreviousÚ_Úgotr- r r r Ú'test_open_signal_receiver_no_starvationT s&
|
|
r2 c s¦ t fdd} td ttjtjh| @ ttjtj}ttj ttj W 5 Q R X t I d H W 5 Q R X tjtjhkst
|
¡ td ttjtjh| P ttjtj6}ttj ttj t I d H | ¡ dksêt W 5 Q R X W 5 Q R X tjtjhkst
|
¡ td ttjhtj 2 ttj}ttj W 5 Q R X t I d H W 5 Q R X td ttjhtj D ttj.}ttj t I d H | ¡ dksºt W 5 Q R X W 5 Q R X dd }ttjtjh|´ t t¡R}ttjtj8}ttj ttj t I d H | ¡ dks8t W 5 Q R X W 5 Q R X |j}|jd h}t|jtspt | |jjd ¡ |tjtjhkst W 5 Q R X d S )
|
Nc s | ¡ d S r )Úadd)ZsignoÚframe©Zdelivered_directlyr r Údirect_handlerv s zAtest_catch_signals_race_condition_on_exit.<locals>.direct_handleré r é é c S s t | d S r )r )r r0 r r r Ú raise_handler£ s z@test_catch_signals_race_condition_on_exit.<locals>.raise_handlerr )r% r+ r r r r* r r r( r
|
Úclearr ÚSIG_IGNr r r ÚvalueÚargsÚ
|
isinstanceÚ __context__r3 )r6 r r: ÚexcinfoÚexcZsignumsr r5 r Ú)test_catch_signals_race_condition_on_exits sV
|
|
|
$
|
&
|
|
& rC )r r r Ú r Z_utilr Z_signalsr r r r r r r" r# r( r2 rC r r r r Ú<module> s
|
|
