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 ]

B

� f5d�@s
dZd
Z
ddlZddlZddlZddlZddlmZ
ddlmZ
ddlm	Z	
ddlm
Z

dd	lmZ
dd
lmZ
ddlm
Z

ddlmZ
Gd
d�de
je
j�ZGdd�dee
j�ZGdd�dee
j�ZGdd�de�ZGdd�deee
j�ZGdd�deee
j�ZGdd�dej�ZdS)z�Event loop using a proactor and related classes.

A proactor is a "notify-on-completion" multiplexer.  Currently a
proactor is only implemented on Windows with IOCP.
)
�BaseProactorEventLoop�N�
)
�base_events)
�	constants)
�events)
�futures)
�	protocols)
�sslproto)
�
transports)
�loggercs|eZ
dZd
Zd�f
dd�	Zdd�Zdd�Zd	d
�Zdd�Zd
d�Z	dd�Z
dd�Zddd�
Zdd�Z
dd�Zdd�Z�ZS)�_ProactorBasePipeTransportz*Base class for pipe and socket transports.Ncs�t��
||
�
|�|�

||_|�|�

||_d|_d|_d|_d
|_	d
|_
d|_d|_|jdk	rl|j�
�
|j�|jj|�
|dk	r�|j�tj|d�
dS)NrF)�super�__init__�
_set_extra�_sock�set_protocol�_server�_buffer�	_read_fut�
_write_fut�_pending_write�
_conn_lost�_closing�_eof_writtenZ_attach�_loop�	call_soon�	_protocolZconnection_maderZ_set_result_unless_cancelled)�self�loop�sock�protocol�waiter�extra�server)
�	__class__��</opt/alt/python37/lib64/python3.7/asyncio/proactor_events.pyrs$




















z#_ProactorBasePipeTransport.__init__c
Cs�|jj
g
}
|jdkr |
�d
�

n|jr0|
�d�

|jdk	rP|
�d|j�����

|jdk	rl|
�d|j���

|jdk	r�|
�d|j���

|jr�|
�dt	|j�
���

|j
r�|
�d�

d�d	�|
�
�
S)
N�closed�closingzfd=zread=zwrite=zwrite_bufsize=zEOF writtenz<{}>�
 )
r$�__name__r�appendr�filenorrr�lenr�format�join)r�infor%r%r&�__repr__2s 






















z#_ProactorBasePipeTransport.__repr__cCs|
|jd
<dS)N�pipe)
�_extra)rrr%r%r&rDs
z%_ProactorBasePipeTransport._set_extracCs
|
|_dS)
N)
r)rr r%r%r&rGs
z'_ProactorBasePipeTransport.set_protocolc


Cs|jS)
N)
r)
rr%r%r&�get_protocolJs
z'_ProactorBasePipeTransport.get_protocolc


Cs|jS)
N)
r)
rr%r%r&�
is_closingMs
z%_ProactorBasePipeTransport.is_closingc

Cs\|jr
dSd
|_|j
d7_
|js>|jdkr>|j�|jd�
|jdk	rX|j��
d|_dS)NTr)	rrrrrr�_call_connection_lostr�cancel)
rr%r%r&�closePs










z _ProactorBasePipeTransport.closec

Cs,|jdk	r(t
jd
|��t|d�
|��
dS)Nzunclosed transport )
�source)r�warnings�warn�ResourceWarningr8)
rr%r%r&�__del__[s




z"_ProactorBasePipeTransport.__del__�Fatal error on pipe transportc	CsVzDt|
t
�r*|j��rBtjd
||dd�
n|j�||
||jd��

Wd|�|
�

XdS)Nz%r: %sT)
�exc_info)�message�	exceptionZ	transportr )	�
isinstance�OSErrorr�	get_debugr�debug�call_exception_handlerr�_force_close)r�excr@r%r%r&�_fatal_erroras









z'_ProactorBasePipeTransport._fatal_errorcCs�|jdk	r6|j�
�s6|
dkr*|j�d�

n|j�|
�

|jr@dSd
|_|jd7_|jrj|j��
d|_|jr�|j��
d|_d|_	d|_
|j�|j
|
�
dS)NTrr)�
_empty_waiter�done�
set_resultZ
set_exceptionrrrr7rrrrrr6)rrHr%r%r&rGps"

















z'_ProactorBasePipeTransport._force_closec	Cs^z|j�
|
�

Wdt|jd
�r,|j�tj�

|j��
d|_|j}|dk	rX|�	�
d|_XdS)N�shutdown)
rZconnection_lost�hasattrrrM�socketZ	SHUT_RDWRr8rZ_detach)rrHr#r%r%r&r6�s









z0_ProactorBasePipeTransport._call_connection_lostc
Cs"|j}
|j
dk	r|
t|j
�
7}
|
S)
N)rrr-)r�sizer%r%r&�get_write_buffer_size�s




z0_ProactorBasePipeTransport.get_write_buffer_size)NNN)
r>)r*�
__module__�__qualname__�__doc__rr1rrr4r5r8r=rIrGr6rQ�
__classcell__r%r%)
r$r&rs

rcsTeZ
dZd
Zd�f
dd�	Zdd�Zdd�Zd	d
�Zdd�Zd
d�Z	ddd�
Z
�ZS)�_ProactorReadPipeTransportzTransport for read pipes.Ncs:d|_d
|_
t��|
|||||�
|j�|j�

d|_
dS)NTF)�
_pending_data�_pausedr
rrr�
_loop_reading)rrrr r!r"r#)
r$r%r&r�s



z#_ProactorReadPipeTransport.__init__c


Cs|jo|j
S)
N)rXr)
rr%r%r&�
is_reading�s
z%_ProactorReadPipeTransport.is_readingc

Cs0|js|j
rdSd
|_
|j��r,t�d|�
dS)NTz%r pauses reading)rrXrrDrrE)
rr%r%r&�
pause_reading�s





z(_ProactorReadPipeTransport.pause_readingc
Csn|js|j
sdSd
|_
|jdkr0|j�|jd�
|j}
d|_|
dk	rT|j�|j|
�
|j��rjt	�
d|�
dS)NFz%r resumes reading)rrXrrrrYrW�_data_receivedrDrrE)r�datar%r%r&�resume_reading�s








z)_ProactorReadPipeTransport.resume_readingc

Csd|j�
�rt�d
|�
y|j��}
Wn.tk
rR
}
z|�|d�
dSd}~XYnX|
s`|��
dS)Nz%r received EOFz1Fatal error: protocol.eof_received() call failed.)	rrDrrErZeof_received�	ExceptionrIr8)rZ	keep_openrHr%r%r&�
_eof_received�s








z(_ProactorReadPipeTransport._eof_receivedc
Cs�|jr|j
dkst�
|
|_
dS|
s.|��
dSt|jtj�r�yt�|j|
�
Wq�t	k
r|
}
z|�
|d
�
dSd}~XYq�Xn|j�|
�

dS)Nz3Fatal error: protocol.buffer_updated() call failed.)rXrW�AssertionErrorr`rBrrZBufferedProtocolZ_feed_data_to_buffered_protor_rIZ
data_received)rr]rHr%r%r&r\�s









z)_ProactorReadPipeTransport._data_receivedc
Cs�
d}�
z`y~|
dk	rP|j|
ks0|jdkr,|j
s0t�
d|_|
��rH|
��}n|
��
|j
r^d}dS|d
krjdS|js�|jj�	|j
d�|_Wn�tk
r�
}
z0|j
s�|�|d�
n|j�
�r�tjddd�
Wdd}~XYn�tk
r�
}
z|�|�

Wdd}~XYnftk
�
r,
}
z|�|d�
Wdd}~XYn8tjk
�
rL


|j
�
sH�YnX|j�
sd|j�|j�

Wd|dk	�
r||�|�

XdS)N�i�z"Fatal read error on pipe transportz*Read error on pipe transport while closingT)
r?)rrrarK�resultr7rXr�	_proactor�recvr�ConnectionAbortedErrorrIrDrrE�ConnectionResetErrorrGrCr�CancelledError�add_done_callbackrYr\)r�futr]rHr%r%r&rY�sB


























z(_ProactorReadPipeTransport._loop_reading)NNN)
N)r*rRrSrTrrZr[r^r`r\rYrUr%r%)
r$r&rV�s
rVcs^eZ
dZd
ZdZ�f
dd�Zdd�Zddd	�
Zd
d�Zdd
�Z	dd�Z
dd�Zdd�Z�Z
S)�_ProactorBaseWritePipeTransportzTransport for write pipes.Tc
st�j
|
|�

d|_dS)
N)r
rrJ)r�args�kw)
r$r%r&r.
s

z(_ProactorBaseWritePipeTransport.__init__cCs�t|
t
ttf�s$td
t|
�
j���
�
|jr2td�
�
|j	dk	rDtd�
�
|
sLdS|j
rz|j
tjkrht
�d�

|j
d7_
dS|jdkr�|jdks�t�
|jt
|
�
d�

n.|js�t|
�
|_|��
n|j�|
�

|��
dS)Nz/data argument must be a bytes-like object, not zwrite_eof() already calledz(unable to write; sendfile is in progresszsocket.send() raised exception.r)
r])rB�bytes�	bytearray�
memoryview�	TypeError�typer*r�RuntimeErrorrJrrZ!LOG_THRESHOLD_FOR_CONNLOST_WRITESr�warningrrra�
_loop_writing�_maybe_pause_protocol�extend)rr]r%r%r&�write2
s,



















z%_ProactorBaseWritePipeTransport.writeNc
Csv
�
y|
dk	r |jdkr |j
r dS|
|jks.t�
d|_d
|_|
rF|
��
|dkrZ|j}d|_|s�|j
rt|j�|jd�
|j	r�|j
�tj
�

|��
n\|jj�|j
|�|_|j��s�|jd
ks�t�
t|�
|_|j�|j�

|��
n|j�|j�

|jdk	�
r|jdk�
r|j�d�

Wn\tk
�
rB
}
z|�|�

Wdd}~XYn0tk
�
rp
}
z|�|d�
Wdd}~XYnXdS)Nrz#Fatal write error on pipe transport)rrrarrcrrrr6rrrMrO�SHUT_WRZ_maybe_resume_protocolrd�sendrKr-rirurvrJrLrgrGrCrI)r�
fr]rHr%r%r&ruX
s<





























z-_ProactorBaseWritePipeTransport._loop_writingc


Csd
S)NTr%)
rr%r%r&�
can_write_eof�
s
z-_ProactorBaseWritePipeTransport.can_write_eofc

Cs|��
dS)
N)
r8)
rr%r%r&�	write_eof�
s
z)_ProactorBaseWritePipeTransport.write_eofc

Cs|�d�

dS)
N)
rG)
rr%r%r&�abort�
s
z%_ProactorBaseWritePipeTransport.abortc

Cs:|jdk	rt
d
�
�
|j��|_|jdkr4|j�d�

|jS)NzEmpty waiter is already set)rJrsrZ
create_futurerrL)
rr%r%r&�_make_empty_waiter�
s







z2_ProactorBaseWritePipeTransport._make_empty_waiterc

Cs
d|_dS)
N)
rJ)
rr%r%r&�_reset_empty_waiter�
s
z3_ProactorBaseWritePipeTransport._reset_empty_waiter)NN)r*rRrSrTZ_start_tls_compatiblerrxrur|r}r~rr�rUr%r%)
r$r&rk(
s&
)rkcs$eZ
dZ�f
d
d�Zdd�Z�ZS)�_ProactorWritePipeTransportc
s4t�j
|
|�

|jj�|jd
�|_|j�|j�

dS)N�)	r
rrrdrerrri�_pipe_closed)rrlrm)
r$r%r&r�
s


z$_ProactorWritePipeTransport.__init__cCsv|
��rdS|
�
�d
kst�
|jr4|jdks0t�
dS|
|jksLt|
|jf�
�
d|_|jdk	rj|�t��

n|��
dS)Nrb)	Z	cancelledrcrarrrrG�BrokenPipeErrorr8)rrjr%r%r&r��
s









z(_ProactorWritePipeTransport._pipe_closed)r*rRrSrr�rUr%r%)
r$r&r��
s
r�c@s eZ
dZd
Zdd�Zdd�ZdS)�_ProactorDuplexPipeTransportzTransport for duplex pipes.c


Csd
S)NFr%)
rr%r%r&r|�
s
z*_ProactorDuplexPipeTransport.can_write_eofc


Cst�
dS)
N)
�NotImplementedError)
rr%r%r&r}�
s
z&_ProactorDuplexPipeTransport.write_eofN)r*rRrSrTr|r}r%r%r%r&r��
sr�csBeZ
dZd
ZejjZd�f
dd�	Zdd�Z	dd�Z
d	d
�Z�ZS)�_ProactorSocketTransportz Transport for connected sockets.Ncs$t��
|
|||||�
t�|�

dS)
N)r
rrZ_set_nodelay)rrrr r!r"r#)
r$r%r&r�
s
z!_ProactorSocketTransport.__init__c	Cs�|
|jd
<y|
�
�|jd<Wn4tjtfk
rP


|j��rLtjd|
dd�
YnXd|jkr�y|
�	�|jd<Wn4tjtfk
r�


|j��r�tjd|
dd�
YnXdS)NrOZsocknamezgetsockname() failed on %rT)
r?�peernamezgetpeername() failed on %r)
r3ZgetsocknamerO�error�AttributeErrorrrDrrtZgetpeername)rrr%r%r&r�
s















z#_ProactorSocketTransport._set_extrac


Csd
S)NTr%)
rr%r%r&r|�
s
z&_ProactorSocketTransport.can_write_eofc

Cs2|js|j
rdSd
|_
|jdkr.|j�tj�

dS)NT)rrrrrMrOry)
rr%r%r&r}�
s






z"_ProactorSocketTransport.write_eof)NNN)
r*rRrSrTrZ
_SendfileModeZ
TRY_NATIVEZ_sendfile_compatiblerrr|r}rUr%r%)
r$r&r��
s
r�cs�eZ
dZ�f
d
d�Zd1dd�
Zd2dddddd�dd	�Zd3d
d�
Zd4dd
�
Zd5dd�
Z�f
dd�Z	dd�Z
dd�Zdd�Zdd�Z
dd�Zdd�Zdd�Zd d!�Zd"d#�Zd6d$d%�
Zd&d'�Zd7d)d*�
Zd+d,�Zd-d.�Zd/d0�Z�ZS)8r
csHt��
�
t�d
|
jj�
|
|_|
|_d|_i|_	|
�
|�

|��
dS)NzUsing proactor: %s)r
rrrEr$r*rd�	_selector�_self_reading_future�_accept_futuresZset_loop�_make_self_pipe)rZproactor)
r$r%r&r�
s









zBaseProactorEventLoop.__init__NcCst||
||||�S)
N)
r�)rrr r!r"r#r%r%r&�_make_socket_transport�
s

z,BaseProactorEventLoop._make_socket_transportF)�server_side�server_hostnamer"r#�ssl_handshake_timeoutc	Cs0tj
|||||||	d
�}
t||
|
||d�
|
jS)N)
r�)r"r#)r	ZSSLProtocolr�Z_app_transport)rZrawsockr �
sslcontextr!r�r�r"r#r�Zssl_protocolr%r%r&�_make_ssl_transport�
s






z)BaseProactorEventLoop._make_ssl_transportcCst||
|||�S)
N)
r�)rrr r!r"r%r%r&�_make_duplex_pipe_transport�
s
z1BaseProactorEventLoop._make_duplex_pipe_transportcCst||
|||�S)
N)
rV)rrr r!r"r%r%r&�_make_read_pipe_transportsz/BaseProactorEventLoop._make_read_pipe_transportcCst||
|||�S)
N)
r�)rrr r!r"r%r%r&�_make_write_pipe_transports
z0BaseProactorEventLoop._make_write_pipe_transportc

sP|��rt
d
�
�
|��rdS|��
|��
|j��
d|_d|_t���
dS)Nz!Cannot close a running event loop)	Z
is_runningrs�	is_closed�_stop_accept_futures�_close_self_piperdr8r�r
)
r)
r$r%r&r8s








zBaseProactorEventLoop.closec�s|j�
|
|�IdHS)
N)rdre)rr�
nr%r%r&�	sock_recv s
zBaseProactorEventLoop.sock_recvc�s|j�
|
|�IdHS)
N)rdZ	recv_into)rrZbufr%r%r&�sock_recv_into#s
z$BaseProactorEventLoop.sock_recv_intoc�s|j�
|
|�IdHS)
N)rdrz)rrr]r%r%r&�sock_sendall&s
z"BaseProactorEventLoop.sock_sendallc�s|j�
|
|�IdHS)
N)rdZconnect)rrZaddressr%r%r&�sock_connect)s
z"BaseProactorEventLoop.sock_connectc�s|j�
|
�
IdHS)
N)rd�accept)rrr%r%r&�sock_accept,s
z!BaseProactorEventLoop.sock_acceptc
�s(
y|��}Wn2t
tjfk
r>
}
zt�d
�
�
Wdd}~XYnXyt�|�
j}Wn,t	k
r|
}
zt�d
�
�
Wdd}~XYnX|r�|n|}|s�dSt
|d�}|r�t
|||�n|}	t
||�}d}
zLxFt
|	||�}|dk
r�|
S|j�|
|||�IdH
||7}|
|7}
q�WWd|
dk�
r"|�
|�

