Operation   : Linux premium131.web-hosting.com 4.18.0-553.44.1.lve.el8.x86_64 #1 SMP Thu Mar 13 14:29:12 UTC 2025 x86_64
Software     : Apache
Server IP    : 162.0.232.56 | Your IP: 216.73.216.111
Domains      : 1034 Domain(s)
Permission   : [ 0755 ]

a

XC?hL��@s$
dZd
Z
ddlZddlZddlZddlZddlZddlZddlZzddl	Z	Wne
yb


dZ	Yn0ddlmZ
ddlm
Z

ddlmZ
ddlmZ
dd	lmZ
dd
lmZ
ddlmZ
ddlmZ
dd
lmZ
dd�ZGdd�dej�ZGdd�dejej�ZGdd�de�ZGdd�de�ZdS)z�Event loop using a selector and related classes.

A selector is a "notify-when-ready" multiplexer.  For a subclass which
also includes support for signal handling, see the unix_events sub-module.
)
�BaseSelectorEventLoop�N�
)
�base_events)
�	constants)
�events)
�futures)
�	protocols)
�sslproto)
�
transports)
�trsock)
�loggercCs6z|�|
�
}Wnt
y"


Yd
S0t|j|@�
SdS�NF)�get_key�KeyError�boolr)�selector�fdZevent�key�r�</opt/alt/python39/lib64/python3.9/asyncio/selector_events.py�_test_selector_event s



rcs�
eZ
dZd
ZdS�f
dd�	ZdTddd�dd�ZdUddddejd	�d
d�ZdVdd
�
Z	�f
dd�Z
dd�Zdd�Zdd�Z
dd�Zdd�Zdddejfdd�
Zdddejfdd�
Zddejfdd �
Zd!d"�Zd#d$�Zd%d&�Zd'd(�Zd)d*�Zd+d,�Zd-d.�Zd/d0�Zd1d2�Zd3d4�ZdWd5d6�
Zd7d8�Zd9d:�Zd;d<�Z d=d>�Z!d?d@�Z"dAdB�Z#dCdD�Z$dXdEdF�
Z%dGdH�Z&dIdJ�Z'dKdL�Z(dMdN�Z)dOdP�Z*dQdR�Z+�Z,S)Yr
zJSelector event loop.

    See events.EventLoop for API specification.
    NcsFt��
�
|
durt��}
t�d
|
jj�
|
|_|�	�
t
��|_dS)NzUsing selector: %s)
�super�__init__�	selectorsZDefaultSelectorr�debug�	__class__�__name__�	_selector�_make_self_pipe�weakrefZWeakValueDictionary�_transports)�selfr�
rrrr1s






zBaseSelectorEventLoop.__init__��extra�servercCst||
||||�S�
N)
�_SelectorSocketTransport)r!�sock�protocol�waiterr$r%rrr�_make_socket_transport;s

�z,BaseSelectorEventLoop._make_socket_transportF)�server_side�server_hostnamer$r%�ssl_handshake_timeoutc	Cs0tj
|||||||	d
�}
t||
|
||d�
|
jS)N)
r.r#)r	ZSSLProtocolr'Z_app_transport)r!Zrawsockr)�
sslcontextr*r,r-r$r%r.Zssl_protocolrrr�_make_ssl_transport@s


�
�z)BaseSelectorEventLoop._make_ssl_transportcCst||
||||�Sr&)
�_SelectorDatagramTransport)r!r(r)�addressr*r$rrr�_make_datagram_transportMs
�z.BaseSelectorEventLoop._make_datagram_transportc

sL|��rt
d
�
�
|��rdS|��
t���
|jdu
rH|j��
d|_dS)Nz!Cannot close a running event loop)Z
is_running�RuntimeError�	is_closed�_close_self_piper�closer�
r!r"rrr7Rs











zBaseSelectorEventLoop.closec

CsB|�|j
���

|j
��
d|_
|j��
d|_|jd
8_dS)Nr)�_remove_reader�_ssock�filenor7�_csock�
_internal_fdsr8rrrr6]s







z&BaseSelectorEventLoop._close_self_pipec

CsNt�
�\|_|_|j�d
�

|j�d
�

|jd7_|�|j��|j�
dS)NFr)	�socketZ
socketpairr:r<�setblockingr=�_add_readerr;�_read_from_selfr8rrrres




