h!@SrSSKrSSKrSSKJr SSKJr SSKJrJ r SSK J r SSjr "S S \ 5r"S S \ R5rS0SSS4S jr"SS\ R5rS0SS4Sjr"SS\ R5rS0SSS4SjrSrSrSr/SQrg)z Utility methods. Nwraps)BytesIO)deferprotocol)failurecUcSSKJn [R"5nU"U/UQ76nUR XU4[ U5-X45 U$)Nr)reactor)twisted.internetr rDeferred spawnProcesstuple) r executableargsenvpathr protoArgsdps ]/root/1688_scrapy/alibaba-scraper/venv/lib/python3.13/site-packages/twisted/internet/utils.py_callProtocolWithDeferredrsI, AYA  d (CSO Hc\rSrSrSrSrSrg)_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). cD[RUSU<35 X lg)Nz got stderr: )IOError__init__ processEnded)selftextr s rr_UnexpectedErrorOutput.__init__*sdX67(r)r N)__name__ __module__ __qualname____firstlineno____doc__r__static_attributes__r rrrrs )rrc:\rSrSrSrS SjrSrSrSrSr Sr g ) _BackRelay/a 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. cXl[5UlU(aURUlgUR UlgN)deferredrserrReceivedIsGood errReceivederrReceivedIsBad)r!r/errortoos rr_BackRelay.__init__Bs/  #55D #44D rcURb[R"5Ul[ XR5nURR [ R"U55 SUlURR5 ggr.) r/rr onProcessEndedrerrbackrFailure transportloseConnection)r!r"errs rr3_BackRelay.errReceivedIsBadJsb == $"'.."2D (/B/BCC MM ! !'//#"6 7 DM NN ) ) + %rc:URRU5 gr.r0writer!r"s rr1_BackRelay.errReceivedIsGoodR  Trc:URRU5 gr.r?rAs r outReceived_BackRelay.outReceivedUrCrcURb4URRURR55 gURbURR U5 ggr.)r/callbackr0getvaluer7r8r!reasons rr _BackRelay.processEndedXsN == $ MM " "466??#4 5  ,    ' ' /-r)r/r2r7r0N)r) r$r%r&r'r(rr3r1rEr r)r rrr+r+/s $5,0rr+c(^[U4SjXX#U5$)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>[UTS9$)N)r4)r+)rr4s r"getProcessOutput..ys *Q2r)r)rrrrr r4s `rgetProcessOutputrQ_s2 %2JcQX rc \rSrSrSrSrSrg) _ValueGetter}cXlgr.r/)r!r/s rr_ValueGetter.__init__~s rcbURRURR5 gr.)r/rHvalueexitCoderJs rr _ValueGetter.processEndeds v||445rrVN)r$r%r&r'rr r)r rrrSrS}s !6rrSc&[[XX#U5$)z7Spawn a process and return its exit code as a Deferred.)rrS)rrrrr s rgetProcessValuer]s $\:SPW XXrc*\rSrSrSSjrSrSrSrg)_EverythingGetterNcXl[5Ul[5UlURRUlURRUlX lgr.)r/routBuferrBufr@rEr2 stdinBytes)r!r/rds rr_EverythingGetter.__init__sB i i ;;,,;;,,$rcURbAURRSUR5 URR5 gg)Nr)rdr: writeToChild closeStdin)r!s rconnectionMade _EverythingGetter.connectionMades; ?? & NN ' '4?? ; NN % % ' 'rcHURR5nURR5nURnURnUR (a(UR RX#UR 45 gUR RX#U45 gr.) rbrIrcrYrZsignalr/r8rH)r!rKoutr<ecodes rr _EverythingGetter.processEndedsqkk""$kk""$ LLzz 88 MM ! !3QXX"6 7 MM " "Cd#3 4r)r/rcr2rbrErdr.)r$r%r&r'rrir r)r rrr_r_s%(5rr_c *[[UUUUUU4S9$)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 rds rgetProcessOutputAndValuerrs( %   - rczUH#n[RRU5 M% U$![a M6f=fr.)warningsfiltersremove ValueError) passthrough addedFiltersfs r_resetWarningFiltersr{sA      # #A &    s , ::cUHupE[R"U0UD6 M [RS[U5nU"U0UD6n[ U[ R 5(aUR[U5 U$[SU5 U$![a9 [R"5n[SU5 USRUS5ef=f)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) rtfilterwarningsrulen isinstancerr addBothr{ BaseExceptionsysexc_infowith_traceback) suppressedWarningsrzakwrkwargsryresultrs rrunWithWarningsSuppressedrs4+ 00+##$=c*<&=>L A fenn - - NN/ >  !| 4  6<<>T<0qk((!556s B ACc4^^[T5UU4Sj5nU$)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$>[TT/UQ70UD6$r.)r)rrrzrs rwarningSuppressingWrapper3suppressWarnings..warningSuppressingWrappers();QIIbIIrr)rzrrs`` rsuppressWarningsrs% 1XJJ %$r)rrrQr]rr)Nr )r(rrt functoolsriorr rrtwisted.pythonrrrrProcessProtocolr+rQrSr]r_rrr{rr__all__r rrrs   ,"DF   )W ) -0))-0`')btTTU<68++6&(RdDY 50058RdDT&(V % r