File manager

�
zfc@s�dZd
dl
Z
d
dlZd
dlZd
dlmZ
d
dlmZ
d
dlm	Z	m
Z

ejejej
ejfZde
jf
d��YZdd
d	��YZd
dd��YZd�ZdS(s�A class supporting chat-style (command/response) protocols.

This class adds support for 'chat' style protocols - where one side
sends a 'command', and the other sends a response (examples would be
the common internet protocols - smtp, nntp, ftp, etc..).

The handle_read() method looks at the input stream for the current
'terminator' (usually '\r\n' for single-line responses, '\r\n.\r\n'
for multi-line output), calling self.found_terminator() on its
receipt.

for example:
Say you build an async nntp client using this class.  At the start
of the connection, you'll have self.terminator set to '\r\n', in
order to process the single-line greeting.  Just before issuing a
'LIST' command you'll set it to '\r\n.\r\n'.  The output of the LIST
command will be accumulated (using your own 'collect_incoming_data'
method) up to the terminator, and then control will be returned to
you - by calling your self.found_terminator() method.
i����N(
tdeque(
tpy3kwarning(tfilterwarningstcatch_warningst
async_chatcBs�eZ
dZd
Zd
Zddd�Zd�Zd�Zd�Z	d�Z
d�Zd�Zd	�Z
d
�Zd�Zd�Zd
�Zd�Zd�Zd�Zd�Zd�ZRS(s�This is an abstract class.  You must derive from this class, and add
    the two methods collect_incoming_data() and found_terminator()icCs8d
|_g|_
t�|_tjj||
|�
dS(Nt(tac_in_buffertincomingRt
producer_fifotasyncoret
dispatchert__init__(tselftsocktmap((s /usr/lib64/python2.7/asynchat.pyREs		
cCstd
�
�
dS(Nsmust be implemented in subclass(
tNotImplementedError(Rtdata((s /usr/lib64/python2.7/asynchat.pytcollect_incoming_dataVs
cCs|jj
|
�

dS(
N(Rtappend(RR((s /usr/lib64/python2.7/asynchat.pyt_collect_incoming_dataYs
c
Csd
j|j
�
}
|j
2|
S(NR(tjoinR(Rt
d((s /usr/lib64/python2.7/asynchat.pyt	_get_data\s


c

Cstd
�
�
dS(Nsmust be implemented in subclass(
R(
R((s /usr/lib64/python2.7/asynchat.pytfound_terminatoras
cCs
|
|_d
S(sRSet the input delimiter.  Can be a fixed string of any length, an integer, or NoneN(
t
terminator(Rtterm((s /usr/lib64/python2.7/asynchat.pytset_terminatordsc


Cs|jS(
N(
R(
R((s /usr/lib64/python2.7/asynchat.pytget_terminatorhs
c
Csy|j|j
�
}
Wn8tjk
rP
}
|jd
tkrBdS|j�
dSX|j|
|_x�
|jrt|j�
}|j	�}|s�|j
|j�

d|_qdt|tt
f�r7
|}||kr�|j
|j�

d|_|j||_q|j
|j| �

|j||_d
|_|j�
qdt|�
}|jj|�
}|dkr�
|d
kr�
|j
|j| �

n|j|||_|j�
qdt|j|�}|r�
||kr�
|j
|j| �

|j||_nPqd|j
|j�

d|_qdWdS(NiRi����(trecvtac_in_buffer_sizetsocketterrortargst_BLOCKING_IO_ERRORSthandle_errorRtlenRRt
isinstancetinttlongRRtfindtfind_prefix_at_end(RRtwhytlbRt
ntterminator_lentindex((s /usr/lib64/python2.7/asynchat.pythandle_readpsN














	


	

	








c


Cs|j�
dS(
N(
t
initiate_send(
R((s /usr/lib64/python2.7/asynchat.pythandle_write�s
c


Cs|j�
dS(
N(
tclose(
R((s /usr/lib64/python2.7/asynchat.pythandle_close�s
cCsz|j}t
|
�
|kr\xNtd
t
|
�
|�D]!}|jj|
|||!�

q4Wn|jj|
�

|j�
dS(Ni(tac_out_buffer_sizeR#txrangeRRR/(RRtsabst
i((s /usr/lib64/python2.7/asynchat.pytpush�s
	


"
cCs|jj
|
�

|j�
dS(
N(RRR/(Rtproducer((s /usr/lib64/python2.7/asynchat.pytpush_with_producer�s

c


Csd
S(s4predicate for inclusion in the readable for select()i
((
R((s /usr/lib64/python2.7/asynchat.pytreadable�sc


Cs|jp|j
S(
s4predicate for inclusion in the writable for select()(Rt	connected(
R((s /usr/lib64/python2.7/asynchat.pytwritable�sc

Cs|jj
d
�

d
S(sAautomatically close this channel once the outgoing queue is emptyN(RRtNone(
R((s /usr/lib64/python2.7/asynchat.pytclose_when_done�sc
Csf
x_
|jra
|j
ra
|jd
}
|
sO|jd
=|
dkrO|j�
dSn|j}y?t��0
tr~tddt�
nt	|
d
|�}WdQXWnCt
k
r�


|
j�}|r�|jj|�

q|jd
=qn
Xy|j
|�
}Wntjk
r



|j�
dSX|r]
|t|�
ks<
|t|
�
krP
|
||jd
<q]
|jd
=ndSWdS(Nitignores.*buffer(RR;R=R2R3RR
RtDeprecationWarningtbuffert	TypeErrortmoret
appendlefttsendRRR"R#(RtfirsttobsRtnum_sent((s /usr/lib64/python2.7/asynchat.pyR/�s:








	


















$

c

Cs!d
|_|j
2|jj�
dS(NR(RRRtclear(
R((s /usr/lib64/python2.7/asynchat.pytdiscard_buffers�s	

N(t__name__t
__module__t__doc__RR3R=RRRRRRRR.R0R2R7R9R:R<R>R/RJ(((s /usr/lib64/python2.7/asynchat.pyR<s(
							D									(tsimple_producercBseZ
dd
�
Zd�ZRS(icCs|
|_||_
dS(
N(Rtbuffer_size(RRRO((s /usr/lib64/python2.7/asynchat.pyR
s
	
c
CsYt|j
�
|jkr?|j
|j }
|j
|j|_
|
S|j
}
d
|_
|
SdS(NR(R#RRO(Rtresult((s /usr/lib64/python2.7/asynchat.pyRC
s



	
	
(RKRLRRC(((s /usr/lib64/python2.7/asynchat.pyRN
stfifocBsAeZ
dd�
Zd
�Zd�Zd�Zd�Zd�ZRS(cCs(|
st�|_
nt|
�
|_
dS(
N(Rtlist(RRR((s /usr/lib64/python2.7/asynchat.pyR
s

c

Cs
t|j
�
S(
N(R#RR(
R((s /usr/lib64/python2.7/asynchat.pyt__len__
s
c


Cs|jS(
N(
RR(
R((s /usr/lib64/python2.7/asynchat.pytis_empty
s
c

Cs|jd
S(Ni(
RR(
R((s /usr/lib64/python2.7/asynchat.pyRF"
s
cCs|jj
|
�

dS(
N(RRR(RR((s /usr/lib64/python2.7/asynchat.pyR7%
s
c

Cs$|jrd
|jj
�fSdSdS(Ni
i(iN(RRtpopleftR=(
R((s /usr/lib64/python2.7/asynchat.pytpop(
s
	
N(	RKRLR=RRSRTRFR7RV(((s /usr/lib64/python2.7/asynchat.pyRQ
s
				cCs?t|
�
d
}x(|r:|j
|
| �
r:|d
8}qW|S(Ni
(R#tendswith(thaystacktneedlet
l((s /usr/lib64/python2.7/asynchat.pyR(=
s



(((RMR	terrnoRtcollectionsRtsysR
twarningsRRtEAGAINtEALREADYtEINPROGRESStEWOULDBLOCKR!R
RRNRQR((((s /usr/lib64/python2.7/asynchat.pyt<module>/s





�(