o 0׾gD@sdZddlmZmZddlZddlZddlZddlZddlZddl Z zddl m Z Wn e y5dZ Ynwzddl Z Wn e yGdZ YnwzddlZWn e yYdZYnwddlmZddlmZddlmZddlmZdd lmZdd lmZmZmZdd lmZdd lmZdd lmZddlmZddlmZddl m!Z!ddl m"Z"ddl#m$Z$m%Z%e$j&Z&ddl'Z(gdZ)ej*+dse),ddZ-dZ.gdZ/gdZ0e/gd7Z/e01de01de),de),de01dze2dZ3WndZ3Ye01de/,de/4gd e)4d!gd"d!Z5d#Z6e(j6r+e)4d$gne/4d$gerDdZ7e)4ej*dkrAd%gnge"e(e8e/d&d'Z9e04e:e/;e:e9e9Z/[9ee(e=e>gZ?e@e0D]1ZAeAe8vr{qqe!ZBe?D]ZCeZ`d?d@ZaGdAdBdBeXZbGdCdDdDeXZcdEdFZdGdGddeXZedHdZfdIdJZgdS)Ka% Cooperative ``subprocess`` module. .. caution:: On POSIX platforms, this module is not usable from native threads other than the main thread; attempting to do so will raise a :exc:`TypeError`. This module depends on libev's fork watchers. On POSIX systems, fork watchers are implemented using signals, and the thread to which process-directed signals are delivered `is not defined`_. Because each native thread has its own gevent/libev loop, this means that a fork watcher registered with one loop (thread) may never see the signal about a child it spawned if the signal is sent to a different thread. .. note:: The interface of this module is intended to match that of the standard library :mod:`subprocess` module (with many backwards compatible extensions from Python 3 backported to Python 2). There are some small differences between the Python 2 and Python 3 versions of that module (the Python 2 ``TimeoutExpired`` exception, notably, extends ``Timeout`` and there is no ``SubprocessError``) and between the POSIX and Windows versions. The HTML documentation here can only describe one version; for definitive documentation, see the standard library or the source code. .. _is not defined: http://www.linuxprogrammingblog.com/all-about-linux-signals?page=11 )absolute_importprint_functionN) GenericAlias) AsyncResult)_get_hub_noargs) linkproxy)sleep) getcurrent) integer_types string_typesxrange)PY311)PYPY)fsdecode)fsencode)PathLike)_NONE) copy_globals)Greenletjoinall)Popencall check_call check_outputwin32_posixsubprocesszPIPE should be imported) PIPESTDOUTCalledProcessErrorCREATE_NEW_CONSOLECREATE_NEW_PROCESS_GROUPSTD_INPUT_HANDLESTD_OUTPUT_HANDLESTD_ERROR_HANDLESW_HIDESTARTF_USESTDHANDLESSTARTF_USESHOWWINDOW)MAXFD_eintr_retry_call STARTUPINFO pywintypes list2cmdline _subprocess_winapi WAIT_OBJECT_0WaitForSingleObjectGetExitCodeProcess GetStdHandle CreatePipeDuplicateHandleGetCurrentProcessDUPLICATE_SAME_ACCESSGetModuleFileName GetVersion CreateProcessINFINITETerminateProcess STILL_ACTIVErunCompletedProcess)DEVNULLgetstatusoutput getoutputSubprocessErrorTimeoutExpiredr<r=r' SC_OPEN_MAXr)) ABOVE_NORMAL_PRIORITY_CLASSBELOW_NORMAL_PRIORITY_CLASSHIGH_PRIORITY_CLASSIDLE_PRIORITY_CLASSNORMAL_PRIORITY_CLASSREALTIME_PRIORITY_CLASSCREATE_NO_WINDOWDETACHED_PROCESSCREATE_DEFAULT_ERROR_MODECREATE_BREAKAWAY_FROM_JOB_use_posix_spawncCdS)NFrQrQrQ[/var/www/html/backend_erp/backend_erp_env/lib/python3.10/site-packages/gevent/subprocess.pyrOF_USE_POSIX_SPAWN _fork_execT) only_namesignore_missing_namesr,r-)r<r=rBc@s0eZdZdZddZddZddZeZeZdS) HandleFcCs|js d|_t|dSdSNT)closedr- CloseHandleselfrQrQrRClose sz Handle.ClosecCs|js d|_t|Std)NTzalready closed)rZint ValueErrorr\rQrQrRDetachsz Handle.DetachcCs dt|S)Nz Handle(%d)r_r\rQrQrR__repr__s zHandle.__repr__N) __name__ __module__ __qualname__rZr^rarc__del____str__rQrQrQrRrXsrX)monkeyosfork)fork_and_watchc@seZdZdZdS)BrokenPipeErrorzNever raised, never caught.N)rdrerf__doc__rQrQrQrRrm%srmcOsh|dd}t|i|}z|j|ddWWdS||1s-wYdS)a^ call(args, *, stdin=None, stdout=None, stderr=None, shell=False, timeout=None) -> returncode Run command with arguments. Wait for command to complete or timeout, then return the returncode attribute. The arguments are the same as for the Popen constructor. Example:: retcode = call(["ls", "-l"]) .. versionchanged:: 1.2a1 The ``timeout`` keyword argument is now accepted on all supported versions of Python (not just Python 3) and if it expires will raise a :exc:`TimeoutExpired` exception (under Python 2 this is a subclass of :exc:`~.Timeout`). timeoutNTro _raise_exc)poprwaitkill) popenargskwargsroprQrQrRr)s rcOs:t|i|}|r|d}|dur|d}t||dS)a check_call(args, *, stdin=None, stdout=None, stderr=None, shell=False, timeout=None) -> 0 Run command with arguments. Wait for command to complete. If the exit code was zero then return, otherwise raise :exc:`CalledProcessError`. The ``CalledProcessError`` object will have the return code in the returncode attribute. The arguments are the same as for the Popen constructor. Example:: retcode = check_call(["ls", "-l"]) argsNr)rgetr)rurvretcodecmdrQrQrRrBs   rc Os|dd}d|vrtdd|vrtdd|vr.d|vr"td |d}|d=t|d<nd}t|dti|G}z |j||d \}}Wn$ty^||\}}t|j||d ||| }|rxt ||j|d Wd|S1swY|S) a check_output(args, *, input=None, stdin=None, stderr=None, shell=False, universal_newlines=False, timeout=None) -> output Run command with arguments and return its output. If the exit code was non-zero it raises a :exc:`CalledProcessError`. The ``CalledProcessError`` object will have the return code in the returncode attribute and output in the output attribute. The arguments are the same as for the Popen constructor. Example:: >>> check_output(["ls", "-1", "/dev/null"]) '/dev/null\n' The ``stdout`` argument is not allowed as it is used internally. To capture standard error in the result, use ``stderr=STDOUT``:: >>> output = check_output(["/bin/sh", "-c", ... "ls -l non_existent_file ; exit 0"], ... stderr=STDOUT).decode('ascii').strip() >>> print(output.rsplit(':', 1)[1].strip()) No such file or directory There is an additional optional argument, "input", allowing you to pass a string to the subprocess's stdin. If you use this argument you may not also use the Popen constructor's "stdin" argument, as it too will be used internally. Example:: >>> check_output(["sed", "-e", "s/foo/bar/"], ... input=b"when in the course of fooman events\n") 'when in the course of barman events\n' If ``universal_newlines=True`` is passed, the return value will be a string rather than bytes. .. versionchanged:: 1.2a1 The ``timeout`` keyword argument is now accepted on all supported versions of Python (not just Python 3) and if it expires will raise a :exc:`TimeoutExpired` exception (under Python 2 this is a subclass of :exc:`~.Timeout`). .. versionchanged:: 1.2a1 The ``input`` keyword argument is now accepted on all supported versions of Python, not just Python 3 .. versionchanged:: 22.08.0 Passing the ``check`` keyword argument is forbidden, just as in Python 3.11. roNstdoutz3stdout argument not allowed, it will be overridden.checkz2check argument not allowed, it will be overridden.inputstdin/stdin and input arguments may not both be used.rooutput) rrr`rr communicaterBrtrxrspollr)rurvro inputdataprocessr unused_errrzrQrQrRrWs> 0    rrB)Timeoutc@s.eZdZdZd ddZeddZddZdS) rBa This exception is raised when the timeout expires while waiting for a child process in `communicate`. Under Python 2, this is a gevent extension with the same name as the Python 3 class for source-code forward compatibility. However, it extends :class:`gevent.timeout.Timeout` for backwards compatibility (because we used to just raise a plain ``Timeout``); note that ``Timeout`` is a ``BaseException``, *not* an ``Exception``. .. versionadded:: 1.2a1 NcCs"t|d||_||_||_dSN)_Timeout__init__r{secondsr)r]r{rorrQrQrRrs  zTimeoutExpired.__init__cCs|jSr)rr\rQrQrRroszTimeoutExpired.timeoutcCsd|j|jfS)Nz'Command '%s' timed out after %s seconds)r{ror\rQrQrRrhs zTimeoutExpired.__str__r)rdrerfrnrpropertyrorhrQrQrQrRrBs    set_inheritablecCrPrYrQ)ivrQrQrRsrcOsddlm}|td<||S)Nr) FileObjectr)gevent.fileobjectrglobals)rxrv _FileObjectrQrQrRrs  rc@sLeZdZdZddZddZddZeZdd Ze d d Z e d d Z dS)_CommunicatingGreenlets)rr|stderr_all_greenletscCsd|_|_|_|jrt|j|j||_|jr t|j|j|_|jr+t|j|j|_g}|j|j|jfD] }|dur@||q5t||_dSr) rr|rspawn_write_and_close_read_and_closeappendtupler)r]popen input_data all_greenletsgrQrQrRrs  z _CommunicatingGreenlets.__init__cC t|jSr)iterrr\rQrQrR__iter__  z _CommunicatingGreenlets.__iter__cCrr)boolrr\rQrQrR__bool__ rz _CommunicatingGreenlets.__bool__cCrr)lenrr\rQrQrR__len__rz_CommunicatingGreenlets.__len__cCszRz|r||t|dr|Wn,ttfy?}zt|tr+|jdur+tj|_|jtjtjfvr5WYd}~nd}~wwWz| WdSt yRYdSwz| Wwt ybYww)Nflush) writehasattrrOSErrorrm isinstanceerrnoEPIPEEINVALcloseEnvironmentError)fobjdataexrQrQrRrs2       z(_CommunicatingGreenlets._write_and_closecCsJz|Wz|WStyYSwz|Wwty$Ywwr)readrr)rrQrQrRr*s    z'_CommunicatingGreenlets._read_and_closeN) rdrerf __slots__rrr __nonzero__r staticmethodrrrQrQrQrRrs  rc@seZdZdZedureeZdZddddddedddddddddddddddddddfd d Z d d Z d dZ ddZ ddZ dZdMddZddZddZddZdNddZerddZdd Zd!d"Zd#d$Zd%d&Zd'd(Zd)d*Zd+d,Zd-d.ZdNd/d0Zd1d2Zd3d4Z e Z!dSd5d*Zd6dZdOd7d8Z"d9d:Z#d;d<Z$d=Z%ed>d?Z&ed@dAZ'edBdCZ(dDd&Ze)j*e)j+e)j,e)j-e)j.e)j/fdEdFZ0dGd(ZdNdHd0ZdId2ZdJd4Z dKdLZ!dS)Pra The underlying process creation and management in this module is handled by the Popen class. It offers a lot of flexibility so that developers are able to handle the less common cases not covered by the convenience functions. .. seealso:: :class:`subprocess.Popen` This class should have the same interface as the standard library class. .. caution:: The default values of some arguments, notably ``buffering``, differ between Python 2 and Python 3. For the most consistent behaviour across versions, it's best to explicitly pass the desired values. .. caution:: On Python 2, the ``read`` method of the ``stdout`` and ``stderr`` attributes will not be buffered unless buffering is explicitly requested (e.g., `bufsize=-1`). This is different than the ``read`` method of the standard library attributes, which will buffer internally even if no buffering has been requested. This matches the Python 3 behaviour. For portability, please explicitly request buffering if you want ``read(n)`` to return all ``n`` bytes, making more than one system call if needed. See `issue 1701 `_ for more context. .. versionchanged:: 1.2a1 Instances can now be used as context managers under Python 2.7. Previously this was restricted to Python 3. .. versionchanged:: 1.2a1 Instances now save the ``args`` attribute under Python 2.7. Previously this was restricted to Python 3. .. versionchanged:: 1.2b1 Add the ``encoding`` and ``errors`` parameters for Python 3. .. versionchanged:: 1.3a1 Accept "path-like" objects for the *cwd* parameter on all platforms. This was added to Python 3.6. Previously with gevent, it only worked on POSIX platforms on 3.6. .. versionchanged:: 1.3a1 Add the ``text`` argument as a synonym for ``universal_newlines``, as added on Python 3.7. .. versionchanged:: 1.3a2 Allow the same keyword arguments under Python 2 as Python 3: ``pass_fds``, ``start_new_session``, ``restore_signals``, ``encoding`` and ``errors``. Under Python 2, ``encoding`` and ``errors`` are ignored because native handling of universal newlines is used. .. versionchanged:: 1.3a2 Under Python 2, ``restore_signals`` defaults to ``False``. Previously it defaulted to ``True``, the same as it did in Python 3. .. versionchanged:: 20.6.0 Add the *group*, *extra_groups*, *user*, and *umask* arguments. These were added to Python 3.9, but are available in any gevent version, provided the underlying platform support is present. .. versionchanged:: 20.12.0 On Python 2 only, if unbuffered binary communication is requested, the ``stdin`` attribute of this object will have a ``write`` method that actually performs internal buffering and looping, similar to the standard library. It guarantees to write all the data given to it in a single call (but internally it may make many system calls and/or trips around the event loop to accomplish this). See :issue:`1711`. .. versionchanged:: 21.12.0 Added the ``pipesize`` argument for compatibility with Python 3.10. This is ignored on all platforms. .. versionchanged:: 22.08.0 Added the ``process_group`` and ``check`` arguments for compatibility with Python 3.11. NFrTrQc+Cs||_||_t}|durd}t|tstdtr6|dur"td|tur(d}|dur/|j }||_ d|_ n0|turttdstdt|tr#tdurtdt|j}nt|tr+|}n t d t ||dkr>td|d}|durttdsMtdt|trVtd g}|D]4}t|trstduritd | t|jqZt|tr|d krtd | |qZt d t ||D] }|dkrtd|fqd}|durttdstdt|trt durtdt |j}n t|tr|}nt d|dkrtd|f|||fS)Nsetregidz>The 'group' parameter is not supported on the current platformzHThe group parameter cannot be a string on systems without the grp modulez,Group must be a string or an integer, not {}rz#Group ID cannot be negative, got %s setgroupszEThe 'extra_groups' parameter is not supported on the current platformz#Groups must be a list, not a stringzIItems in extra_groups cannot be strings on systems without the grp modulelz!Item in extra_groups is too largez9Items in extra_groups must be a string or integer, not {}setreuidz=The 'user' parameter is not supported on the current platformzGThe user parameter cannot be a string on systems without the pwd modulez#User must be a string or an integerz"User ID cannot be negative, got %s)rrjr`rstrgrpgetgrnamgr_gidr_rformattyperpwdgetpwnampw_uid) r]rrrrr extra_group gid_checkrrQrQrR __handle_uidsMsh               zPopen.__handle_uidscCsd|jjt||j|jfS)Nz!<%s at 0x%x pid=%r returncode=%r>) __class__rdidrrr\rQrQrRrcszPopen.__repr__cCsF||j}t|rt| |_nt||_|j|jdSr) stoprstatusrj WIFSIGNALEDWTERMSIGr WEXITSTATUSrset)r]watcherstatusrQrQrR _on_childs   zPopen._on_childcCs"t|dsttjtj|_|jS)Nr)rrjopendevnullO_RDWRrr\rQrQrR _get_devnulls zPopen._get_devnullc Cs|jdur t|||_|j}|s|dur|j|ddt||d}|D]}|q#|dur=t|t|jkr=t|j||j|j fD]}|rWz| WqCt yVYqCwqC||jdurcdn|j|j durodfS|j fS)a Interact with process and return its output and error. - Send *input* data to stdin. - Read data from stdout and stderr, until end-of-file is reached. - Wait for process to terminate. The optional *input* argument should be a string to be sent to the child process, or None, if no data should be sent to the child. communicate() returns a tuple (stdout, stderr). :keyword timeout: Under Python 2, this is a gevent extension; if given and it expires, we will raise :exc:`TimeoutExpired`, which extends :exc:`gevent.timeout.Timeout` (note that this only extends :exc:`BaseException`, *not* :exc:`Exception`) Under Python 3, this raises the standard :exc:`TimeoutExpired` exception. .. versionchanged:: 1.1a2 Under Python 2, if the *timeout* elapses, raise the :exc:`gevent.timeout.Timeout` exception. Previously, we silently returned. .. versionchanged:: 1.1b5 Honor a *timeout* even if there's no way to communicate with the child (stdin, stdout, and stderr are not pipes). NTrpr) _communicating_greenletsrrsrryrrBrxr|rr RuntimeError)r]r~ro greenletsdonegreenletpiperQrQrRrs0         zPopen.communicatecCs|S)zSCheck if child process has terminated. Set and return :attr:`returncode` attribute.)_internal_pollr\rQrQrRrsz Popen.pollcCs|SrrQr\rQrQrR __enter__rSzPopen.__enter__cCsX|jr|j|jr|jz|jr |jW|dSW|dS|wr)r|rrrrs)r]trtbrQrQrR__exit__s    zPopen.__exit__cCs4|jj|d}|r|dur|jst|j||S)Nr)rrsreadyrBrx)r]ro raise_excrrQrQrR_gevent_result_wait s zPopen._gevent_result_waitc Cs~|dur|dur|durdSd\}}d\}}d\}} ztWn ty*t} Ynwt} |durJtt}|durItdd\}} t|}t| n3|t kr_tdd\}}t|t|}}n|| krkt | }nt |trvt |}nt |}||}|durtt}|durtdd\} }t|}t| n3|t krtdd\}}t|t|}}n|| krt | }nt |trt |}nt |}||}|durtt} | durtdd\} } t| } t| n>|t kr tdd\}} t|t| }} n(|tkr|} n || krt | } nt |tr+t |} nt |} || } |||||| fS)|Construct and return tuple with IO objects: p2cread, p2cwrite, c2pread, c2pwrite, errread, errwrite N)rrrrrrrrr)r> NameErrorobjectr1r!r2rXr-r[rr get_osfhandlerrr_fileno_make_inheritabler"r#r) r]rr|rrrrrrrr_rQrQrRrs                 zPopen._get_handlescCstt|tddtS)z2Return a duplicate of handle, which is inheritabler)r3r4r5)r]handlerQrQrRr0fs zPopen._make_inheritablecCsVtjtjtdd}tj|s)tjtjtjd}tj|s)td|S)z-Find and return absolute path to w9xpopen.exerz w9xpopen.exezZCannot locate w9xpopen.exe, which is needed for Popen to work with your shell or platform.) rjpathjoindirnamer6existssys exec_prefixr)r]w9xpopenrQrQrR_find_w9xpopenms  zPopen._find_w9xpopencCstdd|DS)zFilter out console handles that can't be used in lpAttributeList["handle_list"] and make sure the list isn't empty. This also removes duplicate handles.cSs,h|]}|d@dkst|tjkr|qS))r- GetFileTypeFILE_TYPE_CHAR).0r3rQrQrR s z,Popen._filter_handle_list..)list)r] handle_listrQrQrR_filter_handle_list~szPopen._filter_handle_listc& s.|rJdt|tr n&t|tr| rtdt|g}nt|tr.| r(tdt|g}nt|}|dur:t|}t|tsCt|}| durKt} nt | drU| } n t | dr^| } d| ||fv}|rw| j t O_ | | _|| _|| _t | dr| j}t|od |vo|d }|s|r|r|duri}| _t|d g}|d <|r|t| t|t|g7}|||dd<|r|sd dl}|d td }| r| j tO_ t| _tjd d}d||}t dkstj!"|#dkr|$}d||f}| t%O} t&r!t'fddfdd} ||| z1t(||ddt| | || \}!}"}#}$Wdd}%|%| |%||%|t |drRt)|j*ndd}%|%| |%||%|t |drpt)|j*wwd|_+t |!ds~t,|!n|!|_-|#|_.t |"dst/0|"dS|"1dS)z$Execute program (MS Windows version)z"pass_fds not supported on Windows.z$bytes args is not allowed on Windows0path-like args is not allowed when shell is trueNcopy_copyrlpAttributeListrBrz?startupinfo.lpAttributeList['handle_list'] overriding close_fdsFCOMSPECzcmd.exez {} /c "{}"lz command.comz"%s" %scSs.|sdSt|tr dnd}||vr|ddS)Nz0argument must be a string without NUL characters)rbytes)serr_kindnulrQrQrR _check_nuls z(Popen._execute_child.._check_nulcs>sdSD]\}}||d|vrtdqdS)N=z#'=' not allowed in environment keys)itemsr`)krrOrrQrR _check_envsz(Popen._execute_child.._check_envcSs<|dur|dkrt|dr|dSt|dSdSdS)Nrr^)rr^r-r[)xrQrQrR_close%s   z$Popen._execute_child.._closerTr^)2rrrKrr+rrr r)rrErFdwFlagsr% hStdInput hStdOutput hStdErrorrGrrAryr_rCrrrr&r$ wShowWindowrjenvironrr7r4basenamelowerr;rrr`r8rr_child_createdrX_handlerr-r[r^)&r]rxrrrrrrrrrrrrrrrrunused_restore_signals unused_gid unused_gids unused_uid unused_umaskunused_start_new_sessionunused_process_groupuse_std_handlesattribute_listhave_handle_listrBrcomspecr:rThphtrtidrVrQrSrRrs                     &zPopen._execute_childcCs:|jdurt|jdtkrt|j|_|j|j|jS)^Check if child process has terminated. Returns returncode attribute. Nr)rr/r`r.r0rrr\rQrQrRr"8s  zPopen._internal_pollcCs8|js|jsd|_t|j|jt||dSrY)rr'rrr_waitrawlinkrr]callbackrQrQrRrqCs z Popen.rawlinkcCst|jtt|j|_|jSr)r/r`r9r0rr\rQrQrR_blocking_waitJs  zPopen._blocking_waitcCs|j|j|jdSr)rrrtrqrr\rQrQrRrpPsz Popen._waitcCs*|jdur|jsd|_||||S)zOWait for child process to terminate. Returns returncode attribute.NT)rrrpr)r]rorqrQrQrRrsSs  z Popen.waitcCs`|tjkr |dS|tjkrt|jtjdS|tjkr)t|jtjdStd |))Send a signal to the process zUnsupported signal: {}N) signalSIGTERM terminate CTRL_C_EVENTrjrtrCTRL_BREAK_EVENTr`rr]sigrQrQrR send_signal\s    zPopen.send_signalc Cs||jdurdSz t|jdWdSty=}z!|jdkrt|j}|tkr(||_|j|jWYd}~dSd}~ww)z#Terminates the process Nr2) rr:r`rwinerrorr0r;rr)r]ercrQrQrRryhs   zPopen.terminatecCs|jt||dSr)rrqrrrrQrQrRrqsc CsNd\}}d\}}d\}} ztWn tyt} Ynwt} |dur$n |tkr/|\}}n|| kr8|}n t|tr@|}n|}|durIn |tkrT|\}}n|| kr]|}n t|tre|}n|}|durnn1|tkry|\}} n&|t kr|dkr|} nt j } n|| kr|} n t|tr|} n|} |||||| fS)r*r+Nr) r>r,r-r pipe_cloexecrrr_r/rr8 __stdout__) r]rr|rrrrrrrrrQrQrRrsX         cCsfztj}Wn tyd}Ynwt|tj}|r&t|tj||BdSt|tj||@dS)Nr2)fcntl FD_CLOEXECAttributeErrorF_GETFDF_SETFD)r]rcloexec cloexec_flagoldrQrQrR_set_cloexec_flags  zPopen._set_cloexec_flagcCs*t|tjtj@}t|tj|dSr)rF_GETFLrj O_NONBLOCKF_SETFL)r]rflagsrQrQrR_remove_nonblock_flagszPopen._remove_nonblock_flagcCs(t\}}||||||fS)z#Create a pipe with FDs set CLOEXEC.)rjr!r)r]rrrQrQrRrs   zPopen.pipe_cloexec)z /proc/self/fdz/dev/fdcCs6|jD]}tj|r||||Sq|||Sr)_POSSIBLE_FD_DIRSrjr4isdir_close_fds_from_path_close_fds_brute_force)clskeep errpipe_writer4rQrQrR _close_fdss   zPopen._close_fdsc Csz ddt|D}Wnttfy|||YdSw|D] }||kr(q!t|dq!|D]}||vs:|dkr;q0zt|Wq0Yq0dS)NcSsg|]}t|qSrQrb)r?fnamerQrQrR sz.Popen._close_fds_from_path..Tr<)rjlistdirr`rr_set_inheritabler)rr4rrfdsrrrQrQrRrs" zPopen._close_fds_from_pathcCsttdsJt|}t|}t|}td|t|dtt||D]}||vr2t|dq&zt |Wq&Yq&dS)N closeranger<r2T) rrjsortedminmaxrr'r rr)rrrmin_keepmax_keeprrQrQrRrs   zPopen._close_fds_brute_forcec,st|ttfr |g}nt|tr| rtdt|g}nt|}| r7ttdr)dnd}|dg|}|r7||d<|dur?|d}j  \}}g}|dkr^| |t |}|dksP|D]}t |q`zzt}tz tjj d t_Wn |rtjdkrzMz#| d krt | |d krt ||d krt |t ||dkrt |}t|d |d vrt |}t|d |d vsLJfd d}|| d||d||d |dur zt |Wnty}"zd |"_d}"~"ww|dkrt |z'|rt ||r%t |||r.t !|||dur9t "d|WntyK}"zd |"_#d}"~"ww|rR||rdt|}#|#|$|#||rdD]}$t%t&|$d}$|$dur}t&&|$t&j'qi|rt (z|durt )||ndd|*D}t +|||Wnty}"zd |"_,d}"~"wwWn!t-\}%}&}'t./|%|&|'}(d0|(|&_1t 2|t34|&YWt 5dnt 5dwd _6|rtWt |nt |wt%dd})| d kr| d kr| |)krt | |d kr+|d kr+||)kr+t ||d kr?|d kr?||)kr?t ||)durIt |)d _7t8|d}|9}*Wz!zt|drc|nt |Wn tysYnwWd }n/d }wz(zt|dr|n t |WWd }wWWd }wtyYWd }wwd }w|*dkr:t3;|*}+| ||fD]}!|!dur|!d krt |!qt|+tr||+_._dup2r2)SIGPIPESIGXFZSIGXFSZcSs>i|]\}}t|trt|n|t|trt|n|qSrQ)rrKrjr)r?rRrrQrQrR s z(Popen._execute_child..rrrrr _failed_chdir_failed_chuser)=rrrKrrrrArr8rinstall_sigchldrrrjduprgc isenableddisablerlrrkrenablerraddchdirrrrrrrsetpgidrrgetattrrwSIG_DFLsetsidexecvprQexecvpe _failed_execexc_info tracebackformat_exceptionr5child_tracebackrpickledumps_exitr_rrrrsloadsfilename),r]rxrrrrrrrrrrrrrrrrrrrrrrr unix_shell errpipe_readrlow_fds_to_closelow_fdgc_was_enabledrrZrr fds_to_keepr}exc_type exc_valuer% exc_lines devnull_fdrchild_exceptionrQr\rRr$sX                                                          cCsN||r || |_dS||r|||_dS||r#|| |_dStd)NzUnknown child exit status!)rr)r]sts _WIFSIGNALED _WTERMSIG _WIFEXITED _WEXITSTATUS _WIFSTOPPED _WSTOPSIGrQrQrR_handle_exitstatus0szPopen._handle_exitstatuscCs6|jdurtturt|jdd}|rtd|jS)roN sig_pendingTgh㈵>)rrr rrr)r]rrQrQrRr"As  cCs |||S)a Wait for child process to terminate. Returns :attr:`returncode` attribute. :keyword timeout: The floating point number of seconds to wait. Under Python 2, this is a gevent extension, and we simply return if it expires. Under Python 3, if this time elapses without finishing the process, :exc:`TimeoutExpired` is raised. )r)rurQrQrRrsLs cCs |jdurt|j|dSdS)rvN)rrjrtrr|rQrQrRr~Ys cC|tjdS)z/Terminate the process with SIGTERM N)r~rwrxr\rQrQrRry`cCr)z*Kill the process with SIGKILL N)r~rwSIGKILLr\rQrQrRrterz Popen.killNNrY)T)1rdrerfrnr classmethod__class_getitem__rrrrrcrrrrrr#r&r)rrr0r;rCrr"rqrtrprsr~ryrtrrrrrrrrjrr WIFEXITEDr WIFSTOPPEDWSTOPSIGrrQrQrQrRr5sN BV  A O-     <         rcCs|j|_||_|Sr)rr|r)excrrQrQrR_with_stdout_stderrksrc@s:eZdZdZedureeZd ddZddZddZ dS) r=a A process that has finished running. This is returned by run(). Attributes: - args: The list or str args passed to run(). - returncode: The exit code of the process, negative for signals. - stdout: The standard output (None if not captured). - stderr: The standard error (None if not captured). .. versionadded:: 1.2a1 This first appeared in Python 3.5 and is available to all Python versions in gevent. NcCs||_||_||_||_dSr)rxrr|r)r]rxrr|rrQrQrRrs zCompletedProcess.__init__cCshd|jd|jg}|jdur|d|j|jdur(|d|jdt|jd|S)Nz args={!r}zreturncode={!r}z stdout={!r}z stderr={!r}z{}({})z, ) rrxrr|rrrrdr5)r]rxrQrQrRrcs    zCompletedProcess.__repr__cCs$|jrtt|j|j|j|jdS)z6Raise CalledProcessError if the exit code is non-zero.N)rrrrxr|rr\rQrQrRcheck_returncodesz!CompletedProcess.check_returncoder) rdrerfrnrrrrrcrrQrQrQrRr=ss  c OsD|dd}|dd}|dd}|dd}|dur(d|vr$tdt|d<|r>d |vs2d |vr6td t|d <t|d <t|i|M}z |j||d \}}Wn'tym||\}}tt|j||d ||| | } |r| rtt | |j||Wdn1swYt |j| ||S)am run(args, *, stdin=None, input=None, stdout=None, stderr=None, shell=False, timeout=None, check=False) -> CompletedProcess Run command with arguments and return a CompletedProcess instance. The returned instance will have attributes args, returncode, stdout and stderr. By default, stdout and stderr are not captured, and those attributes will be None. Pass stdout=PIPE and/or stderr=PIPE in order to capture them. If check is True and the exit code was non-zero, it raises a CalledProcessError. The CalledProcessError object will have the return code in the returncode attribute, and output & stderr attributes if those streams were captured. If timeout is given, and the process takes too long, a TimeoutExpired exception will be raised. There is an optional argument "input", allowing you to pass a string to the subprocess's stdin. If you use this argument you may not also use the Popen constructor's "stdin" argument, as it will be used internally. The other arguments are the same as for the Popen constructor. If universal_newlines=True is passed, the "input" argument must be a string and stdout/stderr in the returned object will be strings rather than bytes. .. versionadded:: 1.2a1 This function first appeared in Python 3.5. It is available on all Python versions gevent supports. .. versionchanged:: 1.3a2 Add the ``capture_output`` argument from Python 3.7. It automatically sets ``stdout`` and ``stderr`` to ``PIPE``. It is an error to pass either of those arguments along with ``capture_output``. r~Nror}Fcapture_outputrrr|rz@stdout and stderr arguments may not be used with capture_output.rr) rrr`rrrrBrtrrxrsrrr=) rurvr~ror}rrr|rrzrQrQrRr<s< #     cOs<ddlm}|rddl}t|dr|jddddSdSdS)Nr)MACset_start_methodrkT)force)gevent._compatrmultiprocessingrr) target_module_args_kwargsrrrQrQrR_gevent_did_monkey_patchs  r)hrn __future__rrrrrjrwr8rtypesr ImportErrorrr gevent.eventr gevent.hubrrrrr rr r r r rrrr gevent._utilrrgevent.greenletrrr subprocess__subprocess____implements__platform startswithrrr __imports__ __extra__removesysconfr'extendrOrTrUractually_importedr differencerr,r-_attr_resolution_orderrAnamevalueplace__all___xrrr_rXrrgeventri get_originalrk gevent.osrlrmr, Exceptionrrrr-rgevent.timeoutrrrBrrrrrrrr=r<rrQrQrQrRs(                                          O   X@* F