|
Server : Apache System : Linux cvar2.toservers.com 3.10.0-962.3.2.lve1.5.73.el7.x86_64 #1 SMP Wed Aug 24 21:31:23 UTC 2022 x86_64 User : njnconst ( 1116) PHP Version : 8.4.18 Disable Function : NONE Directory : /opt/alt/python310/lib64/python3.10/asyncio/__pycache__/ |
Upload File : |
o
;b�d � @ s d Z ddlZddlZddlZddlZeed�re d7 Z ddlmZ ddlmZ ddlm Z dd lm
Z
dd
lm Z dd l m
Z
dd lmZ d
Zd ed�dd�Zd ed�dd�Zeed�rld ed�dd�Zd ed�dd�ZG dd� de j�ZG dd� dee j�ZG dd � d �ZG d 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 )�limitc � sb � t �� }t||d�}t||d�� |j� fdd�| |fi |��I d H \}}t|� ||�}||fS )N�r �loop�r c � � S �N� r ��protocolr �6/opt/alt/python310/lib64/python3.10/asyncio/streams.py�<lambda>0 � z!open_connection.<locals>.<lambda>)r �get_running_loopr r Zcreate_connectionr ) �host�portr �kwdsr �reader� transport�_�writerr r r r s � ��r c � s8 � t �� �� ��fdd�}�j|||fi |��I d H S )Nc � t ��d�} t| � �d�}|S �Nr r �r r �r! r ��client_connected_cbr r r r �factoryN �
�z start_server.<locals>.factory)r r Z
create_server)r* r r r r r+ r r) r r 5 s
� r c � s` � t �� }t||d�}t||d�� |j� fdd�| fi |��I d H \}}t|� ||�}||fS )Nr r c r r r r r r r r b r z&open_unix_connection.<locals>.<lambda>)r r r r Zcreate_unix_connectionr )�pathr r r r! r" r# r$ r r r r Z s � ��r c � s6 � t �� �� ��fdd�}�j||fi |��I d H S )Nc r% r& r' r( r) r r r+ k r, z"start_unix_server.<locals>.factory)r r Zcreate_unix_server)r* r- r r r+ r r) r r f s
�r c @ s@ e Zd Z ddd�Zdd� Zdd� Zdd � Zd
d � Zd d
� ZdS )�FlowControlMixinNc C s4 |d u r t jdd�| _n|| _d| _d | _d| _d S )N� )�
stacklevelF)r �_get_event_loop�_loop�_paused�
_drain_waiter�_connection_lost)�selfr r r r �__init__~ s
zFlowControlMixin.__init__c C s$ d| _ | j�� rt�d| � d S d S )NTz%r pauses writing)r3 r2 � get_debugr �debug�r6 r r r �
pause_writing� s
�z FlowControlMixin.pause_writingc C sN d| _ | j�� rt�d| � | j}|d ur#d | _|�� s%|�d � d S d S d S )NFz%r resumes writing)r3 r2 r8 r r9 r4 �done�
set_result�r6 �waiterr r r �resume_writing� s
�z FlowControlMixin.resume_writingc C sX d| _ | jsd S | j}|d u rd S d | _|�� rd S |d u r%|�d � d S |�|� d S �NT)r5 r3 r4 r< r= �
set_exception�r6 �excr? r r r �connection_lost� s z FlowControlMixin.connection_lostc � s> �| j rtd��| js
d S | j}| j�� }|| _|I d H d S )NzConnection lost)r5 �ConnectionResetErrorr3 r4 r2 �
create_futurer> r r r �
_drain_helper� s �
z FlowControlMixin._drain_helperc C s t �r )�NotImplementedError�r6 �streamr r r �_get_close_waiter� � z"FlowControlMixin._get_close_waiterr ) �__name__�
__module__� __qualname__r7 r; r@ rE rH rL r r r r r. t s
r. c sd e Zd Z dZd� fdd� Zedd� �Zdd� Z� fdd �Zd
d � Z d d
� Z
dd� Z dd� Z � Z
S )r Nc sn t � j|d� |d urt�|�| _|j| _nd | _|d ur || _d| _d | _d | _ || _
d| _ | j �
� | _d S )Nr F)�superr7 �weakref�ref�_stream_reader_wr�_source_traceback�_strong_reader�_reject_connection�_stream_writer�
_transport�_client_connected_cb� _over_sslr2 rG �_closed)r6 Z
stream_readerr* r �� __class__r r r7 � s
z StreamReaderProtocol.__init__c C s | j d u rd S | � � S r )rT r: r r r �_stream_reader� s
z#StreamReaderProtocol._stream_readerc C s� | j rddi}| jr| j|d< | j�|� |�� d S || _| j}|d ur*|�|� |�d�d u| _ | j
d urWt || || j�| _ | �
|| j �}t
�|�rR| j�|� d | _d S d S )N�messagezpAn open stream was garbage collected prior to establishing network connection; call "stream.close()" explicitly.Zsource_tracebackZ
sslcontext)rW rU r2 Zcall_exception_handler�abortrY r_ �
set_transport�get_extra_infor[ rZ r rX r
Z iscoroutineZ create_taskrV )r6 r" �contextr! �resr r r �connection_made� s2 �
��
�z$StreamReaderProtocol.connection_madec sx | j }|d ur|d u r|�� n|�|� | j�� s+|d u r%| j�d � n| j�|� t� �|� d | _d | _ d | _
d S r ) r_ �feed_eofrB r\ r< r= rQ rE rT rX rY )r6 rD r! r] r r rE � s
z$StreamReaderProtocol.connection_lostc C s | j }|d ur|�|� d S d S r )r_ � feed_data)r6 �datar! r r r �
data_received s �z"StreamReaderProtocol.data_receivedc C s$ | j }|d ur |�� | jrdS dS )NFT)r_ rg r[ )r6 r! r r r � eof_received
s z!StreamReaderProtocol.eof_receivedc C � | j S r )r\ rJ r r r rL � z&StreamReaderProtocol._get_close_waiterc C sD z| j }W n
ty Y d S w |�� r |�� s |�� d S d S d S r )r\ �AttributeErrorr< � cancelled� exception)r6 �closedr r r �__del__ s
� �z StreamReaderProtocol.__del__�NN)rN rO rP rU r7 �propertyr_ rf rE rj rk rL rr �
__classcell__r r r] r r � s
r c @ st e Zd Z dd� Zdd� Zedd� �Zdd� Zd d
� Zd d � Z d
d� Z
dd� Z dd� Z dd� Z
ddd�Zdd� ZdS )r c C s4 || _ || _|| _|| _| j�� | _| j�d � d S r )rY � _protocol�_readerr2 rG Z
_complete_futr= )r6 r" r r! r r r r r7 1 s zStreamWriter.__init__c C s@ | j jd| j��g}| jd ur|�d| j��� d�d�|��S )N�
transport=zreader=�<{}>� )r^ rN rY rw �append�format�join�r6 �infor r r �__repr__; s
zStreamWriter.__repr__c C rl r �rY r: r r r r" A s zStreamWriter.transportc C � | j �|� d S r )rY �write�r6 ri r r r r� E � zStreamWriter.writec C r� r )rY �
writelinesr� r r r r� H r� zStreamWriter.writelinesc C �
| j �� S r )rY � write_eofr: r r r r� K �
zStreamWriter.write_eofc C r� r )rY �
can_write_eofr: r r r r� N r� zStreamWriter.can_write_eofc C r� r )rY �closer: r r r r� Q r� zStreamWriter.closec C r� r )rY �
is_closingr: r r r r� T r� zStreamWriter.is_closingc � s �| j �| �I d H d S r )rv rL r: r r r � wait_closedW s �zStreamWriter.wait_closedNc C s | j �||�S r )rY rc )r6 �name�defaultr r r rc Z s zStreamWriter.get_extra_infoc � sP � | j d ur| j �� }|d ur|�| j�� r td�I d H | j�� I d H d S )Nr )rw rp rY r� r rv rH )r6 rD r r r �drain] s �
zStreamWriter.drainr )rN rO rP r7 r� rt r" r� r� r� r� r� r� r� rc r� r r r r r ' s
r c @ s� e Zd ZdZedfdd�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 )(r Nc C sz |dkrt d��|| _|d u rt�� | _n|| _t� | _d| _d | _d | _ d | _
d| _ | j� � r;t
�t�d��| _d S d S )Nr zLimit cannot be <= 0Fr )�
ValueError�_limitr r1 r2 � bytearray�_buffer�_eof�_waiter�
_exceptionrY r3 r8 r
�
extract_stack�sys� _getframerU )r6 r r r r r r7 { s"
��zStreamReader.__init__c C s� dg}| j r|�t| j �� d�� | jr|�d� | jtkr'|�d| j� �� | jr3|�d| j��� | jr?|�d| j��� | jrK|�d| j��� | j rS|�d� d �
d
� |��S ) Nr z bytes�eofzlimit=zwaiter=z
exception=rx Zpausedry rz ) r� r{ �lenr� r� �_DEFAULT_LIMITr� r� rY r3 r| r} r~ r r r r� � s
zStreamReader.__repr__c C rl r )r� r: r r r rp � rm zStreamReader.exceptionc C s8 || _ | j}|d urd | _|�� s|�|� d S d S d S r )r� r� ro rB rC r r r rB � s �zStreamReader.set_exceptionc C s4 | j }|d urd | _ |�� s|�d � d S d S d S r )r� ro r= r> r r r �_wakeup_waiter� s �zStreamReader._wakeup_waiterc C s
|| _ d S r r� )r6 r" r r r rb � s
zStreamReader.set_transportc C s2 | j rt| j�| jkrd| _ | j�� d S d S d S )NF)r3 r� r� r� rY �resume_readingr: r r r �_maybe_resume_transport� s �z$StreamReader._maybe_resume_transportc C s d| _ | �� d S rA )r� r� r: r r r rg � s zStreamReader.feed_eofc C s | j o| j S r )r� r� r: r r r �at_eof� s zStreamReader.at_eofc C s� |sd S | j �|� | �� | jd ur:| js<t| j �d| j kr>z| j�� W n
ty4 d | _Y d S w d| _d S d S d S d S )N� T) r� �extendr� rY r3 r� r� Z
pause_readingrI r� r r r rh � s
�� �
�zStreamReader.feed_datac � s` � | j d urt|� d���| jrd| _| j�� | j�� | _ z | j I d H W d | _ d S d | _ w )NzF() called while another coroutine is already waiting for incoming dataF)r� � RuntimeErrorr3 rY r� r2 rG )r6 Z func_namer r r �_wait_for_data� s �
�
zStreamReader._wait_for_datac
� s� � d}t |�}z | �|�I d H }W |S tjy) } z |jW Y d }~S d }~w tjyW } z"| j�||j�rC| jd |j| �= n| j� � | �
� t |j d ��d }~ww )N�
r )
r� � readuntilr �IncompleteReadError�partial�LimitOverrunErrorr� �
startswith�consumed�clearr� r� �args)r6 �sep�seplen�line�er r r �readline� s$ �
��
��zStreamReader.readliner� c � s � t |�}|dkrtd��| jd ur| j�d} t | j�}|| |krA| j�||�}|dkr0n-|d | }|| jkrAt�d|��| jrTt | j�}| j�
� t� |d ��| � d�I d H q|| jkrht�d|��| jd || � }| jd || �= | �
� t |�S ) Nr z,Separator should be at least one-byte stringT���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� )r6 Z separatorr� �offsetZbuflenZisep�chunkr r r r� sD �
�
�
�zStreamReader.readuntilr� c � s� � | j d ur
| j �|dkrdS |dk r.g } | �| j�I d H }|s#n|�|� qd�|�S | js<| js<| �d�I d H t| jd |� �}| jd |�= | � � |S )Nr � T�read)
r� r� r� r{ r} r� r� r� r� r� )r6 �nZblocks�blockri r r r r� t s* �
�
zStreamReader.readc � s� � |dk r
t d��| jd ur| j�|dkrdS t| j�|k rA| jr2t| j�}| j�� t�||��| � d�I d H t| j�|k s t| j�|krSt| j�}| j�� nt| jd |� �}| jd |�= | �
� |S )Nr z*readexactly size can not be less than zeror� � readexactly) r� r� r� r� r� r� r� r r� r� r� )r6 r� Z
incompleteri r r r r� � s, �
�
zStreamReader.readexactlyc C s | S r r r: r r r � __aiter__� rM zStreamReader.__aiter__c � s �| � � I d H }|dkrt�|S )Nr� )r� �StopAsyncIteration)r6 �valr r r � __anext__� s
�zStreamReader.__anext__)r� )r� )rN rO rP rU r� r7 r� rp rB r� rb r� rg r� rh r� r� r� r� r� r� r� r r r r r w s&
[2) r rs r )�__all__Zsocketr� �warningsrR �hasattr� r
r r r
r �logr Ztasksr r� r r r r ZProtocolr. r r r r r r r �<module> s@
� �
" � �DoP