*j}| ~ S SK r S SKrS SKr S SKrSSKJr SSKJr SSKJr SSKJ r SSK
J r \b \R \R 4r " S S \R 5 r " S
S \R 5 rS rS
r " S S\ R( \ R* 5 r " S S\R. 5 rg! \ a Sr Nf = f) N ) constants)
exceptions) protocols)
transports)loggerc ( \ rS rSrSrSrSrSrSrSr g) SSLProtocolState UNWRAPPED DO_HANDSHAKEWRAPPEDFLUSHINGSHUTDOWN N)
__name__
__module__ __qualname____firstlineno__r r
r r r __static_attributes__r 7/opt/alt/python313/lib64/python3.13/asyncio/sslproto.pyr
r
s I!LGHHr r
c $ \ rS rSrSrSrSrSrSrg)AppProtocolState
STATE_INITSTATE_CON_MADE STATE_EOFSTATE_CON_LOSTr N) r r r r r r r r r r r r r r s J%NI%Nr r c p U ( a [ S5 e[ R " 5 nU( d SUl U$ )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 U c Uc US- nO
UnSU- nOU nUc US- nOUnX4s=: a S: d O [ SU< SU< S35 eX44$ )Ni r zhigh (z) must be >= low (z) must be >= 0)r! )highlowkbhilos r add_flowcontrol_defaultsr0 = sd | ;dBBRB
{
1W
=q= b" # # 6Mr c \ rS rSrSr\R R rS r S S jr
S r S r S r
S r\4S
jrS rS rS
rS S jrS rS rS S jrS rS r\S 5 rS r S r S r S r S r S r!S r"S r#g) _SSLProtocolTransportR Tc * Xl X l SU l g NF)_loop
_ssl_protocol_closed)selfloop ssl_protocols r __init__ _SSLProtocolTransport.__init__X s
) r Nc 8 U R R X5 $ N)r7 _get_extra_infor9 namedefaults r get_extra_info$_SSLProtocolTransport.get_extra_info] s !!11$@@r c : U R R U5 g r? )r7 _set_app_protocol)r9 protocols r set_protocol"_SSLProtocolTransport.set_protocola s ,,X6r c . U R R $ r? )r7
_app_protocolr9 s r get_protocol"_SSLProtocolTransport.get_protocold s !!///r c \ U R =( d U R R 5 $ r? )r8 r7 _is_transport_closingrM s r
is_closing _SSLProtocolTransport.is_closingg s ||It 1 1 G G IIr c x U R ( d" SU l U R R 5 g S U l g NT)r8 r7 _start_shutdownrM s r close_SSLProtocolTransport.closej s, || DL . . 0!%D r c b U R ( d SU l UR S[ 5 g g )NTz9unclosed transport )r8 warnResourceWarning)r9 _warningss r __del__ _SSLProtocolTransport.__del__x s) || DL NN*
, r c 8 U R R ( + $ r? )r7 _app_reading_pausedrM s r
is_reading _SSLProtocolTransport.is_reading s %%9999r c 8 U R R 5 g r? )r7 _pause_readingrM s r
pause_reading#_SSLProtocolTransport.pause_reading s
))+r c 8 U R R 5 g r? )r7 _resume_readingrM s r resume_reading$_SSLProtocolTransport.resume_reading s
**,r c n U R R X5 U R R 5 g r? )r7 _set_write_buffer_limits_control_app_writingr9 r+ r, s r set_write_buffer_limits-_SSLProtocolTransport.set_write_buffer_limits s* &
33D> //1r c Z U R R U R R 4$ r? )r7 _outgoing_low_water_outgoing_high_waterrM s r get_write_buffer_limits-_SSLProtocolTransport.get_write_buffer_limits * ""66""779 9r c 6 U R R 5 $ r? )r7 _get_write_buffer_sizerM s r get_write_buffer_size+_SSLProtocolTransport.get_write_buffer_size s !!88::r c n U R R X5 U R R 5 g r? )r7 _set_read_buffer_limits_control_ssl_readingrn s r set_read_buffer_limits,_SSLProtocolTransport.set_read_buffer_limits s* &
224= //1r c Z U R R U R R 4$ r? )r7 _incoming_low_water_incoming_high_waterrM s r get_read_buffer_limits,_SSLProtocolTransport.get_read_buffer_limits rv r c 6 U R R 5 $ r? )r7 _get_read_buffer_sizerM s r get_read_buffer_size*_SSLProtocolTransport.get_read_buffer_size s !!7799r c . U R R $ r? )r7 _app_writing_pausedrM s r _protocol_paused&_SSLProtocolTransport._protocol_paused s !!555r c [ U[ [ [ 45 ( d! [ S[ U5 R 35 eU( d g U R R U45 g )Nz+data: expecting a bytes-like instance, got )
isinstancebytes bytearray
memoryview TypeErrortyper r7 _write_appdatar9 datas r write_SSLProtocolTransport.write s[ $ : >?? ##':#6#6"7 9 :
: ))4'2r c : U R R U5 g r? )r7 r )r9 list_of_datas r
writelines _SSLProtocolTransport.writelines s
)),7r c [ er? )NotImplementedErrorrM s r write_eof _SSLProtocolTransport.write_eof s
"!r c gr5 r rM s r
can_write_eof#_SSLProtocolTransport.can_write_eof s r c & U R S 5 g r? ) _force_closerM s r abort_SSLProtocolTransport.abort s
$ r c d SU l U R b U R R U5 g g rU )r8 r7 _abortr9 excs r r "_SSLProtocolTransport._force_close s. ) % %c * *r c U R R R U5 U R =R [ U5 -
sl g r? )r7 _write_backlogappend_write_buffer_sizelenr s r _test__append_write_backlog1_SSLProtocolTransport._test__append_write_backlog s7 ))006 --T:-r )r8 r6 r7 r? NN)$r r r r _start_tls_compatibler
_SendfileModeFALLBACK_sendfile_compatibler< rD rI rN rR rW warningsr] ra re ri ro rt ry r~ r r propertyr r r r r r r r r r r r r2 r2 R s !$22;;
A70J & !) ,:,-2,9;2,9: 6 6 38" +
;r r2 c 4 \ rS rSrSrSrSrSr S-S jrS r S.S jr
S r S r S r
S
rS rS rS
rS.S jrS rS rS rS rS rS rS rS rS rS r S r S r S r S r S r!S r"S r#S r$S! r%S" r&S/S# jr'S$ r(S% r)S& r*S/S' jr+S( r,S) r-S* r.S0S+ jr/S,r0g)1 SSLProtocoli i Nc
[ c [ S5 e[ U R 5 U l [ U R 5 U l Uc [ R nOUS:: a [ SU 35 eU c [ R n OU S:: a [ SU 35 eU( d [ XV5 nXPl U( a U( d X`l
OS U l
X0l [ US9U l [" R$ " 5 U l SU l X@l Xl U R/ U5 S U l SU l S U l Xl Xl [ R: " 5 U l [ R: " 5 U l [@ RB U l" SU l# U( a [H RJ U l& O[H RN U l& U R RQ U R< U R> U R U R S9U l) SU l* SU l+ SU l, SU l- SU l. U R_ 5 SU l0 SU l1 SU l2 SU l3 U Ri 5 U Rk 5 g )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" RuntimeErrorr max_size _ssl_bufferr _ssl_buffer_viewr SSL_HANDSHAKE_TIMEOUTr! SSL_SHUTDOWN_TIMEOUTr( _server_side_server_hostname _sslcontextdict_extra collectionsdequer r _waiterr6 rG _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_pausedr` _ssl_reading_pausedr r r|
_eof_receivedr rs rr rl _get_app_transport)
r9 r: app_protocolr' waiterr% r& call_connection_madessl_handshake_timeoutssl_shutdown_timeouts
r r< SSLProtocol.__init__ s5
; @A A$T]]3 *4+;+; < ($-$C$C !
"a
' ,-/0
0 '#,#A#A
!Q
& +,./
/ 2.J ( ;$3 !$(D !% j1 * / / 1"#
|, "&+# &;#%9" &00 . 9 9DO . = =DO''00 NNDNN )) 1 1 1 3 $) #( #( $%!#$ $$& "#( $%!#$ %%' !r c Xl [ US5 ( aI [ U[ R 5 ( a* UR
U l UR U l SU l g SU l g )N
get_bufferTF)
rL hasattrr r BufferedProtocolr _app_protocol_get_bufferbuffer_updated _app_protocol_buffer_updated_app_protocol_is_buffer)r9 r s r rG SSLProtocol._set_app_protocola sT ) L, / /<)C)CDD,8,C,CD )0<0K0KD -+/D (+0D (r c U R c g U R R 5 ( d: Ub U R R U5 OU R R S 5 S U l g r? )r cancelled
set_exception
set_resultr s r _wakeup_waiterSSLProtocol._wakeup_waiterl sR << ||%%'' **3/ ''- r c U R c> U R ( a [ S5 e[ U R U 5 U l SU l U R $ )Nz$Creating _SSLProtocolTransport twiceT)r r r r2 r6 rM s r r SSLProtocol._get_app_transportv sJ &**"#IJJ"7
D"ID *.D '"""r c ` U R S L=( a U R R 5 $ r? )r rR rM s r rQ !SSLProtocol._is_transport_closing~ s# d*Kt/I/I/KKr c 0 Xl U R 5 g r? )r _start_handshake)r9 transports r connection_madeSSLProtocol.connection_made s
$ r c d U R R 5 U R R 5 U =R S-
sl U R
b SU R
l U R [ R :w a U R [ R :X d U R [ R :X aE [ R U l
U R R! U R" R$ U5 U R' [ R( 5 S U l S U l S U l U R- U5 U R. ( a! U R. R1 5 S U l U R2 ( a" U R2 R1 5 S U l g g )Nr T)r clearr readr r r8 r r
r
r r r r r r6 call_soonrL connection_lost
_set_stater r r _shutdown_timeout_handlecancel_handshake_timeout_handler s r r SSLProtocol.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 UnUS:: d X R : a U R n[ U R 5 U: a* [ U5 U l [ U R 5 U l U R
$ Nr )r r r r r r )r9 nwants r r SSLProtocol.get_buffer s^ 19}},==D t 4 ' (D $.t/?/?$@D !$$$r c U R R U R S U 5 U R [ R
:X a U R
5 g U R [ R :X a U R 5 g U R [ R :X a U R 5 g U R [ R :X a U R 5 g g r? )
r r r r r
r
_do_handshaker _do_readr _do_flushr _do_shutdown)r9 nbytess r r SSLProtocol.buffer_updated s T 2 27F ;< ;;*77 7
[[ , 4 4
4 MMO
[[ , 5 5
5 NN
[[ , 5 5
5 6r c SU l U R R 5 ( a [ R " SU 5 U R
[ R :X a U R [ 5 g U R
[ R :X aB U R [ R 5 U R ( a gU R 5 g U R
[ R :X a@ U R 5 U R [ R 5 U R# 5 g U R
[ R :X a U R# 5 g g ! [$ a U R& R) 5 e f = f)NTz%r received EOF)r r6 get_debugr debugr r
r
_on_handshake_completeConnectionResetErrorr r r r` r
_do_writer r Exceptionr rW rM s r eof_receivedSSLProtocol.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! 3AE! E! A E! 1.E! !&Fc XR ; a U R U $ U R b U R R X5 $ U$ r? )r r rD rA s r r@ SSLProtocol._get_extra_info s? ;; ;;t$ $
__
(??11$@ @Nr c @ SnU[ R :X a SnOU R [ R :X a U[ R :X a SnOU R [ R :X a U[ R :X a SnOiU R [ R :X a U[ R
:X a SnO4U R [ R
:X a U[ R :X a SnU( a Xl g [ SR U R U5 5 e)NFTz!cannot switch state from {} to {}) r
r r r
r r r r format)r9 new_statealloweds r r SSLProtocol._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 #K 3::KK,-
-r c U R R 5 ( a7 [ R " SU 5 U R R 5 U l OS U l U R
[ R 5 U R R U R U R 5 U l U R 5 g )Nz%r starts SSL handshake)r6 r r r time_handshake_start_timer r
r
call_laterr _check_handshake_timeoutr r rM s r r SSLProtocol._start_handshake s :: ! ! LL2D 9)- ):D &)-D & (556
JJ ! !$"="="&"?"?
A
&
r c U R [ R :X a+ SU R S3nU R [ U5 5 g g )Nz$SSL handshake is taking longer than z! seconds: aborting the connection)r r
r
r _fatal_errorConnectionAbortedError)r9 msgs r r% $SSLProtocol._check_handshake_timeout( sN ;;*77 76../ 0*+
4S 9 :
8r c U R R 5 U R S 5 g ! [ a U R 5 g [
R a nU R U5 S nAg S nAff = fr? )r do_handshaker SSLAgainErrors_process_outgoingr" SSLErrorr s r r SSLProtocol._do_handshake1 sb . LL % % '
' ' - % " " $|| - ' ' , , -s . A8
A8 A33A8c U R b! U R R 5 S U l U R n Uc U R [ R
5 OUeUR
5 nU R R 5 ( aA U R R! 5 U R" -
n[$ R& " SXS- 5 U R( R+ UUR- 5 UR/ 5 US9 U R0 [2 R4 :X a> [2 R6 U l U R8 R; U R= 5 5 U R 5 U R? 5 g ! [ aq nS nU R [ R 5 [ U[ R 5 ( a SnOSnU R XE5 U R U5 S nAg S nAff = f)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 r r" CertificateErrorr( r r6 r r" r# r r r updater4 r5 r r r r rL r r r )r9
handshake_excsslobjr3 r r* dts r r "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 344I, c ' $ s 5F
HA'G<<Hc U R [ R [ R [ R 4; a g U R
b SU R
l U R [ R :X a U R S 5 g U R [ R 5 U R R U R U R 5 U l U R 5 g rU )r r
r r r r r8 r
r r r6 r$ r _check_shutdown_timeoutr r
rM s r rV SSLProtocol._start_shutdownd s KK )) )) **
**.D ' ;;*77 7 KK OO , 5 5 6,0JJ,A,A**,,-D )
NN r c U R [ R [ R 4; a0 U R R [ R " S5 5 g g )NzSSL shutdown timed out)r r
r r r r r TimeoutErrorrM s r r? #SSLProtocol._check_shutdown_timeouty sN KK )) ))
OO ( (''(@A
C
r c U R 5 U R [ R 5 U R 5 g r? )r r r
r r rM s r r
SSLProtocol._do_flush s*
(112 r c X U R ( d U R R 5 U R 5 U R 5 U R S 5 g ! [ a U R 5 g [ R a nU R U5 S nAg S nAff = fr? ) r r unwrapr/ _call_eof_received_on_shutdown_completer. r" r0 r s r r SSLProtocol._do_shutdown s
-%% ##%
" " $ # # % & &t , % " " $|| , & &s + + ,s +A B);B)B$$B)c U R b! U R R 5 S U l U( a U R U5 g U R R U R
R 5 g r? )r r r( r6 r r rW )r9 shutdown_excs r rI !SSLProtocol._on_shutdown_complete sU ( ( 4 ) ) 0 0 2,0D ) l + JJ !6!6 7r c U R [ R 5 U R b U R R U5 g g r? )r r
r r r r s r r SSLProtocol._abort s6 (223 ?? & OO ( ( - 'r c H U R [ R [ R [ R 4; aJ U R
[ R : a [ R " S5 U =R
S-
sl g U H< nU R R U5 U =R [ U5 -
sl M> U R [ R :X a U R 5 g g ! [ a nU R# US5 S nAg S nAff = f)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( )r9 r r exs r r SSLProtocol._write_appdata s KK )) )) **
)"M"MM 9: OOq O D & &t , # #s4y 0 # ! A{{ . 6 66 7 A b"? @ @ As .C; ;
D!D D!c U R ( a U R S nU R R U5 n[ U5 nX#: a' XS U R S' U =R U- sl O"U R S U =R U- sl U R ( a M U R
5 g ! [
a N f = fr )r r r r r r. r/ )r9 r countdata_lens r r SSLProtocol._do_write s %%**1- **40 t9#-1&\D''*++u4+ ++A.++x7+ %%%
s B%B: :
CCc U R ( dE U R R 5 n[ U5 ( a U R R U5 U R
5 g r? )r r r r r r rm r s r r/ SSLProtocol._process_outgoing sD ''>>&&(D4yy%%d+ !!#r c U R [ R [ R 4; a g U R ( dd U R
( a U R
5 OU R 5 U R ( a U R 5 OU R 5 U R 5 g ! [ a nU R US5 S nAg S nAff = f)NrQ )r r
r r r` r _do_read__buffered_do_read__copiedr r r/ r} r r( )r9 rT s r r SSLProtocol._do_read s KK (( ))
A++//++-))+&&NN$**, % % ' A b"? @ @ As BB7 7
C CC c SnSnU R U R 5 5 n[ U5 n U R R XC5 nUS: a_ UnX: a3 U R R XA-
X1S 5 nUS: a X-
nOO,X: a M3 U R
R
U R 5 US: a U R U5 U( d! U R 5 U R 5 g g ! [ a NLf = f)Nr r ) r r r r r r6 r r r. r rH rV )r9 offsetrW bufwantss r r] SSLProtocol._do_read__buffered s ++D,F,F,HIC LL%%e1Eqy n LL - -enc'l KE qy n JJ(( 7 A: - -f 5 # # % " s AC0 C0 %C0 0
C=<C=c SnSnSn U R R U R 5 nU( d O/U( a SnSnUnO U( a SnWU/nOWR U5 M\ U( a U R
R
W5 O1U( d* U R
R
SR W5 5 U( d! U R 5 U R 5 g g ! [ a Nf = f)N 1TFr )
r r r r r. rL
data_receivedjoinrH rV )r9 chunkzeroonefirstr s r r^ SSLProtocol._do_read__copied
s ))$--8 D C !E C !5>DKK& , ,U 3 , ,SXXd^ < # # % "
s -C" /C" "
C/.C/c P U R [ R :X aN [ R U l U R R 5 nU( a [ R " S5 g g g ! [ [ 4 a e [ a nU R US5 S nAg S nAff = f)Nz?returning true from eof_received() has no effect when using sslz Error calling eof_received()) r r r r rL r r rS KeyboardInterrupt
SystemExit
BaseExceptionr( )r9 keep_openrT s r rH SSLProtocol._call_eof_received( s
B"2"A"AA"2"<"< . . ; ; = NN $B C B ":. B b"@ A A Bs A*A/ /B% B B%c v U R 5 nXR : a4 U R ( d# SU l U R R 5 g XR :: a5 U R ( a# SU l U R R 5 g g g ! [
[ 4 a e [ a4 nU R R SUU R U S.5 S nAg S nAff = f! [
[ 4 a e [ a4 nU R R SUU R U S.5 S nAg S nAff = f)NTz protocol.pause_writing() failedmessage exceptionr rH Fz protocol.resume_writing() failed)
rx rs r rL
pause_writingro rp rq r6 call_exception_handlerr rr resume_writing)r9 sizer s r rm SSLProtocol._control_app_writing7 s **, ,, ,T5M5M'+D $
""002 --
-$2J2J',D $
""113 3K
- &z2
11 @!$!%!4!4 $ 3
&z2
11 A!$!%!4!4 $ 3
s/ B <C* C'3*C""C'*D8*D33D8c H U R R U R - $ r? )r pendingr rM s r rx "SSLProtocol._get_write_buffer_sizeT s ~~%%(?(???r c T [ X[ R 5 u pXl X l g r? )r0 r !FLOW_CONTROL_HIGH_WATER_SSL_WRITErs rr rn s r rl $SSLProtocol._set_write_buffer_limitsW s& , yBBD $(!#& r c SU l g rU )r` rM s r rd SSLProtocol._pause_reading_ s
#' r c z ^ T R ( a) ST l U 4S jnT R R U5 g g )NFc > T R [ R :X a T R 5 g T R [ R :X a T R 5 g T R [ R :X a T R 5 g g r? )r r
r r r r
r r rM s r resume+SSLProtocol._resume_reading..resumef s` ;;"2":"::MMO[[$4$=$==NN$[[$4$=$==%%' >r )r` r6 r )r9 r s ` r rh SSLProtocol._resume_readingb s2 # #',D $
(
JJ ( $r c . U R 5 nXR : a3 U R ( d" SU l U R R 5 g XR
:: a4 U R ( a" SU l U R R
5 g g g )NTF)r r r r re r ri )r9 r{ s r r} SSLProtocol._control_ssl_readingq sq ))+ ,, ,T5M5M'+D $ OO ) ) +
--
-$2J2J',D $ OO * * , 3K
-r c T [ X[ R 5 u pXl X l g r? )r0 r FLOW_CONTROL_HIGH_WATER_SSL_READr r rn s r r| #SSLProtocol._set_read_buffer_limitsz s& , yAAC $(!#& r c . U R R $ r? )r r~ rM s r r !SSLProtocol._get_read_buffer_size s ~~%%%r c SU l g rU )r rM s r rx SSLProtocol.pause_writing s
$( r c 2 SU l U R 5 g r5 )r r/ rM s r rz SSLProtocol.resume_writing s
$) r c U R ( a U R R U5 [ U[ 5 ( a7 U R R 5 ( a [ R " SXSS9 g g [ U[ R 5 ( d+ U R R UUU R U S.5 g g )Nz%r: %sT)exc_inforu ) r r r OSErrorr6 r r r r CancelledErrorry )r9 r rv s r r( SSLProtocol._fatal_error s ?? OO ( ( - c7 # #zz##%% XttD &C!:!:;; JJ - -" !__ /
r s
?**C,?,?@Ntyy
&tyy
& *r;J 8 8 & 0 0r;jZ
),, Z
{
Cs B1 1B<;B<