XdS)Nznot a regular filerl��)r,r��io�UnsupportedOperationrZSendfileNotAvailableError�os�fstat�st_sizerC�minrd�sendfile�seek)rr�file�offset�countr,�errZfsizeZ	blocksizeZend_posZ
total_sentr%r%r&�_sock_sendfile_native/s2

























z+BaseProactorEventLoop._sock_sendfile_nativec�sV|
��}|
�
�
|
��IdH
z|j|
j|||d
d�IdHS|
��
|rP|
��
XdS)NF)
Zfallback)rZr[rZ
sock_sendfilerr�r^)rZtranspr�r�r�r^r%r%r&�_sendfile_nativeLs







z&BaseProactorEventLoop._sendfile_nativec

CsL|jdk	r|j�
�
d|_|j��
d|_|j��
d|_|jd
8_dS)Nr)r�r7�_ssockr8�_csock�
_internal_fds)
rr%r%r&r�Xs











z&BaseProactorEventLoop._close_self_pipec

CsFt�
�\|_|_|j�d
�

|j�d
�

|jd7_|�|j�

dS)NFr)rOZ
socketpairr�r�Zsetblockingr�r�_loop_self_reading)
rr%r%r&r�bs




z%BaseProactorEventLoop._make_self_pipec
Cs�y$|
dk	r|
��
|j
�|jd
�}
WnHtjk
r:


dStk
rl
}
z|�d||d��

Wdd}~XYnX|
|_|
�	|j
�

dS)Niz.Error on reading from the event loop self pipe)r@rAr)rcrdrer�rrhr_rFr�rir�)rr{rHr%r%r&r�js










z(BaseProactorEventLoop._loop_self_readingc

Cs>y|j�
d
�

Wn(tk
r8


|jr4tjddd�
YnXdS)N�
z3Fail to write a null byte into the self-pipe socketT)
r?)r�rzrC�_debugrrE)
rr%r%r&�_write_to_self|s




z$BaseProactorEventLoop._write_to_self�dcs(d��
�����fd
d�	�����

dS)Nc

s$
y�|dk	rn|��\}
}�j
r,t�d
�||
�
�
�}�dk	rX�j|
|�dd|i
��d�
n�j|
|d|i
�d�
���rzdS�j���
}Wn~t	k
r�
}
zB��
�dkrˆ�d|�d��

���
n�j
r�tjd	�dd
�
Wdd}~XYn8t
jk
�
r


���
YnX|�j��
�<|���

dS)Nz#%r got a new connection from %r: %rTr�)r�r"r#r�)r"r#���zAccept failed on a socket)r@rArOzAccept failed on socket %r)
r?)rcr�rrEr�r�r�rdr�rCr,rFr8rrhr�ri)r{ZconnZaddrr rH)r�protocol_factoryrr#rr�r�r%r&r�s@
































z2BaseProactorEventLoop._start_serving.<locals>.loop)
N)
r)rr�rr�r#Zbacklogr�r%)rr�rr#rr�r�r&�_start_serving�s%z$BaseProactorEventLoop._start_servingc
CsdS)
Nr%)rZ
event_listr%r%r&�_process_events�sz%BaseProactorEventLoop._process_eventsc
Cs*x|j�
�D]}
|
��
qW|j��
dS)
N)r��valuesr7�clear)r�futurer%r%r&r��s


z*BaseProactorEventLoop._stop_accept_futurescCs6|j�
|
��d�}|r|��
|j�|
�

|
��
dS)
N)r��popr,r7rd�
_stop_servingr8)rrr�r%r%r&r��s





z#BaseProactorEventLoop._stop_serving)NNN)
N)NN)NN)NN)
N)NNr�N)r*rRrSrr�r�r�r�r�r8r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�rUr%r%)
r$r&r
�
s<





	










)r
)rT�__all__r�r�rOr:�rrrrrr	r
�logrZ_FlowControlMixinZ
BaseTransportrZ
ReadTransportrVZWriteTransportrkr�Z	Transportr�r�Z
BaseEventLoopr
r%r%r%r&�<module>s:












m




'