��Qc@sdZd
dddddddd	d
ddd
ddddddddddddddgZ
dZddlZddlZddlmZmZmZ
dd l	m
Z
mZ
d!ef
d"��YZ
de
f
d#��YZde
f
d$��YZd%e
f
d&��YZddlZd'�Zed(�Zd)�Zd*�Zd+�Zdd,�Zd-�Zd.�Zd/�Zdd0�Zd1d2�Zd1d3�Zd4�Z d5d6�Z!d5d7�Z"ddd@dd8�Z#d9�Z$d:�Z%d;�Z&d<�Z'ej(d=krd>�Z)e
d?g
7Z
ndS(As0.70a1tProcesstcurrent_processtactive_childrentfreeze_supporttManagertPipet	cpu_countt
log_to_stderrt
get_loggertallow_connection_picklingtBufferTooShorttTimeoutErrortLocktRLockt	SemaphoretBoundedSemaphoret	ConditiontEventtQueuet
JoinableQueuetPooltValuetArraytRawValuetRawArraytSUBDEBUGt
SUBWARNINGs"R. Oudkerk (r.m.oudkerk@gmail.com)i�N(RR
R(RRtProcessErrorc
BseZ
RS((t__name__t
__module__(((s./sys/lib/python2.7/multiprocessing/__init__.pyRGs
c
BseZ
RS((RR(((s./sys/lib/python2.7/multiprocessing/__init__.pyR
Js
c
BseZ
RS((RR(((s./sys/lib/python2.7/multiprocessing/__init__.pyRMs
tAuthenticationErrorc
BseZ
RS((RR(((s./sys/lib/python2.7/multiprocessing/__init__.pyRPs
cCs'd
dlm
}
|�}
|
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�(
tSyncManager(tmultiprocessing.managersRtstart(Rt
m((s./sys/lib/python2.7/multiprocessing/__init__.pyRZs
	


c
Csd
dlm
}

|
|�S(s;
    Returns two connection object connected by a pipe
    i�(
R(tmultiprocessing.connectionR(tduplexR((s./sys/lib/python2.7/multiprocessing/__init__.pyRfs
cCs*
tj
d
krIyttjd�}Wq

ttfk
rE


d}q

Xn�dtj
ksgtj
dkr�d}
tj
dkr�d|
}
ny.tj|
��}t|j��}WdQXWq

tk
r�


d}q

Xn6ytj	d	�}Wn tt
tfk
r	



d}n
X|d
kr
|Std��dS(s2
    Returns the number of CPUs in the system
    twin32tNUMBER_OF_PROCESSORSitbsdtdarwins/sbin/sysctl -n hw.ncpus/usrNtSC_NPROCESSORS_ONLNi
scannot determine number of cpus(
tsystplatformtinttostenviront
ValueErrortKeyErrortpopentreadtsysconftOSErrortAttributeErrortNotImplementedError(tnumtcommt
p((s./sys/lib/python2.7/multiprocessing/__init__.pyRms*





















c
Cs?tj
d
kr;ttdt�r;ddlm}
|�
ndS(s�
    Check whether this is a fake forked process in a frozen executable.
    If so then run code specified by commandline and exit.
    R%tfrozeni�(
RN(R*R+tgetattrtFalsetmultiprocessing.forkingR(
R((s./sys/lib/python2.7/multiprocessing/__init__.pyR�s!

c
Csd
dlm
}
|�S(sR
    Return package logger -- if it does not already exist then it is created
    i�(
R(tmultiprocessing.utilR(
R((s./sys/lib/python2.7/multiprocessing/__init__.pyR�s
c
Csd
dlm
}

|
|�S(sB
    Turn on logging and add a handler which prints to stderr
    i�(
R(R>R(tlevelR((s./sys/lib/python2.7/multiprocessing/__init__.pyR�s
c
Csd
dlm
}
dS(sO
    Install support for sending connections and sockets between processes
    i�(
t	reductionN(tmultiprocessingR@(
R@((s./sys/lib/python2.7/multiprocessing/__init__.pyR	�sc
Csd
dlm
}
|�S(s-
    Returns a non-recursive lock object
    i�(
R(tmultiprocessing.synchronizeR(
R((s./sys/lib/python2.7/multiprocessing/__init__.pyR�s
c
Csd
dlm
}
|�S(s)
    Returns a recursive lock object
    i�(
R
(RBR
(
R
((s./sys/lib/python2.7/multiprocessing/__init__.pyR
�s
c
Csd
dlm
}

|
|�S(s$
    Returns a condition object
    i�(
R(RBR(tlockR((s./sys/lib/python2.7/multiprocessing/__init__.pyR�s
i
c
Csd
dlm
}

|
|�S(s$
    Returns a semaphore object
    i�(
R(RBR(tvalueR((s./sys/lib/python2.7/multiprocessing/__init__.pyR�s
c
Csd
dlm
}

|
|�S(s,
    Returns a bounded semaphore object
    i�(
R(RBR(RDR((s./sys/lib/python2.7/multiprocessing/__init__.pyR�s
c
Csd
dlm
}
|�S(s!
    Returns an event object
    i�(
R(RBR(
R((s./sys/lib/python2.7/multiprocessing/__init__.pyR�s
ic
Csd
dlm
}

|
|�S(s 
    Returns a queue object
    i�(
R(tmultiprocessing.queuesR(tmaxsizeR((s./sys/lib/python2.7/multiprocessing/__init__.pyR�s
c
Csd
dlm
}

|
|�S(s 
    Returns a queue object
    i�(
R(RER(RFR((s./sys/lib/python2.7/multiprocessing/__init__.pyR�s
cCs#d
dlm
}
|||
||�S(s'
    Returns a process pool object
    i�(
R(tmultiprocessing.poolR(t	processestinitializertinitargstmaxtasksperchildR((s./sys/lib/python2.7/multiprocessing/__init__.pyR�s
c
Gsd
dlm
}
|||
�S(s!
    Returns a shared object
    i�(
R(tmultiprocessing.sharedctypesR(ttypecode_or_typetargsR((s./sys/lib/python2.7/multiprocessing/__init__.pyR�s
cCsd
dlm
}
|||
�S(s 
    Returns a shared array
    i�(
R(RLR(RMtsize_or_initializerR((s./sys/lib/python2.7/multiprocessing/__init__.pyR�s
c
Os d
dlm
}
|||
|�S(s.
    Returns a synchronized shared object
    i�(
R(RLR(RMRNtkwdsR((s./sys/lib/python2.7/multiprocessing/__init__.pyR�s
cKs d
dlm
}
|||
|�S(s-
    Returns a synchronized shared array
    i�(
R(RLR(RMRORPR((s./sys/lib/python2.7/multiprocessing/__init__.pyR�s
R%c
Csd
dlm
}

|
|�
dS(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�(
tset_executableN(R=RQ(t
executableRQ((s./sys/lib/python2.7/multiprocessing/__init__.pyRQ
s
RQ((*t__version__t__all__t
__author__R-R*tmultiprocessing.processRR
RR>RRt	ExceptionRR
RRt_multiprocessingRtTrueRRRRtNoneRR	RR
RRRRRRRRRRRR+RQ(((s./sys/lib/python2.7/multiprocessing/__init__.pyt<module>,sN