B
YI~d؟ @ 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
Zejdkreddd ZG dd dejZ G dd dej Z G dd dej ej Z!G dd de
j"Z#G dd dZ$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)SelectorEventLoopAbstractChildWatcherSafeChildWatcherFastChildWatcherDefaultEventLoopPolicywin32z+Signals are not really supported on Windowsc C s d S )N )signumframer r 8/opt/alt/python37/lib64/python3.7/asyncio/unix_events.py_sighandler_noop' s r c s e Zd Zd( fdd Z fddZdd Zdd Zd
d Zd d
Zdd Z d)ddZ
d*ddZ d+ddZ dd Z
d,dddddddZd-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)selfselector) __class__r r r 2 s z _UnixSelectorEventLoop.__init__c s^ t t s2xFt| jD ]}| | q W n(| jrZtjd| dt | d | j
d S )NzClosing the loop z@ on interpreter shutdown stage, skipping signal handlers removal)source) r closesys
is_finalizinglistr remove_signal_handlerwarningswarnResourceWarningclear)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|= | jsytd W n4 t
t fk
r } ztd| W d d }~X Y nX |jtjkr4t d| dn W d d }~X Y nX d S )Nz3coroutines cannot be used with add_signal_handler()Fz set_wakeup_fd(-1) failed: %szsig z cannot be caught)r Z iscoroutineZiscoroutinefunction TypeError
_check_signalZ
_check_closedsignal
set_wakeup_fdZ_csockfileno
ValueErrorOSError RuntimeErrorstrr ZHandler r siginterruptr infoerrnoEINVAL)r r) callbackargsexchandleZnexcr 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 krt
d| dn W d d }~X Y nX | jsyt 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 SIGINTdefault_int_handlerSIG_DFLr4 r9 r: r5 r1 r3 r r8 )r r) Zhandlerr= r r r r$ s(
z,_UnixSelectorEventLoop.remove_signal_handlerc C sL t |tstd|d| kr.tjk sHn td| dtj dd S )Nzsig must be an int, not r zsig z out of range(1, ))
isinstanceintr. r0 NSIGr3 )r r) r r r r/ s
z$_UnixSelectorEventLoop._check_signalc C s t | ||||S )N)_UnixReadPipeTransport)r pipeprotocolwaiterextrar 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_UnixSubprocessTransportadd_child_handlerZget_pid_child_watcher_callback Exceptionr Z_wait)
r rK r< shellstdinstdoutstderrbufsizerM kwargswatcherrL 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)sslsockserver_hostnamessl_handshake_timeoutc s
|r|d kr6t dn |d k r&t d|d k r6t d|d k r|d k rNt dt|}ttjtjd}y |d | ||I d H W q | Y qX n@|d krt d|j tjks|j
tjkrt 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 osfspathsocketAF_UNIX SOCK_STREAM setblockingZ sock_connectr familytypeZ _create_connection_transport) r protocol_factorypathrb rc rd re transportrK r r r create_unix_connection s@
z-_UnixSelectorEventLoop.create_unix_connectiond T)rc backlogrb re
start_servingc
s t |trtd|d k r&|s&td|d k rH|d k r@tdt|}ttjtj}|d dkry t
t |j rt | W nB t
k
r Y n0 tk
r } ztd|| 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|jtjkrtd
||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 statS_ISSOCKst_moderemoveFileNotFoundErrorr4 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 } ztdW d d }~X Y nX y | }W n2 ttjfk
rv } ztdW d d }~X Y nX yt |j }W n, t
k
r } ztdW d d }~X Y nX |r|n|} | sdS | }
| |
d ||||| d |
I d H S )Nz os.sendfile() is not availableznot a regular filer )
rf sendfileAttributeErrorr SendfileNotAvailableErrorr2 ioUnsupportedOperationfstatst_sizer4 rR _sock_sendfile_native_impl) r rc fileoffsetcountr= r2 r~ Zfsize blocksizefutr 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} | | _| } |dkrBtd}
| ||| ||
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 BlockingIOErrorInterruptedError _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_sentfdZsentr= new_excr~ r r r r U s`
z1_UnixSelectorEventLoop._sock_sendfile_native_implc C s |dkrt ||t j d S )Nr )rf lseekSEEK_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 ddZdd Zd d Z ZS ) rI i Nc s t | || jd< || _|| _| | _|| _d| _d| _ t
| jj }t
|st
|st
|sd | _d | _d | _tdt
| jd | j| jj| | j| jj| j| j |d k r| jtj|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_soonconnection_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 )
Nclosedclosingzfd= _selectorpollingidleopenz<{}> )r r r appendr r getattrr r _test_selector_event selectorsZ
EVENT_READformatjoin)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
rt
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:td| 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>td| 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 |tr4|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 | jj
}t|}t|}t|} |s|s| sd | _d | _d | _tdt | jd | j| jj| | s|rtjds| j| jj| j| j |d k r| jt 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 rt || 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_WRITEget_write_buffer_sizer r )r r8 r r r[ r r r r W s&
z _UnixWritePipeTransport.__repr__c C s
t | jS )N)lenr )r r r r r o s z-_UnixWritePipeTransport.get_write_buffer_sizec C s6 | j rtd| | 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 |trt|}|sd S | js&| jrN| jtjkr |}d}td| Y n0X |dkrLd S | |}| j rnt d|| y| j
|\}}W n. t k
r | j rtjd|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 waitpidWNOHANGChildProcessErrorr 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 fddZ fddZdd 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 td| 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 xyt dt j\}}W n tk
r, d S X |dkr:d S | |}| jv y| j|\}}W nB tk
r | j r|| j
|< | j rt
d|| wd }Y nX | j rt
d|| W d Q R X |d krt
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 fddZdd Z fddZdd 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 tjr:| 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 tjr2| 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