/var/opt/nydus/ops/mysql/connector/__pycache__
Edit: /var/opt/nydus/ops/mysql/connector/__pycache__/network.cpython-312.pyc (31944B)
N ju d Z ddlZddlZddlZddlZddlmZmZ ddlm Z ddl
m Z m Z m
Z
mZmZmZ ddlZej$ ej& ej( ej* dZ eed xr ej0 Zd d
lm Z m Z m Z m Z m Z m!Z!m"Z" d Z#d Z$d
Z%dZ&de'de(fdZ) G d de Z* G d de* Z+ G d de+ Z, G d de Z- G d de- Z. G d d e- Z/y# e$ r dZdZY pw xY w) zFModule implementing low-level socket communication with MySQL servers. N)ABCabstractmethod)deque)AnyDequeListOptionalTupleUnion)TLSv1TLSv1.1TLSv1.2TLSv1.3 HAS_TLSv1_3F )ConnectionTimeoutErrorInterfaceErrorNotSupportedErrorOperationalErrorProgrammingErrorReadTimeoutErrorWriteTimeoutError2 i errreturnc h | j s t | S d| j d| j S )z`Reformat the IOError error message.
This function reformats the IOError error message.
zErrno z: )errnostrstrerror)r s H/opt/nydus/tmp/pip-target-a90h98xg/lib/python/mysql/connector/network.py _strioerrorr# I s.
993s8NF399+R ~*NN c e Zd ZdZe d dej
dededee dee ddf d Z
edej
dede fd
Z y)
NetworkBrokeraP Broker class interface.
The network object is a broker used as a delegate by a socket object. Whenever the
socket wants to deliver or get packets to or from the MySQL server it needs to rely
on its network broker (netbroker).
The netbroker sends `payloads` and receives `packets`.
A packet is a bytes sequence, it has a header and body (referred to as payload).
The first `PACKET_HEADER_LENGTH` or `COMPRESSED_PACKET_HEADER_LENGTH`
(as appropriate) bytes correspond to the `header`, the remaining ones represent the
`payload`.
The maximum payload length allowed to be sent per packet to the server is
`MAX_PAYLOAD_LENGTH`. When `send` is called with a payload whose length is greater
than `MAX_PAYLOAD_LENGTH` the netbroker breaks it down into packets, so the caller
of `send` can provide payloads of arbitrary length.
Finally, data received by the netbroker comes directly from the server, expect to
get a packet for each call to `recv`. The received packet contains a header and
payload, the latter respecting `MAX_PAYLOAD_LENGTH`.
Nsockaddresspayload
packet_numbercompressed_packet_numberr c y)a Send `payload` to the MySQL server.
If provided a payload whose length is greater than `MAX_PAYLOAD_LENGTH`, it is
broken down into packets.
Args:
sock: Object holding the socket connection.
address: Socket's location.
payload: Packet's body to send.
packet_number: Sequence id (packet ID) to attach to the header when sending
plain packets.
compressed_packet_number: Same as `packet_number` but used when sending
compressed packets.
Raises:
:class:`OperationalError`: If something goes wrong while sending packets to
the MySQL server.
N )selfr' r( r) r* r+ s r" sendzNetworkBroker.sendi r$ c y)a) Get the next available packet from the MySQL server.
Args:
sock: Object holding the socket connection.
address: Socket's location.
Returns:
packet: A packet from the MySQL server.
Raises:
:class:`OperationalError`: If something goes wrong while receiving packets
from the MySQL server.
:class:`InterfaceError`: If something goes wrong while receiving packets
from the MySQL server.
Nr- )r. r' r( s r" recvzNetworkBroker.recv r0 r$ NN)
__name__
__module__ __qualname____doc__r socketr bytesr intr/ bytearrayr2 r- r$ r" r& r& Q s . (,26
mm
} #+3-
6 r$ r& c
e Zd ZdZddZddZdej dededdfd Z ddej d
e
de fd Z ddej ded ed
e
e
de
e
ddf dZdej dede fdZy)NetworkBrokerPlain,Broker class for MySQL socket communication.r Nc d| _ y N_pktnrr. s r" __init__zNetworkBrokerPlain.__init__ s r$ c 2 | j dz dz | _ yzIncrement packet id.r NrB rD s r" _set_next_pktnrz"NetworkBrokerPlain._set_next_pktnr s {{Q#- r$ r' r( pktc |j | y# t j t f$ r}t d |d}~wt
$ r }t
d|t | f |d}~wt $ r}t
d |d}~ww xY w)z!Write packet to the comm channel. r N r valuesi ) sendallr8 timeout TimeoutErrorr IOErrorr r# AttributeError)r. r' r( rJ r s r" _send_pktz NetworkBrokerPlain._send_pkt sy 8 LL - 9#$/S 8 "G[-=#>
8".C 7 8s* A=
: A=A A=+
A88A=sizec t | }t | }|r5|j || }|dk( r|dkD r t d ||d }||z }|r5|S )z(Read `size` bytes from the comm channel.r i rM N)r;
memoryview recv_intor )r. r' rW rJ pkt_viewreads r" _recv_chunkz NetworkBrokerPlain._recv_chunk s_ o c?>>(D1DqyTAX$400 H DLD
r$ r) r* r+ c
|| j n|| _ t | t k\ rd}t t | t z D ]\ }| j ||dt
j d| j z |||t z z | j |t z
}^ ||d }| j ||t
j dt | dd t
j d| j z |z y)zSend payload to the MySQL server.
If provided a payload whose length is greater than `MAX_PAYLOAD_LENGTH`, it is
broken down into packets.
Nr
# kk$ 45 fv0B'BCD $$&,, ? fg&G KKc'l +Aa 0kk$ ,
-
r$ c n | j |t }t j d|dd dz d |d c}| _ || j || z S # t
j t f$ r }t d|j |d}~wt $ r }t d |t | f
|d}~ww xY w) z+Receive `one` packet from the MySQL server.rW ra r rb rL )r msgNrN rO )
r] PACKET_HEADER_LENGTHrf unpackrC r8 rR rS r r! rT r r# )r. r' r( header payload_lenr s r" r2 zNetworkBrokerPlain.recv s %%d1E%FF
dF1QK'$9:1=q
%K D , ,T , DD D - J"3<<@c I "G[-=#>
s$ AA B42B
B4B//B4r N)r r3 )r4 r5 r6 r7 rE rI r8 r r9 rV r: r; r] r r/ r2 r- r$ r" r= r= s 6 . 8fmm 8c 8 8$ 8
S
" (,26
*
mm*
*
*
} *
#+3-
*
*
X r$ r= c
& e Zd ZdZd fd Zedededee fd Z ddZ
d e j d
e d eddf fd Z
dd e j d
e ded
ee dee ddf fd
Zd e j dededdf fd Zd e j d
e def fd Z xZS )NetworkBrokerCompressedr> r Nc N t | d| _ t | _ y r@ )superrE _compressed_pktnrr _queue_read)r. __class__s r" rE z NetworkBrokerCompressed.__init__ s
!# -2Wr$ r) pktnrc g }t | t k\ rmd}t t | t z D ]H }|j dt j
d| z | ||t z z |dz dz }|t z
}J | |d } |j t j
dt | dd t j
d| z | z |S ) z2Prepare a payload for sending to the MySQL server.r r_ r` r rH Nra rb )rc rd re appendrf rg )r) rz pktsrh ri s r" _prepare_packetsz(NetworkBrokerCompressed._prepare_packets s w<- -F3w<+==> # kk$./ fv0B'BCD
c),, ? fg&G KKc'l +Aa 06;;tU3K Kg U
r$ c 2 | j dz dz | _ yrG )rw rD s r" _set_next_compressed_pktnrz2NetworkBrokerCompressed._set_next_compressed_pktnr s "&"8"81"<!C r$ r' r( rJ c " t j | }t j dt | dd t j d| j
z t j dt | dd z |z }t | ||| S )z1Compress packet and write it to the comm channel.ra r rb r` )zlibcompressrf rg rc rw rv rV )r. r' r( rJ compressed_pktry s r" rV z!NetworkBrokerCompressed._send_pkt# s s+ KKc. 1 21Q 7kk$ 6 67
8kk$C)!A.
/
w w44r$ r* r+ c
|| j n|| _ || j n|| _ t d j | j
|| j }t | t t z
k\ rod}t t | t z D ]8 }| j |||||t z | j |t z
}: | j ||||d yt | t kD r| j ||| yt | - ||t j dt | dd t j d| j z t j dd dd z |z y)zSend `payload` as compressed packets to the MySQL server.
If provided a payload whose length is greater than `MAX_PAYLOAD_LENGTH`, it is
broken down into packets.
Nr$ r ra rb r` )rI rC r rw r; joinr~ rc rd rn re rV MIN_COMPRESS_LENGTHrv rf rg )
r. r' r( r) r* r+ payload_preprh ri ry s
r" r/ z NetworkBrokerCompressed.send. sr "'DK # + + + -%=D " ~**4+@+@$+++VW w<-0DD D F 3|,0BBC'<BT9T#U //1,, D
NN4,vw*? @ 7| 11tWl; !KKc,&781= kk$(>(>?@ kk$*1Q/0 ##r$ compressed_plluncompressed_pllc t | || }|dk( r|n t t j | }d}|t | k rt
j d|||t z dz
dz d }t |z t | |z
kD rt | |t }t
j d|dd dz d |d t
j d|dd dz d c}| _
}t | || }||dk( r|nt j | z
}| j j |||t z |z |t |z z
}|t | k ry y )
z&Handle reading of a compressed packet.rk r ra r rl rb r r N)
rv r] r; r
decompressrc rf ro rn COMPRESSED_PACKET_HEADER_LENGTHrw rx r| )
r. r' r r r rJ rh pllrp ry s
r" _recv_compressed_pktz,NetworkBrokerCompressed._recv_compressed_pktk s ,T,G 1$
4??>:; s3x --c&6,@#@1#DEOC $c)CHv,== ,T8W,X MM$q g(=>qA1IMM$q g(=>qA "*$ "'!4T!4!O '1, # 8
# #C:N1NQT1T$U V *S0 0F? s3x r$ c | j ss t | |t }t j
d|dd dz d |d t j
d|dd dz d c}| _ }| j ||| | j sy
| j j }|d | _ |S # t j t f$ r}t d |d
}~wt $ r }t d |t | f |d
}~ww xY w)
z{Receive `one` or `several` packets from the MySQL server, enqueue them, and
return the packet at the head.
rk ra r rb rl r r rL rM NrN rO )rx rv r] r rf ro rw r r8 rR rS r rT r r# popleftrC ) r. r' r( rp r r r rJ ry s r" r2 z NetworkBrokerCompressed.recv s
,T8W,X MM$q g(=>qA1IMM$q g(=>qA "*$ ))$@PQ &&(!f
NNL1
<&T2;
& S1A'B
s$ A2B4 4D
C D&C??Drr r3 )r4 r5 r6 r7 rE staticmethodr9 r: r r~ r r8 r rV r r/ r r; r2
__classcell__ry s @r" rt rt s 65
% U 2D 5fmm 5c 5 5$ 5 (,26
;mm; ; ;
} ; #+3-
;
;z.1MM.136.1JM.1
.1`! ! ! ! !r$ rt c P e Zd ZdZd dZd dZd dZd dZd dZd e e
ddfd
Z d e d e
ddfd
Z d de e
de e
de e
de e de e de ee
de ee
de fdZ d!dede e
de e
de e
ddf
dZd"de e
defd Zed d Zeede
fd Zy)# MySQLSocketzMySQL socket communication interface.
Examples:
Subclasses: network.MySQLTCPSocket and network.MySQLUnixSocket.
r Nc L d| _ d| _ d| _ t | _ y)zsNetwork layer where transactions are made with plain (uncompressed) packets
is enabled by default.
N)r' _connection_timeout server_hostr=
_netbrokerrD s r" rE zMySQLSocket.__init__ s%
.2 26 *.);)=r$ c " t | _ y)zIEnable network layer where transactions are made with compressed packets.N)rt r rD s r" switch_to_compressed_modez%MySQLSocket.switch_to_compressed_mode s 13r$ c | j j t j | j j y# t
t f$ r Y yw xY w)z'Shut down the socket before closing it.N)r' shutdownr8 SHUT_RDWRcloserU OSErrorrD s r" r zMySQLSocket.shutdown sD II v / / 0 IIOO ( s AA AAc d | j j y# t t f$ r Y yw xY w)zClose the socket.N)r' r rU r rD s r" close_connectionz MySQLSocket.close_connection s, IIOO ( s //c $ | j y N)r rD s r" __del__zMySQLSocket.__del__ s
r$ rR c b || _ | j r | j j | yy)zSet the connection timeout.N)r r'
settimeout)r. rR s r" set_connection_timeoutz"MySQLSocket.set_connection_timeout s( #* 99 II ) r$ ssl_contexthostc | j J | j j dk( r t d t t d |j | j | | _ y# t $ r}t d |d}~wt j t f$ r(}t d| j t | f |d}~wt j $ r}t t | |d}~wt $ r}t t | |d}~ww xY w)a Upgrade an existing connection to TLS.
Args:
ssl_context (ssl.SSLContext): The SSL Context to be used.
host (str): Server host name.
Returns:
None.
Raises:
ProgrammingError: If the transport does not expose the socket instance.
NotSupportedError: If Python installation has no SSL support.
Nr z,SSL is not supported when using Unix sockets&Python installation has no SSL support)server_hostnamerN rO )r' familyr sslr wrap_socket NameErrorSSLErrorrT r r( r# CertificateErrorr NotImplementedError)r. r r r s r"
switch_to_sslzMySQLSocket.switch_to_ssl s yy$$$ 99 q "#QR R ;#$LM M 4#// 4/PDI W#$LMSV V g& DLL+c2B#C
## 4 S* 3" 4 S* 3 4s< "A( ( D
1 A== D
#B<<D
C'' D
3DD
ssl_cassl_certssl_keyssl_verify_certssl_verify_identity tls_versionstls_cipher_suitesc d}| j s t d t t d |g }|g } |r|j d |d }t
| } t j | }
|dk( rd |vr#|
xj t j z c_ d
|vr#|
xj t j z c_ d |vr8|
xj t j z c_ nt j }
||
_ |rt j |
_ n-|rt j |
_ nt j |
_ |
j# |r |
j% | |r |
j+ || |r%|d k( r |
j- dj/ | |
S # t& t j( f$ r} t d | | d} ~ ww xY w# t& t j( f$ r} t d
| | d} ~ ww xY w# t0 $ r} t d | d} ~ wt& t2 t j4 t j( f$ r} t t7 | | d} ~ ww xY w)a Build a SSLContext.
Args:
ssl_ca: Certificate authority, opptional.
ssl_cert: SSL certificate, optional.
ssl_key: Private key, optional.
ssl_verify_cert: Verify the SSL certificate if `True`.
ssl_verify_identity: Verify host identity if `True`.
tls_versions: TLS protocol versions, optional.
tls_cipher_suites: Set of steps that helps to establish a secure connection.
Returns:
ssl_context (ssl.SSLContext): An SSL Context ready be used.
Raises:
NotSupportedError: Python installation has no SSL support.
InterfaceError: Socket undefined or invalid ssl data.
Ni rM r T)reverser r r r
r zInvalid CA Certificate: zInvalid Certificate/Key: :) r' r r r sort TLS_VERSIONS
SSLContextoptions
OP_NO_TLSv1_2
OP_NO_TLSv1_1 OP_NO_TLSv1create_default_contextcheck_hostname
CERT_REQUIRED verify_mode
CERT_OPTIONAL CERT_NONEload_default_certsload_verify_locationsrT r load_cert_chain set_ciphersr r r r r ) r. r r r r r r r tls_version ssl_protocolcontextr s r" build_ssl_contextz MySQLSocket.build_ssl_context s> 8 &* yy t, , ;#$LM M L $ " 6 4 !!$!/ *1o +K 8 .. 6 )+ 4 3+<+<< 4 3+<+<< l2 3??: 446%8G " &)&7&7#$&)&7&7#&)mm# & & (T11&9 U++Hg> ![I%=##CHH->$?@N . T(+CC5)IJPSST
. U(+DSE)JKQTTU W#$LMSV V LL
4 !S* 3
4sl D$H F) +H .G (H )GGGH H2HHH I( H 0I(I##I(r) r* r+
write_timeoutc | j s4| j (| j j |r t | nd | j
j
| j | j ||| y# t $ r
}Y d}~Cd}~ww xY w)at Send `payload` to the MySQL server.
NOTE: if `payload` is an instance of `bytearray`, then `payload` might be
changed by this method - `bytearray` is similar to passing a variable by
reference.
If you're sure you won't read `payload` after invoking `send()`,
then you can use `bytearray.` Otherwise, you must use `bytes`.
N)r* r+ )r r' r floatr r r/ r( )r. r) r* r+ r ri s r" r/ zMySQLSocket.sendr sz ,,1F $$]U=%9PTU
II LL '%=
s A A7 7 B
B
read_timeoutc | j s4| j (| j j |r t | nd | j
j
| j | j S # t $ r
}Y d}~>d}~ww xY w)z.Get packet from the MySQL server comm channel.N)r r' r r r r r2 r( )r. r ri s r" r2 zMySQLSocket.recv sj ,,1F $$LU<%8dS ##DIIt||<< s A A2 2 B Bc y)zOpen the socket.Nr- rD s r" open_connectionzMySQLSocket.open_connection r0 r$ c y)z Get the location of the socket.Nr- rD s r" r( zMySQLSocket.address r0 r$ rr )NNNFFNN)NNNr )r4 r5 r6 r7 rE r r r r r r: r r r r boolr r r9 r/ r; r2 r r propertyr( r- r$ r" r r s >4*hsm * * "4 "4C "4D "4L !%"&!%*/.3,015`4
`4 3-`4 # `4
"$ `4 &d^
`4 tCy)`4 $DI.`4
`4J (,26'+
}
#+3-
}
@
=#
=)
= . . .r$ r c ` e Zd ZdZd deddf fd
Zedefd Zd dZde d e ddfd
Z
xZ S )
MySQLUnixSocketzpMySQL socket class using UNIX sockets.
Opens a connection through the UNIX socket of the MySQL Server.
unix_socketr Nc > t | || _ || _ y r )rv rE r _address)r. r ry s r" rE zMySQLUnixSocket.__init__ s
+ (
r$ c | j S r r rD s r" r( zMySQLUnixSocket.address }} r$ c 0 t j t j t j | _ | j j | j
| j j
| j y # t j t f$ r(}t d| j t | f |d }~wt $ r(}t d| j t | f |d }~wt $ r}t t! | |d }~ww xY w)Ni rO )r8 AF_UNIX SOCK_STREAMr' r r connectr rR rS r r( r# rT r Exceptionr )r. r s r" r z MySQLUnixSocket.open_connection s 4
""DI
II !9!9 : II d . . / - (LL $
DLL+c2B#C
4 S* 3 4s0 BB D #C D #C// D;DDargskwargsc 8 t j dt y)z Switch the socket to use SSL.z2SSL is disabled when using unix socket connectionsN)warningswarnWarning)r. r r s r" r z MySQLUnixSocket.switch_to_ssl s
@
r$ )z/tmp/mysql.sockrr ) r4 r5 r6 r7 r rE r r( r r r r r s @r" r r sX
)C ) )
40
$'
r$ r c Z e Zd ZdZ d
dedededdf fd
Zedefd Z d d Z
xZ S ) MySQLTCPSocketzYMySQL socket class using TCP/IP.
Opens a TCP/IP connection to the MySQL Server.
r port
force_ipv6r Nc r t | || _ || _ || _ d| _ | d| | _ y )Nr r )rv rE r server_portr _familyr )r. r r r ry s r" rE zMySQLTCPSocket.__init__ s@ $ $ * $vQtf -
r$ c | j S r r rD s r" r( zMySQLTCPSocket.address r r$ c J d} t j | j | j dt j t j
}|D ]B }| j r|d t j k( r|} n |d t j k( s@|} n | j r |d t d| j |d |d }|\ | _ }}}} t j | j || | _
| j j | j | j j! | y# t $ r3}t d| j | j t | f |d}~ww xY w# t j" t$ f$ r3}t' d| j | j t | f |d}~wt $ r3}t d| j | j t | f |d}~wt( $ r}t t+ | |d}~ww xY w)z/Open the TCP/IP connection to the MySQL server.)NNNNNr NzNo IPv6 address found for i rO )r8 getaddrinfor r r SOL_TCPr AF_INET6AF_INETr rT r# r r' r r r rR rS r r r ) r. addrinfo addrinfosinfor socktypeprotori sockaddrs r" r z MySQLTCPSocket.open_connection s
+
** "" I "??tAw&//'A #H7fnn, #H
" 8A;#6$'A$BRBRAS%TUU{"$Q< 8@4 x8 4
dllHeDDI II !9!9 : II h ' (($*:*:Kr s& : M
# ; ;
##''''## L !m4H "# OW O OD C D Nb bJ 0 Df.# f.R.
k .
bR4[ R4K
Cs A
C! ! C-,C-