/var/opt/nydus/ops/mysql/connector/aio/__pycache__
Edit: /var/opt/nydus/ops/mysql/connector/aio/__pycache__/utils.cpython-312.pyc (5983B)
N j n d Z ddgZddlZddlZddlZ ddlZddlmZm Z m
Z
m Z erddl m
Z
ej d G d d ej Z G d
dej j" Z dd d d
ededede de ej( ef f
dZde
de de dej, fdZy# e$ r dZY w xY w)z
Utilities. to_threadopen_connection N)
TYPE_CHECKINGAnyCallableTuple)MySQLConnectionAbstract StreamWriterc 4 e Zd ZdZdej
ddfdZy)StreamReaderProtocolzExtends asyncio.streams.StreamReaderProtocol for adding start_tls().
The ``start_tls()`` is based on ``asyncio.streams.StreamWriter`` introduced
in Python 3.11. It provides the same functionality for older Python versions.
writerreturnNc h |j }|| _ || _ |j d du| _ y)zQReplace stream writer.
Args:
writer: Stream Writer.
sslcontextN) transport_stream_writer
_transportget_extra_info _over_ssl)selfr
r s J/opt/nydus/tmp/pip-target-a90h98xg/lib/python/mysql/connector/aio/utils.py_replace_writerz$StreamReaderProtocol._replace_writer< s5 $$ $#"11,?tK )__name__
__module__ __qualname____doc__asyncior
r r r r r 5 s# Lg&:&: Lt Lr r c D e Zd ZdZddddej
dededdfdZy) r
zExtends asyncio.streams.StreamWriter for adding start_tls().
The ``start_tls()`` is based on ``asyncio.streams.StreamWriter`` introduced
in Python 3.11. It provides the same functionality for older Python versions.
N)server_hostnamessl_handshake_timeout ssl_contextr! r" r c " K | j j du}| j }| j d{ | j j | j
||||| d{ }|| _ |j
| y7 P7 w)zUpgrade an existing stream-based connection to TLS.
Args:
ssl_context: Configured SSL context.
server_hostname: Server host name.
ssl_handshake_timeout: SSL handshake timeout.
N) server_sider! r" ) _protocol_client_connected_cbdrain_loop start_tlsr r )r r# r! r" r% protocol
new_transports r r* zStreamWriter.start_tlsO s nn99E >>jjl "jj 2 2 OO # +"7 3
&
s! 8BB 2B-B
. B
B) r r r r ssl
SSLContextstrintr* r r r r
r
H s> $%) '^^ ' '
# '
'r i )limithostportr1 kwdsr c K t j }t j j || }t || |j
fd| |fi | d{ \ }}t
| || }||fS 7 w)a A wrapper for create_connection() returning a (reader, writer) pair.
This function is based on ``asyncio.streams.open_connection`` and adds a custom
stream reader.
MySQL expects TLS negotiation to happen in the middle of a TCP connection, not at
the start.
This function in conjunction with ``_StreamReaderProtocol`` and ``_StreamWriter``
allows the TLS negotiation on an existing connection.
Args:
host: Server host name.
port: Server port.
limit: The buffer size limit used by the returned ``StreamReader`` instance.
By default the limit is set to 64 KiB.
Returns:
tuple: Returns a pair of reader and writer objects that are instances of
``StreamReader`` and ``StreamWriter`` classes.
)r1 loop)r6 c S )Nr )r+ s r
z!open_connection.. s r N)r get_running_loopstreams StreamReaderr create_connectionr
)
r2 r3 r1 r4 r6 readerr _r
r+ s
@r r r o s . # # %D
__
)
)D
)
AF#F6H///0@$UPTUULIq
)Xvt
Vs A A=!A;"A=funcargskwargsc K t j }t j }t j
|j | g|i |}|j d| d{ S 7 w)aQ Asynchronously run function ``func`` in a separate thread.
This function is based on ``asyncio.to_thread()`` introduced in Python 3.9, which
provides the same functionality for older Python versions.
Returns:
coroutine: A coroutine that can be awaited to get the eventual result of
``func``.
N)r r9 contextvars copy_context functoolspartialrunrun_in_executor)r? r@ rA r6 ctx func_calls r r r s] # # %D
"
"
$C!!#''4A$A&AI%%dI6 66 6s A"A+$A)%A+)NN)r __all__r rC rE r- ImportErrortypingr r r r mysql.connector.aio.abstractsr appendr r: r
r/ r0 r; r Futurer r r r rQ s @ )
* 7 6E NN>"L777 L&$'7??// $'P #' 8=
25 GJ
7 -. >
7(
73
7#
7'..
7I
Cs B* *B43B4