File manager

3


 \@,�@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�|_tjj||
|�
dS)N�)�ac_in_buffer�incomingr�
producer_fifo�asyncore�
dispatcher�__init__)�selfZsock�map�r
� /usr/lib64/python3.6/asynchat.pyr
Cs
zasync_chat.__init__cCstd
�
�
dS)Nzmust be implemented in subclass)
�NotImplementedError)r�datar
r
r�collect_incoming_dataQs
z async_chat.collect_incoming_datacCs|jj
|
�

dS)
N)r�append)rrr
r
r�_collect_incoming_dataTs
z!async_chat._collect_incoming_datac
Csd
j|j
�
}
|j
dd�=|
S)Nr)�joinr)r�
dr
r
r�	_get_dataWs


zasync_chat._get_datac

Cstd
�
�
dS)Nzmust be implemented in subclass)
r)
rr
r
r�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)rZtermr
r
r�set_terminator_s




zasync_chat.set_terminatorc


Cs|jS)
N)
r)
rr
r
r�get_terminatorjs
zasync_chat.get_terminatorc
Cs�
y|j|j
�
}
Wn:tk
r$


dStk
rJ
}
z|j�
dSd}~XnXt|
t�rh|jrhtt|j	�}
|j
|
|_
�
xV|j
�
r�t|j
�
}|j�}|s�|j
|j
�

d
|_
qxt|t��
r|}||kr�|j
|j
�

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

|j
|d�|_
d|_|j�
qxt|�
}|j
j|�
}|dk�
rp|dk�
rR|j
|j
d|��

|j
||d�|_
|j�
qxt|j
|�}|�
r�||k�
r�|j
|j
d|��

|j
|d�|_
Pqx|j
|j
�

d
|_
qxWdS)Nrr
�
���)Zrecv�ac_in_buffer_size�BlockingIOError�OSError�handle_errorrrrrrr�lenr!rrrr�find�find_prefix_at_end)rrZwhyZlbr�
nZterminator_len�indexr
r
r�handle_readrsR





















	











zasync_chat.handle_readc


Cs|j�
dS)
N)
�
initiate_send)
rr
r
r�handle_write�s
zasync_chat.handle_writec


Cs|j�
dS)
N)
�close)
rr
r
r�handle_close�s
zasync_chat.handle_closecCs|t|
t
ttf�std
t|
�
��
|j}t|
�
|krdx>tdt|
�
|�D]}|j	j
|
|||��

qBWn|j	j
|
�

|j�
dS)Nz#data argument must be byte-ish (%r)r
)rr�	bytearray�
memoryview�	TypeError�type�ac_out_buffer_sizer(�rangerrr.)rrZsabs�
ir
r
r�push�s








zasync_chat.pushcCs|jj
|
�

|j�
dS)
N)rrr.)rZproducerr
r
r�push_with_producer�s

zasync_chat.push_with_producerc


Csd
S)Nr"r
)
rr
r
r�readable�szasync_chat.readablec


Cs|jp|j
S)
N)r�	connected)
rr
r
r�writable�szasync_chat.writablec

Cs|jj
d�

dS)
N)rr)
rr
r
r�close_when_done�szasync_chat.close_when_donec
Cs
�
x|jo|j
�
r|jd
}
|
s<|jd
=|
dkr<|j�
dS|j}y|
d|�}Wn8tk
r�


|
j�}|r||jj|�

n|jd
=wYnXt|t�r�|j	r�t
||j�}y|j|�
}Wnt
k
r�


|j�
dSX|�
r|t|�
ks�|t|
�
k�
r|
|d�|jd
<n|jd
=dSWdS)Nr
)rr<r1r6r4�more�
appendleftrrrrr�sendr&r'r()r�firstZobsrZnum_sentr
r
rr.�s8




















zasync_chat.initiate_sendc

Cs d
|_|j
dd�=|jj�
dS)Nr)rrr�clear)
rr
r
r�discard_buffers
s

zasync_chat.discard_buffers)NN)�__name__�
__module__�__qualname__r$r6rrr
rrrrr r!r-r/r1r9r:r;r=r>r.rDr
r
r
rr4s*


H(rc@seZ
dZddd�
Zdd�ZdS)�simple_producer�cCs|
|_||_
dS)
N)r�buffer_size)rrrJr
r
rr

s

zsimple_producer.__init__c
CsJt|j
�
|jkr6|j
d|j�}
|j
|jd�|_
|
S|j
}
d
|_
|
SdS)Nr)r(rrJ)r�resultr
r
rr?
s





zsimple_producer.moreN)
rI)rErFrGr
r?r
r
r
rrH
s
rHcCs6t|
�
d
}x$|r0|j
|
d|��
r0|d
8}qW|S)Nr")r(�endswith)ZhaystackZneedle�
lr
r
rr*/
s



r*)r�collectionsrr	rrHr*r
r
r
r�<module>0s

\