z%BaseSelectorEventLoop._make_self_pipec
CsdSr&r�r!�datarrr�_process_self_datams
z(BaseSelectorEventLoop._process_self_datac
CsTz"|j�
d
�
}
|
sWqP|�|
�

Wqty8


YqYqtyL


YqPYq0qdS)Ni)r:�recvrD�InterruptedError�BlockingIOErrorrBrrrrAps







z%BaseSelectorEventLoop._read_from_selfc
CsL|j}
|
durdSz|
�
d
�

Wn&tyF


|jrBtjddd�
Yn0dS)N�
z3Fail to write a null byte into the self-pipe socketT�
�exc_info)r<�send�OSError�_debugrr)r!Zcsockrrr�_write_to_self|s





�z$BaseSelectorEventLoop._write_to_self�dc
Cs"|�|�
�|j|
|||||�
dSr&)r@r;�_accept_connection)r!�protocol_factoryr(r/r%�backlogr.rrr�_start_serving�s


�z$BaseSelectorEventLoop._start_servingc
Cs
t|�
D]�}z0|�
�\}}	|jr0t�d
||	|�
|�d�

Wn�tttfyX


Y
dSt	y�
}

zl|
j
t
jt
jt
j
t
jfvr�|�d|
t�|�
d��

|�|���

|�tj|j|
|||||�
n�WYd}
~
qd}
~
00d|	i
}|�|
|||||�}|�|�

qdS)Nz#%r got a new connection from %r: %rFz&socket.accept() out of system resource)�message�	exceptionr>�peername)�range�acceptrMrrr?rGrF�ConnectionAbortedErrorrL�errnoZEMFILEZENFILEZENOBUFSZENOMEM�call_exception_handlerr�TransportSocketr9r;Z
call_laterrZACCEPT_RETRY_DELAYrS�_accept_connection2Zcreate_task)
r!rQr(r/r%rRr.�
_�conn�addr�excr$rXrrrrP�s@




�


�


�



�



�z(BaseSelectorEventLoop._accept_connectionc
�s�d}d}zr|
�}|��}	|r8|j
||||	d
|||d�}n|j|||	||d�}z|	IdH
Wntyv


|��
�Yn0Wntttfy�


�Yn^ty�
}

zF|jr�d|
d�}|du
r�||d<|du
r�||d<|�|�

WYd}
~
n
d}
~
00dS)NT)r*r,r$r%r.)r*r$r%z3Error on transport creation for incoming connection)rTrUr)�	transport)	�
create_futurer0r+�
BaseExceptionr7�
SystemExit�KeyboardInterruptrMr[)r!rQr_r$r/r%r.r)rbr*ra�contextrrrr]�s@








�

�







�



z)BaseSelectorEventLoop._accept_connection2c
Cs�|
}t|t
�sHzt
|���
}Wn(tttfyF


td
|
���
d�Yn0z|j|}Wntyh


Yn0|��s�t	d|
�d|���
�
dS)NzInvalid file object: zFile descriptor z is used by transport )
�
isinstance�intr;�AttributeError�	TypeError�
ValueErrorr r�
is_closingr4)r!rr;rbrrr�_ensure_fd_no_transport�s 












��z-BaseSelectorEventLoop._ensure_fd_no_transportc		Gs�|��
t
�|||d�}z|j�|
�
}Wn(tyP


|j�|
tj|df�
Yn>0|j
|j	}\}}|j�
|
|tjB||f�
|du
r�|��
|Sr&)�
_check_closedr�Handlerrr�registerr�
EVENT_READrC�modify�cancel�	r!r�callback�args�handler�mask�reader�writerrrrr@�s






�


�

z!BaseSelectorEventLoop._add_readercCs�|��rd
Sz|j
�|
�
}Wnty0


Yd
S0|j|j}\}}|tjM}|sb|j
�|
�

n|j
�	|
|d|f�
|du
r�|�
�
dSd
SdS)NFT)r5rrrrrCrrr�
unregisterrsrt�r!rrryrzr{rrrr9
s










z$BaseSelectorEventLoop._remove_readerc		Gs�|��
t
�|||d�}z|j�|
�
}Wn(tyP


|j�|
tjd|f�
Yn>0|j
|j	}\}}|j�
|
|tjB||f�
|du
r�|��
|Sr&)rorrprrrrqr�EVENT_WRITErCrsrtrurrr�_add_writer!
s






�


�

z!BaseSelectorEventLoop._add_writercCs�|��rd
Sz|j
�|
�
}Wnty0


