;
Ëâ"Ic               @   s7  d  d l  Z d  d l Z d  d l Z d  d l Z d  d l Z d  d l Z d  d l Z d  d l Z d  d l	 m
 Z
 e
 j Z d Z Gd „  d e j ƒ Z Gd „  d e j ƒ Z d „  Z Gd	 „  d
 e j ƒ Z Gd „  d e ƒ Z Gd „  d e j ƒ Z Gd „  d e j ƒ Z d d „ Z e d k o e d d ƒ n d S(   i    N(   u   supports   QUIT
c             B   s&   |  Ee  Z d  Z d „  Z d „  Z d S(   i   c             C   sM   t  j j |  ƒ | |  _ t j t j t j ƒ |  _ t j	 |  j ƒ |  _
 d  S(   N(   u	   threadingu   Threadu   __init__u   eventu   socketu   AF_INETu   SOCK_STREAMu   socku   supportu	   bind_portu   port(   u   selfu   event(    (    u/   /mit/python/lib/python3.0/test/test_asynchat.pyu   __init__   s    	c          
   C   s  |  j  j d ƒ |  j j ƒ  |  j  j ƒ  \ } } d |  _ x@ t |  j k o/ | j d ƒ } | p Pn |  j | |  _ q> W|  j j t d ƒ |  _ yX xQ |  j oF | j	 |  j d  |  j
 … ƒ } t j d ƒ |  j | d  … |  _ qœ WWn Yn X| j ƒ  |  j  j ƒ  d  S(   Ni   s    gü©ñÒMbP?(   u   socku   listenu   eventu   setu   acceptu   bufferu   SERVER_QUITu   recvu   replaceu   sendu
   chunk_sizeu   timeu   sleepu   close(   u   selfu   connu   clientu   datau   n(    (    u/   /mit/python/lib/python3.0/test/test_asynchat.pyu   run   s*    	  

N(   u   __name__u
   __module__u
   chunk_sizeu   __init__u   run(   u
   __locals__(    (    u/   /mit/python/lib/python3.0/test/test_asynchat.pyu   echo_server   s   
	u   echo_serverc             B   sO   |  Ee  Z d  „  Z d „  Z e j d k o d „  Z n d „  Z d „  Z d S(   c             C   s\   t  j j |  ƒ g  |  _ |  j t j t j ƒ |  j t	 | f ƒ |  j
 | ƒ d |  _ d  S(   Ns    (   u   asynchatu
   async_chatu   __init__u   contentsu   create_socketu   socketu   AF_INETu   SOCK_STREAMu   connectu   HOSTu   set_terminatoru   buffer(   u   selfu
   terminatoru   server_port(    (    u/   /mit/python/lib/python3.0/test/test_asynchat.pyu   __init__6   s    	c             C   s   d  S(   N(    (   u   self(    (    u/   /mit/python/lib/python3.0/test/test_asynchat.pyu   handle_connect>   s    u   darwinc             C   s   d  S(   N(    (   u   self(    (    u/   /mit/python/lib/python3.0/test/test_asynchat.pyu   handle_exptD   s    c             C   s   |  j  | 7_  d  S(   N(   u   buffer(   u   selfu   data(    (    u/   /mit/python/lib/python3.0/test/test_asynchat.pyu   collect_incoming_dataG   s    c             C   s    |  j  j |  j ƒ d |  _ d  S(   Ns    (   u   contentsu   appendu   buffer(   u   self(    (    u/   /mit/python/lib/python3.0/test/test_asynchat.pyu   found_terminatorJ   s    N(	   u   __name__u
   __module__u   __init__u   handle_connectu   sysu   platformu   handle_exptu   collect_incoming_datau   found_terminator(   u
   __locals__(    (    u/   /mit/python/lib/python3.0/test/test_asynchat.pyu   echo_client4   s   
			u   echo_clientc              C   sM   t  j ƒ  }  t |  ƒ } | j ƒ  |  j ƒ  |  j ƒ  t j d ƒ | |  f S(   Ng{®Gáz„?(   u	   threadingu   Eventu   echo_serveru   startu   waitu   clearu   timeu   sleep(   u   eventu   s(    (    u/   /mit/python/lib/python3.0/test/test_asynchat.pyu   start_echo_serverO   s    


c             B   s’   |  Ee  Z d Z d  „  Z d „  Z d „  Z d „  Z d „  Z d „  Z	 d „  Z
 d „  Z d „  Z d	 „  Z d
 „  Z d „  Z d „  Z d „  Z d S(   c             C   s   d  S(   N(    (   u   self(    (    u/   /mit/python/lib/python3.0/test/test_asynchat.pyu   setUp\   s    c             C   s   d  S(   N(    (   u   self(    (    u/   /mit/python/lib/python3.0/test/test_asynchat.pyu   tearDown_   s    c             C   sà   t  j ƒ  } t | ƒ } | | _ | j ƒ  | j ƒ  | j ƒ  t j d ƒ t	 | | j
 ƒ } | j d ƒ | j d | ƒ | j d | ƒ | j t ƒ t j d |  j d d d d ƒ | j ƒ  |  j | j d	 d g ƒ d  S(
   Ng{®Gáz„?s   hello s   worlds   I'm not dead yet!u   use_pollu   counti,  u   timeouts   hello world(   u	   threadingu   Eventu   echo_serveru
   chunk_sizeu   startu   waitu   clearu   timeu   sleepu   echo_clientu   portu   pushu   SERVER_QUITu   asyncoreu   loopu   usepollu   joinu   assertEqualu   contents(   u   selfu   termu   server_chunku   eventu   su   c(    (    u/   /mit/python/lib/python3.0/test/test_asynchat.pyu   line_terminator_checkb   s    	



c             C   s%   x d D] } |  j  d | ƒ q Wd  S(   Ni   i   i   s   
(   i   i   i   (   u   line_terminator_check(   u   selfu   l(    (    u/   /mit/python/lib/python3.0/test/test_asynchat.pyu   test_line_terminator1x   s     c             C   s%   x d D] } |  j  d | ƒ q Wd  S(   Ni   i   i   s   
(   i   i   i   (   u   line_terminator_check(   u   selfu   l(    (    u/   /mit/python/lib/python3.0/test/test_asynchat.pyu   test_line_terminator2}   s     c             C   s%   x d D] } |  j  d | ƒ q Wd  S(   Ni   i   i   s   qqq(   i   i   i   (   u   line_terminator_check(   u   selfu   l(    (    u/   /mit/python/lib/python3.0/test/test_asynchat.pyu   test_line_terminator3‚   s     c             C   sŽ   t  ƒ  \ } } t | | j ƒ } d } | j | ƒ | j t ƒ t j d |  j d d d d ƒ | j ƒ  |  j	 | j
 | d  | … g ƒ d  S(   Ns   hello world, I'm not dead yet!
u   use_pollu   counti,  u   timeoutg{®Gáz„?(   u   start_echo_serveru   echo_clientu   portu   pushu   SERVER_QUITu   asyncoreu   loopu   usepollu   joinu   assertEqualu   contents(   u   selfu   termlenu   su   eventu   cu   data(    (    u/   /mit/python/lib/python3.0/test/test_asynchat.pyu   numeric_terminator_check‡   s    
c             C   s   |  j  d ƒ d  S(   Ni   (   u   numeric_terminator_check(   u   self(    (    u/   /mit/python/lib/python3.0/test/test_asynchat.pyu   test_numeric_terminator1“   s    c             C   s   |  j  d ƒ d  S(   Ni   (   u   numeric_terminator_check(   u   self(    (    u/   /mit/python/lib/python3.0/test/test_asynchat.pyu   test_numeric_terminator2˜   s    c             C   s”   t  ƒ  \ } } t d  | j ƒ } d } | j | ƒ | j t ƒ t j d |  j d d d d ƒ | j	 ƒ  |  j
 | j g  ƒ |  j
 | j | ƒ d  S(   Ns   hello world, I'm not dead yet!
u   use_pollu   counti,  u   timeoutg{®Gáz„?(   u   start_echo_serveru   echo_clientu   Noneu   portu   pushu   SERVER_QUITu   asyncoreu   loopu   usepollu   joinu   assertEqualu   contentsu   buffer(   u   selfu   su   eventu   cu   data(    (    u/   /mit/python/lib/python3.0/test/test_asynchat.pyu   test_none_terminator›   s    
c             C   s“   t  ƒ  \ } } t d | j ƒ } d } t j | t d d ƒ} | j | ƒ t j d |  j	 d d d d	 ƒ | j
 ƒ  |  j | j d
 d g ƒ d  S(   Ns   
s   hello world
I'm not dead yet!
u   buffer_sizei   u   use_pollu   counti,  u   timeoutg{®Gáz„?s   hello worlds   I'm not dead yet!(   u   start_echo_serveru   echo_clientu   portu   asynchatu   simple_produceru   SERVER_QUITu   push_with_produceru   asyncoreu   loopu   usepollu   joinu   assertEqualu   contents(   u   selfu   su   eventu   cu   datau   p(    (    u/   /mit/python/lib/python3.0/test/test_asynchat.pyu   test_simple_producer¨   s    
c             C   s~   t  ƒ  \ } } t d | j ƒ } d } | j | t ƒ t j d |  j d d d d ƒ | j ƒ  |  j	 | j
 d d	 g ƒ d  S(
   Ns   
s   hello world
I'm not dead yet!
u   use_pollu   counti,  u   timeoutg{®Gáz„?s   hello worlds   I'm not dead yet!(   u   start_echo_serveru   echo_clientu   portu   push_with_produceru   SERVER_QUITu   asyncoreu   loopu   usepollu   joinu   assertEqualu   contents(   u   selfu   su   eventu   cu   data(    (    u/   /mit/python/lib/python3.0/test/test_asynchat.pyu   test_string_producer³   s    
c             C   s„   t  ƒ  \ } } t d | j ƒ } | j d ƒ | j t ƒ t j d |  j d d d d ƒ | j ƒ  |  j	 | j
 d d	 d
 g ƒ d  S(   Ns   
s   hello world

I'm not dead yet!
u   use_pollu   counti,  u   timeoutg{®Gáz„?s   hello worlds    s   I'm not dead yet!(   u   start_echo_serveru   echo_clientu   portu   pushu   SERVER_QUITu   asyncoreu   loopu   usepollu   joinu   assertEqualu   contents(   u   selfu   su   eventu   c(    (    u/   /mit/python/lib/python3.0/test/test_asynchat.pyu   test_empty_line½   s    
c             C   s¡   t  ƒ  \ } } t d | j ƒ } | j d ƒ | j t ƒ | j ƒ  t j d |  j d d d d ƒ | j	 ƒ  |  j
 | j g  ƒ |  j t | j ƒ d k ƒ d  S(	   Ns   
s   hello world
I'm not dead yet!
u   use_pollu   counti,  u   timeoutg{®Gáz„?i    (   u   start_echo_serveru   echo_clientu   portu   pushu   SERVER_QUITu   close_when_doneu   asyncoreu   loopu   usepollu   joinu   assertEqualu   contentsu
   assertTrueu   lenu   buffer(   u   selfu   su   eventu   c(    (    u/   /mit/python/lib/python3.0/test/test_asynchat.pyu   test_close_when_doneÉ   s    

NF(   u   __name__u
   __module__u   Falseu   usepollu   setUpu   tearDownu   line_terminator_checku   test_line_terminator1u   test_line_terminator2u   test_line_terminator3u   numeric_terminator_checku   test_numeric_terminator1u   test_numeric_terminator2u   test_none_terminatoru   test_simple_produceru   test_string_produceru   test_empty_lineu   test_close_when_done(   u
   __locals__(    (    u/   /mit/python/lib/python3.0/test/test_asynchat.pyu   TestAsynchatY   s   
												
	u   TestAsynchatc             B   s   |  Ee  Z d Z d  S(   NT(   u   __name__u
   __module__u   Trueu   usepoll(   u
   __locals__(    (    u/   /mit/python/lib/python3.0/test/test_asynchat.pyu   TestAsynchat_WithPollÙ   s   
u   TestAsynchat_WithPollc             B   s   |  Ee  Z d  „  Z d S(   c             C   s<   |  j  t j d d ƒ d ƒ |  j  t j d d ƒ d ƒ d  S(   Nu   qwertyu   
i   u
   qwertydkjfi    (   u   assertEqualu   asynchatu   find_prefix_at_end(   u   self(    (    u/   /mit/python/lib/python3.0/test/test_asynchat.pyu   test_find_prefix_at_endÝ   s    N(   u   __name__u
   __module__u   test_find_prefix_at_end(   u
   __locals__(    (    u/   /mit/python/lib/python3.0/test/test_asynchat.pyu   TestHelperFunctionsÜ   s   
u   TestHelperFunctionsc             B   s    |  Ee  Z d  „  Z d „  Z d S(   c             C   s  t  j ƒ  } | j d ƒ | j d ƒ |  j t | ƒ d ƒ |  j | j ƒ  d ƒ |  j | j ƒ  d ƒ |  j t | ƒ d ƒ |  j | j ƒ  d ƒ |  j | j ƒ  d ƒ |  j | j ƒ  d ƒ |  j t | ƒ d ƒ |  j | j ƒ  d	 ƒ |  j | j ƒ  d
 ƒ d  S(   Ni   s   ai   i   i    (   i   i   F(   i   s   aT(   i    N(   u   asynchatu   fifou   pushu   assertEqualu   lenu   firstu   popu   is_emptyu   Falseu   Trueu   None(   u   selfu   f(    (    u/   /mit/python/lib/python3.0/test/test_asynchat.pyu
   test_basicâ   s    c             C   sŠ   t  j d d d g ƒ } |  j t | ƒ d ƒ |  j | j ƒ  d ƒ |  j | j ƒ  d ƒ |  j | j ƒ  d ƒ |  j | j ƒ  d	 ƒ d  S(
   Ns   xi   i   i   i    (   i   s   x(   i   i   (   i   i   (   i    N(   u   asynchatu   fifou   assertEqualu   lenu   popu   None(   u   selfu   f(    (    u/   /mit/python/lib/python3.0/test/test_asynchat.pyu   test_given_listñ   s    N(   u   __name__u
   __module__u
   test_basicu   test_given_list(   u
   __locals__(    (    u/   /mit/python/lib/python3.0/test/test_asynchat.pyu   TestFifoá   s   
	u   TestFifoc             C   s   t  j t t t t ƒ d  S(   N(   u   supportu   run_unittestu   TestAsynchatu   TestAsynchat_WithPollu   TestHelperFunctionsu   TestFifo(   u   verbose(    (    u/   /mit/python/lib/python3.0/test/test_asynchat.pyu	   test_mainú   s    u   __main__u   verboseT(   u   _threadu   threadu   asyncoreu   asynchatu   socketu	   threadingu   timeu   unittestu   sysu   testu   supportu   HOSTu   SERVER_QUITu   Threadu   echo_serveru
   async_chatu   echo_clientu   start_echo_serveru   TestCaseu   TestAsynchatu   TestAsynchat_WithPollu   TestHelperFunctionsu   TestFifou   Noneu	   test_mainu   __name__u   True(    (    (    u/   /mit/python/lib/python3.0/test/test_asynchat.pyu   <module>   s    <	(	
€