֦i| z d dl Z d dlZd dlZ d dlZddlmZ 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. Zy# e$ r dZY w xY w) N ) constants)
exceptions) protocols)
transports)loggerc e Zd ZdZdZdZdZdZy)SSLProtocolState UNWRAPPED DO_HANDSHAKEWRAPPEDFLUSHINGSHUTDOWNN)__name__
__module__ __qualname__r r r
r r )/usr/lib64/python3.12/asyncio/sslproto.pyr
r
s I!LGHHr r
c e Zd ZdZdZdZdZy)AppProtocolState
STATE_INITSTATE_CON_MADE STATE_EOFSTATE_CON_LOSTN)r r r r r r r r r r r r s J%NI%Nr r c Z | r t 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$ / s2 CDD ++-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, = sh | ;dBBRB
{
1W
=q= b" # # 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!y) _SSLProtocolTransportTc . || _ || _ d| _ y )NF)_loop
_ssl_protocol_closed)selfloop ssl_protocols r __init__z _SSLProtocolTransport.__init__X s
) r Nc : | j 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 j | y N)r1 _set_app_protocol)r3 protocols r set_protocolz"_SSLProtocolTransport.set_protocola s ,,X6r c . | j j S r> )r1
_app_protocolr3 s r get_protocolz"_SSLProtocolTransport.get_protocold s !!///r c R | j xs | j j S r> )r2 r1 _is_transport_closingrD s r
is_closingz _SSLProtocolTransport.is_closingg s ||It 1 1 G G IIr c n | j s"d| _ | j j yd| _ y)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!%D r c X | j s d| _ |j dt y y )NTz9unclosed transport )r2 warnResourceWarning)r3 _warningss r __del__z _SSLProtocolTransport.__del__x s) || DL NN*
, r c 0 | j j S r> )r1 _app_reading_pausedrD s r
is_readingz _SSLProtocolTransport.is_reading s %%9999r c 8 | j j y)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 j y)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 p | j j || | j j y)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 s, &
33D#> //1r c Z | j j | j j fS r> )r1 _outgoing_low_water_outgoing_high_waterrD s r get_write_buffer_limitsz-_SSLProtocolTransport.get_write_buffer_limits * ""66""779 9r c 6 | j 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 p | j j || | j j y)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 s, &
224= //1r c Z | j j | j j fS r> )r1 _incoming_low_water_incoming_high_waterrD s r get_read_buffer_limitsz,_SSLProtocolTransport.get_read_buffer_limits rc r c 6 | j 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 !!7799r c . | j j S r> )r1 _app_writing_pausedrD s r _protocol_pausedz&_SSLProtocolTransport._protocol_paused s !!555r c t |t t t f s!t dt | j |sy| j j |f y)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 sX $ : >? ##':#6#6"7 9 :
: ))4'2r c : | j j | y)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
)),7r 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 y)zAReturn True if this transport supports write_eof(), False if not.Fr rD s r
can_write_eofz#_SSLProtocolTransport.can_write_eof s r c & | j d y)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 b d| _ | j | j j | y y NT)r2 r1 _abortr3 excs r r z"_SSLProtocolTransport._force_close s. ) % %c * *r c | j j j | | j xj t | z
c_ y r> )r1 _write_backlogappend_write_buffer_sizelenr} s r _test__append_write_backlogz1_SSLProtocolTransport._test__append_write_backlog s7 ))006 --T:-r r> NN)"r r r _start_tls_compatibler
_SendfileModeFALLBACK_sendfile_compatibler6 r< rA rE rH rK warningsrP rS rV rY r^ rb rf rj rn rq propertyrt r r r r r r r r r r r. r. R s !$22;;
A70J & !) ,:,-2,9;2,9: 6 6 38" +
;r r. c e Zd ZdZdZdZdZ d+dZd Zd,dZ d Z
d Z d Z d Z
d
Zd Zd Zd,d
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! Z%d-d"Z&d# Z'd$ Z(d% Z)d-d&Z*d' Z+d( Z,d) Z-d.d*Z.y)/ SSLProtocoli Nc
t t d t | j | _ t | j | _ |t j }n|dk rt d| | t j } n| dk rt d| |s t || }|| _ |r
|s|| _
nd | _
|| _ t | | _ t# j$ | _ d| _ || _ || _ | j/ | d | _ d| _ d | _ || _ | | _ t j: | _ t j: | _ t@ jB | _" d| _# |rtH jJ | _& ntH jN | _& | j jQ | j< | j> | j | j | _) d| _* d| _+ d| _, d| _- d| _. | j_ d| _0 d| _1 d| _2 d| _3 | ji | jk y )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 RuntimeErrorrx max_size _ssl_bufferry _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_pausedrR _ssl_reading_pausedrm rl rh
_eof_receivedrs ra r` r[ _get_app_transport)
r3 r4 app_protocolr# waiterr! r" call_connection_madessl_handshake_timeoutssl_shutdown_timeouts
r r6 zSSLProtocol.__init__ sE
; @A A$T]]3 *4+;+; < ($-$C$C !
"a
' ,-/0
0 '#,#A#A
!Q
& +,./
/ 2_.J ( ;$3D !$(D !% j1 * / / 1"#
|, "&+# &;#%9" &00 . 9 9DO . = =DO''00 NNDNN )) 1 1 1 3 $) #( #( $%!#$ $$& "#( $%!#$ %%' !r c || _ t |d rDt |t j r*|j
| _ |j | _ d| _ y d| _ y )N
get_bufferTF)
rC hasattrrv 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 sP ) L, /<)C)CD,8,C,CD )0<0K0KD -+/D (+0D (r c | j y | j j s@|#| j j | d | _ y | j j d d | _ y r> )r cancelled
set_exception
set_resultr s r _wakeup_waiterzSSLProtocol._wakeup_waiterl sZ << ||%%' **3/ ''- r c | j 9| j r t d t | j | | _ d| _ | j S )Nz$Creating _SSLProtocolTransport twiceT)r r r r. r0 rD s r r z SSLProtocol._get_app_transportv sJ &**"#IJJ"7
D"ID *.D '"""r c V | j d uxr | j j S r> )r rH rD s r rG z!SSLProtocol._is_transport_closing~ s# d*Kt/I/I/KKr c 2 || _ | j y)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 H | j j | j j | xj dz
c_ | j
d| j
_ | j t j k7 r| j t j k( s | j t j k( rEt j | _
| j j! | j" j$ | | j' t j( d| _ d| _ d| _ | j- | | j. r!| j. j1 d| _ | j2 r"| j2 j1 d| _ yy)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 s9
!!# 1 **.D ' ;;*77 7#3#B#BB#3#=#=="2"A"A
$$T%7%7%G%GM (223 " ! C ( ( ) ) 0 0 2,0D ) ) ) * * 1 1 3-1D * *r c |}|dk s|| j kD r | j }t | j |k r*t | | _ t | j | _ | j
S Nr )r r r rx ry r )r3 nwants r r zSSLProtocol.get_buffer s` 19t}},==D t 4 ' (D $.t/?/?$@D !$$$r c | j j | j d | | j t j
k( r| j
y | j t j k( r| j y | j t j k( r| j y | j t j k( r| j y y r> )
r r r r r
r
_do_handshaker
_do_readr _do_flushr _do_shutdown)r3 nbytess r r zSSLProtocol.buffer_updated s T 2 27F ;< ;;*77 7
[[ , 4 4
4 MMO
[[ , 5 5
5 NN
[[ , 5 5
5 6r c d| _ | j j rt j d| | j
t j k( r| j t y| j
t j k( r=| j t j | j ry| j y| j
t j k( r@| j | j t j | j# y| j
t j k( r| j# yy# t$ $ r | j& 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 rR r _do_writer r Exceptionr rK rD s r eof_receivedzSSLProtocol.eof_received s " zz##% .5{{ . ; ;;++,@A 0 8 88 0 9 9:++ NN$ 0 9 99 0 9 9:!!# 0 9 99!!# : OO ! ! # s& A"E ,AE 5E A E #-E %E7c || j v r| j | S | j | j j || S |S r> )r r r< r9 s r r8 zSSLProtocol._get_extra_info sC 4;; ;;t$ $
__
(??11$@ @Nr c & d}|t j k( rd}n| j t j k( r|t j k( rd}n| j t j k( r|t j k( rd}ne| j t j k( r|t j
k( rd}n2| j t j
k( r|t j k( rd}|r|| _ y t dj | 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 (22 2G
KK+55 5 )66 6G
KK+88 8 )11 1G
KK+33 3 )22 2G
KK+44 4 )22 2G #DK 3::KK,-
-r c n j j r6t j d j j _ nd _ j
t j j j j fd _ j y )Nz%r starts SSL handshakec $ j S r> )_check_handshake_timeoutrD s r z.SSLProtocol._start_handshake..$ s $*G*G*Ir )
r0 r r r time_handshake_start_timer r
r
call_laterr r r rD s `r r z SSLProtocol._start_handshake s :: ! LL2D 9)- ):D &)-D & (556
JJ ! !$"="="I
K
&
r c | j t j k( r+d| j d}| j t | y y )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( sN ;;*77 76../ 0*+
4S 9 :
8r c | j j | j d y # t $ r | j Y y t
j $ r}| j | Y d }~y d }~ww xY wr> )r do_handshaker SSLAgainErrors_process_outgoingr SSLErrorr s r r zSSLProtocol._do_handshake1 sb . LL % % '
' ' - % " " $|| - ' ' , , -s . A6 A6A11A6c | j !| j j d | _ | j } | | j t j
n||j
}| j j rA| j j! | j" z
}t% j& d| |dz | j( j+ ||j- |j/ | | j0 t2 j4 k( r>t2 j6 | _ | j8 j; | j= | j | j? y # t $ rm}d }| j t j t |t j rd}nd}| j || | j | Y d }~y d }~ww xY w)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 rv 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_complete; s ) ) 5 * * 1 1 3-1D * $ 0 8 89## ))+H :: ! "T%?%??B LL94c J
H"(--/'-'9'9';&, . ?? . 9 9 9 . = =DO . .t/F/F/H I
1 M OO , 6 6 7#s 3 34I, c3 ' $ s 4F G7
A#G22G7c j t j t j t j fv ry j
d j
_ j t j k( r j d y j t j j j j fd _
j y )NTc $ j S r> )_check_shutdown_timeoutrD s r r z-SSLProtocol._start_shutdown..u s 446r )r r
r r r r r2 r r r r0 r r r r rD s `r rJ zSSLProtocol._start_shutdownd s KK )) )) **
**.D ' ;;*77 7 KK OO , 5 5 6,0JJ,A,A**6-D )
NN r c | j t j t j fv r/| j j t
j d y y )NzSSL shutdown timed out)r r
r r r r r TimeoutErrorrD s r r z#SSLProtocol._check_shutdown_timeouty sN KK )) ))
OO ( (''(@A
C
r c | j | j t j | j y r> )r r r
r r rD s r r zSSLProtocol._do_flush s*
(112 r c J | j s| j j | j | j | j d y # t $ r | j Y y t j $ r}| j | Y d }~y 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 B"5B"B B"c | j !| j j d | _ |r| j | y | j j | j
j y r> )r r r r0 r r rK )r3 shutdown_excs r r z!SSLProtocol._on_shutdown_complete sU ( ( 4 ) ) 0 0 2,0D ) l + JJ !6!6 7r c | j t j | j | j j | y y r> )r r
r r r r s r r zSSLProtocol._abort s6 (223 ?? & OO ( ( - 'r c 8 | j t j t j t j fv rH| j
t j k\ rt j d | xj
dz
c_ y |D ]; }| j j | | xj t | z
c_ = | j t j k( r| j y y # t $ r }| j# |d Y d }~y 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 KK )) )) **
)"M"MM 9: OOq O D & &t , # #s4y 0 # ! A{{ . 6 66 7 A b"? @ @ As -C4 4 D=DDc ~ | j r| j d }| j j | }t | }||k r(||d | j d< | xj |z c_ n"| j d= | xj |z c_ | j r| j
y # t
$ r Y w xY wr )r r r r r r r )r3 r~ countdata_lens r r zSSLProtocol._do_write s %%**1- **40 t98#-1%&\D''*++u4+ ++A.++x7+ %%
s B B0 0 B<;B<c | j s@| j j }t | r| j j | | j
y r> )r r r r r r r\ r} s r r z SSLProtocol._process_outgoing sB ''>>&&(D4y%%d+ !!#r c | j t j t j fvry | j sZ| j
r| j
n| j | j r| j n| j | j y # t $ r }| j |d Y d }~y d }~ww xY w)Nr )r r
r
r rR r _do_read__buffered_do_read__copiedr r r ri r r )r3 r# s r r zSSLProtocol._do_read s KK (( ))
A++//++-))+&&NN$**, % % ' A b"? @ @ As A6B& & C /CC c d}d} j j }t | } j j || }|dkD rY|}||k r4 j j ||z
||d }|dkD r||z
}nn$||k r4 j
j
fd |dkD r j | |s! j j y y # t $ r Y Ew xY w)Nr r c $ j S r> )r rD s r r z0SSLProtocol._do_read__buffered.. s r ) r rp r r r r0 r r r r rJ )r3 offsetr% bufwantss ` r r) z SSLProtocol._do_read__buffered s ++D,F,F,HIC LL%%eS1Eqy un LL - -efnc&'l KE qy % un JJ(()@A A: - -f 5 # # % " s AC%
C% % C10C1c d}d}d} | j j | j }|sn$|rd}d}|}n|rd}|g}nj | L |r | j
j
n,|s*| j
j
dj |s!| j | j y y # t $ r Y yw xY w)N 1TFr )
r r r r r rC
data_receivedjoinr rJ )r3 chunkzeroonefirstr~ s r r* z SSLProtocol._do_read__copied
s ))$--8 D C !E C !5>DKK& , ,U 3 , ,SXXd^ < # # % "
s A
C CCc > | j t j k( rHt j | _ | j j }|rt
j d y y y # t t f$ r t $ r }| j |d Y d }~y 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"A"AA"2"<"< . . ; ; = NN $B C B ":. B b"@ A A Bs A#A( (B BB c Z | j }|| j k\ r/| j s#d| _ | j j y || j k r0| j r#d| _ | j j y y y # t
t f$ r t $ r4}| j j d|| j | d Y d }~y d }~ww xY w# t
t f$ r t $ r4}| j j d|| j | d Y d }~y d }~ww xY w)NTz protocol.pause_writing() failedmessage exceptionr r@ Fz protocol.resume_writing() failed)
re ra rs rC
pause_writingr9 r: r; r0 call_exception_handlerr r` resume_writing)r3 sizer s r r\ z SSLProtocol._control_app_writing7 s$ **, 4,, ,T5M5M'+D $
""002 T--
-$2J2J',D $
""113 3K
- &z2
11 @!$!%!4!4 $ 3
&z2
11 A!$!%!4!4 $ 3
s/ B 2C C'*CC D*6*D%%D*c H | j j | j z S r> )r pendingr rD s r re z"SSLProtocol._get_write_buffer_sizeT s ~~%%(?(???r c \ t ||t j \ }}|| _ || _ y r> )r, r !FLOW_CONTROL_HIGH_WATER_SSL_WRITEra r` r] s r r[ z$SSLProtocol._set_write_buffer_limitsW s. , #yBBD c$(!#& r c d| _ y r )rR rD s r rU zSSLProtocol._pause_reading_ s
#' r c n j r(d _ fd} j j | y y )NFc j t j k( r j y j t j k( r j y j t j k( r j y y r> )r r
r
r r r r r rD s r resumez+SSLProtocol._resume_reading..resumef s` ;;"2":"::MMO[[$4$=$==NN$[[$4$=$==%%' >r )rR r0 r )r3 rL s ` r rX zSSLProtocol._resume_readingb s2 # #',D $
(
JJ ( $r c | j }|| j k\ r.| j s"d| _ | j j y || j
k r/| j r"d| _ | j j
y y y )NTF)rp rm r r rV rl rY )r3 rD s r ri z SSLProtocol._control_ssl_readingq su ))+ 4,, ,T5M5M'+D $ OO ) ) +
T--
-$2J2J',D $ OO * * , 3K
-r c \ t ||t j \ }}|| _ || _ y r> )r, r FLOW_CONTROL_HIGH_WATER_SSL_READrm rl r] s r rh z#SSLProtocol._set_read_buffer_limitsz s. , #yAAC c$(!#& r c . | j j S r> )r rF rD s r rp z!SSLProtocol._get_read_buffer_size s ~~%%%r c . | j rJ d| _ y)z\Called when the low-level transport's buffer goes over
the high-water mark.
TN)r rD s r rA zSSLProtocol.pause_writing s ++++#' r c N | j sJ d| _ | j y)z^Called when the low-level transport's buffer drains below
the low-water mark.
FN)r r rD s r rC zSSLProtocol.resume_writing s' ''''#( r c f | j r| j j | t |t r5| j j rt
j d| |d y y t |t j s+| j j ||| j | d y y )Nz%r: %sT)exc_infor> ) r r rv OSErrorr0 r r r r CancelledErrorrB )r3 r r? s r r zSSLProtocol._fatal_error s ?? OO ( ( - c7 #zz##% XtWtD &C!:!:; JJ - -" !__ /
r )zFatal error on transport)/r r r r r r r r6 r? r r rG r r r r r r8 r r r r r rJ r r r r r r| r r r r) r* r r\ re r[ rU rX ri rh rp rA rC r r r r r r s H $ # 59&*'+&* Q"f 1 #L "2H%
!F$-P ;.%R *C
-8.A0! $A,#: #< B :@'( ) -' &
(!
r r )r enumr r ImportError r r r r logr SSLWantReadErrorSSLSyscallErrorr Enumr
r r$ r, _FlowControlMixin Transportr. r r r r r r` s
?**C,?,?@Ntyy
&tyy
& *r;J 8 8 & 0 0r;jZ
),, Z
{
Cs B0 0B:9B: