uawdijnntqw1x1x1
IP : 52.15.233.83
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
/
.
/
..
/
lib64
/
sa
/
..
/
krb5
/
.
/
..
/
python3.8
/
asyncio
/
__pycache__
/
streams.cpython-38.opt-2.pyc
/
/
U e5d h�@s&dZddlZddlZddlZddlZeed�r6ed7ZddlmZddlmZddlm Z dd lm Z dd lm Z dd l m Z dd lmZd Zd ded�dd�Zd ded�dd�Zeed�r�d!ded�dd�Zd"ded�dd�ZGdd�de j�ZGdd�dee j�ZGdd �d �ZGd d �d �ZdS)#)� StreamReader� StreamWriter�StreamReaderProtocol�open_connection� start_server�NZAF_UNIX)�open_unix_connection�start_unix_server�)� coroutines)�events)� exceptions)�format_helpers)� protocols)�logger)�sleepi)�loop�limitc �st|dkrt��}ntjdtdd�t||d�}t||d��|j�fdd�||f|�IdH\}}t|�||�}||fS)N�[The loop argument is deprecated since Python 3.8, and scheduled for removal in Python 3.10.��� stacklevel�rr�rcs�S�N�r��protocolr�'/usr/lib64/python3.8/asyncio/streams.py�<lambda>5�z!open_connection.<locals>.<lambda>) r �get_event_loop�warnings�warn�DeprecationWarningrrZcreate_connectionr) �host�portrr�kwds�reader� transport�_�writerrrr rs" � ��rc�sJ�dkrt���ntjdtdd����fdd�}�j|||f|�IdHS)Nrrrcs t��d�}t|��d�}|S�Nrr�rr�r'r ��client_connected_cbrrrr �factoryXs �z start_server.<locals>.factory)r r r!r"r#Z create_server)r/r$r%rrr&r0rr.r r:s �rc�sr|dkrt��}ntjdtdd�t||d�}t||d��|j�fdd�|f|�IdH\}}t|�||�}||fS)Nrrrrrcs�Srrrrrr r pr z&open_unix_connection.<locals>.<lambda>) r r r!r"r#rrZcreate_unix_connectionr)�pathrrr&r'r(r)r*rrr rds � ��rc�sH�dkrt���ntjdtdd����fdd�}�j||f|�IdHS)Nrrrcs t��d�}t|��d�}|Sr+r,r-r.rr r0~s �z"start_unix_server.<locals>.factory)r r r!r"r#Zcreate_unix_server)r/r1rrr&r0rr.r rts �rc@s>eZdZddd�Zdd�Zdd�Zdd �Zd d �Zd d �ZdS)�FlowControlMixinNcCs0|dkrt��|_n||_d|_d|_d|_dS�NF)r r �_loop�_paused� _drain_waiter�_connection_lost)�selfrrrr �__init__�s zFlowControlMixin.__init__cCs d|_|j��r t�d|�dS)NTz%r pauses writing)r5r4� get_debugr�debug�r8rrr � pause_writing�s z FlowControlMixin.pause_writingcCsFd|_|j��r t�d|�|j}|dk rBd|_|��sB|�d�dS)NFz%r resumes writing)r5r4r:rr;r6�done� set_result�r8�waiterrrr �resume_writing�s z FlowControlMixin.resume_writingcCsVd|_|jsdS|j}|dkr"dSd|_|��r4dS|dkrH|�d�n |�|�dS�NT)r7r5r6r>r?� set_exception�r8�excrArrr �connection_lost�s z FlowControlMixin.connection_lostc�s<|jrtd��|jsdS|j}|j��}||_|IdHdS)NzConnection lost)r7�ConnectionResetErrorr5r6r4� create_futurer@rrr � _drain_helper�s z FlowControlMixin._drain_helpercCst�dSr)�NotImplementedError�r8�streamrrr �_get_close_waiter�sz"FlowControlMixin._get_close_waiter)N) �__name__� __module__� __qualname__r9r=rBrGrJrNrrrr r2�s r2csbeZdZdZd�fdd� Zedd��Zdd�Z�fdd �Zd d �Z d d �Z dd�Z dd�Z �Z S)rNcsnt�j|d�|dk r,t�|�|_|j|_nd|_|dk r@||_d|_d|_d|_ ||_ d|_ |j � �|_dS)NrF)�superr9�weakref�ref�_stream_reader_wr�_source_traceback�_strong_reader�_reject_connection�_stream_writer� _transport�_client_connected_cb� _over_sslr4rI�_closed)r8Z stream_readerr/r�� __class__rr r9�s z StreamReaderProtocol.__init__cCs|jdkrdS|��Sr)rUr<rrr �_stream_reader�s z#StreamReaderProtocol._stream_readercCs�|jr6ddi}|jr |j|d<|j�|�|��dS||_|j}|dk rT|�|�|�d�dk |_ |j dk r�t ||||j�|_ |� ||j �}t �|�r�|j�|�d|_dS)N�messagezpAn open stream was garbage collected prior to establishing network connection; call "stream.close()" explicitly.Zsource_tracebackZ sslcontext)rXrVr4Zcall_exception_handler�abortrZr`� set_transport�get_extra_infor\r[rrYr Z iscoroutineZ create_taskrW)r8r(�contextr'�resrrr �connection_made�s2� �� z$StreamReaderProtocol.connection_madecsx|j}|dk r*|dkr |��n |�|�|j��sV|dkrJ|j�d�n |j�|�t��|�d|_d|_ d|_ dSr) r`�feed_eofrDr]r>r?rRrGrUrYrZ)r8rFr'r^rr rG s z$StreamReaderProtocol.connection_lostcCs |j}|dk r|�|�dSr)r`� feed_data)r8�datar'rrr � data_receivedsz"StreamReaderProtocol.data_receivedcCs$|j}|dk r|��|jr dSdS)NFT)r`rhr\)r8r'rrr � eof_received s z!StreamReaderProtocol.eof_receivedcCs|jSr)r]rLrrr rN+sz&StreamReaderProtocol._get_close_waitercCs"|j}|��r |��s |��dSr)r]r>� cancelled� exception)r8�closedrrr �__del__.sz StreamReaderProtocol.__del__)NN)rOrPrQrVr9�propertyr`rgrGrkrlrNrp� __classcell__rrr^r r�s rc@sreZdZdd�Zdd�Zedd��Zdd�Zd d �Zd d �Z d d�Z dd�Z dd�Z dd�Z ddd�Zdd�ZdS)rcCs4||_||_||_||_|j��|_|j�d�dSr)rZ� _protocol�_readerr4rIZ _complete_futr?)r8r(r r'rrrr r9@s zStreamWriter.__init__cCs@|jjd|j��g}|jdk r0|�d|j���d�d�|��S)N� transport=zreader=�<{}>� )r_rOrZrt�append�format�join�r8�inforrr �__repr__Js zStreamWriter.__repr__cCs|jSr�rZr<rrr r(PszStreamWriter.transportcCs|j�|�dSr)rZ�write�r8rjrrr rTszStreamWriter.writecCs|j�|�dSr)rZ� writelinesr�rrr r�WszStreamWriter.writelinescCs |j��Sr)rZ� write_eofr<rrr r�ZszStreamWriter.write_eofcCs |j��Sr)rZ� can_write_eofr<rrr r�]szStreamWriter.can_write_eofcCs |j��Sr)rZ�closer<rrr r�`szStreamWriter.closecCs |j��Sr)rZ� is_closingr<rrr r�cszStreamWriter.is_closingc�s|j�|�IdHdSr)rsrNr<rrr � wait_closedfszStreamWriter.wait_closedNcCs|j�||�Sr)rZrd)r8�name�defaultrrr rdiszStreamWriter.get_extra_infoc�sL|jdk r |j��}|dk r |�|j��r8td�IdH|j��IdHdS)Nr)rtrnrZr�rrsrJ)r8rFrrr �drainls zStreamWriter.drain)N)rOrPrQr9r}rqr(rr�r�r�r�r�r�rdr�rrrr r6s rc@s�eZdZdZedfdd�Zdd�Zdd�Zdd �Zd d �Z d d �Z dd�Z dd�Z dd�Z dd�Zdd�Zdd�Zd&dd �Zd'd d �Zd d!�Zd"d#�Zd$d%�ZdS)(rNcCsv|dkrtd��||_|dkr*t��|_n||_t�|_d|_d|_d|_ d|_ d|_ |j� �rrt �t�d��|_dS)NrzLimit cannot be <= 0Fr )� ValueError�_limitr r r4� bytearray�_buffer�_eof�_waiter� _exceptionrZr5r:r � extract_stack�sys� _getframerV)r8rrrrr r9�s �zStreamReader.__init__cCs�dg}|jr"|�t|j��d��|jr2|�d�|jtkrN|�d|j���|jrf|�d|j���|jr~|�d|j���|jr�|�d|j���|j r�|�d�d � d � |��S) Nrz bytes�eofzlimit=zwaiter=z exception=ruZpausedrvrw) r�rx�lenr�r��_DEFAULT_LIMITr�r�rZr5ryrzr{rrr r}�s zStreamReader.__repr__cCs|jSr)r�r<rrr rn�szStreamReader.exceptioncCs0||_|j}|dk r,d|_|��s,|�|�dSr)r�r�rmrDrErrr rD�s zStreamReader.set_exceptioncCs*|j}|dk r&d|_|��s&|�d�dSr)r�rmr?r@rrr �_wakeup_waiter�s zStreamReader._wakeup_waitercCs ||_dSrr~)r8r(rrr rc�szStreamReader.set_transportcCs*|jr&t|j�|jkr&d|_|j��dSr3)r5r�r�r�rZ�resume_readingr<rrr �_maybe_resume_transport�sz$StreamReader._maybe_resume_transportcCsd|_|��dSrC)r�r�r<rrr rh�szStreamReader.feed_eofcCs|jo |j Sr)r�r�r<rrr �at_eof�szStreamReader.at_eofcCst|sdS|j�|�|��|jdk rp|jspt|j�d|jkrpz|j��Wntk rhd|_YnXd|_dS)NrT) r��extendr�rZr5r�r�Z pause_readingrKr�rrr ri�s �� zStreamReader.feed_datac�sX|jdk rt|�d���|jr.d|_|j��|j��|_z|jIdHW5d|_XdS)NzF() called while another coroutine is already waiting for incoming dataF)r�� RuntimeErrorr5rZr�r4rI)r8Z func_namerrr �_wait_for_data�s � zStreamReader._wait_for_datac �s�d}t|�}z|�|�IdH}Wn�tjk rN}z|jWY�Sd}~XYnhtjk r�}zH|j�||j�r�|jd|j|�=n |j� �|� �t |j d��W5d}~XYnX|S)N� r) r�� readuntilr �IncompleteReadError�partial�LimitOverrunErrorr�� startswith�consumed�clearr�r��args)r8�sep�seplen�line�errr �readline s zStreamReader.readliner�c�s�t|�}|dkrtd��|jdk r(|j�d}t|j�}|||kr||j�||�}|dkrZq�|d|}||jkr|t�d|��|jr�t |j�}|j� �t� |d��|� d�IdHq,||jkr�t�d|��|jd||�}|jd||�=|� �t |�S)Nrz,Separator should be at least one-byte string���r z2Separator is not found, and chunk exceed the limitr�z2Separator is found, but chunk is longer than limit)r�r�r�r��findr�r r�r��bytesr�r�r�r�)r8Z separatorr��offsetZbuflenZisep�chunkrrr r�(s> � �zStreamReader.readuntilr�c�s�|jdk r|j�|dkr dS|dkrVg}|�|j�IdH}|s@qL|�|�q(d�|�S|jsr|jsr|�d�IdHt|jd|��}|jd|�=|� �|S)Nrr �read) r�r�r�rxrzr�r�r�r�r�)r8�nZblocks�blockrjrrr r��s" zStreamReader.readc�s�|dkrtd��|jdk r |j�|dkr,dSt|j�|krr|jr`t|j�}|j��t�||��|� d�IdHq,t|j�|kr�t|j�}|j��n t|jd|��}|jd|�=|� �|S)Nrz*readexactly size can not be less than zeror � readexactly) r�r�r�r�r�r�r�r r�r�r�)r8r�Z incompleterjrrr r��s& zStreamReader.readexactlycCs|Srrr<rrr � __aiter__�szStreamReader.__aiter__c�s |��IdH}|dkrt�|S)Nr )r��StopAsyncIteration)r8�valrrr � __anext__�szStreamReader.__anext__)r�)r�)rOrPrQrVr�r9r}rnrDr�rcr�rhr�rir�r�r�r�r�r�r�rrrr r�s$ [ 2)r)NN)NN)N)N)�__all__Zsocketr�r!rS�hasattr�r r r r r�logrZtasksrr�rrrrZProtocolr2rrrrrrr �<module>sF � !� ' � � DkP
/home/./../lib64/sa/../krb5/./../python3.8/asyncio/__pycache__/streams.cpython-38.opt-2.pyc