Sh3ll
OdayForums


Server : LiteSpeed
System : Linux premium84.web-hosting.com 4.18.0-553.44.1.lve.el8.x86_64 #1 SMP Thu Mar 13 14:29:12 UTC 2025 x86_64
User : claqxcrl ( 523)
PHP Version : 8.1.32
Disable Function : NONE
Directory :  /opt/hc_python/lib64/python3.12/site-packages/mysql/connector/__pycache__/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

Current File : //opt/hc_python/lib64/python3.12/site-packages/mysql/connector/__pycache__/network.cpython-312.pyc
�

���g�J���dZddlmZddlZddlZddlZddlZ	ddlZddlm	Z	m
Z
ddlmZm
Z
mZd�Zd�ZGd	�d
e�ZGd�de�ZGd
�de�Zy#Y�>xYw)zGModule implementing low-level socket communication with MySQL servers.
�)�dequeN�)�	constants�errors)�PY2�init_bytearray�
struct_unpackc�~�|jst|�Sdj|j|j��S)z_Reformat the IOError error message

    This function reformats the IOError error message.
    z{errno} {strerr})�errno�strerr)r�str�format�strerror)�errs �n/opt/hc_python/lib64/python3.12/site-packages/../../../lib/python3.12/site-packages/mysql/connector/network.py�_strioerrorr+s2��
�9�9��3�x���$�$�3�9�9�S�\�\�$�J�J�c�`�g}t|�}tj}||kDrI|jdt	j
d|�z|d|z�||d}t|�}|dz}||kDr�I|jt	j
d|�ddt	j
d|�z|z�|S)z0Prepare a packet for sending to the MySQL server�����<BNr�<Ir�)�lenr�MAX_PACKET_LENGTH�append�struct�pack)�buf�pktnr�pkts�pllen�	maxpktlens     r�_prepare_packetsr#5s���
�D���H�E��+�+�I�
�)�
����O�f�k�k�$��&>�>��*�9�o�&�	'��)�*�o���C�����	���)�
�	�K�K����D�%�(��1�-��+�+�d�E�*�+�-0�1�2��Krc���eZdZdZd�Zed��Zed��Zd�Zd�Z	d�Z
d�Z		dd
�ZeZ
		dd�Zd�Zd
�Zej$dddk(reZeZneZd�Zd�Zd�Zdd�Zy	)�BaseMySQLSocketaBase class for MySQL socket communication

    This class should not be used directly but overloaded, changing the
    at least the open_connection()-method. Examples of subclasses are
      mysql.connector.network.MySQLTCPSocket
      mysql.connector.network.MySQLUnixSocket
    c�h�d|_d|_d|_d|_t	�|_d|_y)N���i )�sock�_connection_timeout�_packet_number�_compressed_packet_numberr�
_packet_queue�recvsize��selfs r�__init__zBaseMySQLSocket.__init__Ns2����	�#'�� � ���)+��&�"�W�����
rc�n�|jdz|_|jdkDrd|_|jS)zIncrements the packet numberr�r)r*r.s r�next_packet_numberz"BaseMySQLSocket.next_packet_numberVs9��#�1�1�A�5�������$�"#�D���"�"�"rc�n�|jdz|_|jdkDrd|_|jS)z'Increments the compressed packet numberrr2r)r+r.s r�next_compressed_packet_numberz-BaseMySQLSocket.next_compressed_packet_number^s9��*.�)G�)G�!�)K��&��)�)�C�/�-.�D�*��-�-�-rc��t�)zOpen the socket��NotImplementedErrorr.s r�open_connectionzBaseMySQLSocket.open_connectionf���!�!rc��t�)zGet the location of the socketr7r.s r�get_addresszBaseMySQLSocket.get_addressjr:rc���	|jjtj�|jj	�|`y#tjtf$rYywxYw)z&Shut down the socket before closing itN)r(�shutdown�socket�	SHUT_RDWR�closer,�error�AttributeErrorr.s rr>zBaseMySQLSocket.shutdownnsN��	��I�I���v�/�/�0��I�I�O�O���"�����n�-�	��	�s�AA�A$�#A$c�|�	|jj�|`y#tjt
f$rYywxYw)zClose the socketN)r(rAr,r?rBrCr.s r�close_connectionz BaseMySQLSocket.close_connectionws6��	��I�I�O�O���"�����n�-�	��	�s��;�;Nc	��|�
|jn||_t||j�}|D]I}	tr%|jjt
|��n|jj|��Ky#t$r5}tjd|j�t|�f���d}~wt$rtjd���wxYw)z Send packets to the MySQL serverN��r�values���r)
r3r*r#rr(�sendall�buffer�IOErrorr�OperationalErrorr<rrC)r/r�
packet_number�compressed_packet_number�packets�packetrs       r�
send_plainzBaseMySQLSocket.send_plains���� ��#�#�"/�D��"�3��(;�(;�<���F�	
:���I�I�%�%�f�V�n�5��I�I�%�%�f�-�����
O��-�-���(8�(8�(:�K��<L�'M�O�O��!�
:��-�-�D�9�9�
:�s�AA<�<	C�0B5�5#Cc	��|�
|jn||_|�
|jn||_|j}t	|�}g}t
j}||kD�r+t||�}tr"t�}	|D]}
|	|
z
}	�	t|	�}	ndj|�}	~tj|	dd�}tjdt	|��ddtjd|j�zdz}trt|�}|j!||z�|	dd}	t	|	�}|j||kDr�tj|	d|�}tjdt	|��ddtjd|j�zd	z}trt|�}|j!||z�|	|d}	t	|	�}|j||kDr��|	r�tj|	�}tjdt	|��ddtjd|j�ztjd|�ddz}trt|�}|j!||z�~	�nRtjd|�ddtjd|�z|z}
trt|
�}
t	|
�}|d
kDr�tj|
�}|j!tjdt	|��ddtjd|j�ztjd|�ddz|z�nytjd|�ddtjd|j�ztjdd�ddz}trt|�}|j!||
z�|D]}
	|j"j%|
