ó O'—^c@@s©dZddlmZddlZddlZddlZddlmZmZm Z m Z m Z m Z m Z ddlmZmZmZddlmZmZdKZd jeeedd !ƒƒd jed ƒZd ZdZdZdZdZdZdddddddddddddd d!d"d#d$d%d&d'd(d)d*d+d,d-d.d/d0gZ d1„Z!d2Z"d3„Z#e$e%e%d4„Z&d5„Z'd6„Z(d7„Z)dd8„Z+d9„Z,d:„Z-d;„Z.dd<„Z/dd=„Z0dd>„Z1d?„Z2dd@„Z3ddA„Z4dddLdddddddddde$de%e%dB„Z5dC„Z6dD„Z7dE„Z8dF„Z9dG„Z:dH„Z;dI„Z<ej=j>dJƒr¥e<e%ƒndS(Ms:Python multiprocessing fork with improvements and bugfixesi(tabsolute_importNi(t ProcessErrortBufferTooShortt TimeoutErrortAuthenticationErrortTimeLimitExceededtSoftTimeLimitExceededtWorkerLostError(tProcesstcurrent_processtactive_children(tSUBDEBUGt SUBWARNINGiit.its&R Oudkerk / Python Software Foundationspython-dev@python.orgs Ask Solemsask@celeryproject.orgs!http://github.com/celery/billiardtrestructuredtextRR R tfreeze_supporttManagertPipet cpu_countt log_to_stderrt get_loggertallow_connection_picklingRRtLocktRLockt SemaphoretBoundedSemaphoret ConditiontEventtQueuet JoinableQueuetPooltValuetArraytRawValuetRawArrayR R tset_executabletforking_enabletforking_is_enabledcC@sddlm}|ƒS(Ni(tensure_multiprocessing(t_extR'(R'((s3/tmp/pip-unpacked-wheel-40MfcW/billiard/__init__.pyR'<ssIforce_execv is not supported as the billiard C extension is not installedcC@s'ddlm}|ƒ}|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(tmanagersR)tstart(R)tm((s3/tmp/pip-unpacked-wheel-40MfcW/billiard/__init__.pyRKs  cC@s ddlm}||||ƒS(s; Returns two connection object connected by a pipe i(R(tbilliard.connectionR(tduplext rnonblockt wnonblockR((s3/tmp/pip-unpacked-wheel-40MfcW/billiard/__init__.pyRXscC@s*tjdkrIyttjdƒ}Wq ttfk rEd}q XnÁdtjksgtjdkrÔd}tjdkr‰d|}ny.tj|ƒ}t|jƒƒ}WdQXWq tk rÐd}q Xn6ytj d ƒ}Wn tt t fk r d}nX|d kr|St d ƒ‚dS( s2 Returns the number of CPUs in the system twin32tNUMBER_OF_PROCESSORSitbsdtdarwins/sbin/sysctl -n hw.ncpus/usrNtSC_NPROCESSORS_ONLNiscannot determine number of cpus( tsystplatformtinttostenviront ValueErrortKeyErrortpopentreadtsysconftOSErrortAttributeErrortNotImplementedError(tnumtcommtp((s3/tmp/pip-unpacked-wheel-40MfcW/billiard/__init__.pyR`s*      cC@s?tjdkr;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. R1tfrozeni(RN(R6R7tgetattrtFalsetforkingR(R((s3/tmp/pip-unpacked-wheel-40MfcW/billiard/__init__.pyR~s!cC@sddlm}|ƒS(sR Return package logger -- if it does not already exist then it is created i(R(tutilR(R((s3/tmp/pip-unpacked-wheel-40MfcW/billiard/__init__.pyRˆscC@sddlm}||ƒS(sB Turn on logging and add a handler which prints to stderr i(R(RJR(tlevelR((s3/tmp/pip-unpacked-wheel-40MfcW/billiard/__init__.pyRscC@sddlm}dS(sO Install support for sending connections and sockets between processes i(t reductionN(RRL(RL((s3/tmp/pip-unpacked-wheel-40MfcW/billiard/__init__.pyR˜scC@sddlm}|ƒS(s- Returns a non-recursive lock object i(R(t synchronizeR(R((s3/tmp/pip-unpacked-wheel-40MfcW/billiard/__init__.pyR£scC@sddlm}|ƒS(s) Returns a recursive lock object i(R(RMR(R((s3/tmp/pip-unpacked-wheel-40MfcW/billiard/__init__.pyR«scC@sddlm}||ƒS(s$ Returns a condition object i(R(RMR(tlockR((s3/tmp/pip-unpacked-wheel-40MfcW/billiard/__init__.pyR³scC@sddlm}||ƒS(s$ Returns a semaphore object i(R(RMR(tvalueR((s3/tmp/pip-unpacked-wheel-40MfcW/billiard/__init__.pyR»scC@sddlm}||ƒS(s, Returns a bounded semaphore object i(R(RMR(ROR((s3/tmp/pip-unpacked-wheel-40MfcW/billiard/__init__.pyRÃscC@sddlm}|ƒS(s! Returns an event object i(R(RMR(R((s3/tmp/pip-unpacked-wheel-40MfcW/billiard/__init__.pyRËscC@sddlm}||ƒS(s Returns a queue object i(R(tqueuesR(tmaxsizeR((s3/tmp/pip-unpacked-wheel-40MfcW/billiard/__init__.pyRÓscC@sddlm}||ƒS(s Returns a queue object i(R(RPR(RQR((s3/tmp/pip-unpacked-wheel-40MfcW/billiard/__init__.pyRÛscC@sJddlm}||||||||||| | | | | |||ƒS(s' Returns a process pool object i(R(tpoolR(t processest initializertinitargstmaxtasksperchildttimeoutt soft_timeouttlost_worker_timeoutt max_restartstmax_restart_freqt on_process_upton_process_downton_timeout_setton_timeout_canceltthreadst semaphoretputlockst allow_restartR((s3/tmp/pip-unpacked-wheel-40MfcW/billiard/__init__.pyRãs    cG@sddlm}|||ŒS(s! Returns a shared object i(R"(t sharedctypesR"(ttypecode_or_typetargsR"((s3/tmp/pip-unpacked-wheel-40MfcW/billiard/__init__.pyR"óscC@sddlm}|||ƒS(s Returns a shared array i(R#(RdR#(Retsize_or_initializerR#((s3/tmp/pip-unpacked-wheel-40MfcW/billiard/__init__.pyR#ûscO@s ddlm}||||ŽS(s. Returns a synchronized shared object i(R (RdR (ReRftkwdsR ((s3/tmp/pip-unpacked-wheel-40MfcW/billiard/__init__.pyR scK@s ddlm}||||S(s- Returns a synchronized shared array i(R!(RdR!(ReRgRhR!((s3/tmp/pip-unpacked-wheel-40MfcW/billiard/__init__.pyR! scC@sddlm}||ƒ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(R$N(RIR$(t executableR$((s3/tmp/pip-unpacked-wheel-40MfcW/billiard/__init__.pyR$scC@sddlm}|jS(s! Returns a boolean value indicating whether billiard is currently set to create child processes by forking the current python process rather than by starting a new instances of python. On Windows this always returns `False`. On Unix it returns `True` by default. i(RI(RRIt_forking_is_enabled(RI((s3/tmp/pip-unpacked-wheel-40MfcW/billiard/__init__.pyR&!s cC@s“|sddlm}|ryddlm}|rQttdƒ rQtdƒ‚nt|ƒ|_|sŒdtj dsj   4 0