cj r 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 7/opt/alt/python311/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 : | j || S N)r2 _get_extra_infor4 namedefaults r get_extra_infoz$_SSLProtocolTransport.get_extra_info] s 1!11$@@@r c : | j | d S r9 )r2 _set_app_protocol)r4 protocols r set_protocolz"_SSLProtocolTransport.set_protocola s ,,X66666r c | j j S r9 )r2
_app_protocolr4 s r get_protocolz"_SSLProtocolTransport.get_protocold s !//r c | j S r9 )r3 rE s r
is_closingz _SSLProtocolTransport.is_closingg s
|r c h | j s"d| _ | j d S d | _ d S NT)r3 r2 _start_shutdownrE s r closez_SSLProtocolTransport.closej sC | & DL . . 0 0 0 0 0!%D r c \ | j s$d| _ | dt d S d S )NTz9unclosed transport )r3 warnResourceWarning)r4 _warningss r __del__z _SSLProtocolTransport.__del__x sE | , DL NN*
,
,
,
,
, , ,r c | j j S r9 )r2 _app_reading_pausedrE s r
is_readingz _SSLProtocolTransport.is_reading s %999r c : | j d S r9 )r2 _pause_readingrE s r
pause_readingz#_SSLProtocolTransport.pause_reading s$
))+++++r c : | j d S r9 )r2 _resume_readingrE s r resume_readingz$_SSLProtocolTransport.resume_reading s$
**,,,,,r c p | j || | j d S r9 )r2 _set_write_buffer_limits_control_app_writingr4 r' r( s r set_write_buffer_limitsz-_SSLProtocolTransport.set_write_buffer_limits s= $
33D#>>> //11111r c 2 | j j | j j fS r9 )r2 _outgoing_low_water_outgoing_high_waterrE s r get_write_buffer_limitsz-_SSLProtocolTransport.get_write_buffer_limits "6"79 9r c 6 | j S r9 )r2 _get_write_buffer_sizerE s r get_write_buffer_sizez+_SSLProtocolTransport.get_write_buffer_size s ;!88:::r c p | j || | j d S r9 )r2 _set_read_buffer_limits_control_ssl_readingr^ s r set_read_buffer_limitsz,_SSLProtocolTransport.set_read_buffer_limits s= $
224=== //11111r c 2 | j j | j j fS r9 )r2 _incoming_low_water_incoming_high_waterrE s r get_read_buffer_limitsz,_SSLProtocolTransport.get_read_buffer_limits rd r c 6 | j S r9 )r2 _get_read_buffer_sizerE s r get_read_buffer_sizez*_SSLProtocolTransport.get_read_buffer_size s 9!77999r c | j j S r9 )r2 _app_writing_pausedrE s r _protocol_pausedz&_SSLProtocolTransport._protocol_paused s !55r c t |t t t f s$t dt | j |sd S | j |f d S )Nz+data: expecting a bytes-like instance, got )
isinstancebytes bytearray
memoryview TypeErrortyper r2 _write_appdatar4 datas r writez_SSLProtocolTransport.write s{
$ : >?? : 9#'::#6 9 9 : :
: F ))4'22222r c < | j | d S r9 )r2 r} )r4 list_of_datas r
writelinesz _SSLProtocolTransport.writelines s&
)),77777r c t r9 )NotImplementedErrorrE s r write_eofz _SSLProtocolTransport.write_eof s "!r c dS r0 r rE s r
can_write_eofz#_SSLProtocolTransport.can_write_eof s
Our c 2 | d d S r9 ) _force_closerE s r abortz_SSLProtocolTransport.abort s#
$ r c Z d| _ | j | j | d S d S rJ )r3 r2 _abortr4 excs r r z"_SSLProtocolTransport._force_close s7 ) % %c * * * * * * )r c | j j | | j xj t | z
c_ d S r9 )r2 _write_backlogappend_write_buffer_sizelenr~ s r _test__append_write_backlogz1_SSLProtocolTransport._test__append_write_backlog s? )00666 --T:----r r9 NN)"r r r _start_tls_compatibler
_SendfileModeFALLBACK_sendfile_compatibler7 r> rB rF rH rL warningsrQ rT rW rZ r_ rc rg rk ro rr propertyru 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 RuntimeErrorry max_size _ssl_bufferrz _ssl_buffer_viewr SSL_HANDSHAKE_TIMEOUTr SSL_SHUTDOWN_TIMEOUTr$ _server_side_server_hostname _sslcontextdict_extra collectionsdequer r _waiterr1 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_pausedrS _ssl_reading_pausedrn rm ri
_eof_receivedrt rb ra r\ _get_app_transport)
r4 r5 app_protocolr# waiterr! r" call_connection_madessl_handshake_timeoutssl_shutdown_timeouts
r r7 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)
rD hasattrrw r BufferedProtocolr _app_protocol_get_bufferbuffer_updated _app_protocol_buffer_updated_app_protocol_is_buffer)r4 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 r9 )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. r1 rE s r r z SSLProtocol._get_app_transportv sK &*
K"#IJJJ"7
D"I"ID *.D '""r c > || _ | d S r9 )r _start_handshake)r4 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 | _ d S d S )Nr T)r clearr readr r r3 r r
r r r r r r r1 call_soonrD connection_lost
_set_stater r r _shutdown_timeout_handlecancel_handshake_timeout_handler s r r zSSLProtocol.connection_lost sT
!!### 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 ry rz r )r4 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 r9 )
r r r r r
r
_do_handshaker
_do_readr _do_flushr _do_shutdown)r4 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 d S | j t j
k r>| t j | j
rdS | d S | j t j k rI| | t j | d S | j t j k r| d S d S # t$ $ r | j w xY w)NTz%r received EOF)r r1 get_debugr debugr r
r _on_handshake_completeConnectionResetErrorr
r r rS r _do_writer r Exceptionr rL rE s r eof_receivedzSSLProtocol.eof_received sl " z##%%
6 .555{ . ;;;++,@AAAAA 0 888 0 9:::+ % 4NN$$$$$ 0 999 0 9:::!!##### 0 999!!##### :9 O ! ! # # # s% A E );E &E r; s r r: 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)r4 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 r9 )_check_handshake_timeoutrE s r z.SSLProtocol._start_handshake..! s $*G*G*I*I r )
r1 r r r time_handshake_start_timer r
r
call_laterr r r rE 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)r4 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 wr9 )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 rw r CertificateErrorr r r1 r r r r r r updater r r r r r rD r r r )r4
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 r9 )_check_shutdown_timeoutrE s r r z-SSLProtocol._start_shutdown..r s 4466 r )r r
r r r r r3 r r r r1 r r r r rE s `r rK 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 TimeoutErrorrE s r r z#SSLProtocol._check_shutdown_timeoutv sf K ) )
O ( ('(@AA
C
C
C
C
C
r c | | t j | d S r9 )r r r
r r rE 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 wr9 ) 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 r9 )r r r r1 r r rL )r4 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 r9 )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 )r4 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 )r4 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 r9 )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 rS r _do_read__buffered_do_read__copiedr r r rj r r )r4 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 r9 )r rE s r r z0SSLProtocol._do_read__buffered.. s r ) r rq r r r r1 r r r r rK )r4 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 rD
data_receivedjoinr rK )r4 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 rD r r r! KeyboardInterrupt
SystemExit
BaseExceptionr )r4 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 rA Fz protocol.resume_writing() failed)
rf rb rt rD
pause_writingr8 r9 r: r1 call_exception_handlerr ra resume_writing)r4 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 r9 )r pendingr rE s r rf z"SSLProtocol._get_write_buffer_sizeQ s ~%(???r c ^ t ||t j \ }}|| _ || _ d S r9 )r, r !FLOW_CONTROL_HIGH_WATER_SSL_WRITErb ra r^ s r r\ z$SSLProtocol._set_write_buffer_limitsT s7 , #yBD D c$(!#& r c d| _ d S rJ )rS rE s r rV 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 r9 )r r
r
r r r r r rE s r resumez+SSLProtocol._resume_reading..resumec s} ;"2":::MMOOOOO[$4$===NN$$$$$[$4$===%%''''' >=r )rS r1 r )r4 rK s ` r rY 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)rq rn r r rW rm rZ )r4 rC s r rj z SSLProtocol._control_ssl_readingn s ))++ 4, , ,T5M ,'+D $ O ) ) + + + + +
T-
-
-$2J
-',D $ O * * , , , , , .
-
-
-r c ^ t ||t j \ }}|| _ || _ d S r9 )r, r FLOW_CONTROL_HIGH_WATER_SSL_READrn rm r^ s r ri z#SSLProtocol._set_read_buffer_limitsw s7 , #yAC C c$(!#& r c | j j S r9 )r rE rE s r rq z!SSLProtocol._get_read_buffer_size} s
~%%r c d| _ d S rJ )r rE s r r@ zSSLProtocol.pause_writing s $( r c > d| _ | d S r0 )r r rE s r rB 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 rw OSErrorr1 r r r r CancelledErrorrA )r4 r r> s r r zSSLProtocol._fatal_error s ? . O ( ( - - - c7 # # z##%%
E XtWtDDDDDD
E
EC!:;; J - -" !_ / /
r )FNTNNr9 r )rR ).r r r r r r r r7 r@ r r r r r r r r: r r r r r rK r r r r r r} r r r r( r) r r] rf r\ rV rY rj ri rq r@ rB 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 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