uawdijnntqw1x1x1
IP : 18.226.180.253
Hostname : host45.registrar-servers.com
Kernel : Linux host45.registrar-servers.com 4.18.0-513.18.1.lve.2.el8.x86_64 #1 SMP Sat Mar 30 15:36:11 UTC 2024 x86_64
Disable Function : None :)
OS : Linux
PATH:
/
home
/
..
/
run
/
..
/
usr
/
lib64
/
python3.8
/
asyncio
/
__pycache__
/
proactor_events.cpython-38.opt-1.pyc
/
/
U e5d<}�@sTdZdZddlZddlZddlZddlZddlZddlZddlZddl m Z ddl m Z ddl m Z ddl m Z dd l mZdd l mZdd l mZdd l mZdd lmZdd�ZGdd�dejej�ZGdd�deej�ZGdd�deej�ZGdd�de�Z Gdd�de�Z Gdd�deeej �Z Gd d �d eeej �Z Gd 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)�loggercCs�t�|�|jd<z|��|jd<Wn0tjk rR|j��rNtj d|dd�YnXd|jkr�z|� �|jd<Wn tjk r�d|jd<YnXdS)N�socketZsocknamezgetsockname() failed on %rT��exc_info�peername) r �TransportSocket�_extraZ getsocknamer �error�_loop� get_debugr �warningZ getpeername)� transport�sock�r�//usr/lib64/python3.8/asyncio/proactor_events.py�_set_socket_extra s � rcs�eZdZdZd �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.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_attachr� call_soon� _protocolZconnection_maderZ _set_result_unless_cancelled��self�loopr�protocol�waiter�extra�server�� __class__rrr 2s( �z#_ProactorBasePipeTransport.__init__cCs�|jjg}|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=z EOF writtenz<{}>� ) r4�__name__r �appendr(�filenor$r%r#�lenr)�format�join)r-�inforrr�__repr__Hs z#_ProactorBasePipeTransport.__repr__cCs||jd<dS)N�pipe)r�r-rrrrr Zsz%_ProactorBasePipeTransport._set_extracCs ||_dS�N�r+)r-r/rrrr!]sz'_ProactorBasePipeTransport.set_protocolcCs|jSrBrC�r-rrr� get_protocol`sz'_ProactorBasePipeTransport.get_protocolcCs|jSrB)r(rDrrr� is_closingcsz%_ProactorBasePipeTransport.is_closingcCs\|jr dSd|_|jd7_|js>|jdkr>|j�|jd�|jdk rX|j��d|_dS)NTr) r(r'r#r%rr*�_call_connection_lostr$�cancelrDrrr�closefs z _ProactorBasePipeTransport.closecCs*|jdk r&|d|��t|d�|��dS)Nzunclosed transport )�source)r �ResourceWarningrI)r-Z_warnrrr�__del__qs z"_ProactorBasePipeTransport.__del__� Fatal error on pipe transportc CsVzDt|t�r*|j��rBtjd||dd�n|j�||||jd��W5|�|�XdS)Nz%r: %sTr)�message� exceptionrr/) � _force_close� isinstance�OSErrorrrr �debug�call_exception_handlerr+)r-�excrNrrr� _fatal_errorvs � 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_exceptionr(r'r%rHr$r&r#rr*rG)r-rUrrrrP�s" z'_ProactorBasePipeTransport._force_closec Cs^z|j� |�W5t|jd�r,|j�tj�|j��d|_|j}|dk rX|��d|_XdS)N�shutdown) �hasattrr rZr Z SHUT_RDWRrIr"Z_detachr+Zconnection_lost)r-rUr2rrrrG�s z0_ProactorBasePipeTransport._call_connection_lostcCs"|j}|jdk r |t|j�7}|SrB)r&r#r;)r-�sizerrr�get_write_buffer_size�s z0_ProactorBasePipeTransport.get_write_buffer_size)NNN)rM)r8� __module__� __qualname__�__doc__r r?r r!rErFrI�warnings�warnrLrVrPrGr]� __classcell__rrr3rr .s � r csTeZdZdZd�fdd� Zdd�Zdd�Zd d �Zd d �Zd d�Z ddd�Z �Z S)�_ProactorReadPipeTransportzTransport for read pipes.Ncs:d|_d|_t��||||||�|j�|j�d|_dS)NTF)� _pending_data�_pausedr r rr*� _loop_readingr,r3rrr �s z#_ProactorReadPipeTransport.__init__cCs|j o|j SrB)rfr(rDrrr� is_reading�sz%_ProactorReadPipeTransport.is_readingcCs0|js |jrdSd|_|j��r,t�d|�dS)NTz%r pauses reading)r(rfrrr rSrDrrr� pause_reading�s z(_ProactorReadPipeTransport.pause_readingcCsn|js |jsdSd|_|jdkr0|j�|jd�|j}d|_|dk rT|j�|j|�|j��rjt � d|�dS)NFz%r resumes reading) r(rfr$rr*rgre�_data_receivedrr rS�r-�datarrr�resume_reading�s z)_ProactorReadPipeTransport.resume_readingc Cs�|j��rt�d|�z|j��}WnLttfk r>�Yn4tk rp}z|� |d�WY�dSd}~XYnX|s~|� �dS)Nz%r received EOFz1Fatal error: protocol.eof_received() call failed.) rrr rSr+Z eof_received� SystemExit�KeyboardInterrupt� BaseExceptionrVrI)r-Z keep_openrUrrr� _eof_received�s �z(_ProactorReadPipeTransport._eof_receivedc Cs�|jr||_dS|s |��dSt|jtj�r�zt�|j|�Wq�tt fk rZ�Yq�t k r�}z|� |d�WY�dSd}~XYq�Xn |j� |�dS)Nz3Fatal error: protocol.buffer_updated() call failed.) rfrerqrQr+rZBufferedProtocolZ _feed_data_to_buffered_protornrorprVZ data_received)r-rlrUrrrrj�s"�z)_ProactorReadPipeTransport._data_receivedc Cstd}�zRzp|dk r2d|_|��r*|��}n|��|jrHd}WW��dS|dkr\WW��dS|jsv|jj� |j d�|_Wn�t k r�}z0|js�|� |d�n|j� �r�tjddd�W5d}~XYn�tk r�}z|�|�W5d}~XYnftk �r }z|� |d�W5d}~XYn8tjk �r>|j�s:�YnX|j�sV|j�|j�W5|dk �rn|�|�XdS)N�i�z"Fatal read error on pipe transportz*Read error on pipe transport while closingTr)rjr$rX�resultrHr(rfr� _proactor�recvr �ConnectionAbortedErrorrVrr rS�ConnectionResetErrorrPrRr�CancelledError�add_done_callbackrg)r-�futrlrUrrrrgs@ � z(_ProactorReadPipeTransport._loop_reading)NNN)N) r8r^r_r`r rhrirmrqrjrgrcrrr3rrd�s� rdcs^eZdZdZdZ�fdd�Zdd�Zddd �Zd d �Zd d �Z dd�Z dd�Z dd�Z �Z S)� _ProactorBaseWritePipeTransportzTransport for write pipes.Tcst�j||�d|_dSrB)r r rW�r-�args�kwr3rrr Gsz(_ProactorBaseWritePipeTransport.__init__cCs�t|tttf�s$tdt|�j����|jr2td��|j dk rDtd��|sLdS|j rz|j t j krht �d�|j d7_ dS|jdkr�|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 progressz socket.send() raised exception.r)rl)rQ�bytes� bytearray� memoryview� TypeError�typer8r)� RuntimeErrorrWr'r�!LOG_THRESHOLD_FOR_CONNLOST_WRITESr rr%� _loop_writingr#�_maybe_pause_protocol�extendrkrrr�writeKs,� z%_ProactorBaseWritePipeTransport.writeNc CsVz�|dk r |jdkr |jr WdSd|_d|_|r8|��|dkrL|j}d|_|s�|jrf|j�|jd�|jrz|j � t j �|� �nN|jj�|j |�|_|j��s�t|�|_|j�|j�|��n|j�|j�|jdk r�|jdkr�|j�d�Wn\tk �r"}z|�|�W5d}~XYn0tk �rP}z|�|d�W5d}~XYnXdS)Nrz#Fatal write error on pipe transport)r%r(r&rsr#rr*rGr)r rZr �SHUT_WR�_maybe_resume_protocolrt�sendrXr;ryr�r�rWrYrwrPrRrV)r-�frlrUrrrr�qs8 z-_ProactorBaseWritePipeTransport._loop_writingcCsdS�NTrrDrrr� can_write_eof�sz-_ProactorBaseWritePipeTransport.can_write_eofcCs |��dSrB)rIrDrrr� write_eof�sz)_ProactorBaseWritePipeTransport.write_eofcCs|�d�dSrB�rPrDrrr�abort�sz%_ProactorBaseWritePipeTransport.abortcCs:|jdk rtd��|j��|_|jdkr4|j�d�|jS)NzEmpty waiter is already set)rWr�rZ create_futurer%rYrDrrr�_make_empty_waiter�s z2_ProactorBaseWritePipeTransport._make_empty_waitercCs d|_dSrB)rWrDrrr�_reset_empty_waiter�sz3_ProactorBaseWritePipeTransport._reset_empty_waiter)NN)r8r^r_r`Z_start_tls_compatibler r�r�r�r�r�r�r�rcrrr3rr{As & )r{cs$eZdZ�fdd�Zdd�Z�ZS)�_ProactorWritePipeTransportcs4t�j||�|jj�|jd�|_|j�|j�dS)N�) r r rrtrur r$ry� _pipe_closedr|r3rrr �sz$_ProactorWritePipeTransport.__init__cCs@|��r dS|jrdSd|_|jdk r4|�t��n|��dSrB)Z cancelledr(r$r%rP�BrokenPipeErrorrI)r-rzrrrr��s z(_ProactorWritePipeTransport._pipe_closed)r8r^r_r r�rcrrr3rr��s r�csXeZdZdZd�fdd� Zdd�Zdd�Zd d �Zdd d �Zdd d�Z ddd�Z �Z S)�_ProactorDatagramTransportiNcs>||_d|_t�j|||||d�t��|_|j�|j �dS)N)r0r1) �_addressrWr r � collections�dequer#rr*rg)r-r.rr/�addressr0r1r3rrr �s z#_ProactorDatagramTransport.__init__cCst||�dSrB�rrArrrr �sz%_ProactorDatagramTransport._set_extracCstdd�|jD��S)Ncss|]\}}t|�VqdSrB)r;)�.0rl�_rrr� <genexpr>�szC_ProactorDatagramTransport.get_write_buffer_size.<locals>.<genexpr>)�sumr#rDrrrr]�sz0_ProactorDatagramTransport.get_write_buffer_sizecCs|�d�dSrBr�rDrrrr��sz _ProactorDatagramTransport.abortcCs�t|tttf�s tdt|���|s&dS|jdk rN|d|jfkrNtd|j����|jr�|jr�|jt j krpt � d�|jd7_dS|j �t|�|f�|jdkr�|��|��dS)Nz,data argument must be bytes-like object (%r)z!Invalid address: must be None or z!socket.sendto() raised exception.r)rQrr�r�r�r�r�� ValueErrorr'rr�r rr#r9r%r�r�)r-rl�addrrrr�sendto�s&� � z!_ProactorDatagramTransport.sendtoc Cs z�|jrWdSd|_|r |��|jr2|jrN|jrN|jrH|j�|jd�WdS|j� �\}}|jdk r||jj � |j |�|_n|jj j |j ||d�|_WnZtk r�}z|j�|�W5d}~XYnDtk r�}z|�|d�W5d}~XYnX|j�|j�|��dS)N)r�z'Fatal write error on datagram transport)r'r%rsr#r�r(rr*rG�popleftrtr�r r�rRr+�error_received� ExceptionrVryr�r�)r-rzrlr�rUrrrr��s2 � � z(_ProactorDatagramTransport._loop_writingc Cs4d}�zz�|jr WW��dSd|_|dk rf|��}|jrFd}WW��dS|jdk r^||j}}n|\}}|jrvWW��dS|jdk r�|jj� |j |j �|_n|jj� |j |j �|_WnJt k r�}z|j�|�W5d}~XYn8tjk r�|js��Yn X|jdk �r|j�|j�W5|�r.|j�||�XdSrB)r+Zdatagram_receivedr'r$rsr(r�rrtrur �max_sizeZrecvfromrRr�rrxryrg)r-rzrlr��resrUrrrrgs> � � z(_ProactorDatagramTransport._loop_reading)NNN)N)N)N) r8r^r_r�r r r]r�r�r�rgrcrrr3rr��s� !r�c@s eZdZdZdd�Zdd�ZdS)� _ProactorDuplexPipeTransportzTransport for duplex pipes.cCsdS)NFrrDrrrr�Jsz*_ProactorDuplexPipeTransport.can_write_eofcCst�dSrB)�NotImplementedErrorrDrrrr�Msz&_ProactorDuplexPipeTransport.write_eofN)r8r^r_r`r�r�rrrrr�Esr�csBeZdZdZejjZd �fdd� Zdd�Z dd�Z d d �Z �Z S) �_ProactorSocketTransportz Transport for connected sockets.Ncs$t��||||||�t�|�dSrB)r r rZ _set_nodelayr,r3rrr Xsz!_ProactorSocketTransport.__init__cCst||�dSrBr�rArrrr ]sz#_ProactorSocketTransport._set_extracCsdSr�rrDrrrr�`sz&_ProactorSocketTransport.can_write_eofcCs2|js |jrdSd|_|jdkr.|j�tj�dSr�)r(r)r%r rZr r�rDrrrr�cs z"_ProactorSocketTransport.write_eof)NNN) r8r^r_r`rZ _SendfileModeZ TRY_NATIVEZ_sendfile_compatibler r r�r�rcrrr3rr�Qs�r�cs�eZdZ�fdd�Zd3dd�Zd4dddddd�dd �Zd5d d �Zd6d d �Zd7dd�Zd8dd�Z �fdd�Z dd�Z dd�Z dd�Z dd�Zd d �Zd d �Zd d!�Zd"d#�Zd$d%�Zd9d&d'�Zd(d)�Zd:d+d,�Zd-d.�Zd/d0�Zd1d2�Z�ZS);rcsht���t�d|jj�||_||_d|_i|_ |� |�|� �t � �t ��krdt�|j���dS)NzUsing proactor: %s)r r r rSr4r8rt� _selector�_self_reading_future�_accept_futuresZset_loop�_make_self_pipe� threading�current_thread� main_thread�signal� set_wakeup_fd�_csockr:)r-Zproactorr3rrr ms z BaseProactorEventLoop.__init__NcCst||||||�SrB)r�)r-rr/r0r1r2rrr�_make_socket_transportzs �z,BaseProactorEventLoop._make_socket_transportF)� server_side�server_hostnamer1r2�ssl_handshake_timeoutc Cs0tj||||||| d�} t||| ||d�| jS)N)r��r1r2)r Z SSLProtocolr�Z_app_transport) r-Zrawsockr/� sslcontextr0r�r�r1r2r�Z ssl_protocolrrr�_make_ssl_transports ��z)BaseProactorEventLoop._make_ssl_transportcCst||||||�SrB)r�)r-rr/r�r0r1rrr�_make_datagram_transport�s �z.BaseProactorEventLoop._make_datagram_transportcCst|||||�SrB)r��r-rr/r0r1rrr�_make_duplex_pipe_transport�s �z1BaseProactorEventLoop._make_duplex_pipe_transportcCst|||||�SrB)rdr�rrr�_make_read_pipe_transport�sz/BaseProactorEventLoop._make_read_pipe_transportcCst|||||�SrB)r�r�rrr�_make_write_pipe_transport�s �z0BaseProactorEventLoop._make_write_pipe_transportcsj|��rtd��|��r dSt��t��kr6t�d�|��|� �|j � �d|_ d|_ t �� �dS)Nz!Cannot close a running event loop���)Z is_runningr�� is_closedr�r�r�r�r��_stop_accept_futures�_close_self_pipertrIr�r rDr3rrrI�s zBaseProactorEventLoop.closec�s|j�||�IdHSrB)rtru)r-r�nrrr� sock_recv�sz BaseProactorEventLoop.sock_recvc�s|j�||�IdHSrB)rtZ recv_into)r-rZbufrrr�sock_recv_into�sz$BaseProactorEventLoop.sock_recv_intoc�s|j�||�IdHSrB)rtr�)r-rrlrrr� sock_sendall�sz"BaseProactorEventLoop.sock_sendallc�s|j�||�IdHSrB)rtZconnect)r-rr�rrr� sock_connect�sz"BaseProactorEventLoop.sock_connectc�s|j�|�IdHSrB)rt�acceptrArrr� sock_accept�sz!BaseProactorEventLoop.sock_acceptc �s(z |��}Wn2ttjfk r>}zt�d��W5d}~XYnXzt�|�j}Wn,t k r|}zt�d��W5d}~XYnX|r�|n|}|s�dSt |d�}|r�t |||�n|} t ||�}d} zLt | ||�}|dkr�| W�0S|j � ||||�IdH||7}| |7} q�W5| dk�r"|� |�XdS)Nznot a regular filerl��)r:�AttributeError�io�UnsupportedOperationrZSendfileNotAvailableError�os�fstat�st_sizerR�min�seekrt�sendfile) r-r�file�offset�countr:�errZfsizeZ blocksizeZend_posZ total_sentrrr�_sock_sendfile_native�s0 z+BaseProactorEventLoop._sock_sendfile_nativec�sZ|��}|��|��IdHz |j|j|||dd�IdHW�S|��|rT|��XdS)NF)Zfallback)rhrir�r�rmZ sock_sendfiler )r-Ztranspr�r�r�rmrrr�_sendfile_native�s�z&BaseProactorEventLoop._sendfile_nativecCsL|jdk r|j��d|_|j��d|_|j��d|_|jd8_dS)Nr)r�rH�_ssockrIr�� _internal_fdsrDrrrr��s z&BaseProactorEventLoop._close_self_pipecCs:t��\|_|_|j�d�|j�d�|jd7_dS)NFr)r Z socketpairr�r�Z setblockingr�rDrrrr��s z%BaseProactorEventLoop._make_self_pipec Cs�z4|dk r|��|j|k r"WdS|j�|jd�}Wnbtjk rLYdSttfk rd�YnFt k r�}z|� d||d��W5d}~XYnX||_|� |j �dS)Niz.Error on reading from the event loop self pipe)rNrOr.) rsr�rtrur�rrxrnrorprTry�_loop_self_reading)r-r�rUrrrr��s$ �z(BaseProactorEventLoop._loop_self_readingcCsN|j}|dkrdSz|�d�Wn(tk rH|jrDtjddd�YnXdS)N�z3Fail to write a null byte into the self-pipe socketTr)r�r�rR�_debugr rS)r-Zcsockrrr�_write_to_selfs�z$BaseProactorEventLoop._write_to_self�dcs(d�������fdd� �����dS)Nc s,z�|dk rn|��\}}�jr,t�d�||���}�dk rX�j||�dd|i��d�n�j||d|i�d����r|WdS�j���}Wn�t k r�}zH�� �dkrʈ� d|t � ��d�����n�jr�tjd �dd �W5d}~XYn8tjk �r���YnX|�j�� �<|���dS) Nz#%r got a new connection from %r: %rTr)r�r1r2r�r�r�zAccept failed on a socket)rNrOr zAccept failed on socket %rr)rsr�r rSr�r�r�rtr�rRr:rTr rrIrrxr�ry)r�Zconnr�r/rU�r.�protocol_factoryr-r2rr�r�rrr./s\ ��� � �z2BaseProactorEventLoop._start_serving.<locals>.loop)N)r*)r-r�rr�r2Zbacklogr�rr�r�_start_serving+s%z$BaseProactorEventLoop._start_servingcCsdSrBr)r-Z event_listrrr�_process_eventsVsz%BaseProactorEventLoop._process_eventscCs&|j��D] }|��q |j��dSrB)r��valuesrH�clear)r-�futurerrrr�Zs z*BaseProactorEventLoop._stop_accept_futurescCs6|j�|��d�}|r |��|j�|�|��dSrB)r��popr:rHrt� _stop_servingrI)r-rr�rrrr�_s z#BaseProactorEventLoop._stop_serving)NNN)N)NNN)NN)NN)NN)N)NNr�N)r8r^r_r r�r�r�r�r�r�rIr�r�r�r�r�r�r�r�r�r�r�r�r�r�r�rcrrr3rrks\ � �� � � � � � +r)#r`�__all__r�r�r rar�r�r��rrrrrr r r �logr rZ_FlowControlMixinZ BaseTransportr Z ReadTransportrdZWriteTransportr{r�r�Z Transportr�r�Z BaseEventLooprrrrr�<module>sR � � �n � �
/home/../run/../usr/lib64/python3.8/asyncio/__pycache__/proactor_events.cpython-38.opt-1.pyc