| Server IP : 127.0.0.1 / Your IP : 216.73.216.109 Web Server : Apache/2.4.54 (Win64) OpenSSL/1.1.1q PHP/8.1.10 System : Windows NT DESKTOP-E5T4RUN 10.0 build 19045 (Windows 10) AMD64 User : SERVERWEB ( 0) PHP Version : 8.1.10 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : OFF | Perl : OFF | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : C:/laragon/bin/python/python-3.10/Lib/asyncio/__pycache__/ |
Upload File : |
o
�L�bʁ � @ sX d Z dZddlZddlZddlZddlZddlZddlZddlZddl m
Z
ddl m Z ddl m Z ddl m
Z
dd l mZ dd
l mZ dd l mZ dd l mZ dd
lmZ dd� ZG dd� dejej�ZG dd� deej�ZG dd� deej�ZG dd� de�Z G dd� deej �Z G dd� deeej �Z G d d � d eeej �Z!G d d � d e
j"�Z#dS ) 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)�futures)�
exceptions)� protocols)�sslproto)�
transports)�trsock)�loggerc C s� t �|�| jd< z |�� | jd< W n tjy( | j�� r&tj d|dd� Y nw d| jvrIz
|�
� | jd< W d S tjyH d | jd< Y d S w d S )N�socketZsocknamezgetsockname() failed on %rT��exc_info�peername) r �TransportSocket�_extra� getsocknamer
�error�_loop� get_debugr �warning� getpeername)� transport�sock� r �/C:\python3.10-64\lib\asyncio\proactor_events.py�_set_socket_extra s"
���
��r c s� e Zd ZdZ d � fdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
e j fdd�Z
d dd�Zdd� Zdd� Zdd� Z� ZS ) �_ProactorBasePipeTransportz*Base class for pipe and socket transports.Nc s� t � �||� | �|� || _| �|� || _d | _d | _d | _d| _ d| _
d| _ d| _ | jd ur6| j�
� | j�| jj| � |d urN| j�tj|d � d S d S )Nr F)�super�__init__�
_set_extra�_sock� set_protocol�_server�_buffer� _read_fut�
_write_fut�_pending_write�
_conn_lost�_closing� _eof_written�_attachr � call_soon� _protocol�connection_mader � _set_result_unless_cancelled��self�loopr �protocol�waiter�extra�server�� __class__r r r 2 s(
��z#_ProactorBasePipeTransport.__init__c C s� | j jg}| jd u r|�d� n| jr|�d� | jd ur(|�d| j�� � �� | jd ur6|�d| j��� | jd urD|�d| j��� | jrR|�dt | j�� �� | j
rZ|�d� d� d � |��S )
N�closed�closingzfd=zread=zwrite=zwrite_bufsize=z EOF writtenz<{}>� )
r9 �__name__r" �appendr* �filenor& r' r% �lenr+ �format�join)r2 �infor r r �__repr__H s
z#_ProactorBasePipeTransport.__repr__c C s || j d< d S )N�pipe)r �r2 r r r r r! Z � z%_ProactorBasePipeTransport._set_extrac C s
|| _ d S �N�r. )r2 r4 r r r r# ] �
z'_ProactorBasePipeTransport.set_protocolc C � | j S rH rI �r2 r r r � get_protocol` � z'_ProactorBasePipeTransport.get_protocolc C rK rH )r* rL r r r �
is_closingc rN z%_ProactorBasePipeTransport.is_closingc C s` | j rd S d| _ | jd7 _| js | jd u r | j�| jd � | jd ur.| j�� d | _d S d S )NTr ) r* r) r% r' r r- �_call_connection_lostr& �cancelrL r r r �closef s
�z _ProactorBasePipeTransport.closec C s0 | j d ur|d| ��t| d� | j �� d S d S )Nzunclosed transport )�source)r" �ResourceWarningrR )r2 �_warnr r r �__del__q s
�z"_ProactorBasePipeTransport.__del__� Fatal error on pipe transportc C sn z0t |t�r| j�� rtjd| |dd� n| j�||| | jd�� W | �|� d S W | �|� d S | �|� w )Nz%r: %sTr )�message� exceptionr r4 ) �
isinstance�OSErrorr r r �debug�call_exception_handlerr. � _force_close)r2 �excrX r r r � _fatal_errorv s
�
�� z'_ProactorBasePipeTransport._fatal_errorc C s� | j d ur| j �� s|d u r| j �d � n| j �|� | jr d S d| _| jd7 _| jr5| j�� d | _| jr@| j�� d | _d| _ d | _
| j � | j
|� d S )NTr r )�
_empty_waiter�done�
set_result�
set_exceptionr* r) r' rQ r& r( r% r r- rP )r2 r_ r r r r^ � s"
z'_ProactorBasePipeTransport._force_closec C s� z5| j �|� W t| jd�r | j�� dkr | j�tj� | j�� d | _| j }|d ur4|�
� d | _ d S d S t| jd�rJ| j�� dkrJ| j�tj� | j�� d | _| j }|d ur`|�
� d | _ w )N�shutdown���) r. �connection_lost�hasattrr" r? re r
� SHUT_RDWRrR r$ �_detach)r2 r_ r7 r r r rP � s&
��
z0_ProactorBasePipeTransport._call_connection_lostc C s" | j }| jd ur|t| j�7 }|S rH )r( r% r@ )r2 �sizer r r �get_write_buffer_size� s
z0_ProactorBasePipeTransport.get_write_buffer_size�NNN)rW )r= �
__module__� __qualname__�__doc__r rD r! r# rM rO rR �warnings�warnrV r` r^ rP rl �
__classcell__r r r8 r r . s �
r c sX e Zd ZdZ d� fdd� Zdd� Zdd � Zd
d � Zd d
� Zdd� Z ddd�Z
� Z S )�_ProactorReadPipeTransportzTransport for read pipes.N� c sD d| _ d| _t� �||||||� t|�| _| j�| j� d| _d S )Nrf TF) �_pending_data_length�_pausedr r � bytearray�_datar r- �
_loop_reading)r2 r3 r r4 r5 r6 r7 Z buffer_sizer8 r r r � s
z#_ProactorReadPipeTransport.__init__c C s | j o| j S rH )rw r* rL r r r �
is_reading� s z%_ProactorReadPipeTransport.is_readingc C s4 | j s| jrd S d| _| j�� rt�d| � d S d S )NTz%r pauses reading)r* rw r r r r\ rL r r r �
pause_reading� s
�z(_ProactorReadPipeTransport.pause_readingc C s~ | j s| jsd S d| _| jd u r| j�| jd � | j}d| _|dkr0| j�| j| jd |� |� | j� � r=t
� d| � d S d S )NFrf z%r resumes reading) r* rw r& r r- rz rv �_data_receivedry r r r\ )r2 �lengthr r r �resume_reading� s
�z)_ProactorReadPipeTransport.resume_readingc
C s~ | j �� r t�d| � z| j�� }W n" ttfy � ty4 } z
| � |d� W Y d }~d S d }~ww |s=| �
� d S d S )Nz%r received EOFz1Fatal error: protocol.eof_received() call failed.) r r r r\ r. � eof_received�
SystemExit�KeyboardInterrupt�
BaseExceptionr` rR )r2 � keep_openr_ r r r �
_eof_received� s
��� �z(_ProactorReadPipeTransport._eof_receivedc
C s� | j r| jdks
J �|| _d S |dkr| �� d S t| jtj�rMz
t�| j|� W d S tt fy4 � t
yL } z
| � |d� W Y d }~d S d }~ww | j� |� d S )Nrf r z3Fatal error: protocol.buffer_updated() call failed.)
rw rv r� rZ r. r �BufferedProtocol� _feed_data_to_buffered_protor� r� r� r` �
data_received)r2 �datar~ r_ r r r r} � s( ���z)_ProactorReadPipeTransport._data_receivedc
C s� d}d }z�za|d urD| j |u s| j d u r| jsJ �d | _ |�� r@|�� }|dkr8W W |dkr6| �||� d S d S | jd |� }n|�� | jrWW W |dkrU| �||� d S d S | jse| jj �
| j | j�| _ W nb t y� } z | jsx| �
|d� n | j�� r�tjddd� W Y d }~nId }~w ty� } z | �|� W Y d }~n3d }~w ty� } z | �
|d� W Y d }~n d }~w tjy� | jsƂ Y n w | js�| j �| j� W |dkr�| �||� d S d S |dkr�| �||� w w )Nrf r z"Fatal read error on pipe transportz*Read error on pipe transport while closingTr )r& r* rb �resultr} ry rQ rw r � _proactor� recv_intor" �ConnectionAbortedErrorr` r r r\ �ConnectionResetErrorr^ r[ r �CancelledError�add_done_callbackrz )r2 �futr~ r� r_ r r r rz sh �"�����
������� ��z(_ProactorReadPipeTransport._loop_reading)NNNru rH ) r= rn ro rp r r{ r| r r� r} rz rs r r r8 r rt � s �
rt c s^ e Zd ZdZdZ� fdd�Zdd� Zddd �Zd
d � Zd d
� Z dd� Z
dd� Z dd� Z � Z
S )� _ProactorBaseWritePipeTransportzTransport for write pipes.Tc s t � j|i |�� d | _d S rH )r r ra �r2 �args�kwr8 r r r I s
z(_ProactorBaseWritePipeTransport.__init__c C s� t |tttf�stdt|�j� ���| jrtd��| j d ur"td��|s&d S | j
r=| j
t j kr4t
�d� | j
d7 _
d S | jd u rS| jd u sIJ �| jt|�d� d S | jsat|�| _| �� d S | j�|� | �� d S )Nz/data argument must be a bytes-like object, not zwrite_eof() already calledz(unable to write; sendfile is in progressz socket.send() raised exception.r )r� )rZ �bytesrx �
memoryview� TypeError�typer= r+ � RuntimeErrorra r) r �!LOG_THRESHOLD_FOR_CONNLOST_WRITESr r r' r% �
_loop_writing�_maybe_pause_protocol�extend)r2 r� r r r �writeM s2 ��
z%_ProactorBaseWritePipeTransport.writeNc
C s� z�|d ur| j d u r| jrW d S || j u sJ �d | _ d| _|r#|�� |d u r-| j}d | _|sI| jr:| j�| jd � | jrD| j �
t j � | �
� n.| jj�| j |�| _ | j �� sp| jdks_J �t|�| _| j �| j� | �� n| j �| j� | jd ur�| j d u r�| j�d � W d S W d S W d S ty� } z | �|� W Y d }~d S d }~w ty� } z
| �|d� W Y d }~d S d }~ww )Nr z#Fatal write error on pipe transport)r' r* r( r� r% r r- rP r+ r" re r
�SHUT_WR�_maybe_resume_protocolr� �sendrb r@ r� r� r� ra rc r� r^ r[ r` )r2 �fr� r_ r r r r� s sD
����z-_ProactorBaseWritePipeTransport._loop_writingc C � dS �NTr rL r r r �
can_write_eof� � z-_ProactorBaseWritePipeTransport.can_write_eofc C s | � � d S rH )rR rL r r r � write_eof� s z)_ProactorBaseWritePipeTransport.write_eofc C � | � d � d S rH �r^ rL r r r �abort� rG z%_ProactorBaseWritePipeTransport.abortc C s: | j d ur td��| j�� | _ | jd u r| j �d � | j S )NzEmpty waiter is already set)ra r� r �
create_futurer' rc rL r r r �_make_empty_waiter� s
z2_ProactorBaseWritePipeTransport._make_empty_waiterc C s
d | _ d S rH )ra rL r r r �_reset_empty_waiter� rJ z3_ProactorBaseWritePipeTransport._reset_empty_waiter�NN)r= rn ro rp �_start_tls_compatibler r� r� r� r� r� r� r� rs r r r8 r r� C s
&)r� c s$ e Zd Z� fdd�Zdd� Z� ZS )�_ProactorWritePipeTransportc s8 t � j|i |�� | jj�| jd�| _| j�| j� d S )N� ) r r r r� �recvr" r& r� � _pipe_closedr� r8 r r r � s z$_ProactorWritePipeTransport.__init__c C sx |� � rd S |�� dksJ �| jr| jd u sJ �d S || ju s&J || jf��d | _| jd ur6| �t� � d S | �� d S )N� )� cancelledr� r* r& r' r^ �BrokenPipeErrorrR )r2 r� r r r r� � s
z(_ProactorWritePipeTransport._pipe_closed)r= rn ro r r� rs r r r8 r r� � s r� c s\ e Zd ZdZ d� fdd� Zdd� Zdd� Zd d
� Zdd d �Zdd
d�Z ddd�Z
� Z S )�_ProactorDatagramTransporti Nc s> || _ d | _t� j|||||d� t�� | _| j�| j � d S )N)r5 r6 )
�_addressra r r � collections�dequer% r r- rz )r2 r3 r r4 �addressr5 r6 r8 r r r � s
z#_ProactorDatagramTransport.__init__c C � t | |� d S rH �r rF r r r r! � rG z%_ProactorDatagramTransport._set_extrac C s t dd� | jD ��S )Nc s s � | ] \}}t |�V qd S rH )r@ )�.0r� �_r r r � <genexpr>� s � zC_ProactorDatagramTransport.get_write_buffer_size.<locals>.<genexpr>)�sumr% rL r r r rl � s z0_ProactorDatagramTransport.get_write_buffer_sizec C r� rH r� rL r r r r� � rG z _ProactorDatagramTransport.abortc C s� t |tttf�stdt|���|sd S | jd ur'|d | jfvr'td| j� ���| jrA| jrA| jt j
kr8t � d� | jd7 _d S | j
�t|�|f� | jd u rT| �� | �� d S )Nz,data argument must be bytes-like object (%r)z!Invalid address: must be None or z!socket.sendto() raised exception.r )rZ r� rx r� r� r� r� �
ValueErrorr) r r� r r r% r> r' r� r� )r2 r� �addrr r r �sendto� s& �
�
z!_ProactorDatagramTransport.sendtoc
C s" zR| j rW d S || ju sJ �d | _|r|�� | jr | j r.| jr.| jr+| j�| jd � W d S | j� � \}}| jd urE| jj
� | j |�| _n | jj
j
| j ||d�| _W n1 tyk } z
| j�|� W Y d }~d S d }~w ty� } z
| �|d� W Y d }~d S d }~ww | j�| j� | �� d S )N)r� z'Fatal write error on datagram transport)r) r' r� r% r� r* r r- rP �popleftr� r� r" r� r[ r. �error_received� Exceptionr` r� r� r� )r2 r� r� r� r_ r r r r� � s<
� ����� z(_ProactorDatagramTransport._loop_writingc
C s� d }z�z�| j rW W |r| j�||� d S d S | j|u s%| jd u r#| js%J �d | _|d urT|�� }| jrDd }W W |rB| j�||� d S d S | jd urP|| j}}n|\}}| j rfW W |rd| j�||� d S d S | jd urw| jj� | j
| j �| _n | jj� | j
| j �| _W n% t
y� } z | j�|� W Y d }~n d }~w tjy� | js�� Y n
w | jd ur�| j�| j� W |r�| j�||� d S d S |r�| j�||� w w rH )r) r. �datagram_receivedr& r* r� r� r r� r� r" �max_size�recvfromr[ r� r r� r� rz )r2 r� r� r� �resr_ r r r rz sf $����
��
� � �����
���z(_ProactorDatagramTransport._loop_readingrm rH ) r= rn ro r� r r! rl r� r� r� rz rs r r r8 r r� � s �
!r� c @ s e Zd ZdZdd� Zdd� ZdS )� _ProactorDuplexPipeTransportzTransport for duplex pipes.c C r� )NFr rL r r r r� M r� z*_ProactorDuplexPipeTransport.can_write_eofc C s t �rH )�NotImplementedErrorrL r r r r� P r� z&_ProactorDuplexPipeTransport.write_eofN)r= rn ro rp r� r� r r r r r� H s r� c sF e Zd ZdZejjZ d � fdd� Zdd� Z dd� Z
d d
� Z � Z S ) �_ProactorSocketTransportz Transport for connected sockets.Nc s$ t � �||||||� t�|� d S rH )r r r � _set_nodelayr1 r8 r r r [ s z!_ProactorSocketTransport.__init__c C r� rH r� rF r r r r! ` rG z#_ProactorSocketTransport._set_extrac C r� r� r rL r r r r� c r� z&_ProactorSocketTransport.can_write_eofc C s6 | j s| jrd S d| _| jd u r| j�tj� d S d S r� )r* r+ r' r" re r
r� rL r r r r� f s
�z"_ProactorSocketTransport.write_eofrm )
r= rn ro rp r �
_SendfileMode�
TRY_NATIVE�_sendfile_compatibler r! r� r� rs r r r8 r r� T s �r� c s e Zd Z� fdd�Z d3dd�Z d4dddddd�dd �Z d3d
d �Z d5d d
�Z d5dd�Z d5dd�Z � fdd�Z
dd� Z dd� Z dd� Z
dd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd4d&d'�Zd(d)� Z * d6d+d,�Zd-d.� Zd/d0� Zd1d2� Z� ZS )7r c sl t � �� t�d|jj� || _|| _d | _i | _ |�
| � | � � t �
� t �� u r4t�| j�� � d S d S )NzUsing proactor: %s)r r r r\ r9 r= r� � _selector�_self_reading_future�_accept_futures�set_loop�_make_self_pipe� threading�current_thread� main_thread�signal�
set_wakeup_fd�_csockr? )r2 �proactorr8 r r r p s
�z BaseProactorEventLoop.__init__Nc C � t | |||||�S rH )r� )r2 r r4 r5 r6 r7 r r r �_make_socket_transport} �
�z,BaseProactorEventLoop._make_socket_transportF)� server_side�server_hostnamer6 r7 �ssl_handshake_timeoutc C s0 t j| |||||| d�}
t| ||
||d� |
jS )N)r� �r6 r7 )r � SSLProtocolr� �_app_transport) r2 �rawsockr4 �
sslcontextr5 r� r� r6 r7 r� � ssl_protocolr r r �_make_ssl_transport� s ��z)BaseProactorEventLoop._make_ssl_transportc C r� rH )r� )r2 r r4 r� r5 r6 r r r �_make_datagram_transport� r� z.BaseProactorEventLoop._make_datagram_transportc C � t | ||||�S rH )r� �r2 r r4 r5 r6 r r r �_make_duplex_pipe_transport� s �z1BaseProactorEventLoop._make_duplex_pipe_transportc C r� rH )rt r� r r r �_make_read_pipe_transport� s z/BaseProactorEventLoop._make_read_pipe_transportc C r� rH )r� r� r r r �_make_write_pipe_transport� s �z0BaseProactorEventLoop._make_write_pipe_transportc sj | � � rtd��| �� rd S t�� t�� u rt�d� | �� | � � | j
� � d | _
d | _ t
� � � d S )Nz!Cannot close a running event looprf )�
is_runningr� � is_closedr� r� r� r� r� �_stop_accept_futures�_close_self_piper� rR r� r rL r8 r r rR � s
zBaseProactorEventLoop.closec � � �| j �||�I d H S rH )r� r� )r2 r �nr r r � sock_recv� � �z BaseProactorEventLoop.sock_recvc � r� rH )r� r� )r2 r �bufr r r �sock_recv_into� r� z$BaseProactorEventLoop.sock_recv_intoc � r� rH )r� r� )r2 r r� r r r � sock_sendall� r� z"BaseProactorEventLoop.sock_sendallc � r� rH )r� �connect)r2 r r� r r r � sock_connect� r� z"BaseProactorEventLoop.sock_connectc � s �| j �|�I d H S rH )r� �acceptrF r r r � sock_accept� s �z!BaseProactorEventLoop.sock_acceptc
� s �z|� � }W n ttjfy } zt�d��d }~ww zt�|�j}W n t y0 t�d��w |r5|n|}|s;dS t
|d�}|rIt
|| |�n|} t
||�}d}
z. t
| | |�}|dkrl|
W |
dkrk|� |� S S | j �
||||�I d H ||7 }|
|7 }
qT|
dkr�|� |� w w )Nznot a regular filer l �� )r? �AttributeError�io�UnsupportedOperationr �SendfileNotAvailableError�os�fstat�st_sizer[ �min�seekr� �sendfile) r2 r �file�offset�countr? �errZfsize� blocksize�end_pos�
total_sentr r r �_sock_sendfile_native� sD �
��
�
��� �z+BaseProactorEventLoop._sock_sendfile_nativec � sn �|� � }|�� |�� I d H z| j|j|||dd�I d H W |�� |r*|�� S S |�� |r6|�� w w )NF)�fallback)r{ r| r� �
sock_sendfiler" r� r )r2 �transpr r
r r r r r �_sendfile_native� s � �
��
�z&BaseProactorEventLoop._sendfile_nativec C sL | j d ur
| j �� d | _ | j�� d | _| j�� d | _| jd8 _d S )Nr )r� rQ �_ssockrR r� �
_internal_fdsrL r r r r� � s
z&BaseProactorEventLoop._close_self_pipec C s: t �� \| _| _| j�d� | j�d� | jd7 _d S )NFr )r
�
socketpairr r� � setblockingr rL r r r r� � s z%BaseProactorEventLoop._make_self_pipec
C s� z|d ur |� � | j|urW d S | j�| jd�}W n/ tjy% Y d S ttfy. � t yI } z| �
d|| d�� W Y d }~d S d }~ww || _|� | j � d S )Ni z.Error on reading from the event loop self pipe)rX rY r3 )
r� r� r� r� r r r� r� r� r� r] r� �_loop_self_reading)r2 r� r_ r r r r s(
���z(BaseProactorEventLoop._loop_self_readingc C sR | j }|d u r d S z|�d� W d S ty( | jr%tjddd� Y d S Y d S w )N� z3Fail to write a null byte into the self-pipe socketTr )r� r� r[ �_debugr r\ )r2 �csockr r r �_write_to_self s ���z$BaseProactorEventLoop._write_to_self�d c s( d� ������fdd� � �� � � d S )Nc
sJ zE| d ur7| � � \}}�jrt�d�||� �� }�d ur,�j||�dd|i��d� n �j||d|i�d� ��� r>W d S �j���} W nQ t y� } z7��
� dkrd�� d|t �
��d�� ��� n�jrvtjd �dd
� W Y d }~d S W Y d }~d S W Y d }~d S d }~w tjy� ��� Y d S w | �j��
� < | �� � d S ) Nz#%r got a new connection from %r: %rTr )r� r6 r7 r� r� rf zAccept failed on a socket)rX rY r
zAccept failed on socket %rr )r� r r r\ r� r� r� r� r r[ r? r] r r rR r r� r� r� )r� �connr� r4 r_ �r3 �protocol_factoryr2 r7 r r� r� r r r3 2 sR ��� �
�����z2BaseProactorEventLoop._start_serving.<locals>.looprH )r- )r2 r$ r r� r7 �backlogr� r r# r �_start_serving. s %z$BaseProactorEventLoop._start_servingc C s d S rH r )r2 �
event_listr r r �_process_eventsY s z%BaseProactorEventLoop._process_eventsc C s& | j �� D ]}|�� q| j �� d S rH )r� �valuesrQ �clear)r2 �futurer r r r� ] s
z*BaseProactorEventLoop._stop_accept_futuresc C s6 | j �|�� d �}|r|�� | j�|� |�� d S rH )r� �popr? rQ r� �
_stop_servingrR )r2 r r+ r r r r- b s
z#BaseProactorEventLoop._stop_servingrm rH r� )NNr! N)r= rn ro r r� r� r� r� r� r� rR r� r� r� r� r r r r� r� r r r& r( r� r- rs r r r8 r r n sP
�� �
�
�
�
�
�+r )$rp �__all__r r r
rq r� r� r� � r r r r r r r
r �logr r �_FlowControlMixin�
BaseTransportr �
ReadTransportrt �WriteTransportr� r� �DatagramTransportr� � Transportr� r� �
BaseEventLoopr r r r r �<module> sX � � �n � � �