/var/opt/nydus/ops/mysql/connector/aio/__pycache__
Edit: /var/opt/nydus/ops/mysql/connector/aio/__pycache__/network.cpython-312.pyc (30596B)
N jo d Z ddgZddlZddlZddlZ ddlZej ej ej ej dZ
ddl m
Z
mZ ddlmZ ddlmZmZmZmZmZ d d
lmZmZmZmZm Z m Z d d l m Z m Z m!Z!m"Z" d d
l#m$Z$m%Z% 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 de, Z.y# e $ r dZY w xY w)zFModule implementing low-level socket communication with MySQL servers.MySQLTcpSocketMySQLUnixSocket N)TLSv1TLSv1.1TLSv1.2TLSv1.3)ABCabstractmethod)deque)AnyDequeListOptionalTuple )InterfaceErrorNotSupportedErrorOperationalErrorProgrammingErrorReadTimeoutErrorWriteTimeoutError) COMPRESSED_PACKET_HEADER_LENGTHMAX_PAYLOAD_LENGTHMIN_COMPRESS_LENGTHPACKET_HEADER_LENGTH ) StreamWriteropen_connectionerrreturnc f | j s t | S | j d| j S )z`Reformat the IOError error message.
This function reformats the IOError error message.
)errnostrstrerror)r s L/opt/nydus/tmp/pip-target-a90h98xg/lib/python/mysql/connector/aio/network.py _strioerrorr' I s,
993s8GSYYKq *GG c e Zd ZdZe ddedededee dee dee d dfd
Z
e dd e j ded ee d e
fd
Zy)
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`.
Nwriteraddresspayload
packet_numbercompressed_packet_number
write_timeoutr c K yw)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.
write_timeout: Timeout in seconds before which sending a packet to the server
should finish else WriteTimeoutError is raised.
Raises:
:class:`OperationalError`: If something goes wrong while sending packets to
the MySQL server.
N )selfr+ r, r- r. r/ r0 s r& writezNetworkBroker.writei reader read_timeoutc K yw)aM Get the next available packet from the MySQL server.
Args:
sock: Object holding the socket connection.
address: Socket's location.
read_timeout: Timeout in seconds before which reading a packet from the server
should finish.
Returns:
packet: A packet from the MySQL server.
Raises:
:class:`OperationalError`: If something goes wrong while receiving packets
from the MySQL server.
:class:`ReadTimeoutError`: If the time to receive a packet from the server takes
longer than `read_timeout`.
:class:`InterfaceError`: If something goes wrong while receiving packets
from the MySQL server.
Nr2 )r3 r7 r, r8 s r& readzNetworkBroker.read r5 r6 NNNN)__name__
__module__ __qualname____doc__r
r r$ bytesr intr4 asyncio StreamReader bytearrayr: r2 r( r& r* r* Q s . (,26'+
} #+3-
}
>
'+ $$ sm
r( r* c e Zd ZdZddZededeeef fd Z dde
e ddfdZ d e d
e
deddfd Z dd ej d
ede
e defdZ dd e d
e
dede
e de
e de
e ddfdZ dd ej d
e
de
e defdZy)NetworkBrokerPlain,Broker class for MySQL socket communication.r Nc d| _ y N_pktnrr3 s r& __init__zNetworkBrokerPlain.__init__ s r( pktc t | t k r t d t j d| dd dz d | d }}||fS )-Recover the header information from a packet.3Can't recover header info from an incomplete packet
8".C 7 8s< A3$0 .0 A30 A0A A0
A++A00A3r7 sizer8 c | K t d }t | |k r[t j |j |t | z
| d{ }|s t d ||z
}t | |k r[|S 7 (# t j $ r}t d |d}~wt j $ r}|d}~ww xY ww)z(Read `size` bytes from the comm channel.r( Ni rh ) rE rW rC wait_forr: r TimeoutErrorr CancelledError)r3 r7 rm r8 rP chunkr s r& _read_chunkz NetworkBrokerPlain._read_chunk s
C.Cc(T/ % . .KKs3x0, (t44u
c(T/ J
## 8".C 7%% I sM B<A
A< A:%A< 8A< 9B<:A< <B9
B B92B44B99B<r- r. r/ r0 c K | j | d} t t | t z D ]x }t j
| j
||dt j d| j z |||t z z | d{ | j |t z
}z t j
| j
||t j dt | |z
dd t j d| j z ||d z | d{ y7 7 # t j $ r} t d | d} ~ wt j $ r} | d} ~ ww xY ww) zSend payload to the MySQL server.
If provided a payload whose length is greater than `MAX_PAYLOAD_LENGTH`, it is
broken down into packets.
r &&OO # ++dDKK89!&64F+FGH " $$&,, ? ""KKc'lV&;
E E(!E##E((E+c K | j |t | d{ }| j | \ }| _ || j ||| d{ z S 7 ;7 # t $ r }t d|t
| f |d}~ww xY ww)z+Receive `one` packet from the MySQL server.Nre rf )rt r r] rM rj r r' )r3 r7 r, r8 header payload_lenr s r& r: zNetworkBrokerPlain.read s ++F4H,WWF (,v'> $K $"2"26; "U UU U
X V "G[-=#>
sJ BA A4A A A BA A B'B BBr Nr< )r Nr; )r= r> r? r@ rO staticmethodrA r rB r] r rc r r$ rl rC rD rE rt r4 r: r2 r( r& rG rG sN 6
%S/
x} 8 8 8 8
8( &* $$ sm
6 (,26'+/ / / /
} / #+3-
/ }/
/j '+ $$ sm
r( rG c X e Zd ZdZd fd Zedededee fd Z edede
eeef fd Z dd
e e ddfd Z
d ed
ededdf fd Z dd ed
edede e de e de e ddf fd
Z ddej& dede e ddf fd
Z ddej& d
ede e def fd
Z xZS )NetworkBrokerCompressedrH r Nc N t | d| _ t | _ y rJ )superrO _compressed_pktnrr _queue_read)r3 __class__s r& rO z NetworkBrokerCompressed.__init__1 s
!# -2Wr( r- pktnrc | d}g }t t | t z D ]H }|j dt j
d| z | ||t z z |dz dz }|t z
}J |j t j
dt | |z
dd t j
d| z | |d z |S ) z2Prepare a payload for sending to the MySQL server.r rv rw r ra rT rU N)rx rW r appendrY ry )r- r rz pktsr{ s r& _prepare_packetsz(NetworkBrokerCompressed._prepare_packets6 s
s7|'99:A KK++dE*+&6,>#>?@
QY#%E ( (F ;
KKc'lV 3 4Qq 9kk$&
'fg
r( rP c t | t k r t d t j d| dd dz d | d t j d| dd dz d }}}|||fS )rR rS rT r rU rV )rW r rX rY rZ )rP compressed_pllr\ uncompressed_plls r& r] z"NetworkBrokerCompressed.get_headerO s{ s85 5 RS S
MM$Aa7 2 3A 6 F MM$Aa7 2 3A 6 0 u&666r( r^ c l || xj dz
c_ n|| _ | xj dz c_ yr` )r rb s r& _set_next_compressed_pktnrz2NetworkBrokerCompressed._set_next_compressed_pktnr] s1 ? " "a ' "%,D " #% r( r+ r, c > K t j | }t j dt | dd t j d| j
z t j dt | dd z |z }t | ||| d{ S 7 w)z1Compress packet and write it to the comm channel.rT r rU rw N)zlibcompressrY ry rW r r rl )r3 r+ r, rP compressed_pktr s r& rl z"NetworkBrokerCompressed._write_pkte s s+ KKc. 1 21Q 7kk$ 6 67
8kk$C)!A.
/
W'====s BB BB r. r/ r0 c X K | j | | j | t d j | j || j
}t
| t t z
k\ rd}t t
| t z D ]T } t j | j |||||t z | d{ | j |t z
}V t j | j ||||d | d{ yt
| t kD r0t j | j ||| | d{ yt j t | 1 ||t j dt
| dd t j d| j" z t j dd dd z |z | d{ y7 !7 7 7 # t j$ t j& f$ r}
t) d |
d}
~
ww xY ww) 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.
r( r NrT rU rw ro rh )rc r rE joinr rM rW r r rx rC rp rl r r rY ry r rr rq r ) r3 r+ r, r- r. r/ r0 payload_preprz r{ r r s r& r4 z NetworkBrokerCompressed.writeu s!
]+ ''(@A6 9$S>..%%gt{{; L 7| 14H HH s< 04F FGA!** " # (&;M2M N
&
335 00F H &&OOFG\&'5JK! w<"55!** F
"** * " # "KKc,.? @1 E $kk$0F0F G H $kk$ 21Q 7 8 + + &
5
&&(<(<= 9#$/S 8 9s #H*B!G2 G) A G2 G,G2 H* A5E"E#2EEA%E<EEEc K | j s t | |t | d{ }| j | \ }| _ }|dk( r3| j j
t | ||| d{ n| j ||| d{ | j sy| j j }|d | _ |S 7 7 Y7 ;# t $ r }t d|t | f |d}~ww xY ww)z{Receive `one` or `several` packets from the MySQL server, enqueue them, and
return the packet at the head.
Nr re rf rU )
r r rt r r] r r r rj r r' popleftrM )
r3 r7 r, r8 r} r r r rP r s
r& r: z NetworkBrokerCompressed.read s
$w 2 ;\ OOF+ "*$ $q($$++ #g 1&., WW
33 &&(!f
A X
& S1A'B
s]
C>C CA C 6C7 C CC 3C>C C C C; C66C;;C>r r< r; )r= r> r? r@ rO r rA rB r r r r] r r r r$ rl r4 rC rD r rE r:
__classcell__r s @r& r r . s 65
% U 0 7 7%S#
"6 7 7&(3- &4 &> > > >
>* (,26'+G9 G9 G9 G9
} G9 #+3-
G9 }G9
G9Z '+ -1$$-1 -1 sm -1
-1f '+ -$$- - sm -
- -r( r c h e Zd ZdZd dZedefd Zede ddfd Z
d dZ de fd Z
d
eddfd Zd d Zd
ej$ ddfdZ d dedee dee dee ddf
dZd!dee defdZdddddg g fdee dee dee dee dee d eee d eee dej$ fd Zy)" MySQLSocketzMySQL socket communication interface.
Examples:
Subclasses: network.MySQLTCPSocket and network.MySQLUnixSocket.
r Nc h d| _ d| _ d| _ d| _ t | _ d| _ y)zsNetwork layer where transactions are made with plain (uncompressed) packets
is enabled by default.
NF)_reader_writer_connection_timeout_addressrG
_netbroker
_is_connectedrN s r& rO zMySQLSocket.__init__$ s3 8< /3 26 '+
);)=#(r( c | j S )zSocket location.)r rN s r& r, zMySQLSocket.address/ s }} r( kwargsc K yw)zOpen the socket.Nr2 r3 r s r& r zMySQLSocket.open_connection4 r5 r6 c n K | j r | j j | j j $| j j j | j j d{ d| _ yd| _ y7 # t
$ r}Y d}~d| _ yd}~ww xY ww)zClose the connection.NF)r close transportabort wait_closed Exceptionr )r3 r{ s r& close_connectionz MySQLSocket.close_connection8 s <<
""$<<))5LL**002ll..000
#U 1
"
s;
B5A1B BB B5B B2! B5-B22B5c | j S )zCheck if the socket is connected.
Return:
bool: Returns `True` if the socket is connected to MySQL server.
)r rN s r& is_connectedzMySQLSocket.is_connectedG s !!!r( timeoutc || _ y)zSet the connection timeout.N)r )r3 r s r& set_connection_timeoutz"MySQLSocket.set_connection_timeoutO s
#* r( c " t | _ y)zIEnable network layer where transactions are made with compressed packets.N)r r rN s r& switch_to_compressed_modez%MySQLSocket.switch_to_compressed_modeS s 13r( ssl_contextc K | j J | j j j d }|j dk( r t d | j j | d{ y7 w)a? Upgrade an existing stream-based connection to TLS.
The `start_tls()` method from `asyncio.streams.StreamWriter` is only available
in Python 3.11. This method is used as a workaround.
The MySQL TLS negotiation happens in the middle of the TCP connection.
Therefore, passing a socket to open connection will cause it to negotiate
TLS on an existing connection.
Args:
ssl_context: The SSL Context to be used.
Raises:
RuntimeError: If the transport does not expose the socket instance.
Nsocketr z,SSL is not supported when using Unix sockets)r r get_extra_infofamilyr start_tls)r3 r r s r&
switch_to_sslzMySQLSocket.switch_to_sslW sb " ||''' ''66x@ ==A "#QR Rll$$[111s A,A6.A4/A6r- r. r/ r0 c K | j j | j | j |||| d{ y7 w)z!Send packets to the MySQL server.)r. r/ r0 N)r r4 r r, )r3 r- r. r/ r0 s r& r4 zMySQLSocket.writep sC oo## LL LL '%='
$
s 9AAAr8 c K | j j | j | j | d{ S 7 w)z#Read packets from the MySQL server.N)r r: r r, )r3 r8 s r& r: zMySQLSocket.read s- __))$,, lSSSSs 5><>Fssl_cassl_certssl_keyssl_verify_certssl_verify_identity tls_versionstls_cipher_suitesc d}| j s t d t t d |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} t3 d | d} ~ wt& t4 t j6 t j( f$ r} t t9 | | d} ~ ww xY w)zBuild a SSLContext.Ni rh z&Python installation has no SSL supportT)reverser r r r r zInvalid CA Certificate: zInvalid Certificate/Key: :) r r ssl RuntimeErrorsort 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_locationsrj SSLErrorload_cert_chain set_ciphersr NameErrorr NotImplementedErrorCertificateErrorr$ ) r3 r r r r r r r tls_version ssl_protocolcontextr s r& build_ssl_contextz MySQLSocket.build_ssl_context s% &* || t, , ; GH H5 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 8(H !G:G GH G>*G99G>>H I
H0I II r r; r< )r= r> r? r@ rO propertyr$ r, r
r r r boolr rB r r r r r rA r r4 rE r: r r r2 r( r& r r s ) c d
# "d "+c +d +42s~~ 2$ 28 (,26'+
}
#+3-
}
"Tx} T T !%"&!%*/.3,.13H4
H4 3-H4 # H4
"$ H4 &d^
H4 tCy)H4 $DI.H4
H4r( r c D e Zd ZdZ d
dededef fd
Zdeddfd Z xZ
S ) r zMySQL socket class using TCP/IP.
Args:
host: MySQL host name.
port: MySQL port.
force_ipv6: Force IPv6 usage.
hostport
force_ipv6c d t | || _ || _ || _ | d| | _ y )Nr )r rO _host_port _force_ipv6r )r3 r r r r s r& rO zMySQLTcpSocket.__init__ s8
!+ $vQtf -
r( r r Nc K t d| j | j d| d{ \ | _ | _ d| _ y7 w)zOpen TCP/IP connection.)r r NTr2 )r r r r r r r s r& r z MySQLTcpSocket.open_connection sG +: ,
$**,
06,
&
" dl "&
s &AAA)z 127.0.0.1i F) r= r> r? r@ r$ rB r rO r r r r s @r& r r s? MR..-0.EI."c "d "r( c : e Zd ZdZddef fd
ZdeddfdZ xZS ) r zbMySQL socket class using UNIX sockets.
Args:
unix_socket: UNIX socket file path.
unix_socketc 0 t | || _ y r< )r rO r )r3 r r s r& rO zMySQLUnixSocket.__init__ s
(
r( r r Nc K t j dd| j i| d{ \ | _ | _ d| _ y7 w)z Open UNIX socket connection.pathNTr2 )rC open_unix_connectionr r r r r s r& r z MySQLUnixSocket.open_connection sM
..
"(
L L "
s %AAA)z/tmp/mysql.sock) r= r> r? r@ r$ rO r r r r s @r& r r s' )C )"c "d "r( )/r@ __all__rC rY r r PROTOCOL_TLSv1PROTOCOL_TLSv1_1PROTOCOL_TLSv1_2 PROTOCOL_TLSr ImportErrorabcr r
collectionsr typingr r
r r r errorsr r r r r r networkr r r r utilsr r rj r$ r' r* rG r r r r r2 r( r& r s > M .
/
##''''## L $ 4 4 1HW H HQ C Q hF FRl 0 l^p4# p4f"[ "4"k "s
Cs 3C C C