+
    f4jY(                         ^ RI t ^ RIt^ RIt^ RIt^ RIt^ RIt^RIHt ^RIHt ^RI	H
t
  ! R R]P                  4      t ! R R]P                  4      t ! R	 R
]]P                  4      tR# )    N)	protocols)
transports)loggerc                   
  a a ] tR t^t oRV 3R lltR tR tR tR tR t	R t
]P                  3R ltR	 tR
 tR tR t]P&                  R8X  d   R tR tR tM	R tR tR tR tR tR tR tR tR tR tR tRtVt V ;t!# )BaseSubprocessTransportc                  < \         SV `  V
4       R V n        W n        Wn        RV n        RV n        RV n        . V n        \        P                  ! 4       V n        / V n        R V n        R V n        V\        P                   8X  d   RV P                  ^ &   V\        P                   8X  d   RV P                  ^&   V\        P                   8X  d   RV P                  ^&    V P"                  ! R
RVRVRVRVRVRV/VB  T P
                  P&                  T n        T P
                  T P(                  R&   T P                  P+                  4       '       dJ   \-        T\.        \0        34      '       d   TpM	T^ ,          p\2        P4                  ! R	YP                  4       T P                  P7                  T P9                  T	4      4       R#    T P%                  4        h ; i)FNargsshellstdinstdoutstderrbufsize
subprocesszprocess %r created: pid %s )super__init___closed	_protocol_loop_proc_pid_returncode_exit_waiterscollectionsdeque_pending_calls_pipes	_finished_pipes_connectedr   PIPE_startclosepid_extra	get_debug
isinstancebytesstrr   debugcreate_task_connect_pipes)selfloopprotocolr	   r
   r   r   r   r   waiterextrakwargsprogram	__class__s   &&&&&&&&&&&, )lib/python3.14/asyncio/base_subprocess.pyr    BaseSubprocessTransport.__init__   s    	!

	)//1 %JOO#!DKKNZ__$!DKKNZ__$!DKKN	KK BT B Be BF B%B/6B:@B JJNN	$(JJL!::!!$--q'LL5 ))- 	

t226:;	JJLs   G Gc                   V P                   P                  .pV P                  '       d   VP                  R 4       V P                  e   VP                  RV P                   24       V P
                  e    VP                  RV P
                   24       M1V P                  e   VP                  R4       MVP                  R4       V P                  P                  ^ 4      pVe   VP                  RVP                   24       V P                  P                  ^4      pV P                  P                  ^4      pVe%   WCJ d    VP                  RVP                   24       MDVe   VP                  RVP                   24       Ve   VP                  RVP                   24       R	P                  R
P                  V4      4      # )closedzpid=zreturncode=runningznot startedzstdin=zstdout=stderr=zstdout=zstderr=z<{}> )r3   __name__r   appendr   r   r   getpipeformatjoin)r,   infor   r   r   s   &    r4   __repr__ BaseSubprocessTransport.__repr__;   sX   ''(<<<KK!99 KK$tyyk*+'KK+d&6&6%789YY"KK	"KK&"KK&-.##&"2KK.67!gfkk]34!gfkk]34}}SXXd^,,    c                    \         hN)NotImplementedError)r,   r	   r
   r   r   r   r   r1   s   &&&&&&&,r4   r!   BaseSubprocessTransport._startX   s    !!rC   c                    Wn         R # rE   r   )r,   r.   s   &&r4   set_protocol$BaseSubprocessTransport.set_protocol[   s    !rC   c                    V P                   # rE   rI   r,   s   &r4   get_protocol$BaseSubprocessTransport.get_protocol^   s    ~~rC   c                    V P                   # rE   )r   rM   s   &r4   
