python (3.12.0)
Browse
Usage
Versions
ΑeI d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlmZ d dl m
Z
d dl m Z d dl m
Z
d dlZd dlZd dlZd dl mZ d dlZej( s ej* r ej, d eed r
ej0 Znej2 ej4 d fd Zd
Z G d d Z G d
d Z G d de ej< Z G d de ej< Z ejB eed d G d de e ej< Z" ejB eed d G d de e ej< Z# ejB eed d G d d e e ej< Z$ ejB eed d G d! d"e e ej< Z%d# Z&e'd$k( r ejP yy# e$ r dZY w xY w)% N)support) os_helper)
socket_helper)sleep) monotonicz,Cannot create socketpair on Emscripten/WASI.
socketpairc t j | || 5 }|j t j df |j t j | || } |j |j
|j
} |j \ }}||k( r
||fcd d d S |j 6# t $ r |j w xY w# 1 sw Y y xY w)Nr )
socketbindr HOSTlistenconnect getsocknameacceptcloseOSError)familytypeprotolccaddraaddrs G/BuggyBox/python/3.12.0/bootstrap/lib/python3.12/test/test_selectors.pyr r s
]]64
/ 1
FFM&&* +
HHJ
fdE2A
!--/*
hhjGAtu} !t GGI
s% A C&"A C7CC##C&&C/c ` g }| D ]& \ }}||z s |j |j ( |S N)appendfileobj)readyflagmatchkeyeventss r find_ready_matchingr% 0 s8 E & V D= LL %& L c ~ e Zd Zd Zd Zd Zd Z ej e j dk( d d Z d Z d Z
d
Zd Zd Zd
Zd Zd Zd Zd Z ej, ej0 dk( d d Zd Z ej ee d d d Z ej ee d d d Z y)BaseSelectorTestCasec t \ }}| j |j | j |j ||fS r )r
addCleanupr )selfrdwrs r make_socketpairz$BaseSelectorTestCase.make_socketpair: s6 B ! !2v
r& c | j }| j |j | j \ }}|j |t
j d }| j |t
j | j |j | | j |j |j | j |j t
j | j |j d | j t |j dd | j t |j dt
j | j t" |j |t
j | j t" |j |j t
j y )Ndatar ?B i)SELECTORr* r r. register selectors
EVENT_READassertIsInstance SelectorKey assertEqualr fdfilenor$ r0 assertRaises
ValueErrorKeyErrorr+ sr, r- r# s r
test_registerz"BaseSelectorTestCase.test_register@ s< MMO %%'BjjY 1 16: c9#8#89 b) - Y%9%9: 6*
*ajj!V<
*ajj#y7K7KL
(AJJI4H4HI
(AJJ #.. 0r& c f | j }| j |j | j \ }}|j |t
j |j | | j t |j d | j t |j | y Nr1 )
r2 r* r r. r3 r4 r5
unregisterr; r= r+ r? r, r- s r test_unregisterz$BaseSelectorTestCase.test_unregisterZ s MMO %%'B
2y++, R
(ALL&9
(ALL"5r& c | j }| j |j | j \ }}|j |j }}|j |t j |j |t j |j |j |j | |j | y r )
r2 r* r r. r: r3 r4 r5 EVENT_WRITErC )r+ r? r, r- rws r test_unregister_after_fd_closez3BaseSelectorTestCase.test_unregister_after_fd_closei s MMO %%'Byy{BIIK1
1i**+
1i++,
Q Qr& posixzrequires posixc | j }| j |j | j \ }}|j |j }}|j |t j |j |t j | j \ }}|j |j t j |j | t j |j | | j t j | | j t j | |j | |j | y r ) r2 r* r r. r: r3 r4 r5 rG osdup2rC )r+ r? r, r- rH rI rd2wr2s r (test_unregister_after_fd_close_and_reusez=BaseSelectorTestCase.test_unregister_after_fd_close_and_reuseu s MMO %%'Byy{BIIK1
1i**+
1i++,'')S
a
a !$ !$ Q Qr& c | j }| j |j | j \ }}|j |t
j |j |t
j |j |j |j | |j | y r ) r2 r* r r. r3 r4 r5 rG rC rD s r "test_unregister_after_socket_closez7BaseSelectorTestCase.test_unregister_after_socket_close s MMO %%'B
2y++,
2y,,-
R Rr& c D | j }| j |j | j \ }}|j |t
j }|j |t
j }| j |j |j | j ||j | |j | t }t }|j |t
j | }|j |t
j | }| j |j |j | j |j |j | j ||j | | j |j | | j! t" |j dt
j t }t$ j& j) |_ t$ j& j) |_
|j |t
j | | j+ |j j, | j+ |j j, y rB )r2 r* r r. r3 r4 r5 modifyrG assertNotEqualr$ r8 get_keyrC objectr0 r; r= unittestmockMock assertFalsecalled) r+ r? r, r- r# key2d1d2d3s r test_modifyz BaseSelectorTestCase.test_modify s MMO %%'BjjY 1 12 xxI 1 12 CJJ 4 qyy}- R X
XjjY 1 126xxI 0 0"5 T[[1 CHHdii0 qyy}- B'
(AHHfi6J6JK X ]]'')
}}))+ Y))2. **+ ,,-r& c | j j dk( r t j j d }n| j j dk( r t j j d }nJ| j j dk( r t j j d }n| j d |5 }t j j
t |j _ | j }| j |j | j \ }}|j |t j | j! t# |j$ d | j' t 5 |j |t j( d d d | j! t# |j$ d
d d d y # 1 sw Y 7xY w# 1 sw Y y xY w) N
EpollSelectorz%selectors.EpollSelector._selector_cls PollSelectorz$selectors.PollSelector._selector_clsDevpollSelectorz'selectors.DevpollSelector._selector_cls ) side_effect r )r2 __name__rY rZ patchskipTestr[ ZeroDivisionError return_valuerU r* r r. r3 r4 r5 r8 len_mapr; rG )r+ rk mr? r, r- s r test_modify_unregisterz+BaseSelectorTestCase.test_modify_unregister s| == ! !_ 4 MM''79E
]]
#
#~
5 MM''68E
]]
#
#'8
8 MM''9;E --# #
-a$,MM$6$6 - %7 %/ANN !
A OOAGG $))+FB
JJr9// 0 S[! ,""#45
4Y 2 23
4 S[! ,
-
-
4
4
-
-s% ?C G. !G",-G."G+ 'G..G7c H | j }| j |j |j }| j \ }}|j |t j |j |t j |j | j t |j | | j t |j | | j t |j | | j t |j | y r )r2 r* r get_mapr. r3 r4 r5 rG r; RuntimeErrorrW r= __getitem__)r+ r? mappingr, r- s r
test_closez BaseSelectorTestCase.test_close s MMO ))+%%'B
2y++,
2y,,- , 26 , 26 (G$7$7< (G$7$7<r& c F | j }| j |j | j \ }}|j |t
j d }| j ||j | | j t |j d y )Nr0 r1 ) r2 r* r r. r3 r4 r5 r8 rW r; r= r> s r test_get_keyz!BaseSelectorTestCase.test_get_key sw MMO %%'BjjY 1 16: aiim,
(AIIv6r& c T | j }| j |j | j \ }}|j }| j | | j
t | d | j
t | g |j |t j d }| j || | j
||| | j
t | d | j
t | |j g | j
t |j |g | j t 5 |d d d d | j t" 5 ||= d d d y # 1 sw Y +xY w# 1 sw Y y xY w)Nr r0 ri r1 )r2 r* r r. rt r\ r8 ro listr3 r4 r5 assertInr: valuesr; r= TypeError)r+ r? r, r- keysr# s r test_get_mapz!BaseSelectorTestCase.test_get_map sT MMO %%'Byy{ TA& dR(jjY 1 16:
b$ d2h' TA& dbiik]3 dkkm,se4
x
( L
y
) R s "FF F F'c V | j }| j |j | j \ }}|j |t
j |j |t
j }|j }|D ]s \ }}| j t |t
j | j | | j |t
j t
j z z u | j |t
j fg| y r )r2 r* r r. r3 r4 r5 rG select
assertTrue
isinstancer7 r\ r8 )r+ r? r, r- wr_keyresultr# r$ s r test_selectz BaseSelectorTestCase.test_select s MMO %%'B
2y++,B 5 56! @KC OOJsI,A,A B C OOF # V (<(<(1(=(=)> '? ?
@ @
69#8#89:FCr& c | j }| j |j | j \ }}|5 }|j |t
j |j |t
j d d d | j t |j | | j t |j | y # 1 sw Y LxY wr ) r2 r* r r. r3 r4 r5 rG r; ru rW )r+ r? r, r- sels r test_context_managerz)BaseSelectorTestCase.test_context_manager s MMO %%'B
4# LLY 1 1 2 LLY 2 2 3 4
, 26 , 26 4 4s
AC
Cc | j }| j |j t |d rB|j }| j t
|t | j |d y y )Nr: r ) r2 r* r hasattrr: r r intassertGreaterEqual)r+ r? r9 s r test_filenoz BaseSelectorTestCase.test_fileno' sZ MMO 1h B OOJr3 / 0 # #B * r& c | j }| j |j d}d}t | }g }g }i }i }t | D ] } | j \ }
} |j
|
t j |j
| t j |j |
|j | | ||
< |
|| < g } |rR|j }
t |
t j }|s| j d t j | } | j! | t d D ]; } |j }
t |
t j }|r n t# d = | j d | j% || g |d }
|
j' | }| j% t | | | j | |j) ||
|j) |
|j+ ||
|rR| j% | |g|z y )N s This is a test.z no sockets ready for writing
g?z no sockets ready for readingr )r2 r* r ro ranger. r3 r4 r5 rG r r r% failrandomchoicesendr r8 recvrC remove)r+ r? NUM_SOCKETSMSGMSG_LENreaderswritersr2ww2rir, r- bufsr
ready_writers
ready_readersbufs r
test_selectorz"BaseSelectorTestCase.test_selector0 s MMO !c({# A))+FB
JJr9// 0
JJr900 1 NN2 NN2 CGCG HHJE /y7L7L MM 89 }-B GGCL2Y
:
3E4=4H4H!J
c
: 89 c"gY
6 q!B'''"C SXw / KK
LLR !
LL NN3r7 #5 8
u{ 23r& win32z1select.select() cannot be used with empty fd setsc | j }| j |j | j |j d g y )Nr )timeout)r2 r* r r8 r )r+ r? s r test_empty_selectz&BaseSelectorTestCase.test_empty_selecte s:
MMO !,b1r& c | j }| j |j | j \ }}|j |t
j t }| j dt |j d | j dt |j d | j t |z
d |j | |j |t
j t }| j |j d | j |j d | j t |z
d t }| j |j d t }||z
}| j d|cxk xr dk | y c | y )Nri r g ?皙? @)r2 r* r r. r3 r4 rG timer8 ro r
assertLessrC r5 r\ r )r+ r? r, r- tt0t1dts r test_timeoutz!BaseSelectorTestCase.test_timeoutn sL MMO %%'B
2y,,- F C ,- C -.
C( R
2y++, F !% " &
C(
V !%
V
"W r(S("-("-r& alarmz%signal.alarm() required for this testc | j }| j |j | j \ }} G d dt fd}t j
t
j | }| j t
j
t
j | t j d |j |t j t }| j 5 |j d d d d | j t |z
d t j d y # 1 sw Y <xY w# t j d w xY w)Nc e Zd Zy)GBaseSelectorTestCase.test_select_interrupt_exc.<locals>.InterruptSelectN)rj
__module__ __qualname__ r& r InterruptSelectr s r& r c r r )argsr s r handlerz?BaseSelectorTestCase.test_select_interrupt_exc.<locals>.handler s ! !r& ri g @r )r2 r* r r. ExceptionsignalSIGALRMr r3 r4 r5 r r; r r )r+ r? r, r- r orig_alrm_handlerr r s @r test_select_interrupt_excz.BaseSelectorTestCase.test_select_interrupt_exc s
MMO %%'B i " #MM&..' B
v~~7HI LLO
JJr9// 0A""?3
OODFQJ , LLO
LLOs% (AE 8E
%E E
E E(c | j }| j |j | j \ }}t j t j
d }| j t j t j
| t j d |j |t j t }| j |j d | j t |z
d t j d y # t j d w xY w)Nc y r r )r s r <lambda>zDBaseSelectorTestCase.test_select_interrupt_noraise.<locals>.<lambda> s r& ri g ?g ?r )r2 r* r r. r r r r3 r4 r5 r r\ r r )r+ r? r, r- r r s r test_select_interrupt_noraisez2BaseSelectorTestCase.test_select_interrupt_noraise s
MMO %%'B "MM&..:L M
v~~7HI LLO
JJr9// 0A
QXXc] + # #DFQJ 4 LLOFLLOs
A<D& &D=N) rj r r r. r@ rE rJ rY
skipUnlessrM namerQ rS rb rr rx rz r r r r r skipIfsysplatformr r r r r r r r& r r( r( 8 s
04
6
XG+-=> ?" $.L-6=
72D$ 7+34j X__S\\W,HJ2J2.4 X1@B B 8 X1@B B r& r( c e Zd Z ej dd ej ed ej d d Z y)ScalableSelectorMixInr zTest needs resource modulecpuc : t j t j \ }} t j t j ||f | j t j t j ||f t |d }|dz }| j }| j |j t |dz D ]W } | j \ }} |j t j |j t j Y |j' } | j/ |dz t1 | y # t t f$ r |}Y w xY w# t $ r | j d Y w xY w# t $ r4}|j" t" j$ k( r| j d d }~ww xY w# t $ rG}|j" t" j( k( r$t* j, dk( r| j d d }~ww xY w)Ni zFD limit reacheddarwinz%Invalid argument error calling poll())resource getrlimit
RLIMIT_NOFILE setrlimitr* minr r< r2 r r r. rl r3 r4 r5 rG errnoENOSPCr EINVALr r r8 ro )
r+ softhardNUM_FDSr? r r, r- efdss
r test_above_fd_setsizez+ScalableSelectorMixIn.test_above_fd_setsize s ''(>(>?
d x 5 5d| D OOH . .0F0F !4L
*$&G
2
MMO w!|$ A
2 --/B
2y 3 34
2y 4 45 & ((*C
A s3x0G $ G
2
01
2
77ell* MM"45
ww%,,&3<<8+C
EF sV A#E
E*!A F
$G
E'&E'*FF
G/GG
HAHHN)
rj r r r requires_mac_verrY r r requires_resourcer r r& r r r sS W b!$X#?@ W u%-1 & A %-1r& r c $ e Zd Zej Zy)DefaultSelectorTestCaseN)rj r r r4 DefaultSelectorr2 r r& r r r s
((Hr& r c $ e Zd Zej Zy)SelectSelectorTestCaseN)rj r r r4 SelectSelectorr2 r r& r r r s
''Hr& r re z!Test needs selectors.PollSelectorc e Zd Z eedd Zy)PollSelectorTestCasere Nrj r r getattrr4 r2 r r& r r r s
y.$7Hr& r rd z"Test needs selectors.EpollSelectorc & e Zd Z eedd Zd Zy)EpollSelectorTestCaserd Nc | j }t j 5 }| j t 5 |j |t j d d d | j t 5 |j | d d d d d d y # 1 sw Y AxY w# 1 sw Y xY w# 1 sw Y y xY wr )
r2 tempfileNamedTemporaryFiler; IOErrorr3 r4 r5 r= rW )r+ r? fs r test_register_filez(EpollSelectorTestCase.test_register_file s MMO
(
(
* a""7+
4
1i 2 23
4 ""8,
!
4
4
s: B4!B B49B( B4 B% !B4(B1 -B44B=)rj r r r r4 r2 r r r& r r r s
y/48H r& r KqueueSelectorz$Test needs selectors.KqueueSelector)c , e Zd Z eedd Zd Zd Zy)KqueueSelectorTestCaser Nc | j }t j }| j t 5 }|j |t j d d d | j j j t j | j t 5 |j | d d d y # 1 sw Y mxY w# 1 sw Y y xY wr )r2 r make_bad_fdr; r r3 r4 r5 r8 exceptionr EBADFr= rW )r+ r? bad_fcms r test_register_bad_fdz+KqueueSelectorTestCase.test_register_bad_fd s
MMO%%'
w
' 42
JJui 2 2 3 4 ++U[[9
x
(
IIe 4 4 s !C,CCC c | j }| j |j t }| j |j d g t }||z
}| j
d|cxk xr dk | y c | y )Nri r r )r2 r* r r r8 r r )r+ r? r r r s r test_empty_select_timeoutz0KqueueSelectorTestCase.test_empty_select_timeout, sn
MMO
V !b)
V
"W r(S("-("-r& )rj r r r r4 r2 r r r r& r r r s
y"2D9H
.r& r rf z$Test needs selectors.DevpollSelectorc e Zd Z eedd Zy)DevpollSelectorTestCaserf Nr r r& r r r : s
y"3T:Hr& r c , t j y r )r
reap_childrenr r& r tearDownModuler B s r& __main__))r rM r r4 r r
r testr test.supportr r r r rY
unittest.mockr r r ImportError
is_emscriptenis_wasiSkipTestr r AF_INET SOCK_STREAMr% r( r TestCaser r r r r r r r rj mainr r& r <module>r s
" & "
GOO
(
J
KK 6< ""J ..v/A/A &D D N 31 31l) 2H4E4E )
( 183D3D (
WY78:8/1F#,,8:8 WY89;
02G $ - -
;
WY(89;= . 13H % . . .= .> WY(9:;=; 24I & / /;=; zHMMO i Hs G G G