;
Ìâ"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	 Z	 d  d l
 Z
 d  d l Z d  d l Z d  d l Z y d  d l Z WnC e k
 o7 Z z! d  d l m Z e e ƒ ‚ WYd d Z [ Xn Xd  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 „  Z e j Z d Z dk Z  e  o dl \ Z! Z" Z# n dm \ Z! Z" Z# e$ e d	 dk ƒ Z% Gd
 „  d e& ƒ Z' Gd „  d e& ƒ Z( d „  Z) Gd „  d e( ƒ Z* Gd „  d e j+ ƒ Z, Gd „  d e( ƒ Z- d „  Z. d „  Z/ Gd „  d e( ƒ Z0 Gd „  d e( ƒ Z1 Gd „  d e( ƒ Z2 Gd „  d e( ƒ Z3 Gd „  d  e( ƒ Z4 Gd! „  d" e( ƒ Z5 Gd# „  d$ e( ƒ Z6 Gd% „  d& e( ƒ Z7 d' d( „ Z8 Gd) „  d* e( ƒ Z9 Gd+ „  d, e( ƒ Z: d  d- l m; Z; m< Z< m= Z= Gd. „  d/ e& ƒ Z> d0 „  Z? Gd1 „  d2 e< ƒ Z@ Gd3 „  d4 e; ƒ ZA eA jB d5 d6 e> ƒeA jB d7 d6 e> d8 dn ƒeA jB d; d6 e? d< e@ ƒGd= „  d> e( ƒ ZC e jD ƒ  ZE d? „  ZF Gd@ „  dA e; ƒ ZG eG jB dB d6 eF ƒGdC „  dD e; ƒ ZH eH jB dB ƒ dE ZI GdF „  dG e( ƒ ZJ e dH ƒ ZK GdI „  dJ e( ƒ ZL GdK „  dL e( ƒ ZM GdM „  dN e( ƒ ZN y, d  dO lO mP ZP mQ ZQ m
 Z
 mR ZR mS ZS Wn$ e k
 o e& ZP d ZR ZS Yn XGdP „  dQ eP ƒ ZU GdR „  dS e( ƒ ZV GdT „  dU e( ƒ ZW GdV „  dW e( ƒ ZX GdX „  dY e( ƒ ZY dZ „  ZZ d[ „  Z[ Gd\ „  d] e& ƒ Z\ e[ e\ d^ d_ ƒZ] e^ ƒ  j_ e] ƒ Gd` „  da e& ƒ Z` e[ e` d^ db ƒZa e^ ƒ  j_ ea ƒ Gdc „  dd e& ƒ Zb e[ eb d^ de ƒZc e^ ƒ  j_ ec ƒ Gdf „  dg e  jd ƒ Ze ee g Zf d dh „ Zg di „  Zh ei dj k o eh ƒ  n d S(o   i    N(   u   TestSkipped(   u   utilc             C   s   |  j  d ƒ S(   Nu   latin(   u   encode(   u   s(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   latin*   s    gš™™™™™¹?g=
×£p=ê?gffffffÖ?gffffffö?u   HAVE_BROKEN_SEM_GETVALUEc             B   s    |  Ee  Z d  „  Z d „  Z d S(   c             C   s   | |  _  d  |  _ d  S(   N(   u   funcu   Noneu   elapsed(   u   selfu   func(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   __init__G   s    	c          	   O   s;   t  j  ƒ  } z |  j | | Ž  SWd  t  j  ƒ  | |  _ Xd  S(   N(   u   timeu   funcu   elapsed(   u   selfu   argsu   kwdsu   t(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   __call__K   s    N(   u   __name__u
   __module__u   __init__u   __call__(   u
   __locals__(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   TimingWrapperE   s   
	u   TimingWrapperc             B   s&   |  Ee  Z d Z d „  Z d „  Z d S(   u	   processesu   manageru   threadsc             C   s"   t  o |  j | | d ƒ n d  S(   Ni   (   u   CHECK_TIMINGSu   assertAlmostEqual(   u   selfu   au   b(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   assertTimingAlmostEqualZ   s    c          	   G   s;   y | | Œ  } Wn t  k
 o Yn X|  j | | ƒ Sd  S(   N(   u   NotImplementedErroru   assertEqual(   u   selfu   valueu   funcu   argsu   res(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   assertReturnsIfImplemented^   s
    N(   u	   processesu   manageru   threads(   u   __name__u
   __module__u   ALLOWED_TYPESu   assertTimingAlmostEqualu   assertReturnsIfImplemented(   u
   __locals__(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   BaseTestCaseV   s   
	u   BaseTestCasec             C   ss   y |  j  ƒ  SWn^ t k
 oR y |  j SWn< t k
 o0 y |  j SWn t k
 o t ‚ Yn XYn XYn Xd  S(   N(   u	   get_valueu   AttributeErroru   _Semaphore__valueu   _valueu   NotImplementedError(   u   self(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu	   get_valuej   s    c             B   se   |  Ee  Z d Z d „  Z d „  Z d „  Z d „  Z d „  Z d „  Z d „  Z	 d	 „  Z
 d
 „  Z d S(   u	   processesu   threadsc             C   s­   |  j  d k o d  S|  j ƒ  } | j } |  j | j ƒ  ƒ |  j | j ƒ |  j t | t ƒ ƒ |  j t | ƒ d k ƒ |  j	 | j
 t j ƒ  ƒ |  j	 | j d  ƒ d  S(   Nu   threadsi    (   u   TYPEu   current_processu   authkeyu
   assertTrueu   is_aliveu   daemonu
   isinstanceu   bytesu   lenu   assertEqualu   identu   osu   getpidu   exitcodeu   None(   u   selfu   currentu   authkey(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_current~   s    	c             O   st   |  j  ƒ  } | j | ƒ | j | ƒ | j | j ƒ |  j d k o* | j t | j ƒ ƒ | j | j ƒ n d  S(   Nu   threads(   u   current_processu   putu   nameu   TYPEu   bytesu   authkeyu   pid(   u   selfu   qu   argsu   kwdsu   current(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   _testŒ   s    c          	   C   sO  |  j  d ƒ } |  j ƒ  } | d d f } i d d 6d d 6} d } |  j d |  j d	 | d
 | d | ƒ } d | _ |  j ƒ  } |  j d k o |  j | j	 | j	 ƒ n |  j | j
 ƒ  d ƒ |  j | j d ƒ |  j | |  j ƒ  k ƒ |  j t |  j ƒ  ƒ t k ƒ |  j | j d  ƒ | j ƒ  |  j | j d  ƒ |  j | j
 ƒ  d ƒ |  j | |  j ƒ  k ƒ |  j | j ƒ  | d d  … ƒ |  j | j ƒ  | ƒ |  j | j ƒ  | j ƒ |  j d k o6 |  j | j ƒ  | j	 ƒ |  j | j ƒ  | j ƒ n | j ƒ  |  j | j d ƒ |  j | j
 ƒ  d ƒ |  j | |  j ƒ  k ƒ d  S(   Ni   i   i   u   hellogR¸…ëQ@u   byeu   SomeProcessu   targetu   argsu   kwargsu   nameu   threadsi    TF(   u   Queueu   Eventu   Processu   _testu   Trueu   daemonu   current_processu   TYPEu   assertEqualsu   authkeyu   is_aliveu   Falseu
   assertTrueu   active_childrenu   typeu   listu   assertEqualu   exitcodeu   Noneu   startu   getu   nameu   pidu   join(   u   selfu   qu   eu   argsu   kwargsu   nameu   pu   current(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_process•   s<    		
 
c             C   s   t  j d ƒ d  S(   Niè  (   u   timeu   sleep(   u   self(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   _test_terminate¼   s    c             C   sû   |  j  d k o d  S|  j d |  j ƒ } d | _ | j ƒ  |  j | j ƒ  d ƒ |  j | |  j	 ƒ  k ƒ |  j | j
 d  ƒ | j ƒ  t | j ƒ } |  j | ƒ  d  ƒ |  j | j d ƒ |  j | j ƒ  d ƒ |  j | |  j	 ƒ  k ƒ | j ƒ  d  S(   Nu   threadsu   targetg        TF(   u   TYPEu   Processu   _test_terminateu   Trueu   daemonu   startu   assertEqualu   is_aliveu
   assertTrueu   active_childrenu   exitcodeu   Noneu	   terminateu   TimingWrapperu   joinu   assertTimingAlmostEqualu   elapsedu   False(   u   selfu   pu   join(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_terminate¿   s    	

c          	   C   s]   y t  j ƒ  } Wn t k
 o d } Yn X|  j t | ƒ t k ƒ |  j | d k ƒ d  S(   Ni   (   u   multiprocessingu	   cpu_countu   NotImplementedErroru
   assertTrueu   typeu   int(   u   selfu   cpus(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_cpu_countÙ   s    c             C   s   |  j  t |  j ƒ  ƒ t ƒ |  j d t j d t f ƒ } |  j | |  j ƒ  k ƒ | j	 ƒ  |  j | |  j ƒ  k ƒ | j
 ƒ  |  j | |  j ƒ  k ƒ d  S(   Nu   targetu   args(   u   assertEqualu   typeu   active_childrenu   listu   Processu   timeu   sleepu   DELTAu
   assertTrueu   startu   join(   u   selfu   p(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_active_childrená   s    

c          	   C   s‹   d d l  m } | j | ƒ t | ƒ d k  oW xT t d ƒ D]B } |  j d |  j d | | | g f ƒ } | j ƒ  | j ƒ  q= Wn d  S(   Ni    (   u   forkingi   u   targetu   args(	   u   multiprocessingu   forkingu   sendu   lenu   rangeu   Processu   _test_recursionu   startu   join(   u   selfu   wconnu   idu   forkingu   iu   p(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   _test_recursioní   s     	
c             C   s°   |  j  d d ƒ \ } } |  j | g  ƒ t j t ƒ g  } x% | j ƒ  o | j | j ƒ  ƒ q> Wg  d g d d g d d g d g d d g d d g g } |  j	 | | ƒ d  S(   Nu   duplexi    i   F(
   u   Pipeu   Falseu   _test_recursionu   timeu   sleepu   DELTAu   pollu   appendu   recvu   assertEqual(   u   selfu   rconnu   wconnu   resultu   expected(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_recursionø   s     			N(   u	   processesu   threads(   u   __name__u
   __module__u   ALLOWED_TYPESu   test_currentu   _testu   test_processu   _test_terminateu   test_terminateu   test_cpu_countu   test_active_childrenu   _test_recursionu   test_recursion(   u
   __locals__(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   _TestProcessz   s   
				'					u   _TestProcessc             B   s2   |  Ee  Z d  „  Z d „  Z d „  Z d „  Z d S(   c             C   s,   t  j j |  ƒ t  j ƒ  \ |  _ |  _ d  S(   N(   u   multiprocessingu   Processu   __init__u   Pipeu
   child_connu   parent_conn(   u   self(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   __init__  s    c             C   sT   |  j  j ƒ  x3 t |  j j d  ƒ D] } |  j j | j ƒ  ƒ q# W|  j j ƒ  d  S(   N(   u   parent_connu   closeu   iteru
   child_connu   recvu   Noneu   sendu   upper(   u   selfu   s(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   run  s
     c             C   s   |  j  j | ƒ |  j  j ƒ  S(   N(   u   parent_connu   sendu   recv(   u   selfu   s(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   submit  s    c             C   s.   |  j  j d  ƒ |  j  j ƒ  |  j j ƒ  d  S(   N(   u   parent_connu   sendu   Noneu   closeu
   child_conn(   u   self(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   stop!  s    N(   u   __name__u
   __module__u   __init__u   runu   submitu   stop(   u
   __locals__(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   _UpperCaser  s   
			u   _UpperCaserc             B   s   |  Ee  Z d Z d „  Z d S(   u	   processesc             C   s]   t  ƒ  } | j ƒ  |  j | j d ƒ d ƒ |  j | j d ƒ d ƒ | j ƒ  | j ƒ  d  S(   Nu   hellou   HELLOu   worldu   WORLD(   u   _UpperCaseru   startu   assertEqualu   submitu   stopu   join(   u   selfu
   uppercaser(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_subclassing*  s    	

N(   u	   processes(   u   __name__u
   __module__u   ALLOWED_TYPESu   test_subclassing(   u
   __locals__(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   _TestSubclassingProcess&  s   
u   _TestSubclassingProcessc             C   s/   t  |  d ƒ o |  j ƒ  S|  j ƒ  d k Sd  S(   Nu   emptyi    (   u   hasattru   emptyu   qsize(   u   q(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   queue_empty6  s    c             C   s/   t  |  d ƒ o |  j ƒ  S|  j ƒ  | k Sd  S(   Nu   full(   u   hasattru   fullu   qsize(   u   qu   maxsize(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu
   queue_full<  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	 S(
   c             C   s9   | j  ƒ  x t d ƒ D] } | j ƒ  q W| j ƒ  d  S(   Ni   (   u   waitu   rangeu   getu   set(   u   selfu   queueu   child_can_startu   parent_can_continueu   i(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu	   _test_putF  s
    
 c             C   sµ  d } |  j  d | ƒ } |  j ƒ  } |  j ƒ  } |  j d |  j d | | | f ƒ } d | _ | j ƒ  |  j t | ƒ d ƒ |  j t	 | | ƒ d ƒ | j d ƒ | j d d ƒ | j d d d  ƒ | j d d ƒ | j d	 d d  ƒ | j d ƒ t j t ƒ |  j t | ƒ d ƒ |  j t	 | | ƒ d ƒ t | j ƒ } t | j ƒ } |  j t j | d
 d ƒ |  j | j d ƒ |  j t j | d
 d d  ƒ |  j | j d ƒ |  j t j | d
 ƒ |  j | j d ƒ |  j t j | d
 d t ƒ |  j | j t ƒ |  j t j | d
 d t ƒ |  j | j d ƒ |  j t j | d
 d d t ƒ|  j | j t ƒ | j ƒ  | j ƒ  |  j t | ƒ d ƒ |  j t	 | | ƒ d ƒ | j ƒ  d  S(   Ni   u   maxsizeu   targetu   argsi   i   i   i   i   i   i    u   timeoutTF(   u   Queueu   Eventu   Processu	   _test_putu   Trueu   daemonu   startu   assertEqualu   queue_emptyu
   queue_fullu   Falseu   putu   Noneu
   put_nowaitu   timeu   sleepu   DELTAu   TimingWrapperu   assertRaisesu   pyqueueu   Fullu   assertTimingAlmostEqualu   elapsedu   TIMEOUT1u   TIMEOUT2u   TIMEOUT3u   setu   waitu   join(   u   selfu   MAXSIZEu   queueu   child_can_startu   parent_can_continueu   procu   putu
   put_nowait(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_putL  sN    			


c             C   sL   | j  ƒ  | j d ƒ | j d ƒ | j d ƒ | j d ƒ | j ƒ  d  S(   Ni   i   i   i   (   u   waitu   putu   set(   u   selfu   queueu   child_can_startu   parent_can_continue(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu	   _test_get†  s    
c             C   sP  |  j  ƒ  } |  j ƒ  } |  j ƒ  } |  j d |  j d | | | f ƒ } d
 | _ | j ƒ  |  j t | ƒ d
 ƒ | j	 ƒ  | j
 ƒ  t j t ƒ |  j t | ƒ d ƒ |  j | j d
 d  ƒ d ƒ |  j | j d
 ƒ d ƒ |  j | j d d ƒ d ƒ |  j | j ƒ  d ƒ |  j t | ƒ d
 ƒ t | j ƒ } t | j ƒ } |  j t j | d ƒ |  j | j d	 ƒ |  j t j | d d  ƒ |  j | j d	 ƒ |  j t j | ƒ |  j | j d	 ƒ |  j t j | d
 t ƒ |  j | j t ƒ |  j t j | d t ƒ |  j | j d	 ƒ |  j t j | d t ƒ|  j | j t ƒ | j ƒ  d  S(   Nu   targetu   argsi   i   u   timeouti   i   i   i    TF(   u   Queueu   Eventu   Processu	   _test_getu   Trueu   daemonu   startu   assertEqualu   queue_emptyu   setu   waitu   timeu   sleepu   DELTAu   Falseu   getu   Noneu
   get_nowaitu   TimingWrapperu   assertRaisesu   pyqueueu   Emptyu   assertTimingAlmostEqualu   elapsedu   TIMEOUT1u   TIMEOUT2u   TIMEOUT3u   join(   u   selfu   queueu   child_can_startu   parent_can_continueu   procu   getu
   get_nowait(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_get  sB    			


c             C   s+   x$ t  d d ƒ D] } | j | ƒ q Wd  S(   Ni
   i   (   u   rangeu   put(   u   selfu   queueu   i(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu
   _test_forkÃ  s     c             C   s¹   |  j  ƒ  } x! t d ƒ D] } | j | ƒ q Wt j t ƒ |  j d |  j d | f ƒ } | j ƒ  x* t d ƒ D] } |  j	 | j
 ƒ  | ƒ qr W|  j t j | j
 d ƒ | j ƒ  d  S(   Ni
   u   targetu   argsi   F(   u   Queueu   rangeu   putu   timeu   sleepu   DELTAu   Processu
   _test_forku   startu   assertEqualu   getu   assertRaisesu   pyqueueu   Emptyu   Falseu   join(   u   selfu   queueu   iu   p(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu	   test_forkÊ  s     
 c          	   C   sË   |  j  ƒ  } y |  j | j ƒ  d ƒ Wn t k
 o d  SYn X| j d ƒ |  j | j ƒ  d ƒ | j d ƒ |  j | j ƒ  d ƒ | j ƒ  |  j | j ƒ  d ƒ | j ƒ  |  j | j ƒ  d ƒ d  S(   Ni    i   i   i   (   u   Queueu   assertEqualu   qsizeu   NotImplementedErroru   putu   get(   u   selfu   q(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu
   test_qsizeä  s    


c             C   s8   x1 t  | j d  ƒ D] } t j t ƒ | j ƒ  q Wd  S(   N(   u   iteru   getu   Noneu   timeu   sleepu   DELTAu	   task_done(   u   selfu   qu   obj(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   _test_task_doneó  s     c          	      s×   ˆ  j  ƒ  ‰ t j d k  o t ˆ d ƒ o d  S‡  ‡ f d †  t d ƒ Dƒ } x | D] } | j ƒ  qX Wx! t d ƒ D] } ˆ j | ƒ qy Wˆ j ƒ  x | D] } ˆ j d  ƒ q¡ Wx | D] } | j ƒ  q¿ Wd  S(   Ni   i   u	   task_donec                s3   g  } |  ]% } | ˆ  j  d  ˆ  j d ˆ f ƒ q
 S(   u   targetu   args(   u   Processu   _test_task_done(   u   .0u   _[1]u   i(   u   selfu   queue(    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu
   <listcomp>þ  s   i   i
   (   i   i   (	   u   JoinableQueueu   sysu   version_infou   hasattru   rangeu   startu   putu   joinu   None(   u   selfu   workersu   pu   i(    (   u   selfu   queueu6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_task_doneø  s$    !  
  N(   u   __name__u
   __module__u	   _test_putu   test_putu	   _test_getu   test_getu
   _test_forku	   test_forku
   test_qsizeu   _test_task_doneu   test_task_done(   u
   __locals__(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu
   _TestQueueC  s   
		:			4				u
   _TestQueuec             B   s    |  Ee  Z d  „  Z d „  Z d S(   c             C   sq   |  j  ƒ  } |  j | j ƒ  d ƒ |  j | j d ƒ d ƒ |  j | j ƒ  d  ƒ |  j t t	 j
 f | j ƒ d  S(   NTF(   u   Locku   assertEqualu   acquireu   Trueu   Falseu   releaseu   Noneu   assertRaisesu
   ValueErroru	   threadingu   ThreadError(   u   selfu   lock(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu	   test_lock  s
    c             C   s­   |  j  ƒ  } |  j | j ƒ  d ƒ |  j | j ƒ  d ƒ |  j | j ƒ  d ƒ |  j | j ƒ  d  ƒ |  j | j ƒ  d  ƒ |  j | j ƒ  d  ƒ |  j t t f | j ƒ d  S(   NT(	   u   RLocku   assertEqualu   acquireu   Trueu   releaseu   Noneu   assertRaisesu   AssertionErroru   RuntimeError(   u   selfu   lock(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu
   test_rlock  s    N(   u   __name__u
   __module__u	   test_locku
   test_rlock(   u
   __locals__(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu	   _TestLock  s   
	u	   _TestLockc             B   s2   |  Ee  Z d  „  Z d „  Z d „  Z d „  Z d S(   c             C   sç   |  j  d t | ƒ |  j | j ƒ  d ƒ |  j  d t | ƒ |  j | j ƒ  d ƒ |  j  d t | ƒ |  j | j d ƒ d ƒ |  j  d t | ƒ |  j | j ƒ  d  ƒ |  j  d t | ƒ |  j | j ƒ  d  ƒ |  j  d t | ƒ d  S(   Ni   i   i    TF(   u   assertReturnsIfImplementedu	   get_valueu   assertEqualu   acquireu   Trueu   Falseu   releaseu   None(   u   selfu   sem(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   _test_semaphore)  s    c             C   sr   |  j  d ƒ } |  j | ƒ |  j | j ƒ  d  ƒ |  j d t | ƒ |  j | j ƒ  d  ƒ |  j d t | ƒ d  S(   Ni   i   i   (   u	   Semaphoreu   _test_semaphoreu   assertEqualu   releaseu   Noneu   assertReturnsIfImplementedu	   get_value(   u   selfu   sem(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_semaphore6  s    c             C   s    |  j  d ƒ } |  j | ƒ d  S(   Ni   (   u   BoundedSemaphoreu   _test_semaphore(   u   selfu   sem(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_bounded_semaphore>  s    c             C   s  |  j  d k o d  S|  j d ƒ } t | j ƒ } |  j | d ƒ d ƒ |  j | j d ƒ |  j | d d  ƒ d ƒ |  j | j d ƒ |  j | d t	 ƒ d ƒ |  j | j d ƒ |  j | d t ƒ d ƒ |  j | j t ƒ |  j | d t ƒ d ƒ |  j | j t ƒ d  S(   Nu	   processesi    g        u   timeoutFT(   u   TYPEu	   Semaphoreu   TimingWrapperu   acquireu   assertEqualu   Falseu   assertTimingAlmostEqualu   elapsedu   Noneu   TIMEOUT1u   Trueu   TIMEOUT2u   TIMEOUT3(   u   selfu   semu   acquire(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_timeoutF  s    N(   u   __name__u
   __module__u   _test_semaphoreu   test_semaphoreu   test_bounded_semaphoreu   test_timeout(   u
   __locals__(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   _TestSemaphore'  s   
			u   _TestSemaphorec             B   s>   |  Ee  Z d d  „ Z d „  Z d „  Z d „  Z d „  Z d S(   c             C   s9   | j  ƒ  | j ƒ  | j | ƒ | j ƒ  | j ƒ  d  S(   N(   u   acquireu   releaseu   wait(   u   selfu   condu   sleepingu   wokenu   timeout(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   f_  s
    


c          	   C   sx   |  j  d k od yI | j j ƒ  | j j ƒ  } |  j | d ƒ |  j | j j ƒ  d ƒ Wqt t k
 o Yqt Xn d  S(   Nu	   processesi    (   u   TYPEu   _sleeping_countu	   get_valueu   _woken_countu   assertEqualu   _wait_semaphoreu   NotImplementedError(   u   selfu   condu   sleepers(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   check_invariantf  s    c             C   sc  |  j  ƒ  } |  j d ƒ } |  j d ƒ } |  j d |  j d | | | f ƒ } d | _ | j ƒ  t j d |  j d | | | f ƒ } d | _ | j ƒ  | j	 ƒ  | j	 ƒ  t
 j t ƒ |  j d t | ƒ | j	 ƒ  | j ƒ  | j ƒ  t
 j t ƒ |  j d t | ƒ | j	 ƒ  | j ƒ  | j ƒ  t
 j t ƒ |  j d t | ƒ |  j | ƒ | j ƒ  d  S(   Ni    u   targetu   argsi   i   T(   u	   Conditionu	   Semaphoreu   Processu   fu   Trueu   daemonu   startu	   threadingu   Threadu   acquireu   timeu   sleepu   DELTAu   assertReturnsIfImplementedu	   get_valueu   notifyu   releaseu   check_invariantu   join(   u   selfu   condu   sleepingu   wokenu   p(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_notifyq  s2    $	
$	








c             C   s,  |  j  ƒ  } |  j d ƒ } |  j d ƒ } xˆ t d ƒ D]z } |  j d |  j d | | | t f ƒ } d | _ | j ƒ  t	 j
 d |  j d | | | t f ƒ } d | _ | j ƒ  q7 Wx t d ƒ D] } | j ƒ  qÂ Wx t d ƒ D] } | j ƒ  qã W|  j d t | ƒ |  j | ƒ x‚ t d ƒ D]t } |  j d |  j d | | | f ƒ } d | _ | j ƒ  t	 j
 d |  j d | | | f ƒ } d | _ | j ƒ  q$Wx t d ƒ D] } | j ƒ  q©Wt j t ƒ |  j d t | ƒ | j ƒ  | j ƒ  | j ƒ  t j t ƒ |  j d t | ƒ |  j | ƒ d  S(   Ni    i   u   targetu   argsi   T(   u	   Conditionu	   Semaphoreu   rangeu   Processu   fu   TIMEOUT1u   Trueu   daemonu   startu	   threadingu   Threadu   acquireu   assertReturnsIfImplementedu	   get_valueu   check_invariantu   timeu   sleepu   DELTAu
   notify_allu   release(   u   selfu   condu   sleepingu   wokenu   iu   pu   t(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_notify_allœ  sP     	
	   $	
$	 


c             C   sb   |  j  ƒ  } t | j ƒ } | j ƒ  | t ƒ } | j ƒ  |  j | d  ƒ |  j | j	 t ƒ d  S(   N(
   u	   Conditionu   TimingWrapperu   waitu   acquireu   TIMEOUT1u   releaseu   assertEqualu   Noneu   assertTimingAlmostEqualu   elapsed(   u   selfu   condu   waitu   res(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_timeout×  s    

N(   u   __name__u
   __module__u   Noneu   fu   check_invariantu   test_notifyu   test_notify_allu   test_timeout(   u
   __locals__(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   _TestCondition]  s
   
		+	;u   _TestConditionc             B   s    |  Ee  Z d  „  Z d „  Z d S(   c             C   s   t  j t ƒ | j ƒ  d  S(   N(   u   timeu   sleepu   TIMEOUT2u   set(   u   selfu   event(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   _test_eventã  s    c             C   s	  |  j  ƒ  } t | j ƒ } |  j | d ƒ d  ƒ |  j | j d ƒ |  j | t ƒ d  ƒ |  j | j t ƒ | j ƒ  |  j | ƒ  d  ƒ |  j | j d ƒ |  j | t ƒ d  ƒ |  j | j d ƒ | j	 ƒ  |  j
 d |  j d | f ƒ j ƒ  |  j | ƒ  d  ƒ d  S(   Ng        u   targetu   args(   u   Eventu   TimingWrapperu   waitu   assertEqualu   Noneu   assertTimingAlmostEqualu   elapsedu   TIMEOUT1u   setu   clearu   Processu   _test_eventu   start(   u   selfu   eventu   wait(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu
   test_eventç  s    

"N(   u   __name__u
   __module__u   _test_eventu
   test_event(   u
   __locals__(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu
   _TestEventá  s   
	u
   _TestEventc             B   s\   |  Ee  Z d d d d	 e d
 ƒ e d ƒ f g Z d „  Z d d „ Z d „  Z d „  Z d S(   u   ii÷  iª^  u   dg      @g      Àu   hiÿÿÿiê   u   cu   xu   yc             C   s4   x- t  | |  j ƒ D] \ } } | d | _ q Wd  S(   Ni   (   u   zipu   codes_valuesu   value(   u   selfu   valuesu   svu   cv(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   _test  s     c                sü   ˆ  j  d k o d  S| o ‡  f d †  ˆ  j Dƒ } n ‡  f d †  ˆ  j Dƒ } x7 t | ˆ  j ƒ D]# \ } } ˆ  j | j | d ƒ qe Wˆ  j d ˆ  j d | f ƒ } | j ƒ  | j ƒ  x7 t | ˆ  j ƒ D]# \ } } ˆ  j | j | d ƒ qÑ Wd  S(   Nu	   processesc                s0   g  } |  ]" \ } } } | ˆ  j  | | ƒ q
 S(    (   u   RawValue(   u   .0u   _[1]u   codeu   valueu   _(   u   self(    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu
   <listcomp>  s   c                s0   g  } |  ]" \ } } } | ˆ  j  | | ƒ q
 S(    (   u   Value(   u   .0u   _[1]u   codeu   valueu   _(   u   self(    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu
   <listcomp>  s   i   u   targetu   argsi   (	   u   TYPEu   codes_valuesu   zipu   assertEqualu   valueu   Processu   _testu   startu   join(   u   selfu   rawu   valuesu   svu   cvu   proc(    (   u   selfu6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu
   test_value  s      

 c             C   s   |  j  d d ƒ d  S(   Nu   rawT(   u
   test_valueu   True(   u   self(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_rawvalue,  s    c             C   sý   |  j  d k o d  S|  j d d ƒ } | j ƒ  } | j ƒ  } |  j d d d d  ƒ} | j ƒ  } | j ƒ  } |  j ƒ  } |  j d d d | ƒ} | j ƒ  }	 | j ƒ  }
 |  j | |	 ƒ |  j d d ƒ } |  j t	 | d ƒ ƒ |  j t	 | d ƒ ƒ d  S(   Nu	   processesu   ii   u   locku   get_locku   get_obj(
   u   TYPEu   Valueu   get_locku   get_obju   Noneu   Locku   assertEqualu   RawValueu   assertFalseu   hasattr(   u   selfu   val1u   lock1u   obj1u   val2u   lock2u   obj2u   locku   val3u   lock3u   obj3u   arr4(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_getobj_getlock/  s     N(   u   ii÷  iª^  (   u   dg      @g      À(   u   hiÿÿÿiê   F(	   u   __name__u
   __module__u   latinu   codes_valuesu   _testu   Falseu
   test_valueu   test_rawvalueu   test_getobj_getlock(   u
   __locals__(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu
   _TestValue	  s   
		u
   _TestValuec             B   s5   |  Ee  Z d  „  Z d d „ Z d „  Z d „  Z d S(   c             C   s<   x5 t  d t | ƒ ƒ D] } | | c | | d 7<q Wd  S(   Ni   (   u   rangeu   len(   u   selfu   sequ   i(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   fH  s     c          
   C   s…  |  j  d k o d  Sd d d d d d d d	 d
 d g
 } | o |  j d | ƒ } n |  j d | ƒ } |  j t | ƒ t | ƒ ƒ |  j | d | d ƒ |  j t | d d … ƒ t | d d … ƒ ƒ t j d d d d d g ƒ | d d … <| d d … <|  j t | d  d  … ƒ | ƒ |  j | ƒ |  j d |  j d | f ƒ } | j	 ƒ  | j
 ƒ  |  j t | d  d  … ƒ | ƒ d  S(   Nu	   processesi¨  ir  i¦  i5  i–   ié   i$  iÖ  iÊ  i?  u   ii   i   i   i   i   i   u   targetu   args(   u   TYPEu   RawArrayu   Arrayu   assertEqualu   lenu   listu   arrayu   fu   Processu   startu   join(   u   selfu   rawu   sequ   arru   p(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu
   test_arrayL  s     $06 

c             C   s   |  j  d d ƒ d  S(   Nu   rawT(   u
   test_arrayu   True(   u   self(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_rawarrayf  s    c             C   s-  |  j  d k o d  S|  j d t t d ƒ ƒ ƒ } | j ƒ  } | j ƒ  } |  j d t t d ƒ ƒ d d  ƒ} | j ƒ  } | j ƒ  } |  j ƒ  } |  j d t t d ƒ ƒ d | ƒ} | j ƒ  }	 | j ƒ  }
 |  j | |	 ƒ |  j	 d t t d ƒ ƒ ƒ } |  j
 t | d ƒ ƒ |  j
 t | d ƒ ƒ d  S(   Nu	   processesu   ii
   u   locku   get_locku   get_obj(   u   TYPEu   Arrayu   listu   rangeu   get_locku   get_obju   Noneu   Locku   assertEqualu   RawArrayu   assertFalseu   hasattr(   u   selfu   arr1u   lock1u   obj1u   arr2u   lock2u   obj2u   locku   arr3u   lock3u   obj3u   arr4(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_getobj_getlock_obji  s     $$NF(   u   __name__u
   __module__u   fu   Falseu
   test_arrayu   test_rawarrayu   test_getobj_getlock_obj(   u
   __locals__(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu
   _TestArrayF  s   
		u
   _TestArrayc             B   s/   |  Ee  Z d Z d „  Z d „  Z d „  Z d S(   u   managerc             C   s[  |  j  t  t d ƒ ƒ ƒ } |  j | d  d  … t  t d ƒ ƒ ƒ |  j  ƒ  } |  j | d  d  … g  ƒ | j t  t d ƒ ƒ ƒ |  j | d  d  … t  t d ƒ ƒ ƒ |  j | d d ƒ |  j | d d … d d d g ƒ | d 9} |  j | d  d  … d d d d d d d d d d g
 ƒ |  j | d d g d d d d d d d d d d d d g ƒ |  j | d  d  … t  t d ƒ ƒ ƒ | | g } |  j  | ƒ } |  j | d  d  … d d d d d d d d	 d
 d g
 d d d d d d d d d d g
 g ƒ |  j  | g ƒ } | j d ƒ |  j | d  d  … d d d d d d d d	 d
 d d g g ƒ d  S(   Ni
   i   i   i   i   i    i   i   i   i   i	   u   hello(   u   listu   rangeu   assertEqualu   extendu   append(   u   selfu   au   bu   du   eu   f(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu	   test_list‡  s(    &&#
8>&Ic             C   sÔ   |  j  ƒ  } t t d d ƒ ƒ } x | D] } t | ƒ | | <q( W|  j | j ƒ  t  d „  | Dƒ ƒ ƒ |  j t | j ƒ  ƒ | ƒ |  j t | j ƒ  ƒ d „  | Dƒ ƒ |  j t | j	 ƒ  ƒ d „  | Dƒ ƒ d  S(   NiA   iF   c             s   s!   |  ] } | t  | ƒ f Vq d  S(   N(   u   chr(   u   .0u   i(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu	   <genexpr>«  s    c             S   s!   g  } |  ] } | t  | ƒ q
 S(    (   u   chr(   u   .0u   _[1]u   i(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu
   <listcomp>­  s    c             S   s'   g  } |  ] } | | t  | ƒ f q
 S(    (   u   chr(   u   .0u   _[1]u   i(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu
   <listcomp>®  s    (
   u   dictu   listu   rangeu   chru   assertEqualu   copyu   sortedu   keysu   valuesu   items(   u   selfu   du   indicesu   i(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu	   test_dict¦  s     &&c             C   s   |  j  ƒ  } d | _ d | _ d | _ |  j | j | j f d ƒ | ` |  j t | ƒ d ƒ |  j t | d ƒ ƒ |  j t | d ƒ ƒ d  S(   Nu   Bobu   Builderu   hiddenu   Namespace(name='Bob')u   nameu   job(   u   Bobu   Builder(   u	   Namespaceu   nameu   jobu   _hiddenu   assertEqualu   stru
   assertTrueu   hasattr(   u   selfu   n(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_namespace°  s    			N(   u   manager(   u   __name__u
   __module__u   ALLOWED_TYPESu	   test_listu	   test_dictu   test_namespace(   u
   __locals__(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   _TestContainersƒ  s   
		
u   _TestContainersg        c             C   s   t  j | ƒ |  |  S(   N(   u   timeu   sleep(   u   xu   wait(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   sqr¿  s    c             B   sV   |  Ee  Z d  „  Z d „  Z d „  Z d „  Z d „  Z d „  Z d „  Z d „  Z	 d S(	   c             C   s[   |  j  j } |  j | t d ƒ t d ƒ ƒ |  j | t d i d d 6ƒ t d d ƒ ƒ d  S(   Ni   i   u   x(   i   (    (   u   poolu   applyu   assertEqualu   sqr(   u   selfu   papply(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu
   test_applyÄ  s    c             C   s–   |  j  j } |  j | t t t d ƒ ƒ ƒ t t t t t d ƒ ƒ ƒ ƒ ƒ |  j | t t t d ƒ ƒ d d ƒt t t t t d ƒ ƒ ƒ ƒ ƒ d  S(   Ni
   id   u	   chunksizei   (   u   poolu   mapu   assertEqualu   sqru   listu   range(   u   selfu   pmap(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_mapÉ  s    @$c             C   sT   |  j  j t d t f ƒ } t | j ƒ } |  j | ƒ  d ƒ |  j | j t ƒ d  S(   Ni   i1   (	   u   poolu   apply_asyncu   sqru   TIMEOUT1u   TimingWrapperu   getu   assertEqualu   assertTimingAlmostEqualu   elapsed(   u   selfu   resu   get(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu
   test_asyncÏ  s    c             C   s^   |  j  j t d t d f ƒ } t | j ƒ } |  j t j | d t ƒ|  j	 | j
 t ƒ d  S(   Ni   gš™™™™™É?u   timeout(   u   poolu   apply_asyncu   sqru   TIMEOUT2u   TimingWrapperu   getu   assertRaisesu   multiprocessingu   TimeoutErroru   assertTimingAlmostEqualu   elapsed(   u   selfu   resu   get(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_async_timeoutÕ  s    c             C   s&  |  j  j t t t d ƒ ƒ ƒ } |  j t | ƒ t t t t t d ƒ ƒ ƒ ƒ ƒ |  j  j t t t d ƒ ƒ ƒ } x. t d ƒ D]  } |  j t | ƒ | | ƒ q€ W|  j t	 | j
 ƒ |  j  j t t t d ƒ ƒ d d ƒ} x. t d ƒ D]  } |  j t | ƒ | | ƒ që W|  j t	 | j
 ƒ d  S(   Ni
   iè  u	   chunksizeid   (   u   poolu   imapu   sqru   listu   rangeu   assertEqualu   mapu   nextu   assertRaisesu   StopIterationu   __next__(   u   selfu   itu   i(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu	   test_imapÛ  s    !1! ' c             C   s®   |  j  j t t t d ƒ ƒ ƒ } |  j t | ƒ t t t t t d ƒ ƒ ƒ ƒ ƒ |  j  j t t t d ƒ ƒ d d ƒ} |  j t | ƒ t t t t t d ƒ ƒ ƒ ƒ ƒ d  S(   Niè  u	   chunksizei5   (   u   poolu   imap_unorderedu   sqru   listu   rangeu   assertEqualu   sortedu   map(   u   selfu   it(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_imap_unorderedé  s    !1'c             C   s@   t  j d ƒ } |  j d t | j ƒ ƒ | j ƒ  | j ƒ  d  S(   Ni   (   u   multiprocessingu   Poolu   assertEqualu   lenu   _poolu   closeu   join(   u   selfu   p(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_make_poolð  s    
c             C   sƒ   |  j  d k o d  S|  j j t j d „  t d ƒ Dƒ d d ƒ} |  j j ƒ  t |  j j ƒ } | ƒ  |  j	 | j
 d k  ƒ d  S(   Nu   managerc             S   s   g  } |  ] } | d  q
 S(   gš™™™™™¹?(    (   u   .0u   _[1]u   i(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu
   <listcomp>  s    i'  u	   chunksizei   gš™™™™™É?(   u   TYPEu   poolu	   map_asyncu   timeu   sleepu   rangeu	   terminateu   TimingWrapperu   joinu
   assertTrueu   elapsed(   u   selfu   resultu   join(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_terminateö  s    	%N(
   u   __name__u
   __module__u
   test_applyu   test_mapu
   test_asyncu   test_async_timeoutu	   test_imapu   test_imap_unorderedu   test_make_poolu   test_terminate(   u
   __locals__(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu	   _TestPoolÂ  s   
							u	   _TestPoolc             B   s   |  Ee  Z d Z d „  Z d S(   u   managerc             C   sa   d } t  j ƒ  t j ƒ  |  j j ƒ  } | | k o t |  j j ƒ  ƒ n |  j | | ƒ d  S(   Ni   (	   u   multiprocessingu   active_childrenu   gcu   collectu   manageru   _number_of_objectsu   printu   _debug_infou   assertEqual(   u   selfu   EXPECTED_NUMBERu   refs(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_number_of_objects  s    

N(   u   manager(   u   __name__u
   __module__u   ALLOWED_TYPESu   test_number_of_objects(   u
   __locals__(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   _TestZZZNumberOfObjects  s   
u   _TestZZZNumberOfObjects(   u   BaseManageru	   BaseProxyu   RemoteErrorc             B   s)   |  Ee  Z d  „  Z d „  Z d „  Z d S(   c             C   s   d S(   Nu   f()(    (   u   self(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   f#  s    c             C   s
   t  ‚ d  S(   N(   u
   ValueError(   u   self(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   g%  s    c             C   s   d S(   Nu   _h()(    (   u   self(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   _h'  s    N(   u   __name__u
   __module__u   fu   gu   _h(   u
   __locals__(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   FooBar"  s   
		u   FooBarc              c   s$   x t  d ƒ D] }  |  |  Vq Wd  S(   Ni
   (   u   range(   u   i(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   baz*  s     c             B   s/   |  Ee  Z d Z d „  Z d „  Z d „  Z d S(   u   nextu   __next__c             C   s   |  S(   N(    (   u   self(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   __iter__0  s    c             C   s   |  j  d ƒ S(   Nu   next(   u   _callmethod(   u   self(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   __next__2  s    c             C   s   |  j  d ƒ S(   Nu   __next__(   u   _callmethod(   u   self(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   __next__4  s    N(   u   nextu   __next__(   u   __name__u
   __module__u	   _exposed_u   __iter__u   __next__(   u
   __locals__(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   IteratorProxy.  s   
		u   IteratorProxyc             B   s   |  Ee  Z d  S(   N(   u   __name__u
   __module__(   u
   __locals__(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu	   MyManager7  s   
u	   MyManageru   Foou   callableu   Baru   exposedu   fu   _hu   bazu	   proxytypec             B   s   |  Ee  Z d Z d „  Z d S(   u   managerc                sy  t  ƒ  } | j ƒ  | j ƒ  ‰ | j ƒ  ‰  | j ƒ  } ‡ f d †  d
 Dƒ } ‡  f d †  d Dƒ } |  j | d d g ƒ |  j | d d g ƒ |  j ˆ j ƒ  d ƒ |  j t ˆ j	 ƒ |  j ˆ j
 d ƒ d ƒ |  j t ˆ j
 d ƒ |  j ˆ  j ƒ  d ƒ |  j ˆ  j ƒ  d ƒ |  j ˆ  j
 d ƒ d ƒ |  j ˆ  j
 d ƒ d ƒ |  j t | ƒ d „  t d	 ƒ Dƒ ƒ | j ƒ  d  S(   Nc                s/   g  } |  ]! } t  ˆ  | ƒ o | | q
 q
 S(    (   u   hasattr(   u   .0u   _[1]u   name(   u   foo(    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu
   <listcomp>K  s    u   fu   gu   _hc                s/   g  } |  ]! } t  ˆ  | ƒ o | | q
 q
 S(    (   u   hasattr(   u   .0u   _[1]u   name(   u   bar(    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu
   <listcomp>L  s    u   f()u   _h()c             S   s   g  } |  ] } | | | q
 S(    (    (   u   .0u   _[1]u   i(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu
   <listcomp>[  s    i
   (   u   fu   gu   _h(   u   fu   gu   _h(   u	   MyManageru   startu   Foou   Baru   bazu   assertEqualu   fu   assertRaisesu
   ValueErroru   gu   _callmethodu   RemoteErroru   _hu   listu   rangeu   shutdown(   u   selfu   manageru   bazu   foo_methodsu   bar_methods(    (   u   baru   foou6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_mymanagerC  s&    	
&N(   u   manager(   u   __name__u
   __module__u   ALLOWED_TYPESu   test_mymanager(   u
   __locals__(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   _TestMyManager?  s   
u   _TestMyManagerc               C   s   t  S(   N(   u   _queue(    (    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu	   get_queued  s    c             B   s   |  Ee  Z d  Z d S(   u$   manager class used by server processN(   u   __name__u
   __module__u   __doc__(   u
   __locals__(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   QueueManagerg  s   
u   QueueManageru	   get_queuec             B   s   |  Ee  Z d  Z d S(   u@   manager class which specifies the same interface as QueueManagerN(   u   __name__u
   __module__u   __doc__(   u
   __locals__(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   QueueManager2k  s   
u   QueueManager2u	   xmlrpclibc             B   s&   |  Ee  Z d Z d „  Z d „  Z d S(   u   managerc             C   sB   t  d | d | d t ƒ } | j ƒ  | j ƒ  } | j d ƒ d  S(   Nu   addressu   authkeyu
   serializeru   hello worldg      @T(   u   hello worldNTg      @(   u   QueueManager2u
   SERIALIZERu   connectu	   get_queueu   putu   Noneu   True(   u   selfu   addressu   authkeyu   manageru   queue(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   _putterv  s
    
c             C   sâ   t  j d ƒ } t d d d | d t ƒ } | j ƒ  |  j d |  j d | j | f ƒ } | j ƒ  t d | j d | d t ƒ } | j	 ƒ  | j
 ƒ  } |  j | j ƒ  d	 d  d d
 g ƒ |  j t | j t j ƒ ~ | j ƒ  d  S(   Ni    u   addressu	   localhosti    u   authkeyu
   serializeru   targetu   argsu   hello worldg      @(   u	   localhosti    T(   u   osu   urandomu   QueueManageru
   SERIALIZERu   startu   Processu   _putteru   addressu   QueueManager2u   connectu	   get_queueu   assertEqualu   getu   Noneu   Trueu   assertRaisesu	   Exceptionu   putu   timeu   sleepu   shutdown(   u   selfu   authkeyu   manageru   pu   manager2u   queue(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_remote~  s    
$

"N(   u   manager(   u   __name__u
   __module__u   ALLOWED_TYPESu   _putteru   test_remote(   u
   __locals__(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   _TestRemoteManagerr  s   
	u   _TestRemoteManageru    c             B   sA   |  Ee  Z d Z d „  Z d „  Z d „  Z d „  Z d „  Z d S(	   u	   processesu   threadsc             C   s8   x' t  | j t ƒ D] } | j | ƒ q W| j ƒ  d  S(   N(   u   iteru
   recv_bytesu   SENTINELu
   send_bytesu   close(   u   selfu   connu   msg(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   _echo¤  s     c             C   sS  |  j  ƒ  \ } } |  j d |  j d | f ƒ } d | _ | j ƒ  d d d  g } t d ƒ } | d } t j d t	 t
 d ƒ ƒ ƒ } |  j d	 k o  |  j t | j ƒ  ƒ t ƒ n |  j | j | ƒ d  ƒ |  j | j ƒ  | ƒ |  j | j | ƒ d  ƒ |  j | j ƒ  | ƒ |  j d	 k oÍt j d d
 g d ƒ } t	 | ƒ d
 g d t | ƒ }	 |  j | j | ƒ d  ƒ |  j | j | ƒ t | ƒ | j ƒ |  j t	 | ƒ |	 ƒ t j d d
 g d ƒ } d
 g d t	 | ƒ d
 g d t | ƒ }	 |  j | j | ƒ d  ƒ |  j | j | d | j ƒ t | ƒ | j ƒ |  j t	 | ƒ |	 ƒ t t d d ƒ ƒ } |  j | j | ƒ d  ƒ y | j | ƒ }
 Wn@ t j k
 o1 } z |  j | j | f ƒ WYd  d  } ~ XqñX|  j d |
 ƒ n t | j ƒ } |  j | ƒ  d ƒ |  j | j  d
 ƒ |  j | t! ƒ d ƒ |  j | j  t! ƒ | j d  ƒ |  j | t! ƒ d ƒ |  j | j  d
 ƒ |  j | j ƒ  d  ƒ t d ƒ d } | j | ƒ |  j | j ƒ  | ƒ | j t" ƒ | j# ƒ  |  j d	 k oP |  j | j$ d ƒ |  j | j% d ƒ |  j& t' | j ƒ |  j& t' | j ƒ n | j( ƒ  d  S(   Nu   targetu   argsi   g      @u   hello worldi
   u   ii   u	   processesi    i   u    i(   u   expected BufferTooShort, got %su   Xi   i   Ti   Fi   i   ()   u   Pipeu   Processu   _echou   Trueu   daemonu   startu   Noneu   latinu   arrayu   listu   rangeu   TYPEu   assertEqualu   typeu   filenou   intu   sendu   recvu
   send_bytesu
   recv_bytesu   lenu   recv_bytes_intou   itemsizeu	   bytearrayu   multiprocessingu   BufferTooShortu   argsu   failu   TimingWrapperu   pollu   Falseu   assertTimingAlmostEqualu   elapsedu   TIMEOUT1u   SENTINELu   closeu   readableu   writableu   assertRaisesu   EOFErroru   join(   u   selfu   connu
   child_connu   pu   sequ   msgu   longmsgu   arru   bufferu   expectedu   resu   eu   pollu   really_big_msg(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_connection©  sl    	

 !,*
c             C   sç   |  j  d d ƒ \ } } |  j | j d ƒ d  ƒ |  j | j ƒ  d ƒ |  j d k oŒ |  j | j d ƒ |  j | j	 d ƒ |  j | j d ƒ |  j | j	 d ƒ |  j
 t | j d ƒ |  j
 t | j ƒ |  j
 t | j ƒ n d  S(   Nu   duplexi   u	   processesi   FT(   u   Pipeu   Falseu   assertEqualu   sendu   Noneu   recvu   TYPEu   readableu   Trueu   writableu   assertRaisesu   IOErroru   poll(   u   selfu   readeru   writer(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_duplex_falseô  s    c             C   s˜   |  j  ƒ  \ } } |  j d |  j d | f ƒ } | j ƒ  | j ƒ  t d ƒ } | j | ƒ |  j | j ƒ  | ƒ | j t	 ƒ | j ƒ  | j
 ƒ  d  S(   Nu   targetu   argsu   hello(   u   Pipeu   Processu   _echou   startu   closeu   latinu
   send_bytesu   assertEqualu
   recv_bytesu   SENTINELu   join(   u   selfu   connu
   child_connu   pu   msg(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_spawn_close  s    


c             C   sž  |  j  d k o d  St d ƒ } |  j ƒ  \ } } | j | ƒ |  j | j ƒ  | ƒ | j | d ƒ |  j | j ƒ  | d d  … ƒ | j | d d ƒ |  j | j ƒ  | d d … ƒ | j | d ƒ |  j | j ƒ  t d ƒ ƒ | j | d d ƒ |  j | j ƒ  t d ƒ ƒ |  j t | j | d	 ƒ |  j t | j | d
 d ƒ |  j t | j | d d ƒ |  j t | j | d ƒ |  j t | j | d d ƒ d  S(   Nu	   processesu   abcdefghijklmnopqrstuvwxyzi   i   i   i   u    i    i   i   i   iÿÿÿÿi   i   (   u   TYPEu   latinu   Pipeu
   send_bytesu   assertEqualu
   recv_bytesu   assertRaisesu
   ValueError(   u   selfu   msgu   au   b(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_sendbytes  s&      N(   u	   processesu   threads(   u   __name__u
   __module__u   ALLOWED_TYPESu   _echou   test_connectionu   test_duplex_falseu   test_spawn_closeu   test_sendbytes(   u
   __locals__(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   _TestConnection   s   
		K		u   _TestConnectionc             B   s&   |  Ee  Z d Z d „  Z d „  Z d S(   u	   processesu   threadsc             C   s-   |  j  j | ƒ } | j d ƒ | j ƒ  d  S(   Nu   hello(   u
   connectionu   Clientu   sendu   close(   u   selfu   addressu   conn(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   _test9  s    c             C   sš   x“ |  j  j D]… } |  j  j d | ƒ } |  j d |  j d | j f ƒ } d | _ | j ƒ  | j	 ƒ  } |  j
 | j ƒ  d ƒ | j ƒ  | j ƒ  q Wd  S(   Nu   familyu   targetu   argsu   helloT(   u
   connectionu   familiesu   Listeneru   Processu   _testu   addressu   Trueu   daemonu   startu   acceptu   assertEqualu   recvu   joinu   close(   u   selfu   familyu   lu   pu   conn(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_listener_client>  s     !	

N(   u	   processesu   threads(   u   __name__u
   __module__u   ALLOWED_TYPESu   _testu   test_listener_client(   u
   __locals__(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   _TestListenerClient5  s   
	u   _TestListenerClientc             B   s   |  Ee  Z d Z d „  Z d S(   u	   processesc             C   s  d } d } g  } x| t  | ƒ D]n } t t j d d ƒ d ƒ } t j j | ƒ } | j | ƒ t | ƒ | k o t j	 | ƒ } | | =q q Wt j j j
 } g  } d }	 xc t | j j ƒ  ƒ D]L }
 xC |
 D]; \ } } } | j | j j | ƒ | | | | d f ƒ qÏ WqÂ WxT | j D]I \ } } } | j | j j | ƒ | | | | d f ƒ |	 | | 7}	 qW| j ƒ  x‰ t  t | ƒ d ƒ D]q } | | d  d … \ } } } | | d d  d … \ } } } |  j | | k o | d k p
 | | k ƒ qŠWd  S(	   Niˆ  i2   i    i   iè  u   freeu   occupiedi   (   u   rangeu   intu   randomu   lognormvariateu   multiprocessingu   heapu   BufferWrapperu   appendu   lenu	   randrangeu   _heapu   listu   _len_to_sequ   valuesu   _arenasu   indexu   _allocated_blocksu   sortu
   assertTrue(   u   selfu
   iterationsu	   maxblocksu   blocksu   iu   sizeu   bu   heapu   allu   occupiedu   Lu   arenau   startu   stopu   narenau   nstartu   nstop(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu	   test_heap¦  s@       
 
 ! N(   u	   processes(   u   __name__u
   __module__u   ALLOWED_TYPESu	   test_heap(   u
   __locals__(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu	   _TestHeap¢  s   
u	   _TestHeap(   u	   Structureu   Valueu   copyu   c_intu   c_doublec             B   s&   |  Ee  Z d  e f d e f g Z d S(   u   xu   yN(   u   __name__u
   __module__u   c_intu   c_doubleu   _fields_(   u
   __locals__(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   _FooÕ  s   
	u   _Fooc             B   s;   |  Ee  Z d Z d „  Z d d „ Z d „  Z d „  Z d S(   u	   processesc             C   s|   | j  d 9_  | j  d 9_  | j d 9_ | j d 9_ | j  d 9_  x* t t | ƒ ƒ D] } | | c d 9<q^ Wd  S(   Ni   (   u   valueu   xu   yu   rangeu   len(   u   selfu   xu   yu   foou   arru   stringu   i(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   _doubleß  s     c       	   	   C   sl  t  d  k o d  St d d d | ƒ} t t j d d | ƒ} t t d d d | ƒ} t d t t d	 ƒ ƒ d | ƒ} t d
 d d | ƒ} d | _	 |  j
 d |  j d | | | | | f ƒ } | j ƒ  | j ƒ  |  j | j	 d ƒ |  j | j	 d ƒ |  j | j d ƒ |  j | j d ƒ x, t d	 ƒ D] } |  j | | | d ƒ q-W|  j | j	 t d ƒ ƒ d  S(   Nu   ii   u   lockg      ð?g      @i   i   u   di
   u   ci   u   hellou   targetu   argsi   g       @i   g      @u
   hellohellogUUUUUUÕ?gUUUUUUå?(   u   c_intu   Noneu   Valueu   ctypesu   c_doubleu   _Foou   Arrayu   listu   rangeu   valueu   Processu   _doubleu   startu   joinu   assertEqualu   assertAlmostEqualu   xu   yu   latin(	   u   selfu   locku   xu   yu   foou   arru   stringu   pu   i(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_sharedctypesè  s&    !	*

 c             C   s   |  j  d d ƒ d  S(   Nu   lockT(   u   test_sharedctypesu   True(   u   self(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_synchronizeÿ  s    c             C   si   t  d  k o d  St d d ƒ } t | ƒ } d | _ d | _ |  j | j d ƒ |  j | j d ƒ d  S(   Ni   g      @i    (   u   c_intu   Noneu   _Foou   copyu   xu   yu   assertEqualu   assertAlmostEqual(   u   selfu   foou   bar(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu	   test_copy  s    		N(   u	   processesF(   u   __name__u
   __module__u   ALLOWED_TYPESu   _doubleu   Falseu   test_sharedctypesu   test_synchronizeu	   test_copy(   u
   __locals__(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   _TestSharedCTypesÛ  s
   
			u   _TestSharedCTypesc             B   s&   |  Ee  Z d Z d „  Z d „  Z d S(   u	   processesc             C   s’  Gd „  d t  ƒ } | ƒ  } t j | | j d d ƒ~ | ƒ  } t j | | j d d ƒ} | ƒ  | ƒ  ~ | ƒ  } t j | | j d d ƒ| ƒ  } t j | | j d d d d	 ƒ| ƒ  } t j | | j d d d d ƒ| ƒ  }	 t j |	 | j d d d d ƒ| ƒ  }
 t j |
 | j d d d d ƒt j d  | j d d d d ƒt j d  | j d d d d ƒt j ƒ  | j ƒ  t j d ƒ d  S(   Nc             B   s   |  Ee  Z d  S(   N(   u   __name__u
   __module__(   u
   __locals__(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   Foo  s   
u   Foou   argsu   au   bu   cu   d10u   exitpriorityi   u   d01i    u   d02u   d03u   eiöÿÿÿu   STOPiœÿÿÿ(   u   a(   u   b(   u   c(   u   d10(   u   d01(   u   d02(   u   d03(   u   e(   u   STOP(	   u   objectu   utilu   Finalizeu   sendu   Noneu   _exit_functionu   closeu   osu   _exit(   u   selfu   connu   Foou   au   bu   close_bu   cu   d10u   d01u   d02u   d03(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   _test_finalize  s0    							

c          	   C   s‰   |  j  ƒ  \ } } |  j d |  j d | f ƒ } | j ƒ  | j ƒ  d „  t | j d ƒ Dƒ } |  j | d d d d d	 d
 d g ƒ d  S(   Nu   targetu   argsc             S   s   g  } |  ] } | | q
 S(    (    (   u   .0u   _[1]u   obj(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu
   <listcomp>A  s    u   STOPu   au   bu   d10u   d03u   d02u   d01u   e(   u   Pipeu   Processu   _test_finalizeu   startu   joinu   iteru   recvu   assertEqual(   u   selfu   connu
   child_connu   pu   result(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_finalize:  s    

N(   u	   processes(   u   __name__u
   __module__u   ALLOWED_TYPESu   _test_finalizeu   test_finalize(   u
   __locals__(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   _TestFinalize  s   
	%u   _TestFinalizec             B   s   |  Ee  Z d Z d „  Z d S(   u	   processesc          
   C   sr   d } xe | D]] } t  | ƒ t j | } x= t | d d ƒ D]) } |  j t | | ƒ d | | f ƒ q= Wq Wd  S(   Nu   multiprocessingu   multiprocessing.connectionu   multiprocessing.heapu   multiprocessing.managersu   multiprocessing.poolu   multiprocessing.processu   multiprocessing.reductionu   multiprocessing.sharedctypesu   multiprocessing.synchronizeu   multiprocessing.utilu   __all__u   %r does not have attribute %r(
   u   multiprocessingu   multiprocessing.connectionu   multiprocessing.heapu   multiprocessing.managersu   multiprocessing.poolu   multiprocessing.processu   multiprocessing.reductionu   multiprocessing.sharedctypesu   multiprocessing.synchronizeu   multiprocessing.util(    (   u
   __import__u   sysu   modulesu   getattru
   assertTrueu   hasattr(   u   selfu   modulesu   nameu   modu   attr(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_importL  s         
 N(   u	   processes(   u   __name__u
   __module__u   ALLOWED_TYPESu   test_import(   u
   __locals__(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   _TestImportStarH  s   
u   _TestImportStarc             B   s/   |  Ee  Z d Z d „  Z d „  Z d „  Z d S(   u	   processesc             C   sZ   t  j ƒ  } | j t j ƒ |  j | d  k	 ƒ | j d ƒ | j d ƒ | j t	 ƒ d  S(   Nu   this will not be printedu   nor will this(
   u   multiprocessingu
   get_loggeru   setLevelu   utilu
   SUBWARNINGu
   assertTrueu   Noneu   debugu   infou	   LOG_LEVEL(   u   selfu   logger(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   test_enable_loggingg  s    c             C   s#   t  j ƒ  } | j | j ƒ  ƒ d  S(   N(   u   multiprocessingu
   get_loggeru   sendu   getEffectiveLevel(   u   selfu   connu   logger(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   _test_levelo  s    c             C   s   d } d } t  j ƒ  } t j ƒ  } | j } t  j d d ƒ \ } } | j | ƒ |  j d |  j	 d | f ƒ j
 ƒ  |  j | | j ƒ  ƒ | j t j ƒ | j | ƒ |  j d |  j	 d | f ƒ j
 ƒ  |  j | | j ƒ  ƒ | j | ƒ | j d t ƒ d  S(   Ni    i%   u   duplexu   targetu   argsu   levelF(   u   multiprocessingu
   get_loggeru   loggingu	   getLoggeru   levelu   Pipeu   Falseu   setLevelu   Processu   _test_levelu   startu   assertEqualu   recvu   NOTSETu	   LOG_LEVEL(   u   selfu   LEVEL1u   LEVEL2u   loggeru   root_loggeru
   root_levelu   readeru   writer(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu
   test_levels  s    	""N(   u	   processes(   u   __name__u
   __module__u   ALLOWED_TYPESu   test_enable_loggingu   _test_levelu
   test_level(   u
   __locals__(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   _TestLoggingc  s   
		u   _TestLoggingc             C   s]   i  } xP | D]H } t  |  | ƒ } t | ƒ t t ƒ k o t | ƒ } n | | | <q W| S(   N(   u   getattru   typeu   get_attributesu   staticmethod(   u   Sourceu   namesu   du   nameu   obj(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   get_attributes  s     c       	      C   sÓ   i  } t  ƒ  } | d j ƒ  | d d  … } xŸ t | j ƒ  ƒ D]‹ } | j d ƒ ou | | } | | j k oW d | | d d  … } Gd „  d | t j |  ƒ } | | | <| | _ |  j	 | _	 qË q@ q@ W| S(   Ni    i   u   _Testu   Withc             B   s   |  Ee  Z d  S(   N(   u   __name__u
   __module__(   u
   __locals__(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   Temp   s   
u   Temp(
   u   globalsu   upperu   listu   keysu
   startswithu   ALLOWED_TYPESu   unittestu   TestCaseu   __name__u
   __module__(	   u   Mixinu   typeu   resultu   globu   Typeu   nameu   baseu   newnameu   Temp(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   create_test_cases–  s    	 

	c             B   s6   |  Ee  Z d  Z e j Z e ƒ  j e e d ƒ ƒ d S(   u	   processesu   Queueu   Locku   RLocku	   Semaphoreu   BoundedSemaphoreu	   Conditionu   Eventu   Valueu   Arrayu   RawValueu   RawArrayu   current_processu   active_childrenu   Pipeu
   connectionu   JoinableQueueN(   u   Queueu   Locku   RLocku	   Semaphoreu   BoundedSemaphoreu	   Conditionu   Eventu   Valueu   Arrayu   RawValueu   RawArrayu   current_processu   active_childrenu   Pipeu
   connectionu   JoinableQueue(   u   __name__u
   __module__u   TYPEu   multiprocessingu   Processu   localsu   updateu   get_attributes(   u
   __locals__(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   ProcessesMixin«  s   
	   u   ProcessesMixinu   typeu	   processesc             B   sK   |  Ee  Z d  Z e j Z e j e j j ƒ Z	 e
 ƒ  j e e	 d ƒ ƒ d S(   u   manageru   Queueu   Locku   RLocku	   Semaphoreu   BoundedSemaphoreu	   Conditionu   Eventu   Valueu   Arrayu   listu   dictu	   Namespaceu   JoinableQueueN(   u   Queueu   Locku   RLocku	   Semaphoreu   BoundedSemaphoreu	   Conditionu   Eventu   Valueu   Arrayu   listu   dictu	   Namespaceu   JoinableQueue(   u   __name__u
   __module__u   TYPEu   multiprocessingu   Processu   objectu   __new__u   managersu   SyncManageru   manageru   localsu   updateu   get_attributes(   u
   __locals__(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   ManagerMixin¹  s   
	  u   ManagerMixinu   managerc             B   s<   |  Ee  Z d  Z e j j Z e ƒ  j e e j d ƒ ƒ d S(   u   threadsu   Queueu   Locku   RLocku	   Semaphoreu   BoundedSemaphoreu	   Conditionu   Eventu   Valueu   Arrayu   current_processu   active_childrenu   Pipeu
   connectionu   dictu   listu	   Namespaceu   JoinableQueueN(   u   Queueu   Locku   RLocku	   Semaphoreu   BoundedSemaphoreu	   Conditionu   Eventu   Valueu   Arrayu   current_processu   active_childrenu   Pipeu
   connectionu   dictu   listu	   Namespaceu   JoinableQueue(	   u   __name__u
   __module__u   TYPEu   multiprocessingu   dummyu   Processu   localsu   updateu   get_attributes(   u
   __locals__(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   ThreadsMixinÇ  s   
   u   ThreadsMixinu   threadsc             B   s    |  Ee  Z d  „  Z d „  Z d S(   c             C   s9   Gd „  d t  ƒ } |  j t j t j j | ƒ  d ƒ d  S(   Nc             B   s    |  Ee  Z d  „  Z d „  Z d S(   c             S   s   d S(   Ns   something bogus(    (   u   selfu   size(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu
   recv_bytesØ  s    c             S   s   d  S(   N(    (   u   selfu   data(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu
   send_bytesÚ  s    N(   u   __name__u
   __module__u
   recv_bytesu
   send_bytes(   u
   __locals__(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   _FakeConnection×  s   
	u   _FakeConnections   abc(   u   objectu   assertRaisesu   multiprocessingu   AuthenticationErroru
   connectionu   deliver_challenge(   u   selfu   _FakeConnection(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu#   test_deliver_challenge_auth_failureÖ  s    	c             C   s9   Gd „  d t  ƒ } |  j t j t j j | ƒ  d ƒ d  S(   Nc             B   s)   |  Ee  Z d  „  Z d „  Z d „  Z d S(   c             S   s   d |  _  d  S(   Ni    (   u   count(   u   self(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   __init__â  s    c             S   sC   |  j  d 7_  |  j  d k o t j j S|  j  d k o d Sd S(   Ni   i   s   something boguss    (   u   countu   multiprocessingu
   connectionu	   CHALLENGE(   u   selfu   size(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu
   recv_bytesä  s    c             S   s   d  S(   N(    (   u   selfu   data(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu
   send_bytesë  s    N(   u   __name__u
   __module__u   __init__u
   recv_bytesu
   send_bytes(   u
   __locals__(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   _FakeConnectioná  s   
		u   _FakeConnections   abc(   u   objectu   assertRaisesu   multiprocessingu   AuthenticationErroru
   connectionu   answer_challenge(   u   selfu   _FakeConnection(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu"   test_answer_challenge_auth_failureà  s    	N(   u   __name__u
   __module__u#   test_deliver_challenge_auth_failureu"   test_answer_challenge_auth_failure(   u
   __locals__(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu	   OtherTestÔ  s   
	
u	   OtherTestc                s¾  t  j j d ƒ oG y t j ƒ  } WqZ t k
 o$ d d l m } | d ƒ ‚ YqZ Xn |  d  k o d d l m	 }  n t
 j ƒ  t j ƒ  j t ƒ t j d ƒ t _ t j j d ƒ t _ t j j ƒ  t j j ƒ  t j j d ƒ t _ t t j ƒ  d d „  ƒt t j ƒ  d d	 „  ƒt t j ƒ  d d
 „  ƒt } t j j  ‰  t j! ‡  f d †  | Dƒ ƒ } |  | ƒ t j j" ƒ  t j j" ƒ  t j j" ƒ  t j j# ƒ  t ` t ` t ` d  S(   Nu   linuxi    (   u   TestSkippedu1   OSError raises on RLock creation, see issue 3111!(   u   run_unittesti   u   keyc             S   s   |  j  S(    (   u   __name__(   u   tc(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   <lambda>  s    c             S   s   |  j  S(    (   u   __name__(   u   tc(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   <lambda>  s    c             S   s   |  j  S(    (   u   __name__(   u   tc(    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   <lambda>  s    c             3   s   |  ] } ˆ  | ƒ Vq d  S(   N(    (   u   .0u   tc(   u   loadTestsFromTestCase(    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu	   <genexpr>  s    ($   u   sysu   platformu
   startswithu   multiprocessingu   RLocku   OSErroru   test.supportu   TestSkippedu   Noneu   run_unittestu   utilu   get_temp_diru
   get_loggeru   setLevelu	   LOG_LEVELu   Poolu   ProcessesMixinu   poolu   dummyu   ThreadsMixinu   ManagerMixinu   manageru   __init__u   startu   sortedu   testcases_processesu   valuesu   testcases_threadsu   testcases_manageru   testcases_otheru   unittestu   defaultTestLoaderu   loadTestsFromTestCaseu	   TestSuiteu	   terminateu   shutdown(   u   runu   locku   TestSkippedu	   testcasesu   suite(    (   u   loadTestsFromTestCaseu6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu	   test_main÷  s2    
J
c               C   s   t  t j d d ƒ j ƒ d  S(   Nu	   verbosityi   (   u	   test_mainu   unittestu   TextTestRunneru   run(    (    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   main  s    u   __main__F(   g=
×£p=ê?gffffffÖ?gffffffö?(   gš™™™™™¹?gš™™™™™¹?gš™™™™™¹?(   u   fu   _h(j   u   unittestu	   threadingu   queueu   pyqueueu   timeu   sysu   osu   gcu   signalu   arrayu   copyu   socketu   randomu   loggingu   multiprocessing.synchronizeu   multiprocessingu   ImportErroru   eu   test.test_supportu   TestSkippedu   multiprocessing.dummyu   multiprocessing.connectionu   multiprocessing.managersu   multiprocessing.heapu   multiprocessing.poolu   _multiprocessingu   utilu   latinu
   SUBWARNINGu	   LOG_LEVELu   DELTAu   Falseu   CHECK_TIMINGSu   TIMEOUT1u   TIMEOUT2u   TIMEOUT3u   getattru   HAVE_GETVALUEu   objectu   TimingWrapperu   BaseTestCaseu	   get_valueu   _TestProcessu   Processu   _UpperCaseru   _TestSubclassingProcessu   queue_emptyu
   queue_fullu
   _TestQueueu	   _TestLocku   _TestSemaphoreu   _TestConditionu
   _TestEventu
   _TestValueu
   _TestArrayu   _TestContainersu   sqru	   _TestPoolu   _TestZZZNumberOfObjectsu   BaseManageru	   BaseProxyu   RemoteErroru   FooBaru   bazu   IteratorProxyu	   MyManageru   registeru   _TestMyManageru   Queueu   _queueu	   get_queueu   QueueManageru   QueueManager2u
   SERIALIZERu   _TestRemoteManageru   SENTINELu   _TestConnectionu   _TestListenerClientu	   _TestHeapu   ctypesu	   Structureu   Valueu   c_intu   c_doubleu   Noneu   _Foou   _TestSharedCTypesu   _TestFinalizeu   _TestImportStaru   _TestLoggingu   get_attributesu   create_test_casesu   ProcessesMixinu   testcases_processesu   globalsu   updateu   ManagerMixinu   testcases_manageru   ThreadsMixinu   testcases_threadsu   TestCaseu	   OtherTestu   testcases_otheru	   test_mainu   mainu   __name__(    (    (    u6   /mit/python/lib/python3.0/test/test_multiprocessing.pyu   <module>   sÈ    			–		Ð6„(==<I		$	,•m-,67*			


	'	