U
|
Z ±d?
|
ã @ s8 d dl Z ddlmZ dd Zdd Zdd Zd
|
d ZdS ) é Né )Ú_corec s\ t d¡ t jddddt ks(t fdd} fdd }t | ¡ t |¡ d S )
|
NÚtest1Útest2Úcatfish©ÚdefaultÚRunVarc s t t¡ ¡ W 5 Q R X d¡ ¡ dks8t ¡ dksHtjdddks\t d¡ ¡ dksvtjdddkstd S )NZ swordfishr Zeelr ZgoldfishZtuna)ÚpytestÚraisesÚ LookupErrorÚgetÚsetÚAssertionError© ©Út1Út2r úRd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\trio/_core/tests/test_local.pyÚ first_check s
|
|
z*test_runvar_smoketest.<locals>.first_checkc s2 t t¡ ¡ W 5 Q R X ¡ dks.td S )Nr )r
|
r r r r r r r r Ú second_check s z+test_runvar_smoketest.<locals>.second_check)r r Úreprr Úrun)r r r r r Útest_runvar_smoketest s
|
|
r c s@ t d¡ t jdddt d¡ fdd} t | ¡ d S )Nr r Údogfishr Ztest3c sô d¡} ¡ dkst | ¡ t t¡ d ¡ W 5 Q R X t t¡ ¡ W 5 Q R X d¡} ¡ dks|t |¡ ¡ dkstt t¡ |¡ W 5 Q R X d¡} ¡ dksÐtt t¡ |¡ W 5 Q R X d S )NZmoonfishZ
|
catdogfishr Zbasculin) r r r Úresetr
|
r Ú TypeErrorr Ú
|
ValueError)ÚtokenZtoken2Ztoken3©r r Út3r r Ú reset_check) s"
|
|
|
|
|
z*test_runvar_resetting.<locals>.reset_check©r r r )r! r r r Útest_runvar_resetting$ s
|
|
|
r# c s$ t d¡ fdd} t | ¡ d S )Nr c
|
s¬ fdd} fdd}t ¡ 4 I d H r} d¡ ¡ dksFt| | ¡ t ¡ I d H ¡ dksnt| | ¡ t ¡ I d H ¡ dkstW 5 Q I d H R X d S )Nc s d¡ ¡ dkstd S )NÚplaice)r r r r ©r r r Útask1I s
|
z3test_runvar_sync.<locals>.sync_check.<locals>.task1c s6 ¡ t t¡ ¡ W 5 Q R X d¡ d S )NÚcod)r r
|
r r r r )Útok)r r r r Útask2M s
|
z3test_runvar_sync.<locals>.sync_check.<locals>.task2r' r$ )r Z open_nurseryr r r Z
|
start_soonZwait_all_tasks_blocked)r& r) Únr% )r r Ú
|
sync_checkH s
|
|
z$test_runvar_sync.<locals>.sync_checkr" )r+ r r% r Útest_runvar_syncE s
|
r, c s t d¡ t t¡ d¡ W 5 Q R X t t¡ ¡ W 5 Q R X fdd} t | ¡}t t¡ |¡ W 5 Q R X d S )Nr Zasdfc s
|
d¡S )NÚok)r r r% r r Ú get_tokenm s z?test_accessing_runvar_outside_run_call_fails.<locals>.get_token) r r r
|
r Ú RuntimeErrorr r r r )r. r r r% r Ú,test_accessing_runvar_outside_run_call_failsd s
|
|
r0 )r
|
Ú r r r# r, r0 r r r r Ú<module> s
|
!
|
