a
´i‹" ã @ sx d dl Z d dlZd dlZddlmZ ddlmZ ddlmZ G dd„ dejƒZ G dd „ d ej
ƒZ G d
d „ d e ej ƒZ
dS ) é Né )Ú protocols)Ú
transports)Úloggerc sÔ e Zd Zd0‡ fdd„ Zdd„ Zdd„ Zdd „ Zd
d „ Zd d
„ Zdd„ Z e
j fdd„Z dd„ Z
dd„ Zdd„ Zdd„ Zdd„ Zd d „ Zd d „ Zd d!„ Zd"d#„ Zd$d%„ Zd&d'„ Zd(d)„ Zd*d+„ Zd,d-„ Zd.d/„ Z‡ Z S )1ÚBaseSubprocessTransportNc
s& t ƒ |
¡ d| _|| _|| _d | _d | _d | _g | _t
¡ | _ i | _ d| _
|tjkr`d | j d< |tjkrtd | j d< |tjkrˆd | j d< z"| jf ||||||dœ| ¤Ž W n | ¡ ‚ Y n0 | jj| _| j| jd< | j ¡ rt|ttfƒrø|} n|d } t d| | j¡ | j | | ¡¡ d S )NFr r é )ÚargsÚshellÚstdinÚstdoutÚstderrÚbufsizeÚ
subprocesszprocess %r created: pid %s) ÚsuperÚ__init__Ú_closedÚ _protocolÚ_loopÚ_procÚ_pidÚ _returncodeÚ
_exit_waitersÚ collectionsÚdequeÚ_pending_callsÚ_pipesÚ _finishedr ÚPIPEÚ_startÚcloseÚpidZ_extraÚ get_debugÚ
isinstanceÚbytesÚstrr ÚdebugZ create_taskÚ_connect_pipes)
ÚselfÚloopÚprotocolr r r
r r r
ÚwaiterÚextraÚkwargsZprogram©Ú __class__© ú//usr/lib64/python3.9/asyncio/base_subprocess.pyr sH
ÿÿ
ÿz BaseSubprocessTransport.__init__c C s | j jg}| jr| d¡ | jd ur6| d| j› ¡ | jd urT| d| j› ¡ n | jd urj| d¡ n
| d¡ | j d¡}|d urš| d|j› ¡ | j d¡}| j d ¡}|d urÖ||u rÖ| d
|j› ¡ n6|d urð| d |j› ¡ |d ur | d |j› ¡ d
d
|¡¡S )NÚclosedzpid=z returncode=Úrunningz not startedr zstdin=r r zstdout=stderr=zstdout=zstderr=z<{}>ú ) r. Ú__name__r Úappendr r r ÚgetÚpipeÚformatÚjoin)r' Úinfor
r r r/ r/ r0 Ú__repr__7 s,
z BaseSubprocessTransport.__repr__c K s t ‚d S ©N)ÚNotImplementedError)r' r r r
r r r
r, r/ r/ r0 r T s z BaseSubprocessTransport._startc C s
|| _ d S r< ©r )r' r) r/ r/ r0 Ú set_protocolW s z$BaseSubprocessTransport.set_protocolc C s | j S r< r> ©r' r/ r/ r0 Ú get_protocolZ s z$BaseSubprocessTransport.get_protocolc C s | j S r< )r r@ r/ r/ r0 Ú
is_closing] s z"BaseSubprocessTransport.is_closingc C s’ | j r
d S d| _ | j ¡ D ]}|d u r(q|j ¡ q| jd urŽ| jd u rŽ| j ¡ d u rŽ| j ¡ rlt
d| ¡ z| j ¡ W n t
yŒ Y n0 d S )NTz$Close running child process: kill %r)r r Úvaluesr7 r r r Úpollr r! r ÚwarningÚkillÚProcessLookupError)r' Úprotor/ r/ r0 r ` s$
þ û
z BaseSubprocessTransport.closec C s& | j s"|d| ›t| d | ¡ d S )Nzunclosed transport )Úsource)r ÚResourceWarningr )r' Ú_warnr/ r/ r0 Ú__del__{ s z BaseSubprocessTransport.__del__c C s | j S r< )r r@ r/ r/ r0 Úget_pid€ s z BaseSubprocessTransport.get_pidc C s | j S r< )r r@ r/ r/ r0 Úget_returncodeƒ s z&BaseSubprocessTransport.get_returncodec C s || j v r| j | jS d S d S r< )r r7 )r' Úfdr/ r/ r0 Úget_pipe_transport† s
z*BaseSubprocessTransport.get_pipe_transportc C s | j d u rtƒ ‚d S r< )r rG r@ r/ r/ r0 Ú _check_procŒ s
z#BaseSubprocessTransport._check_procc C s | ¡ | j |¡ d S r< )rQ r Ú send_signal)r' Úsignalr/ r/ r0 rR s z#BaseSubprocessTransport.send_signalc C s | ¡ | j ¡ d S r< )rQ r Ú terminater@ r/ r/ r0 rT ” s z!BaseSubprocessTransport.terminatec C s | ¡ | j ¡ d S r< )rQ r rF r@ r/ r/ r0 rF ˜ s z BaseSubprocessTransport.killc
ƒ sr zòˆ j }ˆ j}|jd urB| ‡ fdd„|j¡I d H \}}|ˆ jd< |jd urv| ‡ fdd„|j¡I d H \}}|ˆ jd< |jd urª| ‡ fdd„|j¡I d H \}}|ˆ jd< ˆ jd us¸J ‚| ˆ j
j ˆ ¡ ˆ jD ]\}}|j |g|¢R Ž qÎd ˆ _W n\ t t
fy ‚ Y nb tyN } z*|d ur:| ¡ s:| |¡ W Y d }~n(d }~0 0 |d urn| ¡ sn| d ¡ d S )Nc s
t ˆ dƒS )Nr )ÚWriteSubprocessPipeProtor/ r@ r/ r0 Ú