ó úR‹_c@@s3dZddlmZddlZddlZddlmZddlmZddl m Z ddl m Z ddl mZddlZeed d ƒZyddlZWnek rÅdZnXd gZd d gZejZejZeejgZer3edddg7Zd„Zd„Zd„Znd„Z d„Z!e"ed ƒrêej#Z$d„Z%d„Z#e"edƒr³ej&Z'd„Z(e(Z&ej)dƒej)dƒne"edƒsÑe"edƒr÷ddl*Z*ej+Z,ej-Z.d„Z/iZ0d„Z1dd „Z2d!„Z+dde3e%d"„Z4ej)d#ƒej)d$ƒdekr|dde3e(d%„Z5ej)d&ƒne j6s¶d'„Z#dekr¦d(„Z&nej)d)ƒqçd*„Z#dekr×d+„Z&nej)d)ƒq÷n ej7d ƒeee8ƒd,eed-d.ƒZ9e:e;eeƒƒZ<dS(/sQ 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.) i(tabsolute_importN(t_get_hub_noargs(treinit(tconfig(tPY3(t copy_globalstEAGAINi tforkttp_readttp_writetmake_nonblockingtnb_readtnb_writecC@sPtj|tjdƒ}t|tj@ƒsLtj|tj|tjBƒtSdS(s™Put the file descriptor *fd* into non-blocking mode if possible. :return: A boolean value that evaluates to True if successful. iN(tfcntltF_GETFLtbooltost O_NONBLOCKtF_SETFLtTrue(tfdtflags((sB/var/www/syncserver/local/lib/python2.7/site-packages/gevent/os.pyR LscC@sÓd}d}zšx“yt||ƒ}|SWn;tk rf}|jtkrP‚ntsgtjƒqgnX|dkr”tƒ}|j j |dƒ}n|j |ƒqWWd|dk rÎ|j ƒd}d}nXdS(s 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. iN( tNonet_readtOSErrorterrnotignored_errorsRtsyst exc_cleartget_hubtlooptiotwaittclose(Rtnthubteventtresultte((sB/var/www/syncserver/local/lib/python2.7/site-packages/gevent/os.pyR Ws(    cC@sÓd}d}zšx“yt||ƒ}|SWn;tk rf}|jtkrP‚ntsgtjƒqgnX|dkr”tƒ}|j j |dƒ}n|j |ƒqWWd|dk rÎ|j ƒd}d}nXdS(sò 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. iN( Rt_writeRRRRRRRRRR R!(RtbufR#R$R%R&((sB/var/www/syncserver/local/lib/python2.7/site-packages/gevent/os.pyR vs(    cC@stƒjjt||fƒS(sÊ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. (Rt threadpooltapplyR(RR"((sB/var/www/syncserver/local/lib/python2.7/site-packages/gevent/os.pyR•scC@stƒjjt||fƒS(sŽ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(((sB/var/www/syncserver/local/lib/python2.7/site-packages/gevent/os.pyR ŸscC@stƒ}|stƒn|S(s÷ 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 (t _raw_forkR(R%((sB/var/www/syncserver/local/lib/python2.7/site-packages/gevent/os.pyt fork_gevent­s  cC@stƒS(sL A wrapper for :func:`fork_gevent` for non-POSIX platforms. (R,(((sB/var/www/syncserver/local/lib/python2.7/site-packages/gevent/os.pyRÉstforkptycC@s)tƒ\}}|stƒn||fS(s¶ 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 (t _raw_forkptyR(tpidt master_fd((sB/var/www/syncserver/local/lib/python2.7/site-packages/gevent/os.pytforkpty_geventÒs R1tWNOWAITtWNOHANGcC@sdS(N(R(((sB/var/www/syncserver/local/lib/python2.7/site-packages/gevent/os.pytòtcC@sc|jƒzG|j|jtjƒft|j<|rB||ƒntƒtƒWd|jƒXdS(N(tstopR/trstatusttimet_watched_childrent_on_child_hookt_reap_childrenR!(twatchertcallback((sB/var/www/syncserver/local/lib/python2.7/site-packages/gevent/os.pyt _on_child÷s "  i<cC@svtjƒ}||}gtjƒD]1\}}t|tƒr#|d|kr#|^q#}x|D] }t|=qaWdS(Ni(R8R9titemst isinstancettuple(ttimeouttnowtoldest_allowedR/tvaltdead((sB/var/www/syncserver/local/lib/python2.7/site-packages/gevent/os.pyR;s  + cC@sv|dkrÌ|dkrQx6tjƒD]%\}}t|tƒr%|}Pq%q%Wn|dkrÌ|dkr¼|dkr¼tƒ}|jjdtƒ$}|j|ƒ|j |j fSWdQXnt ||ƒSn|tkri|t @sõtt|tƒr!t|}t|tƒrt|=|d SdSt|}|jj|tƒ}tƒj|ƒWdQX|j |j fSt ||ƒS(s# 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. iiÿÿÿÿNi(ii( R9R?R@RARRtchildtFalseR trpidR7t_waitpidt_WNOHANG(R/toptionstktvR#R<R%t new_watcher((sB/var/www/syncserver/local/lib/python2.7/site-packages/gevent/os.pytwaitpids2          cC@sZ|ƒ}|rV|ptƒj}|j|d|ƒ}|t|<|jt||ƒn|S(s¿ 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`. tref(RRRGR9tstartR>(R=RRQRR/R<((sB/var/www/syncserver/local/lib/python2.7/site-packages/gevent/os.pytfork_and_watch„s  RSR,c@s3g‰‡‡fd†}t||||ƒˆdS(s¾ Like :func:`fork_and_watch`, except using :func:`forkpty_gevent`. Availability: Some Unix systems. .. versionadded:: 1.1b5 c@sˆƒ}ˆj|ƒ|dS(Ni(tappend(t pid_and_fd(R-R%(sB/var/www/syncserver/local/lib/python2.7/site-packages/gevent/os.pyt_fork´s  i(RS(R=RRQR-RV((R-R%sB/var/www/syncserver/local/lib/python2.7/site-packages/gevent/os.pytforkpty_and_watchªsRWcO@s t||ŽS(s× 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 (RS(targstkwargs((sB/var/www/syncserver/local/lib/python2.7/site-packages/gevent/os.pyRÁs cO@s t||ŽS(s˜ 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 (RW(RXRY((sB/var/www/syncserver/local/lib/python2.7/site-packages/gevent/os.pyR-Ðs RPcC@stƒS(s› 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,(((sB/var/www/syncserver/local/lib/python2.7/site-packages/gevent/os.pyRÞs cC@stƒS(s~ 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 (R1(((sB/var/www/syncserver/local/lib/python2.7/site-packages/gevent/os.pyR-ês tnames_to_ignoretdunder_names_to_keep((=t__doc__t __future__RRRt gevent.hubRRRtgevent._configRtgevent._compatRt gevent._utilRRtgetattrRR t ImportErrorRt__implements__t__extensions__treadRtwriteR'tEINTRRR R R RR thasattrRR+R,R-R.R1RTR8RPRJR3RKR:R9R>R;RHRSRWtdisable_watch_childrentremovetglobalst __imports__tlisttsett__all__(((sB/var/www/syncserver/local/lib/python2.7/site-packages/gevent/os.pyt*s‚                         f"