ó õ^‚Rc@s dZddlZddlZddlmZddlmZddlmZm Z dej fd„ƒYZ dd 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(t py3kwarning(tfilterwarningstcatch_warningst async_chatcBs¹eZdZdZdZddd„Zd„Zd„Zd„Z d„Z d„Z d„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/lib/python2.7/asynchat.pyR @s   cCstdƒ‚dS(Nsmust be implemented in subclass(tNotImplementedError(R tdata((s/usr/lib/python2.7/asynchat.pytcollect_incoming_dataQscCs|jj|ƒdS(N(Rtappend(R R((s/usr/lib/python2.7/asynchat.pyt_collect_incoming_dataTscCsdj|jƒ}|j2|S(NR(tjoinR(R td((s/usr/lib/python2.7/asynchat.pyt _get_dataWscCstdƒ‚dS(Nsmust be implemented in subclass(R(R ((s/usr/lib/python2.7/asynchat.pytfound_terminator\scCs ||_dS(sRSet the input delimiter. Can be a fixed string of any length, an integer, or NoneN(t terminator(R tterm((s/usr/lib/python2.7/asynchat.pytset_terminator_scCs|jS(N(R(R ((s/usr/lib/python2.7/asynchat.pytget_terminatorcscCs 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 RtwhytlbRtntterminator_lentindex((s/usr/lib/python2.7/asynchat.pyt handle_readksJ            cCs|jƒdS(N(t initiate_send(R ((s/usr/lib/python2.7/asynchat.pyt handle_write­scCs|jƒdS(N(tclose(R ((s/usr/lib/python2.7/asynchat.pyt handle_close°scCsz|j}t|ƒ|kr\xNtdt|ƒ|ƒD]!}|jj||||!ƒq4Wn|jj|ƒ|jƒdS(Ni(tac_out_buffer_sizeR!txrangeRRR-(R Rtsabsti((s/usr/lib/python2.7/asynchat.pytpush³s  "cCs|jj|ƒ|jƒdS(N(RRR-(R tproducer((s/usr/lib/python2.7/asynchat.pytpush_with_producer¼scCsdS(s4predicate for inclusion in the readable for select()i((R ((s/usr/lib/python2.7/asynchat.pytreadableÀscCs|jp|j S(s4predicate for inclusion in the writable for select()(Rt connected(R ((s/usr/lib/python2.7/asynchat.pytwritableÈscCs|jjdƒdS(sAautomatically close this channel once the outgoing queue is emptyN(RRtNone(R ((s/usr/lib/python2.7/asynchat.pytclose_when_doneÌsc Csfx_|jra|jra|jd}|sO|jd=|dkrO|jƒdSn|j}y?tƒ0tr~tddtƒnt |d|ƒ}WdQXWnCt k rÜ|j ƒ}|rÌ|jj |ƒq|jd=qnXy|j |ƒ}Wntjk r|jƒdSX|r]|t|ƒks<|t|ƒkrP|||jd/s  Ç(