/usr/lib/python3.10/asyncio/__pycache__
Edit: /usr/lib/python3.10/asyncio/__pycache__/base_subprocess.cpython-310.pyc (9386B)
o
9j" @ sx d dl Z d dlZd dlZddlmZ ddlmZ ddlmZ G dd dejZ G dd d ej
Z G d
d d e ej Z
dS ) N ) protocols)
transports)loggerc s e Zd Z d0 fdd Zdd Zdd Zdd Zd
d Zd d
Zdd Z e
j fddZ 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 )1BaseSubprocessTransportNc
s t |
d| _|| _|| _d | _d | _d | _g | _t
| _ i | _ d| _
|tjkr0d | j d< |tjkr:d | j d< |tjkrDd | j d< z| jd||||||d| W n | | jj| _| j| jd< | j rt|ttfrx|} n|d } td| | j | j| | d S ) NFr r )argsshellstdinstdoutstderrbufsize
subprocesszprocess %r created: pid %s ) super__init___closed _protocol_loop_proc_pid _returncode
_exit_waiters collectionsdeque_pending_calls_pipes _finishedr PIPE_startclosepid_extra get_debug
isinstancebytesstrr debug create_task_connect_pipes)
selfloopprotocolr r r
r r r
waiterextrakwargsprogram __class__r ./usr/lib/python3.10/asyncio/base_subprocess.pyr sH
z BaseSubprocessTransport.__init__c C s | j jg}| jr
|d | jd ur|d| j | jd ur*|d| j n| jd ur5|d n|d | jd}|d urM|d|j | jd}| jd }|d urk||u rk|d
|j n|d urx|d |j |d ur|d |j d
d
|S )Nclosedzpid=z returncode=runningz not startedr zstdin=r r zstdout=stderr=zstdout=zstderr=z<{}> ) r2 __name__r appendr r r getpipeformatjoin)r* infor
r r r r r3 __repr__7 s,
z BaseSubprocessTransport.__repr__c K s t N)NotImplementedError)r* r r r
r r r
r/ r r r3 r T s z BaseSubprocessTransport._startc C
|| _ d S r? r )r* r, r r r3 set_protocolW
z$BaseSubprocessTransport.set_protocolc C | j S r? rB r* r r r3 get_protocolZ z$BaseSubprocessTransport.get_protocolc C rE r? )r rF r r r3
is_closing] rH z"BaseSubprocessTransport.is_closingc C s | j rd S d| _ | j D ] }|d u rq
|j q
| jd urI| jd u rK| j d u rM| j r6t
d| z| j W d S t
yH Y d S w d S d S d S )NTz$Close running child process: kill %r)r r valuesr: r r r pollr r# r warningkillProcessLookupError)r* protor r r3 r ` s(
z BaseSubprocessTransport.closec C s* | j s|d| t| d | d S d S )Nzunclosed transport )source)r ResourceWarningr )r* _warnr r r3 __del__{ s z BaseSubprocessTransport.__del__c C rE r? )r rF r r r3 get_pid rH z BaseSubprocessTransport.get_pidc C rE r? )r rF r r r3 get_returncode rH z&BaseSubprocessTransport.get_returncodec C s || j v r | j | jS d S r? )r r: )r* fdr r r3 get_pipe_transport s
z*BaseSubprocessTransport.get_pipe_transportc C s | j d u rt d S r? )r rN rF r r r3 _check_proc s
z#BaseSubprocessTransport._check_procc C s | | j| d S r? )rX r send_signal)r* signalr r r3 rY s z#BaseSubprocessTransport.send_signalc C | | j d S r? )rX r terminaterF r r r3 r\ z!BaseSubprocessTransport.terminatec C r[ r? )rX r rM rF r r r3 rM r] z BaseSubprocessTransport.killc
s zy j } j}|jd ur"| fdd|jI d H \}}| jd< |jd ur<| fdd|jI d H \}}| jd< |jd urV| fdd|jI d H \}}| jd< jd us]J | j
j jD ]
\}}|j |g|R qhd _W n7 t t
fy ty } z"|d ur| s|| W Y d }~d S W Y d }~d S W Y d }~d S d }~ww |d ur| s|d d S d S d S )Nc
t dS )Nr )WriteSubprocessPipeProtor rF r r3
z8BaseSubprocessTransport._connect_pipes..r c r^ )Nr ReadSubprocessPipeProtor rF r r3 r` ra r c r^ )Nr rb r rF r r3 r` ra r )r r r
connect_write_piper r connect_read_piper r call_soonr connection_made
SystemExitKeyboardInterrupt
BaseException cancelled
set_exception
set_result) r* r- procr+ _r: callbackdataexcr rF r3 r) sL
z&BaseSubprocessTransport._connect_pipesc G s6 | j d ur| j ||f d S | jj|g|R d S r? )r r8 r rf )r* cbrq r r r3 _call s
z BaseSubprocessTransport._callc C s | | jj|| | d S r? )rt r pipe_connection_lost _try_finish)r* rV rr r r r3 _pipe_connection_lost s z-BaseSubprocessTransport._pipe_connection_lostc C s | | jj|| d S r? )rt r pipe_data_received)r* rV rq r r r3 _pipe_data_received s z+BaseSubprocessTransport._pipe_data_receivedc C s |d usJ || j d u sJ | j | j r td| | || _ | jjd u r+|| j_| | jj |
| j D ] }| sD|
| q9d | _ d S )Nz %r exited with return code %r)r r r# r r= r
returncodert r process_exitedrv r rk rm )r* rz r- r r r3 _process_exited s
z'BaseSubprocessTransport._process_exitedc s2 | j dur | j S | j }| j| |I dH S )zdWait until the process exit and return the process return code.
This method is a coroutine.N)r r
create_futurer r8 )r* r- r r r3 _wait s
z BaseSubprocessTransport._waitc C sL | j rJ | jd u r d S tdd | j D r$d| _ | | jd d S d S )Nc s s | ]
}|d uo
|j V qd S r? ) disconnected).0pr r r3 s z6BaseSubprocessTransport._try_finish..T)r r allr rJ rt _call_connection_lostrF r r r3 rv s
z#BaseSubprocessTransport._try_finishc C s: z| j | W d | _d | _d | _ d S d | _d | _d | _ w r? )r connection_lostr r r* rr r r r3 r s
z-BaseSubprocessTransport._call_connection_lost)NN) r7
__module__ __qualname__r r> r rC rG rI r warningswarnrS rT rU rW rX rY r\ rM r) rt rw ry r| r~ rv r
__classcell__r r r1 r3 r
s2 + & r c @ s< e Zd Zdd Zdd Zdd Zdd Zd d
Zd d Zd
S )r_ c C s || _ || _d | _d| _d S )NF)rn rV r: r )r* rn rV r r r3 r s
z!WriteSubprocessPipeProto.__init__c C rA r? )r: )r* transportr r r3 rg rD z(WriteSubprocessPipeProto.connection_madec C s d| j j d| j d| jdS )N)r2 r7 rV r: rF r r r3 r>
s z!WriteSubprocessPipeProto.__repr__c C s d| _ | j| j| d | _d S )NT)r rn rw rV r r r r3 r
s
z(WriteSubprocessPipeProto.connection_lostc C | j j d S r? )rn r
pause_writingrF r r r3 r z&WriteSubprocessPipeProto.pause_writingc C r r? )rn r resume_writingrF r r r3 r r z'WriteSubprocessPipeProto.resume_writingN) r7 r r r rg r> r r r r r r r3 r_ s r_ c @ s e Zd Zdd ZdS )rc c C s | j | j| d S r? )rn ry rV )r* rq r r r3
data_received s z%ReadSubprocessPipeProto.data_receivedN)r7 r r r r r r r3 rc s rc )r r r r r logr SubprocessTransportr BaseProtocolr_ Protocolrc r r r r3 s v