???<!-- GIF89;a -->
123123123123
.....................................................................................................................................???<!-- GIF89;a -->
123123123123
.....................................................................................................................................ž
«ÿfD-  c               @   s}   d  Z  d d l Z d d l Z d d l m Z Gd d „  d e j ƒ Z Gd d „  d ƒ Z Gd d	 „  d	 ƒ Z d
 d „  Z	 d S(   u¥  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(   u   dequec             B   s  |  Ee  Z d  Z d Z d Z d Z d Z d Z d' d' d d „ Z	 d d „  Z
 d	 d
 „  Z d d „  Z d d „  Z d d „  Z d d „  Z d d „  Z d d „  Z d d „  Z d d „  Z d d „  Z d d „  Z d d  „  Z d! d" „  Z d# d$ „  Z d% d& „  Z d' S((   u
   async_chatu‡   This is an abstract class.  You must derive from this class, and add
    the two methods collect_incoming_data() and found_terminator()i   i    u   latin-1c             C   s8   d |  _  g  |  _ t ƒ  |  _ t j j |  | | ƒ d  S(   Ns    (   u   ac_in_bufferu   incomingu   dequeu   producer_fifou   asyncoreu
   dispatcheru   __init__(   u   selfu   socku   map(    (    u-   /opt/alt/python33/lib64/python3.3/asynchat.pyu   __init__D   s    		u   async_chat.__init__c             C   s   t  d ƒ ‚ d  S(   Nu   must be implemented in subclass(   u   NotImplementedError(   u   selfu   data(    (    u-   /opt/alt/python33/lib64/python3.3/asynchat.pyu   collect_incoming_dataR   s    u    async_chat.collect_incoming_datac             C   s   |  j  j | ƒ d  S(   N(   u   incomingu   append(   u   selfu   data(    (    u-   /opt/alt/python33/lib64/python3.3/asynchat.pyu   _collect_incoming_dataU   s    u!   async_chat._collect_incoming_datac             C   s&   d j  |  j ƒ } |  j d  d  … =| S(   Ns    (   u   joinu   incoming(   u   selfu   d(    (    u-   /opt/alt/python33/lib64/python3.3/asynchat.pyu	   _get_dataX   s    u   async_chat._get_datac             C   s   t  d ƒ ‚ d  S(   Nu   must be implemented in subclass(   u   NotImplementedError(   u   self(    (    u-   /opt/alt/python33/lib64/python3.3/asynchat.pyu   found_terminator]   s    u   async_chat.found_terminatorc             C   s:   t  | t ƒ r- |  j r- t | |  j ƒ } n  | |  _ d S(   uR   Set the input delimiter.  Can be a fixed string of any length, an integer, or NoneN(   u
   isinstanceu   stru   use_encodingu   bytesu   encodingu
   terminator(   u   selfu   term(    (    u-   /opt/alt/python33/lib64/python3.3/asynchat.pyu   set_terminator`   s    u   async_chat.set_terminatorc             C   s   |  j  S(   N(   u
   terminator(   u   self(    (    u-   /opt/alt/python33/lib64/python3.3/asynchat.pyu   get_terminatorf   s    u   async_chat.get_terminatorc             C   s`  y |  j  |  j ƒ } Wn6 t j k
 rN } z |  j ƒ  d  SWYd  d  } ~ Xn Xt | t ƒ r| |  j r| t t |  j	 ƒ } n  |  j
 | |  _
 xÍ|  j
 r[t |  j
 ƒ } |  j ƒ  } | sÕ |  j |  j
 ƒ d |  _
 q t | t ƒ rh| } | | k  r"|  j |  j
 ƒ d |  _
 |  j | |  _ qX|  j |  j
 d  | … ƒ |  j
 | d  … |  _
 d |  _ |  j ƒ  q t | ƒ } |  j
 j | ƒ } | d k râ| d k r»|  j |  j
 d  | … ƒ n  |  j
 | | d  … |  _
 |  j ƒ  q t |  j
 | ƒ } | r?| | k r;|  j |  j
 d  | … ƒ |  j
 | d  … |  _
 n  Pq |  j |  j
 ƒ d |  _
 q Wd  S(   Ns    i    i   iÿÿÿÿ(   u   recvu   ac_in_buffer_sizeu   socketu   erroru   handle_erroru
   isinstanceu   stru   use_encodingu   bytesu   encodingu   ac_in_bufferu   lenu   get_terminatoru   collect_incoming_datau   intu
   terminatoru   found_terminatoru   findu   find_prefix_at_end(   u   selfu   datau   whyu   lbu
   terminatoru   nu   terminator_lenu   index(    (    u-   /opt/alt/python33/lib64/python3.3/asynchat.pyu   handle_readn   sN    
			u   async_chat.handle_readc             C   s   |  j  ƒ  d  S(   N(   u   initiate_send(   u   self(    (    u-   /opt/alt/python33/lib64/python3.3/asynchat.pyu   handle_write²   s    u   async_chat.handle_writec             C   s   |  j  ƒ  d  S(   N(   u   close(   u   self(    (    u-   /opt/alt/python33/lib64/python3.3/asynchat.pyu   handle_closeµ   s    u   async_chat.handle_closec             C   s}   |  j  } t | ƒ | k r_ xQ t d t | ƒ | ƒ D]$ } |  j j | | | | … ƒ q4 Wn |  j j | ƒ |  j ƒ  d  S(   Ni    (   u   ac_out_buffer_sizeu   lenu   rangeu   producer_fifou   appendu   initiate_send(   u   selfu   datau   sabsu   i(    (    u-   /opt/alt/python33/lib64/python3.3/asynchat.pyu   push¸   s    	%u   async_chat.pushc             C   s   |  j  j | ƒ |  j ƒ  d  S(   N(   u   producer_fifou   appendu   initiate_send(   u   selfu   producer(    (    u-   /opt/alt/python33/lib64/python3.3/asynchat.pyu   push_with_producerÁ   s    u   async_chat.push_with_producerc             C   s   d S(   u4   predicate for inclusion in the readable for select()i   (    (   u   self(    (    u-   /opt/alt/python33/lib64/python3.3/asynchat.pyu   readableÅ   s    u   async_chat.readablec             C   s   |  j  p |  j S(   u4   predicate for inclusion in the writable for select()(   u   producer_fifou	   connected(   u   self(    (    u-   /opt/alt/python33/lib64/python3.3/asynchat.pyu   writableÍ   s    u   async_chat.writablec             C   s   |  j  j d ƒ d S(   uA   automatically close this channel once the outgoing queue is emptyN(   u   producer_fifou   appendu   None(   u   self(    (    u-   /opt/alt/python33/lib64/python3.3/asynchat.pyu   close_when_doneÑ   s    u   async_chat.close_when_donec             C   ss  xl|  j  rn|  j rn|  j  d } | sO |  j  d =| d  k rO |  j ƒ  d  Sn  |  j } y | d  | … } WnD t k
 r² | j ƒ  } | r¡ |  j  j | ƒ n
 |  j  d =w Yn Xt | t	 ƒ rà |  j
 rà t | |  j ƒ } n  y |  j | ƒ } Wn# t j k
 r|  j ƒ  d  SYn X| rj| t | ƒ k  sC| t | ƒ k  r]| | d  … |  j  d <qj|  j  d =n  d  SWd  S(   Ni    (   u   producer_fifou	   connectedu   Noneu   handle_closeu   ac_out_buffer_sizeu	   TypeErroru   moreu
   appendleftu
   isinstanceu   stru   use_encodingu   bytesu   encodingu   sendu   socketu   erroru   handle_erroru   len(   u   selfu   firstu   obsu   datau   num_sent(    (    u-   /opt/alt/python33/lib64/python3.3/asynchat.pyu   initiate_sendÕ   s8    

	

	$u   async_chat.initiate_sendc             C   s*   d |  _  |  j d  d  … =|  j j ƒ  d  S(   Ns    (   u   ac_in_bufferu   incomingu   producer_fifou   clear(   u   self(    (    u-   /opt/alt/python33/lib64/python3.3/asynchat.pyu   discard_buffersÿ   s    	u   async_chat.discard_buffersN(   u   __name__u
   __module__u   __qualname__u   __doc__u   ac_in_buffer_sizeu   ac_out_buffer_sizeu   use_encodingu   encodingu   Noneu   __init__u   collect_incoming_datau   _collect_incoming_datau	   _get_datau   found_terminatoru   set_terminatoru   get_terminatoru   handle_readu   handle_writeu   handle_closeu   pushu   push_with_produceru   readableu   writableu   close_when_doneu   initiate_sendu   discard_buffers(   u
   __locals__(    (    u-   /opt/alt/python33/lib64/python3.3/asynchat.pyu
   async_chat5   s,   D	*u
   async_chatc             B   s/   |  Ee  Z d  Z d d d „ Z d d „  Z d S(   u   simple_produceri   c             C   s   | |  _  | |  _ d  S(   N(   u   datau   buffer_size(   u   selfu   datau   buffer_size(    (    u-   /opt/alt/python33/lib64/python3.3/asynchat.pyu   __init__  s    	u   simple_producer.__init__c             C   se   t  |  j ƒ |  j k rK |  j d  |  j … } |  j |  j d  … |  _ | S|  j } d |  _ | Sd  S(   Ns    (   u   lenu   datau   buffer_size(   u   selfu   result(    (    u-   /opt/alt/python33/lib64/python3.3/asynchat.pyu   more  s    		u   simple_producer.moreN(   u   __name__u
   __module__u   __qualname__u   __init__u   more(   u
   __locals__(    (    u-   /opt/alt/python33/lib64/python3.3/asynchat.pyu   simple_producer  s   u   simple_producerc             B   s_   |  Ee  Z d  Z d d d „ Z d d „  Z d d „  Z d d „  Z d	 d
 „  Z d d „  Z	 d S(   u   fifoc             C   s(   | s t  ƒ  |  _ n t  | ƒ |  _ d  S(   N(   u   dequeu   list(   u   selfu   list(    (    u-   /opt/alt/python33/lib64/python3.3/asynchat.pyu   __init__  s    u   fifo.__init__c             C   s   t  |  j ƒ S(   N(   u   lenu   list(   u   self(    (    u-   /opt/alt/python33/lib64/python3.3/asynchat.pyu   __len__  s    u   fifo.__len__c             C   s   |  j  S(   N(   u   list(   u   self(    (    u-   /opt/alt/python33/lib64/python3.3/asynchat.pyu   is_empty  s    u   fifo.is_emptyc             C   s   |  j  d S(   Ni    (   u   list(   u   self(    (    u-   /opt/alt/python33/lib64/python3.3/asynchat.pyu   first"  s    u
   fifo.firstc             C   s   |  j  j | ƒ d  S(   N(   u   listu   append(   u   selfu   data(    (    u-   /opt/alt/python33/lib64/python3.3/asynchat.pyu   push%  s    u	   fifo.pushc             C   s$   |  j  r d |  j  j ƒ  f Sd Sd  S(   Ni   i    (   i    N(   u   listu   popleftu   None(   u   self(    (    u-   /opt/alt/python33/lib64/python3.3/asynchat.pyu   pop(  s    	u   fifo.popN(
   u   __name__u
   __module__u   __qualname__u   Noneu   __init__u   __len__u   is_emptyu   firstu   pushu   pop(   u
   __locals__(    (    u-   /opt/alt/python33/lib64/python3.3/asynchat.pyu   fifo  s   u   fifoc             C   sE   t  | ƒ d } x. | r@ |  j | d  | … ƒ r@ | d 8} q W| S(   Ni   (   u   lenu   endswith(   u   haystacku   needleu   l(    (    u-   /opt/alt/python33/lib64/python3.3/asynchat.pyu   find_prefix_at_end=  s    #u   find_prefix_at_end(
   u   __doc__u   socketu   asyncoreu   collectionsu   dequeu
   dispatcheru
   async_chatu   simple_produceru   fifou   find_prefix_at_end(    (    (    u-   /opt/alt/python33/lib64/python3.3/asynchat.pyu   <module>/   s   Ð(