/usr/lib64/python2.6/multiprocessing/
/usr/lib64/python2.6/multiprocessing
NameSizeModeActions
dummy/-0755rm
connection.py126630644editdlrm
connection.pyc142860644editdlrm
connection.pyo141360644editdlrm
forking.py145380644editdlrm
forking.pyc143140644editdlrm
forking.pyo141500644editdlrm
heap.py57480644editdlrm
heap.pyc65160644editdlrm
heap.pyo61350644editdlrm
managers.py348040644editdlrm
managers.pyc384620644editdlrm
managers.pyo378480644editdlrm
pool.py176990644editdlrm
pool.pyc186310644editdlrm
pool.pyo181720644editdlrm
process.py79040644editdlrm
process.pyc95340644editdlrm
process.pyo87800644editdlrm
queues.py110890644editdlrm
queues.pyc116960644editdlrm
queues.pyo115930644editdlrm
reduction.py51240644editdlrm
reduction.pyc60340644editdlrm
reduction.pyo60340644editdlrm
sharedctypes.py61450644editdlrm
sharedctypes.pyc85530644editdlrm
sharedctypes.pyo84730644editdlrm
synchronize.py89660644editdlrm
synchronize.pyc105060644editdlrm
synchronize.pyo101680644editdlrm
util.py78390644editdlrm
util.pyc97380644editdlrm
util.pyo96430644editdlrm
__init__.py76270644editdlrm
__init__.pyc83690644editdlrm
__init__.pyo83690644editdlrm
Edit: /usr/lib64/python2.6/multiprocessing/__init__.pyc (8369B)
Ńň Ť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__(((s0/usr/lib64/python2.6/multiprocessing/__init__.pyRFscBseZRS((RR(((s0/usr/lib64/python2.6/multiprocessing/__init__.pyR IscBseZRS((RR(((s0/usr/lib64/python2.6/multiprocessing/__init__.pyR LstAuthenticationErrorcBseZRS((RR(((s0/usr/lib64/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((s0/usr/lib64/python2.6/multiprocessing/__init__.pyRYs  cCsddkl}||ƒS(s; Returns two connection object connected by a pipe i˙˙˙˙(R(tmultiprocessing.connectionR(tduplexR((s0/usr/lib64/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((s0/usr/lib64/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((s0/usr/lib64/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((s0/usr/lib64/python2.6/multiprocessing/__init__.pyRŽscCsddkl}||ƒS(sB Turn on logging and add a handler which prints to stderr i˙˙˙˙(R(R<R(tlevelR((s0/usr/lib64/python2.6/multiprocessing/__init__.pyR•scCsddkl}dS(sO Install support for sending connections and sockets between processes i˙˙˙˙(t reductionN(tmultiprocessingR>(R>((s0/usr/lib64/python2.6/multiprocessing/__init__.pyR œscCsddkl}|ƒS(s- Returns a non-recursive lock object i˙˙˙˙(R (tmultiprocessing.synchronizeR (R ((s0/usr/lib64/python2.6/multiprocessing/__init__.pyR ŚscCsddkl}|ƒS(s) Returns a recursive lock object i˙˙˙˙(R (R@R (R ((s0/usr/lib64/python2.6/multiprocessing/__init__.pyR ­scCsddkl}||ƒS(s$ Returns a condition object i˙˙˙˙(R(R@R(tlockR((s0/usr/lib64/python2.6/multiprocessing/__init__.pyR´sicCsddkl}||ƒS(s$ Returns a semaphore object i˙˙˙˙(R(R@R(tvalueR((s0/usr/lib64/python2.6/multiprocessing/__init__.pyRťscCsddkl}||ƒS(s, Returns a bounded semaphore object i˙˙˙˙(R(R@R(RBR((s0/usr/lib64/python2.6/multiprocessing/__init__.pyRÂscCsddkl}|ƒS(s! Returns an event object i˙˙˙˙(R(R@R(R((s0/usr/lib64/python2.6/multiprocessing/__init__.pyRÉsicCsddkl}||ƒS(s Returns a queue object i˙˙˙˙(R(tmultiprocessing.queuesR(tmaxsizeR((s0/usr/lib64/python2.6/multiprocessing/__init__.pyRĐscCsddkl}||ƒS(s Returns a queue object i˙˙˙˙(R(RCR(RDR((s0/usr/lib64/python2.6/multiprocessing/__init__.pyR×scCs ddkl}||||ƒS(s' Returns a process pool object i˙˙˙˙(R(tmultiprocessing.poolR(t processest initializertinitargsR((s0/usr/lib64/python2.6/multiprocessing/__init__.pyRŢscGsddkl}|||ŒS(s! Returns a shared object i˙˙˙˙(R(tmultiprocessing.sharedctypesR(ttypecode_or_typetargsR((s0/usr/lib64/python2.6/multiprocessing/__init__.pyRĺscCsddkl}|||ƒS(s Returns a shared array i˙˙˙˙(R(RIR(RJtsize_or_initializerR((s0/usr/lib64/python2.6/multiprocessing/__init__.pyRěscOs ddkl}||||ŽS(s. Returns a synchronized shared object i˙˙˙˙(R(RIR(RJRKtkwdsR((s0/usr/lib64/python2.6/multiprocessing/__init__.pyRóscKs ddkl}||||S(s- Returns a synchronized shared array i˙˙˙˙(R(RIR(RJRLRMR((s0/usr/lib64/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((s0/usr/lib64/python2.6/multiprocessing/__init__.pyRNsRN((*t __version__t__all__t __author__R-R*tmultiprocessing.processRRRR<RRt ExceptionRR R Rt_multiprocessingRtTrueRRRRtNoneRR R R RRRRRRRRRRRR+RN(((s0/usr/lib64/python2.6/multiprocessing/__init__.pyt+sN