python (3.11.7)
eG z d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl
Z
d dl Z d dl m
Z
d dlmZ d dlmZ dZe j 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 ) N)support) os_helper)
socket_helperg{Gz?c # K | 5 | V n# | xY w d d d d S # 1 swxY w Y d S N)kill)procs D/BuggyBox/python/3.11.7/bootstrap/lib/python3.11/test/_test_eintr.py
kill_on_errorr " s Q
JJJJ IIKKK
s 5
5$599 setitimerzrequires setitimer()c P e Zd Z dZdZdZd Zd Zed Z d Z
d Z d Z d S )
EINTRBaseTestg?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 r )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__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 Z d Zd Zd Z ej ee d d d Z
d Z d Z ej ee d d
d Z
d Zd
ZdS ) OSEINTRTestc @ 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) )rC ).0_r s r
<listcomp>z3OSEINTRTest._test_wait_multiple.<locals>.<listcomp>b s% BBB!T++--BBBr )rangewait)r wait_funcnum processesrH 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 )rO osrK r% s r
test_waitzOSEINTRTest.test_waiti s )))))r wait3zrequires wait3()c 2 | d d S )Nc * t j d S r( )rQ rS r) r r
<lambda>z(OSEINTRTest.test_wait3.<locals>.<lambda>n s ! r )rO r% s r
test_wait3zOSEINTRTest.test_wait3l s !4!455555r c v | } ||j | d S r )rC pidrK )r rL r s r
_test_wait_singlez OSEINTRTest._test_wait_singlep s6 %%'' $( r c 2 | d d S )Nc , t j | d S r( )rQ waitpidrY s r
rV z*OSEINTRTest.test_waitpid.<locals>.<lambda>w s 2:c1+=+= r rZ r% s r
test_waitpidzOSEINTRTest.test_waitpidv s = =>>>>>r wait4zrequires wait4()c 2 | d d S )Nc , t j | d S r( )rQ ra r^ s r
rV 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 )
rQ pipe
addCleanupclosejoinr7 r0 strr assertEqualreadlenrK )r rdwrdatasrB 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 xrf zimport io, os, sys, timerg zrd = int(sys.argv[1])ri 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))rk r )rQ rm rn ro r
PIPE_MAX_SIZErp r7 r0 rq r rt write
memoryviewrr rK )r ru rv rx rB 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= rC rO rR unittest
skipUnlesshasattrrQ rW rZ r` rd ry r r) r r
r@ r@ X s *% % % * * * XW--/ABB6 6 CB6 ? ? ? XW--/ABB= = CB=- - -:$- $- $- $- $-r r@ c ( e Zd Z ej eed d d Zd Z ej eej d d d Z d Z
d Z d
Z ej eej d d d
Z
d Z ej dd ej eed d d Zd Z ej ej dk d d Zd Z ej ej dk d d ZdS )SocketEINTRTest
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 zrf import os, socket, sys, timerg fd = int(sys.argv[1]) family = %ssock_type = %srh ri 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)rk r )socketr rn ro rp intfamilytyper7 filenor0 rq r rr rt rK ) r recv_funcru rv rw rB fdr rx 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 sockrx s r
rV 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 xyzrE rf r rg r r r ri zdata = b"xyz" * %sr| z)rd = socket.fromfd(fd, family, sock_type)r zwith rd:z$ # let the parent block on send()rj 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))rk r )r r rn ro r
SOCK_MAX_SIZErp r r r r7 r r0 rq r rt r rr rK )
r send_funcru rv rx rB 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
rV 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 rf zimport socket, timerg z host = %rz port = %sri z # let parent block on accept()r} z,with socket.create_connection((host, port)):rj )r
create_serverr HOSTrn ro getsocknamerp r7 r0 r acceptrr rK )r r portrB r client_sockrH s r
test_acceptzSocketEINTRTest.test_accept( sT #]%7$;<<
### !!!$yy ! -, , $ / , $ : (
t$$
4
- - ![[]]NK TYY[[! , , , - - - - - - - - - - - - - - - - - -s 0ADDD
rE 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(): %srf import os, timerg z path = %ari z# let the parent blockr} r )r TESTFNunlinkrQ r PermissionErrorskipTestrn rp r7 r0 r rr rK )r do_open_close_readerdo_open_close_writerfilenameerB 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)openro )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 )rQ r O_WRONLYro )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 requires_freebsd_versionrQ 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 Z d ZdS )
TimeEINTRTestc 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 x s& ,$ $ $ $ $r r pthread_sigmaskz need signal.pthread_sigmask()c e Zd Z d Z ej eed d d Z ej eed d d Z dS )SignalEINTRTestc 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
rV z/SignalEINTRTest.check_sigwait.<locals>.<lambda> s $ r rf r zpid = %sz signum = %sri r} zos.kill(pid, signum)r )r SIGUSR1rQ getpidrn rp r r7 r SIG_BLOCK SIG_UNBLOCKr r r0 r rr rK )
r rL r rY old_handlerrB 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
rL z3SignalEINTRTest.test_sigwaitinfo.<locals>.wait_func s x ( ( ( ( (r r r rL 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
rL 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 s /) ) )6 X 7746 6& &6 6& X 8846 6& &6 6& & &r r c v e Zd Z d 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 )SelectEINTRTestc 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 rn ro 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 rn ro 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 rn ro 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 s5 .$ $ $ 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 ) Nrf 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?)rn r r r rp r7 r r r0 r r ExceptionfcntlLOCK_EXLOCK_NBLOCK_UNr BlockingIOErrorr* r: rK )r lock_func lock_namerB
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__)
contextlibr! r rQ r r r r r0 r# r r testr test.supportr r r8 contextmanagerr r r TestCaser r@ r r r r r r; mainr) r r
<module>r, sv
" " " " " " & & & & & &
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