*hSrSS/rSSKrSSKrSSKrSSKrSSKJrJ r J r J r \(aSSK J r \RS5 "SS \R5r"S S\R R"5rSS S .S \S\S\S\ S\ \R(\44 SjjjrS\ S\ S\ S\R,4Sjrg!\a SrNf=f)z Utilities. to_threadopen_connectionN) TYPE_CHECKINGAnyCallableTuple)MySQLConnectionAbstract StreamWriterc>\rSrSrSrS\R SS4SjrSrg)StreamReaderProtocol5zExtends 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. writerreturnNcdURnXlX lURS5SLUlg)z9Replace stream writer. Args: writer: Stream Writer. sslcontextN) transport_stream_writer _transportget_extra_info _over_ssl)selfrrs Q/var/www/auris/envauris/lib/python3.13/site-packages/mysql/connector/aio/utils.py_replace_writer$StreamReaderProtocol._replace_writer<s1 $$ $#"11,?tK)rrr) __name__ __module__ __qualname____firstlineno____doc__asyncior r__static_attributes__rrr r 5s# Lg&:&: Lt Lrr c P\rSrSrSrSSS.S\R S\S\SS4S jjr S r g) r HzExtends 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'rc # URRSLnURnUR5IShvN URR UR UUUUUS9IShvN nUUlUR U5 gNMN7f)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_tlsrr)rr(r&r'r*protocol new_transports rr/StreamWriter.start_tlsOsnn99E >>jjl"jj22 OO  #+"73       &  s!8B B/B *B +B  B )r) rrrrr ssl SSLContextstrintr/r"r#rrr r HsC $%) '^^' ' # '  ''ri)limithostportr7kwdsrc^ # [R"5n[RRX$S9n[ XTS9m UR "U 4SjX40UD6IShvN upg[ UT XT5nXX4$N7f)aA 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. )r7loop)r<c>T$)Nr#)r0sr!open_connection..srN)r!get_running_loopstreams StreamReaderr create_connectionr ) r8r9r7r:r<readerr_rr0s @rrrosq.  # # %D __ ) ) ) AF#F6H//0@$UPTUULI )Xv VsAA3A1A3funcargskwargsc# [R"5n[R"5n[R "UR U/UQ70UD6nURSU5IShvN $N7f)a9Asynchronously 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!r@ contextvars copy_context functoolspartialrunrun_in_executor)rFrGrHr<ctx func_calls rrrs\  # # %D  " " $C!!#''4A$A&AI%%dI6 66 6sA%A.'A,(A.)NN)r __all__r!rJrLr3 ImportErrortypingrrrrmysql.connector.aio.abstractsr appendr rAr r5r6rBrFuturerr#rrrXs@ ) *76E NN>"L777L&$'7??//$'P#'8= 25GJ 7   -.> 7( 73 7# 7'.. 7I CsB33B>=B>