Da

✏️ Editing: asynchat.cpython-310.opt-2.pyc

�����P%x��+��������������������@���s\���	�d�dl�Z�d�dlmZ�d�dlmZ�ededd��G�dd��de�j�ZG�d	d
��d
�Zdd��Z	dS�)
�����N)�deque)�warnzlThe asynchat module is deprecated and will be removed in Python 3.12. The recommended replacement is asyncio����)�
stacklevelc�������������������@���s����e�Zd�Z	�dZdZdZdZd'dd�Zdd��Zd	d
��Z	dd��Z
d
d��Zdd��Zdd��Z
dd��Zdd��Zdd��Zdd��Zdd��Zdd��Zdd ��Zd!d"��Zd#d$��Zd%d&��ZdS�)(�
async_chati���r���zlatin-1Nc�����������������C���s(���d|�_�g�|�_t��|�_tj�|�||��d�S��N�����)�ac_in_buffer�incomingr����
producer_fifo�asyncore�
dispatcher�__init__)�self�sock�map��r����./opt/plesk/python/3/lib/python3.10/asynchat.pyr���K���s���zasync_chat.__init__c�����������������C�������t�d���Nzmust be implemented in subclass��NotImplementedError�r����datar���r���r����collect_incoming_dataY�������z async_chat.collect_incoming_datac�����������������C���s���|�j��|��d�S��N)r
����appendr���r���r���r����_collect_incoming_data\���s���z!async_chat._collect_incoming_datac�����������������C���s���d��|�j�}|�jd�d��=�|S�r���)�joinr
���)r����dr���r���r����	_get_data_���s���zasync_chat._get_datac�����������������C���r���r���r����r���r���r���r����found_terminatord���r���zasync_chat.found_terminatorc�����������������C���sD���	�t�|t�r|�jrt||�j�}n
t�|t�r|dk�rtd��||�_d�S�)Nr���z-the number of received bytes must be positive)�
isinstance�str�use_encoding�bytes�encoding�int�
ValueError�
terminator)r���Ztermr���r���r����set_terminatorg���s���
zasync_chat.set_terminatorc�����������������C���s���|�j�S�r���)r+���r"���r���r���r����get_terminatorr���s���zasync_chat.get_terminatorc�����������������C���s���z|���|�j�}W�n�ty���Y�d�S��ty���|�����Y�d�S�w�t|t�r.|�jr.tt|�j	�}|�j
|�|�_
|�j
r�t|�j
�}|����}|sL|��
|�j
��d|�_
n�t|t�r�|}||k�rg|��
|�j
��d|�_
|�j|�|�_np|��
|�j
d�|����|�j
|d���|�_
d|�_|�����nVt|�}|�j
�|�}|dkr�|dkr�|��
|�j
d�|����|�j
||�d���|�_
|�����n+t|�j
|�}|r�||kr�|��
|�j
d�|�����|�j
|�d���|�_
d�S�|��
|�j
��d|�_
|�j
s7d�S�d�S�)Nr���r������)�recv�ac_in_buffer_size�BlockingIOError�OSError�handle_errorr$���r%���r&���r'���r(���r	����lenr-���r���r)���r+���r#����find�find_prefix_at_end)r���r���Zlbr+����nZterminator_len�indexr���r���r����handle_readz���sV����

�zasync_chat.handle_readc�����������������C�������|������d�S�r���)�
initiate_sendr"���r���r���r����handle_write��������zasync_chat.handle_writec�����������������C���r:���r���)�closer"���r���r���r����handle_close����r=���zasync_chat.handle_closec�����������������C���sx���t�|tttf�stdt|���|�j}t|�|kr0tdt|�|�D�]}|�j	�
||||�����q n|�j	�
|��|�����d�S�)Nz#data argument must be byte-ish (%r)r���)r$���r'����	bytearray�
memoryview�	TypeError�type�ac_out_buffer_sizer4����ranger���r���r;���)r���r���Zsabs�ir���r���r����push����s�����zasync_chat.pushc�����������������C���s���|�j��|��|�����d�S�r���)r���r���r;���)r���Zproducerr���r���r����push_with_producer����s���zasync_chat.push_with_producerc�����������������C���s���	�dS��N����r���r"���r���r���r����readable����s���zasync_chat.readablec�����������������C���s���	�|�j�p|�j�S�r���)r����	connectedr"���r���r���r����writable����s���zasync_chat.writablec�����������������C���s���	�|�j��d���d�S�r���)r���r���r"���r���r���r����close_when_done����s���zasync_chat.close_when_donec�����������������C���s��|�j�r�|�jr�|�j�d�}|s|�j�d=�|d�u�r|�����d�S�|�j}z|d�|��}W�n�ty@���|���}|r:|�j��|��n|�j�d=�Y�q�w�t|t�rO|�j	rOt
||�j�}z|��|�}W�n�t
yd���|�����Y�d�S�w�|r�|t|�k�ss|t|�k�r~||d���|�j�d<�d�S�|�j�d=�d�S�d�S�d�S�)Nr���)r���rL���r?���rD���rB����more�
appendleftr$���r%���r&���r'���r(����sendr2���r3���r4���)r����firstZobsr���Znum_sentr���r���r���r;�������s@���
����zasync_chat.initiate_sendc�����������������C���s ���d|�_�|�jd�d��=�|�j����d�S�r���)r	���r
���r����clearr"���r���r���r����discard_buffers��s���zasync_chat.discard_buffers)NN)�__name__�
__module__�__qualname__r0���rD���r&���r(���r���r���r���r!���r#���r,���r-���r9���r<���r?���rG���rH���rK���rM���rN���r;���rT���r���r���r���r���r���<���s.����
H(r���c�������������������@���s���e�Zd�Zddd�Zdd��ZdS�)�simple_producer����c�����������������C���s���||�_�||�_d�S�r���)r����buffer_size)r���r���rZ���r���r���r���r�����s���
zsimple_producer.__init__c�����������������C���sF���t�|�j�|�jkr|�jd�|�j��}|�j|�jd���|�_|S�|�j}d|�_|S�r���)r4���r���rZ���)r����resultr���r���r���rO�����s���zsimple_producer.moreN)rY���)rU���rV���rW���r���rO���r���r���r���r���rX�����s����
rX���c�����������������C���sD���t�|�d�}|r |��|d�|���s |d8�}|r |��|d�|���r|S�rI���)r4����endswith)ZhaystackZneedle�lr���r���r���r6���7��s
����r6���)
r����collectionsr����warningsr����DeprecationWarningr
���r���rX���r6���r���r���r���r����<module>���s�����\

📁 Sid Gifari File Manager