�� y#t&$r5}t)j*d|j-�t/|�f���d}~wt0$rt)j*d
���wxYw)z+Send compressed packets to the MySQL serverNr�@rrrrs@r�2rGrHrJrK)r3r*r5r+rrrr#r�	bytearrayrM�join�zlib�compressrrrr(rLrNrrOr<rrC)r/rrPrQrr!�zpktsr"r �tmpbuf�pkt�zbuf�header�
zip_packetrs               r�send_compressedzBaseMySQLSocket.send_compressed�s���� ��#�#�"/�D��#�+��.�.�-E�D�*��#�#���C������/�/�	��9��#�C��/�D��"����C��c�M�F� ��������$�����=�=�����0�D��k�k�$��D�	�2�1�Q�7����D�$�*H�*H�I�J�'�(�F�������L�L��$��'��E�F�^�F���K�E��.�.��)�#��}�}�V�J�Y�%7�8�� �+�+�d�C��I�6�q��;�"�K�K��d�.L�.L�M�N�+�,���#�F�^�F����V�d�]�+��	�
�+���F����2�2��)�#���}�}�V�,�� �+�+�d�C��I�6�q��;�"�K�K��d�.L�.L�M�N�"�K�K��e�4�Q�q�9�:���#�F�^�F����V�d�]�+���;�;�t�U�+�A�a�0��;�;�t�U�+�,�.1�2�C���S�k����H�E��r�z��}�}�S�)�����V�[�[��s�4�y�9�!�A�>�%�{�{�4��1O�1O�P�Q�%�{�{�4��7��!�<�=� $�$�%�
!�+�+�d�E�2�1�Q�7�"�K�K��d�.L�.L�M�N�"�K�K��a�0��1�5�6���#�F�^�F����V�c�\�*��J�
:��	�	�!�!�*�-� ���
O��-�-���(8�(8�(:�K��<L�'M�O�O��!�
:��-�-�D�9�9�
:�s�O=�=	Q�0P6�6#Qc���	td�}d}|dkrL|jjd|z
�}|stjd���||z
}t|�}|dkr�L|d|_tr)tjdt|dddz��d}ntjd|dddz�d}|}|jt|��t|�}|dd	}|rI|jj||�}|dk(r|dkDrtjd���||d	}||z}|r�I|S#t$r5}tj d
|j#�t%|�f���d	}~wwxYw)�%Receive packets from the MySQL serverrr���rKrr�NrGrH)rXr(�recvr�InterfaceErrorrr*rr�unpack_fromrM�unpack�extend�
memoryview�	recv_intorNrOr<r)	r/rS�
packet_len�chunk�payload_len�rest�packet_view�readrs	         r�
recv_plainzBaseMySQLSocket.recv_plain�s���"	K��s�^�F��J��q�.��	�	���q�:�~�6��� �/�/�d�;�;��%��� ��[�
��q�.�#)��)�D���$�0�0���6�!�A�;��0�1�3�34�6��%�m�m�D�&��1�+��2G�H��K���D��M�M�)�K�0�1�$�V�,�K�%�a�b�/�K���y�y�*�*�;��=���1�9���� �/�/�d�;�;�)�$�%�0��������M���	K��)�)��D�$4�$4�$6��C�8H�#I�K�
K��	K�s%�AD1� CD1�/D1�1	E/�:0E*�*E/c�F�	td�}d}|dkrL|jjd|z
�}|stjd���||z
}t|�}|dkr�L|d|_td|dddz�d}|}td�}|dkDrL|jj|�}|stjd���||z
}|t|�z
}|dkDr�L||zS#t$r5}tjd	|j�t|�f�
��d}~wwxYw)rdrrrerfrKrrrgrGrHN)
rXr(rhrrirr*r	rrNrOr<r)r/r`�
header_lenrprqrr�payloadrs        r�recv_py26_plainzBaseMySQLSocket.recv_py26_plains7��	K��s�^�F��J��q�.��	�	���q�:�~�6��� �/�/�d�;�;��%��� ��[�
��q�.�#)��)�D��'��f�Q�q�k�G�.C�D�Q�G�K��D�$�S�)�G���(��	�	���t�,��� �/�/�d�;�;��5� ��"�S��\�1����(��G�#�#���	K��)�)��D�$4�$4�$6��C�8H�#I�K�
K��	K�s%�AC"� A<C"�C"�"	D �+0D�D r�)rz�c���|rrtr tjd|dddz�d}ntjd|dddz�d}|jj|d|dz�||dzd}|r�qyy)zSplit compressed payloadrrrrgreN)rrrjrkr,r)r/�packet_bunch�payload_lengths   r�_split_zipped_payloadz%BaseMySQLSocket._split_zipped_payload5s�����!'�!3�!3�� ��1�%��/�"1�12�"4��"(���t�\�!�A�5F��5P�!Q�RS�!T�����%�%�l�1�^�a�5G�&H�I�'���(:�(;�<�L�rc�&�	|jj�}|d|_|S#t$rYnwxYwt	d�}g}	|j
j
d�}|r?t|�dkr1||z
}|j
j
d�}|rt|�dkr�1|�r�t|�dkrtjd���td|ddd	z�d}|d|_td|d
dd	z�d}t|�}t|�|kr_|j
j
|t|�z
�}t|�dk(rtjd���||z}t|�|kr�_|dk(r7|j|�|jj�}|d|_|S|j||f�|dkrnktd�}|j
j
d�}|r?t|�dkr1||z
}|j
j
d�}|rt|�dkr�1|r���nA#t$r5}	tj d|j#�t%|	�f�
��d}	~	wwxYwtd�}
|D]E\}}t&r"|
t)j*t-|��z
}
�.|
t)j*|�z
}
�G|j|
�~
	|jj�}|d|_|S#t$rYywxYw)z0Receive compressed packets from the MySQL serverrrr�rfrKrrrgrerVrGrHN)r,�popleftr*�
IndexErrorrXr(rhrrrir	r+rrrrNrOr<rrrZ�
decompressrM)r/r^r`rR�abyte�zip_payload_lengthr~�zip_payloadrpr�tmprxs            r�recv_compressedzBaseMySQLSocket.recv_compressedBs��	��$�$�,�,�.�C�"%�a�&�D���J���	��	���3�����/	K��I�I�N�N�1�%�E��C��K�!�O��%����	�	���q�)���C��K�!�O���v�;��?� �/�/�d�;�;�&3�4�39�!�A�;��3H�&J�JK�&M�"�17����.�"/�t�V�A�a�[�7�5J�!K�A�!N��,�U�3���+�&�);�;� �I�I�N�N�+=�-0��-=�,>�?�E��5�z�Q��$�3�3�$�?�?�"-��"5�K��+�&�);�;�"�Q�&��.�.�{�;��,�,�4�4�6�C�*-�a�&�D�'��J������<�=�%��.��(��,���	�	���q�)����F��a���e�O�F� �I�I�N�N�1�-�E���F��a��I��P�	K��)�)��D�$4�$4�$6��C�8H�#I�K�
K��	K���S�!��'.�#�N�G���t���v�g��7�7���t���w�/�/��(/�	
�"�"�3�'��	��$�$�,�,�.�C�"%�a�&�D���J���	��	�sQ�%(�	4�4�AH5�!CH5�4;H5�0A?H5�0H5�5	I3�>0I.�.I3�%L�	L�Lc��||_y)zSet the connection timeoutN)r))r/�timeouts  r�set_connection_timeoutz&BaseMySQLSocket.set_connection_timeout�s
��#*�� rc
�h�|jstjd���	|rtj}ntj
}tj|j||||dtj|��|_|jj�y#t$rtjd��tjtf$r5}tjd|j�t|�f���d}~wt$r#}tjt!|���d}~wwxYw)	zSwitch the socket to use SSLirKF)�keyfile�certfile�ca_certs�	cert_reqs�do_handshake_on_connect�ssl_version�ciphersz&Python installation has no SSL supportrGrHN)r(rri�ssl�
CERT_REQUIRED�	CERT_NONE�wrap_socket�PROTOCOL_TLSv1�do_handshake�	NameError�NotSupportedError�SSLErrorrNr<rr8r
)r/�ca�cert�key�verify_cert�cipherr�rs        r�
switch_to_sslzBaseMySQLSocket.switch_to_ssl�s����y�y��'�'�d�3�3�	2���-�-�	��M�M�	�����	�	�3���#�U��.�.��@�D�I�
�I�I�"�"�$���	:��*�*�8�:�
:����g�&�	K��'�'��D�$4�$4�$6��C�8H�#I�K�
K��"�	2��'�'��C��1�1��	2�s$�A7B�6D1�0D�D1�D,�,D1)NN)FN)�__name__�
__module__�__qualname__�__doc__r0�propertyr3r5r9r<r>rErT�sendrbrury�sys�version_inforhrr�r�r��rrr%r%Es������#��#��.��.�"�"���-1�,0�:�(�D�15�15�S:�j$K�LK�>����!���&���$�
���=�M�^+�
2rr%c�0��eZdZdZd�fd�	Zd�Zd�Z�xZS)�MySQLUnixSocketzoMySQL socket class using UNIX sockets

    Opens a connection through the UNIX socket of the MySQL Server.
    c�8��tt|��||_y�N)�superr�r0�unix_socket)r/r��	__class__s  �rr0zMySQLUnixSocket.__init__�s���
�o�t�-�/�&��rc��|jSr�)r�r.s rr<zMySQLUnixSocket.get_address�s�����rc���	tjtjtj�|_|jj	|j
�|jj
|j�y#t$r5}tjd|j�t|�f���d}~wt$r#}tjt|���d}~wwxYw)Ni�rH)r?�AF_UNIX�SOCK_STREAMr(�
settimeoutr)�connectr�rNrrir<r�	Exceptionr
)r/rs  rr9zMySQLUnixSocket.open_connection�s���	2��
�
�f�n�n�f�6H�6H�I�D�I��I�I� � ��!9�!9�:��I�I���d�.�.�/���	K��'�'��D�$4�$4�$6��C�8H�#I�K�
K���	2��'�'��C��1�1��	2�s$�BB�	C,�
0B=�=C,�	C'�'C,)z/tmp/mysql.sock�r�r�r�r�r0r<r9�
__classcell__�r�s@rr�r��s����
'� �	2rr�c�0��eZdZdZd�fd�	Zd�Zd�Z�xZS)�MySQLTCPSocketzXMySQL socket class using TCP/IP

    Opens a TCP/IP connection to the MySQL Server.
    c�b��tt|��||_||_||_d|_y)Nr)r�r�r0�server_host�server_port�
force_ipv6�_family)r/�host�portr�r�s    �rr0zMySQLTCPSocket.__init__�s.���
�n�d�,�.�������$�����rc�N�dj|j|j�S)Nz{0}:{1})rr�r�r.s rr<zMySQLTCPSocket.get_address�s!������ 0� 0�$�2B�2B�C�Crc��dgdz}	tj|j|jdtjtj
�}|D]B}|jr|dtjk(r|}n|dtjk(s�@|}n|jr3|d�.tjdj|j���|d�|d}|\|_}}}}	tj|j||�|_|j j#|j$�|j j'|�y#t$r5}tjd|j�t|�f���d}~wwxYw#t$r5}tjd|j�t|�f���d}~wt($r#}tj*t-|���d}~wwxYw)z7Open the TCP/IP connection to the MySQL server
        N�rzNo IPv6 address found for {0}i�rH)r?�getaddrinfor�r�r��SOL_TCPr��AF_INET6�AF_INETrrirr�rNr<rr(r�r)r�r�rOr
)	r/�addrinfo�	addrinfos�info�socktype�proto�_�sockaddrrs	         rr9zMySQLTCPSocket.open_connection�s����6�A�:��	D��*�*�4�+;�+;�+/�+;�+;�+,�f�.@�.@�+1�>�>�;�I�
"���?�?�t�A�w�&�/�/�'A�#�H���!�W����.�#�H��
"����8�A�;�#6��+�+�3�:�:�4�;K�;K�L�N�N���{�"�$�Q�<��
<D�8�T�\�8�U�A�x�	4��
�
�d�l�l�H�e�D�D�I��I�I� � ��!9�!9�:��I�I���h�'���	K��'�'��D�$4�$4�$6��C�8H�#I�K�
K��	K���	K��'�'��D�$4�$4�$6��C�8H�#I�K�
K���	4��)�)�#�c�(�3�3��	4�sD�B
E�AE�/A&F�	F�0F�F�	G?� 0G�G?�G:�:G?)z	127.0.0.1i�Fr�r�s@rr�r��s����
�D�&4rr�)r��collectionsrr?rr�rZr��rr�catch23rrr	rr#�objectr%r�r�r�rr�<module>r�sk��0��
�
�
��	��
 �7�7�K�
� h2�f�h2�\2�o�2�264�_�64��S
	��s�A�A

ZeroDay Forums Mini