is_closing"BaseSubprocessTransport.is_closinga   s    ||rC   c                z   V P                   '       d   R # RV n         V P                  P                  4        FY  pVf   K	  V P                  '       g   K  V P                  P	                  4       '       d   K?  VP
                  P                  4        K[  	  V P                  e   V P                  fs   V P                  P                  4       fU   V P                  P                  4       '       d   \        P                  ! RV 4        V P                  P                  4        R # R # R # R #   \        \        3 d     R # i ; i)NTz$Close running child process: kill %r)r   r   valuesr   	is_closedr=   r"   r   r   pollr%   r   warningkillProcessLookupErrorPermissionError)r,   protos   & r4   r"   BaseSubprocessTransport.closed   s    <<<[['')E}
 zzz$**"6"6"8"8

  " * JJ"  ( 

!)zz##%%EtL

! * ) # '8 s   D% %D:9D:c                t    V P                   '       g&   V! R V : 2\        V R7       V P                  4        R# R# )zunclosed transport )sourceN)r   ResourceWarningr"   )r,   _warns   &&r4   __del__BaseSubprocessTransport.__del__   s-    |||'x0/$OJJL rC   c                    V P                   # rE   )r   rM   s   &r4   get_pidBaseSubprocessTransport.get_pid   s    yyrC   c                    V P                   # rE   )r   rM   s   &r4   get_returncode&BaseSubprocessTransport.get_returncode   s    rC   c                `    WP                   9   d   V P                   V,          P                  # R # rE   )r   r=   )r,   fds   &&r4   get_pipe_transport*BaseSubprocessTransport.get_pipe_transport   s#    ;;r?'''rC   c                6    V P                   f   \        4       hR # rE   )r   rY   rM   s   &r4   _check_proc#BaseSubprocessTransport._check_proc   s    ::$&& rC   win32c                \    V P                  4        V P                  P                  V4       R # rE   )rn   r   send_signalr,   signals   &&r4   rr   #BaseSubprocessTransport.send_signal   s     JJ""6*rC   c                Z    V P                  4        V P                  P                  4        R # rE   )rn   r   	terminaterM   s   &r4   rw   !BaseSubprocessTransport.terminate   s    JJ  "rC   c                Z    V P                  4        V P                  P                  4        R # rE   )rn   r   rX   rM   s   &r4   rX   BaseSubprocessTransport.kill   s    JJOOrC   c                    V P                  4         \        P                  ! V P                  P                  V4       R #   \
         d     R # i ; irE   )rn   osrX   r   r#   rY   rs   s   &&r4   rr   ru      s;    

/% s   +? AAc                D    V P                  \        P                  4       R # rE   )rr   rt   SIGTERMrM   s   &r4   rw   rx          V^^,rC   c                D    V P                  \        P                  4       R # rE   )rr   rt   SIGKILLrM   s   &r4   rX   rz      r   rC   c                  a "    S P                   pS P                  pVP                  e:   VP                  V 3R lVP                  4      G R j  xL
 w  rEVS P                  ^ &   VP
                  e:   VP                  V 3R lVP
                  4      G R j  xL
 w  rEVS P                  ^&   VP                  e:   VP                  V 3R lVP                  4      G R j  xL
 w  rEVS P                  ^&   S P                  f   Q hVP                  S P                  P                  S 4       S P                   F  w  rgVP                  ! V.VO5!   K  	  R S n        Ve(   VP                  4       '       g   VP                  R 4       RS n        R #  EL> L L  \        \         3 d    h \"         dC   pTe4   TP                  4       '       g   TP%                  T4        R p?R #  R p?R #  R p?R # R p?ii ; i5i)Nc                     < \        S ^ 4      # )r   )WriteSubprocessPipeProtorM   s   r4   <lambda>8BaseSubprocessTransport._connect_pipes.<locals>.<lambda>   s    4T1=rC   c                     < \        S ^4      # )   ReadSubprocessPipeProtorM   s   r4   r   r          3D!<rC   c                     < \        S ^4      # )   r   rM   s   r4   r   r      r   rC   T)r   r   r   connect_write_piper   r   connect_read_piper   r   	call_soonr   connection_made	cancelled
set_resultr   
SystemExitKeyboardInterruptBaseExceptionset_exception)	r,   r/   procr-   _r=   callbackdataexcs	   f&       r4   r+   &BaseSubprocessTransport._connect_pipes   s    $	)::D::Dzz% $ 7 7=JJ!    "&A{{& $ 6 6<KK!! ! "&A{{& $ 6 6<KK!! ! "&A&&222NN4>>994@"&"5"5x/$/ #6"&D !&*:*:*<*<!!$'$(D!? !! -. 	 	*!&*:*:*<*<$$S)) +=!	*sz   G4A	F FAF FAF FA;F G42G4F F F G1.G1/G,	G,G4,G11G4c                    V P                   e   V P                   P                  W34       R # V P                  P                  ! V.VO5!   R # rE   )r   r;   r   r   )r,   cbr   s   &&*r4   _callBaseSubprocessTransport._call   s;    *&&z2JJ  +d+rC   c                r    V P                  V P                  P                  W4       V P                  4        R # rE   )r   r   pipe_connection_lost_try_finish)r,   rj   r   s   &&&r4   _pipe_connection_lost-BaseSubprocessTransport._pipe_connection_lost   s&    

4>>66@rC   c                R    V P                  V P                  P                  W4       R # rE   )r   r   pipe_data_received)r,   rj   r   s   &&&r4   _pipe_data_received+BaseSubprocessTransport._pipe_data_received   s    

4>>44b?rC   c                   Vf   Q V4       hV P                   e   Q V P                   4       hV P                  P                  4       '       d   \        P                  ! RW4       Wn         V P
                  P                  f   WP
                  n        V P                  V P                  P                  4       V P                  4        R # )Nz%r exited with return code %r)r   r   r%   r   r@   r   
returncoder   r   process_exitedr   )r,   r   s   &&r4   _process_exited'BaseSubprocessTransport._process_exited   s    %1z1%'9)9)99'::!!KK7J%::  ( %/JJ!

