fc@sdZddddddddd d d d d ddddddddddddddddgZdZdd lZdd lZdd!lmZmZmZdd"l m Z m Z Gd#d$d$e Z Gd%d d e ZGd&d d e ZGd'd(d(e Zdd lZd)dZdDd*dZd+dZd,dZd-d Zd d.dZd/d Zd0d Zd1dZd d2dZd3d4dZd3d5dZd6dZ d d d7dZ!dd8dZ"dd9dZ#d:dZ$d d fd d;dZ%d<dZ&d=dZ'd>dDd?dZ(d>dDd@dZ)ej*dAkr}dBdCZ+edCg7Znd S(Eu0.70a1uProcessucurrent_processuactive_childrenufreeze_supportuManageruPipeu cpu_countu log_to_stderru get_loggeruallow_connection_picklinguBufferTooShortu TimeoutErroruLockuRLocku SemaphoreuBoundedSemaphoreu ConditionuEventuBarrieruQueueu SimpleQueueu JoinableQueueuPooluValueuArrayuRawValueuRawArrayuSUBDEBUGu SUBWARNINGu"R. Oudkerk (r.m.oudkerk@gmail.com)iN(uProcessucurrent_processuactive_children(uSUBDEBUGu SUBWARNINGcBs|EeZdZdS(u ProcessErrorN(u__name__u __module__u __qualname__(u __locals__((u=/opt/alt/python33/lib64/python3.3/multiprocessing/__init__.pyu ProcessError.su ProcessErrorcBs|EeZdZdS(uBufferTooShortN(u__name__u __module__u __qualname__(u __locals__((u=/opt/alt/python33/lib64/python3.3/multiprocessing/__init__.pyuBufferTooShort1scBs|EeZdZdS(u TimeoutErrorN(u__name__u __module__u __qualname__(u __locals__((u=/opt/alt/python33/lib64/python3.3/multiprocessing/__init__.pyu TimeoutError4scBs|EeZdZdS(uAuthenticationErrorN(u__name__u __module__u __qualname__(u __locals__((u=/opt/alt/python33/lib64/python3.3/multiprocessing/__init__.pyuAuthenticationError7suAuthenticationErrorcCs'ddlm}|}|j|S(u 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(u SyncManager(umultiprocessing.managersu SyncManagerustart(u SyncManagerum((u=/opt/alt/python33/lib64/python3.3/multiprocessing/__init__.pyuManager@s  cCsddlm}||S(u; Returns two connection object connected by a pipe i(uPipe(umultiprocessing.connectionuPipe(uduplexuPipe((u=/opt/alt/python33/lib64/python3.3/multiprocessing/__init__.pyuPipeLscCs-tjdkrJyttjd}Wq ttfk rFd}Yq Xndtjkshtjdkrd}tjdkrd|}ny.tj|}t|j}WdQXWq tk rd}Yq Xn7ytj d }Wn!tt t fk r d}YnX|d kr|St d dS( u2 Returns the number of CPUs in the system uwin32uNUMBER_OF_PROCESSORSiubsdudarwinu/sbin/sysctl -n hw.ncpuu/usrNuSC_NPROCESSORS_ONLNiucannot determine number of cpus( usysuplatformuintuosuenvironu ValueErroruKeyErrorupopenureadusysconfuOSErroruAttributeErroruNotImplementedError(unumucommup((u=/opt/alt/python33/lib64/python3.3/multiprocessing/__init__.pyu cpu_countSs*    cCs?tjdkr;ttddr;ddlm}|ndS(u Check whether this is a fake forked process in a frozen executable. If so then run code specified by commandline and exit. uwin32ufrozeni(ufreeze_supportNF(usysuplatformugetattruFalseumultiprocessing.forkingufreeze_support(ufreeze_support((u=/opt/alt/python33/lib64/python3.3/multiprocessing/__init__.pyufreeze_supportps!cCsddlm}|S(uR Return package logger -- if it does not already exist then it is created i(u get_logger(umultiprocessing.utilu get_logger(u get_logger((u=/opt/alt/python33/lib64/python3.3/multiprocessing/__init__.pyu get_loggeryscCsddlm}||S(uB Turn on logging and add a handler which prints to stderr i(u log_to_stderr(umultiprocessing.utilu log_to_stderr(ulevelu log_to_stderr((u=/opt/alt/python33/lib64/python3.3/multiprocessing/__init__.pyu log_to_stderrscCsddl}dS(uO Install support for sending connections and sockets between processes iN(umultiprocessing.connection(umultiprocessing((u=/opt/alt/python33/lib64/python3.3/multiprocessing/__init__.pyuallow_connection_picklingscCsddlm}|S(u- Returns a non-recursive lock object i(uLock(umultiprocessing.synchronizeuLock(uLock((u=/opt/alt/python33/lib64/python3.3/multiprocessing/__init__.pyuLockscCsddlm}|S(u) Returns a recursive lock object i(uRLock(umultiprocessing.synchronizeuRLock(uRLock((u=/opt/alt/python33/lib64/python3.3/multiprocessing/__init__.pyuRLockscCsddlm}||S(u$ Returns a condition object i(u Condition(umultiprocessing.synchronizeu Condition(ulocku Condition((u=/opt/alt/python33/lib64/python3.3/multiprocessing/__init__.pyu ConditionsicCsddlm}||S(u$ Returns a semaphore object i(u Semaphore(umultiprocessing.synchronizeu Semaphore(uvalueu Semaphore((u=/opt/alt/python33/lib64/python3.3/multiprocessing/__init__.pyu SemaphorescCsddlm}||S(u, Returns a bounded semaphore object i(uBoundedSemaphore(umultiprocessing.synchronizeuBoundedSemaphore(uvalueuBoundedSemaphore((u=/opt/alt/python33/lib64/python3.3/multiprocessing/__init__.pyuBoundedSemaphorescCsddlm}|S(u! Returns an event object i(uEvent(umultiprocessing.synchronizeuEvent(uEvent((u=/opt/alt/python33/lib64/python3.3/multiprocessing/__init__.pyuEventscCs ddlm}||||S(u" Returns a barrier object i(uBarrier(umultiprocessing.synchronizeuBarrier(upartiesuactionutimeoutuBarrier((u=/opt/alt/python33/lib64/python3.3/multiprocessing/__init__.pyuBarrierscCsddlm}||S(u Returns a queue object i(uQueue(umultiprocessing.queuesuQueue(umaxsizeuQueue((u=/opt/alt/python33/lib64/python3.3/multiprocessing/__init__.pyuQueuescCsddlm}||S(u Returns a queue object i(u JoinableQueue(umultiprocessing.queuesu JoinableQueue(umaxsizeu JoinableQueue((u=/opt/alt/python33/lib64/python3.3/multiprocessing/__init__.pyu JoinableQueuescCsddlm}|S(u Returns a queue object i(u SimpleQueue(umultiprocessing.queuesu SimpleQueue(u SimpleQueue((u=/opt/alt/python33/lib64/python3.3/multiprocessing/__init__.pyu SimpleQueuescCs#ddlm}|||||S(u' Returns a process pool object i(uPool(umultiprocessing.pooluPool(u processesu initializeruinitargsumaxtasksperchilduPool((u=/opt/alt/python33/lib64/python3.3/multiprocessing/__init__.pyuPoolscGsddlm}|||S(u! Returns a shared object i(uRawValue(umultiprocessing.sharedctypesuRawValue(utypecode_or_typeuargsuRawValue((u=/opt/alt/python33/lib64/python3.3/multiprocessing/__init__.pyuRawValuescCsddlm}|||S(u Returns a shared array i(uRawArray(umultiprocessing.sharedctypesuRawArray(utypecode_or_typeusize_or_initializeruRawArray((u=/opt/alt/python33/lib64/python3.3/multiprocessing/__init__.pyuRawArraysulockcGs#ddlm}||d||S(u. Returns a synchronized shared object i(uValueulock(umultiprocessing.sharedctypesuValue(utypecode_or_typeulockuargsuValue((u=/opt/alt/python33/lib64/python3.3/multiprocessing/__init__.pyuValuescCs#ddlm}|||d|S(u- Returns a synchronized shared array i(uArrayulock(umultiprocessing.sharedctypesuArray(utypecode_or_typeusize_or_initializerulockuArray((u=/opt/alt/python33/lib64/python3.3/multiprocessing/__init__.pyuArraysuwin32cCsddlm}||dS(u 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(uset_executableN(umultiprocessing.forkinguset_executable(u executableuset_executable((u=/opt/alt/python33/lib64/python3.3/multiprocessing/__init__.pyuset_executablesuset_executableT(,u __version__u__all__u __author__uosusysumultiprocessing.processuProcessucurrent_processuactive_childrenumultiprocessing.utiluSUBDEBUGu SUBWARNINGu Exceptionu ProcessErroruBufferTooShortu TimeoutErroruAuthenticationErroru_multiprocessinguManageruTrueuPipeu cpu_countufreeze_supportu get_loggeruNoneu log_to_stderruallow_connection_picklinguLockuRLocku Conditionu SemaphoreuBoundedSemaphoreuEventuBarrieruQueueu JoinableQueueu SimpleQueueuPooluRawValueuRawArrayuValueuArrayuplatformuset_executable(((u=/opt/alt/python33/lib64/python3.3/multiprocessing/__init__.pyusR