U
e5d @ s d dl Z d dlZ d dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl
Z
d dl Z d dl Z d dl
Z
d dlZd dlZd dlZz d dlZW n ek
r dZY nX ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ dd lmZ dd
lmZ dd lm Z dd lm Z dd
lm Z ddl m Z dZ!dZ"dZ#e$edZ%dZ&e' Z(dd Z)dd Z*dd Z+d*ddZ,d+d d Z-d d Z.e$ed rd!d" Z/nd#d" Z/G d$d% d%ej0Z1G d&d' d'ej2Z3G d(d) d)ej4Z5dS ), N ) constants)
coroutines)events)
exceptions)futures) protocols)sslproto) staggered)tasks)
transports)trsock)logger)
BaseEventLoopd g ?AF_INET6iQ c C s0 | j }tt|dd tjr$t|jS t| S d S )N__self__)Z _callback
isinstancegetattrr Taskreprr str)handlecb r +/usr/lib64/python3.8/asyncio/base_events.py_format_handleJ s
r c C s( | t jkrdS | t jkr dS t| S d S )Nzz)
subprocessPIPESTDOUTr )fdr r r _format_pipeS s
r! c C sL t tdstdn4z| tjtjd W n tk
rF tdY nX d S )N SO_REUSEPORTz)reuse_port not supported by socket moduler zTreuse_port not supported by socket module, SO_REUSEPORT defined but not implemented.)hasattrsocket
ValueError
setsockopt
SOL_SOCKETr" OSErrorsockr r r _set_reuseport\ s
r+ c C s t tdsd S |dtjtjhks(| d kr,d S |tjkr>tj}n|tjkrPtj}nd S |d krbd}nXt|trz|dkrzd}n@t|tr|dkrd}n(z t |}W n t
t fk
r Y d S X |tj krtj
g}tr|tj n|g}t| tr| d} d| krd S |D ]t}zVt|| trJ|tjkrJ|||d| |||ffW S |||d| |ffW S W n tk
rz Y nX q
d S )N inet_ptonr Zidna%)r# r$ IPPROTO_TCPZ IPPROTO_UDP SOCK_STREAM
SOCK_DGRAMr bytesr int TypeErrorr% AF_UNSPECAF_INET _HAS_IPv6appendr decoder, r( ) hostportfamilytypeprotoZflowinfoZscopeidZafsafr r r _ipaddr_infog sN
rA c C s t }| D ]*}|d }||kr(g ||< || | q t| }g }|dkr|||d d |d |d d |d = |dd tjtj | D |S )Nr r c s s | ]}|d k r|V qd S Nr ).0ar r r s z(_interleave_addrinfos..)
collections OrderedDictr9 listvaluesextend itertoolschain
from_iterable zip_longest)Z addrinfosZfirst_address_family_countZaddrinfos_by_familyaddrr= Zaddrinfos_listsZ reorderedr r r _interleave_addrinfos s"
rP c C s4 | s"| }t|ttfr"d S t| d S rB ) cancelled exceptionr
SystemExitKeyboardInterruptr Z _get_loopstop)futexcr r r _run_until_complete_cb s
rX TCP_NODELAYc C s@ | j tjtjhkr<| jtjkr<| jtjkr<| tjtj d d S Nr )
r= r$ r7 r r> r1 r? r0 r& rY r) r r r _set_nodelay s
r[ c C s d S rB r r) r r r r[ s c @ sT e Zd Zdd Zdd Zdd Zdd Zd d
Zd d Zd
d Z dd Z
dd Z dS )_SendfileFallbackProtocolc C sh t |tjstd|| _| | _| | _|j | _
| | | | j
r^| jj
| _nd | _d S )Nz.transport should be _FlowControlMixin instance)r r Z_FlowControlMixinr5
_transportZ get_protocol_protoZ
is_reading_should_resume_readingZ_protocol_paused_should_resume_writing
pause_reading set_protocol_loop
create_future_write_ready_fut)selftranspr r r __init__ s
z"_SendfileFallbackProtocol.__init__c s2 | j rtd| j}|d kr$d S |I d H d S )NzConnection closed by peer)r]
is_closingConnectionErrorre )rf rV r r r drain s
z _SendfileFallbackProtocol.drainc C s t dd S )Nz?Invalid state: connection should have been established already. RuntimeError)rf transportr r r connection_made s z)_SendfileFallbackProtocol.connection_madec C s@ | j d k r0|d kr$| j td n | j | | j| d S )Nz Connection is closed by peer)re Z
set_exceptionrj r^ connection_lost)rf rW r r r rp s
z)_SendfileFallbackProtocol.connection_lostc C s | j d k rd S | jj | _ d S rB )re r] rc rd rf r r r
pause_writing s
z'_SendfileFallbackProtocol.pause_writingc C s$ | j d krd S | j d d | _ d S )NF)re
set_resultrq r r r resume_writing s
z(_SendfileFallbackProtocol.resume_writingc C s t dd S Nz'Invalid state: reading should be pausedrl )rf datar r r
data_received s z'_SendfileFallbackProtocol.data_receivedc C s t dd S ru rl rq r r r eof_received s z&_SendfileFallbackProtocol.eof_receivedc sF | j | j | jr | j | jd k r2| j | jrB| j d S rB ) r] rb r^ r_ resume_readingre cancelr` rt rq r r r restore s
z!_SendfileFallbackProtocol.restoreN) __name__
__module__ __qualname__rh rk ro rp rr rt rw rx r{ r r r r r\ s r\ c @ sx e Zd Zdd Zdd Zdd Zdd Zd d
Zd d Zd
d Z dd Z
e dd Z dd Z
dd Zdd Zdd ZdS ) Serverc C s@ || _ || _d| _g | _|| _|| _|| _|| _d| _d | _ d S )Nr F)
rc _sockets
_active_count_waiters_protocol_factory_backlog _ssl_context_ssl_handshake_timeout_serving_serving_forever_fut)rf loopsocketsprotocol_factoryZ ssl_contextbacklogssl_handshake_timeoutr r r rh s zServer.__init__c C s d| j j d| jdS )N) __class__r| r rq r r r __repr__ s zServer.__repr__c C s | j d7 _ d S rZ )r rq r r r _attach# s zServer._attachc C s. | j d8 _ | j dkr*| jd kr*| d S )Nr r )r r _wakeuprq r r r _detach' s zServer._detachc C s, | j }d | _ |D ]}| s|| qd S rB )r doners )rf waiterswaiterr r r r - s
zServer._wakeupc C sJ | j r
d S d| _ | jD ].}|| j | j| j|| j| | j| j qd S NT) r r Zlistenr rc _start_servingr r r )rf r* r r r r 4 s
zServer._start_servingc C s | j S rB )rc rq r r r get_loop> s zServer.get_loopc C s | j S rB )r rq r r r
is_servingA s zServer.is_servingc C s" | j d krdS tdd | j D S )Nr c s s | ]}t |V qd S rB )r
ZTransportSocket)rC sr r r rE H s z!Server.sockets..)r tuplerq r r r r D s
zServer.socketsc C sn | j }|d krd S d | _ |D ]}| j| q d| _| jd k rX| j sX| j d | _| jdkrj| d S )NFr ) r rc Z
_stop_servingr r r rz r r )rf r r* r r r closeJ s
z Server.closec s" | tjd| jdI d H d S )Nr r )r r sleeprc rq r r r
start_serving] s zServer.start_servingc s | j d k rtd| d| jd kr4td| d| | j | _ zLz| j I d H W n6 tjk
r z| | I d H W 5 X Y nX W 5 d | _ X d S )Nzserver z, is already being awaited on serve_forever()z
is closed)
r rm r r rc rd r ZCancelledErrorr wait_closedrq r r r
serve_foreverc s
zServer.serve_foreverc s< | j d ks| jd krd S | j }| j| |I d H d S rB )r r rc rd r9 )rf r r r r r x s
zServer.wait_closedN)r| r} r~ rh r r r r r r r propertyr r r r r r r r r r s
r c @ sP e Zd Zdd Zdd Zdd Zddd d
Zd d Zd
d ZddddddZ ddddddddddZ
dddZ dddZ ddd Z
dd d Zd d Zd!d" Zd#d$ Zd%d& Zd'd( Zd)d* Zd+d, Zd-d. Zd/d0 Zd1d2 Zd3d4 Zd5d6 Zej fd7d8Z d9d: Z d;d< Z dd=d>d?Z dd=d@dAZ!dd=dBdCZ"dDdE Z#dFdG Z$dHdI Z%dd=dJdKZ&dLdM Z'dNdO Z(dPdQ Z)dRdRdRdRdSdTdUZ*ddVdWZ+dddXdYdZZ,d[d\ Z-d]d^ Z.d_d` Z/ddadbZ0dddRdRdRdddddddc
dddeZ1ddfdgZ2dddXdhdiZ3djdk Z4dldm Z5ddddndodpZ6ddRdRdRe7ddddqdrdsZ8dRe9j:dRdRdSdtduZ;dvdw Zddxddddddy dzd{Z?ddd|d}d~Z@dd ZAdd ZBdd ZCeDjEeDjEeDjEdddRdddd ddZFeDjEeDjEeDjEdddRdddd ddZGdd ZHdd ZIdd ZJdd ZKdd ZLdd ZMdd ZNdd ZOdd ZPdd ZQdd ZRdS )r c C s d| _ d| _d| _t | _g | _d | _d| _d | _ t
dj | _
d | _| t d| _d | _d | _d| _d | _t | _d| _d S )Nr F monotonicg?)_timer_cancelled_count_closed _stoppingrF deque_ready
_scheduled_default_executorZ
_internal_fds
_thread_idtimeget_clock_infoZ
resolution_clock_resolution_exception_handler set_debugr Z_is_debug_modeslow_callback_duration_current_handle
_task_factory"_coroutine_origin_tracking_enabled&_coroutine_origin_tracking_saved_depthweakrefZWeakSet
_asyncgens_asyncgens_shutdown_calledrq r r r rh s$
zBaseEventLoop.__init__c C s. d| j j d| d| d| d S )Nr z running=z closed=z debug=r )r r|
is_running is_closed get_debugrq r r r r s ,zBaseEventLoop.__repr__c C s t j| dS )Nr )r ZFuturerq r r r rd s zBaseEventLoop.create_futureN)namec C sN | | jd kr2tj|| |d}|jrJ|jd= n| | |}t|| |S )N)r r )
_check_closedr r r _source_tracebackZ_set_task_name)rf coror Ztaskr r r create_task s
zBaseEventLoop.create_taskc C s" |d k rt |std|| _d S )Nz'task factory must be a callable or None)callabler5 r )rf factoryr r r set_task_factory s
z BaseEventLoop.set_task_factoryc C s | j S rB )r rq r r r get_task_factory s z BaseEventLoop.get_task_factory)extraserverc C s t d S rB NotImplementedError)rf r* protocolr r r r r r _make_socket_transport s z$BaseEventLoop._make_socket_transportFT) server_sideserver_hostnamer r r call_connection_madec C s t d S rB r ) rf Zrawsockr
sslcontextr r r r r r r r r r _make_ssl_transport s z!BaseEventLoop._make_ssl_transportc C s t d S rB r )rf r* r addressr r r r r _make_datagram_transport s z&BaseEventLoop._make_datagram_transportc C s t d S rB r rf piper r r r r r _make_read_pipe_transport s z'BaseEventLoop._make_read_pipe_transportc C s t d S rB r r r r r _make_write_pipe_transport s z(BaseEventLoop._make_write_pipe_transportc
s t d S rB r )
rf r argsshellstdinstdoutstderrbufsizer kwargsr r r _make_subprocess_transport s z(BaseEventLoop._make_subprocess_transportc C s t d S rB r rq r r r _write_to_self s z BaseEventLoop._write_to_selfc C s t d S rB r )rf
event_listr r r _process_events s z BaseEventLoop._process_eventsc C s | j rtdd S )NzEvent loop is closed)r rm rq r r r r s zBaseEventLoop._check_closedc C s* | j | | s&| | j| d S rB )r discardr call_soon_threadsafer acloserf agenr r r _asyncgen_finalizer_hook s z&BaseEventLoop._asyncgen_finalizer_hookc C s. | j r tjd|dt| d | j| d S )Nzasynchronous generator z3 was scheduled after loop.shutdown_asyncgens() callsource)r warningswarnResourceWarningr addr r r r _asyncgen_firstiter_hook s
z&BaseEventLoop._asyncgen_firstiter_hookc s d| _ t| jsd S t| j}| j tjdd |D d| dI d H }t||D ]*\}}t|t rT|
d|||d qTd S )NTc S s g | ] }| qS r )r )rC Zagr r r
s z4BaseEventLoop.shutdown_asyncgens..)Zreturn_exceptionsr z;an error occurred during closing of asynchronous generator )messagerR Zasyncgen) r lenr rH clearr gatherzipr Exceptioncall_exception_handler)rf Z
closing_agensZresultsresultr r r r shutdown_asyncgens s"
z BaseEventLoop.shutdown_asyncgensc C s( | rtdt d k r$tdd S )Nz"This event loop is already runningz7Cannot run the event loop while another loop is running)r rm r Z_get_running_looprq r r r _check_running& s z BaseEventLoop._check_runningc C s | | | | j t | _t }tj | j
| j d z t
| | | j rLq^qLW 5 d| _ d | _t
d | d tj | X d S )N) firstiter finalizerF)r r _set_coroutine_origin_tracking_debug threading get_identr sysget_asyncgen_hooksset_asyncgen_hooksr r r r Z_set_running_loop _run_once)rf Zold_agen_hooksr r r run_forever- s$
zBaseEventLoop.run_foreverc C s | | t| }tj|| d}|r4d|_|t z|jd= |S )N call_soonr )r r r r
_call_soonr rf r r
r r r r r r s
zBaseEventLoop.call_soonc C sD t |st |r$td| dt|s@td| d|d S )Nz coroutines cannot be used with z()z"a callable object was expected by z(), got )r Z iscoroutineZiscoroutinefunctionr5 r )rf r methodr r r r s
z BaseEventLoop._check_callbackc C s. t ||| |}|jr |jd= | j| |S )Nr )r ZHandler r r9 )rf r r r
r r r r r s
zBaseEventLoop._call_soonc C s, | j d krd S t }|| j kr(tdd S )NzMNon-thread-safe operation invoked on an event loop other than the current one)r r r rm )rf Z thread_idr r r r s
zBaseEventLoop._check_threadc G sB | | jr| |d | |||}|jr6|jd= | |S )Nr r )r r r r r r r r r r r s z"BaseEventLoop.call_soon_threadsafec G sZ | | jr| |d |d kr@| j}|d kr@tj }|| _tj|j|f| | dS )Nrun_in_executorr ) r r r r
concurrentr ThreadPoolExecutorZ wrap_futureZsubmit)rf r funcr r r r r s
z BaseEventLoop.run_in_executorc C s& t |tjjs tdtd || _d S )Nz{Using the default executor that is not an instance of ThreadPoolExecutor is deprecated and will be prohibited in Python 3.9 )r r r r r r DeprecationWarningr r
r r r set_default_executor s z"BaseEventLoop.set_default_executorc C s | d|g}|r$| d| |r8| d| |rL| d| |r`| d| d|}td| | }t||||||} | | }
d| d |
d
d d | }|
| jkrt| n
t| | S )
N:zfamily=ztype=zproto=zflags=, zGet address info %szGetting address info z took g @@z.3fzms: ) r9 joinr r r r$ getaddrinfor info) rf r; r< r= r> r? flagsmsgt0addrinfodtr r r _getaddrinfo_debug s&
z BaseEventLoop._getaddrinfo_debugr r= r> r? r' c
s2 | j r| j}ntj}| d |||||||I d H S rB )r r, r$ r% r )rf r; r< r= r> r? r' Z getaddr_funcr r r r% 2 s zBaseEventLoop.getaddrinfoc s | d tj||I d H S rB )r r$ getnameinfo)rf Zsockaddrr' r r r r. < s zBaseEventLoop.getnameinfo)fallbackc
s | j r| dkrtd| |||| z| ||||I d H W S tjk
rl } z
|s\ W 5 d }~X Y nX | ||||I d H S )Nr z the socket must be non-blocking)r Z
gettimeoutr% _check_sendfile_params_sock_sendfile_nativer SendfileNotAvailableError_sock_sendfile_fallback)rf r* fileoffsetcountr/ rW r r r
sock_sendfile@ s zBaseEventLoop.sock_sendfilec s t d|dd S )Nz-syscall sendfile is not available for socket z and file {file!r} combinationr r2 rf r* r4 r5 r6 r r r r1 N s
z#BaseEventLoop._sock_sendfile_nativec
s |r| | |r t|tjntj}t|}d}zt|rNt|| |}|dkrNqt|d | }| d |j|I d H } | szq| ||d | I d H || 7 }q2|W S |dkrt|dr| || X d S )Nr seek)
r: minr Z!SENDFILE_FALLBACK_READBUFFER_SIZE bytearrayr#
memoryviewr readintoZ sock_sendall)
rf r* r4 r5 r6 blocksizebuf
total_sentviewreadr r r r3 U s,
z%BaseEventLoop._sock_sendfile_fallbackc C s dt |ddkrtd|jtjks,td|d k rbt|tsLtd||dkrbtd|t|tsztd||dk rtd|d S )Nbmodez$file should be opened in binary modez+only SOCK_STREAM type sockets are supportedz+count must be a positive integer (got {!r})r z0offset must be a non-negative integer (got {!r})) r r% r> r$ r1 r r4 r5 formatr9 r r r r0 o s2
z$BaseEventLoop._check_sendfile_paramsc s@ g }| | |\}}}}} d }
ztj|||d}
|
d |d k r|D ]r\}}}}} z|
| W qW qH tk
r } z0d| d| j }
t| j|
} | | W 5 d } ~ X Y qHX qH| | |
| I d H |
W S tk
r } z"| | |
d k r
|
W 5 d } ~ X Y n |
d k r4|
Y nX d S )Nr= r> r? Fz*error while attempting to bind on address : ) r9 r$ setblockingbindr( strerrorlowererrnopop sock_connectr )rf r Z addr_infoZlocal_addr_infosZ
my_exceptionsr= Ztype_r? _r r* ZladdrrW r( r r r
_connect_sock s:
zBaseEventLoop._connect_sock)
sslr= r? r' r*
local_addrr r happy_eyeballs_delay
interleavec
sl |
d k r|st d|
d kr0|r0|s,t d|}
| d k rD|sDt d| d k rX|
d krXd}
|d k sj|d k r|d k rzt dj||f|tj||dI d H }|std| d k r܈j| |tj||dI d H stdnd |
rt||
}g | d krH|D ]D}z |I d H }W qvW n tk
r@ Y q Y nX q n.tj fdd |D | d
I d H \}}}|d kr d d D t dkr d
nJt
d
t fdd D r҈ d
td d
dd D n.|d krt d|jtjkr t d|j||||
| dI d H \}}jrd|d}td||||| ||fS )Nz+server_hostname is only meaningful with sslz:You must set server_hostname when using ssl without a host1ssl_handshake_timeout is only meaningful with sslr 8host/port and sock can not be specified at the same timer= r> r? r' r !getaddrinfo() returned empty listc 3 s | ]}t j |V qd S rB ) functoolspartialrQ )rC r* )r laddr_infosrf r r rE s z2BaseEventLoop.create_connection..r c S s g | ]}|D ]}|q qS r r )rC subrW r r r r s z3BaseEventLoop.create_connection..r c 3 s | ]}t | kV qd S rB r rC rW )modelr r rE s zMultiple exceptions: {}r# c s s | ]}t |V qd S rB r^ r_ r r r rE
s z5host and port was not specified and no sock specified"A Stream Socket was expected, got )r r$ z %r connected to %s:%r: (%r, %r))r% _ensure_resolvedr$ r1 r( rP rQ r
Zstaggered_racer r allrF r$ r> _create_connection_transportr get_extra_infor r )rf r r; r< rR r= r? r' r* rS r r rT rU infosr* rP rn r r )r r\ r` rf r create_connection s
z BaseEventLoop.create_connectionc s | d | }| }|rHt|tr*d n|} | j||| ||||d}
n| |||}
z|I d H W n |
Y nX |
|fS )NFr r r )rI rd r boolr r r ) rf r* r rR r r r r r r rn r r r rd % s*
z*BaseEventLoop._create_connection_transportc
s | rtdt|dtjj}|tjjkr:td||tjjkrz| ||||I d H W S tj k
r } z
|sx W 5 d }~X Y nX |std||
||||I d H S )NzTransport is closingZ_sendfile_compatiblez(sendfile is not supported for transport zHfallback is disabled and native sendfile is not supported for transport ) ri rm r r Z
_SendfileModeZ UNSUPPORTEDZ
TRY_NATIVE_sendfile_nativer r2 _sendfile_fallback)rf rn r4 r5 r6 r/ rE rW r r r sendfile? s4 zBaseEventLoop.sendfilec s t dd S )Nz!sendfile syscall is not supportedr8 )rf rg r4 r5 r6 r r r rj n s z BaseEventLoop._sendfile_nativec
s |r| | |r t|dnd}t|}d}t|}z|rXt|| |}|dkrX|W bS t|d | } | d |j| I d H }
|
s|W 0S | I d H |
| d |
||
7 }q6W 5 |dkrt|dr| || | I d H X d S )Ni @ r r: ) r: r; r< r\ r# r{ r= r r> rk write) rf rg r4 r5 r6 r? r@ rA r? rB rC r r r rk r s*
z BaseEventLoop._sendfile_fallbackrh c
s t d krtdt|t js*td|t|ddsFtd|d| }tj| ||||||dd}| |
| | |j |} | |j
}
z|I d H W n. tk
r | | |
Y nX |jS )Nz"Python ssl module is not availablez@sslcontext is expected to be an instance of ssl.SSLContext, got Z_start_tls_compatibleFz
transport z is not supported by start_tls())r r )rR rm r Z
SSLContextr5 r rd r Z SSLProtocolra rb r ro ry
BaseExceptionr rz Z_app_transport) rf rn r r r r r r Z ssl_protocolZ
conmade_cbZ resume_cbr r r start_tls sB
zBaseEventLoop.start_tls)r= r? r'
reuse_address
reuse_portallow_broadcastr* c s |
d k r|
j tjkr"td|
s>s>|s>|s>|s>|s>| r~t |||||| d} ddd | D } td| d|
d d }
n ss|d krtd
||fd ff}nttd r|tj kr fD ] }|d k rt
|t st d
qڈ rx d dkrxz"t
t
jr.t W nF tk
rF Y n2 tk
rv } ztd | W 5 d }~X Y nX ||f fff}ni }d fdffD ]\}}|d k r| j||tj||| dI d H }|std|D ]:\}}}}}||f}||krd d g||< ||| |< qq fdd| D }|sHtdg }|tk rv|rftdntjdtdd |D ]\\}}\}}d }
d }
zxtj|tj|d}
|rt|
| r|
tj tj d |
d r|
| r| s| |
|I d H |}
W n^ tk
rJ } z |
d k r0|
! |"| W 5 d } ~ X Y n& |
d k rb|
! Y nX q|qz|d | } | # } | $|
| |
| } | j%r̈ rt&d | | nt'd | | z| I d H W n | ! Y nX | | fS ) Nz A UDP Socket was expected, got )rS remote_addrr= r? r' rp rq rr r# c s s$ | ] \}}|r| d | V qdS )=Nr )rC kvr r r rE s z9BaseEventLoop.create_datagram_endpoint..zKsocket modifier keyword arguments can not be used when sock is specified. ()Fr zunexpected address family)NNAF_UNIXzstring is expected)r z2Unable to check or remove stale UNIX socket %r: %rr rX rY c s8 g | ]0\}} r |d dksr,|d dks||fqS )r Nr r )rC keyZ addr_pairrS rs r r r s z:BaseEventLoop.create_datagram_endpoint..z can not get address informationz~Passing `reuse_address=True` is no longer supported, as the usage of SO_REUSEPORT in UDP poses a significant security concern.zdThe *reuse_address* parameter has been deprecated as of 3.5.10 and is scheduled for removal in 3.11.r )
stacklevelrG z@Datagram endpoint local_addr=%r remote_addr=%r created: (%r, %r)z2Datagram endpoint remote_addr=%r created: (%r, %r))(r> r$ r2 r% dictr$ itemsrI r# rx r r r5 statS_ISSOCKosst_moderemoveFileNotFoundErrorr( r errorrb _unsetr r r r+ r& r' Z SO_BROADCASTrJ rO r r9 rd r r r& r ) rf r rS rs r= r? r' rp rq rr r* ZoptsZproblemsZr_addrZaddr_pairs_inforO errZ
addr_infosidxrf ZfamrP Zpror rz r Z
local_addressZremote_addressrW r r rn r r{ r create_datagram_endpoint s$
z&BaseEventLoop.create_datagram_endpointc
s\ |d d \}}t |||||f|dd } | d k r<| gS |j||||||dI d H S d S )Nr r- )rA r% )
rf r r= r> r? r' r r; r< r& r r r rb L s z BaseEventLoop._ensure_resolvedc s8 | j ||f|tj|| dI d H }|s4td|d|S )N)r= r> r' r z getaddrinfo(z) returned empty list)rb r$ r1 r( )rf r; r< r= r' rf r r r _create_server_getaddrinfoX s z(BaseEventLoop._create_server_getaddrinfor ) r= r' r* r rR rp rq r r c s t |trtd| d k r*|d kr*td|d k s<d k r"|d k rLtd| d krhtjdkoftjdk} g }
|dkr|d g}n$t |tst |t j
j s|g}n|} fdd|D }t j
|d iI d H }ttj|}d
}z |D ]}|\}}}}}zt|||}W n8 tjk
rH jr@tjd |||d d
Y qY nX |
| | rl|tjtjd |
rzt | t r|tj krt tdr|tj tj!d z|"| W q t#k
r } z t#|j$d||j%& f d W 5 d }~X Y qX qd }W 5 |s |
D ]}| qX n4|d kr4td|j'tj(krPtd||g}
|
D ]}|)d
qZt*|
|||| }| r|+ t j,ddI d H jrt-d| |S )Nz*ssl argument must be an SSLContext or NonerV rW posixcygwinr. c s g | ]}j | d qS ))r= r' )r )rC r; r= r' r< rf r r r s
z/BaseEventLoop.create_server..r Fz:create_server() failed to create socket.socket(%r, %r, %r)Texc_info IPPROTO_IPV6z0error while attempting to bind on address %r: %sz)Neither host/port nor sock were specifiedra r r z
%r is serving).r ri r5 r% r r r platformr rF abcIterabler r setrK rL rM r r$ r r r warningr9 r& r' Z SO_REUSEADDRr+ r8 r r# r Z IPV6_V6ONLYrJ r( rM rK rL r> r1 rI r r r r& )rf r r; r< r= r' r* r rR rp rq r r r ZhostsZfsrf Z completedresr@ Zsocktyper? Z canonnameZsar r r r r
create_server` s
zBaseEventLoop.create_server)rR r c sv |j tjkrtd||d k r.|s.td| j|||dd|dI d H \}}| jrn|d}td||| ||fS )Nra rV r. T)r r r$ z%r handled: (%r, %r)) r> r$ r1 r% rd r re r r )rf r r* rR r rn r r r r connect_accepted_socket s$
z%BaseEventLoop.connect_accepted_socketc sd | }| }| |||}z|I d H W n | Y nX | jr\td| || ||fS )Nz Read pipe %r connected: (%r, %r))rd r r r r r filenorf r r r r rn r r r connect_read_pipe s z BaseEventLoop.connect_read_pipec sd | }| }| |||}z|I d H W n | Y nX | jr\td| || ||fS )Nz!Write pipe %r connected: (%r, %r))rd r r r r r r r r r r connect_write_pipe s z BaseEventLoop.connect_write_pipec C s |g}|d k r"| dt| |d k rJ|tjkrJ| dt| n8|d k rf| dt| |d k r| dt| td| d S )Nzstdin=zstdout=stderr=zstdout=zstderr= )r9 r! r r r r r$ )rf r( r r r r& r r r _log_subprocess s z BaseEventLoop._log_subprocess) r r r universal_newlinesr r encodingerrorstextc s t |ttfstd|r"td|s.td|dkr>td| rJtd| d k rZtd|
d k rjtd| }
d }| jrd | }| |||| | j|
|d
||||f| I d H }| jr|d k rtd || ||
fS ) Nzcmd must be a string universal_newlines must be Falsezshell must be Truer bufsize must be 0text must be Falseencoding must be Noneerrors must be Nonezrun shell command %rT%s: %r) r r3 r r% r r r r r& )rf r cmdr r r r r r r r r r r debug_logrn r r r subprocess_shell sB
z BaseEventLoop.subprocess_shellc s |r t d|rt d|dkr(t d| r4t d| d k rDt d|
d k rTt d|f| }| }d }| jrd|}| |||| | j||d ||||f|
I d H }| jr|d k rtd
|| ||fS ) Nr zshell must be Falser r r r r zexecute program Fr )r% r r r r r& )rf r Zprogramr r r r r r r r r r r Z
popen_argsr r rn r r r subprocess_execC s@
z BaseEventLoop.subprocess_execc C s | j S rB )r rq r r r get_exception_handlere s z#BaseEventLoop.get_exception_handlerc C s( |d k r t |s td||| _d S )Nz+A callable object or None is expected, got )r r5 r )rf Zhandlerr r r set_exception_handlerj s z#BaseEventLoop.set_exception_handlerc C s | d}|sd}| d}|d k r6t|||jf}nd}d|kr`| jd k r`| jjr`| jj|d< |g}t|D ]}|dkr|qn|| }|dkrdt|}d }|| 7 }n2|dkrdt|}d
}|| 7 }nt
|}| | d | qnt j
d ||d
d S )Nr z!Unhandled exception in event looprR FZsource_tracebackZhandle_traceback> r rR r. z+Object created at (most recent call last):
z+Handle created at (most recent call last):
rH
r )getr>
__traceback__r r sortedr$ traceback format_listrstripr r9 r r ) rf r
r rR r Z log_linesrz valuetbr r r default_exception_handler{ s<
z'BaseEventLoop.default_exception_handlerc C s | j d krVz| | W q ttfk
r2 Y q tk
rR tjddd Y qX nz| | | W n ttfk
r Y nt tk
r } zVz| d||d W n: ttfk
r Y n" tk
r tjddd Y nX W 5 d }~X Y nX d S )Nz&Exception in default exception handlerTr z$Unhandled error in exception handler)r rR r
zeException in default exception handler while handling an unexpected error in custom exception handler)r r rS rT rn r r )rf r
rW r r r r s4
z$BaseEventLoop.call_exception_handlerc C s |j r
d S | j| d S rB )
_cancelledr r9 rf r r r r
_add_callback s zBaseEventLoop._add_callbackc C s | | | d S rB )r r r r r r _add_callback_signalsafe s
z&BaseEventLoop._add_callback_signalsafec C s |j r| jd7 _d S rZ )r r r r r r _timer_handle_cancelled s z%BaseEventLoop._timer_handle_cancelledc C s t | j}|tkr`| j| tkr`g }| jD ] }|jr sb
;
Do