iKfdZddlmZddlZddlmZddlmZddlm Z ddl m Z ddl m Z dd lmZddlZeed d Z ddlZn #e$rdZYnwxYwd gZd dgZejZejZejZejZeejgZ dZ!erdZ"ndZ"eriZ#edgz ZdZegdz ZdZ$dZ%dZ&dZ'dZ(e)ed rqej*Z+dZ,dZ*e)edr6ej-Z.dZ/e/Z-e0de0de)eds e)ed rddl1Z1ej2Z3ej4Z5d!Z6iZ7d"Z8d8d$Z9d%Z2d9d'Z:ddd&e,fd(Z;e0d)e0d*devrddd&e/fd+Zej>Z?ej@ZAd1Z>d2Z@e0d0e0d3n5d4Z*devrd5Z-e0d/neBd eeeCeezd67ZDeEeFeezZGdS):aQ 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_writeTc@tj|tjSN)fcntlF_GETFDfds 4/usr/local/lib/python3.11/dist-packages/gevent/os.py_check_fd_validrQs{2u}---cdSrrs rrrVs  rclosect|t|}t|jrtrt |St }|j}|tvrt |dV| 5}| |dddn #1swxYwY dttj|||t#t|<fd}||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 t|n#t$rYnwxYwt|ddS#t|dwxYwr)_closeOSErrorset_closing_fd_to_eventpopstopr)rcheckevents rcbzclose..cbs r      $((T222   $((T222  s"A< A< A< ? ? ?[[F ! ! ! ! ! ! ! ! ! ! ! ! ! ! !  HHH s*AAActS)zL A wrapper for :func:`fork_gevent` for non-POSIX platforms. rVrrrr r Hs}}rforkptycLt\}}|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)pid master_fds rforkpty_geventr^Qs,*^^NC  > !rr^WNOWAITWNOHANGcdSrrrrrrbqsrc6| |j|jtjft|j<|r ||t t |dS#|wxYwr)r"r\rstatustime_watched_children_on_child_hook_reap_childrenr)r3callbacks r _on_childrjvs LLNNN 29+wPTPYP[P[1\!'+.&HW%%%        s ABB<ctj}||z fdtD}|D] }t|= dS)Nc\g|](\}}t|tr|dk&|)S)rH) isinstancetuple).0r\valoldest_alloweds r z"_reap_children..sJ Sc5))/2!f~.E.E.E.E.Er)rerfitems)timeoutnowdeadr\rrs @rrhrhss )++C 7]N$**,,D  + +%c** + +rc|dkr|dkrNd}tD]2\}}t|tr| |d|kr |}|d}3|dkr|dkrj|dkrdt }|jdd5}|||j|j fcdddS#1swxYwYt||S|tvr|tzs tt|tr6t|}t|trt|=|ddSdSt|}|j|d5}t |dddn #1swxYwY|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. rNrHF)rr) rfrtrnror)r*childr,rpidrd_waitpid_WNOHANG) r\options finished_atkvr2r3rD new_watchers rwaitpidrscBaxx"99 #'K 1 7 7 9 9//1 *1e 4 4/%0%8AaD;Djj#j..G%, c " MM)Wh 7 7 7 7 7rcB|}|rt|||||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)rir*rr r\s rfork_and_watchrs02$&&C 7S(D#666JrrrVcJgfd}t||||dS)z Like :func:`fork_and_watch`, except using :func:`forkpty_gevent`. Availability: Some Unix systems. .. versionadded:: 1.1b5 cR}||dS)Nr)append) pid_and_fdrYrDs r_forkz forkpty_and_watch.._forkBs*!(JMM*---%a=(rrr)rir*rrYrrDs ` @rforkpty_and_watchr8sI))))))xsE:::ay rrct|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 rargskwargss rr r Os&t6v666rct|i|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 )rrs rrYrY^s-d=f===rr posix_spawnc<t|i|}t||Sr)_raw_posix_spawnrrrr\s rrrps'*D;F;;C %%%Jrc<t|i|}t||Sr)_raw_posix_spawnprrs r posix_spawnprus'+Trs ))V'&&&&& 111111!!!!!!%%%%%% " % %LLLL EEEZ(    %+&   ....     pwj NeeePBBBBN   ::666999 72vu"IB wr90z  " " "&!i(((.///wr9k-Y!7!7k- ::&  + + + +4n *n *n *` 8 8 8 8 %)t[    > .///m,,,  & &+/d~ ! ! ! !"  ! !"5 6 6 6,H - 7 7 7N** > > >  ! !) , , ,wr=)) 6#%> $&O!  %%m444%%n555 % % %N** , , ,  ! !) , , ,&!!!l2wwyy+9N+J02444  $ss>N233 4 4sAAA