4>>001rC   c                   "   V P                   e   V P                   # V P                  P                  4       pV P                  P	                  V4       VG Rj  xL
 #  L5i)z\Wait until the process exit and return the process return code.

This method is a coroutine.N)r   r   create_futurer   r;   r,   r/   s   & r4   _waitBaseSubprocessTransport._wait   sO      '###))+!!&)||s   AAAAc                   V P                   '       d   Q hV P                  f   R # V P                  '       gG   V P                   F6  pVP	                  4       '       d   K  VP                  V P                  4       K8  	  \        ;QJ d4    R V P                  P                  4        4       F  '       d   K   RM)	  RM%! R V P                  P                  4        4       4      '       d&   RV n         V P                  V P                  R 4       R # R # )Nc              3   R   "   T F  pVR J;'       d    VP                   x  K  	  R # 5irE   )disconnected).0ps   & r4   	<genexpr>6BaseSubprocessTransport._try_finish.<locals>.<genexpr>  s*      .,1 }///,s   ''FT)r   r   r   r   doner   allr   rT   r   _call_connection_lostr   s   & r4   r   #BaseSubprocessTransport._try_finish  s    >>>!!#$$$ ,,{{}}%%d&6&67 - 3 .**,.333 .**,. . .!DNJJt1148.rC   c                    V P                   P                  V4       V P                   F6  pVP                  4       '       d   K  VP	                  V P
                  4       K8  	  R V n        R V n        R V n        R V n         R #   T P                   F6  pTP                  4       '       d   K  TP	                  T P
                  4       K8  	  R T n        R T n        R T n        R T n         i ; irE   )r   connection_lostr   r   r   r   r   r   )r,   r   r/   s   && r4   r   -BaseSubprocessTransport._call_connection_lost  s    
	"NN**3/ ,,{{}}%%d&6&67 - "&DDJDJ!DN ,,{{}}%%d&6&67 - "&DDJDJ!DNs   B #C%)<C%)r   r   r   r   r   r   r   r   r   r   r   )NN)"r:   
__module____qualname____firstlineno__r   rA   r!   rJ   rN   rQ   r"   warningswarnra   rd   rg   rk   rn   sysplatformrr   rw   rX   r+   r   r   r   r   r   r   r   __static_attributes____classdictcell____classcell__)r3   __classdict__s   @@r4   r   r      s     *<X-:""B %MM 
 ' ||w	+	#			-	-%)N,@	9$" "rC   r   c                   D   a  ] tR tRt o R tR tR tR tR tR t	Rt
V tR	# )
r   i!  c                :    Wn         W n        R V n        RV n        R # )NF)r   rj   r=   r   )r,   r   rj   s   &&&r4   r   !WriteSubprocessPipeProto.__init__#  s    		!rC   c                    Wn         R # rE   )r=   )r,   	transports   &&r4   r   (WriteSubprocessPipeProto.connection_made)  s    	rC   c                l    R V P                   P                   RV P                   RV P                  : R2# )<z fd=z pipe=>)r3   r:   rj   r=   rM   s   &r4   rA   !WriteSubprocessPipeProto.__repr__,  s0    4>>**+4ytyym1MMrC   c                n    R V n         V P                  P                  V P                  V4       RV n        R# )TN)r   r   r   rj   )r,   r   s   &&r4   r   (WriteSubprocessPipeProto.connection_lost/  s)     		''5	rC   c                N    V P                   P                  P                  4        R # rE   )r   r   pause_writingrM   s   &r4   r   &WriteSubprocessPipeProto.pause_writing4  s    		))+rC   c                N    V P                   P                  P                  4        R # rE   )r   r   resume_writingrM   s   &r4   r   'WriteSubprocessPipeProto.resume_writing7  s    		**,rC   )r   rj   r=   r   N)r:   r   r   r   r   r   rA   r   r   r   r   r   r   s   @r4   r   r   !  s)     "N
,- -rC   r   c                   &   a  ] tR tRt o R tRtV tR# )r   i;  c                R    V P                   P                  V P                  V4       R # rE   )r   r   rj   )r,   r   s   &&r4   data_received%ReadSubprocessPipeProto.data_received>  s    		%%dggt4rC   r   N)r:   r   r   r   r   r   r   r   s   @r4   r   r   ;  s     5 5rC   r   )r   r   r   r|   rt   r    r   r   logr   SubprocessTransportr   BaseProtocolr   Protocolr   r   rC   r4   <module>r      s]       	  
   Q"j<< Q"h-y55 -456'005rC   