python (3.11.7)
Browse
Usage
Versions
eN 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 dlZn
# e$ r dZY nw xY wej sej r ej d eed rej Znej ej d fd Zd
Z G d d Z G d
d Z G d de ej Z G d de ej Z ej! eed d G d de e ej Z" ej! eed d G d de e ej Z# ej! eed d G d d e e ej Z$ ej! eed d G d! d"e e ej Z%d# Z&e'd$k r ej( dS dS )% N)support) os_helper)
socket_helper)sleep) monotonicz,Cannot create socketpair on Emscripten/WASI.
socketpairc $ t j | || 5 }| t j df | t j | || } | | | } | \ }}||k r||fcd d d S | B# t $ r | w xY w# 1 swxY w Y d S )Nr )
socketbindr HOSTlistenconnect getsocknameacceptcloseOSError)familytypeprotolccaddraaddrs G/BuggyBox/python/3.11.7/bootstrap/lib/python3.11/test/test_selectors.pyr r sD
]64
/
/ 1
FFM&* + + +
HHJJJ
fdE22A
!--//***
hhjjGAtu}} !t GGIII
s+ A D$A C"
C"" DDD D c X g }| D ]$\ }}||z r| |j %|S N)appendfileobj)readyflagmatchkeyeventss r find_ready_matchingr% 0 s@ 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 Zd Z ej ej dk d d Zd Z ej e e d d d Z ej e e d d d Z dS ) BaseSelectorTestCasec t \ }}| |j | |j ||fS r )r
addCleanupr )selfrdwrs r make_socketpairz$BaseSelectorTestCase.make_socketpair: s@ B !!! !!!2v
r& c | }| |j | \ }}| |t
j d }| |t
j | |j
| | |j | | |j
t
j | |j d | t |j dd | t |j dt
j | t" |j |t
j | t" |j | t
j d S )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@ sn MMOO %%''BjjY 16:: c9#8999 b))) --- Y%9::: 6***
*aj!V<<<
*aj#y7KLLL
(AJI4HIII
(AJ #. 0 0 0 0 0r& c ~ | }| |j | \ }}| |t
j | | | t |j d | t |j | d S Nr1 )
r2 r* r r. r3 r4 r5
unregisterr; r= r+ r? r, r- s r test_unregisterz$BaseSelectorTestCase.test_unregisterZ s MMOO %%''B
2y+,,, R
(AL&999
(AL"55555r& c | }| |j | \ }}| | }}| |t j | |t j | | | | | | d S 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 MMOO %%''Byy{{BIIKK1
1i*+++
1i+,,,
Q Qr& posixzrequires posixc N | }| |j | \ }}| | }}| |t j | |t j | \ }}| | t j
| | t j
| | | t j | | t j | | | | | d S 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 s0 MMOO %%''Byy{{BIIKK1
1i*+++
1i+,,,''))S
a
a !$$$ !$$$ Q Qr& c | }| |j | \ }}| |t
j | |t
j | | | | | | d S r ) r2 r* r r. r3 r4 r5 rG rC rD s r "test_unregister_after_socket_closez7BaseSelectorTestCase.test_unregister_after_socket_close s MMOO %%''B
2y+,,,
2y,---
R Rr& c N | }| |j | \ }}| |t
j }| |t
j }| |j
|j
| || | |
| t }t }| |t
j | }| |t
j | }| |j
|j
| |j |j | || | | |j | | t" |j dt
j t }t$ j |_ t$ j |_
| |t
j | | |j j | |j
j d S 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 MMOO %%''BjjY 122 xxI 122 CJ 444 qyy}}--- R XX
XXjjY 1266xxI 0"55 T[111 CHdi000 qyy}}--- B'''
(AHfi6JKKK XX ]''))
}))++ Y)2... *+++ ,-----r& c | j j dk r t j d }nu| j j dk r t j d }nE| j j dk r t j d }n| d |5 }t j t |j _ | }|
|j | \ }}|
|t j | t# |j d | t 5 | |t j d d d n # 1 swxY w Y | t# |j d
d d d d S # 1 swxY w Y d S ) 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 s2 = !_ 4 4 M''79 9EE
]
#~
5
5 M''68 8EE
]
#'8
8
8 M''9; ;EE --## #
-a$,M$6$6 - %7 %/ %/AN !
A OOAG $ $ $))++FB
JJr9/ 0 0 0 S[[! , , ,""#455
4
4Y 2333
4
4
4
4
4
4
4
4
4
4
4
4
4
4
4 S[[! , , ,
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-s7 (CG,?!F, G,,F0 0G,3F0 4+G,,G03G0c h | }| |j | }| \ }}| |t j | |t j | | t |j | | t |j | | t |j
| | t |j
| d S 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 MMOO ))++%%''B
2y+,,,
2y,--- , 2666 , 2666 (G$7<<< (G$7<<<<<r& c f | }| |j | \ }}| |t
j d }| || | | t |j d d S )Nr0 r1 ) r2 r* r r. r3 r4 r5 r8 rW r; r= r> s r test_get_keyz!BaseSelectorTestCase.test_get_key s MMOO %%''BjjY 16:: aiimm,,,
(AIv66666r& c | }| |j | \ }}| }| | | t | d | t | g | |t j d }| || | ||| | t | d | t | |
g | t | |g | t 5 |d d d d n # 1 swxY w Y | t" 5 ||= d d d d S # 1 swxY w Y d S )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 s6 MMOO %%''Byy{{ TA&&& dR(((jjY 16::
b$ d2h''' TA&&& dbiikk]333 dkkmm,,se444
x
(
( LL
y
)
) R s$ 1 GG
G
+G<<H H c r | }| |j | \ }}| |t
j | |t
j }| }|D ]w\ }}| t |t
j | | | |t
j t
j z z x|
|t
j fg| d S 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 MMOO %%''B
2y+,,,B 566! @ @KC OOJsI,A B B C C C OOF # # # V (<(1(=)> '? ?
@
@
@
@
69#89:FCCCCCr& c n | }| |j | \ }}| d | |t j t j z }d\ }}| }|
t | d |D ]\ }} | t |t j | || | | t j t j z z | t j z r| | d}| t j z r| | d}| | | | d S )Ns foo)FF T)r2 r* r r. sendr3 r4 r5 rG r assertLessEqualro r r r7 r8 r\ )
r+ r? sock1sock2my_key seen_read
seen_writer r# r$ s
r test_select_read_writez+BaseSelectorTestCase.test_select_read_write s
MMOO ++-- u
6E9#7):O#OPP , :
S[[!,,,!
"
"KC OOJsI,A B B C C C S& ) ) ) V (<(1(=)> '? ?
@
@
@ ,,
! +++ --
" ,,, !
"""
#####r& c | }| |j | \ }}|5 }| |t
j | |t
j d d d n # 1 swxY w Y | t |j
| | t |j
| d S r ) r2 r* r r. r3 r4 r5 rG r; ru rW )r+ r? r, r- sels r test_context_managerz)BaseSelectorTestCase.test_context_manager7 s MMOO %%''B
4# LLY 1 2 2 2 LLY 2 3 3 3 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4
, 2666 , 266666s ABB Bc * | }| |j t |d rT| }| t
|t | |d d S d S )Nr: r ) r2 r* r hasattrr: r r intassertGreaterEqual)r+ r? r9 s r test_filenoz BaseSelectorTestCase.test_filenoD s MMOO 1h +B OOJr3 / / 0 0 0 # #B * * * * * + +r& c < | }| |j d}d}t | }g }g }i }i }t | D ]} | \ }
} | |
t j | | t j |
|
|
| | ||
< |
|| < g } |r| }
t |
t j }|s|
d t j | } | | t d D ]C} | }
t |
t j }|r n%t# d D|
d | || g| |d }
|
| }| t | | |
| | ||
| |
| ||
|| | |g|z d S )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% failrandomchoicer r r8 recvrC remove)r+ r? NUM_SOCKETSMSGMSG_LENreaderswritersr2ww2rir, r- bufsr
ready_writers
ready_readersbufs r
test_selectorz"BaseSelectorTestCase.test_selectorM s MMOO !c(({## A))++FB
JJr9/ 0 0 0
JJr90 1 1 1 NN2 NN2 CGCGG $HHJJE /y7L M MM
: 8999 }--B GGCLLL2YY
:
:
3E4=4H!J !J
E c
8999 c"gY
6 6 6 q!B'''""C SXXw / / / KK
LLR ! ! !
LL NN3r7 # # #5 $8
u{ 233333r& win32z1select.select() cannot be used with empty fd setsc | }| |j | | d g d S )Nr )timeout)r2 r* r r8 r )r+ r? s r test_empty_selectz&BaseSelectorTestCase.test_empty_select sO
MMOO !,,b11111r& c X | }| |j | \ }}| |t
j t }| dt |
d | dt |
d | t |z
d | | | |t
j
t }| |
d | |
d | t |z
d t }| |
d t }||z
}| d|cxk odk nc | d S )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_timeout s MMOO %%''B
2y,--- FF C , ,--- C - -...
C((( R
2y+,,, FF !%%% " &&&
C(((
VV !%%%
VV
"W r((((S(((("-----r& alarmz%signal.alarm() required for this testc | }| |j | \ }} G d dt fd}t j t
j | }| t
j t
j | t j d | |t j
t }| 5 |
d d d d n # 1 swxY w Y | t |z
d t j d d S # t j d w xY w)Nc e Zd ZdS )GBaseSelectorTestCase.test_select_interrupt_exc.<locals>.InterruptSelectN)rj
__module__ __qualname__ r& r InterruptSelectr s Dr& 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
MMOO %%''B i " " " " " #M&.' B B
v~7HIII LOOO
JJr9/ 0 0 0A""?33
OODFFQJ , , , LOOOOOFLOOOOs1 *AE) D# E) #D''E) *D'+(E) )E?c | }| |j | \ }}t j t j d }| t j t j | t j d | |t j t }| | d |
t |z
d t j d d S # t j d w xY w)Nc d S 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
MMOO %%''B "M&.:L:L M M
v~7HIII LOOO
JJr9/ 0 0 0A
QXXc]] + + + # #DFFQJ 4 4 4 LOOOOOFLOOOOs
BD7 7E
N) rj r r r. r@ rE rJ rY
skipUnlessrM namerQ rS rb rr rx rz r r r r r r skipIfsysplatformr r r r r r r r& r r( r( 8 s 0 0 04
6
6
6
XG+-=>> ?>" $. $. $.L- - -6= = =
7
7
7 2D D D$$ $ $: 7 7 7+ + +34 34 34j X_S\W,HJ J2 2J J2. . .4 X11@B B B B 8 X11@B B B B r& r( c e Zd Z ej dd ej ed ej d d Z dS )ScalableSelectorMixInr zTest needs resource modulecpuc T t j t j \ }} t j t j ||f | t j t j ||f t |d }n# t t f$ r |}Y nw xY w|dz }| }| |j t |dz D ]} | \ }}n%# t $ r | d Y nw xY w |
|t j |
|t j # t $ r0}|j t" j k r| d d }~ww xY w | } nM# t $ r@}|j t" j k r%t* j dk r| d d }~ww xY w| |dz t1 | d S )Ni r 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 5d| D D D OOH .0F !4L
*
*
*$&&GG$ GGG 2
MMOO w!|$$ A
2 --//BB
2
2
2
011111
2
2y 3444
2y 45555
7el** MM"4555
((**CC w%,&&3<8+C+C
EFFF
A s3xx00000sU A B BB#C;; D D !A E""
F ,+FF F5 5
G??;G::G?N)
rj r r r requires_mac_verrY r r requires_resourcer r r& r r r ss W b!$$X#?@@ W u%%-1 -1 &% A@ %$-1 -1 -1r& r c e Zd Zej ZdS )DefaultSelectorTestCaseN)rj r r r4 DefaultSelectorr2 r r& r r r s (HHHr& r c e Zd Zej ZdS )SelectSelectorTestCaseN)rj r r r4 SelectSelectorr2 r r& r r r s 'HHHr& r re z!Test needs selectors.PollSelectorc ( e Zd Z eedd ZdS )PollSelectorTestCasere Nrj r r getattrr4 r2 r r& r r r s#
wy.$77HHHr& r rd z"Test needs selectors.EpollSelectorc . e Zd Z eedd Zd ZdS )EpollSelectorTestCaserd Nc | }t j 5 }| t 5 | |t j d d d n # 1 swxY w Y | t 5 | | d d d n # 1 swxY w Y d d d d S # 1 swxY w Y d S r )
r2 tempfileNamedTemporaryFiler; IOErrorr3 r4 r5 r= rW )r+ r? fs r test_register_filez(EpollSelectorTestCase.test_register_file+ sy MMOO
(
*
* a""7++
4
4
1i 2333
4
4
4
4
4
4
4
4
4
4
4
4
4
4
4 ""8,,
!
sY C!A0$ C0A4 4C7A4 8 CB7+ C7B; ;C>B; ?CCC)rj r r r r4 r2 r r r& r r r $ s8
wy/488H r& r KqueueSelectorz$Test needs selectors.KqueueSelector)c 4 e Zd Z eedd Zd Zd ZdS )KqueueSelectorTestCaser Nc | }t j }| t 5 }| |t j d d d n # 1 swxY w Y | |j j
t j | t 5 |
| d d d d S # 1 swxY w Y d S r )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= sC
MMOO%''
w
'
' 42
JJui 2 3 3 3 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 +U[999
x
(
(
IIe s$ !A//A36A3>C!!C%(C%c > | }| |j t }| | d g t }||z
}| d|cxk odk nc | d S )Nri r r )r2 r* r r r8 r r )r+ r? r r r s r test_empty_select_timeoutz0KqueueSelectorTestCase.test_empty_select_timeoutI s
MMOO
VV !b)))
VV
"W r((((S(((("-----r& )rj r r r r4 r2 r r r r& r r r 6 sH
wy"2D99H
. . . . .r& r rf z$Test needs selectors.DevpollSelectorc ( e Zd Z eedd ZdS )DevpollSelectorTestCaserf Nr r r& r r r W s$
wy"3T::HHHr& r c , t j d S r )r
reap_childrenr r& r tearDownModuler _ 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
" " " " " " & & & & & & " " " " " "OOOO HHH LGO L
(
J
K
KK 76< "JJ .v/A & a a a a a a a a H
31 31 31 31 31 31 31 31l) ) ) ) ) 2H4E ) ) )
( ( ( ( ( 183D ( ( (
WWY778: :8 8 8 8 8/1F#,8 8: :8 WWY889; ;
02G $ -
; ;
WWY(899;= = . . . . . 13H % . . .= = .> WWY(9::;= =; ; ; ; ; 24I & /; ;= =; zHMOOOOO s A
AA