1902041114081995

U e5dT��@s.dZdZddlZddlZddlZddlZddlZddlZddlZzddl Z Wne k rddZ YnXddlmZddlm Z ddlmZddlmZdd lmZdd lmZddlmZddlmZdd lmZdd�Zdd�ZGdd�dej�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)�loggercCs8z|�|�}Wntk r$YdSXt|j|@�SdS�NF)�get_key�KeyError�boolr)�selector�fdZevent�key�r�//usr/lib64/python3.8/asyncio/selector_events.py�_test_selector_event s rcCs tdk rt|tj�rtd��dS)Nz"Socket cannot be of type SSLSocket)�ssl� isinstanceZ SSLSocket� TypeError)�sockrrr�_check_ssl_socket+srcs�eZdZdZdS�fdd� ZdTddd�dd�ZdUddddejd �d d�ZdVdd �Z �fdd�Z dd�Zdd�Zdd�Z dd�Zdd�Zdddejfdd�Zdddejfdd�Zddejfdd �Zd!d"�Zd#d$�Zd%d&�Zd'd(�Zd)d*�Zd+d,�Zd-d.�Zd/d0�Zd1d2�Zd3d4�Zd5d6�Zd7d8�Zd9d:�Zd;d<�Z d=d>�Z!d?d@�Z"dAdB�Z#dCdD�Z$dEdF�Z%dGdH�Z&dIdJ�Z'dKdL�Z(dMdN�Z)dOdP�Z*dQdR�Z+�Z,S)WrzJSelector event loop. See events.EventLoop for API specification. NcsFt��|dkrt��}t�d|jj�||_|� �t ��|_dS)NzUsing selector: %s) �super�__init__� selectorsZDefaultSelectorr�debug� __class__�__name__� _selector�_make_self_pipe�weakrefZWeakValueDictionary�_transports)�selfr�r rrr6s zBaseSelectorEventLoop.__init__��extra�servercCst||||||�S�N)�_SelectorSocketTransport)r&r�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)r2r()r ZSSLProtocolr,Z_app_transport)r&Zrawsockr-� sslcontextr.r0r1r)r*r2Zssl_protocolrrr�_make_ssl_transportEs��z)BaseSelectorEventLoop._make_ssl_transportcCst||||||�Sr+)�_SelectorDatagramTransport)r&rr-�addressr.r)rrr�_make_datagram_transportRs �z.BaseSelectorEventLoop._make_datagram_transportcsL|��rtd��|��rdS|��t��|jdk rH|j��d|_dS)Nz!Cannot close a running event loop)Z is_running�RuntimeError� is_closed�_close_self_piper�closer"�r&r'rrr;Ws zBaseSelectorEventLoop.closecCsB|�|j��|j��d|_|j��d|_|jd8_dS)Nr)�_remove_reader�_ssock�filenor;�_csock� _internal_fdsr<rrrr:bs z&BaseSelectorEventLoop._close_self_pipecCsNt��\|_|_|j�d�|j�d�|jd7_|�|j��|j�dS)NFr) �socketZ socketpairr>r@�setblockingrA�_add_readerr?�_read_from_selfr<rrrr#js z%BaseSelectorEventLoop._make_self_pipecCsdSr+r�r&�datarrr�_process_self_datarsz(BaseSelectorEventLoop._process_self_datacCsXz"|j�d�}|sWqT|�|�Wqtk r:YqYqtk rPYqTYqXqdS)Ni)r>�recvrH�InterruptedError�BlockingIOErrorrFrrrrEusz%BaseSelectorEventLoop._read_from_selfcCsN|j}|dkrdSz|�d�Wn(tk rH|jrDtjddd�YnXdS)N�z3Fail to write a null byte into the self-pipe socketT��exc_info)r@�send�OSError�_debugrr)r&Zcsockrrr�_write_to_self�s�z$BaseSelectorEventLoop._write_to_self�dc Cs"|�|��|j||||||�dSr+)rDr?�_accept_connection)r&�protocol_factoryrr3r*�backlogr2rrr�_start_serving�s�z$BaseSelectorEventLoop._start_servingc Cst|�D]�}z0|��\}} |jr0t�d|| |�|�d�Wn�tttfk rZYdSt k r�} zd| j t jt jt j t jfkr�|�d| t�|�d��|�|��|�tj|j||||||�n�W5d} ~ XYqXd| i}|�||||||�}|�|�qdS)Nz#%r got a new connection from %r: %rFz&socket.accept() out of system resource)�message� exceptionrB�peername)�range�acceptrQrrrCrKrJ�ConnectionAbortedErrorrP�errnoZEMFILEZENFILEZENOBUFSZENOMEM�call_exception_handlerr�TransportSocketr=r?Z call_laterrZACCEPT_RETRY_DELAYrW�_accept_connection2Zcreate_task) r&rUrr3r*rVr2�_�conn�addr�excr)r\rrrrT�sV��z(BaseSelectorEventLoop._accept_connectionc �s�d}d}zt|�}|��} |r8|j|||| d|||d�}n|j||| ||d�}z| IdHWntk rx|��YnXWntttfk r��Yn\tk r�} z>|jr�d| d�}|dk r�||d<|dk r�||d<|�|�W5d} ~ XYnXdS)NT)r.r0r)r*r2)r.r)r*z3Error on transport creation for incoming connection)rXrYr-� transport) � create_futurer4r/� BaseExceptionr;� SystemExit�KeyboardInterruptrQr_)r&rUrcr)r3r*r2r-rfr.re�contextrrrra�sP��z)BaseSelectorEventLoop._accept_connection2c Cs�|}t|t�sJzt|��}Wn*tttfk rHtd|��d�YnXz|j|}Wntk rlYnX|��s�t d|�d|��dS)NzInvalid file object: zFile descriptor z is used by transport ) r�intr?�AttributeErrorr� ValueErrorr%r� is_closingr8)r&rr?rfrrr�_ensure_fd_no_transport�s �z-BaseSelectorEventLoop._ensure_fd_no_transportc Gs�|��t�|||d�}z|j�|�}Wn*tk rR|j�|tj|df�Yn>X|j|j }\}}|j� ||tjB||f�|dk r�|��dSr+)� _check_closedr�Handler"rr�registerr� EVENT_READrG�modify�cancel� r&r�callback�argsZhandler�mask�reader�writerrrrrDs� �z!BaseSelectorEventLoop._add_readercCs�|��rdSz|j�|�}Wntk r2YdSX|j|j}\}}|tjM}|sd|j�|�n|j� ||d|f�|dk r�|� �dSdSdS�NFT)r9r"rrrrGrrt� unregisterrurv�r&rrrzr{r|rrrr=sz$BaseSelectorEventLoop._remove_readerc Gs�|��t�|||d�}z|j�|�}Wn*tk rR|j�|tjd|f�Yn>X|j|j }\}}|j� ||tjB||f�|dk r�|��dSr+)rqrrrr"rrrsr�EVENT_WRITErGrurvrwrrr�_add_writer%s� �z!BaseSelectorEventLoop._add_writercCs�|��rdSz|j�|�}Wntk r2YdSX|j|j}\}}|tjM}|sd|j�|�n|j� |||df�|dk r�|� �dSdSdS)�Remove a writer callback.FNT)r9r"rrrrGrr�r~rurvrrrr�_remove_writer4sz$BaseSelectorEventLoop._remove_writercGs|�|�|j||f|��S)zAdd a reader callback.)rprD�r&rrxryrrr� add_readerKs z BaseSelectorEventLoop.add_readercCs|�|�|�|�S)zRemove a reader callback.)rpr=�r&rrrr� remove_readerPs z#BaseSelectorEventLoop.remove_readercGs|�|�|j||f|��S)zAdd a writer callback..)rpr�r�rrr� add_writerUs z BaseSelectorEventLoop.add_writercCs|�|�|�|�S)r�)rpr�r�rrr� remove_writerZs z#BaseSelectorEventLoop.remove_writerc �s�t|�|jr"|��dkr"td��z|�|�WSttfk rFYnX|��}|��}|� ||j |||�|�t� |j|��|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-blockingN)rrQ� gettimeoutrnrIrKrJrgr?r�� _sock_recv�add_done_callback� functools�partial�_sock_read_done)r&r�n�futrrrr� sock_recv_s�zBaseSelectorEventLoop.sock_recvcCs|�|�dSr+)r��r&rr�rrrr�tsz%BaseSelectorEventLoop._sock_read_donec Cs�|��rdSz|�|�}Wn\ttfk r4YdSttfk rL�Yn6tk rv}z|�|�W5d}~XYnX|�|�dSr+) �donerIrKrJrirjrh� set_exception� set_result)r&r�rr�rGrerrrr�wsz BaseSelectorEventLoop._sock_recvc �s�t|�|jr"|��dkr"td��z|�|�WSttfk rFYnX|��}|��}|� ||j |||�|�t� |j|��|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�N)rrQr�rn� recv_intorKrJrgr?r��_sock_recv_intor�r�r�r�)r&r�bufr�rrrr�sock_recv_into�s�z$BaseSelectorEventLoop.sock_recv_intoc Cs�|��rdSz|�|�}Wn\ttfk r4YdSttfk rL�Yn6tk rv}z|�|�W5d}~XYnX|�|�dSr+) r�r�rKrJrirjrhr�r�)r&r�rr��nbytesrerrrr��sz%BaseSelectorEventLoop._sock_recv_intoc �s�t|�|jr"|��dkr"td��z|�|�}Wnttfk rLd}YnX|t|�kr^dS|��}|� �}|� t�|j |��|�||j||t|�|g�|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�N)rrQr�rnrOrKrJ�lenrgr?r�r�r��_sock_write_doner�� _sock_sendall� memoryview)r&rrGr�r�rrrr�sock_sendall�s& ��z"BaseSelectorEventLoop.sock_sendallc Cs�|��rdS|d}z|�||d��}Wnbttfk rDYdSttfk r\�Yn2tk r�}z|�|�WY�dSd}~XYnX||7}|t|�kr�|� d�n||d<dS)Nr) r�rOrKrJrirjrhr�r�r�)r&r�rZview�pos�startr�rerrrr��s z#BaseSelectorEventLoop._sock_sendallc�s�t|�|jr"|��dkr"td��ttd�r8|jtjkrf|j||j|j |d�IdH}|d\}}}}}|� �}|�|||�|IdHS)zTConnect to a remote socket at address. This method is a coroutine. rr��AF_UNIX)�family�proto�loopN)rrQr�rn�hasattrrBr�r�Z_ensure_resolvedr�rg� _sock_connect)r&rr6Zresolvedrbr�rrr�sock_connect�s�z"BaseSelectorEventLoop.sock_connectc Cs�|��}z|�|�Wn�ttfk rV|�t�|j|��|�||j |||�YnNt tfk rn�Yn6tk r�}z|� |�W5d}~XYnX|�d�dSr+)r?ZconnectrKrJr�r�r�r�r��_sock_connect_cbrirjrhr�r�)r&r�rr6rrerrrr��s�z#BaseSelectorEventLoop._sock_connectcCs|�|�dSr+)r�r�rrrr�sz&BaseSelectorEventLoop._sock_write_donec Cs�|��rdSz,|�tjtj�}|dkr6t|d|��WnZttfk rPYnNtt fk rh�Yn6t k r�}z|�|�W5d}~XYnX|�d�dS)NrzConnect call failed ) r�Z getsockoptrBZ SOL_SOCKETZSO_ERRORrPrKrJrirjrhr�r�)r&r�rr6�errrerrrr�sz&BaseSelectorEventLoop._sock_connect_cbc�sBt|�|jr"|��dkr"td��|��}|�|d|�|IdHS)aWAccept 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�FN)rrQr�rnrg�_sock_accept)r&rr�rrr�sock_acceptsz!BaseSelectorEventLoop.sock_acceptc Cs�|��}|r|�|�|��r"dSz|��\}}|�d�Wnnttfk rh|�||j|d|�YnRt t fk r��Yn:tk r�}z|�|�W5d}~XYnX|� ||f�dSr})r?r�r�r\rCrKrJr�r�rirjrhr�r�)r&r�Z registeredrrrcr6rerrrr�*s z"BaseSelectorEventLoop._sock_acceptc �sp|j|j=|��}|��|��IdHz |j|j|||dd�IdHW�S|��|r^|��||j|j<XdS)NF)Zfallback) r%�_sock_fd� is_reading� pause_reading�_make_empty_waiter�_reset_empty_waiter�resume_readingZ sock_sendfile�_sock)r&Ztransp�file�offset�countr�rrr�_sendfile_native<s �z&BaseSelectorEventLoop._sendfile_nativecCs�|D]v\}}|j|j}\}}|tj@rL|dk rL|jrB|�|�n |�|�|tj@r|dk r|jrp|�|�q|�|�qdSr+) �fileobjrGrrtZ _cancelledr=Z _add_callbackr�r�)r&Z event_listrrzr�r{r|rrr�_process_eventsJs z%BaseSelectorEventLoop._process_eventscCs|�|��|��dSr+)r=r?r;)r&rrrr� _stop_servingXsz#BaseSelectorEventLoop._stop_serving)N)N)N)NNN)-r!� __module__�__qualname__�__doc__rr/rZSSL_HANDSHAKE_TIMEOUTr4r7r;r:r#rHrErRrWrTrarprDr=r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�� __classcell__rrr'rr0s~ �� .� )rcs�eZdZdZeZdZd�fdd� Zdd�Zdd�Z d d �Z dd�Zd d�Zdd�Z ejfdd�Zddd�Zdd�Zdd�Zdd�Zdd�Z�ZS) �_SelectorTransportiNcs�t��||�t�|�|jd<z|��|jd<Wntk rNd|jd<YnXd|jkr�z|��|jd<Wn tj k r�d|jd<YnX||_ |��|_d|_ |�|�||_|��|_d|_d|_|jdk r�|j��||j|j<dS)NrBZsocknamerZFr)rrrr`�_extraZgetsocknamerPZgetpeernamerB�errorr�r?r��_protocol_connected�set_protocol�_server�_buffer_factory�_buffer� _conn_lost�_closingZ_attachr%)r&r�rr-r)r*r'rrris, z_SelectorTransport.__init__cCs�|jjg}|jdkr |�d�n|jr0|�d�|�d|j��|jdk 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=zread=pollingz read=idle�pollingZidlezwrite=<z , bufsize=�>z<{}>� )r r!r��appendr�r��_loopr9rr"rrtr��get_write_buffer_size�format�join)r&�infor��state�bufsizerrr�__repr__�s0 � �z_SelectorTransport.__repr__cCs|�d�dSr+)�_force_closer<rrr�abort�sz_SelectorTransport.abortcCs||_d|_dS�NT)� _protocolr��r&r-rrrr��sz_SelectorTransport.set_protocolcCs|jSr+)r�r<rrr�get_protocol�sz_SelectorTransport.get_protocolcCs|jSr+)r�r<rrrro�sz_SelectorTransport.is_closingcCsT|jr dSd|_|j�|j�|jsP|jd7_|j�|j�|j�|jd�dS�NTr) r�r�r=r�r�r�r�� call_soon�_call_connection_lostr<rrrr;�sz_SelectorTransport.closecCs,|jdk r(|d|��t|d�|j��dS)Nzunclosed transport )�source)r��ResourceWarningr;)r&Z_warnrrr�__del__�s z_SelectorTransport.__del__�Fatal error on transportcCsNt|t�r(|j��r@tjd||dd�n|j�||||jd��|�|�dS)Nz%r: %sTrM)rXrYrfr-) rrPr�� get_debugrrr_r�r�)r&rerXrrr�_fatal_error�s �z_SelectorTransport._fatal_errorcCsd|jr dS|jr(|j��|j�|j�|jsBd|_|j�|j�|jd7_|j�|j |�dSr�) r�r��clearr�r�r�r�r=r�r��r&rerrrr��s z_SelectorTransport._force_closecCsVz|jr|j�|�W5|j��d|_d|_d|_|j}|dk rP|��d|_XdSr+)r�r;r�r�r�Z_detachr�Zconnection_lost)r&rer*rrrr��s z(_SelectorTransport._call_connection_lostcCs t|j�Sr+)r�r�r<rrrr��sz(_SelectorTransport.get_write_buffer_sizecGs"|jr dS|jj||f|��dSr+)r�r�rDr�rrrrD�sz_SelectorTransport._add_reader)NN)r�)r!r�r��max_size� bytearrayr�r�rr�r�r�r�ror;�warnings�warnr�r�r�r�r�rDr�rrr'rr�]s r�cs�eZdZdZejjZd#�fdd� Z�fdd�Z dd�Z d d �Zdd�Zd d�Z dd�Zdd�Zdd�Zdd�Zdd�Zdd�Zdd�Z�fdd�Zdd �Zd!d"�Z�ZS)$r,TNcs~d|_t��|||||�d|_d|_d|_t�|j�|j � |jj|�|j � |j |j|j�|dk rz|j � tj|d�dSr )�_read_ready_cbrr�_eof�_paused� _empty_waiterrZ_set_nodelayr�r�r�r��connection_maderDr��_read_readyr�_set_result_unless_cancelled)r&r�rr-r.r)r*r'rrr�s � �z!_SelectorSocketTransport.__init__cs.t|tj�r|j|_n|j|_t��|�dSr+)rrZBufferedProtocol�_read_ready__get_bufferr��_read_ready__data_receivedrr�r�r'rrr� s z%_SelectorSocketTransport.set_protocolcCs|jo|jSr+)r�r�r<rrrr�sz#_SelectorSocketTransport.is_readingcCs>|js|jrdSd|_|j�|j�|j��r:t�d|�dS)NTz%r pauses reading)r�r�r�r=r�r�rrr<rrrr�s z&_SelectorSocketTransport.pause_readingcCs@|js|jsdSd|_|�|j|j�|j��r<t�d|�dS)NFz%r resumes reading) r�r�rDr�r�r�r�rrr<rrrr�s z'_SelectorSocketTransport.resume_readingcCs|��dSr+)r�r<rrrr�$sz$_SelectorSocketTransport._read_readyc Cs`|jr dSz |j�d�}t|�s(td��WnLttfk rD�Yn4tk rv}z|�|d�WY�dSd}~XYnXz|j � |�}Wndttfk r�YdSttfk r��Yn4tk r�}z|�|d�WY�dSd}~XYnX|�s|� �dSz|j�|�WnJttfk �r,�Yn0tk �rZ}z|�|d�W5d}~XYnXdS)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�r8rirjrhr�r�r�rKrJ�_read_ready__on_eofZbuffer_updated)r&r�rer�rrrr�'sF��z0_SelectorSocketTransport._read_ready__get_bufferc Cs�|jr dSz|j�|j�}Wndttfk r6YdSttfk rN�Yn4tk r�}z|� |d�WY�dSd}~XYnX|s�|� �dSz|j�|�WnFttfk r��Yn.tk r�}z|� |d�W5d}~XYnXdS)Nr�z2Fatal error: protocol.data_received() call failed.) r�r�rIr�rKrJrirjrhr�r�r�Z data_received)r&rGrerrrr�Ls.�z3_SelectorSocketTransport._read_ready__data_receivedc Cs�|j��rt�d|�z|j��}WnLttfk r>�Yn4tk rp}z|� |d�WY�dSd}~XYnX|r�|j� |j�n|��dS)Nz%r received EOFz1Fatal error: protocol.eof_received() call failed.) r�r�rrr�Zeof_receivedrirjrhr�r=r�r;)r&Z keep_openrerrrr�es �z,_SelectorSocketTransport._read_ready__on_eofc Cs6t|tttf�s$tdt|�j��|jr2td��|j dk rDtd��|sLdS|j rz|j tjkrht �d�|j d7_ dS|j�sz|j�|�}Wnbttfk r�Ynbttfk r��YnJtk r�}z|�|d�WY�dSd}~XYnX||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)r�bytesr�r�r�typer!r�r8r�r�r�!LOG_THRESHOLD_FOR_CONNLOST_WRITESr�warningr�r�rOrKrJrirjrhr�r�r�r��_write_ready�extend�_maybe_pause_protocol)r&rGr�rerrr�writezs: z_SelectorSocketTransport.writec Cs|jr dSz|j�|j�}Wn�ttfk r4Yn�ttfk rL�Yn�tk r�}z>|j � |j�|j��|� |d�|jdk r�|j�|�W5d}~XYnnX|r�|jd|�=|��|j�s|j � |j�|jdk r�|j�d�|jr�|�d�n|j�r|j�tj�dS)Nr�)r�r�rOr�rKrJrirjrhr�r�r�r�r�r�r��_maybe_resume_protocolr�r�r�r��shutdownrB�SHUT_WR)r&r�rerrrr�s2 z%_SelectorSocketTransport._write_readycCs.|js|jrdSd|_|js*|j�tj�dSr�)r�r�r�r�rrBrr<rrr� write_eof�s z"_SelectorSocketTransport.write_eofcCsdSr�rr<rrr� can_write_eof�sz&_SelectorSocketTransport.can_write_eofcs*t��|�|jdk r&|j�td��dS)NzConnection is closed by peer)rr�r�r��ConnectionErrorr�r'rrr��s �z._SelectorSocketTransport._call_connection_lostcCs6|jdk rtd��|j��|_|js0|j�d�|jS)NzEmpty waiter is already set)r�r8r�rgr�r�r<rrrr��s z+_SelectorSocketTransport._make_empty_waitercCs d|_dSr+)r�r<rrrr��sz,_SelectorSocketTransport._reset_empty_waiter)NNN)r!r�r�Z_start_tls_compatiblerZ _SendfileModeZ TRY_NATIVEZ_sendfile_compatiblerr�r�r�r�r�r�r�r�rrrr r�r�r�r�rrr'rr,�s*�%'r,csFeZdZejZd�fdd� Zdd�Zdd�Zd dd �Z d d�Z �ZS)r5Ncs^t��||||�||_|j�|jj|�|j�|j|j|j �|dk rZ|j�t j|d�dSr+)rr�_addressr�r�r�r�rDr�r�rr�)r&r�rr-r6r.r)r'rrr�s � �z#_SelectorDatagramTransport.__init__cCstdd�|jD��S)Ncss|]\}}t|�VqdSr+)r�)�.0rGrbrrr� <genexpr>�szC_SelectorDatagramTransport.get_write_buffer_size.<locals>.<genexpr>)�sumr�r<rrrr��sz0_SelectorDatagramTransport.get_write_buffer_sizec Cs�|jr dSz|j�|j�\}}Wn�ttfk r8Yn�tk rd}z|j�|�W5d}~XYnTt t fk r|�Yn<tk r�}z|�|d�W5d}~XYnX|j� ||�dS)Nz&Fatal read error on datagram transport)r�r�Zrecvfromr�rKrJrPr��error_receivedrirjrhr�Zdatagram_received�r&rGrdrerrrr��sz&_SelectorDatagramTransport._read_readyc Cs�t|tttf�s$tdt|�j��|s,dS|jrV|d|jfkrPtd|j��|j}|j r�|jr�|j t jkrxt� d�|j d7_ dS|j�slz,|jdr�|j�|�n|j�||�WdSttfk r�|j�|j|j�Yn�tk �r}z|j�|�WY�dSd}~XYnPttfk �r6�Yn6tk �rj}z|�|d�WY�dSd}~XYnX|j� t|�|f�|�!�dS)Nr�z!Invalid address: must be None or r�rrZ�'Fatal write error on datagram transport)"rr�r�r�rr�r!rrnr�rr�rrr�r�r�rO�sendtorKrJr�r�r�� _sendto_readyrPr�rrirjrhr�r�rrrrrr�sH � �z!_SelectorDatagramTransport.sendtoc Cs|jr�|j��\}}z*|jdr.|j�|�n|j�||�Wqttfk rj|j�||f�Yq�Yqt k r�}z|j �|�WY�dSd}~XYqtt fk r��Yqtk r�}z|�|d�WY�dSd}~XYqXq|��|j�s|j�|j�|j�r|�d�dS)NrZr)r��popleftr�r�rOrrKrJ� appendleftrPr�rrirjrhr�rr�r�r�r�r�rrrrr*s2 �z(_SelectorDatagramTransport._sendto_ready)NNN)N)r!r�r��collections�dequer�rr�r�rrr�rrr'rr5�s� +r5)r��__all__rr^r�rrBr�r$r�ImportError�rrrrrr r r�logrrrZ BaseEventLooprZ_FlowControlMixinZ Transportr�r,r5rrrr�<module>sF 1�o

