python (3.12.0)
Browse
Usage
Versions
Αe , d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlmZm Z m
Z
m Z d dlm Z d dl
mZ ej e
d d Z G d d
ej& Zed k( r ej, yy# e$ r ej" d w xY w) N) cpython_onlyrequires_subprocessrequires_working_socketrequires_resource)threading_helper)TESTFNzselect.poll not definedT)modulec L g }| D ] \ }}||z s |j | |S )N)append)readyflagmatchfdmodes B/BuggyBox/python/3.12.0/bootstrap/lib/python3.12/test/test_poll.pyfind_ready_matchingr s4 E D $; LL L c e Zd Zd Zd Z e ed d Zd Ze d Z
e j d Z
ej ed e j d Zy
) PollTestsc t j }d}d}t | }g }g }i }i }t | D ] } t j
\ }
} |j
|
|j |
t j |j
| t j |j |
|j | | ||
< |
|| < g } |rZ|j }
t |
t j }|s t d t j | } t j | | |j }
t |
t j }|s t d t j | }
t j |
| }| j# t | | | j | t j$ ||
t j$ |
|j' ||
|j' |
|j) ||
|rZ| j# | |g|z y )N s This is a test.zno pipes ready for writingzno pipes ready for reading)selectpolllenrangeospiperegistermodifyPOLLINPOLLOUTr r RuntimeErrorrandomchoicewriteread assertEqualclose
unregisterremove)selfp NUM_PIPESMSGMSG_LENreaderswritersr2ww2rirdwrbufsr
ready_writers
ready_readersbufs r
test_poll1zPollTests.test_poll1! s
KKM !c(y! AWWYFB
JJrN
HHR '
JJr6>> * NN2 NN2 CGCG FFHE /v~~ FM "#?@@ }-B HHR FFHE /v}} EM "#?@@ }-B''"g&C SXw / KK HHSW "
LL#b' #
LL" NN3r7 #' *
uy 01r c t j \ }}t j | t j | t j }|j | |j }| j
|d |t j f t t d 5 }|j }t j }|j | |j }| j
|d d | d d d |j }| j
|d t j f t j t t j }| j t |j
| | j t |j | t j }| j t |j d t j } G d d } G d d } | j t |j
| d | j t |j
| d y # 1 sw Y ZxY w)Nr w c e Zd Zy),PollTests.test_poll_unit_tests.<locals>.NopeN)__name__
__module__ __qualname__ r r Noper@ q s r rE c e Zd Zd Zy).PollTests.test_poll_unit_tests.<locals>.Almostc y)NfilenorD )r+ s r rI z5PollTests.test_poll_unit_tests.<locals>.Almost.filenou s r N)rA rB rC rI rD r r AlmostrG t s
r rJ )r r r( r r r r' POLLNVALopenr rI unlink assertRaises TypeErrorr) KeyError)
r+ FDr= r, rfr pollsterrE rJ s
r test_poll_unit_testsz PollTests.test_poll_unit_testsR s A
KKM
2
FFH 1FOO 45
&#
*!B
A
JJqMA QqT!Wb ) *
FFH 1FOO 45
&
KKM )QZZ3 )Q\\15
KKM (ALL!4 ;;=
)X%6%6B )X%6%6!D; * *s
,A I""I,walltimec T d}t j |dt j d }| j | |j }t j }|j |t
j dD ] }|j
| }|g k( r|d \ }}|t
j z r'|j } | dk7 r| j d \|t
j z r'|j } | s y | j | d | j d |z y )
Nz?for i in 0 1 2 3 4 5 6 7 8 9; do echo testing...; sleep 1; doneTr )shellstdoutbufsize)r i i i i@ i> r[ r[ r[ r[ r[ r[ r[ r[ r[ r z6error: pipe seems to be closed, but still returns datas testing...
z,Unexpected return value from select.poll: %s)
subprocessPopenPIPE enterContextrY r r r r POLLHUPreadlinefailr' )
r+ cmdprocr, rT toutfdlistr flagslines
r
test_poll2zPollTests.test_poll2~ s P 4
()+ $ KK;;=1fmm-A SD ]]4(F" q IBv~~%zz|3;II VW &zz| 7 H6QR% Sr c t j }|j d | j t |j d d}|dk7 r| j d | j t |j dd | j t |j dd | j t |j dd | j t |j dd y )N l zOverflow must have occurredr r[ )r r r rN
OverflowErrorrb
ValueErrorr )r+ rT xs r
test_poll3zPollTests.test_poll3 s ;;=! - @ 6 II3 4
*h&7&7B? -):):AwG *hooq"= - !WEr c ddl m}m}m} t j
}|j
d | j t |j d|dz | j t |j d|dz | j t |j
|dz | j t |j
|dz y )Nr ) USHRT_MAXINT_MAXUINT_MAXrk )
_testcapirr rs rt r r r rN rm r )r+ rr rs rt rT s r test_poll_c_limitsz PollTests.test_poll_c_limits s ::;;=!
-):):Ay1}M - !Y]K - ! D - 1 Er c t j \ }}| j t j | | j t j | g }t d D ]H }t j
| }| j t j | |j
| J t j }|D ]" }|j |t j $ t j |j }|j t j d |D ] }|j! | |j |t j" | j% t& |j t j( |d |j+ y # t j( |d |j+ w xY w)N
)targetg ? spam)r r
addCleanupr( r dupr r r r r threadingThreadstarttimesleepr) r! rN r" r% join)r+ rR r= rfdsr4 r rT ts r test_threaded_pollz PollTests.test_threaded_poll sO wwy1 !$ !$r AB OOBHHb ) KKO ;;= 1B b&-- 0 1
HMM 2
JJsO
(##B'
( a 0 lHMM :
HHQ
FFH
HHQ
FFHs
A-F0 0(Gz!Threading required for this test.c P dD ] }t j \ }}t j }|j |t j
t
j |j |f }|j |j d | j |j t j |d |j | j |j t j | t j | # y )N)Nir[ g gg0.+)ry argsg?)timeoutrz )r r r r r r r} r~ r r
assertTrueis_aliver% assertFalser( )r+
timeout_msrR r= rT poll_threads r !test_poll_blocks_with_negative_msz+PollTests.test_poll_blocks_with_negative_ms s A J 779DAq {{}H a /#**(--zmTK S ) OOK 0 0 2 3
HHQ [ 1 1 3 4 HHQK HHQK# r N)rA rB rC r; rU r r ri rp r rv r reap_threadsr unittest
skipUnlessr} r rD r r r r s /2b'EX z"S # S8F" F F "" #6 X$GH"" # Ir r __main__)r r\ r# r r} r r test.supportr r r r r test.support.os_helperr r AttributeErrorSkipTestr TestCaser rA mainrD r r <module>r s
* )7
KK t $J!! JZ zHMMO s 7
(
5
667s A; ;B