o U˟iKf@sdZddlmZddlZddlmZddlmZddlm Z ddl m Z ddl m Z dd lmZddlZeed d ZzddlZWn eyKdZYnwd gZd dgZejZejZejZejZeejgZ dZ!ermddZ"nddZ"eriZ#edg7ZddZegd7ZddZ$ddZ%ddZ&dd Z'ddZ(e)ed r\ej*Z+ddZ,d d Z*e)ed!rej-Z.d"d#Z/e/Z-e0d!e0d#e)ed$se)ed%r[ddl1Z1ej2Z3ej4Z5d&d'Z6iZ7d(d)Z8d@d+d,Z9d-d.Z2dAd0d1Z:ddd/e,fd2d3Z;e0d3e0dd!evrddd/e/fd4d5ZZ?ej@ZAd9d8Z>d:d;Z@e0d8e0d;ndd?ZDeEeFeeZGdS)BaQ 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)S_ISREG)_get_hub_noargs)reinit)Event)config) copy_globalsEAGAIN forktp_readtp_writeTcCst|tjSN)fcntlF_GETFDfdrQ/var/www/apps/myagent/mysuperagent/venv/lib/python3.10/site-packages/gevent/os.py_check_fd_validQsrcCdSrrrrrrrVsclosecst|t|}t|jrtrt|St}|j}|tvrJt |ddurE| }| |Wdn1s;wY dt t j|||tt|<fdd}||dS)a Close a file descriptor. This function cooperates with gevent to avoid crashing the process if you (accidentally) call it while you're still performing IO on the file descriptor; for example, if you have it registered with a ``Selector`` implementation, which documents that you *must* unregister FDs before closing them. If the *fd* refers to a regular file, this cooperation is *not* used. This is because trying to use gevent to poll on regular files doesn't work and shouldn't be done. We assume that everyone is following the rules. .. caution:: This function is not intended for use on Windows. .. versionadded:: 25.8.1 NgMbP?c sz:zt|Wn tyYnwWt|ddSWt|ddSt|dwr)_closeOSErrorset_closing_fd_to_eventpopstoprrcheckeventrrcbs&        zclose..cb)r_fstatrst_mode_NO_DEFER_REG_FILErget_hublooprridlewaitrerrnoEBADF closing_fdrrstart)rstatshubr&watcherr!rrrr`s(#      )make_nonblockingnb_readnb_writecCs<t|tjd}t|tj@st|tj|tjBdSdS)zPut the file descriptor *fd* into non-blocking mode if possible. :return: A boolean value that evaluates to True if successful. rTN)rF_GETFLboolos O_NONBLOCKF_SETFL)rflagsrrrr0s r0c Csd}d}zD zt||}|WW|dur|d}d}SSty4}z |jtvr*WYd}~nd}~ww|durCt}|j|d}||q|durU|d}d}w)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) _readrrr)ignored_errorsr%r&ior()rnr.r resulterrrr16      r1c Csd}d}zD zt||}|WW|dur|d}d}SSty4}z |jtvr*WYd}~nd}~ww|durCt}|j|d}||q|durU|d}d}w)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. Nr9) _writerrr)r;r%r&r<r()rbufr.r r>r?rrrr2r@r2cCtjt||fS)zRead 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% threadpoolapplyr:)rr=rrrr scCrD)zWrite bytes from buffer *buf* to file descriptor *fd*. Return the number of bytes written. Writing is done using the threadpool. )r%rErFrB)rrCrrrr scCsPddl}||dtt}Wdn1swY|s&t|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 rNignore)warningscatch_warnings simplefilterDeprecationWarning _raw_forkr)rHr>rrr fork_gevent's  rMcCtS)zL A wrapper for :func:`fork_gevent` for non-POSIX platforms. rMrrrrr HsforkptycCst\}}|s t||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)pid master_fdrrrforkpty_geventQs rTWNOWAITWNOHANGcCrrrrrrrqsrWcCsR|z|j|jtft|j<|r||ttW|dS|wr)rrRrstatustime_watched_children_on_child_hook_reap_childrenr)r/callbackrrr _on_childvsr^<cs:t}||fddtD}|D]}t|=qdS)Ncs*g|]\}}t|tr|dkr|qS)rA) isinstancetuple).0rRvaloldest_allowedrr s z"_reap_children..)rYrZitems)timeoutnowdeadrRrrdrr\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. rNrAF)rr) rZrgr`rar%r&childr(rpidrX_waitpid_WNOHANG) rRoptions finished_atkvr.r/r> new_watcherrrrwaitpids>!      ruFcCs4|ptj}|j||d}|t|<|t||dS)N)ref)r%r&rlrZr,r^)rRr]r&rvr/rrr _watch_childs rwcCs|}|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`. )rw)r]r&rvr rRrrrfork_and_watchsrxcs(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_fdrPr>rr_forkBs z forkpty_and_watch.._forkrrx)r]r&rvrPr|rr{rforkpty_and_watch8sr~cOt|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 r}argskwargsrrrr Os 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 )r~rrrrrP^s posix_spawncOt|i|}t||Sr)_raw_posix_spawnrwrrrRrrrrpcOrr)_raw_posix_spawnprwrrrr posix_spawnpurrcCrN)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. rOrrrrr }s cCrN)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 )rTrrrrrPs r)names_to_ignoredunder_names_to_keep)r_)NNF)H__doc__ __future__rr5statr gevent.hubrr%r gevent.eventrgevent._configr gevent._utilrr)getattrr r ImportError__implements____extensions__readr:writerBrrfstatr"EINTRr;r$rrr0r1r2r r hasattrr rLrMrPrQrTryrYrurnrVror[rZr^r\rwrxr~disable_watch_childrenrrrrremoveglobals __imports__listr__all__rrrrs +             h  !     p