
Â�Â­Â�Â­Â�Â­Â�Â­Â�Â­Â�Â­Â�Â­Â�Â­Â�Â­Â�Â­Â�Â­Â�Â­Â�Â­Â�Â­Â�Â­Â�Â­Â�Â­Â�Â­
<!DOCTYPE html>
<html>
ó
wWS`c           @   s  d  Z  d d d d d d d d d	 d
 d d d d d d d d d d d d d d d d d g Z d Z d d l Z d d l Z d d l m Z m Z m Z d d  l	 m
 Z
 m Z d! e f d" „  ƒ  YZ d e f d# „  ƒ  YZ d e f d$ „  ƒ  YZ d% e f d& „  ƒ  YZ d d l Z d' „  Z e d( „ Z d) „  Z d* „  Z d+ „  Z d d, „ Z d- „  Z d. „  Z d/ „  Z d d0 „ Z d1 d2 „ Z d1 d3 „ Z d4 „  Z  d5 d6 „ Z! d5 d7 „ Z" d d d@ d d8 „ Z# d9 „  Z$ d: „  Z% d; „  Z& d< „  Z' e j( d= k rd> „  Z) e d? g 7Z n  d S(A   s   0.70a1t   Processt   current_processt   active_childrent   freeze_supportt   Managert   Pipet	   cpu_countt   log_to_stderrt
   get_loggert   allow_connection_picklingt   BufferTooShortt   TimeoutErrort   Lockt   RLockt	   Semaphoret   BoundedSemaphoret	   Conditiont   Eventt   Queuet   JoinableQueuet   Poolt   Valuet   Arrayt   RawValuet   RawArrayt   SUBDEBUGt
   SUBWARNINGs"   R. Oudkerk (r.m.oudkerk@gmail.com)iÿÿÿÿN(   R    R   R   (   R   R   t   ProcessErrorc           B   s   e  Z RS(    (   t   __name__t
   __module__(    (    (    s=   /opt/alt/python27/lib64/python2.7/multiprocessing/__init__.pyR   G   s   c           B   s   e  Z RS(    (   R   R   (    (    (    s=   /opt/alt/python27/lib64/python2.7/multiprocessing/__init__.pyR
   J   s   c           B   s   e  Z RS(    (   R   R   (    (    (    s=   /opt/alt/python27/lib64/python2.7/multiprocessing/__init__.pyR   M   s   t   AuthenticationErrorc           B   s   e  Z RS(    (   R   R   (    (    (    s=   /opt/alt/python27/lib64/python2.7/multiprocessing/__init__.pyR   P   s   c          C   s'   d d l  m }  |  ƒ  } | j ƒ  | S(   s¶   
    Returns a manager associated with a running server process

    The managers methods such as `Lock()`, `Condition()` and `Queue()`
    can be used to create shared objects.
    iÿÿÿÿ(   t   SyncManager(   t   multiprocessing.managersR   t   start(   R   t   m(    (    s=   /opt/alt/python27/lib64/python2.7/multiprocessing/__init__.pyR   Z   s    	
c         C   s   d d l  m } | |  ƒ S(   s;   
    Returns two connection object connected by a pipe
    iÿÿÿÿ(   R   (   t   multiprocessing.connectionR   (   t   duplexR   (    (    s=   /opt/alt/python27/lib64/python2.7/multiprocessing/__init__.pyR   f   s    c          C   s*  t  j d k rI y t t j d ƒ }  Wq
t t f k
 rE d }  q
XnÁ d t  j k sg t  j d k rÔ d } t  j d k r‰ d | } n  y. t j | ƒ � } t | j ƒ  ƒ }  Wd QXWq
t k
 rÐ d }  q
Xn6 y t j	 d	 ƒ }  Wn  t t
 t f k
 r	d }  n X|  d
 k r|  St d ƒ ‚ d S(   s2   
    Returns the number of CPUs in the system
    t   win32t   NUMBER_OF_PROCESSORSi    t   bsdt   darwins   /sbin/sysctl -n hw.ncpus   /usrNt   SC_NPROCESSORS_ONLNi   s   cannot determine number of cpus(   t   syst   platformt   intt   ost   environt
   ValueErrort   KeyErrort   popent   readt   sysconft   OSErrort   AttributeErrort   NotImplementedError(   t   numt   commt   p(    (    s=   /opt/alt/python27/lib64/python2.7/multiprocessing/__init__.pyR   m   s*    
c          C   s?   t  j d k r; t t  d t ƒ r; d d l m }  |  ƒ  n  d S(   sˆ   
    Check whether this is a fake forked process in a frozen executable.
    If so then run code specified by commandline and exit.
    R%   t   frozeniÿÿÿÿ(   R   N(   R*   R+   t   getattrt   Falset   multiprocessing.forkingR   (   R   (    (    s=   /opt/alt/python27/lib64/python2.7/multiprocessing/__init__.pyR   Š   s    !c          C   s   d d l  m }  |  ƒ  S(   sR   
    Return package logger -- if it does not already exist then it is created
    iÿÿÿÿ(   R   (   t   multiprocessing.utilR   (   R   (    (    s=   /opt/alt/python27/lib64/python2.7/multiprocessing/__init__.pyR   “   s    c         C   s   d d l  m } | |  ƒ S(   sB   
    Turn on logging and add a handler which prints to stderr
    iÿÿÿÿ(   R   (   R>   R   (   t   levelR   (    (    s=   /opt/alt/python27/lib64/python2.7/multiprocessing/__init__.pyR   š   s    c          C   s   d d l  m }  d S(   sO   
    Install support for sending connections and sockets between processes
    iÿÿÿÿ(   t	   reductionN(   t   multiprocessingR@   (   R@   (    (    s=   /opt/alt/python27/lib64/python2.7/multiprocessing/__init__.pyR	   ¡   s    c          C   s   d d l  m }  |  ƒ  S(   s-   
    Returns a non-recursive lock object
    iÿÿÿÿ(   R   (   t   multiprocessing.synchronizeR   (   R   (    (    s=   /opt/alt/python27/lib64/python2.7/multiprocessing/__init__.pyR   «   s    c          C   s   d d l  m }  |  ƒ  S(   s)   
    Returns a recursive lock object
    iÿÿÿÿ(   R   (   RB   R   (   R   (    (    s=   /opt/alt/python27/lib64/python2.7/multiprocessing/__init__.pyR   ²   s    c         C   s   d d l  m } | |  ƒ S(   s$   
    Returns a condition object
    iÿÿÿÿ(   R   (   RB   R   (   t   lockR   (    (    s=   /opt/alt/python27/lib64/python2.7/multiprocessing/__init__.pyR   ¹   s    i   c         C   s   d d l  m } | |  ƒ S(   s$   
    Returns a semaphore object
    iÿÿÿÿ(   R   (   RB   R   (   t   valueR   (    (    s=   /opt/alt/python27/lib64/python2.7/multiprocessing/__init__.pyR   À   s    c         C   s   d d l  m } | |  ƒ S(   s,   
    Returns a bounded semaphore object
    iÿÿÿÿ(   R   (   RB   R   (   RD   R   (    (    s=   /opt/alt/python27/lib64/python2.7/multiprocessing/__init__.pyR   Ç   s    c          C   s   d d l  m }  |  ƒ  S(   s!   
    Returns an event object
    iÿÿÿÿ(   R   (   RB   R   (   R   (    (    s=   /opt/alt/python27/lib64/python2.7/multiprocessing/__init__.pyR   Î   s    i    c         C   s   d d l  m } | |  ƒ S(   s    
    Returns a queue object
    iÿÿÿÿ(   R   (   t   multiprocessing.queuesR   (   t   maxsizeR   (    (    s=   /opt/alt/python27/lib64/python2.7/multiprocessing/__init__.pyR   Õ   s    c         C   s   d d l  m } | |  ƒ S(   s    
    Returns a queue object
    iÿÿÿÿ(   R   (   RE   R   (   RF   R   (    (    s=   /opt/alt/python27/lib64/python2.7/multiprocessing/__init__.pyR   Ü   s    c         C   s#   d d l  m } | |  | | | ƒ S(   s'   
    Returns a process pool object
    iÿÿÿÿ(   R   (   t   multiprocessing.poolR   (   t	   processest   initializert   initargst   maxtasksperchildR   (    (    s=   /opt/alt/python27/lib64/python2.7/multiprocessing/__init__.pyR   ã   s    c         G   s   d d l  m } | |  | Œ S(   s!   
    Returns a shared object
    iÿÿÿÿ(   R   (   t   multiprocessing.sharedctypesR   (   t   typecode_or_typet   argsR   (    (    s=   /opt/alt/python27/lib64/python2.7/multiprocessing/__init__.pyR   ê   s    c         C   s   d d l  m } | |  | ƒ S(   s    
    Returns a shared array
    iÿÿÿÿ(   R   (   RL   R   (   RM   t   size_or_initializerR   (    (    s=   /opt/alt/python27/lib64/python2.7/multiprocessing/__init__.pyR   ñ   s    c         O   s    d d l  m } | |  | | Ž S(   s.   
    Returns a synchronized shared object
    iÿÿÿÿ(   R   (   RL   R   (   RM   RN   t   kwdsR   (    (    s=   /opt/alt/python27/lib64/python2.7/multiprocessing/__init__.pyR   ø   s    c         K   s    d d l  m } | |  | | � S(   s-   
    Returns a synchronized shared array
    iÿÿÿÿ(   R   (   RL   R   (   RM   RO   RP   R   (    (    s=   /opt/alt/python27/lib64/python2.7/multiprocessing/__init__.pyR   ÿ   s    R%   c         C   s   d d l  m } | |  ƒ d S(   s»   
        Sets the path to a python.exe or pythonw.exe binary used to run
        child processes on Windows instead of sys.executable.
        Useful for people embedding Python.
        iÿÿÿÿ(   t   set_executableN(   R=   RQ   (   t
   executableRQ   (    (    s=   /opt/alt/python27/lib64/python2.7/multiprocessing/__init__.pyRQ     s    RQ   (    (*   t   __version__t   __all__t
   __author__R-   R*   t   multiprocessing.processR    R   R   R>   R   R   t	   ExceptionR   R
   R   R   t   _multiprocessingR   t   TrueR   R   R   R   t   NoneR   R	   R   R   R   R   R   R   R   R   R   R   R   R   R   R+   RQ   (    (    (    s=   /opt/alt/python27/lib64/python2.7/multiprocessing/__init__.pyt   <module>,   sN   							
									