Operation   : Linux premium131.web-hosting.com 4.18.0-553.44.1.lve.el8.x86_64 #1 SMP Thu Mar 13 14:29:12 UTC 2025 x86_64
Software     : Apache
Server IP    : 162.0.232.56 | Your IP: 216.73.216.111
Domains      : 1034 Domain(s)
Permission   : [ 0755 ]

o

�=?h�)�@sz	dZGd
d�d�Z
Gdd�de
�ZGdd�de
�ZGdd�dee�ZGd	d
�d
e
�ZGdd�de
�ZGd
d�de�ZdS))�
BaseTransport�
ReadTransport�WriteTransport�	Transport�DatagramTransport�SubprocessTransportc@sFeZ
dZ	d
Zddd�
Zddd�
Zdd�Zd	d
�Zdd�Zd
d�Z	dS)r
�
�_extraNcCs|
duri}
|
|_dS�
Nr)�self�extra�r�9/opt/alt/python310/lib64/python3.10/asyncio/transports.py�__init__s



zBaseTransport.__init__cCs	|j�
|
|�Sr	)r�get)r
�name�defaultrrr
�get_extra_infos

zBaseTransport.get_extra_infoc


C�	t�
r	�
�NotImplementedError�
r
rrr
�
is_closing�

zBaseTransport.is_closingc


Crr	rrrrr
�close�
zBaseTransport.closec
Crr	r)r
�protocolrrr
�set_protocol%rzBaseTransport.set_protocolc


Crr	rrrrr
�get_protocol)rzBaseTransport.get_protocolr	)
�__name__�
__module__�__qualname__�	__slots__rrrrrrrrrr
r
	s



r
c@s*eZ
dZ	d
Zdd�Zdd�Zdd�ZdS)	rrc


Crr	rrrrr
�
is_reading3rzReadTransport.is_readingc


Crr	rrrrr
�
pause_reading7�
zReadTransport.pause_readingc


Crr	rrrrr
�resume_reading?r$zReadTransport.resume_readingN)rrr r!r"r#r%rrrr
r.s
rc@sTeZ
dZ	d
Zddd�
Zdd�Zdd�Zd	d
�Zdd�Zd
d�Z	dd�Z
dd�ZdS)rrNc
Crr	r�r
�high�lowrrr
�set_write_buffer_limitsMs
z&WriteTransport.set_write_buffer_limitsc


Crr	rrrrr
�get_write_buffer_sizebrz$WriteTransport.get_write_buffer_sizec


Crr	rrrrr
�get_write_buffer_limitsfs
z&WriteTransport.get_write_buffer_limitsc
Crr	r)r
�datarrr
�writelr$zWriteTransport.writecCs	d
�|
�
}|�
|�

dS)N�)�joinr-)r
Zlist_of_datar,rrr
�
writelinests


zWriteTransport.writelinesc


Crr	rrrrr
�	write_eof}�
zWriteTransport.write_eofc


Crr	rrrrr
�
can_write_eof�rzWriteTransport.can_write_eofc


Crr	rrrrr
�abort�r2zWriteTransport.abort�NN)rrr r!r)r*r+r-r0r1r3r4rrrr
rHs

		rc
@seZ
dZ	d
ZdS)rrN)rrr r!rrrr
r�s
rc@s$eZ
dZ	d
Zddd�
Zdd�ZdS)rrNc
Crr	r)r
r,Zaddrrrr
�sendto�rzDatagramTransport.sendtoc


Crr	rrrrr
r4�r2zDatagramTransport.abortr	)rrr r!r6r4rrrr
r�s



rc@s@eZ
dZd
Zdd�Zdd�Zdd�Zdd	�Zd
d�Zdd
�Z	dS)rrc


Crr	rrrrr
�get_pid�rzSubprocessTransport.get_pidc


Crr	rrrrr
�get_returncode�r$z"SubprocessTransport.get_returncodec
Crr	r)r
�fdrrr
�get_pipe_transport�rz&SubprocessTransport.get_pipe_transportc
Crr	r)r
�signalrrr
�send_signal�r$zSubprocessTransport.send_signalc


Crr	rrrrr
�	terminate�s
zSubprocessTransport.terminatec


Crr	rrrrr
�kill�s
zSubprocessTransport.killN)
rrr r!r7r8r:r<r=r>rrrr
r�srcsXeZ
dZ	d
Zd�f
dd�	Zdd�Zdd�Zd	d
�Zddd�
Zdd
d�
Z	dd�Z
�ZS)�_FlowControlMixin)�_loop�_protocol_paused�_high_water�
_low_waterNcs$t��
|
�

||_d
|_|��
dS)NF)�superrr@rA�_set_write_buffer_limits)r
rZloop�
�	__class__rr
r
s


z_FlowControlMixin.__init__c

Cs�|��}
|
|j
k
rdS|jsBd
|_z|j��
WdSttfy#


�tyA
}
z|j�	d|||jd��

WYd}~dSd}~w
wdS)NTzprotocol.pause_writing() failed��messageZ	exceptionZ	transportr)
r*rBrA�	_protocolZ
pause_writing�
SystemExit�KeyboardInterrupt�
BaseExceptionr@�call_exception_handler)r
�size�excrrr
�_maybe_pause_protocol
s&















����z'_FlowControlMixin._maybe_pause_protocolc

Cs�|jr>|�
�|jk
r@d
|_z|j��
WdSttfy


�ty=
}

z|j�	d|
||jd��

WYd}
~
dSd}
~
w
wdSdS)NFz protocol.resume_writing() failedrH)
rAr*rCrJZresume_writingrKrLrMr@rN)r
rPrrr
�_maybe_resume_protocol'
s$












����
z(_FlowControlMixin._maybe_resume_protocolc

Cs|j|j
fSr	)rCrBrrrr
r+7
s
z)_FlowControlMixin.get_write_buffer_limitscCsj|
dur|durd
}
nd|}
|dur|
d}|
|kr!dks-n

td|
�d|�d��
�
|
|_
||_dS)Ni
��zhigh (z) must be >= low (z) must be >= 0)�
ValueErrorrBrCr&rrr
rE:
s






�

z*_FlowControlMixin._set_write_buffer_limitscCs|j|
|d
�
|�
�
dS)N)r'r()rErQr&rrr
r)J
s

z)_FlowControlMixin.set_write_buffer_limitsc


Cst�
r	rrrrr
r*N
s
z'_FlowControlMixin.get_write_buffer_sizer5)rrr r!rrQrRr+rEr)r*�
__classcell__rrrFr
r?�s


r?N)�__all__r
rrrrrr?rrrr
�<module>
s%L6