/usr/lib/python2.6/multiprocessing/
/usr/lib/python2.6/multiprocessing
NameSizeModeActions
dummy/-0755rm
connection.py126630644editdlrm
connection.pyc142160644editdlrm
connection.pyo140660644editdlrm
forking.py145380644editdlrm
forking.pyc142480644editdlrm
forking.pyo140840644editdlrm
heap.py57480644editdlrm
heap.pyc64780644editdlrm
heap.pyo60970644editdlrm
managers.py348040644editdlrm
managers.pyc382440644editdlrm
managers.pyo376300644editdlrm
pool.py176990644editdlrm
pool.pyc185310644editdlrm
pool.pyo180720644editdlrm
process.py79040644editdlrm
process.pyc94820644editdlrm
process.pyo87280644editdlrm
queues.py110890644editdlrm
queues.pyc116260644editdlrm
queues.pyo115230644editdlrm
reduction.py51240644editdlrm
reduction.pyc60000644editdlrm
reduction.pyo60000644editdlrm
sharedctypes.py61450644editdlrm
sharedctypes.pyc85010644editdlrm
sharedctypes.pyo84210644editdlrm
synchronize.py89660644editdlrm
synchronize.pyc104360644editdlrm
synchronize.pyo100980644editdlrm
util.py78390644editdlrm
util.pyc96840644editdlrm
util.pyo95890644editdlrm
__init__.py76270644editdlrm
__init__.pyc83170644editdlrm
__init__.pyo83170644editdlrm
Edit: /usr/lib/python2.6/multiprocessing/__init__.pyc (8317B)
Ńň Ťgc@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