�
q�fc@s�dZd
dl
Z
d
dlZd
dlmZ
d
dlmZ
d
dlmZm	Z	
dej
f
d��YZdd
d	��YZd
dd��YZ
d�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.pyR@s		
cCstd
�
�
dS(Nsmust be implemented in subclass(
tNotImplementedError(Rtdata((s /usr/lib64/python2.7/asynchat.pytcollect_incoming_dataQs
cCs|jj
|
�

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


c

Cstd
�
�
dS(Nsmust be implemented in subclass(
R(
R((s /usr/lib64/python2.7/asynchat.pytfound_terminator\s
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_terminator_sc


Cs|jS(
N(
R(
R((s /usr/lib64/python2.7/asynchat.pytget_terminatorcs
c
Cs	y|j|j
�
}
Wn!tjk
r9
}
|j�
dSX|j|
|_x�
|jrt|j�
}|j�}|s�|j|j�

d
|_qMt	|t
�s�t	|t�r)
|}||kr�|j|j�

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

|j||_d|_|j
�
qMt|�
}|jj|�
}|dkr�
|dkrv
|j|j| �

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

|j||_nPqM|j|j�

d
|_qMWdS(NRii����(trecvtac_in_buffer_sizetsocketterrorthandle_errorRtlenRRt
isinstancetinttlongRRtfindtfind_prefix_at_end(RRtwhytlbRt
ntterminator_lentindex((s /usr/lib64/python2.7/asynchat.pythandle_readksJ












	


	

	








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(RR9R;R0R1RR
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__RR1R;RRRRRRRR,R.R0R5R7R8R:R<R-RH(((s /usr/lib64/python2.7/asynchat.pyR7s(
							B									(tsimple_producercBseZ
dd
�
Zd�ZRS(icCs|
|_||_
dS(
N(Rtbuffer_size(RRRM((s /usr/lib64/python2.7/asynchat.pyR
s
	
c
CsYt|j
�
|jkr?|j
|j }
|j
|j|_
|
S|j
}
d
|_
|
SdS(NR(R!RRM(Rtresult((s /usr/lib64/python2.7/asynchat.pyRA
s



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

c

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


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

Cs|jd
S(Ni(
RP(
R((s /usr/lib64/python2.7/asynchat.pyRD
s
cCs|jj
|
�

dS(
N(RPR(RR((s /usr/lib64/python2.7/asynchat.pyR5
s
c

Cs$|jrd
|jj
�fSdSdS(Ni
i(iN(RPtpopleftR;(
R((s /usr/lib64/python2.7/asynchat.pytpop!
s
	
N(	RIRJR;RRQRRRDR5RT(((s /usr/lib64/python2.7/asynchat.pyRO
s
				cCs?t|
�
d
}x(|r:|j
|
| �
r:|d
8}qW|S(Ni
(R!tendswith(thaystacktneedlet
l((s /usr/lib64/python2.7/asynchat.pyR&6
s



(((RKRR	tcollectionsRtsysR
twarningsRRR
RRLROR&(((s /usr/lib64/python2.7/asynchat.pyt<module>/s



�(