Yd
S0|j|j}\}}|tjM}|sb|j
�|
�

n|j
�	|
||df�
|du
r�|�
�
dSd
SdS)�Remove a writer callback.FNT)r5rrrrrCrr~r|rsrtr}rrr�_remove_writer1
s








z$BaseSelectorEventLoop._remove_writercGs"|�|
�

|j
|
|g|�
R�
d
S)zAdd a reader callback.N)rnr@�r!rrvrwrrr�
add_readerH
s

z BaseSelectorEventLoop.add_readercCs|�|
�

|�
|
�
S)
zRemove a reader callback.)rnr9�r!rrrr�
remove_readerM
s

z#BaseSelectorEventLoop.remove_readercGs"|�|
�

|j
|
|g|�
R�
d
S)zAdd a writer callback..N)rnrr�rrr�
add_writerR
s

z BaseSelectorEventLoop.add_writercCs|�|
�

|�
|
�
S)
r�)rnr�r�rrr�
remove_writerW
s

z#BaseSelectorEventLoop.remove_writerc	�s�t�
|
�

|jr$|
��d
kr$td�
�
z|
�|�
WSttfyF


Yn0|��}|
�	�}|�
|�

|�||j||
|�}|�
tj|j||d��

|IdHS)z�Receive data from the socket.

        The return value is a bytes object representing the data received.
        The maximum amount of data to be received at once is specified by
        nbytes.
        r�the socket must be non-blocking�
rxN)r�_check_ssl_socketrM�
gettimeoutrlrErGrFrcr;rnr@�
_sock_recv�add_done_callback�	functools�partial�_sock_read_done)r!r(�
n�futrrxrrr�	sock_recv\
s













�zBaseSelectorEventLoop.sock_recvcCs|dus|��s|�
|
�

dSr&)�	cancelledr��r!rr�rxrrrr�r
s

z%BaseSelectorEventLoop._sock_read_donec
Cs�|
��rdSz|�
|�
}WnZttfy2


YdSttfyH


�Yn8tyt
}
z|
�|�

WYd}~nd}~00|
�|�

dSr&)	�donerErGrFrerfrd�
set_exception�
set_result)r!r�r(r�rCrarrrr�v
s








 z BaseSelectorEventLoop._sock_recvc	�s�t�
|
�

|jr$|
��d
kr$td�
�
z|
�|�
WSttfyF


Yn0|��}|
�	�}|�
|�

|�||j||
|�}|�
tj|j||d��

|IdHS)z�Receive data from the socket.

        The received data is written into *buf* (a writable buffer).
        The return value is the number of bytes written.
        rr�r�N)rr�rMr�rl�	recv_intorGrFrcr;rnr@�_sock_recv_intor�r�r�r�)r!r(�bufr�rrxrrr�sock_recv_into�
s













�z$BaseSelectorEventLoop.sock_recv_intoc
Cs�|
��rdSz|�
|�
}WnZttfy2


YdSttfyH


�Yn8tyt
}
z|
�|�

WYd}~nd}~00|
�|�

dSr&)	r�r�rGrFrerfrdr�r�)r!r�r(r��nbytesrarrrr��
s








 z%BaseSelectorEventLoop._sock_recv_intoc	�s�t�
|
�

|jr$|
��d
kr$td�
�
z|
�|�
}WnttfyL


d
}Yn0|t|�
kr^dS|�	�}|
�
�}|�|�

|�||j
||
t|�
|g
�}|�tj|j||d��

|IdHS)a�
Send data to the socket.

        The socket must be connected to a remote socket. This method continues
        to send data from data until either all data has been sent or an
        error occurs. None is returned on success. On error, an exception is
        raised, and there is no way to determine how much data, if any, was
        successfully processed by the receiving end of the connection.
        rr�Nr�)rr�rMr�rlrKrGrF�lenrcr;rnr�
_sock_sendall�
memoryviewr�r�r��_sock_write_done)r!r(rCr�r�rrxrrr�sock_sendall�
s&	












�
�z"BaseSelectorEventLoop.sock_sendallc
Cs�|
��rdS|d
}z|�
||d��
}Wn\ttfyB


YdSttfyX


�Yn0ty�
}
z|
�|�

WYd}~dSd}~00||7}|t|�
kr�|
�	d�

