B
–?Ào Ðy"ã @ s d Z ddlZddlZddlZddlZddlZddlZddlZy ddlZW n e k
r` dZY nX ddl
m Z ddl
m Z ddl
m
Z
ddl
mZ ddl
mZ dd l
mZ dd
l
mZ dd lmZ d d
„ Zdd„ ZG dd„ de jƒZG dd„ dejejƒZG dd„ deƒZG dd„ deƒZ dS ))ÚBaseSelectorEventLoopé Né )Ú base_events)Ú constants)Úevents)Úfutures)Ú protocols)Ússlproto)Ú
transports)Úloggerc C s6 y| |¡}W n tk
r" dS X t|j|@ ƒS d S )NF)Úget_keyÚKeyErrorÚboolr )ÚselectorÚfdZeventÚkey© r úd?„ Z!d@dA„ Z"dBdC„ Z#dDdE„ Z$dFdG„ Z%dHdI„ Z&dJdK„ Z'dLdM„ Z(dNdO„ Z)‡ Z*S )Tr Nc sF t ƒ ¡ |d krt ¡ }t d|jj¡ || _| ¡ t
¡ | _ d S )NzUsing selector: %s)
ÚsuperÚ__init__Ú selectorsZDefaultSelectorr ÚdebugÚ __class__Ú__name__Ú _selectorÚ_make_self_pipeÚweakrefZWeakValueDictionaryÚ _transports)Úselfr )r r r r 5 s
z BaseSelectorEventLoop.__init__)ÚextraÚserverc C s t | |||||ƒS )N)Ú_SelectorSocketTransport)r$ r ÚprotocolÚwaiterr% r& r r r Ú_make_socket_transport? s
z,BaseSelectorEventLoop._make_socket_transportF)Ú server_sideÚserver_hostnamer% r& Ússl_handshake_timeoutc C s0 t j| |||||| d}
t| ||
||d |
jS )N)r- )r% r& )r Z SSLProtocolr' Z_app_transport) r$ Zrawsockr( Ú
sslcontextr) r+ r, r% r& r- Z ssl_protocolr r r Ú_make_ssl_transportD s
z)BaseSelectorEventLoop._make_ssl_transportc C s t | |||||ƒS )N)Ú_SelectorDatagramTransport)r$ r r( Úaddressr) r% r r r Ú_make_datagram_transportQ s z.BaseSelectorEventLoop._make_datagram_transportc sL | ¡ rtdƒ‚| ¡ r d S | ¡ tƒ ¡ | jd k rH| j ¡ d | _d S )Nz!Cannot close a running event loop)Z
is_runningÚ RuntimeErrorÚ is_closedÚ_close_self_piper Úcloser )r$ )r r r r6 V s
zBaseSelectorEventLoop.closec C sB | | j ¡ ¡ | j ¡ d | _| j ¡ d | _| jd8 _d S )Nr )Ú_remove_readerÚ_ssockÚfilenor6 Ú_csockÚ
_internal_fds)r$ r r r r5 a s
z&BaseSelectorEventLoop._close_self_pipec C sN t ¡ \| _| _| j d¡ | j d¡ | jd7 _| | j ¡ | j¡ d S )NFr ) ÚsocketZ
socketpairr8 r: Ú setblockingr; Ú _add_readerr9 Ú_read_from_self)r$ r r r r! i s
z%BaseSelectorEventLoop._make_self_pipec C s d S )Nr )r$ Údatar r r Ú_process_self_dataq s z(BaseSelectorEventLoop._process_self_datac C sV xPy | j d¡}|sP | |¡ W q tk
r8 wY q tk
rL P Y qX qW d S )Ni )r8 ÚrecvrA ÚInterruptedErrorÚBlockingIOError)r$ r@ r r r r? t s z%BaseSelectorEventLoop._read_from_selfc C sJ | j }|d k rFy| d¡ W n( tk
rD | jr@tjddd Y nX d S )Nó z3Fail to write a null byte into the self-pipe socketT)Úexc_info)r: ÚsendÚOSErrorÚ_debugr r )r$ Zcsockr r r Ú_write_to_self€ s z$BaseSelectorEventLoop._write_to_selféd c
C s" | | ¡ | j||||||¡ d S )N)r> r9 Ú_accept_connection)r$ Úprotocol_factoryr r. r& Úbacklogr- r r r Ú_start_serving s
z$BaseSelectorEventLoop._start_servingc
C s xüt |ƒD ]ð}y0| ¡ \}} | jr4t d|| |¡ | d¡ W n” tttfk
rZ d S t k
rÔ }
z^|
j
t
j t
j t
j
t
jfkrÂ| d|
|dœ¡ | | ¡ ¡ | tj| j||||||¡ n‚ W d d }
~
X Y q X d| i} | ||| |||¡} | | ¡ q W d S )Nz#%r got a new connection from %r: %rFz&socket.accept() out of system resource)ÚmessageÚ exceptionr< Úpeername)ÚrangeÚacceptrI r r r= rD rC ÚConnectionAbortedErrorrH ÚerrnoZEMFILEZENFILEZENOBUFSZENOMEMÚcall_exception_handlerr7 r9 Z
call_laterr ZACCEPT_RETRY_DELAYrO Ú_accept_connection2Z create_task)
r$ rM r r. r& rN r- Ú_ÚconnÚaddrÚexcr% rT r r r rL — s6
z(BaseSelectorEventLoop._accept_connectionc
à sÖ d }d }yl|ƒ }| ¡ } |r8| j|||| d|||d}n| j||| ||d}y| I d H W n | ¡ ‚ Y nX W n\ tk
rÐ }
z>| jrÀd|
dœ} |d k r¦|| d< |d k r¶|| d< | | ¡ W d d }
~
X Y nX d S )NT)r) r+ r% r& r- )r) r% r& z3Error on transport creation for incoming connection)rP rQ r( Ú transport)Ú
create_futurer/ r* r6 Ú ExceptionrI rW ) r$ rM rZ r% r. r& r- r( r] r) r\ Úcontextr r r rX Ã s6
z)BaseSelectorEventLoop._accept_connection2c
C sŽ |}t |tƒsJyt| ¡ ƒ}W n* tttfk
rH td|›ƒd ‚Y nX y| j| }W n tk
rl Y n X | ¡ sŠt d|›d|›ƒ‚d S )NzInvalid file object: zFile descriptor z is used by transport )
r Úintr9 ÚAttributeErrorr Ú
ValueErrorr# r
Ú
is_closingr3 )r$ r r9 r] r r r Ú_ensure_fd_no_transportê s
z-BaseSelectorEventLoop._ensure_fd_no_transportc G s” | ¡ t ||| d ¡}y| j |¡}W n* tk
rR | j |tj|d f¡ Y n>X |j|j }\}}| j
||tjB ||f¡ |d k r| ¡ d S )N) Ú
_check_closedr ÚHandler r r
Úregisterr Ú
EVENT_READr@ ÚmodifyÚcancel) r$ r ÚcallbackÚargsÚhandler ÚmaskÚreaderÚwriterr r r r> ü s
z!BaseSelectorEventLoop._add_readerc C s’ | ¡ r dS y| j |¡}W n tk
r0 dS X |j|j }\}}|tj M }|sb| j |¡ n| j ||d |f¡ |d k rŠ|
¡ dS dS d S )NFT) r4 r r r
r r@ r ri Ú
unregisterrj rk )r$ r r ro rp rq r r r r7 s z$BaseSelectorEventLoop._remove_readerc G s” | ¡ t ||| d ¡}y| j |¡}W n* tk
rR | j |tjd |f¡ Y n>X |j|j }\}}| j
||tjB ||f¡ |d k r| ¡ d S )N) rf r rg r r r
rh r Ú EVENT_WRITEr@ rj rk ) r$ r rl rm rn r ro rp rq r r r Ú _add_writer s
z!BaseSelectorEventLoop._add_writerc C s’ | ¡ r dS y| j |¡}W n tk
r0 dS X |j|j }\}}|tj M }|sb| j |¡ n| j |||d f¡ |d k rŠ|
¡ dS dS d S )NFT) r4 r r r
r r@ r rs rr rj rk )r$ r r ro rp rq r r r Ú_remove_writer/ s z$BaseSelectorEventLoop._remove_writerc G s | |¡ | j||f|žŽ S )N)re r> )r$ r rl rm r r r Ú
add_readerF s
z BaseSelectorEventLoop.add_readerc C s | |¡ | |¡S )N)re r7 )r$ r r r r Ú
remove_readerK s
z#BaseSelectorEventLoop.remove_readerc G s | |¡ | j||f|žŽ S )N)re rt )r$ r rl rm r r r Ú
add_writerP s
z BaseSelectorEventLoop.add_writerc C s | |¡ | |¡S )N)re ru )r$ r r r r Ú
remove_writerU s
z#BaseSelectorEventLoop.remove_writerc à sD t |ƒ | jr"| ¡ dkr"tdƒ‚| ¡ }| |d ||¡ |I d H S )Nr z the socket must be non-blocking)r rI Ú
gettimeoutrc r^ Ú
_sock_recv)r$ r ÚnÚfutr r r Ú sock_recvZ s z BaseSelectorEventLoop.sock_recvc C sœ |d k r| |¡ | ¡ r d S y| |¡}W n` ttfk
rb | ¡ }| || j||||¡ Y n6 tk
rŒ } z| |¡ W d d }~X Y n X |
|¡ d S )N) rw Ú cancelledrB rD rC r9 rv r{ r_ Ú
set_exceptionÚ
set_result)r$ r} Ú
registered_fdr r| r@ r r\ r r r r{ h s
z BaseSelectorEventLoop._sock_recvc à sD t |ƒ | jr"| ¡ dkr"tdƒ‚| ¡ }| |d ||¡ |I d H S )Nr z the socket must be non-blocking)r rI rz rc r^ Ú_sock_recv_into)r$ r Úbufr} r r r Úsock_recv_into} s z$BaseSelectorEventLoop.sock_recv_intoc C sœ |d k r| |¡ | ¡ r d S y| |¡}W n` ttfk
rb | ¡ }| || j||||¡ Y n6 tk
rŒ } z| |¡ W d d }~X Y n X |
|¡ d S )N) rw r Ú recv_intorD rC r9 rv rƒ r_ r€ r )r$ r} r‚ r r„ Únbytesr r\ r r r rƒ Š s
z%BaseSelectorEventLoop._sock_recv_intoc à sT t |ƒ | jr"| ¡ dkr"tdƒ‚| ¡ }|r@| |d ||¡ n
| d ¡ |I d H S )Nr z the socket must be non-blocking)r rI rz rc r^ Ú
_sock_sendallr )r$ r r@ r} r r r Ú sock_sendall s
z"BaseSelectorEventLoop.sock_sendallc
C s¾ |d k r| |¡ | ¡ r d S y| |¡}W nF ttfk
rH d}Y n, tk
rr } z| |¡ d S d }~X Y nX |t|ƒkrŒ| d ¡ n.|rœ||d … }| ¡ }|
|| j ||||¡ d S )Nr ) ry r rG rD rC r_ r€ Úlenr r9 rx rˆ )r$ r} r‚ r r@ r| r\ r r r r rˆ ³ s"
z#BaseSelectorEventLoop._sock_sendallc à s† t |ƒ | jr"| ¡ dkr"tdƒ‚ttdƒr8|jtjkrf| j||j|j | dI d H }|d \}}}}}|
¡ }| |||¡ |I d H S )Nr z the socket must be non-blockingÚAF_UNIX)ÚfamilyÚprotoÚloop) r rI rz rc Úhasattrr< rŒ r‹ Z_ensure_resolvedr r^ Ú
_sock_connect)r$ r r1 ZresolvedrY r} r r r Ú sock_connectÉ s z"BaseSelectorEventLoop.sock_connectc
C s | ¡ }y| |¡ W nj ttfk
rV | t | j|¡¡ | || j |||¡ Y n6 t
k
r€ } z| |¡ W d d }~X Y n X | d ¡ d S )N)
r9 ZconnectrD rC Zadd_done_callbackÚ functoolsÚpartialÚ_sock_connect_donerx Ú_sock_connect_cbr_ r€ r )r$ r} r r1 r r\ r r r r Û s z#BaseSelectorEventLoop._sock_connectc C s | |¡ d S )N)ry )r$ r r} r r r r” ì s z(BaseSelectorEventLoop._sock_connect_donec
C sŠ | ¡ r d S y,| tjtj¡}|dkr6t|d|› ƒ‚W nB ttfk
rP Y n6 tk
rz } z| |¡ W d d }~X Y n X |
d ¡ d S )Nr zConnect call failed ) r Z
getsockoptr< Z
SOL_SOCKETZSO_ERRORrH rD rC r_ r€ r )r$ r} r r1 Úerrr\ r r r r• ï s z&BaseSelectorEventLoop._sock_connect_cbc à sB t |ƒ | jr"| ¡ dkr"tdƒ‚| ¡ }| |d|¡ |I d H S )Nr z the socket must be non-blockingF)r rI rz rc r^ Ú _sock_accept)r$ r r} r r r Ú sock_accept s z!BaseSelectorEventLoop.sock_acceptc
C s¦ | ¡ }|r| |¡ | ¡ r"d S y| ¡ \}}| d¡ W nV ttfk
rh | || j|d|¡ Y n: t k
r’ } z|
|¡ W d d }~X Y nX | ||f¡ d S )NFT) r9 rw r rT r= rD rC rv r— r_ r€ r )r$ r} Z
registeredr r rZ r1 r\ r r r r— s
z"BaseSelectorEventLoop._sock_acceptc à sl | j |j= | ¡ }| ¡ | ¡ I d H z | j|j|||ddI d H S | ¡ |rZ| ¡ || j |j< X d S )NF)Úfallback) r# Ú_sock_fdÚ
is_readingÚ
pause_readingÚ_make_empty_waiterZ
sock_sendfileÚ_sockÚ_reset_empty_waiterÚresume_reading)r$ ZtranspÚfileÚoffsetÚcountr r r r Ú_sendfile_native s
z&BaseSelectorEventLoop._sendfile_nativec C s„ x~|D ]v\}}|j |j }\}}|tj@ rN|d k rN|jrD| |¡ n
| |¡ |tj@ r|d k r|jrr| |¡ q| |¡ qW d S )N) Úfileobjr@ r ri Z
_cancelledr7 Z
_add_callbackrs ru )r$ Z
event_listr ro r¥ rp rq r r r Ú_process_events- s
z%BaseSelectorEventLoop._process_eventsc C s | | ¡ ¡ | ¡ d S )N)r7 r9 r6 )r$ r r r r Ú
_stop_serving; s z#BaseSelectorEventLoop._stop_serving)N)N)N)NNN)+r Ú
__module__Ú __qualname__r r* r ZSSL_HANDSHAKE_TIMEOUTr/ r2 r6 r5 r! rA r? rJ rO rL rX re r> r7 rt ru rv rw rx ry r~ r{ r… rƒ r‰ rˆ r‘ r r” r• r˜ r— r¤ r¦ r§ Ú
__classcell__r r )r r r / sX
+$
r c sŒ e Zd ZdZeZdZd ‡ fdd„ Zdd„ Zdd„ Z d d
„ Z
d d „ Z d
d„ Z dd„ Z
dd„ Zd dd„Zdd„ Zdd„ Zdd„ Zd d „ Z‡ ZS ) Ú_SelectorTransporti Nc sè t ƒ ||¡ || jd< y| ¡ | jd< W n tk
rH d | jd< Y nX d| jkrˆy| ¡ | jd< W n tjk
r† d | jd< Y nX || _| ¡ | _
d| _ | |¡ || _
| ¡ | _d| _d| _| j
d k rØ| j
¡ | |j| j
< d S )Nr< ZsocknamerR Fr )r r Ú_extraZ getsocknamerH Z getpeernamer< Úerrorrž r9 rš Ú_protocol_connectedÚ set_protocolÚ_serverÚ_buffer_factoryÚ_bufferÚ
_conn_lostÚ_closingZ_attachr# )r$ rŽ r r( r% r& )r r r r L s,
z_SelectorTransport.__init__c C sÖ | j jg}| jd kr | d¡ n| jr0| d¡ | d| j› ¡ | jd k rÆ| j ¡ sÆt| jj | jt
j ƒ}|rz| d¡ n
| d¡ t| jj | jt
j ƒ}|r¢d}nd}|
¡ }| d|› d |› d
¡ d d |¡¡S )
NÚclosedÚclosingzfd=z read=pollingz read=idleÚpollingZidlezwrite=z<{}>ú )r r rž Úappendr´ rš Ú_loopr4 r r r ri rs Úget_write_buffer_sizeÚformatÚjoin)r$ Úinfor· ÚstateÚbufsizer r r Ú__repr__f s*
z_SelectorTransport.__repr__c C s | d ¡ d S )N)Ú _force_close)r$ r r r Úabort‚ s z_SelectorTransport.abortc C s || _ d| _d S )NT)Ú _protocolr® )r$ r( r r r r¯ … s z _SelectorTransport.set_protocolc C s | j S )N)rÅ )r$ r r r Ú get_protocol‰ s z _SelectorTransport.get_protocolc C s | j S )N)r´ )r$ r r r rd Œ s z _SelectorTransport.is_closingc C sT | j r
d S d| _ | j | j¡ | jsP| jd7 _| j | j¡ | j | jd ¡ d S )NTr ) r´ r» r7 rš r² r³ ru Ú call_soonÚ_call_connection_lost)r$ r r r r6 s z_SelectorTransport.closec C s. | j d k r*tjd| ›t| d | j ¡ d S )Nzunclosed transport )Úsource)rž ÚwarningsÚwarnÚResourceWarningr6 )r$ r r r Ú__del__™ s
z_SelectorTransport.__del__úFatal error on transportc C sN t |tƒr(| j ¡ r@tjd| |dd n| j ||| | jdœ¡ | |¡ d S )Nz%r: %sT)rF )rP rQ r] r( ) r rH r» Ú get_debugr r rW rÅ rà )r$ r\ rP r r r Ú _fatal_errorŸ s
z _SelectorTransport._fatal_errorc C sd | j r
d S | jr(| j ¡ | j | j¡ | jsBd| _| j | j¡ | j d7 _ | j | j |¡ d S )NTr )
r³ r² Úclearr» ru rš r´ r7 rÇ rÈ )r$ r\ r r r rà s
z _SelectorTransport._force_closec C sV z| j r| j |¡ W d | j ¡ d | _d | _d | _| j}|d k rP| ¡ d | _X d S )N)r® rÅ Zconnection_lostrž r6 r» r° Z_detach)r$ r\ r& r r r rÈ ¹ s
z(_SelectorTransport._call_connection_lostc C s
t | jƒS )N)rŠ r² )r$ r r r r¼ Ç s z(_SelectorTransport.get_write_buffer_sizec G s" | j r
d S | jj||f|žŽ d S )N)r´ r» r> )r$ r rl rm r r r r> Ê s z _SelectorTransport._add_reader)NN)rÎ )r r¨ r© Úmax_sizeÚ bytearrayr± rž r r rÄ r¯ rÆ rd r6 rÍ rÐ rà rÈ r¼ r> rª r r )r r r« @ s
r« c sª e Zd ZdZejjZd#‡ fdd„ Z‡ fdd„Z dd„ Z
d d
„ Z d d „ Z d
d„ Z
dd„ Zdd„ Zdd„ Zdd„ Zdd„ Zdd„ Zdd „ Z‡ fd d „Zd d „ Zd!d"„ Z‡ ZS )$r' TNc s~ d | _ tƒ |||||¡ d| _d| _d | _t | j¡ | j
| j j | ¡ | j
| j
| j| j¡ |d k rz| j
tj|d ¡ d S )NF)Ú_read_ready_cbr r Ú_eofÚ_pausedÚ
_empty_waiterr Z _set_nodelayrž r» rÇ rÅ Úconnection_mader> rš Ú _read_readyr Ú _set_result_unless_cancelled)r$ rŽ r r( r) r% r& )r r r r Ö s
z!_SelectorSocketTransport.__init__c s. t |tjƒr| j| _n| j| _tƒ |¡ d S )N)r r ZBufferedProtocolÚ_read_ready__get_bufferrÔ Ú_read_ready__data_receivedr r¯ )r$ r( )r r r r¯ í s
z%_SelectorSocketTransport.set_protocolc C s | j o| j S )N)rÖ r´ )r$ r r r r› õ s z#_SelectorSocketTransport.is_readingc C s> | j s | jrd S d| _| j | j¡ | j ¡ r:t d| ¡ d S )NTz%r pauses reading)r´ rÖ r» r7 rš rÏ r r )r$ r r r rœ ø s
z&_SelectorSocketTransport.pause_readingc C s@ | j s | jsd S d| _| | j| j¡ | j ¡ r rš rÙ r» rÏ r r )r$ r r r r s
z'_SelectorSocketTransport.resume_readingc C s | ¡ d S )N)rÔ )r$ r r r rÙ s z$_SelectorSocketTransport._read_readyc
C s | j r
d S y | j d¡}t|ƒs(tdƒ‚W n. tk
rX } z| |d¡ d S d }~X Y nX y| j |¡}W nD t t
fk
r‚ d S tk
r® } z| |d¡ d S d }~X Y nX |sÀ| ¡ d S y| j |¡ W n0 tk
r } z| |d¡ W d d }~X Y nX d S )Néÿÿÿÿz%get_buffer() returned an empty bufferz/Fatal error: protocol.get_buffer() call failed.z$Fatal read error on socket transportz3Fatal error: protocol.buffer_updated() call failed.)
r³ rÅ Z
get_bufferrŠ r3 r_ rÐ rž r† rD rC Ú_read_ready__on_eofZbuffer_updated)r$ r„ r\ r‡ r r r rÛ s2 z0_SelectorSocketTransport._read_ready__get_bufferc
C s¶ | j r
d S y| j | j¡}W nD ttfk
r4 d S tk
r` } z| |d¡ d S d }~X Y nX |sr| ¡ d S y| j
|¡ W n. tk
r° } z| |d¡ W d d }~X Y nX d S )Nz$Fatal read error on socket transportz2Fatal error: protocol.data_received() call failed.) r³ rž rB rÒ rD rC r_ rÐ rÞ rÅ Z
data_received)r$ r@ r\ r r r rÜ * s" z3_SelectorSocketTransport._read_ready__data_receivedc
C st | j ¡ rt d| ¡ y| j ¡ }W n. tk
rR } z| |d¡ d S d }~X Y nX |rh| j | j ¡ n|
¡ d S )Nz%r received EOFz1Fatal error: protocol.eof_received() call failed.) r» rÏ r r rÅ Z eof_receivedr_ rÐ r7 rš r6 )r$ Z keep_openr\ r r r rÞ ? s
z,_SelectorSocketTransport._read_ready__on_eofc
C s t |tttfƒs$tdt|ƒj›ƒ‚| jr2tdƒ‚| j d k rDtdƒ‚|sLd S | j
rz| j
t j krht
d¡ | j
d7 _
d S | j sþy| j |¡}W nD ttfk
rª Y nB tk
rÖ } z| |d¡ d S d }~X Y nX ||d … }|sìd S | j | j| j¡ | j |¡ | ¡ d S )Nz/data argument must be a bytes-like object, not z%Cannot call write() after write_eof()z(unable to write; sendfile is in progressz socket.send() raised exception.r z%Fatal write error on socket transport) r ÚbytesrÓ Ú
memoryviewr Útyper rÕ r3 r× r³ r Ú!LOG_THRESHOLD_FOR_CONNLOST_WRITESr Úwarningr² rž rG rD rC r_ rÐ r» rt rš Ú _write_readyÚextendÚ_maybe_pause_protocol)r$ r@ r| r\ r r r ÚwriteR s6
z _SelectorSocketTransport.writec
C sü | j r
d S y| j | j¡}W nr ttfk
r4 Y nÄ tk
rŽ } z>| j | j ¡ | j
¡ | |d¡ | j d k r~| j
|¡ W d d }~X Y njX |r | jd |…= | ¡ | jsø| j | j ¡ | j d k rÒ| j d ¡ | jrä| d ¡ n| jrø| j tj¡ d S )Nz%Fatal write error on socket transport)r³ rž rG r² rD rC r_ r» ru rš rÑ rÐ r× r€ Ú_maybe_resume_protocolr r´ rÈ rÕ Úshutdownr< ÚSHUT_WR)r$ r| r\ r r r rä w s.
z%_SelectorSocketTransport._write_readyc C s. | j s | jrd S d| _| js*| j tj¡ d S )NT)r´ rÕ r² rž ré r< rê )r$ r r r Ú write_eof“ s
z"_SelectorSocketTransport.write_eofc C s dS )NTr )r$ r r r Ú
can_write_eofš s z&_SelectorSocketTransport.can_write_eofc s* t ƒ |¡ | jd k r&| j tdƒ¡ d S )Nz Connection is closed by peer)r rÈ r× r€ ÚConnectionError)r$ r\ )r r r rÈ s
z._SelectorSocketTransport._call_connection_lostc C s6 | j d k rtdƒ‚| j ¡ | _ | js0| j d ¡ | j S )NzEmpty waiter is already set)r× r3 r» r^ r² r )r$ r r r r £ s
z+_SelectorSocketTransport._make_empty_waiterc C s
d | _ d S )N)r× )r$ r r r rŸ « s z,_SelectorSocketTransport._reset_empty_waiter)NNN)r r¨ r© Z_start_tls_compatibler Z
_SendfileModeZ
TRY_NATIVEZ_sendfile_compatibler r¯ r› rœ r rÙ rÛ rÜ rÞ rç rä rë rì rÈ r rŸ rª r r )r r r' Ñ s& % r' c sF e Zd ZejZd ‡ fdd„ Zdd„ Zdd„ Zd
dd „Z d
d „ Z
‡ Z S )r0 Nc s^ t ƒ ||||¡ || _| j | jj| ¡ | j | j| j| j ¡ |d k rZ| j t
j |d ¡ d S )N) r r Ú_addressr» rÇ rÅ rØ r> rš rÙ r rÚ )r$ rŽ r r( r1 r) r% )r r r r ³ s
z#_SelectorDatagramTransport.__init__c C s t dd„ | jD ƒƒS )Nc s s | ]\}}t |ƒV qd S )N)rŠ )Ú.0r@ rY r r r ú Á s zC_SelectorDatagramTransport.get_write_buffer_size..)Úsumr² )r$ r r r r¼ À s z0_SelectorDatagramTransport.get_write_buffer_sizec
C s¤ | j r
d S y| j | j¡\}}W np ttfk
r8 Y nh tk
rd } z| j |¡ W d d }~X Y n< t k
r } z|
|d¡ W d d }~X Y nX | j ||¡ d S )Nz&Fatal read error on datagram transport) r³ rž ZrecvfromrÒ rD rC rH rÅ Úerror_receivedr_ rÐ Zdatagram_received)r$ r@ r[ r\ r r r rÙ Ã s z&_SelectorDatagramTransport._read_readyc
C sd t |tttfƒs$tdt|ƒj›ƒ‚|s,d S | jrV|d | jfkrPtd| j› ƒ‚| j}| j rŠ| jrŠ| j t
j krxt
d¡ | j d7 _ d S | jsDy*| jd r¬| j |¡ n| j ||¡ d S ttfk
ræ | j | j| j¡ Y n^ tk
r } z| j |¡ d S d }~X Y n0 t k
rB } z| |d¡ d S d }~X Y nX | j t|ƒ|f¡ | ¡ d S )Nz/data argument must be a bytes-like object, not z!Invalid address: must be None or z socket.send() raised exception.r rR z'Fatal write error on datagram transport) r rß rÓ rà r rá r rî rc r³ r râ r rã r² r¬ rž rG ÚsendtorD rC r» rt rš Ú
_sendto_readyrH rÅ rò r_ rÐ rº ræ )r$ r@ r[ r\ r r r ró Ñ s>
z!_SelectorDatagramTransport.sendtoc
C sø xÆ| j rÆ| j ¡ \}}y*| jd r0| j |¡ n| j ||¡ W q ttfk
rj | j ||f¡ P Y q t k
r– } z| j
|¡ d S d }~X Y q t k
r } z|
|d¡ d S d }~X Y qX qW | ¡ | j sô| j | j¡ | jrô| d ¡ d S )NrR z'Fatal write error on datagram transport)r² Úpopleftr¬ rž rG ró rD rC Ú
appendleftrH rÅ rò r_ rÐ rè r» ru rš r´ rÈ )r$ r@ r[ r\ r r r rô ú s*
z(_SelectorDatagramTransport._sendto_ready)NNN)N) r r¨ r© Ú collectionsÚdequer± r r¼ rÙ ró rô rª r r )r r r0 ¯ s
)r0 ) Ú__all__r÷ rV r’ r r< rÊ r" r Ú ImportErrorÚ r r r r r r r
Úlogr r r Z
BaseEventLoopr Z_FlowControlMixinZ Transportr« r' r0 r r r r Ú s@
_