H/\c@@sdZddlmZmZddlZddlZddlZddlZddlZddl Z ddl m Z ddl m Zddl mZddl mZddl mZdd lmZmZmZdd lmZdd lmZdd lmZdd lmZddlmZddlmZddlmZmZej Z ddl!Z"ddddgZ#eoej$j%d re#j&de'Z(ndZ)ddddddddd d!d"g Z*d#d$d%d&d'd(d)d*d+d,d-d.d/d0d1d2d3d4d5d6d7d8d9gZ+ej,d: d;d;fkrIe*d<d=d>d?d@g7Z*n e+j&d@ej,d: d;dAfkre+j-d8e+j-d9e#j&d8e#j&d9e+j-d#yej.dBZ/Wn dCZ/nXnej,d: d;dDfkr e+j-d%e*j&d%nej,d: d;dEfkrSe*j0dFdGdHdIdJdKdLdMdNdOg nee"e1dPe*dQe2Z3e+j0e4e*j5e4e3e3Z*[3e6e"d(eZ7e6e"d)eZ8e"e7e8gZ9xe:e+D]}Z;e;e1krqneZ<x0e9D](Z=e6e=e;eZ<e<ek r,PnqWe<ekrLe+j-e;n e<e1e;x3d8d9d@fD]"Z?e?e>kre>j&e?nqzWej$dkZ@e@rddlAZAerdReBfdSYZCnnJddlDZDddlEZEddTlFmGZGeGjHdUdVZIddWlJmKZKdXZLdYZMdZZNeOZPd@e1krdd[lQmRZSd@eSfd\YZTneUed]rejVZWn d^ZWd_ZXdeOfd`YZYdaZZdbZ[d9eOfdcYZ\ddZ]dS(es% 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 i(tabsolute_importtprint_functionN(t AsyncResult(t_get_hub_noargs(t linkproxy(tsleep(t getcurrent(t integer_typest string_typestxrange(tPY3(treraise(tfspath(tfsencode(t_NONE(t copy_globals(tGreenlettjoinalltPopentcallt check_callt check_outputtwin32t_posixsubprocesssPIPE should be importedtPIPEtSTDOUTtCalledProcessErrortCREATE_NEW_CONSOLEtCREATE_NEW_PROCESS_GROUPtSTD_INPUT_HANDLEtSTD_OUTPUT_HANDLEtSTD_ERROR_HANDLEtSW_HIDEtSTARTF_USESTDHANDLEStSTARTF_USESHOWWINDOWtMAXFDt_eintr_retry_callt STARTUPINFOt pywintypest list2cmdlinet _subprocesst_winapit WAIT_OBJECT_0tWaitForSingleObjecttGetExitCodeProcesst GetStdHandlet CreatePipetDuplicateHandletGetCurrentProcesstDUPLICATE_SAME_ACCESStGetModuleFileNamet GetVersiont CreateProcesstINFINITEtTerminateProcesst STILL_ACTIVEtruntCompletedProcessiitDEVNULLtgetstatusoutputt getoutputtSubprocessErrortTimeoutExpiredit SC_OPEN_MAXiiitABOVE_NORMAL_PRIORITY_CLASStBELOW_NORMAL_PRIORITY_CLASStHIGH_PRIORITY_CLASStIDLE_PRIORITY_CLASStNORMAL_PRIORITY_CLASStREALTIME_PRIORITY_CLASStCREATE_NO_WINDOWtDETACHED_PROCESStCREATE_DEFAULT_ERROR_MODEtCREATE_BREAKAWAY_FROM_JOBt only_namestignore_missing_namestHandlecB@s5eZeZdZdZdZeZeZRS(cC@s&|js"t|_tj|ndS(N(tclosedtTrueR)t CloseHandle(tself((s0lib/python2.7/site-packages/gevent/subprocess.pytCloses  cC@s,|jst|_t|StddS(Nsalready closed(RMRNtintt ValueError(RP((s0lib/python2.7/site-packages/gevent/subprocess.pytDetachs   cC@sdt|S(Ns Handle(%d)(RR(RP((s0lib/python2.7/site-packages/gevent/subprocess.pyt__repr__s( t__name__t __module__tFalseRMRQRTRUt__del__t__str__(((s0lib/python2.7/site-packages/gevent/subprocess.pyRLs    (tmonkeytostfork(tfork_and_watchc O@si|jdd}t||B}y|jd|dtSWn|j|jnXWdQXdS(s^ 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`). ttimeoutt _raise_excN(tpoptNoneRtwaitRNtkill(t popenargstkwargsR_tp((s0lib/python2.7/site-packages/gevent/subprocess.pyRs  cO@sSt||}|rO|jd}|dkr=|d}nt||ndS(s 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"]) targsiN(RtgetRbR(ReRftretcodetcmd((s0lib/python2.7/site-packages/gevent/subprocess.pyRs   c O@sK|jdd}d|kr-tdnd|krrd|krTtdn|d}|d=t|d 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``:: >>> print(check_output(["/bin/sh", "-c", ... "ls -l non_existent_file ; exit 0"], ... stderr=STDOUT).decode('ascii').strip()) ls: non_existent_file: 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 R_tstdouts3stdout argument not allowed, it will be overridden.tinputtstdins/stdin and input arguments may not both be used.toutputN( RaRbRSRRt communicateR>RdRhRctpollR(ReRfR_t inputdatatprocessRot unused_errRj((s0lib/python2.7/site-packages/gevent/subprocess.pyRs2-          !(tTimeoutcB@s2eZdZddZedZdZRS(s 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 cC@s/tj|d||_||_||_dS(N(t_Timeoutt__init__RbRktsecondsRo(RPRkR_Ro((s0lib/python2.7/site-packages/gevent/subprocess.pyRwys  cC@s|jS(N(Rx(RP((s0lib/python2.7/site-packages/gevent/subprocess.pyR_scC@sd|j|jfS(Ns'Command '%s' timed out after %s seconds(RkR_(RP((s0lib/python2.7/site-packages/gevent/subprocess.pyRZsN(RVRWt__doc__RbRwtpropertyR_RZ(((s0lib/python2.7/site-packages/gevent/subprocess.pyR>ks  tset_inheritablecC@stS(N(RN(titv((s0lib/python2.7/site-packages/gevent/subprocess.pytscG@s'ddlm}|td<||S(Ni(t FileObjectR(tgevent.fileobjectRtglobals(Rht _FileObject((s0lib/python2.7/site-packages/gevent/subprocess.pyRs cB@seZdZdZerdndd*d*d*d*d*eed*d*d*d*deed+d*d*d*d*dZdZ dZ dZ d*Z d*Z d*d*dZd Zd Zd Zd*ed ZerDd ZdZdZdZdZdZdZdZdZd*edZdZdZeZ ndZdZe!dZ"dZ#dZ$d,Z%e&d Z'e&d!Z(e&d"Z)d#Zd$Z*d%Zd*ed&Zd'Zd(Zd)Z RS(-sQ 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. .. 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. tiic$C@s||_||_t}|dkr<tr3dnd}nt|tsZtdntr6|dk r{t dnt j d dkr|t kr t }q nc|dk p|dk p|dk }|t kr|rt}q t }n|r |r t dn|dkr!|j}n||_t|_n|t krZtrQt }qZt}n|r| rddl}|jd tt }n| dk rt d n|dkrt d n|dkst|j|_|dk r| dk rt| t|krtd n||_d|_d|_d|_d|_d|_| |_t |_!|j"|||\}}}}}}tr|dkrt#j$|j%d}n|dkrt#j$|j%d}n|dkrt#j$|j%d}qnto0|jp0|jp0| p0|}|s?| rKd |_&n|dkrtr|rt'|d||_|jj(ddt d|dkd|jd|jqt'|d||_n|dkrO| s|r7trt'|d||_|jj(dd|jd|jqLt'|d||_qOt'|d||_n|dkr| sg|rtrt'|d||_|jj(dd|d|qt'|d||_qt'|d||_nt|_)| dk rt*| nd} yG|j+|||||| | | | || ||||||||WnUtsZt j,} nxQt-d|j|j|jfD].}!y|!j.Wq|t/t0fk rq|Xq|W|j)srg}"|t1kr|"j2|n|t1kr|"j2|n|t1kr|"j2|nt3|dr3|"j2|j4nx<|"D]1}#yt5j.|#Wq:t/t0fk rjq:Xq:Wntszt6| Wd~ XnnXdS(Niisbufsize must be an integers0preexec_fn is not supported on Windows platformsiiisSclose_fds is not supported on Windows platforms if you redirect stdin/stdout/stderrspass_fds overriding close_fds.s2startupinfo is only supported on Windows platformss4creationflags is only supported on Windows platformsslCannot disambiguate when both text and universal_newlines are supplied but different. Pass one or the other.Rtwbt write_throughtline_bufferingitencodingterrorstrbtrtrUt_devnull(ii(7RRtget_hubRbR t isinstanceRt TypeErrort mswindowsRStsyst version_infot_PLATFORM_DEFAULT_CLOSE_FDSRNRXt threadpoolt_waitingtwarningstwarntRuntimeWarningtAssertionErrortloopt_looptboolR=RhRnRltstderrtpidt returncodetuniversal_newlinesRtresultt _get_handlestmsvcrttopen_osfhandleRTt_communicate_empty_valueRttranslate_newlinest_closed_child_pipe_fdsR t_execute_childtexc_infotfiltertclosetOSErrortIOErrorRtappendthasattrRR\R ($RPRhtbufsizet executableRnRlRt preexec_fnt close_fdstshelltcwdtenvRt startupinfot creationflagstrestore_signalststart_new_sessiontpass_fdsRRttextRthubt any_stdio_setRtp2creadtp2cwritetc2preadtc2pwriteterrreadterrwritet text_modeRtftto_closetfd((s0lib/python2.7/site-packages/gevent/subprocess.pyRws                                 '   $       %     (      cC@s&d|jjt||j|jfS(Ns!<%s at 0x%x pid=%r returncode=%r>(t __class__RVtidRR(RP((s0lib/python2.7/site-packages/gevent/subprocess.pyRUscC@sa|j|j}tj|r8tj| |_ntj||_|jj|jdS(N( tstoptrstatusR\t WIFSIGNALEDtWTERMSIGRt WEXITSTATUSRtset(RPtwatchertstatus((s0lib/python2.7/site-packages/gevent/subprocess.pyt _on_childs   cC@s4t|ds-tjtjtj|_n|jS(NR(RR\topentdevnulltO_RDWRR(RP((s0lib/python2.7/site-packages/gevent/subprocess.pyt _get_devnullsc@sg}jr.|jttj|nfd}jrn|d}t|}|j|nd}jr|d}t|}|j|nd}| r|dk rjd|dtnt |d|} |dk r"t | t |kr"t j |nxEjjfD]1} | r5y| j Wqftk rbqfXq5q5Wjfd} | d} | d} |dkrdn| |dkrdn| fS(sCInteract with process: Send 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). c@s6t|d|dfd}|S(Nt_t_bufferc@skyj}Wntk r$dSX|s/dSt}|rT|j|nt|gdS(N(treadt RuntimeErrortgetattrRtsetattr(tdatat the_buffer(tbuf_nametpipeRP(s0lib/python2.7/site-packages/gevent/subprocess.pyt_reads (R(t pipe_nameR(RP(RRs0lib/python2.7/site-packages/gevent/subprocess.pyt_make_pipe_readers RlRR_R`c@sUd|d}t|}t|d|rHjj|}n j}|S(NRR(RRRbRtjoin(RRt buf_value(RP(s0lib/python2.7/site-packages/gevent/subprocess.pyt_get_output_values N(RnRtspawntwrite_and_closeRlRbRRcRNRtlenR>RhRR(RPRmR_t greenletsRt _read_outRlt _read_errRtdoneRRt stdout_valuet stderr_value((RPs0lib/python2.7/site-packages/gevent/subprocess.pyRps>        $     cC@s |jS(sSCheck if child process has terminated. Set and return :attr:`returncode` attribute.(t_internal_poll(RP((s0lib/python2.7/site-packages/gevent/subprocess.pyRqscC@s|S(N((RP((s0lib/python2.7/site-packages/gevent/subprocess.pyt __enter__scC@sa|jr|jjn|jr2|jjnz|jrN|jjnWd|jXdS(N(RlRRRnRc(RPttR}ttb((s0lib/python2.7/site-packages/gevent/subprocess.pyt__exit__s   cC@sP|jjd|}|rL|dk rL|jj rLt|j|n|S(NR_(RRcRbtreadyR>Rh(RPR_t raise_excR((s0lib/python2.7/site-packages/gevent/subprocess.pyt_gevent_result_wait*s"c C@s|dkr(|dkr(|dkr(dSd\}}d\}}d\}} ytWntk rpt} nXt} |dkrtt}|dkrxtdd\}} trt|}t j | qqxn|t krtdd\}}trxt|t|}}qxnZ|| krBt j |j}n6t|trct j |}nt j |j}|j|}|dkrtt}|dkrtdd\} }trt|}t j | qqn|t kr.tdd\}}trt|t|}}qnZ|| krRt j |j}n6t|trst j |}nt j |j}|j|}|dkrtt} | dkrtdd\} } trt| } t j | qqn|t kr>tdd\}} trt|t| }} qno|tkrS|} nZ|| krwt j |j} n6t|trt j |} nt j |j} |j| } |||||| fS(s|Construct and return tuple with IO objects: p2cread, p2cwrite, c2pread, c2pwrite, errread, errwrite iiN(iiiiii(ii(ii(ii(RbR:t NameErrortobjectR-RR.R RLR)RORRt get_osfhandleRRRRtfilenot_make_inheritableRRR( RPRnRlRRRRRRRRR((s0lib/python2.7/site-packages/gevent/subprocess.pyR5s$                         cC@stt|tddtS(s2Return a duplicate of handle, which is inheritableii(R/R0R1(RPthandle((s0lib/python2.7/site-packages/gevent/subprocess.pyRs cC@stjjtjjtdd}tjj|stjjtjjtjd}tjj|stdqn|S(s-Find and return absolute path to w9xpopen.exeis w9xpopen.exesZCannot locate w9xpopen.exe, which is needed for Popen to work with your shell or platform.( R\tpathRtdirnameR2texistsRt exec_prefixR(RPtw9xpopen((s0lib/python2.7/site-packages/gevent/subprocess.pyt_find_w9xpopens  cC@std|DS(sFilter 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.cS@s>h|]4}|d@dks4tj|tjkr|qS(i(R)t GetFileTypetFILE_TYPE_CHAR(t.0R((s0lib/python2.7/site-packages/gevent/subprocess.pys s  (tlist(RPt handle_list((s0lib/python2.7/site-packages/gevent/subprocess.pyt_filter_handle_listsc! C@sN| stdt|ts1t|}n| dkrIt} nd| ||fk}|r| jtO_| | _|| _ || _ nt | dr| j }t |od|ko|d}|s|r|r|dkri}| _ nt|jdg}|d<|rG|t| t|t|g7}n|j||(|r|sddl}|jdtnt}qqn| r/| jtO_t| _tjjdd }d j||}td kstjj|jd kr/|j }d ||f}| t!O} q/nzpy;t"||ddt| | ||| \}}}}Wn.t#k r}t$rnt%|j&nXWdd} | | | || |t |drtj'|j(nXt)|_*t |dst+|n||_,||_-t |ds@t.j/|n |j0dS(s$Execute program (MS Windows version)s"pass_fds not supported on Windows.itlpAttributeListR iNs?startupinfo.lpAttributeList['handle_list'] overriding close_fdstCOMSPECscmd.exes {} /c "{}"Is command.coms"%s" %scS@sH|dk rD|dkrDt|dr4|jqDtj|ndS(NiRQ(RbRRQR)RO(tx((s0lib/python2.7/site-packages/gevent/subprocess.pyt_closes RRQ(1RRRR'RbR%tdwFlagsR!t hStdInputt hStdOutputt hStdErrorRR RRRiRRR RRRRXR"R t wShowWindowR\tenvirontformatR3RtbasenametlowerRRR4RR t WindowsErrorRhRRRNt_child_createdRLt_handleRR)RORQ(!RPRhRRRRRRRRRRRRRRRRtunused_restore_signalstunused_start_new_sessiontuse_std_handlestattribute_listthave_handle_listR RtcomspecRthpthtRttidteR((s0lib/python2.7/site-packages/gevent/subprocess.pyRsz            (    -        $ cC@sY|jdkrRt|jdtkrRt|j|_|jj|jqRn|jS(s^Check if child process has terminated. Returns returncode attribute. iN(RRbR+RR*R,RR(RP((s0lib/python2.7/site-packages/gevent/subprocess.pyR's cC@sS|jj r6|j r6t|_tj|jn|jjt||dS(N( RRRRNRRt_waittrawlinkR(RPtcallback((s0lib/python2.7/site-packages/gevent/subprocess.pyR&2s cC@s)t|jtt|j|_|jS(N(R+RR5R,R(RP((s0lib/python2.7/site-packages/gevent/subprocess.pyt_blocking_wait9scC@s#|jj|jj|jdS(N(RRR(R&R(RP((s0lib/python2.7/site-packages/gevent/subprocess.pyR%?scC@sA|jdkr1|js1t|_|jq1n|j||S(sOWait for child process to terminate. Returns returncode attribute.N(RRbRRNR%R(RPR_R`((s0lib/python2.7/site-packages/gevent/subprocess.pyRcBs   cC@s|tjkr|jne|tjkrDtj|jtjn=|tjkrltj|jtjntdj |dS(s)Send a signal to the process sUnsupported signal: {}N( tsignaltSIGTERMt terminatet CTRL_C_EVENTR\RdRtCTRL_BREAK_EVENTRSR(RPtsig((s0lib/python2.7/site-packages/gevent/subprocess.pyt send_signalKs cC@s|jdk rdSyt|jdWnetk r}|jdkrNnt|j}|tkron||_|jj |jnXdS(s#Terminates the process Nii( RRbR6RRtwinerrorR,R7RR(RPR$trc((s0lib/python2.7/site-packages/gevent/subprocess.pyR+Ws  cC@s|jjt||dS(N(RR&R(RPR'((s0lib/python2.7/site-packages/gevent/subprocess.pyR&rsc C@sd\}}d\}}d\}} ytWntk rHt} nXt} |dkr^n`|tkr|j\}}n?|| kr|j}n$t|tr|}n |j }|dkrn`|tkr|j\}}n?|| kr |j}n$t|tr!|}n |j }|dkr<n|tkr]|j\}} nr|t kr|dkr~|} qt j j } n?|| kr|j} n$t|tr|} n |j } |||||| fS(s|Construct and return tuple with IO objects: p2cread, p2cwrite, c2pread, c2pwrite, errread, errwrite i(ii(ii(iiN( R:RRRbRt pipe_cloexecRRRRRRRt __stdout__( RPRnRlRRRRRRRR((s0lib/python2.7/site-packages/gevent/subprocess.pyRwsT                       cC@s~y tj}Wntk r&d}nXtj|tj}|r_tj|tj||Bntj|tj||@dS(Ni(tfcntlt FD_CLOEXECtAttributeErrortF_GETFDtF_SETFD(RPRtcloexect cloexec_flagtold((s0lib/python2.7/site-packages/gevent/subprocess.pyt_set_cloexec_flags   cC@s7tj|tjtj@}tj|tj|dS(N(R4tF_GETFLR\t O_NONBLOCKtF_SETFL(RPRtflags((s0lib/python2.7/site-packages/gevent/subprocess.pyt_remove_nonblock_flagscC@s6tj\}}|j||j|||fS(s#Create a pipe with FDs set CLOEXEC.(R\RR<(RPRtw((s0lib/python2.7/site-packages/gevent/subprocess.pyR2s  s /proc/self/fds/dev/fdcC@sIx6|jD]+}tjj|r |j|||Sq W|j||S(N(t_POSSIBLE_FD_DIRSR\Rtisdirt_close_fds_from_patht_close_fds_brute_force(tclstkeept errpipe_writeR((s0lib/python2.7/site-packages/gevent/subprocess.pyt _close_fdsscC@sy,gtj|D]}t|^q}Wn'ttfk rU|j||n{Xx-|D]%}||kruq]nt|tq]WxG|D]?}||ks|dkrqnytj|WqqXqWdS(Ni( R\tlistdirRRRSRRFt_set_inheritableRNR(RGRRHRItfnametfdsR|R((s0lib/python2.7/site-packages/gevent/subprocess.pyREs,   cC@sttdstt|}t|}t|}tjd|tj|dtxQt||D]@}||krt |t qmnytj |WqmqmXqmWdS(Nt closerangeii( RR\RtsortedtmintmaxROR#R RLRNR(RGRHRItmin_keeptmax_keepR|((s0lib/python2.7/site-packages/gevent/subprocess.pyRFs      c&@sztr't|ttfr'|g}nUt rIt|trI|g}n3yt|}Wn tk r{t|g}nX| rddg|}|r||dtj||nyj|Wntk rbnXdS(Ni(R<RXR\tdup2RAR(texistingtdesired(RP(s0lib/python2.7/site-packages/gevent/subprocess.pyt_dup2cs   itSIGPIPEtSIGXFZtSIGXFSZcS@s[i|]Q\}}t|tr0tj|n|t|trQtj|n|qS((RtbytesR\tfsdecode(RtkR}((s0lib/python2.7/site-packages/gevent/subprocess.pys s RNRRRt _failed_chdir(ii(RYRZR[(8R RtstrR\RRRR RbRtinstall_sigchldR2RR\tdupRtgct isenabledtdisableR^RRNR]RtenableRtaddtchdirRR_RJRR)tSIG_DFLtsetsidtexecvptitemstexecvpeRRt tracebacktformat_exceptionRtchild_tracebacktwritetpickletdumpst_exitRRRRRRctloadstfilename(&RPRhRRRRRRRRRRRRRRRRRRt errpipe_readRItlow_fds_to_closetlow_fdtgc_was_enabledRXRMRR$t fds_to_keepR.texc_typet exc_valueRt exc_linest devnull_fdRtchild_exception((RPs0lib/python2.7/site-packages/gevent/subprocess.pyRs           "                       ! $$$      cC@sYtj|r%tj| |_n0tj|rItj||_n tddS(NsUnknown child exit status!(R\RRRt WIFEXITEDRR(RPtsts((s0lib/python2.7/site-packages/gevent/subprocess.pyt_handle_exitstatuss cC@sV|jdkrOttk rOt|jdt}|rLtdqLqOn|jS(s^Check if child process has terminated. Returns returncode attribute. t sig_pendinggh㈵>N(RRbRRRRRNR(RPR((s0lib/python2.7/site-packages/gevent/subprocess.pyRs cC@s|j||S(s 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(RPR_R`((s0lib/python2.7/site-packages/gevent/subprocess.pyRcs cC@s)|jdkr%tj|j|ndS(s)Send a signal to the process N(RRbR\RdR(RPR.((s0lib/python2.7/site-packages/gevent/subprocess.pyR/scC@s|jtjdS(s/Terminate the process with SIGTERM N(R/R)R*(RP((s0lib/python2.7/site-packages/gevent/subprocess.pyR+ scC@s|jtjdS(s*Kill the process with SIGKILL N(R/R)tSIGKILL(RP((s0lib/python2.7/site-packages/gevent/subprocess.pyRdsN((s /proc/self/fds/dev/fd(+RVRWRyRR RbRRXRwRURRt_stdout_buffert_stderr_bufferRpRqRRRRRRRR RRR&R(R%RcR/R+RdRNR<RAR2RCt classmethodRJRERFR(((s0lib/python2.7/site-packages/gevent/subprocess.pyRsl'     j    U    w       <      cC@szy6|r8|j|t|dr8|jq8nWnCttfk r~}|jtjkr|jtjkrqnXWdy|jWnt k rnXXdS(Ntflush( RqRRRRterrnotEPIPEtEINVALRtEnvironmentError(tfobjRtex((s0lib/python2.7/site-packages/gevent/subprocess.pyRs $ cC@s|j|_||_|S(N(RoRlR(texcR((s0lib/python2.7/site-packages/gevent/subprocess.pyt_with_stdout_stderr&s  cB@s/eZdZdddZdZdZRS(s 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. cC@s(||_||_||_||_dS(N(RhRRlR(RPRhRRlR((s0lib/python2.7/site-packages/gevent/subprocess.pyRw>s   cC@sdj|jdj|jg}|jdk rO|jdj|jn|jdk rz|jdj|jndjt|jdj |S(Ns args={!r}sreturncode={!r}s stdout={!r}s stderr={!r}s{}({})s, ( RRhRRlRbRRttypeRVR(RPRh((s0lib/python2.7/site-packages/gevent/subprocess.pyRUDscC@s7|jr3tt|j|j|j|jndS(s6Raise CalledProcessError if the exit code is non-zero.N(RRRRhRlR(RP((s0lib/python2.7/site-packages/gevent/subprocess.pytcheck_returncodeMs N(RVRWRyRbRwRUR(((s0lib/python2.7/site-packages/gevent/subprocess.pyR9.s c O@s|jdd }|jdd }|jdt}|jdt}|d k r|d|krotdnt|d 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``. RmR_tchecktcapture_outputRns/stdin and input arguments may not both be used.RlRs@stdout and stderr arguments may not be used with capture_output.RoN(RaRbRXRSRRRpR>RdRRhRcRqRR9( ReRfRmR_RRRsRlRRj((s0lib/python2.7/site-packages/gevent/subprocess.pyR8Ts8#       $    '(^Ryt __future__RRRRcR\R)RRnt gevent.eventRt gevent.hubRRRRRtgevent._compatRRR R R R R t gevent._utilRRtgevent.greenletRRRt subprocesst__subprocess__t__implements__tplatformt startswithRRbRRt __imports__t __extra__RtremovetsysconfR#textendRRNtactually_importedRt differenceRR(R)t_attr_resolution_orderRtnametvaluetplacet__all__t_xRRRRRLR4RrtgeventR[t get_originalR]t gevent.osR^RRRRRtgevent.timeoutRuRvR>RR{RLRRRRR9R8(((s0lib/python2.7/site-packages/gevent/subprocess.pyts*                        "           I      &