;
Ëâ"Ic               @   s¸  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	 d  d l
 m Z m Z m Z d  d l m Z d  d l m Z e	 j Z Gd „  d ƒ Z Gd „  d	 ƒ Z Gd
 „  d ƒ Z Gd „  d ƒ Z d „  Z Gd „  d e j ƒ Z Gd „  d e j ƒ Z Gd „  d e  j ƒ Z Gd „  d e j ƒ Z Gd „  d e ƒ Z e e  d ƒ o Gd „  d e j ƒ Z n d „  Z  e! d k o e  ƒ  n d S(   i    N(   u   support(   u   TESTFNu   run_unittestu   unlink(   u   BytesIO(   u   StringIOc             B   s)   |  Ee  Z d  „  Z d „  Z d „  Z d S(   c             C   s   d |  _ d  S(   NF(   u   Falseu   closed(   u   self(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   __init__   s    c             C   s   d |  _ d  S(   NT(   u   Trueu   closed(   u   self(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   close   s    c             C   s   d S(   Ni*   (    (   u   self(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   fileno   s    N(   u   __name__u
   __module__u   __init__u   closeu   fileno(   u
   __locals__(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   dummysocket   s   
		u   dummysocketc             B   s    |  Ee  Z d  „  Z d „  Z d S(   c             C   s   t  ƒ  |  _ d  S(   N(   u   dummysocketu   socket(   u   self(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   __init__   s    c             C   s   |  j  j ƒ  d  S(   N(   u   socketu   close(   u   self(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   close   s    N(   u   __name__u
   __module__u   __init__u   close(   u
   __locals__(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   dummychannel   s   
	u   dummychannelc             B   s2   |  Ee  Z d  „  Z d „  Z e Z e Z e Z d S(   c             C   s   d  S(   N(    (   u   self(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   __init__#   s    c             C   s   t  j ƒ  ‚ d  S(   N(   u   asyncoreu   ExitNow(   u   self(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   handle_read_event&   s    N(   u   __name__u
   __module__u   __init__u   handle_read_eventu   handle_write_eventu   handle_closeu   handle_expt_event(   u
   __locals__(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   exitingdummy"   s
   
		u   exitingdummyc             B   s;   |  Ee  Z d  „  Z d „  Z e Z e Z e Z d „  Z d S(   c             C   s   d |  _ d  S(   NF(   u   Falseu   error_handled(   u   self(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   __init__.   s    c             C   s   t  ƒ  ‚ d  S(   N(   u	   Exception(   u   self(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   handle_read_event1   s    c             C   s   d |  _ d  S(   NT(   u   Trueu   error_handled(   u   self(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   handle_error8   s    N(   u   __name__u
   __module__u   __init__u   handle_read_eventu   handle_write_eventu   handle_closeu   handle_expt_eventu   handle_error(   u
   __locals__(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   crashingdummy-   s   
		u   crashingdummyc       
      C   sÿ   zã y# | j  d ƒ | j ƒ  \ } } Wn t j k
 o Yn¤ Xd } x | d k o t j | g g  g  ƒ \ } } } | o> | j d ƒ }	 | j |	 j d d ƒ ƒ d |	 k o Pq¼ n | d 8} t j	 d ƒ qI W| j
 ƒ  Wd  | j
 ƒ  |  j ƒ  Xd  S(	   Ni   iÈ   i    i
   s   
s    i   g{®Gáz„?(   u   listenu   acceptu   socketu   timeoutu   selectu   recvu   writeu   replaceu   timeu   sleepu   closeu   set(
   u   evtu   bufu   servu   connu   addru   nu   ru   wu   eu   data(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   capture_server<   s(      !	

c             B   sX   |  Ee  Z d  „  Z e e d ƒ o d „  Z n d „  Z d „  Z d „  Z d „  Z	 d S(   c             C   sÓ   t  ƒ  } |  j t j t j | ƒ |  j t j t j | ƒ |  j t j t j | ƒ t ƒ  } t j | ƒ |  j | j	 d ƒ t ƒ  } t j | ƒ |  j | j	 d ƒ t ƒ  } t j | ƒ |  j | j	 d ƒ d  S(   NT(   u   exitingdummyu   assertRaisesu   asyncoreu   ExitNowu   readu   writeu
   _exceptionu   crashingdummyu   assertEqualu   error_handledu   True(   u   selfu   tr1u   tr2(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   test_readwriteexcV   s    				u   pollc             C   s9  Gd „  d ƒ } xª t  j t  j f D]– } | ƒ  } |  j | j d ƒ t j | | ƒ |  j | j d ƒ t	 ƒ  } |  j
 t j t j | | ƒ t ƒ  } t j | | ƒ |  j | j d ƒ q# W| ƒ  } |  j | j d ƒ t j | t  j ƒ |  j | j d ƒ t	 ƒ  } |  j
 t j t j | t  j ƒ t ƒ  } t j | t  j ƒ |  j | j d ƒ xÜ t  j t  j t  j f D]Â } | ƒ  } |  j | j | j f | t  j k d ƒ t j | | ƒ |  j | j | j f | t  j k d ƒ t	 ƒ  } |  j
 t j t j | | ƒ t ƒ  } t j | | ƒ |  j | j d ƒ qoWd  S(   Nc             B   sD   |  Ee  Z d  „  Z d „  Z d „  Z d „  Z d „  Z d „  Z d S(   c             S   s(   d |  _ d |  _ d |  _ d |  _ d  S(   NF(   u   Falseu   readu   writeu   closedu   expt(   u   self(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   __init__x   s    			c             S   s   d |  _ d  S(   NT(   u   Trueu   read(   u   self(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   handle_read_event~   s    c             S   s   d |  _ d  S(   NT(   u   Trueu   write(   u   self(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   handle_write_event   s    c             S   s   d |  _ d  S(   NT(   u   Trueu   closed(   u   self(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   handle_close„   s    c             S   s   d |  _ d  S(   NT(   u   Trueu   expt(   u   self(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   handle_expt_event‡   s    c             S   s   d |  _ d  S(   NT(   u   Trueu   error_handled(   u   self(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   handle_errorŠ   s    N(   u   __name__u
   __module__u   __init__u   handle_read_eventu   handle_write_eventu   handle_closeu   handle_expt_eventu   handle_error(   u
   __locals__(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   testobjw   s   
					u   testobjFT(   u   selectu   POLLINu   POLLPRIu   assertEqualu   readu   Falseu   asyncoreu	   readwriteu   Trueu   exitingdummyu   assertRaisesu   ExitNowu   crashingdummyu   error_handledu   writeu   POLLOUTu   POLLERRu   POLLHUPu   POLLNVALu   exptu   closed(   u   selfu   testobju   flagu   tobju   tr1u   tr2(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   test_readwritet   sB     					
	 	))		c             C   s   |  j  d ƒ d  S(   NF(   u   closeall_checku   False(   u   self(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   test_closeallÀ   s    c             C   s   |  j  d ƒ d  S(   NT(   u   closeall_checku   True(   u   self(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   test_closeall_defaultÃ   s    c             C   sé   g  } i  } xJ t  d ƒ D]< } t ƒ  } | j | ƒ |  j | j j d ƒ | | | <q W| o; t j } z | t _ t j	 ƒ  Wd  t j | } t _ Xn t j	 | ƒ |  j t
 | ƒ d ƒ x$ | D] } |  j | j j d ƒ qÅ Wd  S(   Ni
   i    FT(   u   rangeu   dummychannelu   appendu   assertEqualu   socketu   closedu   Falseu   asyncoreu
   socket_mapu	   close_allu   lenu   True(   u   selfu
   usedefaultu   lu   testmapu   iu   cu	   socketmap(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   closeall_checkÆ   s&     			 c             C   sÕ   y t  d ƒ ‚ Wn) t j ƒ  \ } } } t j ƒ  } Yn X|  j d ƒ | \ \ } } } } }	 }
 |  j t j j	 | ƒ d d ƒ |  j | d ƒ |  j | | ƒ |  j |	 | ƒ |  j |
 d | | | f ƒ d  S(   Nu   I don't like spam!u   Expected exceptioniÿÿÿÿu   test_asyncore.pyu   test_compact_tracebacku
   [%s|%s|%s](
   u	   Exceptionu   sysu   exc_infou   asyncoreu   compact_tracebacku   failu   assertEqualu   osu   pathu   split(   u   selfu   real_tu   real_vu   real_tbu   ru   fu   functionu   lineu   tu   vu   info(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   test_compact_tracebackà   s     N(
   u   __name__u
   __module__u   test_readwriteexcu   hasattru   selectu   test_readwriteu   test_closeallu   test_closeall_defaultu   closeall_checku   test_compact_traceback(   u
   __locals__(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   HelperFunctionTestsU   s   
	L			u   HelperFunctionTestsc             B   sM   |  Ee  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_asyncore.pyu   setUpò   s    c             C   s   t  j ƒ  d  S(   N(   u   asyncoreu	   close_all(   u   self(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   tearDownõ   s    c             C   s<   t  j ƒ  } |  j | j ƒ  d ƒ |  j | j ƒ  d ƒ d  S(   NT(   u   asyncoreu
   dispatcheru   assertEqualu   readableu   Trueu   writable(   u   selfu   d(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu
   test_basicø   s    c             C   s0   t  j ƒ  } |  j t | ƒ d t | ƒ ƒ d  S(   Nu   <asyncore.dispatcher at %#x>(   u   asyncoreu
   dispatcheru   assertEqualu   repru   id(   u   selfu   d(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu	   test_reprý   s    c             C   s’   t  j ƒ  } t ƒ  } t j } d } d } z' | t _ | j | ƒ | j | ƒ Wd  | t _ X| j ƒ  j ƒ  } |  j | d | d | g ƒ d  S(   Nu   Lovely spam! Wonderful spam!u   I don't like spam!u   log: %s(	   u   asyncoreu
   dispatcheru   StringIOu   sysu   stderru   logu   getvalueu
   splitlinesu   assertEquals(   u   selfu   du   fpu   stderru   l1u   l2u   lines(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   test_log  s    			
c       	   
   C   s¸   t  j ƒ  } t ƒ  } t j } d } d } d } z: | t _ | j | d ƒ | j | ƒ | j | d ƒ Wd  | t _ X| j ƒ  j ƒ  } d | d | d | g } |  j | | ƒ d  S(	   Nu#   Have you got anything without spam?u.   Why can't she have egg bacon spam and sausage?u   THAT'S got spam in it!u   EGGSu   SPAMu   EGGS: %su   info: %su   SPAM: %s(	   u   asyncoreu
   dispatcheru   StringIOu   sysu   stdoutu   log_infou   getvalueu
   splitlinesu   assertEquals(	   u   selfu   du   fpu   stdoutu   l1u   l2u   l3u   linesu   expected(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   test_log_info  s    			
c             C   s¥   t  j ƒ  } t ƒ  } t j } z? | t _ | j ƒ  | j ƒ  | j ƒ  | j ƒ  | j	 ƒ  Wd  | t _ X| j
 ƒ  j ƒ  } d d d d d g } |  j | | ƒ d  S(   Nu   warning: unhandled exceptionu   warning: unhandled read eventu   warning: unhandled write eventu    warning: unhandled connect eventu   warning: unhandled accept event(   u   asyncoreu
   dispatcheru   StringIOu   sysu   stdoutu   handle_exptu   handle_readu   handle_writeu   handle_connectu   handle_acceptu   getvalueu
   splitlinesu   assertEquals(   u   selfu   du   fpu   stdoutu   linesu   expected(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   test_unhandled,  s$    			




	N(	   u   __name__u
   __module__u   setUpu   tearDownu
   test_basicu	   test_repru   test_logu   test_log_infou   test_unhandled(   u
   __locals__(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   DispatcherTestsñ   s   
						u   DispatcherTestsc             B   s    |  Ee  Z d  „  Z d „  Z d S(   c             C   s   d S(   NF(   u   False(   u   self(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   readableG  s    c             C   s   d  S(   N(    (   u   self(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   handle_connectJ  s    N(   u   __name__u
   __module__u   readableu   handle_connect(   u
   __locals__(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   dispatcherwithsend_noreadF  s   
	u   dispatcherwithsend_noreadc             B   s/   |  Ee  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_asyncore.pyu   setUpP  s    c             C   s   t  j ƒ  d  S(   N(   u   asyncoreu	   close_all(   u   self(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   tearDownS  s    c             C   si  t  j ƒ  |  _ t j t j t j ƒ |  _ |  j j d ƒ t j	 |  j ƒ |  _
 t ƒ  } |  j | |  j f } t  j d t d | ƒ j ƒ  t j d ƒ d } t ƒ  } | j t j t j ƒ | j t |  j
 f ƒ t j d ƒ | j | ƒ | j | ƒ | j d ƒ d } x0 | j o% | d	 k o t j ƒ  | d
 8} qW|  j j ƒ  |  j | j ƒ  | d ƒ d  S(   Ni   u   targetu   argsgš™™™™™É?s$   Suppose there isn't a 16-ton weight?gš™™™™™¹?s   
iè  i    i   i   (   u	   threadingu   Eventu   evtu   socketu   AF_INETu   SOCK_STREAMu   socku
   settimeoutu   supportu	   bind_portu   portu   BytesIOu   Threadu   capture_serveru   startu   timeu   sleepu   dispatcherwithsend_noreadu   create_socketu   connectu   HOSTu   sendu
   out_bufferu   asyncoreu   pollu   waitu   assertEqualu   getvalue(   u   selfu   capu   argsu   datau   du   n(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu	   test_sendV  s.    		 
NF(   u   __name__u
   __module__u   Falseu   usepollu   setUpu   tearDownu	   test_send(   u
   __locals__(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   DispatcherWithSendTestsM  s   
		u   DispatcherWithSendTestsc             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_asyncore.pyu   DispatcherWithSendTests_UsePollz  s   
u   DispatcherWithSendTests_UsePollu   file_wrapperc             B   s2   |  Ee  Z d  „  Z d „  Z d „  Z d „  Z d S(   c             C   s&   d |  _  t t d ƒ j |  j  ƒ d  S(   Ns   It's not dead, it's sleeping!u   wb(   u   du   openu   TESTFNu   write(   u   self(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   setUp  s    	c             C   s   t  t ƒ d  S(   N(   u   unlinku   TESTFN(   u   self(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   tearDownƒ  s    c             C   s°   t  j t t  j ƒ } t j | ƒ } t  j | ƒ |  j | j | ƒ |  j | j	 ƒ  | ƒ |  j
 | j d ƒ d ƒ |  j
 | j d ƒ d ƒ | j ƒ  |  j t | j d ƒ d  S(   Ni   s   It's not deadi   s   , it'si   (   u   osu   openu   TESTFNu   O_RDONLYu   asyncoreu   file_wrapperu   closeu   assertNotEqualu   fdu   filenou   assertEqualu   recvu   readu   assertRaisesu   OSError(   u   selfu   fdu   w(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu	   test_recv†  s    
c             C   s–   d } d } t  j t t  j t  j Bƒ } t j | ƒ } t  j | ƒ | j | ƒ | j	 | ƒ | j ƒ  |  j
 t t d ƒ j ƒ  |  j | | ƒ d  S(   Ns   Come again?s   I want to buy some cheese.u   rb(   u   osu   openu   TESTFNu   O_WRONLYu   O_APPENDu   asyncoreu   file_wrapperu   closeu   writeu   sendu   assertEqualu   readu   d(   u   selfu   d1u   d2u   fdu   w(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu	   test_send’  s    
N(   u   __name__u
   __module__u   setUpu   tearDownu	   test_recvu	   test_send(   u
   __locals__(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   FileWrapperTest~  s   
			u   FileWrapperTestc              C   sA   t  t t t g }  t t d ƒ o |  j t ƒ n t |  Œ  d  S(   Nu   file_wrapper(	   u   HelperFunctionTestsu   DispatcherTestsu   DispatcherWithSendTestsu   DispatcherWithSendTests_UsePollu   hasattru   asyncoreu   appendu   FileWrapperTestu   run_unittest(   u   tests(    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu	   test_mainŸ  s
    		u   __main__("   u   asyncoreu   unittestu   selectu   osu   socketu	   threadingu   sysu   timeu   testu   supportu   test.supportu   TESTFNu   run_unittestu   unlinku   iou   BytesIOu   StringIOu   HOSTu   dummysocketu   dummychannelu   exitingdummyu   crashingdummyu   capture_serveru   TestCaseu   HelperFunctionTestsu   DispatcherTestsu   dispatcher_with_sendu   dispatcherwithsend_noreadu   DispatcherWithSendTestsu   DispatcherWithSendTests_UsePollu   hasattru   FileWrapperTestu	   test_mainu   __name__(    (    (    u/   /mit/python/lib/python3.0/test/test_asyncore.pyu   <module>   s6   	
	œU-!	