python (3.11.7)
eG | d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl
Z
ddl Z ddl Z ddl
mZ ddlmZ ddlmZ dZej d Z e j eed d G d
d e j Z e j eed d G d d
e Z e j eed d G d de Z e j eed d G d de Z e j eed d e j eed d G d de Z e j eed d G d de Z G d de Z e dk r e j dS dS )a
This test suite exercises some system calls subject to interruption with EINTR,
to check that it is actually handled transparently.
It is intended to be run by the main test suite within a child process, to
ensure there is no background thread running (so that signals are delivered to
the correct thread).
Signals are generated in-process using setitimer(ITIMER_REAL), which allows
sub-second periodicity (contrarily to signal()).
N)support) os_helper)
socket_helperg{Gz?c # K | 5 | V n# | xY w ddd dS # 1 swxY w Y dS )zGContext manager killing the subprocess if a Python exception is raised.N)kill)procs D/BuggyBox/python/3.11.7/bootstrap/lib/python3.11/test/_test_eintr.py
kill_on_errorr
" s
JJJJ IIKKK
s 4 4#488 setitimerzrequires setitimer()c R e Zd ZdZdZdZdZd Zd Ze d Z
d Z d Z d Z
d
S )
EINTRBaseTestz Base class for EINTR tests. g?g?c & | xj dz
c_ d S N )signals)selfsignumframes r
sighandlerzEINTRBaseTest.sighandler9 s c d| _ t j t j | j | _ t j t j | j | j t j
ddt j d S )Nr iX T)exitfile)
r signalSIGALRMr orig_handlerr ITIMER_REAL signal_delay
signal_period faulthandlerdump_traceback_latersys
__stderr__r s r setUpzEINTRBaseTest.setUp< su "M&.$/ J J+T-> + - - -
)'/2~ ? ? ? ? ? ?r c F t j t j dd d S Nr )r r r r r
stop_alarmzEINTRBaseTest.stop_alarmG s +Q22222r c | t j t j | j t j d S N)r) r r r r cancel_dump_traceback_laterr$ s r tearDownzEINTRBaseTest.tearDownK s>
fnd&7888022222r c H t j df|z }t j |fi |S )Nz-c)r"
executable
subprocessPopen)r argskwcmd_argss r r0 zEINTRBaseTest.subprocessP s, ND)D0 //B///r c L | || j t z
d S r+ )assertGreaterEqual
sleep_time CLOCK_RES)r elapseds r check_elapsed_timez EINTRBaseTest.check_elapsed_timeT s% 9)DEEEEEr N)__name__
__module__ __qualname____doc__r r r7 r r% staticmethodr) r- r0 r: r( r r r
r
- s '' LM J ? ? ? 3 3 \33 3 3
0 0 0F F F F Fr r
c e Zd ZdZd Zd Zd Z ej e e
d d d Z d Z d Z
ej e e
d
d d Zd
Zd ZdS ) OSEINTRTestz EINTR tests for the os module. c @ d| j z }| | S )Nzimport time; time.sleep(%r))r7 r0 )r codes r new_sleep_processz OSEINTRTest.new_sleep_process\ s ,t>t$$$r c d} fdt | D }t | D ] } |
|D ]}| d S )N c 8 g | ]} S r( )rD ).0_r s r
<listcomp>z3OSEINTRTest._test_wait_multiple.<locals>.<listcomp>b s% BBB!T++--BBBr )rangewait)r wait_funcnum processesrI r s ` r _test_wait_multiplez OSEINTRTest._test_wait_multiple` sq BBBBuSzzBBB s A IKKKK D IIKKKK r c D | t j d S r+ )rP osrL r$ s r test_waitzOSEINTRTest.test_waiti s )))))r wait3zrequires wait3()c 2 | d d S )Nc * t j d S r' )rR rT r( r r <lambda>z(OSEINTRTest.test_wait3.<locals>.<lambda>n s ! r )rP r$ s r
test_wait3zOSEINTRTest.test_wait3l s !4!455555r c v | } ||j | d S r+ )rD pidrL )r rM r s r _test_wait_singlez OSEINTRTest._test_wait_singlep s6 %%'' $( r c 2 | d d S )Nc , t j | d S r' )rR waitpidrZ s r rW z*OSEINTRTest.test_waitpid.<locals>.<lambda>w s 2:c1+=+= r r[ r$ s r test_waitpidzOSEINTRTest.test_waitpidv s = =>>>>>r wait4zrequires wait4()c 2 | d d S )Nc , t j | d S r' )rR rb r_ s r rW z(OSEINTRTest.test_wait4.<locals>.<lambda>{ s 28C+;+; r r` r$ s r
test_wait4zOSEINTRTest.test_wait4y s ; ;<<<<<r c X t j \ }}| t j | g d}d dddd|z d| j z ddd d
d f
}| |t | |g }t | 5 t j | |D ]8}| |t j
|t | 9| | d
d d d d S # 1 swxY w Y d S )N)s hellos worlds spam
zimport os, sys, time zwr = int(sys.argv[1])
datas = %rsleep_time = %rzfor data in datas:z$ # let the parent block on read() time.sleep(sleep_time)z os.write(wr, data)pass_fdsr )
rR pipe
addCleanupclosejoinr7 r0 strr
assertEqualreadlenrL )r rdwrdatasrC r datas r test_readzOSEINTRTest.test_read} sn B "%%%
.--yy " # 5 / 2 ( $
tSWWt<<
4
- - HRLLL
?
? rwr3t99'='=>>>> TYY[[! , , , - - - - - - - - - - - - - - - - - -s A8D D#&D#c t j \ }}| t j | dt j z }d dddd| j z dt j z ddd d
dd d d
ddddddf }| |t | |g }t | 5 t j | d}|t | k r@|t j |t | |d z
}|t | k @| | d d d d d S # 1 swxY w Y d S )N xrg zimport io, os, sys, timerh zrd = int(sys.argv[1])rj zdata = b"x" * %sdata_len = len(data)z!# let the parent block on write()time.sleep(sleep_time)zread_data = io.BytesIO()z+while len(read_data.getvalue()) < data_len:z% chunk = os.read(rd, 2 * data_len)z read_data.write(chunk)z value = read_data.getvalue()zif value != data:z0 raise Exception("read error: %s vs %s bytes"z- % (len(value), data_len))rl r )rR rn ro rp r
PIPE_MAX_SIZErq r7 r0 rr r
ru write
memoryviewrs rL )r rv rw ry rC r writtens r
test_writezOSEINTRTest.test_write s B "%%% g++yy & # / !6 6 " / $ & 9 3 ( * > ;'
, tSWWt<<
4
- - HRLLLGCII%%28B
4(8(8(BCCC CII%% TYY[[! , , , - - - - - - - - - - - - - - - - - -s 8BEE EN)r; r< r= r> rD rP rS unittest
skipUnlesshasattrrR rX r[ ra re rz r r( r r rA rA X s **% % % * * * XW--/ABB6 6 CB6 ? ? ? XW--/ABB= = CB=- - -:$- $- $- $- $-r rA c * e Zd ZdZ ej eed d d Zd Z ej eej d d d Z
d Z d
Z d Z
ej eej d d
d Zd Z ej dd ej eed d d Zd Z ej ej dk d d Zd Z ej ej dk d d ZdS ) SocketEINTRTestz$ EINTR tests for the socket module.
socketpairzneeds socketpair()c t j \ }}| |j g d}d ddddt |j z dt |j z d|z d | j z dd
d dd d
dddf }| }|
|t | |g }t | 5 | |D ]/}|
| ||t | 0|
| d d d d d S # 1 swxY w Y d S )N)r| y zrg import os, socket, sys, timerh fd = int(sys.argv[1]) family = %ssock_type = %sri rj z)wr = socket.fromfd(fd, family, sock_type) os.close(fd)zwith wr:z for data in datas:z( # let the parent block on recv()z time.sleep(sleep_time)z wr.sendall(data)rl r )socketr ro rp rq intfamilytyper7 filenor0 rr r
rs ru rL ) r recv_funcrv rw rx rC fdr ry s r
_test_recvzSocketEINTRTest._test_recv s "$$B !!! #""yy * # C NN * s27|| + 5 / 7 $ 6 , &!
& YY[[tSWWt<<
4
- - HHJJJ
A
A yySYY'?'?@@@@ TYY[[! , , , - - - - - - - - - - - - - - - - - -s A/EEEc N | t j j d S r+ )r r recvr$ s r test_recvzSocketEINTRTest.test_recv
*+++++r recvmsgzneeds recvmsg()c 2 | d d S )Nc 8 | | d S r' )r sockry s r rW z.SocketEINTRTest.test_recvmsg.<locals>.<lambda> s 4<<+=+=a+@ r )r r$ s r test_recvmsgz SocketEINTRTest.test_recvmsg s @@AAAAAr c b t j \ }}| |j dt j dz z }d ddddt |j z dt |j z d | j
z d
t j dz z d dd d
dddddddddddddf }| }| |t | |g }t | 5 | d}|t | k rJ ||t! | |d } || t | n| z
}|t | k J| | d d d d d S # 1 swxY w Y d S )Ns xyzrF rg r rh r r r rj zdata = b"xyz" * %sr} z)rd = socket.fromfd(fd, family, sock_type)r zwith rd:z$ # let the parent block on send()rk z' received_data = bytearray(data_len)z n = 0z while n < data_len:z8 n += rd.recv_into(memoryview(received_data)[n:])zif received_data != data:z0 raise Exception("recv error: %s vs %s bytes"z5 % (len(received_data), data_len))rl r )r r ro rp r
SOCK_MAX_SIZErq r r r r7 r r0 rr r
ru r rs rL )
r send_funcrv rw ry rC r r r sents
r
_test_sendzSocketEINTRTest._test_send s "$$B !!! .!34yy * # C NN * s27|| + / G$9Q$> ? " 7 2 ( 5 % F ' > C1
6 YY[[tSWWt<<
4
- - HHJJJGCII%% yZ%5%5ghh%?@@ 3t999$> CII%%
TYY[[! , , , - - - - - - - - - - - - - - - - - -s ;B F$$F(+F(c N | t j j d S r+ )r r sendr$ s r test_sendzSocketEINTRTest.test_send r r c N | t j j d S r+ )r r sendallr$ s r test_sendallz SocketEINTRTest.test_sendall! s
-.....r sendmsgzneeds sendmsg()c 2 | d d S )Nc . | |g S r+ )r r s r rW z.SocketEINTRTest.test_sendmsg.<locals>.<lambda>& s 4<<+?+? r )r r$ s r test_sendmsgz SocketEINTRTest.test_sendmsg$ s ??@@@@@r c < t j t j df }| |j | d }d dddt j z d|z d| j z dd d
d d f
}| | }t | 5 | \ }}| | |
d d d d d S # 1 swxY w Y d S )
Nr r rg zimport socket, timerh z host = %rz port = %srj z # let parent block on accept()r~ z,with socket.create_connection((host, port)):rk )r
create_serverr HOSTro rp getsocknamerq r7 r0 r
acceptrs rL )r r portrC r client_sockrI s r test_acceptzSocketEINTRTest.test_accept( sT #]%7$;<<
### !!!$yy ! -, , $ / , $ : (
t$$
4
- - ![[]]NK TYY[[! , , , - - - - - - - - - - - - - - - - - -s 0ADDD
rF mkfifozneeds mkfifo()c B t j }t j | t j | n/# t
$ r"}| d|z Y d }~nd }~ww xY w| t j | d ddd|z d| j z dddd|f }|
| }t | 5 || | |
d d d d d S # 1 swxY w Y d S )
Nzos.mkfifo(): %srg import os, timerh z path = %arj z# let the parent blockr~ r )r TESTFNunlinkrR r PermissionErrorskipTestro rq r7 r0 r
rs rL )r do_open_close_readerdo_open_close_writerfilenameerC r s r
_test_openzSocketEINTRTest._test_openD s # """ 1 Ih 1 1 1 MM+a/ 0 0 0 0 0 0 0 0 1 ((333yy ( " / $ $
t$$
4
- - * * * TYY[[! , , , - - - - - - - - - - - - - - - - - -s' 7
A#A A#4DDDc N t |d }| d S )Nw)openrp )r pathfps r python_openzSocketEINTRTest.python_openc s
$__
r darwinz+hangs under macOS; see bpo-25234, bpo-35363c < | d| j d S )Nz fp = open(path, 'r')
fp.close())r r r$ s r test_openzSocketEINTRTest.test_openg s-
: ( * * * * *r c l t j |t j }t j | d S r+ )rR r O_WRONLYrp )r r r s r os_openzSocketEINTRTest.os_openm s&
WT2;
'
'
r c < | d| j d S )Nz,fd = os.open(path, os.O_RDONLY)
os.close(fd))r r r$ s r test_os_openz SocketEINTRTest.test_os_openq s,
G & & & & &r N)r; r< r= r> r r r r r r r r r r r r r requires_freebsd_versionrR r r skipIfr" platformr r r r( r r r r s ..X 668LMM!- !- NM!-F, , , X ::<MNNB B ONB,- ,- ,-\, , ,/ / / X ::<MNNA A ONA- - -8 &W%b!,,XX..0@AA- - BA -,-: X_S\X-BD D* *D D* X_S\X-BD D& &D D& & &r r c e Zd ZdZd ZdS )
TimeEINTRTestz" EINTR tests for the time module. c t j }t j | j | t j |z
}| | d S r+ )time monotonicsleepr7 r) r: r t0dts r
test_sleepzTimeEINTRTest.test_sleep| s]
^
4?###
^
" #####r N)r; r< r= r> r r( r r r r x s) ,,$ $ $ $ $r r pthread_sigmaskz need signal.pthread_sigmask()c e Zd ZdZd Z ej eed d d Z ej eed d d Z
dS ) SignalEINTRTestz$ EINTR tests for the signal module. c t j }t j }t j |d }| t j || d ddt j z dt
| z d| j z ddf }t j t j |g }| t j t j
|g t j }|
| }t | 5 || t j |z
} d d d n # 1 swxY w Y | | d d S )
Nc d S r+ r( )r2 s r rW z/SignalEINTRTest.check_sigwait.<locals>.<lambda> s $ r rg r zpid = %sz signum = %srj r~ zos.kill(pid, signum)r )r SIGUSR1rR getpidro rq r r7 r SIG_BLOCK SIG_UNBLOCKr r r0 r
rs rL )
r rM r rZ old_handlerrC old_maskr r r s
r
check_sigwaitz SignalEINTRTest.check_sigwait s ikk mF,>,>??
v{;;;yy $ CKK ' / $ "
)&*:VHEE .0BVHMMM
^
t$$
4
' ' If !!B&B ' ' ' ' ' ' ' ' ' ' ' ' ' ' '
a(((((s !"EEE sigwaitinfozneed signal.sigwaitinfo()c 6 d }| | d S )Nc 0 t j | g d S r+ )r r r s r rM z3SignalEINTRTest.test_sigwaitinfo.<locals>.wait_func s x ( ( ( ( (r r r rM s r test_sigwaitinfoz SignalEINTRTest.test_sigwaitinfo s- ) ) )
9%%%%%r sigtimedwaitc 6 d }| | d S )Nc 2 t j | gd d S )Ng ^@)r r r s r rM z4SignalEINTRTest.test_sigtimedwait.<locals>.wait_func s % 0 0 0 0 0r r r s r test_sigtimedwaitz!SignalEINTRTest.test_sigtimedwait s- 1 1 1
9%%%%%r N) r; r< r= r> r r r r r r r r( r r r r s /.) ) )6 X 7746 6& &6 6& X 8846 6& &6 6& & &r r c x e Zd ZdZd Z ej ej dk d ej e
e d d d Z ej e
e d d d
Z
ej e
e d d d
Z ej e
e d d d ZdS )SelectEINTRTestz$ EINTR tests for the select module. c t j }t j g g g | j t j |z
}| | | d S r+ )r r selectr7 r) r: r s r test_selectzSelectEINTRTest.test_select sc
^
b"b$/222
^
" #####r r z(poll may fail on macOS; see issue #28087pollzneed select.pollc
t j }t j }| | j dz t j |z
}| | | d S Ng @@)r r r r r7 r) r: r pollerr r s r test_pollzSelectEINTRTest.test_poll sq
^
DOc)***
^
" #####r epollzneed select.epollc 8 t j }| |j t j }| | j t j |z
}| | | d S r+ )
r r ro rp r r r r7 r) r: r s r
test_epollzSelectEINTRTest.test_epoll s~ %%%
^
DO$$$
^
" #####r kqueuezneed select.kqueuec < t j }| |j t j }| d d| j t j |z
}| | | d S r )
r r ro rp r r controlr7 r) r: )r r r r s r test_kqueuezSelectEINTRTest.test_kqueue s %%%
^
tQ000
^
" #####r devpollzneed select.devpollc > t j }| |j t j }| | j dz t j |z
}| | | d S r )
r r ro rp r r r r7 r) r: r s r test_devpollz SelectEINTRTest.test_devpoll s !! %%%
^
DOc)***
^
" #####r N)r; r< r= r> r r r r" r r r r r r r r r( r r r r s8 ..$ $ $ X_S\X-?A AX002DEE$ $ FEA A$ X113FGG$ $ HG$ X224HII$ $ JI$ X335JKK$ $ LK$ $ $r r c p e Zd Zd Z ej ej dk d d Zd Z dS )
FNTLEINTRTestc | t j t j d ddt j z d|z d| j z f }t
j }| | }t | 5 t t j d 5 } t
j |z
}|dk rt d |z ||t j
t j z ||t j t
j d
n# t" $ r Y nw xY w ||t j
t
j |z
}| | | d d d n # 1 swxY w Y | d d d d S # 1 swxY w Y d S ) Nrg zimport fcntl, timezwith open('%s', 'wb') as f:z fcntl.%s(f, fcntl.LOCK_EX)z time.sleep(%s)wbTg N@z failed to sync child in %.1f secg{Gz?)ro r r r rq r7 r r r0 r
r ExceptionfcntlLOCK_EXLOCK_NBLOCK_UNr BlockingIOErrorr) r: rL )r lock_func lock_namerC
start_timer fr s r _lockzFNTLEINTRTest._lock sF ()*:;;;yy )I,< < +i 7 $/ 1 3 4 4
^%%
t$$
4
i&--
, ))J6BDyy '(JR(O P PP ! !U]U]%BCCC! !U]333
4((((* !U]+++^%%
2!!!''+++#
,
,
,
,
,
,
,
,
,
,
,
,
,
,
,$
IIKKK' s\ G .0F A
D-,F -
D:7F 9D::AF G F# #G &F# 'G GGAIXzAIX returns PermissionErrorc F | t j d d S )Nlockf)r r r r$ s r
test_lockfzFNTLEINTRTest.test_lockf s
5;(((((r c F | t j d d S )Nflock)r r r# r$ s r
test_flockzFNTLEINTRTest.test_flock s
5;(((((r N)
r; r< r= r r r r systemr! r$ r( r r r r sn @ X__X_&&%/1NOO) ) PO)) ) ) ) )r r __main__)!r>
contextlibr r rR r r r r r0 r" r r testr test.supportr r r8 contextmanagerr
r r TestCaser
rA r r r r r r; mainr( r r <module>r- s{
" " " " " " & & & & & &
WWV[113IJJ'F 'F 'F 'F 'FH% 'F 'F KJ'FT WWV[113IJJe- e- e- e- e-- e- e- KJe-P WWV[113IJJs& s& s& s& s&m s& s& KJs&l WWV[113IJJ$ $ $ $ $M $ $ KJ$ WWV[113IJJ WWV%67746 6,& ,& ,& ,& ,&m ,& ,&6 6 KJ
,&^ WWV[113IJJ5$ 5$ 5$ 5$ 5$m 5$ 5$ KJ5$p&) &) &) &) &)M &) &) &)R zHMOOOOO r 
Browse
Usage
Versions