n||d
<dS)Nr)
r�rKrGrFrerfrdr�r�r�)r!r�r(Zview�pos�startr�rarrrr��
s 












z#BaseSelectorEventLoop._sock_sendallc�s�t�
|
�

|jr$|
��d
kr$td�
�
|
jtjksBtjrt|
jtj	krt|j
||
j|
j|
j|d�IdH}|d
\}}}}}|�
�}|�||
|�
|IdHS)zTConnect to a remote socket at address.

        This method is a coroutine.
        rr�)�family�type�proto�loopN)rr�rMr�rlr�r>ZAF_INETZ	_HAS_IPv6ZAF_INET6Z_ensure_resolvedr�r�rc�
_sock_connect)r!r(r2Zresolvedr^r�rrr�sock_connect�
s 



�

�

�

z"BaseSelectorEventLoop.sock_connectc
Cs�|��}z|�
|�

Wn�ttfyb


|�|�

|�||j|
||�}|
�tj	|j
||d
��

YnNttfyx


�Yn8t
y�
}
z|
�|�

WYd}~nd}~00|
�d�

dS)Nr�)r;ZconnectrGrFrnr�_sock_connect_cbr�r�r�r�rerfrdr�r�)r!r�r(r2rrxrarrrr��
s 






�
�


 z#BaseSelectorEventLoop._sock_connectcCs|dus|��s|�
|
�

dSr&)r�r�r�rrrr�s

z&BaseSelectorEventLoop._sock_write_donec
Cs�|
��rdSz,|�
tjtj�}|d
kr6t|d|����
WnXttfyN


YnNtt	fyd


�Yn8t
y�
}
z|
�|�

WYd}~nd}~00|
�d�

dS)NrzConnect call failed )
r�Z
getsockoptr>Z
SOL_SOCKETZSO_ERRORrLrGrFrerfrdr�r�)r!r�r(r2�errrarrrr�s








 z&BaseSelectorEventLoop._sock_connect_cbc�sBt�
|
�

|jr$|
��d
kr$td�
�
|��}|�||
�
|IdHS)aW
Accept a connection.

        The socket must be bound to an address and listening for connections.
        The return value is a pair (conn, address) where conn is a new socket
        object usable to send and receive data on the connection, and address
        is the address bound to the socket on the other end of the connection.
        rr�N)rr�rMr�rlrc�_sock_accept)r!r(r�rrr�sock_accept"s





z!BaseSelectorEventLoop.sock_acceptc
Cs�|��}z|�
�\}}|�d
�

Wn�ttfyl


|�|�

|�||j|
|�}|
�t	j
|j||d��

YnRtt
fy�


�Yn<ty�
}
z|
�|�

WYd}~nd}~00|
�||f�

dS)NFr�)r;rXr?rGrFrnr@r�r�r�r�r�rerfrdr�r�)r!r�r(rr_r2rxrarrrr�1s









�


 z"BaseSelectorEventLoop._sock_acceptc	�s�|j|
j
=|
��}|
��
|
��IdH
zL|j|
j|||d
d�IdHW|
��
|rZ|
��
|
|j|
j
<S|
|j|
j
<n"|
��
|r�|
��
|
|j|
j
<0dS)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�rrr�_sendfile_nativeBs*







�


�


�


z&BaseSelectorEventLoop._sendfile_nativecCs�|
D]v\}}|j|j
}\}}|tj@rL|du
rL|jrB|�|�

n
|�|�

|tj@r|du
r|jrp|�|�

q|�|�

qdSr&)	�fileobjrCrrrZ
_cancelledr9Z
_add_callbackr~r�)r!Z
event_listrryr�rzr{rrr�_process_eventsPs








z%BaseSelectorEventLoop._process_eventscCs|�|
�
��

|
��
dSr&)r9r;r7)r!r(rrr�
_stop_serving^s

z#BaseSelectorEventLoop._stop_serving)
N)
N)
N)NNN)
N)
N)-r�
__module__�__qualname__�__doc__rr+rZSSL_HANDSHAKE_TIMEOUTr0r3r7r6rrDrArNrSrPr]rnr@r9rr�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r��
__classcell__rrr"rr
+sj


��

��

�
	
�
.
�
)

r
cs�eZ
dZd
ZeZdZd�f
dd�	Zdd�Zdd�Z	d	d
�Z
dd�Zd
d�Zdd�Z
ejf
dd�
Zddd�
Zdd�Zdd�Zdd�Zdd�Z�ZS) �_SelectorTransportiNcs�t��
||
�
t�|�
|jd
<z|��|jd<WntyL


