?????????? ????????? - ??????????????? - /home/agenciai/.local/lib/python3.9/site-packages/mysql/connector/aio/__pycache__/utils.cpython-39.pyc
???????
a ��Jh� � @ s� d Z ddgZddlZddlZddlZz ddlZW n eyF dZY n0 ddlmZm Z m Z m Z erzddl m Z e�d� G dd � d ej�ZG d d� dejj�Zdd d �eeee e ejef d �dd�Ze e e ejd�dd�ZdS )z Utilities.� to_thread�open_connection� N)� TYPE_CHECKING�Any�Callable�Tuple)�MySQLConnectionAbstract� StreamWriterc @ s" e Zd ZdZejdd�dd�ZdS )�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. N)�writer�returnc C s& |j }|| _|| _|�d�du| _dS )zQReplace stream writer. Args: writer: Stream Writer. � sslcontextN)� transport�_stream_writer� _transport�get_extra_info� _over_ssl)�selfr r � r �N/home/agenciai/.local/lib/python3.9/site-packages/mysql/connector/aio/utils.py�_replace_writer< s z$StreamReaderProtocol._replace_writer)�__name__� __module__� __qualname__�__doc__�asyncior r r r r r r 5 s r c @ s. e Zd ZdZddd�ejeedd�dd�ZdS )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 � sT | j jdu}| j }| �� I dH | jj| j|||||d�I dH }|| _|�| � dS )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 �protocolZ new_transportr r r r$ O s � �zStreamWriter.start_tls) r r r r �ssl� SSLContext�str�intr$ r r r r r H s ��i )�limit)�host�portr* �kwdsr c � sb t �� }t jj||d�}t||d�� |j� fdd�| |fi |��I dH \}}t|� ||�}||fS )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. )r* �loop)r. c s � S )Nr r �r% r r �<lambda>� � z!open_connection.<locals>.<lambda>N)r �get_running_loop�streams� StreamReaderr �create_connectionr ) r+ r, r* r- r. �readerr �_r r r/ r r o s ()�func�args�kwargsr c � s> t �� }t�� }tj|j| g|�R i |��}|�d|�I dH S )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 r2 � contextvars� copy_context� functools�partial�run�run_in_executor)r8 r9 r: r. �ctx� func_callr r r r � s )NN)r �__all__r r; r= r& � ImportError�typingr r r r Z mysql.connector.aio.abstractsr �appendr r3 r r( r) r4 r �Futurer r r r r �<module> s, ( �� �
| ver. 1.6 |
Github
|
.
| PHP 8.2.30 | ??????????? ?????????: 0 |
proxy
|
phpinfo
|
???????????