Ë
|
Wñúhµ ã ó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_threadÚopen_connectioné N)Ú TYPE_CHECKINGÚAnyÚCallableÚTuple)ÚMySQLConnectionAbstractÚ StreamWriterc ó4 e Zd ZdZdej
|
ddfdZy)ÚStreamReaderProtocolzìExtends 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.
|
ÚwriterÚreturnNc óh |j }|| _ || _ |j d« du| _ y)zQReplace stream writer.
|
|
Args:
|
writer: Stream Writer.
|
Ú
|
sslcontextN)Ú transportÚ_stream_writerÚ
|
_transportÚget_extra_infoÚ _over_ssl)Úselfr r s úLH:\Change_password\venv_build\Lib\site-packages\mysql/connector/aio/utils.pyÚ_replace_writerz$StreamReaderProtocol._replace_writer< s5 ð ×$Ñ$ Ø $ÔØ#Ø"×1Ñ1°,Ó?ÀtÐKó )Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__Úasyncior
|
r © r r r r 5 s# ñð L g×&:Ñ&:ð L¸tô Lr r c óD e Zd ZdZddddej
|
dededdfdZy) r
|
zäExtends 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_hostnameÚssl_handshake_timeoutÚ ssl_contextr! r" r c ó" K | j j du}| j }| j « d{ | j j | j
|
|||||¬« d{ }|| _ |j | « y7 P7 w)zåUpgrade 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_cbÚdrainÚ_loopÚ start_tlsr r )r r# r! r" r% ÚprotocolÚ new_transports r r* zStreamWriter.start_tlsO s è ø ð nn×9Ñ9ÀÐE Ø>>Øjjl×ÐØ "jj× 2Ñ 2à OOØ Ø Ø#Ø +Ø"7ð 3ó
|
÷
|
ð ð ð × Ñ Õ&ð øð
|
ús! 8BºB »2BÁ-B Á. BÂ B) r r r r ÚsslÚ
|
SSLContextÚstrÚintr* r r r r
|
r
|
H s> ñð $Ø%)ò 'à^^ð 'ð ð 'ð
|
#ð 'ð
|
ô 'r i )ÚlimitÚhostÚportr1 Ú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 ú<lambda>z!open_connection.<locals>.<lambda> s ø ¸ r N)r Úget_running_loopÚstreamsÚ StreamReaderr Úcreate_connectionr
|
)
|
r2 r3 r1 r4 r6 Úreaderr Ú_r r+ s
|
@r r r o s øè ø ô. × #Ñ #Ó %DÜ __× )Ñ )°¸DÐ )Ó AFÜ# F°Ô6HØ/×/Ñ/Ó0@À$ÈÑUÐPTÑU×ULIqÜ ) X¨v°tÓ <FØ 6>Ðð Vús A A=Á!A;Á"A=ÚfuncÚargsÚkwargsc óÚ 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Ú functoolsÚpartialÚrunÚrun_in_executor)r? r@ rA r6 ÚctxÚ func_calls r r r s] è ø ô × #Ñ #Ó %DÜ
|
×
|
"Ñ
|
"Ó
|
$CÜ×!Ñ! #§'¡'¨4ÐA°$ÒA¸&ÑAIØ×%Ñ% d¨IÓ6× 6Ð6Ð 6ús A"A+Á$A)Á%A+)NN)r Ú__all__r rC rE r- Ú ImportErrorÚtypingr r r r Ú mysql.connector.aio.abstractsr Úappendr r: r
|
r/ r0 r; r ÚFuturer r r r ú<module>rQ sò ðñ@ à Ð)Ð
|
*ã Û Û ðÛ÷ 7Ó 6áÝEà NN>Ô"ôL7×7Ñ7ô Lô&$'7??×/Ñ/ô $'ðP #'ð Ø8=ò Ø
|
ð Ø ð Ø25ð ØGJð à
|
7× Ñ Ð -Ñ.ó ð> 7(ð 7¨3ð 7¸#ð 7À'Ç.Á.ô 7øðI ò Ø
|
Cðús B* Â*B4Â3B4
|
