U
|
Z ±d ã @ s\ d dl mZmZ d dlmZ d dlmZ dd Zdd Zdd Z d
|
d Z
|
d d Z dd Z dS )é )ÚGLOBAL_RUN_CONTEXTÚ_NO_SEND)Ú LOCALS_KEY_KI_PROTECTION_ENABLED)Ú
|
Instrumentc C s: dt t< ztjj ¡ W S tk
|
r4 tdY nX d S ©NTz!must be called from async context)Úlocalsr r ÚrunnerÚ
|
io_managerÚcurrent_kqueueÚAttributeErrorÚ RuntimeError© r r úVd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\trio/_core/_generated_io_kqueue.pyr
|
s
|
|
r
|
c C s> dt t< ztjj | |¡W S tk
|
r8 tdY nX d S r )r r r r r Úmonitor_keventr r )ÚidentÚfilterr r r r s
|
|
r c à sF dt t< ztjj | ||¡I d H W S tk
|
r@ tdY nX d S r )r r r r r Ú wait_keventr r )r r Z
|
abort_funcr r r r s
|
|
r c à sB dt t< ztjj | ¡I d H W S tk
|
r< tdY nX d S r )r r r r r Ú wait_readabler r ©Úfdr r r r # s
|
|
r c à sB dt t< ztjj | ¡I d H W S tk
|
r< tdY nX d S r )r r r r r Ú wait_writabler r r r r r r + s
|
|
r c C s< dt t< ztjj | ¡W S tk
|
r6 tdY nX d S r )r r r r r Únotify_closingr r r r r r r 3 s
|
|
r N) Z_runr r Z_kir Z_instrumentationr r
|
r r r r r r r r r Ú<module> s
|