d|jd<Yn0d|jv
r�z|��|jd<Wntj	y�


d|jd<Yn0||_
|��|_d|_
|�|�

||_|��|_d|_d|_|jdu
r�|j��
||
j|j<dS)Nr>ZsocknamerVFr)rrrr\�_extraZgetsocknamerLZgetpeernamer>�errorr�r;r��_protocol_connected�set_protocol�_server�_buffer_factory�_buffer�
_conn_lost�_closingZ_attachr )r!r�r(r)r$r%r"rrros,

























z_SelectorTransport.__init__c
Cs�|jj
g
}
|jdur |
�d
�

n|jr0|
�d�

|
�d|j���

|jdu
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
, bufsize=�
>z<{}>�
 )rrr��appendr�r��_loopr5rrrrrr~�get_write_buffer_size�format�join)r!�infor��state�bufsizerrr�__repr__�s.










�



�


z_SelectorTransport.__repr__c

Cs|�d�

dSr&)
�_force_closer8rrr�abort�s
z_SelectorTransport.abortcCs|
|_d
|_
dS�NT)�	_protocolr��r!r)rrrr��s

z_SelectorTransport.set_protocolc


Cs|jSr&)
r�r8rrr�get_protocol�s
z_SelectorTransport.get_protocolc


Cs|jSr&)
r�r8rrrrm�s
z_SelectorTransport.is_closingc

CsT|jr
dSd
|_|j
�|j�

|jsP|jd7_|j
�|j�

|j
�|jd�
dS�NTr)	r�r�r9r�r�r�r��	call_soon�_call_connection_lostr8rrrr7�s







z_SelectorTransport.closecCs,|jdu
r(|
d
|��t
|d�
|j��
dS)Nzunclosed transport )
�source)r��ResourceWarningr7)r!Z_warnrrr�__del__�s



z_SelectorTransport.__del__�Fatal error on transportcCsNt|
t
�r(|j��r@tjd
||dd�
n|j�||
||jd��

|�|
�

dS)Nz%r: %sTrI)rTrUrbr))	rhrLr��	get_debugrrr[r�r�)r!rarTrrr�_fatal_error�s







�z_SelectorTransport._fatal_errorcCsd|jr
dS|j
r(|j
��
|j�|j�

|jsBd
|_|j�|j�

|jd7_|j�|j	|
�
dSr�)
r�r��clearr�r�r�r�r9r�r��r!rarrrr��s










z_SelectorTransport._force_closecCs�zN|jr|j
�|
�

W|j��
d|_d|_
d|_|j}|du
r�|��
d|_n:|j��
d|_d|_
d|_|j}|du
r�|��
d|_0dSr&)r�r�Zconnection_lostr�r7r�r�Z_detach)r!rar%rrrr��s&










�







z(_SelectorTransport._call_connection_lostc

Cs
t|j
�
Sr&)r�r�r8rrrr��s
z(_SelectorTransport.get_write_buffer_sizecGs$|jr
dS|j
j|
|g|�
R�
dSr&)r�r�r@r�rrrr@�s

z_SelectorTransport._add_reader)NN)
r�)rr�r��max_size�	bytearrayr�r�rr�r�r�r�rmr7�warnings�warnr�r�r�r�r�r@r�rrr"rr�cs 

r�cs�eZ
dZd
ZejjZd#�f
dd�	Z�f
dd�Z	dd�Z
d	d
�Zdd�Zd
d�Z
dd�Zdd�Zdd�Zdd�Zdd�Zdd�Zdd�Z�f
dd�Zdd �Zd!d"�Z�ZS)$r'TNcs~d|_t
��|
||||�
d
|_d
|_d|_t�|j�

|j	�
|jj|�
|j	�
|j
|j|j�
|du
rz|j	�
tj|d�
dSr
)�_read_ready_cbrr�_eof�_paused�
_empty_waiterrZ_set_nodelayr�r�r�r��connection_mader@r��_read_readyr�_set_result_unless_cancelled)r!r�r(r)r*r$r%r"rrr�s





�

�z!_SelectorSocketTransport.__init__cs.t|
t
j�r|j|_n|j|_t��|
�

dSr&)rhrZBufferedProtocol�_read_ready__get_bufferr��_read_ready__data_receivedrr�r�r"rrr�s


z%_SelectorSocketTransport.set_protocolc


