File manager

U

i�f@,�@s@dd
lZddl
mZ
Gdd�dej�ZGdd�d�Zdd�Zd
S)	�N)
�dequec@s�eZ
dZd
Zd
ZdZdZd'dd�
Zdd�Zd	d
�Z	dd�Z
d
d�Zdd�Zdd�Z
dd�Zdd�Zdd�Zdd�Zdd�Zdd�Zdd �Zd!d"�Zd#d$�Zd%d&�ZdS)(�
async_chati
r
zlatin-1NcCs(d
|_g|_
t�|_tj�||
|�
dS�N�)�ac_in_buffer�incomingr�
producer_fifo�asyncore�
dispatcher�__init__)�selfZsock�map�r�-/opt/alt/python38/lib64/python3.8/asynchat.pyrCs
zasync_chat.__init__cCstd
�
�
dS�Nzmust be implemented in subclass�
�NotImplementedError�r�datarrr�collect_incoming_dataQs
z async_chat.collect_incoming_datacCs|j�
|
�

dS�
N)r�appendrrrr�_collect_incoming_dataTs
z!async_chat._collect_incoming_datac
Csd
�|j
�
}
|j
dd�=|
Sr)�joinr)r�
drrr�	_get_dataWs


zasync_chat._get_datac

Cstd
�
�
dSrr�
rrrr�found_terminator\s
zasync_chat.found_terminatorcCsBt|
t
�r|jrt|
|j�}
nt|
t�r8|
d
kr8td�
�
|
|_dS)Nr
z-the number of received bytes must be positive)�
isinstance�str�use_encoding�bytes�encoding�int�
ValueError�
terminator)rZtermrrr�set_terminator_s




zasync_chat.set_terminatorc


Cs|jSr)
r%rrrr�get_terminatorjs
zasync_chat.get_terminatorc

Cs�
z|�|j
�
}
WnDtk
r&


YdStk
rT
}
z|��
WY�dSd}~XYnXt|
t�rr|jrrtt|j	�}
|j
|
|_
|j
�
r�t|j
�
}|��}|s�|�
|j
�

d
|_
q~t|t��
r|}||kr�|�
|j
�

d
|_
|j||_n2|�
|j
d|��

|j
|d�|_
d|_|��
q~t|�
}|j
�|�
}|dk�
rv|dk�
rX|�
|j
d|��

|j
||d�|_
|��
q~t|j
|�}|�
r�||k�
r�|�
|j
d|��

|j
|d�|_
�
q�q~|�
|j
�

d
|_
q~dS)Nrr
���)Zrecv�ac_in_buffer_size�BlockingIOError�OSError�handle_errorrrr r!r"r�lenr'rr#r%r�find�find_prefix_at_end)rrZwhyZlbr%�
nZterminator_len�indexrrr�handle_readrsR





















	











zasync_chat.handle_readc

Cs|��
dSr)
�
initiate_sendrrrr�handle_write�s
zasync_chat.handle_writec

Cs|��
dSr)
�closerrrr�handle_close�s
zasync_chat.handle_closecCsxt|
t
ttf�std
t|
�
��
|j}t|
�
|kr`tdt|
�
|�D]}|j	�
|
|||��

q@n|j	�
|
�

|��
dS)Nz#data argument must be byte-ish (%r)r
)rr!�	bytearray�
memoryview�	TypeError�type�ac_out_buffer_sizer-�rangerrr3)rrZsabs�
irrr�push�s


�



zasync_chat.pushcCs|j�
|
�

|��
dSr)rrr3)rZproducerrrr�push_with_producer�s

zasync_chat.push_with_producerc


Csd
S�N�
rrrrr�readable�szasync_chat.readablec


Cs|jp|j
Sr)r�	connectedrrrr�writable�szasync_chat.writablec

Cs|j�
d�

dSr)rrrrrr�close_when_done�szasync_chat.close_when_donec
Cs
|j�
r|j
�
r|jd
}
|
s:|jd
=|
dkr:|��
dS|j}z|
d|�}Wn:tk
r�


|
��}|rz|j�|�

n|jd
=YqYnXt|t�r�|j	r�t
||j�}z|�|�
}Wnt
k
r�


|��
YdSX|�
r|t|�
ks�|t|
�
k�
r
|
|d�|jd
<n|jd
=dSdS)Nr
)rrCr6r;r9�more�
appendleftrrr r!r"�sendr+r,r-)r�firstZobsrZnum_sentrrrr3�s8





















zasync_chat.initiate_sendc

Cs d
|_|j
dd�=|j��
dSr)rrr�clearrrrr�discard_buffers
s

zasync_chat.discard_buffers)NN)�__name__�
__module__�__qualname__r)r;r r"rrrrrr&r'r2r4r6r>r?rBrDrEr3rKrrrrr4s*


H(rc@seZ
dZddd�
Zdd�ZdS)�simple_producer�cCs|
|_||_
dSr)r�buffer_size)rrrQrrrr
s

zsimple_producer.__init__c
CsJt|j
�
|jkr6|j
d|j�}
|j
|jd�|_
|
S|j
}
d
|_
|
SdSr)r-rrQ)r�resultrrrrF
s





zsimple_producer.moreN)
rP)rLrMrNrrFrrrrrO
s
rOcCs0t|
�
d
}|r,|�
|
d|��
s,|d
8}q|Sr@)r-�endswith)ZhaystackZneedle�
lrrrr//
s




r/)r	�collectionsrr
rrOr/rrrr�<module>0s

\