!A?h{ P d dl Z d dlZd dlZ d dlZn
# e$ r dZY nw xY wddlmZ ddlmZ ddlmZ ddlm Z ddl
m Z eej ej
fZ G d d ej Z G d
d ej Zd Zd
Z G d de j e j Z G d dej ZdS ) N ) constants)
exceptions) protocols)
transports)loggerc " e Zd ZdZdZdZdZdZdS )SSLProtocolState UNWRAPPED DO_HANDSHAKEWRAPPEDFLUSHINGSHUTDOWNN)__name__
__module__ __qualname__r r r
r r =/opt/alt/python-internal/lib64/python3.11/asyncio/sslproto.pyr
r
s' I!LGHHHHr r
c e Zd ZdZdZdZdZdS )AppProtocolState
STATE_INITSTATE_CON_MADE STATE_EOFSTATE_CON_LOSTN)r r r r r r r r r r r r s$ J%NI%NNNr r c ` | rt d t j }|sd|_ |S )Nz(Server side SSL needs a valid SSLContextF)
ValueErrorsslcreate_default_contextcheck_hostname) server_sideserver_hostname
sslcontexts r _create_transport_contextr$ / s@ ECDDD +--J *$)
! r c | ||dz }n
|}d|z }n| }||dz }n|}||cxk rdk sn t d|d|d ||fS )Ni r zhigh (z) must be >= low (z) must be >= 0)r )highlowkbhilos r add_flowcontrol_defaultsr, = s | ;dBBBRBB
{
1W
====q====j ""bbb" # # # r6Mr c e Zd ZdZej j Zd ZddZ d Z
d Z d Z d Z
efd Zd
Zd Zd Zd d
Zd Zd Zd dZd Zd Zed Zd Zd Z d Z d Z d Z d Z d Z!dS ) _SSLProtocolTransportTc 0 || _ || _ d| _ d S )NF)_loop
_ssl_protocol_closed)selfloop ssl_protocols r __init__z _SSLProtocolTransport.__init__X s
) r Nc 8 | j || S )z#Get optional transport information.)r1 _get_extra_infor3 namedefaults r get_extra_infoz$_SSLProtocolTransport.get_extra_info] s !11$@@@r c : | j | d S N)r1 _set_app_protocol)r3 protocols r set_protocolz"_SSLProtocolTransport.set_protocola s ,,X66666r c | j j S r> )r1
_app_protocolr3 s r get_protocolz"_SSLProtocolTransport.get_protocold s !//r c | j S r> )r2 rD s r
is_closingz _SSLProtocolTransport.is_closingg s
|r c f | j s"d| _ | j dS d| _ dS )a
Close the transport.
Buffered data will be flushed asynchronously. No more data
will be received. After all buffered data is flushed, the
protocol's connection_lost() method will (eventually) called
with None as its argument.
TN)r2 r1 _start_shutdownrD s r closez_SSLProtocolTransport.closej s> | & DL . . 0 0 0 0 0!%D r c \ | j s$d| _ | dt d S d S )NTz9unclosed transport <asyncio._SSLProtocolTransport object>)r2 warnResourceWarning)r3 _warningss r __del__z _SSLProtocolTransport.__del__x sE | , DL NN*
,
,
,
,
, , ,r c | j j S r> )r1 _app_reading_pausedrD s r
is_readingz _SSLProtocolTransport.is_reading s %999r c 8 | j dS )zPause the receiving end.
No data will be passed to the protocol's data_received()
method until resume_reading() is called.
N)r1 _pause_readingrD s r
pause_readingz#_SSLProtocolTransport.pause_reading s
))+++++r c 8 | j dS )zResume the receiving end.
Data received will once again be passed to the protocol's
data_received() method.
N)r1 _resume_readingrD s r resume_readingz$_SSLProtocolTransport.resume_reading s
**,,,,,r c n | j || | j dS )a Set the high- and low-water limits for write flow control.
These two values control when to call the protocol's
pause_writing() and resume_writing() methods. If specified,
the low-water limit must be less than or equal to the
high-water limit. Neither value can be negative.
The defaults are implementation-specific. If only the
high-water limit is given, the low-water limit defaults to an
implementation-specific value less than or equal to the
high-water limit. Setting high to zero forces low to zero as
well, and causes pause_writing() to be called whenever the
buffer becomes non-empty. Setting low to zero causes
resume_writing() to be called only once the buffer is empty.
Use of zero for either limit is generally sub-optimal as it
reduces opportunities for doing I/O and computation
concurrently.
N)r1 _set_write_buffer_limits_control_app_writingr3 r' r( s r set_write_buffer_limitsz-_SSLProtocolTransport.set_write_buffer_limits s8 &
33D#>>> //11111r c 2 | j j | j j fS r> )r1 _outgoing_low_water_outgoing_high_waterrD s r get_write_buffer_limitsz-_SSLProtocolTransport.get_write_buffer_limits "6"79 9r c 4 | j S )z-Return the current size of the write buffers.)r1 _get_write_buffer_sizerD s r get_write_buffer_sizez+_SSLProtocolTransport.get_write_buffer_size s !88:::r c n | j || | j dS )a Set the high- and low-water limits for read flow control.
These two values control when to call the upstream transport's
pause_reading() and resume_reading() methods. If specified,
the low-water limit must be less than or equal to the
high-water limit. Neither value can be negative.
The defaults are implementation-specific. If only the
high-water limit is given, the low-water limit defaults to an
implementation-specific value less than or equal to the
high-water limit. Setting high to zero forces low to zero as
well, and causes pause_reading() to be called whenever the
buffer becomes non-empty. Setting low to zero causes
resume_reading() to be called only once the buffer is empty.
Use of zero for either limit is generally sub-optimal as it
reduces opportunities for doing I/O and computation
concurrently.
N)r1 _set_read_buffer_limits_control_ssl_readingr\ s r set_read_buffer_limitsz,_SSLProtocolTransport.set_read_buffer_limits s8 &
224=== //11111r c 2 | j j | j j fS r> )r1 _incoming_low_water_incoming_high_waterrD s r get_read_buffer_limitsz,_SSLProtocolTransport.get_read_buffer_limits rb r c 4 | j S )z+Return the current size of the read buffer.)r1 _get_read_buffer_sizerD s r get_read_buffer_sizez*_SSLProtocolTransport.get_read_buffer_size s !77999r c | j j S r> )r1 _app_writing_pausedrD s r _protocol_pausedz&_SSLProtocolTransport._protocol_paused s !55r c t |t t t f s$t dt | j |sdS | j |f dS )zWrite some data bytes to the transport.
This does not block; it buffers the data and arranges for it
to be sent out asynchronously.
z+data: expecting a bytes-like instance, got N)
isinstancebytes bytearray
memoryview TypeErrortyper r1 _write_appdatar3 datas r writez_SSLProtocolTransport.write sv $ : >?? : 9#'::#6 9 9 : :
: F ))4'22222r c : | j | dS )zWrite a list (or any iterable) of data bytes to the transport.
The default implementation concatenates the arguments and
calls write() on the result.
N)r1 r{ )r3 list_of_datas r
writelinesz _SSLProtocolTransport.writelines s!
)),77777r c t )zuClose the write end after flushing buffered data.
This raises :exc:`NotImplementedError` right now.
)NotImplementedErrorrD s r write_eofz _SSLProtocolTransport.write_eof s
"!r c dS )zAReturn True if this transport supports write_eof(), False if not.Fr rD s r
can_write_eofz#_SSLProtocolTransport.can_write_eof s ur c 0 | d dS )zClose the transport immediately.
Buffered data will be lost. No more data will be received.
The protocol's connection_lost() method will (eventually) be
called with None as its argument.
N) _force_closerD s r abortz_SSLProtocolTransport.abort s
$ r c Z d| _ | j | j | d S d S NT)r2 r1 _abortr3 excs r r z"_SSLProtocolTransport._force_close s7 ) % %c * * * * * * )r c | j j | | j xj t | z
c_ d S r> )r1 _write_backlogappend_write_buffer_sizelenr| s r _test__append_write_backlogz1_SSLProtocolTransport._test__append_write_backlog s? )00666 --T:----r r> NN)"r r r _start_tls_compatibler
_SendfileModeFALLBACK_sendfile_compatibler6 r< rA rE rG rJ warningsrO rR rU rX r] ra re ri rm rp propertyrs r~ r r r r r r r r r r. r. R s !$2;
A A A A7 7 70 0 0 & & & !) , , , ,: : :, , ,- - -2 2 2 2,9 9 9; ; ;2 2 2 2,9 9 9: : : 6 6 X6 3 3 38 8 8" " " + + +
; ; ; ; ;r r. c e Zd ZdZdZdZdZ d-dZd Zd.dZ d Z
d Z d
Z d Z
d Zd
Zd.dZd Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Z d Z d Z d Z d Z d Z!d Z"d! Z#d" Z$d/d#Z%d$ Z&d% Z'd& Z(d/d'Z)d( Z*d) Z+d* Z,d0d,Z-dS )1 SSLProtocoli NFTc
t t d t | j | _ t | j | _ |
t j }n|dk rt d| |
t j
} n| dk rt d| |st || }|| _ |r
|s|| _
nd | _
|| _ t | | _ t# j | _ d| _ || _ || _ | | d | _ d| _ d | _ || _ | | _ t j | _ t j | _ t@ j! | _" d| _# |rtH j% | _& ntH j' | _& | j ( | j | j | j | j
| _) d| _* d| _+ d| _, d| _- d| _. | / d| _0 d| _1 d| _2 d| _3 | 4 | 5 d S )Nz stdlib ssl module not availabler z7ssl_handshake_timeout should be a positive number, got z6ssl_shutdown_timeout should be a positive number, got )r# F)r! r" )6r RuntimeErrorrw max_size _ssl_bufferrx _ssl_buffer_viewr SSL_HANDSHAKE_TIMEOUTr SSL_SHUTDOWN_TIMEOUTr$ _server_side_server_hostname _sslcontextdict_extra collectionsdequer r _waiterr0 r? _app_transport_app_transport_created
_transport_ssl_handshake_timeout_ssl_shutdown_timeout MemoryBIO _incoming _outgoingr
r _state
_conn_lostr r
_app_stater wrap_bio_sslobj_ssl_writing_pausedrQ _ssl_reading_pausedrl rk rg
_eof_receivedrr r` r_ rZ _get_app_transport)
r3 r4 app_protocolr# waiterr! r" call_connection_madessl_handshake_timeoutssl_shutdown_timeouts
r r6 zSSLProtocol.__init__ s
; @AA A$T]33 *4+; < < ($-$C ! !
"a
'
' /,/ /0 0
0 '#,#A
!Q
&
& .+. ./ /
/ .2_. .J ( ); )$3D ! !$(D !% j111 * / 1 1"#
|,,, "&+# &;#%9" &0 > . 9DOO . =DO'00 NDN ) 1 1 3 3 $) #( #( $%!#$ $$&&& "#( $%!#$ %%''' !!!!!r c || _ t |d r;t |t j r!|j | _ |j | _ d| _ d S d| _ d S )N
get_bufferTF)
rC hasattrru r BufferedProtocolr _app_protocol_get_bufferbuffer_updated _app_protocol_buffer_updated_app_protocol_is_buffer)r3 r s r r? z SSLProtocol._set_app_protocola sc ) L, / / 1<)CDD 1,8,CD )0<0KD -+/D ( ( (+0D ( ( (r c | j d S | j s7|| j | n| j d d | _ d S r> )r cancelled
set_exception
set_resultr s r _wakeup_waiterzSSLProtocol._wakeup_waiterl sd < F|%%'' . **3//// ''--- r c | j 7| j rt d t | j | | _ d| _ | j S )Nz$Creating _SSLProtocolTransport twiceT)r r r r. r0 rD s r r z SSLProtocol._get_app_transportv sK &*
K"#IJJJ"7
D"I"ID *.D '""r c < || _ | dS )zXCalled when the low-level connection is made.
Start the SSL handshake.
N)r _start_handshake)r3 transports r connection_madezSSLProtocol.connection_made~ s#
$ r c | j | j | xj dz
c_ | j d| j _ | j t j k r`| j
t j k s| j
t j
k r6t j | _
| j | j j | | t j d| _ d| _ d| _ | | | j r | j d| _ | j r"| j d| _ dS dS )zCalled when the low-level connection is lost or closed.
The argument is an exception object or None (the latter
meaning a regular EOF is received or the connection was
aborted or closed).
r NT)r clearr readr r r2 r r
r r r r r r r0 call_soonrC connection_lost
_set_stater r r _shutdown_timeout_handlecancel_handshake_timeout_handler s r r zSSLProtocol.connection_lost sO
!!### 1 **.D ' ;*7 7 7#3#BBB#3#==="2"A
$$T%7%GMMM (2333 " ! C ( 1 ) 0 0 2 2 2,0D ) ) 2 * 1 1 3 3 3-1D * * * 2 2r c |}|dk s || j k r| j }t | j |k r-t | | _ t | j | _ | j S Nr )r r r rw rx r )r3 nwants r r zSSLProtocol.get_buffer sc 199t},,=D t 4 ' ' (D $.t/?$@$@D !$$r c | j | j d | | j t j k r| d S | j t j k r| d S | j t j k r|
d S | j t j k r| d S d S r> )
r r~ r r r
r
_do_handshaker
_do_readr _do_flushr _do_shutdown)r3 nbytess r r zSSLProtocol.buffer_updated s T 27F7 ;<<< ;*7 7 7
[ , 4
4
4 MMOOOOO
[ , 5
5
5 NN
[ , 5
5
5 6
5r c d| _ | j rt j d| | j t j k r | t dS | j t j
k r>| t j | j
rdS | dS | j t j k rI| | t j | dS | j t j k r| dS dS # t$ $ r | j w xY w)a Called when the other end of the low-level stream
is half-closed.
If this returns a false value (including None), the transport
will close itself. If it returns a true value, closing the
transport is up to the protocol.
Tz%r received EOFN)r r0 get_debugr debugr r
r _on_handshake_completeConnectionResetErrorr
r r rQ r _do_writer r Exceptionr rJ rD s r eof_receivedzSSLProtocol.eof_received sg " z##%%
6 .555{ . ;;;++,@AAAAA 0 888 0 9:::+ % 4NN$$$$$ 0 999 0 9:::!!##### 0 999!!##### :9 O ! ! # # # s% A E (;E %E ;A E )E %E+c v || j v r
| j | S | j | j || S |S r> )r r r< r9 s r r8 zSSLProtocol._get_extra_info sA 4; ;t$ $
_
(?11$@@ @Nr c d}|t j k rd}n| j t j k r|t j k rd}nw| j t j k r|t j k rd}nO| j t j k r|t j k rd}n'| j t j k r|t j k rd}|r || _ d S t d | j | )NFTz!cannot switch state from {} to {}) r
r r r r
r r r format)r3 new_statealloweds r r zSSLProtocol._set_state s (2 2 2GG
K+5 5 5 )6 6 6GG
K+8 8 8 )1 1 1GG
K+3 3 3 )2 2 2GG
K+4 4 4 )2 2 2G -#DKKK 3::K, ,- -
-r c f j r4t j d j _ nd _ t j j j
fd _ d S )Nz%r starts SSL handshakec , S r> )_check_handshake_timeoutrD s r <lambda>z.SSLProtocol._start_handshake.<locals>.<lambda>! s $*G*G*I*I r )
r0 r r r time_handshake_start_timer r
r
call_laterr r r rD s `r r z SSLProtocol._start_handshake s : ! ! . L2D 9 9 9)- ):):D & &)-D & (5666
J ! !$"="I"I"I"I
K
K
&
r c | j t j k r/d| j d}| t | d S d S )Nz$SSL handshake is taking longer than z! seconds: aborting the connection)r r
r r _fatal_errorConnectionAbortedError)r3 msgs r r z$SSLProtocol._check_handshake_timeout% s_ ;*7 7 7+.+ + +
4S 9 9 : : : : :
8 7r c | j | d d S # t $ r | Y d S t
j $ r }| | Y d }~d S d }~ww xY wr> )r do_handshaker SSLAgainErrors_process_outgoingr SSLErrorr s r r zSSLProtocol._do_handshake. s . L % % ' ' '
' ' - - - - - % % % " " $ $ $ $ $ $| - - - ' ' , , , , , , , , , -s 2 BB!A<<Bc | j | j d | _ | j } | | t j n|| }n# t $ rv}d }| t j t |t j rd}nd}| || |
| Y d }~d S d }~ww xY w| j r:| j | j z
}t% j d| |dz | j || | | | j t2 j k r=t2 j | _ | j | |
| d S )Nz1SSL handshake failed on verifying the certificatezSSL handshake failedz %r: SSL handshake took %.1f msg @@)peercertcipher compression
ssl_object) r r r r r
r
getpeercertr r ru r CertificateErrorr r r0 r r r r r r updater r r r r r rC r r r )r3
handshake_excsslobjr r r dts r r z"SSLProtocol._on_handshake_complete8 s ) 5 * 1 1 3 3 3-1D * $ 0 89999## ))++HH M OO , 6 7 7 7#s 344
-I, c3 ' ' ' $ $ $ FFFFF : ! ! K ""T%??B L94c J J J
H"(--//'-'9'9';';&, . . . ? . 9 9 9 . =DO . .t/F/F/H/H I I I
s 8A) )
C)3A+C$$C)c j t j t j t j fv rd S j d j _ j t j k r d d S t j j
j fd _
d S )NTc , S r> )_check_shutdown_timeoutrD s r r z-SSLProtocol._start_shutdown.<locals>.<lambda>r s 4466 r )r r
r r r r r2 r r r r0 r r r r rD s `r rI zSSLProtocol._start_shutdowna s K ) ) *
F **.D ' ;*7 7 7 KK OO , 5 6 6 6,0J,A,A*6666- -D )
NN r c | j t j t j fv r.| j t
j d d S d S )NzSSL shutdown timed out)r r
r r r r r TimeoutErrorrD s r r z#SSLProtocol._check_shutdown_timeoutv sf K ) )
O ( ('(@AA
C
C
C
C
C
r c | | t j | d S r> )r r r
r r rD s r r zSSLProtocol._do_flush s=
(1222 r c f | j s| j | | | d d S # t $ r | Y d S t j $ r }| | Y d }~d S d }~ww xY wr> ) r r unwrapr _call_eof_received_on_shutdown_completer r r r s r r zSSLProtocol._do_shutdown s
-%
& ##%%%
" " $ $ $ # # % % % & &t , , , , , % % % " " $ $ $ $ $ $| , , , & &s + + + + + + + + + ,s A! ! B0B0B++B0c | j | j d | _ |r| | d S | j | j j d S r> )r r r r0 r r rJ )r3 shutdown_excs r r z!SSLProtocol._on_shutdown_complete sk ( 4 ) 0 0 2 2 2,0D ) 8 l + + + + + J !6 7 7 7 7 7r c | t j | j | j | d S d S r> )r r
r r r r s r r zSSLProtocol._abort sD (2333 ? & O ( ( - - - - - ' &r c | j t j t j t j fv r;| j t j k rt j d | xj dz
c_ d S |D ]9}| j
| | xj t | z
c_ : | j t j k r| d S d S # t $ r!}| |d Y d }~d S d }~ww xY w)NzSSL connection is closedr Fatal error on SSL protocol)r r
r r r r r !LOG_THRESHOLD_FOR_CONNLOST_WRITESr warningr r r r r
r r r )r3 r r} exs r r{ zSSLProtocol._write_appdata s& K ) ) *
)"MMM 9::: OOq OO F 1 1D & &t , , , # #s4yy 0 # # # A{ . 666 76 A A A b"? @ @ @ @ @ @ @ @ @ As #)C
C;C66C;c \ | j r~| j d }| j | }t | }||k r#||d | j d< | xj |z c_ n| j d= | xj |z c_ | j ~n# t
$ r Y nw xY w| d S r )r r r~ r r r r )r3 r} countdata_lens r r zSSLProtocol._do_write s %
8*1- **400 t998##-1%&&\D'*++u4+++ +A.++x7++ %
8 D s BB
BBc | j sB| j }t | r| j | | d S r> )r r r r r r~ r[ r| s r r z SSLProtocol._process_outgoing s\ ' ,>&&((D4yy
,%%d+++ !!#####r c | j t j t j fvrd S | j s`| j r| n| | j r| n|
| d S # t $ r!}|
|d Y d }~d S d }~ww xY w)Nr )r r
r
r rQ r _do_read__buffered_do_read__copiedr r r rh r r )r3 r! s r r zSSLProtocol._do_read s K ( )
F A+
-/ ,++----))+++& -NN$$$$**,,, % % ' ' ' ' ' A A A b"? @ @ @ @ @ @ @ @ @ As A;B
C *CC c , d}d} }t | } j || }|dk r^|}||k r9 j ||z
||d }|dk r||z
}nn#||k 9 j fd n# t $ r Y nw xY w|dk r | |s*
d S d S )Nr r c , S r> )r rD s r r z0SSLProtocol._do_read__buffered.<locals>.<lambda> s r ) r ro r r r r0 r r r r rI )r3 offsetr# bufwantss ` r r' z SSLProtocol._do_read__buffered sK ++D,F,F,H,HIIC L%%eS11Eqyy unn L - -efnc&''l K KE qyy % unn J(()@)@)@)@AAA D A:: - -f 5 5 5 # # # % % % " " " " " # #s A?B= =
C
C
c d}d}d} | j | j }|sn(|rd}d}|}n |rd}||g}n| | Jn# t $ r Y nw xY w|r| j | n/|s-| j d | |s*| | d S d S )N 1TFr )
r r r r r rC
data_receivedjoinr rI )r3 chunkzeroonefirstr} s r r( z SSLProtocol._do_read__copied s3
' ))$-88 ' D C !EE ' C !5>DDKK&&&
' D = , ,U 3 3 3 3 = , ,SXXd^^ < < < # # # % % % " " " " " # #s A A
A! A!c 8 | j t j k rBt j | _ | j }|rt
j d d S d S d S # t t f$ r t $ r!}| |d Y d }~d S d }~ww xY w)Nz?returning true from eof_received() has no effect when using sslz Error calling eof_received()) r r r r rC r r r KeyboardInterrupt
SystemExit
BaseExceptionr )r3 keep_openr! s r r z SSLProtocol._call_eof_received% s
B"2"AAA"2"< . ; ; = = CN $B C C C C C BAC C ":. B B B b"@ A A A A A A A A A Bs AA B8BBc : | }|| j k rw| j spd| _ | j d S # t
t f$ r t $ r/}| j d|| j
| d Y d }~d S d }~ww xY w|| j k rw| j rrd| _ | j d S # t
t f$ r t $ r/}| j d|| j
| d Y d }~d S d }~ww xY wd S d S )NTz protocol.pause_writing() failedmessage exceptionr r@ Fz protocol.resume_writing() failed)
rd r` rr rC
pause_writingr7 r8 r9 r0 call_exception_handlerr r_ resume_writing)r3 sizer s r r[ z SSLProtocol._control_app_writing4 s **,, 4, , ,T5M ,'+D $
"0022222%z2
11 @!$!%!4 $ 3 3
T-
-
-$2J
-',D $
"1133333%z2
11 A!$!%!4 $ 3 3
.
-
-
-s/ A
B%$BB1C D'$DDc * | j j | j z S r> )r pendingr rD s r rd z"SSLProtocol._get_write_buffer_sizeQ s ~%(???r c ^ t ||t j \ }}|| _ || _ d S r> )r, r !FLOW_CONTROL_HIGH_WATER_SSL_WRITEr` r_ r\ s r rZ z$SSLProtocol._set_write_buffer_limitsT s7 , #yBD D c$(!#& r c d| _ d S r )rQ rD s r rT zSSLProtocol._pause_reading\ s #' r c f j r(d _ fd} j | d S d S )NFc
j t j k r d S j t j k r d S j t j k r d S d S r> )r r
r
r r r r r rD s r resumez+SSLProtocol._resume_reading.<locals>.resumec s} ;"2":::MMOOOOO[$4$===NN$$$$$[$4$===%%''''' >=r )rQ r0 r )r3 rJ s ` r rW zSSLProtocol._resume_reading_ sW #
)',D $
(
(
(
(
(
J ( ( ( ( (
)
)r c | }|| j k r)| j s"d| _ | j d S || j k r)| j r$d| _ | j d S d S d S )NTF)ro rl r r rU rk rX )r3 rB s r rh z SSLProtocol._control_ssl_readingn s ))++ 4, , ,T5M ,'+D $ O ) ) + + + + +
T-
-
-$2J
-',D $ O * * , , , , , .
-
-
-r c ^ t ||t j \ }}|| _ || _ d S r> )r, r FLOW_CONTROL_HIGH_WATER_SSL_READrl rk r\ s r rg z#SSLProtocol._set_read_buffer_limitsw s7 , #yAC C c$(!#& r c | j j S r> )r rD rD s r ro z!SSLProtocol._get_read_buffer_size} s
~%%r c d| _ dS )z\Called when the low-level transport's buffer goes over
the high-water mark.
TN)r rD s r r? zSSLProtocol.pause_writing s
$( r c < d| _ | dS )z^Called when the low-level transport's buffer drains below
the low-water mark.
FN)r r rD s r rA zSSLProtocol.resume_writing s$
$) r Fatal error on transportc \ | j r| j | t |t r5| j rt
j d| |d d S d S t |t j s&| j
||| j | d d S d S )Nz%r: %sT)exc_infor< ) r r ru OSErrorr0 r r r r CancelledErrorr@ )r3 r r= s r r zSSLProtocol._fatal_error s ? . O ( ( - - - c7 # # z##%%
E XtWtDDDDDD
E
EC!:;; J - -" !_ / /
r )FNTNNr> r )rQ ).r r r r r r r r6 r? r r r r r r r r8 r r r r r rI r r r r r r{ r r r r' r( r r[ rd rZ rT rW rh rg ro r? rA r r r r r r s H $ # 59&*'+&* Q" Q" Q" Q"f 1 1 1 # # # "2 "2 "2H% % %
! ! !F $- $- $-P ; ; ;. . .% % %R *C C C
- - -8 8 8. . .A A A0! ! ! $ $ $A A A,# # #: # # #< B B B :@ @ @' ' ' '( ( ( ) ) ) - - -' ' ' ' & & &
( ( (! ! !
r r )r enumr r ImportError r r r r logr SSLWantReadErrorSSLSyscallErrorr Enumr
r r$ r, _FlowControlMixin Transportr. r r r r r <module>r_ s
JJJJ
CCC ?*C,?@N ty
&
&
&
&
&ty
&
&
& *r; r; r; r; r;J 8 & 0r; r; r;jW
W
W
W
W
), W
W
W
W
W
s