. :D_ d Z ddlZddlZddlZddlZddlZddlZddl Z ddl
Z
ddl Z ddl Z ddl
mZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ dd lmZ dd
lmZ dd lmZ dd lmZ d
dlmZ d
dl m Z d
dl m Z d
dl m Z d
dl m!Z! e j" # d r e j$ dk reee%e&f Z'neee%e&ddf Z' G d d Z( G d de( Z)dS )zFakePopen class declaration N)partial)Any)Callable)Dict)IO)List)Optional)Sequence)Tuple)Union )
exceptions)BUFFER)
OPTIONAL_TEXT)OPTIONAL_TEXT_OR_ITERABLE)Threadwin zos.PathLike[str]zos.PathLike[bytes]c 6 e Zd ZU dZdZee ed< dZee ed< dZ ee
ed< dZ e ed< dZ
e
ed < d;d
eeeef ef dedede
d ee d ee d
eeeef dee dee deeef ddfdZedeeeef fd Zddee de
fd"Z$d#e
ddfd$Z%d?d%Z&d?d&Z'dee ddfd'Z(e)deeef deeef fd( Z* d>ded)ee dee+j, e+j- e.j/ f fd*Z0d+e defd,Z1d-e2eeef de2e fd.Z3d-edefd/Z4d-ed0e5ddfd1Z6deeef deeef fd2Z7d3eddfd4Z8d?d5Z9d?d6Z:d?d7Z;d ee ddfd8Z|D ];} t | t j r d| j j
d} t | <|| _ d | _
|| _ || _ d | _ || _ | | _ d | _ g | _ || _ || _ || _ || _ d S )Nr r zargument of type z is not iterable)
isinstancestrbytessysplatform
startswith version_infoosPathLike __class____name__ TypeErrorargs_FakePopen__kwargs_FakePopen__stdout_FakePopen__stderr_FakePopen__thread_FakePopen__signal_callback_FakePopen__stdin_callable _FakePopen__universal_newlines_signals _returncode
_wait_timeout _callback_callback_kwargs)
selfr r r r r r r! r" r# r$ argmsgs
n/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib/python3.11/site-packages/pytest_subprocess/fake_popen.py__init__zFakePopen.__init__. s " 7S%L11 ) ''.. ) 6))
)
) c2;// )Xcm.DXXXC#C..() 6:
39
39
*.
5D >L FJ!#%
*4.27?>M c | j S N)r4 r@ s rC kwargszFakePopen.kwargsU s
} rE c | S rG rH s rC __enter__zFakePopen.__enter__Y s rE r3 rI c H | j r| j j r| j j d S d S rG )r7 exception)r@ r3 rI s rC __exit__zFakePopen.__exit__\ s7 = *T] 4 *-) ) * * * *rE inputtimeoutc r | | | | t | j t j s t | j t j r t j | j r| j nd | j r| j nd fS rG )
_handle_stdin_finalize_threadr' r asyncio StreamReaderr r PluginInternalErrorgetvaluer@ rP rQ s rC communicatezFakePopen.communicate` s
5!!! g&&& dk7#7 8 8 1J K-=
=
1 0 0 '+k ;DK " " "t&*k ;DK " " "t
rE c |ru| j rp| | }t |t rH| |d| j | _ | |d| j | _ d S d S d S d S )Nr r )r9 r' dict_extend_stream_from_dictr r )r@ rP callable_outputs rC rS zFakePopen._handle_stdinp s T* " 3 3E : :O/400
" ; ;#Xt{ # ; ;#Xt{
rE c | j d S | j | | j | j | j | _ | j j r | j j d S rG )r7 joinr r< rN r@ rQ s rC rT zFakePopen._finalize_thread{ sa = F
7### ? "t'7'C " .DO = " *-) ) * *rE
dictionarykeystreamc b | | }|r| || S d S )N)rP io_base)get_prepare_buffer)r@ rb rc rd datas rC r] z"FakePopen._extend_stream_from_dict s< ~~c"" D''dF'CC CtrE c | j S rG )r rH s rC pollzFakePopen.poll s
rE c |r<| j r5| xj |z c_ || j k rt j | j | | | | j t j | j S rG )r=
subprocessTimeoutExpiredr3 rT r r rW ra s rC r zFakePopen.wait sz Dt) D ' ) +++ / 7CCC g&&& ? " 0 0 rE sigc x | j | | j r| | | d S d S rG )r; appendr8 )r@ ro s rC send_signalzFakePopen.send_signal sI
S!!! ! . " "4 - - - - - . .rE c D | t j d S rG )rr signalSIGTERMrH s rC terminatezFakePopen.terminate s (((((rE c t j dk r| d S | t j d S )Nwin32)r* r+ rv rr rt SIGKILLrH s rC killzFakePopen.kill sA <7 " " NN V^ , , , , ,rE c | | | _ | dd | _ | dd }| dd }| dd }|r t j dk rt
d t |p
| j p|p| | _ |@| j 9t | j t | k rt j
d | d }|t j k r | | j
| _ nAt |t j t j f r| | j
| | d
}|t j k r7| j r0| j J | | j | j | _ dS |t j k r!| | j | _ dS t |t j t j f r | | j | dS dS ) z=Setup the FakePopen instance based on a real Popen arguments.universal_newlinesNtextencodingerrors)r z4__init__() got an unexpected keyword argument 'text'zlCannot disambiguate when both text and universal_newlines are supplied but different. Pass one or the other.r r ) safe_copyr4 rg r: r* r- r2 boolr rm SubprocessErrorPIPErh r5 r r' ioBufferedWriter
TextIOWrapper_write_to_bufferSTDOUTr6 r )r@ rI r} r~ r r r s rC configurezFakePopen.configure s v..
$*JJ/CT$J$J!zz&$''::j$//Hd++ TC$v-- RSS S d Ud&? U8 UvVV
)5T.//4::== ,4
H%% Z_ $ $ ..t}==DKK
!2B4D E
F
F 9 ! !$- 8 8 8H%% Z& & &4= &;*** ..t}dkJJDKKK
z
&
& ..t}==DKKK
!2B4D E
F
F 9 ! !$- 8 8 8 8 8 9 9rE c d t j | S # t $ r t di | cY S w xY w)z_
Deepcopy can fail if the value is not serializable, fallback to shallow copy.
NrK )copydeepcopyr2 r\ )rI s rC r zFakePopen.safe_copy sH
"=(( ( " " ">>&>> ! ! ! "s //rf c | t j }t |t t
f r/| t | j | }|r||z
}t |t r| j s|
}t |t r| j r| }|r2| j
r+t |t r| dd }|rIt |t j s/| dk r| |z }|| | j }||S t |t j r)| | | n| | |S )Nz
r )_convertr. linesepr' listtupler` mapr( r encoder) decoder: replacerU rV tellrX _get_empty_buffer feed_data_data_to_byteswrite)r@ rP rf r s rC rh zFakePopen._prepare_buffer s
--
++ edE] + + ! LLT]E!:!:;;E
! eS ! ! #$. #LLNNE eU # # # #LLNNE 0T. 0:eS3I3I 0MM&$//E
1 w(<== 1 !## $$&&%0E ?,,T^<z'FakePopen._to_bytes..
s3 TTTt
4//BT[[]]TTTrE rK r@ ri s rC _to_byteszFakePopen._to_bytes s TTtTTTTrE c t |t j j r4t |t s d d |D S t |t r| S |sdS |S )N
c 3 l K | ]/}t |t r|n| V 0d S rG r )r items rC z+FakePopen._data_to_bytes.. s= UUD%00CdkkmmUUUUUUrE rE )r' collectionsabcr
r) r` r( r r s rC r zFakePopen._data_to_bytes s dKO 4 5 5 ju>U>U ::UUPTUUU
dC !;;== 3 rE bufferc 0 d|j v r't t t j nt
t
|t t f r#| fd|D d S |
| d S )Nb)r~ c , g | ]} |d z S )r rK )r line data_types rC r z.FakePopen._write_to_buffer.." s' G G G$yy 5 5 G G GrE ) moder r) r* getfilesystemencodingr( r' r r
writelinesr )r@ ri r r s @rC r zFakePopen._write_to_buffer s fk!!
EC$=$?$? @ @ @ @ dT5M * * * G G G G$ G G G H H H H H LL4 ) ) ) ) )rE c t |t r| j r| S t |t r| j s| S |S rG )r' r) r r r( r )r@ rP s rC r zFakePopen._convert& sY eU # # " "<<>> ! eS ! ! "$. "<<>> ! rE wait_periodc h t j | | j | d S d S rG )timesleepr _finish_process)r@ r s rC _waitzFakePopen._wait- s:
; ? " " " " " " # "rE c | j | j | dS | j r%t | j | f| j pi | _ n!t | j | j f | _ | j dS )z2Run the user-defined callback or wait in a thread.N)targetr3 rI )r r3 )r= r> r r r? r7 r startrH s rC
run_threadzFakePopen.run_thread2 s %$.*@ " " " " "~
V & > 06B! ! !
!'dj@R?T U U U
M ! ! ! ! !rE c F | j | _ | d S rG )r< r _finalize_streamsrH s rC r zFakePopen._finish_processA s$ * rE c n | | j | | j d S rG )_finalize_streamr r rH s rC r zFakePopen._finalize_streamsF s4 dk*** dk*****rE c t |t j r| d S |r| d d S d S )Nr )r' rU rV feed_eofseek)r@ rd s rC r zFakePopen._finalize_streamJ sR fg 2 3 3 OO
KKNNNNN rE .c * t | j S )z/Get a tuple of signals received by the process.)r r; rH s rC received_signalszFakePopen.received_signalsP s T]###rE )NNr NNNNN)r% r NNrG r% N)>r1
__module__ __qualname____doc__r r r __annotations__r r intr r r r r) r( COMMAND_SEQr floatr r AnyTyperD propertyrI rL r rO r r rZ rS rT r] rk r rr rv rz r staticmethodr r r r rU rV rh r r
r r r r r r r r r r r rK rE rC r r % s ;; #FHV ### #FHV ### $J
$$$ItCLLL -1,0 $'+8<.2-1%N %N %*
%N *
%N *%N %N uo%N 8$%N "$sG|"45%N "(+%N !*%N #w,
%N
%N %N %N %NN c7l!34 X *d *d *t * * * *
GK
"
4
*
*t
*
*
*
*eCJ / E#u*4E # #4 # # # #
"
"
"
" ! ! ! !
+ + + +x'7 D $%S/ $ $ $ $ $ $rE r c : e Zd ZU dZeej ed< eej ed< ddedee de
e e f fdZ ddee de
fd Zd
edej fd Zdd Zd
eej deej fdZddZddZddZddee ddfdZdS )AsyncFakePopenz Class to handle async processesr r NrP rQ r% c f K |rC| d {V | | | | | d {V | j r | j d {V nd | j r | j d {V nd fS rG )_reopen_streamsrS r _finalizer readr rY s rC rZ zAsyncFakePopen.communicate[ s %&&(( ( ( ( ( ( ( ( u % % %
" " $ $ $nnW%%%%%%%%%(, =$+""$$ $ $ $ $ $ $ $(, =$+""$$ $ $ $ $ $ $ $
rE c K |r<| j r5|| j k r*| xj |z c_ t j | j | | | d {V | j t j | j S rG )r= rm rn r3 r r r rW ra s rC r zAsyncFakePopen.waitl s @t) @g8J.J.J ' ) +DIw?? ?nnW%%%%%%%%% ? " 0 0 rE r$ c ( t j S rG )rU rV )r@ r$ s rC r z AsyncFakePopen._get_empty_bufferu s #%%%rE c K | | j d {V | _ | | j d {V | _ d S rG )_reopen_streamr r rH s rC r z AsyncFakePopen._reopen_streamsx s\ / / < <<<<<<< / / < <<<<<<< rE rd c K |rF| d {V }| d }| | |S d S )NF)r r r )r@ rd ri fresh_streams rC r z AsyncFakePopen._reopen_stream| sa &&&&&&D 11%88L " "4 ( ( ( trE c dS )z=Async impl should not contain any thread based implementationNrK rH s rC r zAsyncFakePopen.run_thread s rE c R | j | j | dS dS dS )z&Check if process needs to be finished.N)r= r> r rH s rC evaluatezAsyncFakePopen.evaluate s8 %$.*@ " " " " " & %*@*@rE c z K t j }t j 5 }| j r9| j pi }t | j fi |}| ||| d{V n.| j '| || j
| j d{V ddd dS # 1 swxY w Y dS )z2Run in executor the user-defined callback or wait.N) rU get_running_loop
concurrentfuturesThreadPoolExecutorr> r? r run_in_executorr= r )r@ looppoolrI cbks rC _run_callback_in_executorz(AsyncFakePopen._run_callback_in_executor s1 '))
2
2
4
4 Q~
Q .4" dn7777**4d;;;;;;;;;;#/**4T=OPPPPPPPPP
Q Q Q Q Q Q Q Q Q Q Q Q Q Q Q Q Q Qs A/B00B47B4c K | j dS |/t j | | d{V n| d{V | j | j | _ | dS )z5Run the user-defined callback or wait. Finish processN)rQ )r rU wait_forr r< r ra s rC r zAsyncFakePopen._finalize s ? & F "4#A#A#C#CWUUU U U U U U U U U0022 2 2 2 2 2 2 2 ? " " .DO rE r rG r )r1 r r r r rU rV r r r r r rZ r r r r r r r r r r rK rE rC r r U s )) W) **** W) **** GK
"
4r sB ! !
! ! ! ! ! ! , , , , , , <5!! Xc&6&?&?5e,-KK5e-?AU!UVWKm$ m$ m$ m$ m$ m$ m$ m$` N! N! N! N! N!Y N! N! N! N! N!rE