o 0׾g|P@sdZddlmZddlZddlmZddlmZddlm Z ddl m Z ddl Z e e dd ZzddlZWn ey?dZYnwd gZd d gZejZejZee jgZerfegd 7ZddZddZddZdd Zdd Zeed r0ejZ ddZ!dd Zeedrej"Z#ddZ$e$Z"e%de%deedseedr/ddl&Z&ej'Z(ej)Z*ddZ+iZ,d d!Z-d8d#d$Z.d%d&Z'd9d(d)Z/ddd'e!fd*d+Z0e%d+e%ddevrddd'e$fd,d-Z1e%d-e j2sd.d Zdevrd/dZ"e%d&eed0rej3Z4ej5Z6d1d0Z3d2d3Z5e%d0e%d3nd4d Zdevr*d5dZ"e%d&ne7d e ee8eed6d7Z9e:e;eeZsr;cCsR|z|j|jtft|j<|r||ttW|dS|wr:)stopr5rstatustime_watched_children_on_child_hook_reap_childrenr)watchercallbackrrr _on_childsrD<cs:t}||fddtD}|D]}t|=qdS)Ncs*g|]\}}t|tr|dkr|qS)r)) isinstancetuple).0r5valoldest_allowedrr s z"_reap_children..)r>r?items)timeoutnowdeadr5rrJrrAs rAc CsZ|dkr^|dkr(d}tD]\}}t|tr'|dus!|d|kr'|}|d}q|dkr^|dkrY|dkrYt}|jdd}|||j|j fWdS1sTwYt ||S|tvr|t @smtt|trt|}t|trt|=|ddSdSt|}|j|d}t|Wdn1swY|j|j fSt ||S)a Wait for a child process to finish. If the child process was spawned using :func:`fork_and_watch`, then this function behaves cooperatively. If not, it *may* have race conditions; see :func:`fork_gevent` for more information. The arguments are as for the underlying :func:`os.waitpid`. Some combinations of *options* may not be supported cooperatively (as of 1.1 that includes WUNTRACED). Using a *pid* of 0 to request waiting on only processes from the current process group is not cooperative. A *pid* of -1 to wait for any child is non-blocking, but may or may not require a trip around the event loop, depending on whether any children have already terminated but not been waited on. Availability: POSIX. .. versionadded:: 1.1b1 .. versionchanged:: 1.2a1 More cases are handled in a cooperative manner. rNr)F)rr) r?rMrFrGrr childr"rpidr=_waitpid_WNOHANG) r5options finished_atkvr$rBr& new_watcherrrrwaitpids>!      r[FcCs4|ptj}|j||d}|t|<|t||dS)N)ref)rr rRr?startrD)r5rCr r\rBrrr _watch_childs r^cCs|}|r t|||||S)a Fork a child process and start a child watcher for it in the parent process. This call cooperates with :func:`waitpid` to enable cooperatively waiting for children to finish. When monkey-patching, these functions are patched in as :func:`os.fork` and :func:`os.waitpid`, respectively. In the child process, this function calls :func:`gevent.hub.reinit` before returning. Availability: POSIX. :keyword callback: If given, a callable that will be called with the child watcher when the child finishes. :keyword loop: The loop to start the watcher in. Defaults to the loop of the current hub. :keyword fork: The fork function. Defaults to :func:`the one defined in this module ` (which automatically calls :func:`gevent.hub.reinit`). Pass the builtin :func:`os.fork` function if you do not need to initialize gevent in the child process. .. versionadded:: 1.1b1 .. seealso:: :func:`gevent.monkey.get_original` To access the builtin :func:`os.fork`. )r^)rCr r\r r5rrrfork_and_watchsr_cs(gfdd}t||||dS)z Like :func:`fork_and_watch`, except using :func:`forkpty_gevent`. Availability: Some Unix systems. .. versionadded:: 1.1b5 cs}||dS)Nr)append) pid_and_fdr3r&rr_forks z forkpty_and_watch.._forkrr_)rCr r\r3rcrrbrforkpty_and_watchsrecOt|i|S)a Forks a child process and starts a child watcher for it in the parent process so that ``waitpid`` and SIGCHLD work as expected. This implementation of ``fork`` is a wrapper for :func:`fork_and_watch` when the environment variable ``GEVENT_NOWAITPID`` is *not* defined. This is the default and should be used by most applications. .. versionchanged:: 1.1b2 rdargskwargsrrrr s cOrf)a Like :func:`fork`, but using :func:`forkpty_gevent`. This implementation of ``forkpty`` is a wrapper for :func:`forkpty_and_watch` when the environment variable ``GEVENT_NOWAITPID`` is *not* defined. This is the default and should be used by most applications. .. versionadded:: 1.1b5 )rergrrrr3s posix_spawncOt|i|}t||Sr:)_raw_posix_spawnr^rhrir5rrrrjcOrkr:)_raw_posix_spawnpr^rmrrr posix_spawnprnrpcCr1)a Forks a child process, initializes gevent in the child, but *does not* prepare the parent to wait for the child or receive SIGCHLD. This implementation of ``fork`` is a wrapper for :func:`fork_gevent` when the environment variable ``GEVENT_NOWAITPID`` *is* defined. This is not recommended for most applications. r2rrrrr s cCr1)a~ Like :func:`fork`, but using :func:`os.forkpty` This implementation of ``forkpty`` is a wrapper for :func:`forkpty_gevent` when the environment variable ``GEVENT_NOWAITPID`` *is* defined. This is not recommended for most applications. .. versionadded:: 1.1b5 )r7rrrrr3s r)names_to_ignoredunder_names_to_keep)rE)NNF)=__doc__ __future__rr gevent.hubrrrgevent._configr gevent._utilrrgetattrrr ImportError__implements____extensions__readrwriter*EINTRrr r rr r hasattrr r/r0r3r4r7r`r>r[rTr9rUr@r?rDrAr^r_redisable_watch_childrenrjrlrproremoveglobals __imports__listset__all__rrrrs +                p