python (3.12.0)
͑eF " d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl
Z
ddl Z ddl Z ddl
mZ ddlmZ ddlmZ ej$ 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> yy)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_helperc # r K | 5 | ddd y# | j xY w# 1 sw Y yxY ww)zGContext manager killing the subprocess if a Python exception is raised.N)kill)procs D/BuggyBox/python/3.12.0/bootstrap/lib/python3.12/test/_test_eintr.py
kill_on_errorr
sA
J IIK s 7+ 7(+47 setitimerzrequires setitimer()c D e Zd ZdZdZdZdZd Zd Ze d Z
d Z d Z y )
EINTRBaseTestz Base class for EINTR tests. g?g?c . | xj dz
c_ y N )signals)selfsignumframes r
sighandlerzEINTRBaseTest.sighandler3 s c 6 d| _ t j t j | j | _ t j
t j | j | j t j ddt j y )Nr iX T)exitfile)
r signalSIGALRMr orig_handlerr ITIMER_REAL signal_delay
signal_period faulthandlerdump_traceback_latersys
__stderr__r s r setUpzEINTRBaseTest.setUp6 sf "MM&..$// J++T->-> ++ -
))'/2~~ ?r c N t j t j dd y Nr )r r r r r
stop_alarmzEINTRBaseTest.stop_alarmA s ++Q2r c | j t j t j | j t j
y N)r) r r r r cancel_dump_traceback_laterr$ s r tearDownzEINTRBaseTest.tearDownE s0
fnnd&7&78002r c X t j df|z }t j |fi |S )Nz-c)r"
executable
subprocessPopen)r argskwcmd_argss r r0 zEINTRBaseTest.subprocessJ s+ NND)D0 /B//r N)
__name__
__module__ __qualname____doc__r r
sleep_timer r% staticmethodr) r- r0 r( r r r
r
' s@ ' LM J ? 3 33
0r 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 Zy) OSEINTRTestz EINTR tests for the os module. c B d| j z }| j | S )Nzimport time; time.sleep(%r))r9 r0 )r codes r new_sleep_processz OSEINTRTest.new_sleep_processS s ,t>t$$r c d}t | D cg c] }| j }}t | D ] } | |D ] }|j y c c}w )N )ranger? wait)r wait_funcnum_ processesr s r _test_wait_multiplez OSEINTRTest._test_wait_multipleW s_ 7<SzB!T++-B Bs A K D IIK Cs Ac B | j t j y r+ )rH osrC r$ s r test_waitzOSEINTRTest.test_wait` s )r wait3zrequires wait3()c ( | j d y )Nc , t j d S r' )rJ rL r( r r <lambda>z(OSEINTRTest.test_wait3.<locals>.<lambda>e s ! r )rH r$ s r
test_wait3zOSEINTRTest.test_wait3c s !45r c h | j } ||j |j y r+ )r? pidrC )r rD r s r _test_wait_singlez OSEINTRTest._test_wait_singleg s% %%'$(( r c ( | j d y )Nc . t j | d S r' )rJ waitpidrR s r rO z*OSEINTRTest.test_waitpid.<locals>.<lambda>n s 2::c1+= r rS r$ s r test_waitpidzOSEINTRTest.test_waitpidm s =>r wait4zrequires wait4()c ( | j d y )Nc . t j | d S r' )rJ rZ rW s r rO z(OSEINTRTest.test_wait4.<locals>.<lambda>r s 288C+; r rX r$ s r
test_wait4zOSEINTRTest.test_wait4p s ;<r c " t j \ }}| j t j | g d}dj dddd|z d| j
z ddd d
d f
}| j
|t | |g }t | 5 t j | |D ]1 }| j |t j |t | 3 | j |j d
d d d y # 1 sw Y y xY w)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 )
rJ pipe
addCleanupclosejoinr9 r0 strr
assertEqualreadlenrC )r rdwrdatasr> r datas r test_readzOSEINTRTest.test_readt s B "%
.yy " # 5 / 2 ( $
tSWt<
4
- HHRL
? rwwr3t9'=>
? TYY[! , - - -s
A,DDc t j \ }}| j t j | dt j
z }dj
dddd| j z dt j
z ddd d
dd d d
ddddddf }| j |t | |g }t | 5 t j | d}|t | k r4|t j |t | |d z
}|t | k r4| j |j d d d d y # 1 sw Y y xY w)N xr_ zimport io, os, sys, timer` zrd = int(sys.argv[1])rb 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))rd r )rJ rf rg rh r
PIPE_MAX_SIZEri r9 r0 rj r
rm write
memoryviewrk rC )r rn ro rq r> r writtens r
test_writezOSEINTRTest.test_write s/ B "% g+++yy & # / !6!6 6 " / $ & 9 3 ( * > ;'
, tSWt<
4
- HHRLGCI%288B
4(8(BCC CI% TYY[! , - - -s 6AD9 D99EN)r5 r6 r7 r8 r? rH rK unittest
skipUnlesshasattrrJ rP rS rY r] rr r{ r( r r r< r< O s *%* XW-/AB6 C6 ? XW-/AB= C=-:$-r r< 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 Zy) SocketEINTRTestz$ EINTR tests for the socket module.
socketpairzneeds socketpair()c x t j \ }}| j |j g d}dj ddddt |j z dt |j z d|z d | j z dd
d dd d
dddf }|j }| j |t | |g }t | 5 |j |D ]$ }| j | ||t | & | j |j d d d d y # 1 sw Y y xY w)N)rt y zr_ import os, socket, sys, timer` fd = int(sys.argv[1]) family = %ssock_type = %sra rb 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)rd r )socketr rg rh ri intfamilytyper9 filenor0 rj r
rk rm rC ) r recv_funcrn ro rp r> fdr rq s r
_test_recvzSocketEINTRTest._test_recv s% ""$B ! #yy * # C N * s277| + 5 / 7 $ 6 , &!
& YY[tSWt<
4
- HHJ
A ySY'?@
A TYY[! , - - -s
AD00D9c V | j t j j y r+ )r r recvr$ s r test_recvzSocketEINTRTest.test_recv
**+r recvmsgzneeds recvmsg()c ( | j d y )Nc * | j | d S r' )r sockrq s r rO z.SocketEINTRTest.test_recvmsg.<locals>.<lambda> s 4<<+=a+@ r )r r$ s r test_recvmsgz SocketEINTRTest.test_recvmsg s @Ar c t j \ }}| j |j dt j
dz z }dj
ddddt |j z dt |j z d | j z d
t j
dz z d dd d
dddddddddddddf }|j }| j |t | |g }t | 5 |j d}|t | k r6 ||t! | |d } || t | n| z
}|t | k r6| j# |j% d d d d y # 1 sw Y y xY w)Ns xyzrA r_ r r` r r r rb zdata = b"xyz" * %sru z)rd = socket.fromfd(fd, family, sock_type)r zwith rd:z$ # let the parent block on send()rc 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))rd r )r r rg rh r
SOCK_MAX_SIZEri r r r r9 r r0 rj r
rm ry rk rC )
r send_funcrn ro rq r> r r rz sents
r
_test_sendzSocketEINTRTest._test_send sy ""$B ! ..!34yy * # C N * s277| + / G$9$9Q$> ? " 7 2 ( 5 % F ' > C1
6 YY[tSWt<
4
- HHJGCI% Z%5gh%?@ 3t9$> CI%
TYY[! , - - -s 8AE8 E88Fc V | j t j j y r+ )r r sendr$ s r test_sendzSocketEINTRTest.test_send r r c V | j t j j y r+ )r r sendallr$ s r test_sendallz SocketEINTRTest.test_sendall s
--.r sendmsgzneeds sendmsg()c ( | j d y )Nc & | j |g S r+ )r r s r rO 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 |j
|j
d }dj dddt j z d|z d| j z dd d
d d f
}| j | }t | 5 |j \ }}|j | j |j d d d d y # 1 sw Y y xY w)
Nr r r_ zimport socket, timer` z host = %rz port = %srb z # let parent block on accept()rv z,with socket.create_connection((host, port)):rc )r
create_serverr HOSTrg rh getsocknameri r9 r0 r
acceptrk rC )r r portr> r client_sockrF s r test_acceptzSocketEINTRTest.test_accept s ##]%7%7$;<
# !!$yy ! -,, , $ / , $ : (
t$
4
- ![[]NK TYY[! , - - -s
,AC99D
rA mkfifozneeds mkfifo()c t j }t j | t j | | j t j | dj ddd|z d| j z dddd|f }| j | }t | 5 || | j |j d d d d y # t
$ r }| j
d|z Y d }~d }~ww xY w# 1 sw Y y xY w)
Nzos.mkfifo(): %sr_ import os, timer` z path = %arb z# let the parent blockrv r )r TESTFNunlinkrJ r PermissionErrorskipTestrg ri r9 r0 r
rk rC )r do_open_close_readerdo_open_close_writerfilenameer> r s r
_test_openzSocketEINTRTest._test_open; s ## " 1 IIh
(((3yy ( " / $ $
t$
4
- * TYY[! , - -# 1 MM+a/ 0 0 1" - -s# C ")C> C; C66C;>Dc < t |d }|j y )Nw)openrh )r pathfps r python_openzSocketEINTRTest.python_openZ s
$_
r darwinz+hangs under macOS; see bpo-25234, bpo-35363c < | j d| j y )Nz fp = open(path, 'r')
fp.close())r r r$ s r test_openzSocketEINTRTest.test_open^ s
: (( *r c v t j |t j }t j | y r+ )rJ r O_WRONLYrh )r r r s r os_openzSocketEINTRTest.os_opend s!
WWT2;;
'
r c < | j d| j y )Nz,fd = os.open(path, os.O_RDONLY)
os.close(fd))r r r$ s r test_os_openz SocketEINTRTest.test_os_openh s
G &r N)r5 r6 r7 r8 r| r} r~ r r r r r r r r r r requires_freebsd_versionrJ r r skipIfr" platformr r r r( r r r r sY .X 68LM!- N!-F, X :<MNB OB,-\,/ X :<MNA OA-8 &W%%b!,XX.0@A- B --: X__S\\X-BD*D* X__S\\X-BD&D&r r c e Zd ZdZd Zy)
TimeEINTRTestz" EINTR tests for the time module. c t j }t j | j | j t j |z
}| j || j y r+ )time monotonicsleepr9 r) assertGreaterEqualr t0dts r
test_sleepzTimeEINTRTest.test_sleeps sM
^^
4??#
^^
" DOO4r N)r5 r6 r7 r8 r r( r r r r o s
,5r r pthread_sigmaskz need signal.pthread_sigmask()c e Zd ZdZd Z ej eed d d Z ej eed d d Z
y) SignalEINTRTestz$ EINTR tests for the signal module. c t j }t j }t j |d }| j t j || dj ddt j z dt
| z d| j z ddf }t j t j |g }| j t j t j |g | j | }t | 5 || d d d | j |j d y # 1 sw Y *xY w)
Nc y r+ r( )r2 s r rO z/SignalEINTRTest.check_sigwait.<locals>.<lambda> s r r_ r zpid = %sz signum = %srb rv zos.kill(pid, signum)r )r SIGUSR1rJ getpidrg ri r r9 r SIG_BLOCK SIG_UNBLOCKr0 r
rk rC )r rD r rR old_handlerr> old_maskr s r
check_sigwaitz SignalEINTRTest.check_sigwait s iik mmF,>?
v{;yy $ CK ' / $ "
))&*:*:VHE ..0B0BVHMt$
4
f
a( s EE sigwaitinfozneed signal.sigwaitinfo()c , d }| j | y )Nc 0 t j | g y r+ )r r r s r rD z3SignalEINTRTest.test_sigwaitinfo.<locals>.wait_func s x (r r r rD s r test_sigwaitinfoz SignalEINTRTest.test_sigwaitinfo s )
9%r sigtimedwaitc , d }| j | y )Nc 2 t j | gd y )Ng ^@)r r r s r rD z4SignalEINTRTest.test_sigtimedwait.<locals>.wait_func s % 0r r r s r test_sigtimedwaitz!SignalEINTRTest.test_sigtimedwait s 1
9%r N) r5 r6 r7 r8 r r| r} r~ r r r r( r r r r { sf /)2 X 746&6& X 846&6&r r c \ 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 Zy)SelectEINTRTestz$ EINTR tests for the select module. c t j }t j g g g | j t j |z
}| j | j || j y r+ )r r selectr9 r) r r s r test_selectzSelectEINTRTest.test_select sS
^^
b"b$//2
^^
" DOO4r r z(poll may fail on macOS; see issue #28087pollzneed select.pollc t j }t j }|j | j dz t j |z
}| j | j
|| j y Ng @@)r r r r r9 r) r r pollerr r s r test_pollzSelectEINTRTest.test_poll s_
^^
DOOc)*
^^
" DOO4r epollzneed select.epollc F t j }| j |j t j
}|j
| j t j
|z
}| j | j || j y r+ )
r r rg rh r r r r9 r) r r s r
test_epollzSelectEINTRTest.test_epoll sh %
^^
DOO$
^^
" DOO4r kqueuezneed select.kqueuec J t j }| j |j t j
}|j
d d| j t j
|z
}| j | j || j y r )
r r rg rh r r controlr9 r) r )r r r r s r test_kqueuezSelectEINTRTest.test_kqueue sl %
^^
tQ0
^^
" DOO4r devpollzneed select.devpollc L t j }| j |j t j
}|j
| j dz t j
|z
}| j | j || j y r )
r r rg rh r r r r9 r) r r s r test_devpollz SelectEINTRTest.test_devpoll sn ! %
^^
DOOc)*
^^
" DOO4r N)r5 r6 r7 r8 r r| r r" r r} r~ r r r r r r( r r r r s .5 X__S\\X-?AX02DE5 FA5 X13FG5 H5 X24HI5 J5 X35JK5 L5r r c n e Zd Zd Z ej
ej dk( d d Zd Z y)
FNTLEINTRTestc | j t j t j dj ddt j z d|z d| j
z f }t
j }| j | }t | 5 t t j d 5 }t
j }t j t j d D ]B } ||t j t j z ||t j" D t
j |z
}t' d |z # t$ $ r Y nw xY w ||t j t
j |z
}| j) || j
| j+ d d d n # 1 sw Y nxY w|j- d d d y # 1 sw Y y xY w)
Nr_ zimport fcntl, timezwith open('%s', 'wb') as f:z fcntl.%s(f, fcntl.LOCK_EX)z time.sleep(%s)wbF)errorz failed to sync child in %.1f sec)rg r r r ri r9 r r r0 r
r r sleeping_retry LONG_TIMEOUTfcntlLOCK_EXLOCK_NBLOCK_UNBlockingIOError Exceptionr r) rC ) r lock_func lock_namer>
start_timer frF r s r _lockzFNTLEINTRTest._lock s (()*:*:;yy )I,<,< < +i 7 $// 1 3 4
^^%
t$
4
i&&-
" !^^ -
//0D0DER MA !!U]]U]]%BC!!U]]3M )J6B#$F$KLL + !U]]+^^%
2''DOO<!'
"
"
"(
IIK+ sI G,0=G.?E-'G E! G E! !A G> G,G G,,G5AIXzAIX returns PermissionErrorc D | j t j d y )Nlockf)r r r r$ s r
test_lockfzFNTLEINTRTest.test_lockf s
5;;(r c D | j t j d y )Nflock)r r r r$ s r
test_flockzFNTLEINTRTest.test_flock
s
5;;(r N)
r5 r6 r7 r r| r r systemr r r( r r r r s> D X___X__&%/1NO) P))r r __main__) r8
contextlibr r rJ r r r r r0 r" r r| testr test.supportr r contextmanagerr
r} r~ TestCaser
r< r r r r r r5 mainr( r r <module>r) s
" & WV[13IJ$0H%% $0 K$0N WV[13IJe-- e- Ke-P WV[13IJs&m s& Ks&l WV[13IJ5M 5 K5 WV[13IJ WV%6746*&m *&6 K
*&Z WV[13IJ55m 55 K55p()M ()V zHMMO r 
Browse
Usage
Versions