Cs|jo|j
Sr&)r�r�r8rrrr�s
z#_SelectorSocketTransport.is_readingc

Cs>|js|j
rdSd
|_
|j�|j�

|j��r:t�d|�
dS)NTz%r pauses reading)r�r�r�r9r�r�rrr8rrrr�s






z&_SelectorSocketTransport.pause_readingc

Cs@|js|j
sdSd
|_
|�|j|j�
|j��r<t�d|�
dS)NFz%r resumes reading)	r�r�r@r�r�r�r�rrr8rrrr�"s






z'_SelectorSocketTransport.resume_readingc

Cs|��
dSr&)
r�r8rrrr�*s
z$_SelectorSocketTransport._read_readyc

CsV
|jr
dSz |j
�d
�
}
t|
�
s(td�
�
WnHttfyB


�Yn2tyr
}
z|�|d�
WYd}~dSd}~00z|j	�
|
�
}Wn^ttfy�


YdSttfy�


�Yn2ty�
}
z|�|d�
WYd}~dSd}~00|�s�|�
�
dSz|j
�|�

WnJttf�
y 


�Yn2t�
yP
}
z|�|d�
WYd}~n
d}~00dS)N���z%get_buffer() returned an empty bufferz/Fatal error: protocol.get_buffer() call failed.�$Fatal read error on socket transportz3Fatal error: protocol.buffer_updated() call failed.)r�r�Z
get_bufferr�r4rerfrdr�r�r�rGrF�_read_ready__on_eofZbuffer_updated)r!r�rar�rrrr�-sB









�















�z0_SelectorSocketTransport._read_ready__get_bufferc

Cs�|jr
dSz|j
�|j�
}
Wn^ttfy4


YdSttfyJ


�Yn2tyz
}
z|�	|d
�
WYd}~dSd}~00|
s�|�
�
dSz|j�|
�

WnFttfy�


�Yn0ty�
}
z|�	|d�
WYd}~n
d}~00dS)Nr�z2Fatal error: protocol.data_received() call failed.)
r�r�rEr�rGrFrerfrdr�r�r�Z
data_received)r!rCrarrrr�Rs,


















�z3_SelectorSocketTransport._read_ready__data_receivedc

Cs�|j�
�rt�d
|�
z|j��}
WnHttfy<


�Yn2tyl
}
z|�	|d�
WYd}~dSd}~00|
r�|j�
|j�

n|��
dS)Nz%r received EOFz1Fatal error: protocol.eof_received() call failed.)
r�r�rrr�Zeof_receivedrerfrdr�r9r�r7)r!Z	keep_openrarrrr�ks








�z,_SelectorSocketTransport._read_ready__on_eofc
Cs0
t|
t
ttf�s$td
t|
�
j���
�
|jr2td�
�
|j	du
rDtd�
�
|
sLdS|j
rz|j
tjkrht
�d�

|j
d7_
dS|j�
sz|j�|
�
}Wn\ttfy�


Yn^ttfy�


�YnHty�
}
z|�|d�
WYd}~dSd}~00|
|d�}
|
�
sdS|j�|j|j�
|j�|
�

|��
dS)N�/data argument must be a bytes-like object, not z%Cannot call write() after write_eof()z(unable to write; sendfile is in progress�socket.send() raised exception.r�%Fatal write error on socket transport)rh�bytesr�r�rkr�rr�r4r�r�r�!LOG_THRESHOLD_FOR_CONNLOST_WRITESr�warningr�r�rKrGrFrerfrdr�r�rr��_write_ready�extend�_maybe_pause_protocol)r!rCr�rarrr�write�s>


�





















z_SelectorSocketTransport.writec

Cs&
|jsJd
�
�
|j
rdSz|j�|j�
}
Wn�ttfy@


Yn�ttfyV


�Yn�ty�
}
zF|j	�
|j�

|j��
|�
|d�
|jdu
r�|j�|�

WYd}~nxd}~00|
r�|jd|
�=|��
|j�
s"|j	�
|j�

|jdu
r�|j�d�

|j�
r|�d�

n|j�
r"|j�tj�

dS)NzData should not be emptyr�)r�r�r�rKrGrFrerfrdr�r�r�r�r�r�r��_maybe_resume_protocolr�r�r�r��shutdownr>�SHUT_WR)r!r�rarrrr
�s4















"










z%_SelectorSocketTransport._write_readyc

