Ńň $8Zc@sdZddddddddd d d d d ddddddddddddddgZdZddkZddkZddklZlZlZdd k l Z l Z d!e fd"„ƒYZ d e fd#„ƒYZd e fd$„ƒYZd%e fd&„ƒYZddkZd'„Zed(„Zd)„Zd*„Zd+„Zdd,„Zd-„Zd.„Zd/„Zdd0„Zd1d2„Zd1d3„Zd4„Z d5d6„Z!d5d7„Z"ddd@d8„Z#d9„Z$d:„Z%d;„Z&d<„Z'ei(d=jod>„Z)ed?g7ZndS(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(RRR(RRt ProcessErrorcBseZRS((t__name__t __module__(((s./usr/lib/python2.6/multiprocessing/__init__.pyRFscBseZRS((RR(((s./usr/lib/python2.6/multiprocessing/__init__.pyR IscBseZRS((RR(((s./usr/lib/python2.6/multiprocessing/__init__.pyR LstAuthenticationErrorcBseZRS((RR(((s./usr/lib/python2.6/multiprocessing/__init__.pyROscCs'ddkl}|ƒ}|iƒ|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(tmultiprocessing.managersRtstart(Rtm((s./usr/lib/python2.6/multiprocessing/__init__.pyRYs  cCsddkl}||ƒS(s; Returns two connection object connected by a pipe i˙˙˙˙(R(tmultiprocessing.connectionR(tduplexR((s./usr/lib/python2.6/multiprocessing/__init__.pyRescCstidjo=yttidƒ}Wqättfj o d}qäXn˜dtijptidjo?yttidƒiƒƒ}Wqätj o d}qäXn9yti dƒ}Wn"tt t fj o d}nX|djo|St d ƒ‚d S( s2 Returns the number of CPUs in the system twin32tNUMBER_OF_PROCESSORSitbsdtdarwinssysctl -n hw.ncputSC_NPROCESSORS_ONLNiscannot determine number of cpusN( tsystplatformtinttostenviront ValueErrortKeyErrortpopentreadtsysconftOSErrortAttributeErrortNotImplementedError(tnum((s./usr/lib/python2.6/multiprocessing/__init__.pyRls"   cCsBtidjo.ttdtƒoddkl}|ƒ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./usr/lib/python2.6/multiprocessing/__init__.pyR…s#cCsddkl}|ƒS(sR Return package logger -- if it does not already exist then it is created i˙˙˙˙(R(tmultiprocessing.utilR(R((s./usr/lib/python2.6/multiprocessing/__init__.pyRŽscCsddkl}||ƒS(sB Turn on logging and add a handler which prints to stderr i˙˙˙˙(R(R<R(tlevelR((s./usr/lib/python2.6/multiprocessing/__init__.pyR•scCsddkl}dS(sO Install support for sending connections and sockets between processes i˙˙˙˙(t reductionN(tmultiprocessingR>(R>((s./usr/lib/python2.6/multiprocessing/__init__.pyR œscCsddkl}|ƒS(s- Returns a non-recursive lock object i˙˙˙˙(R (tmultiprocessing.synchronizeR (R ((s./usr/lib/python2.6/multiprocessing/__init__.pyR ŚscCsddkl}|ƒS(s) Returns a recursive lock object i˙˙˙˙(R (R@R (R ((s./usr/lib/python2.6/multiprocessing/__init__.pyR ­scCsddkl}||ƒS(s$ Returns a condition object i˙˙˙˙(R(R@R(tlockR((s./usr/lib/python2.6/multiprocessing/__init__.pyR´sicCsddkl}||ƒS(s$ Returns a semaphore object i˙˙˙˙(R(R@R(tvalueR((s./usr/lib/python2.6/multiprocessing/__init__.pyRťscCsddkl}||ƒS(s, Returns a bounded semaphore object i˙˙˙˙(R(R@R(RBR((s./usr/lib/python2.6/multiprocessing/__init__.pyRÂscCsddkl}|ƒS(s! Returns an event object i˙˙˙˙(R(R@R(R((s./usr/lib/python2.6/multiprocessing/__init__.pyRÉsicCsddkl}||ƒS(s Returns a queue object i˙˙˙˙(R(tmultiprocessing.queuesR(tmaxsizeR((s./usr/lib/python2.6/multiprocessing/__init__.pyRĐscCsddkl}||ƒS(s Returns a queue object i˙˙˙˙(R(RCR(RDR((s./usr/lib/python2.6/multiprocessing/__init__.pyR×scCs ddkl}||||ƒS(s' Returns a process pool object i˙˙˙˙(R(tmultiprocessing.poolR(t processest initializertinitargsR((s./usr/lib/python2.6/multiprocessing/__init__.pyRŢscGsddkl}|||ŒS(s! Returns a shared object i˙˙˙˙(R(tmultiprocessing.sharedctypesR(ttypecode_or_typetargsR((s./usr/lib/python2.6/multiprocessing/__init__.pyRĺscCsddkl}|||ƒS(s Returns a shared array i˙˙˙˙(R(RIR(RJtsize_or_initializerR((s./usr/lib/python2.6/multiprocessing/__init__.pyRěscOs ddkl}||||ŽS(s. Returns a synchronized shared object i˙˙˙˙(R(RIR(RJRKtkwdsR((s./usr/lib/python2.6/multiprocessing/__init__.pyRóscKs ddkl}||||S(s- Returns a synchronized shared array i˙˙˙˙(R(RIR(RJRLRMR((s./usr/lib/python2.6/multiprocessing/__init__.pyRúsR%cCsddkl}||ƒ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;RN(t executableRN((s./usr/lib/python2.6/multiprocessing/__init__.pyRNsRN((*t __version__t__all__t __author__R-R*tmultiprocessing.processRRRR<RRt ExceptionRR R Rt_multiprocessingRtTrueRRRRtNoneRR R R RRRRRRRRRRRR+RN(((s./usr/lib/python2.6/multiprocessing/__init__.pyt+sN