B ÐH/\bLã@sndZddlmZddlZddlZddlmZddlmZddl m Z ddl m Z ddl mZddlZeed d ƒZy ddlZWnek r”dZYnXd gZd d gZejZejZeejgZeräedddg7Zdd„Zdd„Zdd„Zdd „Zdd „Z e!ed ƒr:ej"Z#dd„Z$dd „Z"e!edƒrHej%Z&dd„Z'e'Z%e (d¡e (d¡e!edƒs`e!edƒrDddl)Z)ej*Z+ej,Z-dd„Z.iZ/d d!„Z0d2d#d$„Z1d%d&„Z*ddd'e$fd(d)„Z2e (d)¡e (d¡dekræddd'e'fd*d+„Z3e (d+¡e j4sd,d „Z"dekrd-d„Z%e (d&¡n$d.d „Z"dekr.d/d„Z%e (d&¡n e 5d ¡eee6ƒeed0d1Z7e8e9eeƒƒZ:dS)3aQ Low-level operating system functions from :mod:`os`. Cooperative I/O =============== This module provides cooperative versions of :func:`os.read` and :func:`os.write`. These functions are *not* monkey-patched; you must explicitly call them or monkey patch them yourself. POSIX functions --------------- On POSIX, non-blocking IO is available. - :func:`nb_read` - :func:`nb_write` - :func:`make_nonblocking` All Platforms ------------- On non-POSIX platforms (e.g., Windows), non-blocking IO is not available. On those platforms (and on POSIX), cooperative IO can be done with the threadpool. - :func:`tp_read` - :func:`tp_write` Child Processes =============== The functions :func:`fork` and (on POSIX) :func:`forkpty` and :func:`waitpid` can be used to manage child processes. .. warning:: Forking a process that uses greenlets does not eliminate all non-running greenlets. Any that were scheduled in the hub of the forking thread in the parent remain scheduled in the child; compare this to how normal threads operate. (This behaviour may change is a subsequent major release.) é)Úabsolute_importN)Ú_get_hub_noargs)Úreinit)Úconfig)ÚPY3)Ú copy_globalsÚEAGAINé ÚforkÚtp_readÚtp_writeÚmake_nonblockingÚnb_readÚnb_writecCs<t |tjd¡}t|tj@ƒs8t |tj|tjB¡dSdS)z™Put the file descriptor *fd* into non-blocking mode if possible. :return: A boolean value that evaluates to True if successful. rTN)ÚfcntlZF_GETFLÚboolÚosÚ O_NONBLOCKZF_SETFL)ÚfdÚflags©rú(lib/python3.7/site-packages/gevent/os.pyr Lsc Cs¢d}d}zzxtyt||ƒ}|Stk rT}z|jtkr8‚tsDt ¡Wdd}~XYnX|dkrrtƒ}|j  |d¡}|  |¡q WWd|dk rœ|  ¡d}d}XdS)a Read up to *n* bytes from file descriptor *fd*. Return a byte string containing the bytes read, which may be shorter than *n*. If end-of-file is reached, an empty string is returned. The descriptor must be in non-blocking mode. Né) Ú_readÚOSErrorÚerrnoÚignored_errorsrÚsysÚ exc_clearÚget_hubÚloopÚioÚwaitÚclose)rÚnÚhubÚeventÚresultÚerrrrWs(  c Cs¢d}d}zzxtyt||ƒ}|Stk rT}z|jtkr8‚tsDt ¡Wdd}~XYnX|dkrrtƒ}|j  |d¡}|  |¡q WWd|dk rœ|  ¡d}d}XdS)zò Write some number of bytes from buffer *buf* to file descriptor *fd*. Return the number of bytes written, which may be less than the length of *buf*. The file descriptor must be in non-blocking mode. Né) Ú_writerrrrrrrr r!r"r#)rÚbufr%r&r'r(rrrrvs(  cCstƒj t||f¡S)zÊRead up to *n* bytes from file descriptor *fd*. Return a string containing the bytes read. If end-of-file is reached, an empty string is returned. Reading is done using the threadpool. )rÚ threadpoolÚapplyr)rr$rrrr •scCstƒj t||f¡S)zŽWrite bytes from buffer *buf* to file descriptor *fd*. Return the number of bytes written. Writing is done using the threadpool. )rr,r-r*)rr+rrrr ŸscCstƒ}|stƒ|S)a÷ Forks the process using :func:`os.fork` and prepares the child process to continue using gevent before returning. .. note:: The PID returned by this function may not be waitable with either the original :func:`os.waitpid` or this module's :func:`waitpid` and it may not generate SIGCHLD signals if libev child watchers are or ever have been in use. For example, the :mod:`gevent.subprocess` module uses libev child watchers (which parts of gevent use libev child watchers is subject to change at any time). Most applications should use :func:`fork_and_watch`, which is monkey-patched as the default replacement for :func:`os.fork` and implements the ``fork`` function of this module by default, unless the environment variable ``GEVENT_NOWAITPID`` is defined before this module is imported. .. versionadded:: 1.1b2 )Ú _raw_forkr)r'rrrÚ fork_gevent­sr/cCstƒS)zL A wrapper for :func:`fork_gevent` for non-POSIX platforms. )r/rrrrr ÉsÚforkptycCstƒ\}}|stƒ||fS)a¶ Forks the process using :func:`os.forkpty` and prepares the child process to continue using gevent before returning. Returns a tuple (pid, master_fd). The `master_fd` is *not* put into non-blocking mode. Availability: Some Unix systems. .. seealso:: This function has the same limitations as :func:`fork_gevent`. .. versionadded:: 1.1b5 )Ú _raw_forkptyr)ÚpidZ master_fdrrrÚforkpty_geventÒs r3ÚWNOWAITÚWNOHANGcCsdS)NrrrrrÚòsr6cCsL| ¡z4|j|jt ¡ft|j<|r.||ƒtƒtƒWd| ¡XdS)N)Ústopr2ÚrstatusÚtimeÚ_watched_childrenÚ_on_child_hookÚ_reap_childrenr#)ÚwatcherÚcallbackrrrÚ _on_child÷s r?é<cs>t ¡}||‰‡fdd„t ¡Dƒ}x|D] }t|=q,WdS)Ncs*g|]"\}}t|tƒr|dˆkr|‘qS)r))Ú isinstanceÚtuple)Ú.0r2Úval)Úoldest_allowedrrú sz"_reap_children..)r9r:Úitems)ZtimeoutZnowZdeadr2r)rErr<s    r<c Cs|dkrŠ|dkr6x$t ¡D]\}}t|tƒr|}PqW|dkrŠ|dkr€|dkr€tƒ}|j dd¡}| |¡|j|j fSQRXt ||ƒS|tkr |t @sªtt|tƒrÒt|}t|tƒrÎt|=|dd…SdSt|}|j |d¡}tƒ |¡WdQRX|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. Availability: POSIX. .. versionadded:: 1.1b1 .. versionchanged:: 1.2a1 More cases are handled in a cooperative manner. réÿÿÿÿFNr))rr) r:rGrArBrr Úchildr"Zrpidr8Ú_waitpidÚ_WNOHANG)r2ZoptionsÚkÚvr%r=r'Z new_watcherrrrÚwaitpids2       rNFcCs>|ƒ}|r:|ptƒj}|j||d}|t|<| 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`. )Úref)rr rIr:Ústartr?)r>r rOr r2r=rrrÚfork_and_watch„s rQcs(g‰‡‡fdd„}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_fd)r0r'rrÚ_fork´s z forkpty_and_watch.._forkr)rQ)r>r rOr0rSr)r0r'rÚforkpty_and_watchªsrTcOs t||Ž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 )rQ)ÚargsÚkwargsrrrr Ás cOs t||ŽS)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 )rT)rUrVrrrr0Ðs cCstƒS)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 cCstƒS)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 )r3rrrrr0ês r)Znames_to_ignoreZdunder_names_to_keep)r@);Ú__doc__Z __future__rrrZ gevent.hubrrrZgevent._configrZgevent._compatrZ gevent._utilrrÚgetattrrrÚ ImportErrorZ__implements__Z__extensions__ÚreadrÚwriter*ZEINTRrr rrr r Úhasattrr r.r/r0r1r3rRr9rNrJr5rKr;r:r?r<rQrTZdisable_watch_childrenÚremoveÚglobalsZ __imports__ÚlistÚsetÚ__all__rrrrÚ*s‚                 f"