+ j!@Rt^RIt^RIt^RIHt^RIHt^RIHtH t ^RI H t RRlt !RR] 4t!R R ] P4tR/RR^3R lt!R R ] P4tR/RR3Rlt!RR] P4tR/RRR3RltRtRtRt.ROtR#)z Utility methods. Nwraps)BytesIO)deferprotocol)failurecVf^RIHp\P!4pV!V.VO5!pVP WV3\ V4,W44V#)N)reactor)twisted.internetr rDeferred spawnProcesstuple) r executableargsenvpathr protoArgsdps &&&&&&& 8/usr/lib/python3/dist-packages/twisted/internet/utils.py_callProtocolWithDeferredrsI, AYA  d (CSO Hc*a]tRt^toRtRtRtVtR#)_UnexpectedErrorOutputa] Standard error data was received where it was not expected. This is a subclass of L{IOError} to preserve backward compatibility with the previous error behavior of L{getProcessOutput}. @ivar processEnded: A L{Deferred} which will fire when the process which produced the data on stderr has ended (exited and all file descriptors closed). cF\PVRV: 24W nR#)z got stderr: N)IOError__init__ processEnded)selftextrs&&&rr_UnexpectedErrorOutput.__init__*sdX67(r)rN)__name__ __module__ __qualname____firstlineno____doc__r__static_attributes____classdictcell__ __classdict__s@rrrs))rrcFa]tRt^/toRtR RltRtRtRtRt Rt Vt R#) _BackRelaya Trivial protocol for communicating with a process and turning its output into the result of a L{Deferred}. @ivar deferred: A L{Deferred} which will be called back with all of stdout and, if C{errortoo} is true, all of stderr as well (mixed together in one string). If C{errortoo} is false and any bytes are received over stderr, this will fire with an L{_UnexpectedErrorOutput} instance and the attribute will be set to L{None}. @ivar onProcessEnded: If C{errortoo} is false and bytes are received over stderr, this attribute will refer to a L{Deferred} which will be called back when the process ends. This C{Deferred} is also associated with the L{_UnexpectedErrorOutput} which C{deferred} fires with earlier in this case so that users can determine when the process has actually ended, in addition to knowing when bytes have been received via stderr. cWn\4VnV'dVPVnR#VP VnR#N)deferredrserrReceivedIsGood errReceivederrReceivedIsBad)rr.errortoos&&&rr_BackRelay.__init__Bs/  #55D #44D rc$VPe\P!4Vn\ WP4pVPP \ P!V44RVnVPP4R#R#r-) r.rr onProcessEndedrerrbackrFailure transportloseConnection)rrerrs&& rr2_BackRelay.errReceivedIsBadJsb == $"'.."2D (/B/BCC MM ! !'//#"6 7 DM NN ) ) + %rc<VPPV4R#r-r/writerrs&&rr0_BackRelay.errReceivedIsGoodR  Trc<VPPV4R#r-r>r@s&&r outReceived_BackRelay.outReceivedUrBrcVPe6VPPVPP44R#VPeVPP V4R#R#r-)r.callbackr/getvaluer6r7rreasons&&rr_BackRelay.processEndedXsN == $ MM " "466??#4 5  ,    ' ' /-r)r.r1r6r/N)) r!r"r#r$r%rr2r0rDrr&r'r(s@rr+r+/s($5,00rr+c(a\V3RlWW#V4#)a Spawn a process and return its output as a deferred returning a L{bytes}. @param executable: The file name to run and get the output of - the full path should be used. @param args: the command line arguments to pass to the process; a sequence of strings. The first string should B{NOT} be the executable's name. @param env: the environment variables to pass to the process; a dictionary of strings. @param path: the path to run the subprocess in - defaults to the current directory. @param reactor: the reactor to use - defaults to the default reactor @param errortoo: If true, include stderr in the result. If false, if stderr is received the returned L{Deferred} will errback with an L{IOError} instance with a C{processEnded} attribute. The C{processEnded} attribute refers to a L{Deferred} which fires when the executed process ends. c<\VSR7#))r3)r+)rr3s&r"getProcessOutput..ys *Q2r)r)rrrrr r3s&&&&&frgetProcessOutputrQ_s2 %2JcQX rc,a]tRt^}toRtRtRtVtR#) _ValueGettercWnR#r-r.)rr.s&&rr_ValueGetter.__init__~s rcdVPPVPP4R#r-)r.rGvalueexitCoderIs&&rr_ValueGetter.processEndeds v||445rrUN)r!r"r#r$rrr&r'r(s@rrSrS}s!66rrSc&\\WW#V4#)z7Spawn a process and return its exit code as a Deferred.)rrS)rrrrr s&&&&&rgetProcessValuer\s $\:SPW XXrc6a]tRt^toRRltRtRtRtVtR#)_EverythingGetterNcWn\4Vn\4VnVPPVnVPPVnW nR#r-)r.routBuferrBufr?rDr1 stdinBytes)rr.rbs&&&rr_EverythingGetter.__init__sB i i ;;,,;;,,$rcVPeCVPP^VP4VPP4R#R#r-)rbr9 writeToChild closeStdin)rs&rconnectionMade _EverythingGetter.connectionMades; ?? & NN ' '4?? ; NN % % ' 'rcNVPP4pVPP4pVPpVPpVP 'd*VP PW#VP 34R#VP PW#V34R#r-) r`rHrarXrYsignalr.r7rG)rrJoutr;ecodes&& rr_EverythingGetter.processEndedsskk""$kk""$ LLzz 888 MM ! !3QXX"6 7 MM " "Cd#3 4r)r.rar1r`rDrbr-) r!r"r#r$rrgrr&r'r(s@rr^r^s%(55rr^c 0\\VVVVVV3R7#)aSpawn a process and returns a Deferred that will be called back with its output (from stdout and stderr) and it's exit code as (out, err, code) If a signal is raised, the Deferred will errback with the stdout and stderr up to that point, along with the signal, as (out, err, signalNum) )r)rr^)rrrrr rbs&&&&&&rgetProcessOutputAndValuerps( %   - rc|VF#p\PPV4K% V# \dK7i;ir-)warningsfiltersremove ValueError) passthrough addedFiltersfs&& r_resetWarningFiltersrysA      # #A &    s , ;;cVFwrE\P!V/VBK \PR\V4pV!V/VBp\ V\ P 4'dVP\V4V#\RV4V# \dB\P!4p\RT4T^,PT^,4hi;i)a= Run the function I{f}, but with some warnings suppressed. This calls L{warnings.filterwarnings} to add warning filters before invoking I{f}. If I{f} returns a L{Deferred} then the added filters are removed once the deferred fires. Otherwise they are removed immediately. Note that the list of warning filters is a process-wide resource, so calling this function will affect all threads. @param suppressedWarnings: A list of arguments to pass to L{warnings.filterwarnings}, a sequence of (args, kwargs) 2-tuples. @param f: A callable, which may return a L{Deferred}. @param a: Positional arguments passed to I{f} @param kw: Keyword arguments passed to I{f} @return: The result of C{f(*a, **kw)} @seealso: L{twisted.python.util.runWithWarningsSuppressed} functions similarly, but doesn't handled L{Deferred}s. N) rrfilterwarningsrslen isinstancerr addBothry BaseExceptionsysexc_infowith_traceback) suppressedWarningsrxakwrkwargsrwresultrs &&*, rrunWithWarningsSuppressedrs4+ 00+##$=c*<&=>L A fenn - - NN/ >  !| 4  6<<>T<0qk((!556s B A Cc4aa\S4VV3Rl4pV#)z Wrap C{f} in a callable which suppresses the indicated warnings before invoking C{f} and unsuppresses them afterwards. If f returns a Deferred, warnings will remain suppressed until the Deferred fires. c$<\SS.VO5/VB#r-)r)rrrxrs*,rwarningSuppressingWrapper3suppressWarnings..warningSuppressingWrappers();QIIbIIrr)rxrrsfj rsuppressWarningsrs% 1XJJ %$r)Nr)rrrQr\rp)r%rrr functoolsriorr rrtwisted.pythonrrrrProcessProtocolr+rQrSr\r^rpryrr__all__rrrrs   ,"   )W ) -0))-0`')btTTU<68++6&(RdDY 50058RdDT&(V % r