Cs.|js|j
rdSd
|_
|js*|j�tj�

dSr�)r�r�r�r�r
r>r
r8rrr�	write_eof�s





z"_SelectorSocketTransport.write_eofc


Csd
Sr�rr8rrr�
can_write_eof�s
z&_SelectorSocketTransport.can_write_eofcs*t��
|
�

|jdu
r&|j�td
�
�

dS)NzConnection is closed by peer)rr�r�r��ConnectionErrorr�r"rrr��s





�z._SelectorSocketTransport._call_connection_lostc

Cs6|jdu
rt
d
�
�
|j��|_|js0|j�d�

|jS)NzEmpty waiter is already set)r�r4r�rcr�r�r8rrrr��s






z+_SelectorSocketTransport._make_empty_waiterc

Cs
d|_dSr&)
r�r8rrrr��s
z,_SelectorSocketTransport._reset_empty_waiter)NNN)rr�r�Z_start_tls_compatiblerZ
_SendfileModeZ
TRY_NATIVEZ_sendfile_compatiblerr�r�r�r�r�r�r�r�r
r
r
r
r�r�r�r�rrr"rr'�s(

�%'r'csFeZ
dZejZd�f
dd�	Zdd�Zdd�Zd
dd	�
Z	d
d�Z
�ZS)r1Ncs^t��
|
|||�
||_|j�|jj|�
|j�|j|j|j	�
|du
rZ|j�t
j|d�
dSr&)rr�_addressr�r�r�r�r@r�r�rr�)r!r�r(r)r2r*r$r"rrr�s



�

�z#_SelectorDatagramTransport.__init__c

Cstd
d�|j
D�
�
S)Nc
ss|]\}
}t|
�
V
qdSr&)
r�)�.0rCr^rrr�	<genexpr>��zC_SelectorDatagramTransport.get_write_buffer_size.<locals>.<genexpr>)�sumr�r8rrrr��s
z0_SelectorDatagramTransport.get_write_buffer_sizec

Cs�|jr
dSz|j
�|j�
\}
}Wn�ttfy6


Yn�tyd
}
z|j�|�

WYd}~n\d}~0t	t
fyz


�Yn>ty�
}
z|�|d
�
WYd}~nd}~00|j�
|
|�
dS)Nz&Fatal read error on datagram transport)r�r�Zrecvfromr�rGrFrLr��error_receivedrerfrdr�Zdatagram_received�r!rCr`rarrrr��s







 



"z&_SelectorDatagramTransport._read_readyc
Cs�
t|
t
ttf�s$td
t|
�
j���
�
|
s,dS|jrV|d|jfv
rPtd|j���
�
|j}|j	r�|jr�|j	t
jkrxt�
d�

|j	d7_	dS|j�
sdz,|jdr�|j�|
�

n|j�|
|�
WdSttfy�


|j�|j|j�
Yn~t�
y
}
z|j�|�

WYd}~dSd}~0ttf�
y0


�Yn4t�
yb
}
z|�|d�
WYd}~dSd}~00|j� t
|
�
|f�

|�!�
dS)Nr�z!Invalid address: must be None or r�rrV�'Fatal write error on datagram transport)"rhr�r�r�rkr�rr

rlr�rr�rr�r�r�r�rK�sendtorGrFr�rr��
_sendto_readyrLr�r
rerfrdr�r�r
r
rrrr
sJ


�




�


















�
z!_SelectorDatagramTransport.sendtoc

Cs
|jr�|j�
�\}
}z*|jd
r.|j�|
�

n|j�|
|�
Wqttfyh


|j�|
|f�

Yq�Yqt	y�
}
z|j
�|�

WYd}~dSd}~0tt
fy�


�Yqty�
}
z|�|d�
WYd}~dSd}~00q|��
|j�
s|j�|j�

|j�
r|�d�

dS)NrVr
)r��popleftr�r�rKr
rGrF�
appendleftrLr�r
rerfrdr�r
r�r�r�r�r�r
rrrr
0s0
















�



z(_SelectorDatagramTransport._sendto_ready)NNN)
N)rr�r��collections�dequer�rr�r�r
r
r�rrr"rr1�s
�

+r1)r��__all__r
rZr�rr>r�rZssl�ImportError�rrrrrr	r
r�logrrZ
BaseEventLoopr
Z_FlowControlMixinZ	Transportr�r'r1rrrr�<module>
sD


















<
�o