Ë
|
ê^iG ã ó¶ d dl mZ d dlZd dlZd dlmZ ddgZ d d dZ d d dZddZ d d d a
|
ddd
|
Z ddd Z y)é )Ú annotationsN)ÚpartialÚ wait_for_readÚwait_for_writec óê |s |s t d« g }g }|r|j | « |r|j | « t t j |||« } ||« \ }}} t |xs |xs | « S )Nú2must specify at least one of read=True, write=True)Ú RuntimeErrorÚappendr ÚselectÚbool)
|
ÚsockÚreadÚwriteÚtimeoutÚrcheckÚwcheckÚfnÚrreadyÚwreadyÚxreadys
|
õd H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\urllib3/util/wait.pyÚselect_wait_for_socketr ! sx ñ ÜÐOÓPÐPØ FØ FÙ Ø dÔÙ Ø dÔô
|
¨°Ó 7BÙ [ÑFFFÜ Ò*&Ò* FÓ +Ð+ó c óô |s |s t d« d}|r|t j z }|r|t j z }t j « j | |« dfd }t ||« « S )Nr r c ó4 | | dz } j | « S )Niè )Úpoll)ÚtÚpoll_objs r Údo_pollz%poll_wait_for_socket.<locals>.do_pollJ s ø Ø =Ø IAØ}}QÓ Ð r )r ú float | NoneÚreturnzlist[tuple[int, int]])r r ÚPOLLINÚPOLLOUTr Úregisterr )r r r r Úmaskr r s @r Úpoll_wait_for_socketr& 9 so ø ñ ÜÐOÓPÐPØ DÙ Ø Ñ Ù Ø Ñ Ü{{}HØ ×ÑdDÔ!õ ô
|
Ó Ó !Ð!r c óz t j « } | j d« y# t t f$ r Y yw xY w)Nr TF)r r ÚAttributeErrorÚOSError)r s r Ú_have_working_pollr* R s< ðÜ;;=Ø aÔð øô GÐ $ò Ùðús %( ¨:¹:c ól t « rt ant t d« rt
|
at | |||« S )Nr )r* r& Úwait_for_socketÚhasattrr r )r r r r s r r, r, _ s/ ô ÔÜ.Ü Ô "Ü0Ü 4 u¨gÓ 6Ð6r c ó t | d|¬« S )zWaits for reading to be available on a given socket.
|
Returns True if the socket is readable, or False if the timeout expired.
|
T)r r ©r, ©r r s r r r q s ô 4 d°GÔ <Ð<r c ó t | d|¬« S )zWaits for writing to be available on a given socket.
|
Returns True if the socket is readable, or False if the timeout expired.
|
T)r r r/ r0 s r r r x s ô 4 t°WÔ =Ð=r )FFN)
|
r ú socket.socketr r r r r r r! r )r! r )N)r r2 r r r! r ) Ú
|
__future__r r ÚsocketÚ functoolsr Ú__all__r r& r* r, r r © r r ú<module>r8 så ðÝ "ã Û Ý à Ð ,Ð
|
-ð8 ØØ ð ,Ø
|
ð,à
|
ð,ð ð,ð ð ,ð
|
|
ó ,ð4 ØØ ð "Ø
|
ð"à
|
ð"ð ð"ð ð "ð
|
|
ó "ó2
|
ð ØØ ð 7Ø
|
ð7à
|
ð7ð ð7ð ð 7ð
|
|
ó 7ô$=õ>r
|
