B
‡Ž€Æ›Õ0œã @ s– d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl
Z
ddl m Z ddl m
Z
ddl mZ ddl mZ ddl mZ ddl mZ dd l mZ dd
l mZ dd l mZ dd lmZ d
Zejdkræedƒ‚dd„ ZG dd„ dejƒZ G dd„ dej ƒZ G dd„ dej ej ƒZ!G dd„ de
j"ƒZ#G dd„ dƒZ$G d d „ d e$ƒZ%G d d „ d e%ƒZ&G d d!„ d!e%ƒZ'G d"d#„ d#ej(ƒZ)e Z*e)Z+dS )$é Né )Ú base_events)Úbase_subprocess)Ú constants)Ú
coroutines)Úevents)Úfutures)Úselector_events)Útasks)Ú
transports)Úlogger)ÚSelectorEventLoopÚAbstractChildWatcherÚSafeChildWatcherÚFastChildWatcherÚDefaultEventLoopPolicyÚwin32z+Signals are not really supported on Windowsc C s d S )N© )ÚsignumÚframer r ú8/opt/alt/python37/lib64/python3.7/asyncio/unix_events.pyÚ_sighandler_noop' s r c sÆ e Zd Zd(‡ fdd„ Z‡ fdd„Zdd„ Zdd „ Zd
d „ Zd d
„ Zdd„ Z d)dd„Z
d*dd„Z d+dd„Z dd„ Z
d,dddddœdd„Zd-ddddd d œd d „Zd d!„ Zd"d#„ Zd$d%„ Zd&d'„ Z‡ ZS ).Ú_UnixSelectorEventLoopNc s t ƒ |¡ i | _d S )N)ÚsuperÚ__init__Ú_signal_handlers)ÚselfÚselector)Ú __class__r r r 2 s z _UnixSelectorEventLoop.__init__c s^ t ƒ ¡ t ¡ s2xFt| jƒD ]}| |¡ q W n(| jrZtjd| ›dt | d | j
¡ d S )NzClosing the loop z@ on interpreter shutdown stage, skipping signal handlers removal)Úsource) r ÚcloseÚsysÚ
is_finalizingÚlistr Úremove_signal_handlerÚwarningsÚwarnÚResourceWarningÚclear)r Úsig)r r r r 6 s
z _UnixSelectorEventLoop.closec C s" x |D ]}|sq| |¡ qW d S )N)Ú_handle_signal)r Údatar r r r Ú_process_self_dataD s
z)_UnixSelectorEventLoop._process_self_datac
G sL t |¡st |¡r tdƒ‚| |¡ | ¡ yt | j ¡ ¡ W n2 t
t fk
rt } zt t
|ƒƒ‚W d d }~X Y nX t ||| d ¡}|| j|< y t |t¡ t |d¡ W nš t k
rF } zz| j|= | jsyt d¡ W n4 t
t fk
r } zt d|¡ W d d }~X Y nX |jtjkr4t d|› dƒ‚n‚ W d d }~X Y nX d S )Nz3coroutines cannot be used with add_signal_handler()Féÿÿÿÿz set_wakeup_fd(-1) failed: %szsig z cannot be caught)r Z iscoroutineZiscoroutinefunctionÚ TypeErrorÚ
_check_signalZ
_check_closedÚsignalÚ
set_wakeup_fdZ_csockÚfilenoÚ
ValueErrorÚOSErrorÚ RuntimeErrorÚstrr ZHandler r Ú siginterruptr ÚinfoÚerrnoÚEINVAL)r r) ÚcallbackÚargsÚexcÚhandleZnexcr r r Úadd_signal_handlerK s0
z)_UnixSelectorEventLoop.add_signal_handlerc C s8 | j |¡}|d krd S |jr*| |¡ n
| |¡ d S )N)r ÚgetZ
_cancelledr$ Z_add_callback_signalsafe)r r) r> r r r r* x s z%_UnixSelectorEventLoop._handle_signalc
C sä | |¡ y | j|= W n tk
r* dS X |tjkr>tj}ntj}yt ||¡ W nB tk
r– } z$|jtj kr„t
d|› dƒ‚n‚ W d d }~X Y nX | jsàyt d¡ W n2 t tfk
rÞ } zt
d|¡ W d d }~X Y nX dS )NFzsig z cannot be caughtr- z set_wakeup_fd(-1) failed: %sT)r/ r ÚKeyErrorr0 ÚSIGINTÚdefault_int_handlerÚSIG_DFLr4 r9 r: r5 r1 r3 r r8 )r r) Zhandlerr= r r r r$ ‚ s(
z,_UnixSelectorEventLoop.remove_signal_handlerc C sL t |tƒstd|›ƒ‚d| kr.tjk sHn td|› dtj› dƒ‚d S )Nzsig must be an int, not r zsig z out of range(1, ú))Ú
isinstanceÚintr. r0 ÚNSIGr3 )r r) r r r r/ ¢ s
z$_UnixSelectorEventLoop._check_signalc C s t | ||||ƒS )N)Ú_UnixReadPipeTransport)r ÚpipeÚprotocolÚwaiterÚextrar r r Ú_make_read_pipe_transport® s z0_UnixSelectorEventLoop._make_read_pipe_transportc C s t | ||||ƒS )N)Ú_UnixWritePipeTransport)r rJ rK rL rM r r r Ú_make_write_pipe_transport² s z1_UnixSelectorEventLoop._make_write_pipe_transportc
Ë s” t ¡ ‚}
| ¡ } t| |||||||f| |dœ| —Ž} |
| ¡ | j| ¡ y| I d H W n, tk
r„ | ¡ | ¡ I d H ‚ Y nX W d Q R X | S )N)rL rM )
r Úget_child_watcherÚ
create_futureÚ_UnixSubprocessTransportÚadd_child_handlerZget_pidÚ_child_watcher_callbackÚ Exceptionr Z_wait)
r rK r< ÚshellÚstdinÚstdoutÚstderrÚbufsizerM ÚkwargsÚwatcherrL Útranspr r r Ú_make_subprocess_transport¶ s
z1_UnixSelectorEventLoop._make_subprocess_transportc C s | |j|¡ d S )N)Zcall_soon_threadsafeZ_process_exited)r ÚpidÚ
returncoder^ r r r rU Ë s z._UnixSelectorEventLoop._child_watcher_callback)ÚsslÚsockÚserver_hostnameÚssl_handshake_timeoutc à s
|r|d kr6t dƒ‚n |d k r&t dƒ‚|d k r6t dƒ‚|d k r¤|d k rNt dƒ‚t |¡}t tjtjd¡}y | d¡ | ||¡I d H W qä | ¡ ‚ Y qäX n@|d kr´t dƒ‚|j tjksÌ|j
tjkrÚt d|›ƒ‚| d¡ | j |||||d I d H \}}||fS )
Nz/you have to pass server_hostname when using sslz+server_hostname is only meaningful with sslz1ssl_handshake_timeout is only meaningful with sslz3path and sock can not be specified at the same timer Fz no path and sock were specifiedz.A UNIX Domain Stream Socket was expected, got )re ) r3 ÚosÚfspathÚsocketÚAF_UNIXÚ SOCK_STREAMÚ setblockingZ sock_connectr ÚfamilyÚtypeZ _create_connection_transport) r Úprotocol_factoryÚpathrb rc rd re Ú transportrK r r r Úcreate_unix_connectionÎ s@
z-_UnixSelectorEventLoop.create_unix_connectionéd T)rc Úbacklogrb re Ú
start_servingc
à sÊ t |tƒrtdƒ‚|d k r&|s&tdƒ‚|d k rH|d k r@tdƒ‚t |¡}t tjtj¡}|d dkrÊy t
t |¡j ¡r„t |¡ W nB t
k
rš Y n0 tk
rÈ } zt d||¡ W d d }~X Y nX y| |¡ W nl tk
r0 } z8| ¡ | jtjkr d|›d}
ttj|
ƒd ‚n‚ W d d } ~ X Y n | ¡ ‚ Y nX n<|d krZtd ƒ‚|jtjksv|jtjkr„td
|›ƒ‚| d ¡ t | |g||||¡} |rÆ| ¡ tj d| d I d H | S )
Nz*ssl argument must be an SSLContext or Nonez1ssl_handshake_timeout is only meaningful with sslz3path and sock can not be specified at the same timer )r ú z2Unable to check or remove stale UNIX socket %r: %rzAddress z is already in usez-path was not specified, and no sock specifiedz.A UNIX Domain Stream Socket was expected, got F)Úloop) rF Úboolr. r3 rf rg rh ri rj ÚstatÚS_ISSOCKÚst_modeÚremoveÚFileNotFoundErrorr4 r ÚerrorZbindr r9 Z
EADDRINUSErl rm rk r ZServerZ_start_servingr
Zsleep) r rn ro rc rs rb re rt Úerrr= ÚmsgZserverr r r Úcreate_unix_serverû sZ
z)_UnixSelectorEventLoop.create_unix_serverc
à sô y
t j W n, tk
r6 } zt d¡‚W d d }~X Y nX y | ¡ }W n2 ttjfk
rv } zt d¡‚W d d }~X Y nX yt |¡j }W n, t
k
r´ } zt d¡‚W d d }~X Y nX |r¾|n|} | sÊdS | ¡ }
| |
d ||||| d¡ |
I d H S )Nz os.sendfile() is not availableznot a regular filer )
rf ÚsendfileÚAttributeErrorr ÚSendfileNotAvailableErrorr2 ÚioÚUnsupportedOperationÚfstatÚst_sizer4 rR Ú_sock_sendfile_native_impl) r rc ÚfileÚoffsetÚcountr= r2 r~ ZfsizeÚ blocksizeÚfutr r r Ú_sock_sendfile_native> s(
z,_UnixSelectorEventLoop._sock_sendfile_nativec C s | ¡ } |d k r| |¡ | ¡ r4| |||¡ d S |rd|| }|dkrd| |||¡ | |¡ d S yt | |||¡}
W n* ttfk
rÆ |d kr¢| ||¡ |
| | j || ||||||¡
Y nH t k
rj } z†|d k r| j
t
jkrt| ƒtk rtdt
jƒ} | | _| } |dkrBt d¡}
| |||¡ | |
¡ n| |||¡ | | ¡ W d d } ~ X Y n¤ tk
r¤ } z | |||¡ | | ¡ W d d } ~ X Y njX |
dkrÊ| |||¡ | |¡ nD||
7 }||
7 }|d krð| ||¡ |
| | j || ||||||¡
d S )Nr zsocket is not connectedzos.sendfile call failed)r2 Ú
remove_writerÚ cancelledÚ _sock_sendfile_update_fileposZ
set_resultrf r ÚBlockingIOErrorÚInterruptedErrorÚ _sock_add_cancellation_callbackZ
add_writerrˆ r4 r9 ZENOTCONNrm ÚConnectionErrorÚ __cause__r rƒ Z
set_exceptionrV )r r Z
registered_fdrc r2 rŠ r‹ rŒ Ú
total_sentÚfdZsentr= Únew_excr~ r r r rˆ U s`
z1_UnixSelectorEventLoop._sock_sendfile_native_implc C s |dkrt ||t j¡ d S )Nr )rf ÚlseekÚSEEK_SET)r r2 rŠ r— r r r r‘ ™ s z4_UnixSelectorEventLoop._sock_sendfile_update_fileposc s ‡ ‡fdd„}| |¡ d S )Nc s& | ¡ r"ˆ ¡ }|dkr"ˆ |¡ d S )Nr- )r r2 r )r r˜ )r rc r r Úcbž s zB_UnixSelectorEventLoop._sock_add_cancellation_callback..cb)Zadd_done_callback)r r rc rœ r )r rc r r” s z6_UnixSelectorEventLoop._sock_add_cancellation_callback)N)NN)NN)N)N)N)Ú__name__Ú
__module__Ú __qualname__r r r, r? r* r$ r/ rN rP r_ rU rq r€ rŽ rˆ r‘ r” Ú
__classcell__r r )r r r , s2 -
*?Dr c s„ e Zd ZdZd ‡ fdd„ Zdd„ Zdd„ Zd d
„ Zd d „ Zd
d„ Z dd„ Z
dd„ Z dd„ Z dd„ Z
d dd„Zdd„ Zd d „ Z‡ ZS ) rI i Nc sÚ t ƒ |¡ || jd< || _|| _| ¡ | _|| _d| _d| _ t
| j¡j }t
|¡s„t
|¡s„t
|¡s„d | _d | _d | _tdƒ‚t
| jd¡ | j | jj| ¡ | j | jj| j| j¡ |d k rÖ| j tj|d ¡ d S )NrJ Fz)Pipe transport is for pipes/sockets only.)r r Ú_extraÚ_loopÚ_piper2 Ú_filenoÚ _protocolÚ_closingÚ_pausedrf r† rz rx ÚS_ISFIFOry ÚS_ISCHRr3 Ú set_blockingÚ call_soonÚconnection_madeÚ _add_readerÚ _read_readyr Ú _set_result_unless_cancelled)r rv rJ rK rL rM Úmode)r r r r ª s.
z _UnixReadPipeTransport.__init__c C sÀ | j jg}| jd kr | d¡ n| jr0| d¡ | d| j› ¡ t| jdd ƒ}| jd k r|d k rt || jt
j ¡}|r„| d¡ q°| d¡ n | jd k r¦| d¡ n
| d¡ d d
|¡¡S )
NÚclosedÚclosingzfd=Ú _selectorÚpollingÚidleÚopenz<{}>ú )r r r£ Úappendr¦ r¤ Úgetattrr¢ r Ú_test_selector_eventÚ selectorsZ
EVENT_READÚformatÚjoin)r r8 r r´ r r r Ú__repr__È s"
z _UnixReadPipeTransport.__repr__c
C sº yt | j| j¡}W nD ttfk
r, Y nŠ tk
rX } z| |d¡ W d d }~X Y n^X |rl| j |¡ nJ| j
¡ r‚t
d| ¡ d| _| j
| j¡ | j
| jj¡ | j
| jd ¡ d S )Nz"Fatal read error on pipe transportz%r was closed by peerT)rf Úreadr¤ Úmax_sizer’ r“ r4 Ú _fatal_errorr¥ Z
data_receivedr¢ Ú get_debugr r8 r¦ Ú_remove_readerr« Z eof_receivedÚ_call_connection_lost)r r+ r= r r r r® Ý s
z"_UnixReadPipeTransport._read_readyc C s> | j s | jrd S d| _| j | j¡ | j ¡ r:t d| ¡ d S )NTz%r pauses reading)r¦ r§ r¢ rà r¤ r r Údebug)r r r r Ú
pause_readingï s
z$_UnixReadPipeTransport.pause_readingc C sB | j s | jsd S d| _| j | j| j¡ | j ¡ r>t d| ¡ d S )NFz%r resumes reading) r¦ r§ r¢ r r¤ r® r r rÅ )r r r r Úresume_reading÷ s
z%_UnixReadPipeTransport.resume_readingc C s
|| _ d S )N)r¥ )r rK r r r Ú set_protocolÿ s z#_UnixReadPipeTransport.set_protocolc C s | j S )N)r¥ )r r r r Ú get_protocol s z#_UnixReadPipeTransport.get_protocolc C s | j S )N)r¦ )r r r r Ú
is_closing s z!_UnixReadPipeTransport.is_closingc C s | j s| d ¡ d S )N)r¦ Ú_close)r r r r r s z _UnixReadPipeTransport.closec C s. | j d k r*tjd| ›t| d | j ¡ d S )Nzunclosed transport )r )r£ r% r& r' r )r r r r Ú__del__ s
z _UnixReadPipeTransport.__del__ú Fatal error on pipe transportc C sZ t |tƒr4|jtjkr4| j ¡ rLtjd| |dd n| j ||| | j dœ¡ |
|¡ d S )Nz%r: %sT)Úexc_info)ÚmessageÚ exceptionrp rK ) rF r4 r9 ZEIOr¢ r r rÅ Úcall_exception_handlerr¥ rË )r r= rÏ r r r rÁ s
z#_UnixReadPipeTransport._fatal_errorc C s( d| _ | j | j¡ | j | j|¡ d S )NT)r¦ r¢ rà r¤ r« rÄ )r r= r r r rË s z _UnixReadPipeTransport._closec C s4 z| j |¡ W d | j ¡ d | _d | _ d | _X d S )N)r¥ Úconnection_lostr£ r r¢ )r r= r r r rÄ % s
z,_UnixReadPipeTransport._call_connection_lost)NN)rÍ )r rž rŸ rÀ r r¾ r® rÆ rÇ rÈ rÉ rÊ r rÌ rÁ rË rÄ r r r )r r rI ¦ s
rI c s¢ e Zd Zd%‡ fdd„ Zdd„ Zdd„ Zdd „ Zd
d „ Zd d
„ Zdd„ Z dd„ Z
dd„ Z dd„ Z dd„ Z
dd„ Zdd„ Zd d „ Zd&d d „Zd'd!d"„Zd#d$„ Z‡ ZS )(rO Nc
sþ t ƒ ||¡ || jd< || _| ¡ | _|| _tƒ | _d| _ d| _
t | j¡j
}t |¡}t |¡}t |¡} |s”|s”| s”d | _d | _d | _tdƒ‚t | jd¡ | j | jj| ¡ | sÈ|ràtj d¡sà| j | jj| j| j¡ |d k rú| j t j |d ¡ d S )NrJ r Fz?Pipe transport is only for pipes, sockets and character devicesZaix) r r r¡ r£ r2 r¤ r¥ Ú bytearrayÚ_bufferÚ
_conn_lostr¦ rf r† rz rx r© r¨ ry r3 rª r¢ r« r¬ r! ÚplatformÚ
startswithr r® r r¯ )
r rv rJ rK rL rM r° Zis_charZis_fifoZ is_socket)r r r r 2 s2
z _UnixWritePipeTransport.__init__c C sØ | j jg}| jd kr | d¡ n| jr0| d¡ | d| j› ¡ t| jdd ƒ}| jd k r¨|d k r¨t || jt
j ¡}|r„| d¡ n
| d¡ | ¡ }| d|› ¡ n | jd k r¾| d¡ n
| d¡ d
d
|¡¡S ) Nr± r² zfd=r³ r´ rµ zbufsize=r¶ z<{}>r· )r r r£ r¸ r¦ r¤ r¹ r¢ r rº r» Z EVENT_WRITEÚget_write_buffer_sizer¼ r½ )r r8 r r´ r[ r r r r¾ W s&
z _UnixWritePipeTransport.__repr__c C s
t | jƒS )N)ÚlenrÔ )r r r r rØ o s z-_UnixWritePipeTransport.get_write_buffer_sizec C s6 | j ¡ rt d| ¡ | jr*| tƒ ¡ n| ¡ d S )Nz%r was closed by peer)r¢ r r r8 rÔ rË ÚBrokenPipeError)r r r r r® r s
z#_UnixWritePipeTransport._read_readyc
C s t |tƒrt|ƒ}|sd S | js&| jrN| jtjkr |}d}t d|¡ Y n0X |dkrLd S | |¡}| j ¡ rnt d||¡ y| j
|¡\}}W n. t k
r° | j ¡ r¬tjd|dd Y nX |||f|žŽ d S )Néÿ z8Unknown child process pid %d, will report returncode 255r z$process %s exited with returncode %sz'Child watcher got an unexpected pid: %rT)rÎ )
rf ÚwaitpidÚWNOHANGÚChildProcessErrorr rÜ r r¢ r rÅ rö ÚpoprA )r r÷ r` r ra r; r< r r r rø Á s*
z SafeChildWatcher._do_waitpid) r rž rŸ r rð rô rT rî rù rø r r r )r r r • s r c sP e Zd Z‡ fdd„Z‡ fdd„Zdd„ Zdd„ Zd d
„ Zd d „ Zd
d„ Z ‡ Z
S )r c s$ t ƒ ¡ t ¡ | _i | _d| _d S )Nr )r r Ú threadingZLockÚ_lockÚ_zombiesÚ_forks)r )r r r r î s
zFastChildWatcher.__init__c s" | j ¡ | j ¡ tƒ ¡ d S )N)rö r( r
r r )r )r r r r ô s
zFastChildWatcher.closec C s$ | j | jd7 _| S Q R X d S )Nr )r r )r r r r rð ù s zFastChildWatcher.__enter__c C sT | j 8 | jd8 _| js"| js&d S t| jƒ}| j ¡ W d Q R X t d|¡ d S )Nr z5Caught subprocesses termination from unknown pids: %s)r r r
r6 r( r rÜ )r rñ rò ró Zcollateral_victimsr r r rô ÿ s
zFastChildWatcher.__exit__c G sl | j d krtdƒ‚| j: y| j |¡}W n" tk
rL ||f| j|< d S X W d Q R X |||f|žŽ d S )NzICannot add child handler, the child watcher does not have a loop attached)r¢ r5 r r
r rA rö )r r` r; r< ra r r r rT
s
z"FastChildWatcher.add_child_handlerc C s& y | j |= dS tk
r dS X d S )NTF)rö rA )r r` r r r rî s
z%FastChildWatcher.remove_child_handlerc C sö xðyt dt j¡\}}W n tk
r, d S X |dkr:d S | |¡}| jv y| j |¡\}}W nB tk
r¢ | j rš|| j
|< | j ¡ r˜t
d||¡ wd }Y nX | j ¡ r¼t
d||¡ W d Q R X |d krÞt
d||¡ q|||f|žŽ qW d S )Nr- r z,unknown process %s exited with returncode %sz$process %s exited with returncode %sz8Caught subprocess termination from unknown pid: %d -> %d)rf r r r r r rö r rA r r
r¢ r r rÅ rÜ )r r` r ra r; r< r r r rù ' s6
z FastChildWatcher._do_waitpid_all) r rž rŸ r r rð rô rT rî rù r r r )r r r ä s
r c sD e Zd ZeZ‡ fdd„Zdd„ Z‡ fdd„Zdd„ Zd d
„ Z ‡ Z
S ) Ú_UnixDefaultEventLoopPolicyc s t ƒ ¡ d | _d S )N)r r Ú_watcher)r )r r r r V s
z$_UnixDefaultEventLoopPolicy.__init__c C sH t j8 | jd kr:tƒ | _tt ¡ tjƒr:| j | j j
¡ W d Q R X d S )N) r r r
r rF r Úcurrent_threadÚ _MainThreadrï Ú_localr¢ )r r r r Ú
_init_watcherZ s
z)_UnixDefaultEventLoopPolicy._init_watcherc s6 t ƒ |¡ | jd k r2tt ¡ tjƒr2| j |¡ d S )N)r Úset_event_loopr
rF r r r rï )r rv )r r r r b s
z*_UnixDefaultEventLoopPolicy.set_event_loopc C s | j d kr| ¡ | j S )N)r
r )r r r r rQ p s
z-_UnixDefaultEventLoopPolicy.get_child_watcherc C s | j d k r| j ¡ || _ d S )N)r
r )r r] r r r Úset_child_watcherz s
z-_UnixDefaultEventLoopPolicy.set_child_watcher) r rž rŸ r Z
_loop_factoryr r r rQ r r r r )r r r R s
r ),r9 r„ rf r» r0 rh rx rç r! r r% Ú r r r r r r r r
r Úlogr Ú__all__rÖ Ú ImportErrorr ZBaseSelectorEventLoopr Z
ReadTransportrI Z_FlowControlMixinZWriteTransportrO ZBaseSubprocessTransportrS r rõ r r ZBaseDefaultEventLoopPolicyr r
r r r r r Ú sP
|
JF=On3