+
     Bi9                     >   Rt ^ RIt^RIHt ^RIHt ^RIHt ^RIHt ^RIHt ]P                  t	]P                  t
]P                  t ! R R]P                  ]P                  4      t ! R	 R
4      tRRR]P                   3R ltRRRRRRR]P                   /R ltR# )create_subprocess_execN)events)	protocols)streams)tasks)loggerc                   `   a a ] tR t^t oRtV 3R ltR tR tR tR t	R t
R tR	 tR
tVtV ;t# )SubprocessStreamProtocolz0Like StreamReaderProtocol, but for a subprocess.c                   < \         SV `  VR 7       Wn        R;V n        ;V n        V n        RV n        RV n        . V n        V P                  P                  4       V n        R# ))loopNF)super__init___limitstdinstdoutstderr
_transport_process_exited	_pipe_fds_loopcreate_future_stdin_closed)selflimitr   	__class__s   &&&)/usr/lib/python3.14/asyncio/subprocess.pyr   !SubprocessStreamProtocol.__init__   sX    d#155
5T[4;$!ZZ557    c                ~   V P                   P                  .pV P                  e    VP                  RV P                  : 24       V P                  e    VP                  RV P                  : 24       V P
                  e    VP                  RV P
                  : 24       RP                  RP                  V4      4      # )Nzstdin=zstdout=zstderr=z<{}> )r   __name__r   appendr   r   formatjoin)r   infos   & r   __repr__!SubprocessStreamProtocol.__repr__   s    ''(::!KK&/0;;"KK'$++12;;"KK'$++12}}SXXd^,,r   c                   Wn         VP                  ^4      pVeh   \        P                  ! V P                  V P
                  R7      V n        V P                  P                  V4       V P                  P                  ^4       VP                  ^4      pVeh   \        P                  ! V P                  V P
                  R7      V n
        V P                  P                  V4       V P                  P                  ^4       VP                  ^ 4      pVe,   \        P                  ! VV RV P
                  R7      V n        R# R# )   Nr   r   )protocolreaderr   )r   get_pipe_transportr   StreamReaderr   r   r   set_transportr   r!   r   StreamWriterr   )r   	transportstdout_transportstderr_transportstdin_transports   &&   r   connection_made(SubprocessStreamProtocol.connection_made(   s    #$77:'!..T[[48JJ@DKKK%%&67NN!!!$$77:'!..T[[48JJ@DKKK%%&67NN!!!$#66q9& --o7;5937::?DJ 'r   c                    V^8X  d   V P                   pMV^8X  d   V P                  pMRpVe   VP                  V4       R# R# )r(   N)r   r   	feed_data)r   fddatar+   s   &&& r   pipe_data_received+SubprocessStreamProtocol.pipe_data_received@   s@    7[[F1W[[FFT" r   c                2   V^ 8X  d   V P                   pVe   VP                  4        V P                  V4       Vf   V P                  P	                  R4       R# V P                  P                  V4       RV P                  n        R# V^8X  d   V P                  pMV^8X  d   V P                  pMRpVe'   Vf   VP                  4        MVP                  V4       WP                  9   d   V P                  P                  V4       V P                  4        R# )    NF)r   closeconnection_lostr   
set_resultset_exception_log_tracebackr   r   feed_eofr   remove_maybe_close_transport)r   r8   excpiper+   s   &&&  r   pipe_connection_lost-SubprocessStreamProtocol.pipe_connection_lostJ   s    7::D

  %{""--d3 	 ""005 5:""17[[F1W[[FF{!$$S)NN!!"%##%r   c                4    R V n         V P                  4        R# )TN)r   rE   r   s   &r   process_exited'SubprocessStreamProtocol.process_exitedh   s    ###%r   c                    \        V P                  4      ^ 8X  d8   V P                  '       d$   V P                  P	                  4        RV n        R# R# R# )r=   N)lenr   r   r   r>   rK   s   &r   rE   /SubprocessStreamProtocol._maybe_close_transportl   s=    t~~!#(<(<(<OO!!#"DO )=#r   c                <    WP                   J d   V P                  # R # N)r   r   )r   streams   &&r   _get_close_waiter*SubprocessStreamProtocol._get_close_waiterq   s    ZZ%%%  r   )r   r   r   r   r   r   r   r   )r    
__module____qualname____firstlineno____doc__r   r%   r4   r:   rH   rL   rE   rT   __static_attributes____classdictcell____classcell__)r   __classdict__s   @@r   r	   r	      s5     :8-?0#&<&#
& &r   r	   c                   p   a  ] tR t^vt o R tR t]R 4       tR tR t	R t
R tR tR	 tR
 tRR ltRtV tR# )Processc                    Wn         W n        W0n        VP                  V n        VP                  V n        VP
                  V n        VP                  4       V n        R # rR   )r   	_protocolr   r   r   r   get_pidpid)r   r0   r*   r   s   &&&&r   r   Process.__init__w   sB    #!
^^
oooo$$&r   c                P    R V P                   P                   RV P                   R2# )<r   >)r   r    rc   rK   s   &r   r%   Process.__repr__   s&    4>>**+1TXXJa88r   c                6    V P                   P                  4       # rR   )r   get_returncoderK   s   &r   
returncodeProcess.returncode   s    --//r   c                R   "   V P                   P                  4       G Rj  xL
 #  L5i)z?Wait until the process exit and return the process return code.N)r   _waitrK   s   &r   waitProcess.wait   s     __**,,,,s   '%'c                <    V P                   P                  V4       R # rR   )r   send_signal)r   signals   &&r   rr   Process.send_signal   s    ##F+r   c                :    V P                   P                  4        R # rR   )r   	terminaterK   s   &r   rv   Process.terminate   s    !!#r   c                :    V P                   P                  4        R # rR   )r   killrK   s   &r   ry   Process.kill   s    r   c                  "   V P                   P                  4       p VeE   V P                  P                  V4       V'       d"   \        P
                  ! RV \        V4      4       V P                  P                  4       G R j  xL
  V'       d   \        P
                  ! RV 4       V P                  P                  4        R #  L?  \        \        3 d*   pT'       d   \        P
                  ! RY4        R p?LrR p?ii ; i5i)Nz%%r communicate: feed stdin (%s bytes)z%r communicate: stdin got %rz%r communicate: close stdin)r   	get_debugr   writer   debugrO   drainBrokenPipeErrorConnectionResetErrorr>   )r   inputr~   rF   s   &&  r   _feed_stdinProcess._feed_stdin   s     