Name	Size	Last Modified	Owner / Group	Permissions
..	--	March 05 2024 23:45:16	root / root	0755

__init__.cpython-38.opt-1.pyc	0.734 KB	October 17 2023 18:13:00	root / root	0644
__init__.cpython-38.opt-2.pyc	0.68 KB	October 17 2023 18:13:05	root / root	0644
__init__.cpython-38.pyc	0.734 KB	October 17 2023 18:13:00	root / root	0644
__main__.cpython-38.opt-1.pyc	3.064 KB	October 17 2023 18:13:00	root / root	0644
__main__.cpython-38.opt-2.pyc	3.064 KB	October 17 2023 18:13:00	root / root	0644
__main__.cpython-38.pyc	3.064 KB	October 17 2023 18:13:00	root / root	0644
base_events.cpython-38.opt-1.pyc	49.605 KB	October 17 2023 18:13:02	root / root	0644
base_events.cpython-38.opt-2.pyc	40.835 KB	October 17 2023 18:13:05	root / root	0644
base_events.cpython-38.pyc	49.826 KB	October 17 2023 18:13:00	root / root	0644
base_futures.cpython-38.opt-1.pyc	1.855 KB	October 17 2023 18:13:00	root / root	0644
base_futures.cpython-38.opt-2.pyc	1.607 KB	October 17 2023 18:13:05	root / root	0644
base_futures.cpython-38.pyc	1.855 KB	October 17 2023 18:13:00	root / root	0644
base_subprocess.cpython-38.opt-1.pyc	9.104 KB	October 17 2023 18:13:02	root / root	0644
base_subprocess.cpython-38.opt-2.pyc	9.006 KB	October 17 2023 18:13:05	root / root	0644
base_subprocess.cpython-38.pyc	9.197 KB	October 17 2023 18:13:00	root / root	0644
base_tasks.cpython-38.opt-1.pyc	1.9 KB	October 17 2023 18:13:00	root / root	0644
base_tasks.cpython-38.opt-2.pyc	1.9 KB	October 17 2023 18:13:00	root / root	0644
base_tasks.cpython-38.pyc	1.9 KB	October 17 2023 18:13:00	root / root	0644
constants.cpython-38.opt-1.pyc	0.569 KB	October 17 2023 18:13:00	root / root	0644
constants.cpython-38.opt-2.pyc	0.569 KB	October 17 2023 18:13:00	root / root	0644
constants.cpython-38.pyc	0.569 KB	October 17 2023 18:13:00	root / root	0644
coroutines.cpython-38.opt-1.pyc	6.417 KB	October 17 2023 18:13:02	root / root	0644
coroutines.cpython-38.opt-2.pyc	6.19 KB	October 17 2023 18:13:05	root / root	0644
coroutines.cpython-38.pyc	6.5 KB	October 17 2023 18:13:00	root / root	0644
events.cpython-38.opt-1.pyc	27.296 KB	October 17 2023 18:13:02	root / root	0644
events.cpython-38.opt-2.pyc	18.456 KB	October 17 2023 18:13:05	root / root	0644
events.cpython-38.pyc	27.401 KB	October 17 2023 18:13:00	root / root	0644
exceptions.cpython-38.opt-1.pyc	2.491 KB	October 17 2023 18:13:00	root / root	0644
exceptions.cpython-38.opt-2.pyc	1.862 KB	October 17 2023 18:13:05	root / root	0644
exceptions.cpython-38.pyc	2.491 KB	October 17 2023 18:13:00	root / root	0644
format_helpers.cpython-38.opt-1.pyc	2.279 KB	October 17 2023 18:13:00	root / root	0644
format_helpers.cpython-38.opt-2.pyc	2.041 KB	October 17 2023 18:13:05	root / root	0644
format_helpers.cpython-38.pyc	2.279 KB	October 17 2023 18:13:00	root / root	0644
futures.cpython-38.opt-1.pyc	10.76 KB	October 17 2023 18:13:02	root / root	0644
futures.cpython-38.opt-2.pyc	7.531 KB	October 17 2023 18:13:05	root / root	0644
futures.cpython-38.pyc	10.933 KB	October 17 2023 18:13:00	root / root	0644
locks.cpython-38.opt-1.pyc	15.986 KB	October 17 2023 18:13:00	root / root	0644
locks.cpython-38.opt-2.pyc	9.539 KB	October 17 2023 18:13:05	root / root	0644
locks.cpython-38.pyc	15.986 KB	October 17 2023 18:13:00	root / root	0644
log.cpython-38.opt-1.pyc	0.223 KB	October 17 2023 18:13:00	root / root	0644
log.cpython-38.opt-2.pyc	0.185 KB	October 17 2023 18:13:05	root / root	0644
log.cpython-38.pyc	0.223 KB	October 17 2023 18:13:00	root / root	0644
proactor_events.cpython-38.opt-1.pyc	23.31 KB	October 17 2023 18:13:02	root / root	0644
proactor_events.cpython-38.opt-2.pyc	22.919 KB	October 17 2023 18:13:05	root / root	0644
proactor_events.cpython-38.pyc	23.581 KB	October 17 2023 18:13:00	root / root	0644
protocols.cpython-38.opt-1.pyc	8.414 KB	October 17 2023 18:13:00	root / root	0644
protocols.cpython-38.opt-2.pyc	3.278 KB	October 17 2023 18:13:05	root / root	0644
protocols.cpython-38.pyc	8.414 KB	October 17 2023 18:13:00	root / root	0644
queues.cpython-38.opt-1.pyc	8.187 KB	October 17 2023 18:13:00	root / root	0644
queues.cpython-38.opt-2.pyc	5.57 KB	October 17 2023 18:13:05	root / root	0644
queues.cpython-38.pyc	8.187 KB	October 17 2023 18:13:00	root / root	0644
runners.cpython-38.opt-1.pyc	1.903 KB	October 17 2023 18:13:00	root / root	0644
runners.cpython-38.opt-2.pyc	1.237 KB	October 17 2023 18:13:05	root / root	0644
runners.cpython-38.pyc	1.903 KB	October 17 2023 18:13:00	root / root	0644
selector_events.cpython-38.opt-1.pyc	28.933 KB	October 17 2023 18:13:02	root / root	0644
selector_events.cpython-38.opt-2.pyc	27.337 KB	October 17 2023 18:13:05	root / root	0644
selector_events.cpython-38.pyc	28.991 KB	October 17 2023 18:13:00	root / root	0644
sslproto.cpython-38.opt-1.pyc	20.918 KB	October 17 2023 18:13:02	root / root	0644
sslproto.cpython-38.opt-2.pyc	14.274 KB	October 17 2023 18:13:05	root / root	0644
sslproto.cpython-38.pyc	21.113 KB	October 17 2023 18:13:00	root / root	0644
staggered.cpython-38.opt-1.pyc	3.854 KB	October 17 2023 18:13:02	root / root	0644
staggered.cpython-38.opt-2.pyc	1.771 KB	October 17 2023 18:13:05	root / root	0644
staggered.cpython-38.pyc	4.023 KB	October 17 2023 18:13:00	root / root	0644
streams.cpython-38.opt-1.pyc	19.89 KB	October 17 2023 18:13:02	root / root	0644
streams.cpython-38.opt-2.pyc	14.134 KB	October 17 2023 18:13:05	root / root	0644
streams.cpython-38.pyc	20.158 KB	October 17 2023 18:13:00	root / root	0644
subprocess.cpython-38.opt-1.pyc	7.158 KB	October 17 2023 18:13:02	root / root	0644
subprocess.cpython-38.opt-2.pyc	7.033 KB	October 17 2023 18:13:05	root / root	0644
subprocess.cpython-38.pyc	7.188 KB	October 17 2023 18:13:00	root / root	0644
tasks.cpython-38.opt-1.pyc	23.659 KB	October 17 2023 18:13:02	root / root	0644
tasks.cpython-38.opt-2.pyc	16.251 KB	October 17 2023 18:13:05	root / root	0644
tasks.cpython-38.pyc	23.714 KB	October 17 2023 18:13:00	root / root	0644
transports.cpython-38.opt-1.pyc	11.947 KB	October 17 2023 18:13:02	root / root	0644
transports.cpython-38.opt-2.pyc	6.673 KB	October 17 2023 18:13:05	root / root	0644
transports.cpython-38.pyc	11.977 KB	October 17 2023 18:13:00	root / root	0644
trsock.cpython-38.opt-1.pyc	8.286 KB	October 17 2023 18:13:00	root / root	0644
trsock.cpython-38.opt-2.pyc	8.036 KB	October 17 2023 18:13:05	root / root	0644
trsock.cpython-38.pyc	8.286 KB	October 17 2023 18:13:00	root / root	0644
unix_events.cpython-38.opt-1.pyc	38.044 KB	October 17 2023 18:13:03	root / root	0644
unix_events.cpython-38.opt-2.pyc	33.512 KB	October 17 2023 18:13:05	root / root	0644
unix_events.cpython-38.pyc	38.416 KB	October 17 2023 18:13:00	root / root	0644
windows_events.cpython-38.opt-1.pyc	23.978 KB	October 17 2023 18:13:03	root / root	0644
windows_events.cpython-38.opt-2.pyc	22.896 KB	October 17 2023 18:13:05	root / root	0644
windows_events.cpython-38.pyc	24.009 KB	October 17 2023 18:13:00	root / root	0644
windows_utils.cpython-38.opt-1.pyc	4.286 KB	October 17 2023 18:13:03	root / root	0644
windows_utils.cpython-38.opt-2.pyc	3.862 KB	October 17 2023 18:13:05	root / root	0644
windows_utils.cpython-38.pyc	4.368 KB	October 17 2023 18:13:00	root / root	0644

GRAYBYTE WORDPRESS FILE MANAGER2581