a
XC?hLš ã @ s d Z ddlZddlZddlZddlZddlZddlZddlZz ddlZW n e y^ dZY n0 ddl
m Z ddl
m Z ddl
m
Z
ddl
mZ ddl
mZ dd l
mZ dd
l
mZ dd l
mZ dd lmZ d
d„ 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)Útrsock)Úloggerc C s6 z| |¡}W n ty" Y dS 0 t|j|@ ƒS d S ©NF)Úget_keyÚKeyErrorÚboolr )ÚselectorÚfdZeventÚkey© r úd?„ Z!d@dA„ Z"dBdC„ Z#dWdDdE„Z$dFdG„ Z%dHdI„ Z&dJdK„ Z'dLdM„ Z(dNdO„ Z)dPdQ„ Z*‡ Z+S )Xr Nc sF t ƒ ¡ |d u rt ¡ }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 1 s
z BaseSelectorEventLoop.__init__©ÚextraÚserverc C s t | |||||ƒS ©N)Ú_SelectorSocketTransport)r! ÚsockÚ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 Z SSLProtocolr' Z_app_transport) r! Zrawsockr) Ú
sslcontextr* r, r- r$ r% r. Z ssl_protocolr r r Ú_make_ssl_transport@ s ýÿz)BaseSelectorEventLoop._make_ssl_transportc C s t | |||||ƒS r& )Ú_SelectorDatagramTransport)r! r( r) Úaddressr* r$ r r r Ú_make_datagram_transportM s ÿz.BaseSelectorEventLoop._make_datagram_transportc sL | ¡ rtdƒ‚| ¡ r d S | ¡ tƒ ¡ | jd urH| 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 r7 R s
zBaseSelectorEventLoop.closec C sB | | j ¡ ¡ | j ¡ d | _| j ¡ d | _| jd8 _d S )Nr )Ú_remove_readerÚ_ssockÚfilenor7 Ú_csockÚ
_internal_fdsr8 r r r r6 ] s
z&BaseSelectorEventLoop._close_self_pipec C sN t ¡ \| _| _| j d¡ | j d¡ | jd7 _| | j ¡ | j¡ d S )NFr ) ÚsocketZ
socketpairr: r< Ú setblockingr= Ú _add_readerr; Ú_read_from_selfr8 r r r r e s
z%BaseSelectorEventLoop._make_self_pipec C s d S r& r ©r! Údatar r r Ú_process_self_datam s z(BaseSelectorEventLoop._process_self_datac C sT z"| j d¡}|sW qP| |¡ W q ty8 Y q Y q tyL Y qPY q 0 q d S )Ni )r: ÚrecvrD ÚInterruptedErrorÚBlockingIOErrorrB r r r rA p s z%BaseSelectorEventLoop._read_from_selfc C sL | j }|d u rd S z| d¡ W n& tyF | jrBtjddd Y n0 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 r& )r@ r; Ú_accept_connection)r! Úprotocol_factoryr( r/ r% Úbacklogr. r r r Ú_start_servingŽ s
þz$BaseSelectorEventLoop._start_servingc
C s t |ƒD ]ú}z0| ¡ \}} | jr0t d|| |¡ | d¡ W nž tttfyX Y d S t yÚ }
zl|
j
t
j t
j t
j
t
jfv rÄ| d|
t |¡dœ¡ | | ¡ ¡ | tj| j||||||¡ n‚ W Y d }
~
qd }
~
0 0 d| i} | ||| |||¡} | | ¡ qd S )Nz#%r got a new connection from %r: %rFz&socket.accept() out of system resource)ÚmessageÚ exceptionr> Úpeername)ÚrangeÚacceptrM r r r? rG rF ÚConnectionAbortedErrorrL ÚerrnoZEMFILEZENFILEZENOBUFSZENOMEMÚcall_exception_handlerr ÚTransportSocketr9 r; Z
call_laterr ZACCEPT_RETRY_DELAYrS Ú_accept_connection2Z create_task)
r! rQ r( r/ r% rR r. Ú_ÚconnÚaddrÚexcr$ rX r r r rP • s@ ÿ ÿýý
þz(BaseSelectorEventLoop._accept_connectionc
à sô d }d }zr|ƒ }| ¡ } |r8| j|||| d|||d}n| j||| ||d}z| I d H W n tyv | ¡ ‚ Y n0 W nt ttfy’ ‚ Y n^ tyî }
zF| jrÚd|
dœ} |d urÀ|| d< |d urÐ|| d< | | ¡ W Y d }
~
n
d }
~
0 0 d S )NT)r* r, r$ r% r. )r* r$ r% z3Error on transport creation for incoming connection)rT rU r) Ú transport) Ú
create_futurer0 r+ Ú
BaseExceptionr7 Ú
SystemExitÚKeyboardInterruptrM r[ ) r! rQ r_ r$ r/ r% r. r) rb r* ra Úcontextr r r r] Á s@ ýþ ýz)BaseSelectorEventLoop._accept_connection2c
C sŠ |}t |tƒsHzt| ¡ ƒ}W n( tttfyF td|›ƒd ‚Y n0 z| j| }W n tyh Y n 0 | ¡ s†t d|›d|›ƒ‚d S )NzInvalid file object: zFile descriptor z is used by transport )
Ú
isinstanceÚintr; ÚAttributeErrorÚ TypeErrorÚ
ValueErrorr r Ú
is_closingr4 )r! r r; rb r r r Ú_ensure_fd_no_transportê s
ÿÿz-BaseSelectorEventLoop._ensure_fd_no_transportc G s’ | ¡ t ||| d ¡}z| j |¡}W n( tyP | j |tj|d f¡ Y n>0 |j|j }\}}| j
||tjB ||f¡ |d urŽ| ¡ |S r& ) Ú
_check_closedr ÚHandler r r Úregisterr Ú
EVENT_READrC ÚmodifyÚcancel© r! r ÚcallbackÚargsÚhandler ÚmaskÚreaderÚwriterr r r r@ ü s ÿ
ÿz!BaseSelectorEventLoop._add_readerc C s’ | ¡ r dS z| j |¡}W n ty0 Y dS 0 |j|j }\}}|tj M }|sb| j |¡ n| j ||d |f¡ |d urŠ|
¡ dS dS d S ©NFT) r5 r r r r rC r rr Ú
unregisterrs rt ©r! r r ry rz r{ r r r r9 s z$BaseSelectorEventLoop._remove_readerc G s’ | ¡ t ||| d ¡}z| j |¡}W n( tyP | j |tjd |f¡ Y n>0 |j|j }\}}| j
||tjB ||f¡ |d urŽ| ¡ |S r& ) ro r rp r r r rq r Ú EVENT_WRITErC rs rt ru r r r Ú _add_writer! s ÿ
ÿz!BaseSelectorEventLoop._add_writerc C s’ | ¡ r dS z| j |¡}W n ty0 Y dS 0 |j|j }\}}|tj M }|sb| j |¡ n| j |||d f¡ |d urŠ|
¡ dS dS d S r| ) r5 r r r r rC r r r} rs rt r~ r r r Ú_remove_writer1 s z$BaseSelectorEventLoop._remove_writerc G s" | |¡ | j||g|¢R Ž d S r& )rn r@ ©r! r rv rw r r r Ú
add_readerH s
z BaseSelectorEventLoop.add_readerc C s | |¡ | |¡S r& )rn r9 ©r! r r r r Ú
remove_readerM s
z#BaseSelectorEventLoop.remove_readerc G s" | |¡ | j||g|¢R Ž d S r& )rn r€ r‚ r r r Ú
add_writerR s
z BaseSelectorEventLoop.add_writerc C s | |¡ | |¡S r& )rn r r„ r r r Ú
remove_writerW s
z#BaseSelectorEventLoop.remove_writerc à s˜ t |¡ | jr$| ¡ dkr$tdƒ‚z | |¡W S ttfyF Y n0 | ¡ }| ¡ }|
|¡ | || j |||¡}|
tj| j||d¡ |I d H S ©Nr ú the socket must be non-blocking©rx )r Ú_check_ssl_socketrM Ú
gettimeoutrl rE rG rF rc r; rn r@ Ú
_sock_recvÚadd_done_callbackÚ functoolsÚpartialÚ_sock_read_done)r! r( ÚnÚfutr rx r r r Ú sock_recv\ s
ÿz BaseSelectorEventLoop.sock_recvc C s |d u s| ¡ s| |¡ d S r& )Ú cancelledr… ©r! r r“ rx r r r r‘ r s z%BaseSelectorEventLoop._sock_read_donec
C s„ | ¡ r d S z| |¡}W nZ ttfy2 Y d S ttfyH ‚ Y n8 tyt } z| |¡ W Y d }~nd }~0 0 | |¡ d S r& ) ÚdonerE rG rF re rf rd Ú
set_exceptionÚ
set_result)r! r“ r( r’ rC ra r r r r v s z BaseSelectorEventLoop._sock_recvc à s˜ t |¡ | jr$| ¡ dkr$tdƒ‚z | |¡W S ttfyF Y n0 | ¡ }| ¡ }|
|¡ | || j |||¡}|
tj| j||d¡ |I d H S rˆ )r r‹ rM rŒ rl Ú recv_intorG rF rc r; rn r@ Ú_sock_recv_intorŽ r r r‘ )r! r( Úbufr“ r rx r r r Úsock_recv_into† s
ÿz$BaseSelectorEventLoop.sock_recv_intoc
C s„ | ¡ r d S z| |¡}W nZ ttfy2 Y d S ttfyH ‚ Y n8 tyt } z| |¡ W Y d }~nd }~0 0 | |¡ d S r& ) r— rš rG rF re rf rd r˜ r™ )r! r“ r( rœ Únbytesra r r r r› › s z%BaseSelectorEventLoop._sock_recv_intoc à s¶ t |¡ | jr$| ¡ dkr$tdƒ‚z| |¡}W n ttfyL d}Y n0 |t|ƒkr^d S | ¡ }|
¡ }| |¡ | || j
||t|ƒ|g¡}| tj| j||d¡ |I d H S rˆ )r r‹ rM rŒ rl rK rG rF Úlenrc r; rn r€ Ú
_sock_sendallÚ
memoryviewrŽ r r Ú_sock_write_done)r! r( rC r’ r“ r rx r r r Ú sock_sendall¬ s&
ÿÿz"BaseSelectorEventLoop.sock_sendallc
C s´ | ¡ r d S |d }z| ||d … ¡}W n\ ttfyB Y d S ttfyX ‚ Y n0 ty† } z| |¡ W Y d }~d S d }~0 0 ||7 }|t|ƒkr¨| d ¡ n||d< d S )Nr )
r— rK rG rF re rf rd r˜ rŸ r™ )r! r“ r( ZviewÚposÚstartr’ ra r r r r Ë s
z#BaseSelectorEventLoop._sock_sendallc à s” t |¡ | jr$| ¡ dkr$tdƒ‚|jtjksBt jrt|jtj krt| j
||j|j |j | dI d H }|d \}}}}}|
¡ }| |||¡ |I d H S )Nr r‰ )ÚfamilyÚtypeÚprotoÚloop)r r‹ rM rŒ rl r¦ r> ZAF_INETZ _HAS_IPv6ZAF_INET6Z_ensure_resolvedr§ r¨ rc Ú
_sock_connect)r! r( r2 Zresolvedr^ r“ r r r Ú sock_connectá s
ÿ
ÿþ z"BaseSelectorEventLoop.sock_connectc
C s´ | ¡ }z| |¡ W nŽ ttfyb | |¡ | || j|||¡}| tj | j
||d¡ Y nN t t fyx ‚ Y n8 t
y¤ } z| |¡ W Y d }~nd }~0 0 | d ¡ d S )NrŠ )r; ZconnectrG rF rn r€ Ú_sock_connect_cbrŽ r r r¢ re rf rd r˜ r™ )r! r“ r( r2 r rx ra r r r rª ö s
ÿÿ z#BaseSelectorEventLoop._sock_connectc C s |d u s| ¡ s| |¡ d S r& )r• r‡ r– r r r r¢ s z&BaseSelectorEventLoop._sock_write_donec
C s | ¡ r d S z,| tjtj¡}|dkr6t|d|› ƒ‚W nX ttfyN Y nN tt fyd ‚ Y n8 t
y } z| |¡ W Y d }~nd }~0 0 | d ¡ d S )Nr zConnect call failed )
r— Z
getsockoptr> Z
SOL_SOCKETZSO_ERRORrL rG rF re rf rd r˜ r™ )r! r“ r( r2 Úerrra r r r r¬ s z&BaseSelectorEventLoop._sock_connect_cbc à sB t |¡ | jr$| ¡ dkr$tdƒ‚| ¡ }| ||¡ |I d H S )Nr r‰ )r r‹ rM rŒ rl rc Ú _sock_accept)r! r( r“ r r r Ú sock_accept" s
z!BaseSelectorEventLoop.sock_acceptc
C s | ¡ }z| ¡ \}}| d¡ W nŒ ttfyl | |¡ | || j||¡}| t j
| j ||d¡ Y nR t t
fy‚ ‚ Y n< ty® } z| |¡ W Y d }~nd }~0 0 | ||f¡ d S )NFrŠ )r; rX r? rG rF rn r@ r® rŽ r r r‘ re rf rd r˜ r™ )r! r“ r( r r_ r2 rx ra r r r r® 1 s
ÿ z"BaseSelectorEventLoop._sock_acceptc à sœ | j |j= | ¡ }| ¡ | ¡ I d H zL| j|j|||ddI d H W | ¡ |rZ| ¡ || j |j< S || j |j< n"| ¡ |rŠ| ¡ || j |j< 0 d S )NF)Zfallback) 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_nativeB s*
ÿ ú ýz&BaseSelectorEventLoop._sendfile_nativec C s€ |D ]v\}}|j |j }\}}|tj@ rL|d urL|jrB| |¡ n
| |¡ |tj@ r|d ur|jrp| |¡ q| |¡ qd S r& ) ÚfileobjrC r rr Z
_cancelledr9 Z
_add_callbackr r )r! Z
event_listr ry r» rz r{ r r r Ú_process_eventsP s
z%BaseSelectorEventLoop._process_eventsc C s | | ¡ ¡ | ¡ d S r& )r9 r; r7 )r! r( r r r Ú
_stop_serving^ s z#BaseSelectorEventLoop._stop_serving)N)N)N)NNN)N)N),r Ú
__module__Ú __qualname__r r+ r ZSSL_HANDSHAKE_TIMEOUTr0 r3 r7 r6 r rD rA rN rS rP r] rn r@ r9 r€ r rƒ r… r† r‡ r” r‘ r r r› r£ r r« rª r¢ r¬ r¯ r® rº r¼ r½ Ú
__classcell__r r r" r r + sh
ÿ ÿü ÿ
þ
ý
.ý
)
r c s’ e Zd ZdZeZdZd ‡ fdd„ Zdd„ Zdd„ Z d d
„ Z
d d „ Z d
d„ Z dd„ Z
ejfdd„Zd dd„Zdd„ Zdd„ Zdd„ Zd d „ Z‡ ZS ) Ú_SelectorTransporti Nc sê t ƒ ||¡ t |¡| jd< z| ¡ | jd< W n tyL d | jd< Y n0 d| jvrŠz| ¡ | jd< W n tj yˆ d | jd< Y n0 || _
| ¡ | _ d| _
| |¡ || _| ¡ | _d| _d| _| jd urÚ| j ¡ | |j| j < d S )Nr> ZsocknamerV Fr )r r r r\ Ú_extraZ getsocknamerL Z getpeernamer> Úerrorr´ r; r° Ú_protocol_connectedÚ set_protocolÚ_serverÚ_buffer_factoryÚ_bufferÚ
_conn_lostÚ_closingZ_attachr )r! r© r( r) r$ r% r" r r r o s,
z_SelectorTransport.__init__c C sÖ | j jg}| jd u r | d¡ n| jr0| d¡ | d| j› ¡ | jd urÆ| 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° Ú_loopr5 r r r rr r Úget_write_buffer_sizeÚformatÚjoin)r! ÚinforÍ ÚstateÚbufsizer r r Ú__repr__‰ s.
ÿ
þz_SelectorTransport.__repr__c C s | d ¡ d S r& )Ú _force_closer8 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 r& )rÜ r8 r r r Ú get_protocol¬ s z _SelectorTransport.get_protocolc C s | j S r& )rÊ r8 r r r rm ¯ 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Ñ r9 r° rÈ rÉ r Ú call_soonÚ_call_connection_lostr8 r r r r7 ² s z_SelectorTransport.closec C s, | j d ur(|d| ›t| d | j ¡ d S )Nzunclosed transport )Úsource)r´ ÚResourceWarningr7 )r! Z_warnr 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: %sTrI )rT rU rb r) ) rh rL rÑ Ú get_debugr r r[ rÜ rÙ )r! ra rT 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 rß )
rÉ rÈ ÚclearrÑ r r° rÊ r9 rà rá ©r! ra r r r rÙ Ï s
z _SelectorTransport._force_closec C sŽ zN| j r| j |¡ W | j ¡ d | _d | _d | _| j}|d urŠ| ¡ d | _n:| j ¡ d | _d | _d | _| j}|d urˆ| ¡ d | _0 d S r& )rÄ rÜ Zconnection_lostr´ r7 rÑ rÆ Z_detach)r! ra r% r r r rá Û s&
ù
z(_SelectorTransport._call_connection_lostc C s
t | jƒS r& )rŸ rÈ r8 r r r rÒ é s z(_SelectorTransport.get_write_buffer_sizec G s$ | j r
d S | jj||g|¢R Ž d S r& )rÊ rÑ r@ r‚ r r r r@ ì s z _SelectorTransport._add_reader)NN)rå )r r¾ r¿ Úmax_sizeÚ bytearrayrÇ r´ r rØ rÚ rÅ rÞ rm r7 ÚwarningsÚwarnrä rç rÙ rá rÒ r@ rÀ r r r" r rÁ c 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 urz| j
tj|d ¡ d S r
)Ú_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 r& )rh r ZBufferedProtocolÚ_read_ready__get_bufferrî Ú_read_ready__data_receivedr rÅ rÝ r" r r rÅ s
z%_SelectorSocketTransport.set_protocolc C s | j o| j S r& )rð rÊ r8 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Ñ r9 r° ræ r r r8 r r r r² s
z&_SelectorSocketTransport.pause_readingc C s@ | j s | jsd S d| _| | j| j¡ | j ¡ r ÿ
z _SelectorSocketTransport.writec
C s | j r
d S z| j | j¡}W nˆ ttfy2 Y nà ttfyH ‚ Y nÊ ty¤ } zF| j
| j ¡ | j ¡ |
|d¡ | jd ur| j |¡ W Y d }~nvd }~0 0 |r¶| jd |…= | ¡ | js| j
| j ¡ | jd urê| j d ¡ | jrü| d ¡ n| jr| j tj¡ d S )Nrü )rÉ r´ rK rÈ rG rF re rf rd rÑ r r° rè rç rñ r˜ Ú_maybe_resume_protocolr™ rÊ rá rï Úshutdownr> ÚSHUT_WR)r! r’ ra r r r r § s2
"
z%_SelectorSocketTransport._write_readyc C s. | j s | jrd S d| _| js*| j tj¡ d S rÛ )rÊ rï rÈ r´ r r> r r8 r r r Ú write_eofÅ s
z"_SelectorSocketTransport.write_eofc C s dS rÛ r r8 r r r Ú
can_write_eofÌ s z&_SelectorSocketTransport.can_write_eofc s* t ƒ |¡ | jd ur&| j tdƒ¡ d S )Nz Connection is closed by peer)r rá rñ r˜ ÚConnectionErrorré r" r r rá Ï s
ÿz._SelectorSocketTransport._call_connection_lostc C s6 | j d urtdƒ‚| j ¡ | _ | js0| j d ¡ | j S )NzEmpty waiter is already set)rñ r4 rÑ rc rÈ r™ r8 r r r r³ Õ s
z+_SelectorSocketTransport._make_empty_waiterc C s
d | _ d S r& )rñ r8 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 )r1 Nc s^ t ƒ ||||¡ || _| j | jj| ¡ | j | j| j| j ¡ |d urZ| j t
j |d ¡ d S r& ) r r Ú_addressrÑ rà rÜ rò r@ r° ró r rô )r! r© r( r) r2 r* r$ r" r r r å s
ÿ
ÿz#_SelectorDatagramTransport.__init__c C s t dd„ | jD ƒƒS )Nc s s | ]\}}t |ƒV qd S r& )rŸ )Ú.0rC r^ r r r Ú ó ó zC_SelectorDatagramTransport.get_write_buffer_size..)ÚsumrÈ r8 r r r rÒ ò s z0_SelectorDatagramTransport.get_write_buffer_sizec
C s¼ | j r
d S z| j | j¡\}}W nˆ ttfy6 Y n‚ tyd } z| j |¡ W Y d }~n\d }~0 t t
fyz ‚ Y n> t y¨ } z| |d¡ W Y d }~nd }~0 0 | j
||¡ d S )Nz&Fatal read error on datagram transport)rÉ r´ Zrecvfromrê rG rF rL rÜ Úerror_receivedre rf rd rç Zdatagram_received©r! rC r` ra r r r ró õ s "z&_SelectorDatagramTransport._read_readyc
C s„ t |tttfƒs$tdt|ƒj›ƒ‚|s,d S | jrV|d | jfvrPtd| j› ƒ‚| j}| j rŠ| jrŠ| j t
j krxt
d¡ | j d7 _ d S | jsdz,| jd r¬| j |¡ n| j ||¡ W d S ttfyæ | j | j| j¡ Y n~ ty } z| j |¡ W Y d }~d S d }~0 t t fy0 ‚ Y n4 t yb } z| |d¡ W Y d }~d S d }~0 0 | j t|ƒ|f¡ | !¡ d S )Nrú z!Invalid address: must be None or rû r rV ú'Fatal write error on datagram transport)"rh rý rë r¡ rk r§ r r
rl rÉ r rþ r rÿ rÈ r r´ rK ÚsendtorG rF rÑ r€ r° Ú
_sendto_readyrL rÜ r re rf rd rç rÐ r r r r r r sJ ÿ
ÿ
ÿz!_SelectorDatagramTransport.sendtoc
C s | j râ| j ¡ \}}z*| jd r.| j |¡ n| j ||¡ W q ttfyh | j ||f¡ Y qâY q t y˜ } z| j
|¡ W Y d }~d S d }~0 t t
fy® ‚ Y q tyÞ } z| |d¡ W Y d }~d S d }~0 0 q | ¡ | j s| j | j¡ | jr| d ¡ d S )NrV r )rÈ Úpopleftr r´ rK r rG rF Ú
appendleftrL rÜ r re rf rd rç r rÑ r r° rÊ rá r r r r r 0 s0
ÿz(_SelectorDatagramTransport._sendto_ready)NNN)N) r r¾ r¿ Ú collectionsÚdequerÇ r rÒ ró r r rÀ r r r" r r1 á s ÿ
+r1 ) Ú__all__r rZ r r r> rì r ZsslÚ ImportErrorÚ r r r r r r r
r Úlogr r Z
BaseEventLoopr Z_FlowControlMixinZ TransportrÁ r' r1 r r r r Ú sB
<ÿ o