a
´iLš ã @ 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ÚfdÚeventÚkey© r ú//usr/lib64/python3.9/asyncio/selector_events.pyÚ_test_selector_event s
r c sŽ e Zd ZdR‡ fdd„ ZdSdddœdd„ZdTddddejdœd d
„ZdUd d „Z‡ fd
d„Z dd„ Z
dd„ Z dd„ Z dd„ Z
dd„ Zdddejfdd„Zdddejfd d „Zddejfd d „Zd d!„ Zd"d#„ Zd$d%„ Zd&d'„ Zd(d)„ Zd*d+„ Zd,d-„ Zd.d/„ Zd0d1„ Zd2d3„ ZdVd4d5„Z d6d7„ Z d8d9„ Z d:d;„ Z dd?„ 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__Ú selectorsÚDefaultSelectorr ÚdebugÚ __class__Ú__name__Ú _selectorÚ_make_self_pipeÚweakrefÚWeakValueDictionaryÚ _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)r1 r& )r Z SSLProtocolr* Z_app_transport) r$ Zrawsockr, Ú
sslcontextr- r/ r0 r' r( r1 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 r: R s
zBaseSelectorEventLoop.closec C sB | | j ¡ ¡ | j ¡ d | _| j ¡ d | _| jd8 _d S )Nr )Ú_remove_readerÚ_ssockÚfilenor: Ú_csockÚ
_internal_fdsr; r r r r9 ] s
z&BaseSelectorEventLoop._close_self_pipec C sN t ¡ \| _| _| j d¡ | j d¡ | jd7 _| | j ¡ | j¡ d S )NFr ) ÚsocketÚ
socketpairr= r? Ú setblockingr@ Ú _add_readerr> Ú_read_from_selfr; 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= ÚrecvrH ÚInterruptedErrorÚBlockingIOErrorrF r r r rE 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$ Úcsockr r r Ú_write_to_self| s þz$BaseSelectorEventLoop._write_to_selféd c
C s" | | ¡ | j||||||¡ d S r) )rD r> Ú_accept_connection)r$ Úprotocol_factoryr+ r2 r( Úbacklogr1 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Ú exceptionrA Úpeername)ÚrangeÚacceptrQ r r rC rK rJ ÚConnectionAbortedErrorrP ÚerrnoZEMFILEZENFILEZENOBUFSZENOMEMÚcall_exception_handlerr ÚTransportSocketr< r> Z
call_laterr ZACCEPT_RETRY_DELAYrX Ú_accept_connection2Z create_task)
r$ rV r+ r2 r( rW r1 Ú_ÚconnÚaddrÚexcr' r] r r r rU • 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( r1 )r- r' r( z3Error on transport creation for incoming connection)rY rZ r, Ú transport) Ú
create_futurer3 r. Ú
BaseExceptionr: Ú
SystemExitÚKeyboardInterruptrQ r` ) r$ rV rd r' r2 r( r1 r, rg r- rf Úcontextr r r rb Á 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_closingr7 )r$ r r> rg 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_READrG ÚmodifyÚcancel© r$ r ÚcallbackÚargsÚhandler ÚmaskÚreaderÚwriterr r r rD ü 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) r8 r r r r rG r rw Ú
unregisterrx ry ©r$ r r r~ r r€ r r r r< 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) ) rt r ru r r r rv r Ú EVENT_WRITErG rx ry rz 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 ) r8 r r r r rG r r„ r‚ rx ry rƒ r r r Ú_remove_writer1 s z$BaseSelectorEventLoop._remove_writerc G s" | |¡ | j||g|¢R Ž d S r) )rs rD ©r$ r r{ r| r r r Ú
add_readerH s
z BaseSelectorEventLoop.add_readerc C s | |¡ | |¡S r) )rs r< ©r$ r r r r Ú
remove_readerM s
z#BaseSelectorEventLoop.remove_readerc G s" | |¡ | j||g|¢R Ž d S r) )rs r… r‡ r r r Ú
add_writerR s
z BaseSelectorEventLoop.add_writerc C s | |¡ | |¡S r) )rs 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©r} )r Ú_check_ssl_socketrQ Ú
gettimeoutrq rI rK rJ rh r> rs rD Ú
_sock_recvÚadd_done_callbackÚ functoolsÚpartialÚ_sock_read_done)r$ r+ ÚnÚfutr r} r r r Ú sock_recv\ s
ÿz BaseSelectorEventLoop.sock_recvc C s |d u s| ¡ s| |¡ d S r) )Ú cancelledrŠ ©r$ r r˜ r} 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) ) ÚdonerI rK rJ rj rk ri Ú
set_exceptionÚ
set_result)r$ r˜ r+ r— rG rf 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 rQ r‘ rq Ú recv_intorK rJ rh r> rs rD Ú_sock_recv_intor“ r” r• r– )r$ r+ Úbufr˜ r r} 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Ÿ rK rJ rj rk ri r rž )r$ r˜ r+ r¡ Únbytesrf 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 rQ r‘ rq rO rK rJ Úlenrh r> rs r… Ú
_sock_sendallÚ
memoryviewr“ r” r• Ú_sock_write_done)r$ r+ rG r— r˜ r r} 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œ rO rK rJ rj rk ri r r¤ rž )r$ r˜ r+ ÚviewÚposÚstartr— rf 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 rQ r‘ rq r¬ rA ÚAF_INETZ _HAS_IPv6ÚAF_INET6Z_ensure_resolvedr r® rh Ú
_sock_connect)r$ r+ r5 Zresolvedrc 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> ÚconnectrK rJ rs r… Ú_sock_connect_cbr“ r” r• r§ rj rk ri r rž )r$ r˜ r+ r5 r r} rf 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œ Ú
getsockoptrA Ú
SOL_SOCKETÚSO_ERRORrP rK rJ rj rk ri r rž )r$ r˜ r+ r5 Úerrrf r r r rµ s z&BaseSelectorEventLoop._sock_connect_cbc à sB t |¡ | jr$| ¡ dkr$tdƒ‚| ¡ }| ||¡ |I d H S )Nr rŽ )r r rQ r‘ rq rh Ú _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> r] rC rK rJ rs rD rº r“ r” r• r– rj rk ri r rž )r$ r˜ r+ r rd r5 r} rf 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)Ú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_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) ) ÚfileobjrG r rw Z
_cancelledr< Z
_add_callbackr„ r† )r$ Z
event_listr r~ rÈ r r€ r r r Ú_process_eventsP s
z%BaseSelectorEventLoop._process_eventsc C s | | ¡ ¡ | ¡ d S r) )r< r> r: )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_TIMEOUTr3 r6 r: r9 r rH rE rS rX rU rb rs rD r< 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 )NrA Zsocknamer[ Fr )r r r ra Ú_extraÚ getsocknamerP Ú getpeernamerA Ú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½ Ú_loopr8 r r r rw 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_closer; 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ë r; r r r Ú get_protocol¬ s z _SelectorTransport.get_protocolc C s | j S r) )rÙ r; r r r rr ¯ 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à r< r½ r× rØ r† Ú call_soonÚ_call_connection_lostr; r r r r: ² s z_SelectorTransport.closec C s, | j d ur(|d| ›t| d | j ¡ d S )Nzunclosed transport )Úsource)rÁ ÚResourceWarningr: )r$ Ú_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: %sTrM )rY rZ rg r, ) rm rP rà Ú get_debugr r r` rë rè )r$ rf rY 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Ù r< rï rð ©r$ rf 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Á r: rà rÕ Z_detach)r$ rf r( r r r rð Û s&
ù
z(_SelectorTransport._call_connection_lostc C s
t | jƒS r) )r¤ r× r; 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à rD r‡ r r r rD ì s z _SelectorTransport._add_reader)NN)rõ )r rË rÌ Úmax_sizeÚ bytearrayrÖ rÁ r rç ré rÔ rí rr r: ÚwarningsÚwarnrô r÷ rè rð rá rD 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_maderD 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) )rm 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Ù 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à r< 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 ÿ
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Á rO r× rK rJ rj rk ri rà r† r½ rø r÷ r r Ú_maybe_resume_protocolrž rÙ rð rÿ ÚshutdownrA ÚSHUT_WR)r$ r— rf 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 rA r r; r r r Ú write_eofÅ s
z"_SelectorSocketTransport.write_eofc C s dS rê r r; 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 r7 rà rh r× rž r; r r r rÀ Õ s
z+_SelectorSocketTransport._make_empty_waiterc C s
d | _ d S r) )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 )r4 Nc s^ t ƒ ||||¡ || _| j | jj| ¡ | j | j| j| j ¡ |d urZ| j t
j |d ¡ d S r) ) r r Ú_addressrà rï rë r rD r½ r r r )r$ r¯ r+ r, r5 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¤ )Ú.0rG rc r r r Ú ó ó 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 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Á Úrecvfromrú rK rJ rP rë Úerror_receivedrj rk ri r÷ Zdatagram_received©r$ rG re rf 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 r[ ú'Fatal write error on datagram transport)"rm r
rû r¦ rp r r r rq rØ r r r r r× rÏ rÁ rO ÚsendtorK rJ rà r… r½ Ú
_sendto_readyrP rë r rj rk ri 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 )Nr[ r" )r× ÚpopleftrÏ rÁ rO r# rK rJ Ú
appendleftrP rë r rj rk ri 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 r4 á s ÿ
+r4 ) Ú__all__r' r_ r” r rA rü r! ZsslÚ ImportErrorÚ r r r r r r r
r Úlogr r Z
BaseEventLoopr Z_FlowControlMixinZ TransportrÎ r* r4 r r r r Ú sB
<ÿ o