$$&	H 

  'LL?s5zS **""$$$ LL6=

 %!56 	H ;TG		HsL   D&C >C CC D3DC C?C:5D:C??Dc                   "   R # 5irR    rK   s   &r   _noopProcess._noop   s     s   c                  "   V P                   P                  V4      pV^8X  d   V P                  pMV^8X  g   Q hV P                  pV P                  P                  4       '       d#   V^8X  d   RMRp\        P                  ! RW4       VP                  4       G Rj  xL
 pV P                  P                  4       '       d#   V^8X  d   RMRp\        P                  ! RW4       VP                  4        V#  LX5i)   r   r   z%r communicate: read %sNz%r communicate: close %s)
r   r,   r   r   r   r|   r   r~   readr>   )r   r8   r0   rS   nameoutputs   &&    r   _read_streamProcess._read_stream   s     OO66r:	7[[F7N7[[F::!!!Qw8HDLL2D?{{}$::!!!Qw8HDLL3T@ %s   A$C7'5C7C5#C75C7Nc                  "   V P                   e   V P                  V4      pMV P                  4       pV P                  e   V P	                  ^4      pMV P                  4       pV P
                  e   V P	                  ^4      pMV P                  4       p\        P                  ! W#V4      G R j  xL
 w  r#pV P                  4       G R j  xL
  W43#  L" L	5irR   )	r   r   r   r   r   r   r   gatherro   )r   r   r   r   r   s   &&   r   communicateProcess.communicate   s     ::!$$U+EJJLE;;"&&q)FZZ\F;;"&&q)FZZ\F&+ll5&&I Iviik !Js$   B+C-C.CC	CC)r   ra   r   rc   r   r   r   rR   )r    rV   rW   rX   r   r%   propertyrk   ro   rr   rv   ry   r   r   r   r   rZ   r[   )r]   s   @r   r_   r_   v   sP     '9 0 0-,$("   r   r_   c           	         aa	"   \         P                  ! 4       o	VV	3R  lpS	P                  ! VV 3RVRVRV/VB G Rj  xL
 w  rx\        WxS	4      #  L5i)c                     < \        S SR 7      # r)   r	   r)   s   r   <lambda>)create_subprocess_shell.<locals>.<lambda>       7e=A Cr   r   r   r   N)r   get_running_loopsubprocess_shellr_   )
cmdr   r   r   r   kwdsprotocol_factoryr0   r*   r   s
   &&&&f,   @r   create_subprocess_shellr      ss     ""$DC $ 5 5!!!'! ! ! I 9--	s   :AAAr   r   r   r   c          	         aa
"   \         P                  ! 4       o
VV
3R  lpS
P                  ! VV .VO5RVRVRV/VB G Rj  xL
 w  r\        WS
4      #  L5i)c                     < \        S SR 7      # r   r   r)   s   r   r   (create_subprocess_exec.<locals>.<lambda>   r   r   r   r   r   N)r   r   subprocess_execr_   )programr   r   r   r   argsr   r   r0   r*   r   s   &$$$d*,   @r   r   r      s      ""$DC $ 4 4!! ! #! 	! 	! I
 9--s   =AAA)r   r   )__all__
subprocess r   r   r   r   logr   PIPESTDOUTDEVNULLFlowControlMixinSubprocessProtocolr	   r_   _DEFAULT_LIMITr   r   r   r   r   <module>r      s   
=       			


b&w77(;;b&JU  U p .2$t(/(>(>	..t .D .(,.4;4J4J.r   