şgSrSS/rSSKrSSKrSSKrSSKrSSKJrJr SSK r SSK J r J r JrJr \ (aSSKJr \R%S5 "S S \R&5r"S S\R(R*5rSS S .S\S\S\S\ S\\R0\44 SjjjrS\S\ S\ S\R44SjrS\S\4SjrS\4Sjrg!\ a Sr Nf=f)z Utilities. to_threadopen_connectionN)ReadTimeoutErrorWriteTimeoutError) TYPE_CHECKINGAnyCallableTuple)MySQLConnectionAbstract StreamWriterc>\rSrSrSrS\R SS4SjrSrg)StreamReaderProtocol8zExtends 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 Z/var/www/blue/EV-Temp_rev04/venv/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__rrrr8s# Lg&:&: Lt Lrrc P\rSrSrSrSSS.S\R S\S\SS4S jjr S r g) r KzExtends 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 rr1StreamWriter.start_tlsRsnn99E >>jjl"jj22 OO  #+"73       &  s!8B B/B *B +B  B )r) rrr r!r"ssl SSLContextstrintr1r$r%rrr r KsC $%) '^^' ' # '  ''ri)limithostportr9kwdsrc^ # [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. )r9loop)r>c>T$Nr%)r2sr!open_connection..srN)r#get_running_loopstreams StreamReaderrcreate_connectionr ) r:r;r9r<r>readerr_rr2s @rrrrsq.  # # %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#rC contextvars copy_context functoolspartialrunrun_in_executor)rIrJrKr>ctx func_calls rrrs\  # # %D  " " $C!!#''4A$A&AI%%dI6 66 6sA%A.'A,(A.reasonc0^S[S[4U4SjjnU$)z&Use it to decorate deprecated methods.rIrcr>^[R"T5S[S[S[4UU4Sjj5nU$)NrJrKrc># [R"STRST3[SS9 T"U0UD6IShvN $N7f)NzCall to deprecated function z . Reason: )category stacklevel)warningswarnrDeprecationWarning)rJrKrIrUs rwrapper.deprecated..decorator..wrappersD MM.t}}oZxP+  t.v.. ..s6A>A)rOwrapsrr )rIr_rUs` r decoratordeprecated..decorators:   / / / /  /rr )rUrbs` r deprecatedres  X  rc(S[S[4SjnU$)z Decorator to close the current connection if a read or a write timeout is raised by the method passed via the func parameter. cnx_methodrc r^[R"T5SSS[S[S[4U4Sjj5nU$)Ncnxr rJrKrc># T"U/UQ70UD6IShvN $N![a;n[U[[45(aUR 5IShvN UeSnAff=f7fr@) Exception isinstancerrclose)rirJrKerrrgs rhandle_cnx_methodGhandle_read_write_timeout..decorator..handle_cnx_methods] '=d=f==== c$46G#HII))+%%  s<A#A# A .AAAA  A#)rOrar)rgros` rrb,handle_read_write_timeout..decoratorsF  $ * 36 BE    % ! rrd)rbs rhandle_read_write_timeoutrrs !h !8 ! r)NN)r"__all__r#rMrOr\mysql.connector.errorsrrr5 ImportErrortypingrrr r mysql.connector.aio.abstractsr appendrrDr r7r8rErFuturerrerrr%rrrzs@ ) *F76E NN>"L777L&$'7??//$'P#'8= 25GJ 7   -.> 7( 73 7# 7'.. 7 sx$8M CsCCC