o e|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;eeZsr6cCsR|z|j|jtft|j<|r||ttW|dS|wr5)stopr2rstatustime_watched_children_on_child_hook_reap_childrenr)watchercallbackrrr _on_childsr?<cs:t}||fddtD}|D]}t|=qdS)Ncs*g|]\}}t|tr|dkr|qS)r&) isinstancetuple).0r2valZoldest_allowedrr s z"_reap_children..)r9r:items)timeoutnowZdeadr2rrErr<s r<c 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:rGrArBrrchildrZrpidr8_waitpid_WNOHANG) r2optionsZ finished_atkvr!r=r#Z new_watcherrrrwaitpids>!      rQFcCs4|ptj}|j||d}|t|<|t||dS)N)ref)rrrKr:startr?)r2r>rrRr=rrr _watch_childs rTcCs|}|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`. )rT)r>rrRr r2rrrfork_and_watchsrUcs(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)Z pid_and_fdr0r#rr_forks z forkpty_and_watch.._forkrrU)r>rrRr0rXrrWrforkpty_and_watchsrZcOt|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 rYargskwargsrrrr s cOr[)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 )rZr\rrrr0s posix_spawncOt|i|}t||Sr5)_raw_posix_spawnrTr]r^r2rrrr_cOr`r5)_raw_posix_spawnprTrbrrr posix_spawnprcrecCr.)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. r/rrrrr s cCr.)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 )r3rrrrr0s r)Znames_to_ignoreZdunder_names_to_keep)r@)NNF)=__doc__ __future__rrZ gevent.hubrrrZgevent._configrZ gevent._utilrrgetattrrr ImportErrorZ__implements__Z__extensions__readrwriter'ZEINTRrr r rr r hasattrr r,r-r0r1r3rVr9rQrLr4rMr;r:r?r<rTrUrZZdisable_watch_childrenr_rarerdremoveglobalsZ __imports__listset__all__rrrrs +                p