Ńņ
$8Zc           @   s  d  d k  Z  d  d k Z d  d k Z d  d k l Z l Z d d d d d d g Z d	   Z d  d
 k l	 Z	 d e	 f d     YZ
 d   Z e
 i e e
 i  e  d   Z e
 i e e i  e  e
 i e e i  e  y d  d k l Z Wn e j
 o n$ Xd   Z d   Z e
 i e e  e i d j oA d  d k Z e  i Z e  i Z e  i Z d e  f d     YZ! n{d  d k" Z" d  d k# Z# d  d k$ Z$ d  d k Z d  d k% l& Z& l' Z' l( Z( d d k l) Z) d  d k l* Z* l+ Z+ d d  Z- d Z. e i d j o e/ e d e0  Z1 e& i2 Z e& i3 Z e i4 i5   i6 d  o e  i7 i8 e i9 d  a: n
 e i4 a: d   Z; d e0 d  Z d e  f d     YZ! d   Z< d    Z= d!   Z> d"   Z? d#   Z@ d$   ZA e
 i e' eA  e
 i e( eA  g  ZB d%   ZC d S(&   i’’’’N(   t   utilt   processt   Popent   assert_spawningt   exitt	   duplicatet   closet   ForkingPicklerc         C   s.   t  i   p t d t |   i   n d  S(   NsF   %s objects should only be shared between processes through inheritance(   R   t   thread_is_spawningt   RuntimeErrort   typet   __name__(   t   self(    (    s-   /usr/lib/python2.6/multiprocessing/forking.pyR      s    (   t   Picklerc           B   s&   e  Z e i i   Z e d     Z RS(   c            s      f d   } | |  i  | <d  S(   Nc            s#     |  } |  i  d | |  d  S(   Nt   obj(   t   save_reduce(   R   R   t   rv(   t   reduce(    s-   /usr/lib/python2.6/multiprocessing/forking.pyt
   dispatcher&   s    (   t   dispatch(   t   clsR
   R   R   (    (   R   s-   /usr/lib/python2.6/multiprocessing/forking.pyt   register$   s    (   R   t
   __module__R   R   t   copyt   classmethodR   (    (    (    s-   /usr/lib/python2.6/multiprocessing/forking.pyR   !   s   c         C   sG   |  i  d  j o t |  i |  i i f f St |  i  |  i i f f Sd  S(   N(   t   im_selft   Nonet   getattrt   im_classt   im_funct	   func_name(   t   m(    (    s-   /usr/lib/python2.6/multiprocessing/forking.pyt   _reduce_method+   s    c         C   s   t  |  i |  i f f S(   N(   R   t   __objclass__R   (   R   (    (    s-   /usr/lib/python2.6/multiprocessing/forking.pyt   _reduce_method_descriptor2   s    (   t   partialc         C   s#   t  |  i |  i |  i p h  f f S(   N(   t   _rebuild_partialt   funct   argst   keywords(   t   p(    (    s-   /usr/lib/python2.6/multiprocessing/forking.pyt   _reduce_partialA   s    c         C   s   t  |  | |  S(   N(   R#   (   R%   R&   R'   (    (    s-   /usr/lib/python2.6/multiprocessing/forking.pyR$   C   s    t   win32c           B   sD   e  Z d    Z e i d  Z d d  Z d   Z e	 d    Z
 RS(   c         C   s§   t  i i   t  i i   d  |  _ t i   |  _ |  i d j oa d t  i	 j o d d  k
 } | i   n | i   } t  i i   t  i i   t i |  n d  S(   Ni    t   randomi’’’’(   t   syst   stdoutt   flusht   stderrR   t
   returncodet   ost   forkt   pidt   modulesR+   t   seedt
   _bootstrapt   _exit(   R   t   process_objR+   t   code(    (    s-   /usr/lib/python2.6/multiprocessing/forking.pyt   __init__Y   s    	c         C   s   |  i  d  j o t i |  i |  \ } } | |  i j oT t i |  o t i |  |  _  q t i |  p t  t i	 |  |  _  q n |  i  S(   N(
   R0   R   R1   t   waitpidR3   t   WIFSIGNALEDt   WTERMSIGt	   WIFEXITEDt   AssertionErrort   WEXITSTATUS(   R   t   flagR3   t   sts(    (    s-   /usr/lib/python2.6/multiprocessing/forking.pyt   pollh   s    c         C   s   | d  j o |  i d  St i   | } d } xf |  i   } | d  j	 o Pn | t i   } | d j o Pn t | d | d  } t i |  q4 | S(   Ni    gü©ńŅMb@?i   g©?(   R   RC   t   timet   mint   sleep(   R   t   timeoutt   deadlinet   delayt   rest	   remaining(    (    s-   /usr/lib/python2.6/multiprocessing/forking.pyt   waits   s    c         C   sj   |  i  d  j oV y t i |  i t i  Wqf t j
 o) } |  i d d  d  j o   qb qf Xn d  S(   NRG   g¹?(	   R0   R   R1   t   killR3   t   signalt   SIGTERMt   OSErrorRL   (   R   t   e(    (    s-   /usr/lib/python2.6/multiprocessing/forking.pyt	   terminate   s    c           C   s   t  S(   N(   t   False(    (    (    s-   /usr/lib/python2.6/multiprocessing/forking.pyR      s    N(   R   R   R:   R1   t   WNOHANGRC   R   RL   RR   t   staticmethodR   (    (    (    s-   /usr/lib/python2.6/multiprocessing/forking.pyR   W   s
   		(   R*   t
   Connectiont   PipeConnectioni   (   t   Finalize(   t   loadt   HIGHEST_PROTOCOLc         C   s   t  | |  i |   d  S(   N(   R   t   dump(   R   t   filet   protocol(    (    s-   /usr/lib/python2.6/multiprocessing/forking.pyR[   ”   s    i   t   frozens   pythonservice.exes
   python.exec         C   s
   |  a  d  S(   N(   t   _python_exe(   t   exe(    (    s-   /usr/lib/python2.6/multiprocessing/forking.pyt   set_executableø   s    c         C   sH   | d  j o t i   } n t i t i   |  | d | t i  i   S(   Ni    (   R   t   _subprocesst   GetCurrentProcesst   DuplicateHandlet   DUPLICATE_SAME_ACCESSt   Detach(   t   handlet   target_processt   inheritable(    (    s-   /usr/lib/python2.6/multiprocessing/forking.pyR   Ą   s
    c           B   s_   e  Z d  Z e i   Z d   Z e d    Z e d    Z	 d d  Z d   Z d   Z RS(   sH   
        Start a subprocess to run the code of a process object
        c      
   C   s7  t  i   \ } } t t i |  d t } t  i |  t   | g } d i d   | D  } t	 i
 t | d  d  d d d  d  d  	 \ } } } }	 | i   t |  | |  _ d  |  _ | |  _ t | i  }
 t  i | d  } t |  t i _ z$ t |
 | t  t | | t  Wd  t i ` | i   Xd  S(   NRi   t    c         s   s   x |  ] } d  | Vq Wd S(   s   "%s"N(    (   t   .0t   x(    (    s-   /usr/lib/python2.6/multiprocessing/forking.pys	   <genexpr>Ż   s   	 i   i    t   wb(   R1   t   pipeR   t   msvcrtt   get_osfhandlet   TrueR   t   get_command_linet   joinRb   t   CreateProcessR_   R   t   CloseR3   R0   t   _handlet   get_preparation_datat   _namet   fdopent   intR   t   _tlst   process_handleR[   RZ   (   R   R8   t   rfdt   wfdt   rhandlet   cmdt   hpt   htR3   t   tidt	   prep_datat   to_child(    (    s-   /usr/lib/python2.6/multiprocessing/forking.pyR:   Ó   s(    -

				c           C   s   t  t i d d   d  j	 S(   NR|   (   R   R   R{   R   (    (    (    s-   /usr/lib/python2.6/multiprocessing/forking.pyR   ō   s    c         C   s   t  |  t i i  S(   N(   R   R   R{   R|   (   Rg   (    (    s-   /usr/lib/python2.6/multiprocessing/forking.pyt   duplicate_for_childų   s    c         C   s·   |  i  d  j o  | d  j o t i } n t d t | d d   } t i t |  i  |  } | t i j o: t i	 |  i  } | t
 j o t i } n | |  _  q° n |  i  S(   Ni    ič  g      ą?(   R0   R   Rb   t   INFINITEt   maxRz   t   WaitForSingleObjectRv   t   WAIT_OBJECT_0t   GetExitCodeProcesst	   TERMINATERN   RO   (   R   RG   t   msecsRJ   R9   (    (    s-   /usr/lib/python2.6/multiprocessing/forking.pyRL   ü   s    c         C   s   |  i  d d  S(   NRG   i    (   RL   (   R   (    (    s-   /usr/lib/python2.6/multiprocessing/forking.pyRC     s    c         C   sk   |  i  d  j oW y t i t |  i  t  Wqg t j
 o' |  i d d  d  j o   qc qg Xn d  S(   NRG   g¹?(	   R0   R   Rb   t   TerminateProcessRz   Rv   R   t   WindowsErrorRL   (   R   (    (    s-   /usr/lib/python2.6/multiprocessing/forking.pyRR     s    N(   R   R   t   __doc__t   threadt   _localR{   R:   RU   R   R   R   RL   RC   RR   (    (    (    s-   /usr/lib/python2.6/multiprocessing/forking.pyR   Ķ   s   	!	c         C   sK   t  |   d j o0 |  d d j o t  |   d j p t  t St Sd S(   sE   
        Return whether commandline indicates we are forking
        i   i   s   --multiprocessing-forki   N(   t   lenR?   Rq   RS   (   t   argv(    (    s-   /usr/lib/python2.6/multiprocessing/forking.pyt
   is_forking  s    $c           C   s)   t  t i  o t   t i   n d S(   sM   
        Run code for process object if this in not the main process
        N(   R   R,   R   t   mainR   (    (    (    s-   /usr/lib/python2.6/multiprocessing/forking.pyt   freeze_support&  s    c          C   sq   t  i   i d j o  t t i  o t d   n t t d t  o t i	 d g Sd }  t
 d |  d g Sd S(   sR   
        Returns prefix of command line used for spawning a child process
        s÷  
            Attempt to start a new process before the current process
            has finished its bootstrapping phase.

            This probably means that you are on Windows and you have
            forgotten to use the proper idiom in the main module:

                if __name__ == '__main__':
                    freeze_support()
                    ...

            The "freeze_support()" line can be omitted if the program
            is not going to be frozen to produce a Windows executable.R^   s   --multiprocessing-forks0   from multiprocessing.forking import main; main()s   -cN(    (   R   t   current_processt	   _identityR   R,   R   R	   R   RS   t
   executableR_   (   t   prog(    (    s-   /usr/lib/python2.6/multiprocessing/forking.pyRr   /  s    &c          C   sµ   t  t i  p t  t t i d  }  t i |  t i  } t i	 | d  } t
 t i   _ t |  } t |  t |  } t t i   _ | i   | i   } t |  d S(   s>   
        Run code specifed by data received over pipe
        i’’’’t   rbN(   R   R,   R   R?   Rz   Ro   t   open_osfhandleR1   t   O_RDONLYRy   Rq   R   R   t   _inheritingRY   t   prepareRS   R   R6   R   (   Rg   t   fdt   from_parentt   preparation_dataR   t   exitcode(    (    s-   /usr/lib/python2.6/multiprocessing/forking.pyR   I  s    

c         C   s2  d d k  l } l } t d |  d t i d t i d | d t i d t i	   i
  } | d j	 o | i   | d	 <n t p± t t i d
 d d  } | o% t i d d j o t i d } n | d j	 oZ t i i |  o, t i d j	 o t i i t i |  } n t i i |  | d <q.n | S(   sU   
        Return info about parent needed by child to unpickle process object
        i   (   t   _loggert   _log_to_stderrt   namet   sys_patht   sys_argvt   log_to_stderrt   orig_dirt   authkeyt	   log_levelt   __main__t   __file__i    t    s   -ct	   main_pathN(   R°   s   -c(   R    R„   R¦   t   dictR,   t   pathR   R   t   ORIGINAL_DIRR   R¬   R   t   getEffectiveLevelt   WINEXER   R4   R1   t   isabsRs   t   normpath(   R§   R„   R¦   t   dR±   (    (    s-   /usr/lib/python2.6/multiprocessing/forking.pyRw   _  s(    			c         C   sX   t  i   p t d t |   i   n t |   t  i |  i    |  i |  i f f S(   NsL   By default %s objects can only be shared between processes
using inheritance(	   R   R   R	   R
   R   R   t   filenot   readablet   writable(   t   conn(    (    s-   /usr/lib/python2.6/multiprocessing/forking.pyt   reduce_connection  s    c   
   
   C   sń  t  i t i d  d |  j o |  d t i   _ n d |  j o |  d t i   _ n d |  j o |  d o t i	   n d |  j o t i
   i |  d  n d |  j o |  d t _ n d |  j o |  d t _ n d |  j o t i |  d  n d	 |  j o |  d	 t _ n d
 |  j oŗ|  d
 } t i i t i i |   d } | d j o" t i i t i i |   } n | d j oNd d k } | d j o
 d } nW t i i |  i d  o% t i i t i i |   g } n t i i |  g } | t i j p
 t |  | i | |  \ } } } z | i d | | |  } Wd | o | i   n X| t i d <d | _ xR | i i   D]= }	 y! |	 i d j o d |	 _ n Wq¤t j
 o q¤Xq¤Wqķn d S(   sE   
    Try to get current process ready to unpickle process object
    R®   R§   R¬   RŖ   R­   RØ   R©   t   dirR«   R±   i    R:   t   ipythoni’’’’Ns   __init__.pyt   __parents_main__(    t   old_main_modulest   appendR,   R4   R   R   R§   t   _authkeyR    RŖ   t
   get_loggert   setLevelR³   R   R1   t   chdirR“   t   splitextt   basenamet   dirnamet   impR   t
   startswithR?   t   find_modulet   load_moduleR   R   t   __dict__t   valuesR   t	   Exception(
   t   dataR±   t	   main_nameRĖ   t   dirsR\   t	   path_namet   etct   main_moduleR   (    (    s-   /usr/lib/python2.6/multiprocessing/forking.pyR      sZ    
""
%	 (D   R1   R,   RN   t   multiprocessingR    R   t   __all__R   t   pickleR   R   R    R   R
   t   saveR"   t   listRĆ   Rz   t   __add__t	   functoolsR#   t   ImportErrorR)   R$   t   platformRD   R7   R   t   dupR   R   t   objectR   R   Ro   Rb   t   _multiprocessingR*   RV   RW   RX   RY   RZ   R   R[   R   R   RS   R¶   t   ExitProcesst   CloseHandleR   t   lowert   endswithR³   Rs   t   exec_prefixR_   Ra   R   R   Rr   R   Rw   R¾   RĀ   R    (    (    (    s-   /usr/lib/python2.6/multiprocessing/forking.pyt   <module>	   sj   	
							="				N						"		