B
ú?ÂCúG;ã @ 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 dlZy d dlZW n ek
rœ dZY nX ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ dd lmZ dd
lmZ dd lm Z d Z d
Z dZ e edƒZ!dZ"e#ƒ Z$dd„ Z%dd„ Z&dd„ Z'd%dd„Z(dd„ Z)e edƒrjd d „ Z*nd d „ Z*G d d „ d ej+ƒZ,G d!d"„ d"ej-ƒZ.G d#d$„ d$ej/ƒZ0dS )&é Né )Ú constants)Ú
coroutines)Úevents)Úfutures)Ú protocols)Ússlproto)Útasks)Ú
transports)Úlogger)Ú
BaseEventLoopéd g à?ÚAF_INET6i€Q c C s0 | j }tt|dd ƒtjƒr$t|jƒS t| ƒS d S )NÚ__self__)Z _callbackÚ
isinstanceÚgetattrr ÚTaskÚreprr Ústr)ÚhandleÚcb© r ú8/opt/alt/python37/lib64/python3.7/asyncio/base_events.pyÚ_format_handleE s
r c C s( | t jkrdS | t jkr dS t| ƒS d S )Nzz)Ú
subprocessÚPIPEÚSTDOUTr )Úfdr r r Ú _format_pipeN s
r c C sL t tdƒstdƒ‚n4y| tjtjd¡ W n tk
rF tdƒ‚Y 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.)ÚhasattrÚsocketÚ
ValueErrorÚ
setsockoptÚ
SOL_SOCKETr ÚOSError)Úsockr r r Ú_set_reuseportW s
r' c C sz t tdƒsd S |dtjtjhks(| d kr,d S |tjkr>tj}n|tjkrPtj}nd S |d krbd}nVt|tƒrz|dkrzd}n>t|tƒr’|dkr’d}n&y t |ƒ}W n t
t fk
r¶ d S X |tj krÜtj
g}trâ| tj¡ n|g}t| tƒrö| d¡} d| krd S xp|D ]h}yJt || ¡ trD|tjkrD|||d| |||ffS |||d| |ffS W n tk
rn Y nX q
W d S )NÚ inet_ptonr ó Ú Zidnaú%)r r! Ú IPPROTO_TCPZ IPPROTO_UDPÚ SOCK_STREAMÚ
SOCK_DGRAMr Úbytesr ÚintÚ TypeErrorr" Ú AF_UNSPECÚAF_INETÚ _HAS_IPv6Úappendr Údecoder( r% ) ÚhostÚportÚfamilyÚtypeÚprotoZflowinfoZscopeidZafsÚafr r r Ú _ipaddr_infob sL
r= c C s: | ¡ s(| ¡ }t|tƒr(t|tƒs(d S t | ¡ ¡ d S )N)Ú cancelledÚ exceptionr Ú
BaseExceptionÚ Exceptionr Z _get_loopÚstop)ÚfutÚexcr r r Ú_run_until_complete_cb s
rE Ú TCP_NODELAYc C s@ | j tjtjhkr<| jtjkr<| jtjkr<| tjtj d¡ d S )Nr )
r9 r! r3 r r: r- r; r, r# rF )r& r r r Ú _set_nodelay¨ s rG c C s d S )Nr )r& r r r rG ® 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 |tjƒstdƒ‚|| _| ¡ | _| ¡ | _|j | _
| ¡ | | ¡ | j
r^| jj
¡ | _nd | _d S )Nz.transport should be _FlowControlMixin instance)r r
Z_FlowControlMixinr1 Ú
_transportZ get_protocolÚ_protoZ
is_readingÚ_should_resume_readingZ_protocol_pausedÚ_should_resume_writingÚ
pause_readingÚ set_protocolÚ_loopÚ
create_futureÚ_write_ready_fut)ÚselfÚtranspr 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)rI Ú
is_closingÚConnectionErrorrQ )rR rC r r r ÚdrainÁ s
z _SendfileFallbackProtocol.drainc C s t dƒ‚d S )Nz?Invalid state: connection should have been established already.)Ú RuntimeError)rR Ú 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)rQ Z
set_exceptionrV rJ Úconnection_lost)rR rD r r r r[ Í s
z)_SendfileFallbackProtocol.connection_lostc C s | j d k rd S | jj ¡ | _ d S )N)rQ rI rO rP )rR r r r Ú
pause_writingØ s
z'_SendfileFallbackProtocol.pause_writingc C s$ | j d krd S | j d¡ d | _ d S )NF)rQ Ú
set_result)rR r r r Úresume_writingÝ s
z(_SendfileFallbackProtocol.resume_writingc C s t dƒ‚d S )Nz'Invalid state: reading should be paused)rX )rR Údatar r r Ú
data_receivedã s z'_SendfileFallbackProtocol.data_receivedc C s t dƒ‚d S )Nz'Invalid state: reading should be paused)rX )rR r r r Ú eof_receivedæ s z&_SendfileFallbackProtocol.eof_receivedc à sF | j | j¡ | jr | j ¡ | jd k r2| j ¡ | jrB| j ¡ d S )N) rI rN rJ rK Úresume_readingrQ ÚcancelrL r^ )rR r r r Úrestoreé s
z!_SendfileFallbackProtocol.restoreN) Ú__name__Ú
__module__Ú __qualname__rT rW rZ r[ r\ r^ r` ra rd r r r r rH ² s rH 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)
rO Ú_socketsÚ
_active_countÚ_waitersÚ_protocol_factoryÚ_backlogÚ _ssl_contextÚ_ssl_handshake_timeoutÚ_servingÚ_serving_forever_fut)rR ÚloopÚsocketsÚprotocol_factoryZ ssl_contextÚbacklogÚssl_handshake_timeoutr r r rT ø s zServer.__init__c C s d| j j› d| j›dS )Nú)Ú __class__re rs )rR r r r Ú__repr__ s zServer.__repr__c C s | j d7 _ d S )Nr )rj )rR r r r Ú_attach s zServer._attachc C s. | j d8 _ | j dkr*| jd kr*| ¡ d S )Nr r )rj ri Ú_wakeup)rR r r r Ú_detach s zServer._detachc C s0 | j }d | _ x |D ]}| ¡ s| |¡ qW d S )N)rk Údoner] )rR ÚwaitersÚwaiterr r r r| s
zServer._wakeupc C sN | j r
d S d| _ x8| jD ].}| | j¡ | j | j|| j| | j| j¡ qW d S )NT) rp ri Zlistenrm rO Ú_start_servingrl rn ro )rR r& r r r r s
zServer._start_servingc C s | j S )N)rO )rR r r r Úget_loop# s zServer.get_loopc C s | j S )N)rp )rR r r r Ú
is_serving& s zServer.is_servingc C s | j d krg S t| j ƒS )N)ri Úlist)rR r r r rs ) s
zServer.socketsc C sr | j }|d krd S d | _ x|D ]}| j |¡ q W d| _| jd k r\| j ¡ s\| j ¡ d | _| jdkrn| ¡ d S )NFr ) ri rO Z
_stop_servingrp rq r~ rc rj r| )rR rs r& r r r Úclose/ s
z Server.closec à s" | ¡ tjd| jdI d H d S )Nr )rr )r r ÚsleeprO )rR r r r Ú
start_servingB s zServer.start_servingc à s¢ | j d k rtd| ›dƒ‚| jd kr4td| ›dƒ‚| ¡ | j ¡ | _ zLy| j I d H W n6 tjk
r z| ¡ | ¡ I d H W d ‚ X Y nX W d d | _ X d S )Nzserver z, is already being awaited on serve_forever()z
is closed)
rq rX ri r rO rP r ZCancelledErrorr… Ú wait_closed)rR r r r Ú
serve_foreverH s
zServer.serve_foreverc à s< | j d ks| jd krd S | j ¡ }| j |¡ |I d H d S )N)ri rk rO rP r5 )rR r€ r r r rˆ ] s
zServer.wait_closedN)re rf rg rT rz r{ r} r| r r‚ rƒ Úpropertyrs r… r‡ r‰ rˆ r r r r rh ö s
rh c @ s* e Zd Zdd„ Zdd„ Zdd„ Zdd„ Zd d
„ Zd d „ Zdd
d
dœdd„Z dždd
d
d
d
ddœdd„Z
dŸdd„Z d dd„Z d¡dd„Z
d¢d d „Zd d „ Zd d!„ Zd"d#„ Zd$d%„ Zd&d'„ Zd(d)„ Zd*d+„ Zd,d-„ Zd.d/„ Zd0d1„ Zd2d3„ Zd4d5„ Zd6d7„ Zd8d9„ Z d:d;„ Z d
d<œd=d>„Z d
d<œd?d@„Z d
d<œdAdB„Z dCdD„ Z!dEdF„ Z"dGdH„ Z#d
d<œdIdJ„Z$dKdL„ Z%dMdN„ Z&dOdP„ Z'dQdQdQdQdRœdSdT„Z(d£dUdV„Z)d¤ddWœdXdY„Z*dZd[„ Z+d\d]„ Z,d^d_„ Z-d¥d
dQdQdQd
d
d
d
d`œdadb„Z.d¦dcdd„Z/d§ddWœdedf„Z0dgdh„ Z1didj„ Z2dd
d
dkœdldm„Z3d¨dQdQdQe4d
d
d
dnœdodp„Z5dQe6j7dQdQdRœdqdr„Z8dsdt„ Z9d©e6j:e6j;d
dud
d
d
d
ddvœ dwdx„Zd~d„ Z?d€d„ Z@eAjBeAjBeAjBdddQd‚œdƒd„„ZCeAjBeAjBeAjBdddQd‚œd…d†„ZDd‡dˆ„ ZEd‰dŠ„ ZFd‹dŒ„ ZGddŽ„ ZHdd„ ZId‘d’„ ZJd“d”„ ZKd•d–„ ZLd—d˜„ ZMd™dš„ ZNd›dœ„ ZOd
S )ªr c C sˆ d| _ d| _d| _t ¡ | _g | _d | _d| _d | _ t
d¡j | _
d | _| t ¡ ¡ d| _d | _d | _d| _d | _t ¡ | _d| _d S )Nr FÚ monotonicgš™™™™™¹?)Ú_timer_cancelled_countÚ_closedÚ _stoppingÚ collectionsÚdequeÚ_readyÚ
_scheduledÚ_default_executorZ
_internal_fdsÚ
_thread_idÚtimeZget_clock_infoZ
resolutionÚ_clock_resolutionÚ_exception_handlerÚ set_debugr Z_is_debug_modeÚslow_callback_durationÚ_current_handleÚ
_task_factoryÚ"_coroutine_origin_tracking_enabledÚ&_coroutine_origin_tracking_saved_depthÚweakrefZWeakSetÚ
_asyncgensÚ_asyncgens_shutdown_called)rR r r r rT g s$
zBaseEventLoop.__init__c C s. d| j j› d| ¡ › d| ¡ › d| ¡ › d S )Nrw z running=z closed=z debug=rx )ry re Ú
is_runningÚ is_closedÚ get_debug)rR r r r rz ƒ s zBaseEventLoop.__repr__c C s t j| dS )N)rr )r ZFuture)rR r r r rP ‰ s zBaseEventLoop.create_futurec C s@ | ¡ | jd kr0tj|| d}|jr<|jd= n | | |¡}|S )N)rr éÿÿÿÿ)Ú
_check_closedr› r r Ú_source_traceback)rR ÚcoroZtaskr 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)Úcallabler1 r› )rR Úfactoryr r r Úset_task_factory› s
z BaseEventLoop.set_task_factoryc C s | j S )N)r› )rR r r r Úget_task_factory© s z BaseEventLoop.get_task_factoryN)ÚextraÚserverc C s t ‚d S )N)ÚNotImplementedError)rR r& Úprotocolr€ r r® r r r Ú_make_socket_transport s z$BaseEventLoop._make_socket_transportFT)Ú server_sideÚserver_hostnamer r® rv Úcall_connection_madec C s t ‚d S )N)r¯ ) rR Zrawsockr° Ú
sslcontextr€ r² r³ r r® rv r´ r r r Ú_make_ssl_transport² s z!BaseEventLoop._make_ssl_transportc C s t ‚d S )N)r¯ )rR r& r° Úaddressr€ r r r r Ú_make_datagram_transport» s z&BaseEventLoop._make_datagram_transportc C s t ‚d S )N)r¯ )rR Úpiper° r€ r r r r Ú_make_read_pipe_transportÀ s z'BaseEventLoop._make_read_pipe_transportc C s t ‚d S )N)r¯ )rR r¹ r° r€ r r r r Ú_make_write_pipe_transportÅ s z(BaseEventLoop._make_write_pipe_transportc
Ë s t ‚d S )N)r¯ )
rR r° ÚargsÚshellÚstdinÚstdoutÚstderrÚbufsizer Úkwargsr r r Ú_make_subprocess_transportÊ s z(BaseEventLoop._make_subprocess_transportc C s t ‚d S )N)r¯ )rR r r r Ú_write_to_selfÐ s z BaseEventLoop._write_to_selfc C s t ‚d S )N)r¯ )rR Ú
event_listr r r Ú_process_eventsÙ s z BaseEventLoop._process_eventsc C s | j rtdƒ‚d S )NzEvent loop is closed)r rX )rR r r r r¥ Ý s zBaseEventLoop._check_closedc C s* | j |¡ | ¡ s&| | j| ¡ ¡ d S )N)rŸ Údiscardr¢ Úcall_soon_threadsafer¨ Úaclose)rR Ú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() call)Úsource)r ÚwarningsÚwarnÚResourceWarningrŸ Úadd)rR rÊ r r r Ú_asyncgen_firstiter_hookæ s
z&BaseEventLoop._asyncgen_firstiter_hookc à sˆ d| _ t| jƒsd S t| jƒ}| j ¡ tjdd„ |D ƒd| dœŽI d H }x8t||ƒD ]*\}}t|t ƒrV|
d|›||dœ¡ qVW d S )NTc S s g | ] }| ¡ ‘qS r )rÉ )Ú.0Zagr r r ú
ü s z4BaseEventLoop.shutdown_asyncgens..)Zreturn_exceptionsrr z;an error occurred during closing of asynchronous generator )Úmessager? Zasyncgen) r ÚlenrŸ r„ Úclearr ÚgatherÚzipr rA Úcall_exception_handler)rR Z
closing_agensÚresultsÚresultrÊ r r r Úshutdown_asyncgensï s
z BaseEventLoop.shutdown_asyncgensc C s( | ¡ rtdƒ‚t ¡ d k r$tdƒ‚d S )Nz"This event loop is already runningz7Cannot run the event loop while another loop is running)r¡ rX r Z_get_running_loop)rR r r r Ú_check_runnung s
z BaseEventLoop._check_runnungc C s– | ¡ | ¡ | | j¡ t ¡ | _t ¡ }tj | j
| j d z$t
| ¡ x| ¡ | jrNP qNW W d d| _d | _t
d ¡ | d¡ tj |Ž X d S )N)Ú firstiterÚ finalizerF)r¥ rÝ Ú _set_coroutine_origin_trackingÚ_debugÚ threadingÚ get_identr” ÚsysÚget_asyncgen_hooksÚset_asyncgen_hooksrÑ rË r Z_set_running_loopÚ _run_oncerŽ )rR Zold_agen_hooksr r r Ú run_forever s$
zBaseEventLoop.run_foreverc C s | ¡ | ¡ t |¡ }tj|| d}|r4d|_| t¡ z r? Zremove_done_callbackrX rÛ )rR ZfutureZnew_taskr r r Úrun_until_complete' s"
z BaseEventLoop.run_until_completec C s
d| _ d S )NT)rŽ )rR r r r rB M s zBaseEventLoop.stopc C sj | ¡ rtdƒ‚| jrd S | jr,t d| ¡ d| _| j ¡ | j ¡ | j }|d k rfd | _ |j
dd d S )Nz!Cannot close a running event loopzClose %rTF)Úwait) r¡ rX r rá r Údebugr‘ rÖ r’ r“ Zshutdown)rR Úexecutorr r r r… U s
zBaseEventLoop.closec C s | j S )N)r )rR r r r r¢ k s zBaseEventLoop.is_closedc C s2 | ¡ s.tjd| ›t| d | ¡ s.| ¡ d S )Nzunclosed event loop )rÌ )r¢ rÍ rÎ rÏ r¡ r… )rR r r r Ú__del__o s
zBaseEventLoop.__del__c C s
| j d k S )N)r” )rR r r r r¡ v s zBaseEventLoop.is_runningc C s t ¡ S )N)r• r‹ )rR r r r r• z s zBaseEventLoop.time)Úcontextc G s2 | j | ¡ | |f|žd|iŽ}|jr.|jd= |S )Nrî r¤ )Úcall_atr• r¦ )rR ZdelayÚcallbackrî r¼ Útimerr r r Ú
call_laterƒ s
zBaseEventLoop.call_laterc G sZ | ¡ | jr"| ¡ | |d¡ t |||| |¡}|jrB|jd= t | j |¡ d|_ |S )Nrï r¤ T)
r¥ rá Ú
_check_threadÚ_check_callbackr Z TimerHandler¦ ÚheapqÚheappushr’ )rR Úwhenrð rî r¼ rñ r r r rï ™ s zBaseEventLoop.call_atc G sB | ¡ | jr"| ¡ | |d¡ | |||¡}|jr>|jd= |S )NÚ call_soonr¤ )r¥ rá ró rô Ú
_call_soonr¦ )rR rð rî r¼ r r r r rø © s
zBaseEventLoop.call_soonc C sD t |¡st |¡r$td|› dƒ‚t|ƒs@td|› d|›ƒ‚d S )Nz coroutines cannot be used with z()z"a callable object was expected by z(), got )r Z iscoroutineZiscoroutinefunctionr1 r© )rR rð Úmethodr r r rô ¼ s
z BaseEventLoop._check_callbackc C s. t ||| |¡}|jr |jd= | j |¡ |S )Nr¤ )r ZHandler¦ r‘ r5 )rR rð r¼ rî r r r r rù Æ s
zBaseEventLoop._call_soonc C s, | j d krd S t ¡ }|| j kr(tdƒ‚d S )NzMNon-thread-safe operation invoked on an event loop other than the current one)r” râ rã rX )rR 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Ä )rR 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 )NÚrun_in_executor)rr ) r¥ rá rô r“ Ú
concurrentr ZThreadPoolExecutorZ wrap_futureZsubmit)rR rì Úfuncr¼ r r r rû é s
z BaseEventLoop.run_in_executorc C s
|| _ d S )N)r“ )rR 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 |¡}t d|¡ | ¡ }t ||||||¡} | ¡ | }
d|› d |
d
d ›d | ›}|
| jkrÐt |¡ n
t |¡ | S )
Nú:zfamily=ztype=zproto=zflags=z, zGet address info %szGetting address info z took g @@z.3fzms: ) r5 Újoinr rë r• r! Ú getaddrinfor™ Úinfo) rR r7 r8 r9 r: r; ÚflagsÚmsgÚt0ZaddrinfoÚdtr r r Ú_getaddrinfo_debugø s&
z BaseEventLoop._getaddrinfo_debugr )r9 r: r; r c
à s2 | j r| j}ntj}| d |||||||¡I d H S )N)rá r r! r rû )rR r7 r8 r9 r: r; r Z getaddr_funcr r r r s
zBaseEventLoop.getaddrinfoc à s | d tj||¡I d H S )N)rû r! Ú getnameinfo)rR Zsockaddrr r r r r s zBaseEventLoop.getnameinfo)Úfallbackc
à s‚ | j r| ¡ dkrtdƒ‚| ||||¡ y| ||||¡I d H S tjk
rj } z
|sZ‚ W d 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)rR r& ÚfileÚoffsetÚcountr rD r r r Ú
sock_sendfile s zBaseEventLoop.sock_sendfilec à s t d|›d¡‚d S )Nz-syscall sendfile is not available for socket z and file {file!r} combination)r r )rR r& r r r r r r r , s z#BaseEventLoop._sock_sendfile_nativec
à sÌ |r| |¡ |r t|tjƒntj}t|ƒ}d}ztxn|rPt|| |ƒ}|dkrPP t|ƒd |… }| d |j|¡I d H } | s|P | ||d | … ¡I d H || 7 }q4W |S |dkrÆt |dƒrÆ| || ¡ X d S )Nr Úseek)
r Úminr Z!SENDFILE_FALLBACK_READBUFFER_SIZEÚ bytearrayÚ
memoryviewrû ÚreadintoZ sock_sendallr )
rR r& r r r Ú blocksizeÚbufÚ
total_sentÚviewÚreadr r r r
3 s(
z%BaseEventLoop._sock_sendfile_fallbackc C s” dt |ddƒkrtdƒ‚|jtjks,tdƒ‚|d k rbt|tƒsLtd |¡ƒ‚|dkrbtd |¡ƒ‚t|tƒsztd |¡ƒ‚|dk rtd |¡ƒ‚d S )NÚbÚmodez$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! r- r r0 r1 Úformat)rR r& r r r r r r r
M s&
z$BaseEventLoop._check_sendfile_params)Ússlr9 r; r r& Ú
local_addrr³ rv c ƒ s |
d k r|st dƒ‚|
d kr0|r0|s,t dƒ‚|}
| d k rD|sDt dƒ‚|d k sV|d k r†|d k rft dƒ‚| j||f|tj||| dI d H } | s”tdƒ‚| d k rÆ| j| |tj||| dI d H }
|
sÆtdƒ‚g }xæ| D ]J\}}}}}yÚtj|||d}| d¡ | d k r’xˆ|
D ]r\}}}}}y| |¡ P W nP tk
r| } z0d |›d
|j ¡ › }t|j |ƒ}|
|¡ W d d }~X Y nX qW | ¡ d }wÒ| j r¨t
d ||¡ | ||¡I d H W n^ tk
rü } z |d k râ| ¡ |
|¡ W d d }~X Y qÒ |d k r| ¡ ‚ Y qÒX P qÒW t|ƒd kr:|d
‚nJt|d
ƒ‰ t‡ fdd„|D ƒƒrf|d
‚td d dd„ |D ƒ¡¡ƒ‚n.|d kr˜t dƒ‚|jtjkr´t d|›ƒ‚| j||||
| dI d H \}}| j rø| d¡}t
d|||||¡ ||fS )Nz+server_hostname is only meaningful with sslz:You must set server_hostname when using ssl without a hostz1ssl_handshake_timeout is only meaningful with sslz8host/port and sock can not be specified at the same time)r9 r: r; r rr z!getaddrinfo() returned empty list)r9 r: r; Fz*error while attempting to bind on address z: zconnect %r to %rr r c 3 s | ]}t |ƒˆ kV qd S )N)r )rÒ rD )Úmodelr r ú Æ s z2BaseEventLoop.create_connection..zMultiple exceptions: {}z, c s s | ]}t |ƒV qd S )N)r )rÒ rD r r r r" Ë s z5host and port was not specified and no sock specifiedz"A Stream Socket was expected, got )rv r! z %r connected to %s:%r: (%r, %r))r" Ú_ensure_resolvedr! r- r% Ú setblockingÚbindÚstrerrorÚlowerÚerrnor5 r… rá r rë Ú sock_connectrÕ r Úallr r r: Ú _create_connection_transportÚget_extra_info)rR rt r7 r8 r r9 r; r r& r r³ rv ÚinfosZ laddr_infosÚ
exceptionsr: Zcnamer· Ú_ZladdrrD r rY r° r )r! r Úcreate_connectionb s–
"
z BaseEventLoop.create_connectionc à s„ | d¡ |ƒ }| ¡ }|rHt|tƒr*d n|} | j||| ||||d}
n| |||¡}
y|I d H W n |
¡ ‚ Y nX |
|fS )NF)r² r³ rv )r$ rP r Úboolr¶ r± r… ) rR r& rt r r³ r² rv r° r€ rµ rY r r r r+ æ s
z*BaseEventLoop._create_connection_transportc
à s° | ¡ rtdƒ‚t|dtjjƒ}|tjjkr:td|›ƒ‚|tjjkrˆy| ||||¡I d H S tj k
r† } z
|sv‚ W d d }~X Y nX |sštd|›ƒ‚|
||||¡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 ) rU rX r r Z
_SendfileModeZ UNSUPPORTEDZ
TRY_NATIVEÚ_sendfile_nativer r Ú_sendfile_fallback)rR rY r r r r r rD r r r Úsendfile s&
zBaseEventLoop.sendfilec à s t d¡‚d S )Nz!sendfile syscall is not supported)r r )rR rS r r r r r r r2 / s z BaseEventLoop._sendfile_nativec
à sè |r| |¡ |r t|dƒnd}t|ƒ}d}t|ƒ}z~xx|rVt|| |ƒ}|dkrV|S t|ƒd |… } | d |j| ¡I d H }
|
s„|S | ¡ I d H | | d |
… ¡ ||
7 }q8W W d |dkrÔt |dƒrÔ| || ¡ |
¡ I d H X d S )Ni @ r r ) r r r rH r rû r rW Úwriter rd ) rR rS r r r r r r r; r r r r r r3 3 s,
z BaseEventLoop._sendfile_fallback)r² r³ rv c
à sØ t d krtdƒ‚t|t jƒs*td|›ƒ‚t|ddƒsFtd|›dƒ‚| ¡ }tj| ||||||dd}| ¡ |
|¡ | |j |¡} | |j
¡}
y|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())rv r´ )r rX r Z
SSLContextr1 r rP r Z SSLProtocolrM rN rø rZ rb rA r… rc Z_app_transport) rR rY r° rµ r² r³ rv r€ Z ssl_protocolZ
conmade_cbZ resume_cbr r r Ú start_tlsL s4
zBaseEventLoop.start_tls)r9 r; r Ú
reuse_addressÚ
reuse_portÚallow_broadcastr& c ƒ sŽ |
d k r|
j tjkr"td|
›ƒ‚ˆ s>ˆs>|s>|s>|s>|s>| r~tˆ ˆ|||||| d} d dd„ | ¡ D ƒ¡} td| › dƒ‚|
d¡ d }
n€ˆ sºˆsº|d kr¨td
ƒ‚||fd ff}n ttd ƒr|tj krx*ˆ ˆfD ] }|d k rÜt
|t ƒsÜt d
ƒ‚qÜW ||fˆ ˆfff}nÈt
¡ }x˜d ˆ fdˆffD ]„\}}|d k r,| j||tj||| dI d H }|sjtdƒ‚xB|D ]:\}}}}}||f}||krœd d g||< ||| |< qpW q,W ‡ ‡fdd„| ¡ D ƒ}|sÚtdƒ‚g }|tk r|røtdƒ‚ntjdtdd x|D ]ô\\}}\}}d }
d }
yxtj|tj|d}
|rJt|
ƒ | rb|
tjtjd¡ |
d¡ ˆ r||
|¡ ˆrž| sš| |
|¡I d H |}
W n^ tk
rà } z |
d k rÆ|
¡ | |¡ W d d }~X Y n" |
d k rø|
¡ ‚ Y nX P qW |d ‚|ƒ } | ¡ } | |
| |
| ¡} | j r`ˆ rPt !dˆ ˆ| | ¡ nt "dˆ| | ¡ y| I d H W n | ¡ ‚ Y nX | | fS )Nz A UDP Socket was expected, got )r Ú remote_addrr9 r; r r7 r8 r9 z, c s s$ | ] \}}|r|› d |› V qdS )ú=Nr )rÒ ÚkÚvr r r r" Œ s z9BaseEventLoop.create_datagram_endpoint..zKsocket modifier keyword arguments can not be used when sock is specified. (ú)Fr zunexpected address family)NNÚAF_UNIXzstring is expectedr )r9 r: r; r rr z!getaddrinfo() returned empty listc s8 g | ]0\}}ˆ r |d dksˆr,|d dks||f‘qS )r Nr r )rÒ ÚkeyZ addr_pair)r r: 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.zcThe *reuse_address* parameter has been deprecated as of 3.7.6 and is scheduled for removal in 3.11.é )Ú
stacklevel)r9 r: r; z@Datagram endpoint local_addr=%r remote_addr=%r created: (%r, %r)z2Datagram endpoint remote_addr=%r created: (%r, %r))#r: r! r. r" Údictr Úitemsr$ r r? r r r1 r Ú OrderedDictr# r% Ú_unsetrÍ rÎ ÚDeprecationWarningr' r# r$ Z SO_BROADCASTr% r) r… r5 rP r¸ rá r r rë ) rR rt r r: r9 r; r r7 r8 r9 r& ZoptsZproblemsZr_addrZaddr_pairs_infoZaddrZ
addr_infosÚidxr- Zfamr/ Zpror· r@ r. Z
local_addressZremote_addressrD r° r€ rY r )r r: r Úcreate_datagram_endpointz s¼
z&BaseEventLoop.create_datagram_endpointc
à s\ |d d… \}}t |||||f|dd … žŽ } | d k r<| gS |j||||||dI d H S d S )NrA )r9 r: r; r )r= r )
rR r· r9 r: r; r rr r7 r8 r r r r r# s z BaseEventLoop._ensure_resolvedc à s8 | j ||f|tj|| dI d H }|s4td|›dƒ‚|S )N)r9 r: r rr z getaddrinfo(z) returned empty list)r# r! r- r% )rR r7 r8 r9 r r- r r r Ú_create_server_getaddrinfo s z(BaseEventLoop._create_server_getaddrinfor
) r9 r r& ru r r7 r8 rv r‡ c ƒ sÄ t |tƒrtdƒ‚| d k r*|d kr*tdƒ‚|d k s<ˆd k r*|d k rLtdƒ‚| d krhtjdkoftjdk} g }
|dkr|d g}n$t |tƒs”t |t j
j ƒsœ|g}n|}‡ ‡‡‡fdd„|D ƒ}t j
|d ˆiŽI d H }ttj |¡ƒ}d
}z"x|D ] }|\}}}}}yt |||¡}W n6 tjk
rJ ˆjrDtjd |||d d
wîY nX |
|¡ | rn| tjtjd ¡ |
r|t|ƒ t r¬|tj kr¬t tdƒr¬| tj tj d ¡ y| !|¡ W qî t"k
rú } z t"|j#d||j$ %¡ f ƒd ‚W d d }~X Y qîX qîW d }W d |s&x|
D ]}| &¡ qW X n4|d kr.rr Fz:create_server() failed to create socket.socket(%r, %r, %r)T)Úexc_infoÚ IPPROTO_IPV6z0error while attempting to bind on address %r: %sz)Neither host/port nor sock were specifiedz"A Stream Socket was expected, got r )rr z
%r is serving).r r1 r1 r" ÚosÚnamerä Úplatformr r ÚabcÚIterabler r× ÚsetÚ itertoolsÚchainÚ
from_iterabler! Úerrorrá r Úwarningr5 r# r$ Z SO_REUSEADDRr' r4 r r rN Z IPV6_V6ONLYr% r% r( r& r' r… r: r- r$ rh r r† r )rR rt r7 r8 r9 r r& ru r r7 r8 rv r‡ rs ZhostsZfsr- Z completedZresr< Zsocktyper; Z canonnameZsaÚerrr® r )r9 r r8 rR r Ú
create_server sŠ
*
zBaseEventLoop.create_server)r rv c à sv |j tjkrtd|›ƒ‚|d k r.|s.tdƒ‚| j|||dd|dI d H \}}| jrn| d¡}t d|||¡ ||fS )Nz"A Stream Socket was expected, got z1ssl_handshake_timeout is only meaningful with sslr* T)r² rv r! z%r handled: (%r, %r)) r: r! r- r" r+ rá r, r rë )rR rt r& r rv rY r° r r r Úconnect_accepted_socket‰ s
z%BaseEventLoop.connect_accepted_socketc à sd |ƒ }| ¡ }| |||¡}y|I d H W n | ¡ ‚ Y nX | jr\t d| ¡ ||¡ ||fS )Nz Read pipe %r connected: (%r, %r))rP rº r… rá r rë Úfileno)rR rt r¹ r° r€ rY r r r Úconnect_read_pipe¦ s z BaseEventLoop.connect_read_pipec à sd |ƒ }| ¡ }| |||¡}y|I d H W n | ¡ ‚ Y nX | jr\t d| ¡ ||¡ ||fS )Nz!Write pipe %r connected: (%r, %r))rP r» r… rá r rë r] )rR rt r¹ r° r€ rY 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|ƒ› ¡ t d |¡¡ d S )Nzstdin=zstdout=stderr=zstdout=zstderr=ú )r5 r r r r rë r )rR r r¾ r¿ rÀ r r r r Ú_log_subprocessÆ s z BaseEventLoop._log_subprocess)r¾ r¿ rÀ Úuniversal_newlinesr½ rÁ c
Ë sª t |ttfƒstdƒ‚|r"tdƒ‚|s.tdƒ‚|dkr>tdƒ‚|ƒ }
d } | jrfd| } | | |||¡ | j|
|d||||f| ŽI d H } | jr¢| d k r¢t d| | ¡ | |
fS ) Nzcmd must be a stringz universal_newlines must be Falsezshell must be Truer zbufsize must be 0zrun shell command %rTz%s: %r) r r/ r r" rá ra rà r r )
rR rt Úcmdr¾ r¿ rÀ rb r½ rÁ r r° Ú debug_logrY r r r Úsubprocess_shellÓ s$ z BaseEventLoop.subprocess_shellc Ï sÐ |r t dƒ‚|rt dƒ‚|dkr(t dƒ‚|f| } x.| D ]&} t| ttfƒs8tdt| ƒj› ƒ‚q8W |ƒ }
d }| jrŒd|›}| ||||¡ | j |
| d||||f|
ŽI d H }| jrÈ|d k rÈt
d||¡ ||
fS ) Nz universal_newlines must be Falsezshell must be Falser zbufsize must be 0z6program arguments must be a bytes or text string, not zexecute program Fz%s: %r) r" r r r/ r1 r: re rá ra rà r r )rR rt Zprogramr¾ r¿ rÀ rb r½ rÁ r¼ r Z
popen_argsÚargr° rd rY r r r Úsubprocess_execï s,
z BaseEventLoop.subprocess_execc C s | j S )N)r— )rR r r r Úget_exception_handler
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© r1 r— )rR Zhandlerr r r Úset_exception_handler 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}x’t|ƒD ]†}|dkr~qp|| }|dkr°d t |¡¡}d }|| ¡ 7 }n2|dkrÚd t |¡¡}d
}|| ¡ 7 }nt
|ƒ}| |› d |› ¡ qpW t j
d |¡|d
d S )NrÔ z!Unhandled exception in event loopr? FZsource_tracebackZhandle_traceback> r? rÔ r* z+Object created at (most recent call last):
z+Handle created at (most recent call last):
z: Ú
)rM )Úgetr: Ú
__traceback__rš r¦ Úsortedr Ú tracebackÚ format_listÚrstripr r5 r rX ) rR rî rÔ r? rM Z log_linesr@ ÚvalueÚtbr r r Údefault_exception_handler# s6
z'BaseEventLoop.default_exception_handlerc C s° | j d kr>y| |¡ W q¬ tk
r: tjddd Y q¬X nny| | |¡ W n\ tk
rª } z>y| d||dœ¡ W n" tk
r˜ tjddd Y nX W d d }~X Y nX d S )Nz&Exception in default exception handlerT)rM z$Unhandled error in exception handler)rÔ r? rî zeException in default exception handler while handling an unexpected error in custom exception handler)r— rs rA r rX )rR rî rD r r r rÙ U s"
z$BaseEventLoop.call_exception_handlerc C s |j r
d S | j |¡ d S )N)Ú
_cancelledr‘ r5 )rR r r r r Ú
_add_callbackˆ s zBaseEventLoop._add_callbackc C s | |¡ | ¡ d S )N)ru rÄ )rR r r r r Ú_add_callback_signalsafe s
z&BaseEventLoop._add_callback_signalsafec C s |j r| jd7 _d S )Nr )r’ rŒ )rR r r r r Ú_timer_handle_cancelled• s z%BaseEventLoop._timer_handle_cancelledc C sš t | jƒ}|tkrd| j| tkrdg }x&| jD ] }|jr>d|_q,| |¡ q,W t |¡ || _d| _n8x6| jrš| jd jrš| jd8 _t | j¡}d|_qfW d }| j
s¬| j r²d}n*| jrÜ| jd j }t
td|| ¡ ƒtƒ}| jr”|dkr”| ¡ }| j |¡}| ¡ | }|dkr tj} ntj} t |ƒ}
|d krNt | d|d |
¡ nD|
rpt | d|d |d |
¡ n"|dkr t | d|d |d ¡ n | j |¡}| |¡ | ¡ | j } xD| jrü| jd }|j | krÚP t | j¡}d|_| j
|¡ qºW t | j
ƒ} xˆt| ƒD ]|}
| j
¡ }|jr,q| jr„zD|| _ | ¡ }| ¡ | ¡ | }|| j krvt d t!|ƒ|¡ W d d | _ X n| ¡ qW d }d S )
NFr r g ð?z poll took %.3f ms: %s eventsg @@z$poll %.3f ms took %.3f ms: %s eventsz"poll %.3f ms took %.3f ms: timeoutz Executing %s took %.3f seconds)"rÕ r’ Ú _MIN_SCHEDULED_TIMER_HANDLESrŒ Ú%_MIN_CANCELLED_TIMER_HANDLES_FRACTIONrt r5 rõ ÚheapifyÚheappopr‘ rŽ Z_whenr Úmaxr• ÚMAXIMUM_SELECT_TIMEOUTrá Z _selectorZselectÚloggingÚINFOÚDEBUGr ÚlogrÆ r– ÚrangeÚpopleftrš Z_runr™ rY r )rR Z sched_countZ
new_scheduledr Ztimeoutr÷ r rÅ r ÚlevelZneventZend_timeZntodoÚir r r rç š sˆ
zBaseEventLoop._run_oncec C sH t |ƒt | jƒkrd S |r2t ¡ | _t tj¡ n t | j¡ || _d S )N)r1 rœ rä Ú#get_coroutine_origin_tracking_depthr Ú#set_coroutine_origin_tracking_depthr ZDEBUG_STACK_DEPTH)rR Úenabledr r r rà ý s
z,BaseEventLoop._set_coroutine_origin_trackingc C s | j S )N)rá )rR r r r r£ s zBaseEventLoop.get_debugc C s || _ | ¡ r | | j|¡ d S )N)rá r¡ rÈ rà )rR rˆ r r r r˜ s zBaseEventLoop.set_debug)N)N)NNN)NN)NN)N)r )r N)NN)FN)r N)NN)NN)Pre rf rg rT rz rP r¨ r« r¬ r± r¶ r¸ rº r» rà rÄ rÆ r¥ rË rÑ rÜ rÝ rè ré rB r… r¢ rí r¡ r• rò rï rø rô rù ró rÈ rû rþ r r r r r r
r
r0 r+ r4 r2 r3 r6 rF rI r! r- r# rJ r2 Z
AI_PASSIVEr[ r\ r^ r_ ra r r re rg rh ri rs rÙ ru rv rw rç rà r£ r˜ r r r r r e sØ
&
.,
l23cr )r r )1r Zcollections.abcÚconcurrent.futuresrü rõ rU r~ rO r! r râ r• rn rä rÍ rž r Ú ImportErrorr* r r r r r r r r
r r Ú__all__rx ry r r4 r} ÚobjectrF r r r' r= rE rG ZProtocolrH ZAbstractServerrh ZAbstractEventLoopr r r r r Ú sX
;
Do