python (3.12.0)
ϑeF d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl
Z
d dl Z d dl Z d dl
Z
d dlZd dl mZ d dlmZ d dlmZmZ d dlZd dl mZ d dl mZ d dl mZ d dl mZ d d l mZ d d
l m Z d d l m Z d d l m!Z! d d
l m"Z" d Z# e#d Z$ e#d Z% e#d Z& e#d Z'dddddddddd d
Z(d Z)d d d!Z*d" Z+d# Z,e jZ fd$Z.d% Z/ G d& d'e Z0 G d( d)e Z1 G d* d+ Z2 G d, d-e2e1 Z3d.d/d0Z4 e5ed1 rc G d2 d3e jl e Z7 G d4 d5e7e Z8 G d6 d7e8 Z9 G d8 d9e2e9 Z:d: Z;ejx d; Z=ejx d.d/d< Z>ejx d=d d.d>d? Z?d@ Z@ejx d=d dAdB ZAdC ZB G dD dEej ZD G dF dGej ZFdH ZG G dI dJeH ZI G dK dL ZJdM ZK G dN dOe j ZLejx dP ZMej ej ej fdQZQy# e$ r dZY w xY w)R N)mock)
HTTPServer)WSGIRequestHandler
WSGIServer) base_events)events)format_helpers)futures)tasks)logger)support)
socket_helper)threading_helperc t t d rOt j j t j
| }t j j
| r|S t j j t j j t d| }t j j
| r|S t | )N
TEST_HOME_DIRz..)
hasattrr
ospathjoinr isfiledirname__file__FileNotFoundError)filenamefullnames K/BuggyBox/python/3.12.0/bootstrap/lib/python3.12/test/test_asyncio/utils.py data_filer ' s~ w(77<< 5 5x@
77>>( #Oww||BGGOOH 5tXFH ww~~h
H
%% z ssl_cert.pemz ssl_key.pemz keycert3.pemz pycacert.pem)z)http://testca.pythontest.net/testca/ocsp/)z0http://testca.pythontest.net/testca/pycacert.cer)z2http://testca.pythontest.net/testca/revocation.crl)) countryNameXY))organizationNamez Python Software Foundation CA))
commonNamez
our-ca-serverzOct 28 14:23:16 2037 GMTzAug 29 14:23:16 2018 GMTCB2D80995A69525C)r )) localityNamezCastle Anthrax))r" zPython Software Foundation))r# localhost))DNSr& )
OCSP caIssuerscrlDistributionPointsissuernotAfter notBefore serialNumbersubjectsubjectAltNameversionc t j t j } | j t t
d| _ t j | _ | S NF) ssl
SSLContextPROTOCOL_TLS_SERVERload_cert_chainONLYCERTONLYKEYcheck_hostname CERT_NONE verify_mode)server_contexts r simple_server_sslcontextr? I s@ ^^C$;$;<N""8W5$)N!!$ N r Tdisable_verifyc t j t j }d|_ | rt j |_ |S r4 )r5 r6 PROTOCOL_TLS_CLIENTr; r< r= )rA client_contexts r simple_client_sslcontextrE Q s3 ^^C$;$;<N$)N!%(]]" r c ( t y t d S )NTr@ )r5 rE r r dummy_ssl_contextrH Y s
{'t<<r c d } | }| j | }d|_ | j | |j y # |j w xY w)Nc K y wNrG rG r r oncezrun_briefly.<locals>.oncea s s F) create_task_log_destroy_pendingrun_until_completeclose)looprL gents r run_brieflyrT ` sN
&C A #A " s A Ac d}t j |d D ]> } | r y | j t j | t |dz d }@ t
j )NgMbP?F)error g ?)r
busy_retryrO r sleepmaxr
TimeoutError)rQ predtimeoutdelay_s r run_untilr` n sc E
u
5 % 6 E 23EAIs# % ""$$r c \ | j | j | j y rK ) call_soonstop run_forever)rQ s r run_oncere y s% NN499 r c e Zd Zd Zd Zy)SilentWSGIRequestHandlerc * t j S rK )ioStringIOselfs r
get_stderrz#SilentWSGIRequestHandler.get_stderr s {{} r c y rK rG )rl formatargss r log_messagez$SilentWSGIRequestHandler.log_message r N)__name__
__module__ __qualname__rm rq rG r r rg rg s
r rg c < e Zd Zej Z fdZd Z xZS )SilentWSGIServerc d t | \ }}|j | j ||fS rK super get_request
settimeoutrequest_timeoutrl request client_addr __class__s r r{ z SilentWSGIServer.get_request s4 $w 2 4 4//0 ##r c y rK rG rl r client_addresss r handle_errorz SilentWSGIServer.handle_error rr r ) rs rt ru r
LOOPBACK_TIMEOUTr} r{ r
__classcell__r s @r rw rw s ..O$
r rw c e Zd Zd Zy)SSLWSGIServerMixinc
t j t j }|j t t
|j
|d } | j ||| |j y # t $ r Y y w xY w)NT) server_side)
r5 r6 r7 r8 r9 r: wrap_socketRequestHandlerClassrP OSError)rl r r contextssocks r finish_requestz!SSLWSGIServerMixin.finish_request so
..!8!89 '2##G#> $ $UND A KKM s #A6 6 BBN)rs rt ru r rG r r r r s r r c e Zd Zy)
SSLWSGIServerNrs rt ru rG r r r r s r r F)use_sslc # K d fd}|r|n|} || t j | j _ t j
fd }|j
j j |j y # j j |j w xY ww)Nc 3 K t | d }|r4| d j t |d }| |t | z }|r3y y w)NCONTENT_LENGTHz
wsgi.inputi )intreadminlen)environsizedatas r rQ z _run_test_server.<locals>.loop sM 7+,-<(--c$.@ADJ CI D s AAAc F d}dg} ||| | d dk( r | S dgS )Nz200 OK)z Content-typez
text/plain PATH_INFOz/loops Test messagerG )r start_responsestatusheadersrQ s r appz _run_test_server.<locals>.app s: 12vw' ; 7 *= #$ $r c ( j d S )Ng?)
poll_interval)
serve_forever)httpds r <lambda>z"_run_test_server.<locals>.<lambda> s u***> r target)
rg set_appserver_addressaddress threadingThreadstartshutdown server_closer ) r r
server_clsserver_ssl_clsr server_class
server_threadr rQ s @@r _run_test_serverr s % &->*L ": ;E MM#((EM $$>@M
s A'C,B! 01C!2CCAF_UNIXc e Zd Zd Zy)UnixHTTPServerc ^ t j j | d| _ d| _ y )N 127.0.0.1P ) socketserverUnixStreamServer server_bind server_name server_portrk s r r zUnixHTTPServer.server_bind s& ) ) 5 5d ; *D !D r N)rs rt ru r rG r r r r s "r r c < e Zd Zej Zd Z fdZ xZS )UnixWSGIServerc N t j | | j y rK )r r
setup_environrk s r r zUnixWSGIServer.server_bind s & &t , r c d t | \ }}|j | j |dfS )N)r ry r~ s r r{ zUnixWSGIServer.get_request s7 #(7#6#8 G[ t 3 3 4 -- -r ) rs rt ru r
r r} r r{ r r s @r r r s !22 ! . .r r c e Zd Zd Zy)SilentUnixWSGIServerc y rK rG r s r r z!SilentUnixWSGIServer.handle_error s r N)rs rt ru r rG r r r r s r r c e Zd Zy)UnixSSLWSGIServerNr rG r r r r s r r c * t j S rK )r create_unix_domain_namerG r r gen_unix_socket_pathr s 4466r c # K t } | t j | y # t $ r Y y w xY w# t j | w # t $ r Y w w xY wxY wwrK )r r unlinkr )r s r unix_socket_pathr s[ #% J
$
$
sR A"8 ) A" 5A"5A"A AA A A A A A"c # K t 5 }t || t t E d { d d d y 7
# 1 sw Y y xY wwN)r r r r )r r r r )r r s r run_test_unix_serverr sR
J4'g3G7HJ
J
J J J
J J Js$ A868 A8AAr hostportr c # R K t | |f|t t E d { y 7 wr )r rw r r s r run_test_serverr s& t g+;/<> > >s '%'c ~ | j d \ }}|dk( r| j y | j || =)Ni STOP)recvfromrP sendto)sockr addrs r echo_datagramsr s=
]]4(
d 7? JJL KKd #
r )r r c # K t j | |t j }|d \ }}}}}t j ||| j | |f t j
fd }|j
j j d j |j y # j d j |j w xY ww)N)typer c t S rK )r )r s r r z%run_udp_echo_server.<locals>.<lambda>+ s ^D-A r r r )
socket getaddrinfo
SOCK_DGRAMbindr r r getsocknamer r )
r r addr_infofamilyr protor_ sockaddrthreadr s
@r run_udp_echo_serverr % s ""4F4E4EFI'0|$FD%H ==u -DIItTl
%A
BF
LLN GT - - /0
GT - - /0
s BD C 1D 2C>>Dc i }t | D ]4 }|j d r|j d r&t d ||< 6 t d| f| j
z | S )N__) return_value TestProtocol)dir
startswithendswith MockCallbackr __bases__)basedctnames r make_test_protocolr 4 sc
CD 4 ??4 T]]4%8 d3D 4
?4$.. 8# > @@r c , e Zd Zd ZddZd Zd Zd Zy) TestSelectorc i | _ y rK keysrk s r __init__zTestSelector.__init__@ s r Nc T t j |d|| }|| j |< |S )Nr ) selectors SelectorKeyr )rl fileobjr r keys r registerzTestSelector.registerC s+ ##GQ= '
r c 8 | j j | S rK )r pop)rl r
s r
unregisterzTestSelector.unregisterH s yy}}W%%r c g S rK rG )rl r] s r selectzTestSelector.selectK s r c | j S rK r rk s r get_mapzTestSelector.get_mapN s yyr rK )rs rt ru r r r r r rG r r r r > s
&r r c e Zd Z d fd Zd Zd Z fdZd Zd Zd Z d Z
d
Z d Z d Z
d
Zd Zd Zd Zd Zd Z fdZdd fd
Zd Zd Z xZS )TestLoopNc B t | | d }d| _ nd| _ | | _ t | j d| _ d| _ g | _ t | _ i | _
i | _ | j t j | _ y )Nc 3 K d y wrK rG rG r r rR z TestLoop.__init__.<locals>.geni s s FTr g& .>)rz r _check_on_close_gennext_time_clock_resolution_timersr _selectorreaderswritersreset_countersweakrefWeakValueDictionary _transports)rl rR r s r r zTestLoop.__init__e s
;
#(D #'D E TYY
!% % "668r c | j S rK r rk s r timez
TestLoop.time| s zzr c 6 |r| xj |z
c_ y y rK r& )rl advances r advance_timezTestLoop.advance_time s % JJ' !J r c t | | j r' | j j d t d y # t $ r Y y w xY w)Nr z Time generator is not finished)rz rP r r sendAssertionError
StopIteration)rl r s r rP zTestLoop.close sR
G q! %%EFF
!
s A AAc N t j ||| d | j |< y rK )r Handler rl fdcallbackrp s r _add_readerzTestLoop._add_reader !==4tD Rr c j | j |xx dz
cc< || j v r| j |= yyN TF)remove_reader_countr rl r2 s r _remove_readerzTestLoop._remove_reader 6 $)$
R r c || j vrt d| d | j | }|j |k7 rt d|j d| |j |k7 rt d|j d| y )Nfd is not registeredzunexpected callback: != zunexpected callback args: )r r- _callback_argsrl r2 r3 rp handles r
assert_readerzTestLoop.assert_reader s
T\\ ! 3rd*<!=> > b! x ' '(8(8'9hZHJ
J <<4 ,V\\N$tfEG
G r c > || j v rt d| d y )Nr> z is registered)r r- r: s r assert_no_readerzTestLoop.assert_no_reader s'
3rd.!9: : r c N t j ||| d | j |< y rK )r r0 r r1 s r _add_writerzTestLoop._add_writer r5 r c j | j |xx dz
cc< || j v r| j |= yyr7 )remove_writer_countr r: s r _remove_writerzTestLoop._remove_writer r< r c || j vrt d| d | j | }|j |k7 rt |j d| |j |k7 rt |j d| y )Nr> r? r@ )r r- rA rB rC s r
assert_writerzTestLoop.assert_writer s
T\\ ! 3rd*<!=> > b! x ' F$4$4#7tH<!HI I <<4 FLL#34x!@A A r c 0 t |t s t |j } | j | }t dj
|| # t t t
f$ r t dj
| d w xY w# t $ r Y y w xY w)NzInvalid file object: {!r}z.File descriptor {!r} is used by transport {!r})
isinstancer filenoAttributeError TypeError
ValueErrorro r$ RuntimeErrorKeyError)rl r2 transports r _ensure_fd_no_transportz TestLoop._ensure_fd_no_transport s "c"
>%
$ ((,I @GG #$
$ #Iz:
> "((.r
49=>
> s A B 0B BBc N | j | | j ||g| S rK )rX r4 r1 s r
add_readerzTestLoop.add_reader s- $ $$R( t H4t44r c H | j | | j | S rK )rX r; r: s r
remove_readerzTestLoop.remove_reader $ ' $$R(""2&&r c N | j | | j ||g| S rK )rX rI r1 s r
add_writerzTestLoop.add_writer s- % $$R( t H4t44r c H | j | | j | S rK )rX rL r: s r
remove_writerzTestLoop.remove_writer r] r c | t j t | _ t j t | _ y rK ) collections defaultdictr r9 rK rk s r r! zTestLoop.reset_counters s( #.#:#:3#? #.#:#:3#? r c t | | j D ]. }| j j | }| j | 0 g | _ y rK )rz _run_oncer r r, r* )rl whenr) r s r rf zTestLoop._run_once sJ
LL 'DiinnT*G g & ' r )r c b | j j | t | ||g|d|iS )Nr )r appendrz call_at)rl rg r3 r rp r s r rj zTestLoop.call_at s0 D!wtXFFgFFr c y rK rG )rl
event_lists r _process_eventszTestLoop._process_events s r c y rK rG rk s r _write_to_selfzTestLoop._write_to_self rr r rK )rs rt ru r r' r* rP r4 r; rE rG rI rL rN rX rZ r\ r_ ra r! rf rj rm ro r r s @r r r R s} $9."
GE G;EB$"5
'
5
'
@ 6: G
r r c 2 t j dddgi| S )Nspec__call__rG )r Mock)kwargss r r r s 99 1:, 1& 11r c e Zd Z d Zy) MockPatternc p t t j t | |t j S rK )boolresearchstrSrl others r __eq__zMockPattern.__eq__ s" BIIc$i566r N)rs rt ru r rG r r rv rv s 7r rv c e Zd Zd Zd Zy)MockInstanceOfc || _ y rK )_type)rl r s r r zMockInstanceOf.__init__ s
r c . t || j S rK )rP r r} s r r zMockInstanceOf.__eq__ s %,,r N)rs rt ru r r rG r r r r s -r r c P t j | }|t d| |S )Nz unable to get the source of )r _get_function_sourcerT )funcsources r get_function_sourcer s*
0
0
6F
~TCDD Mr c < e Zd Zed ZdddZd dZd Zd Zy)
TestCasec r | j L| j s | j | j n | j j d | j t
j }| t j 5 t j dt |j }d d d t t j r;t! |j" j% }|D ] }|j' y y y # 1 sw Y `xY w# t( $ r Y y w xY w)NT)waitignore)_default_executor is_closedrO shutdown_default_executorr rP r
maybe_get_event_loop_policywarningscatch_warnings simplefilterDeprecationWarningget_child_watcherrP asyncioThreadedChildWatcherlist_threadsvaluesr NotImplementedError)rQ policywatcherthreadsr s r
close_loopzTestCase.close_loop s ! ! ->>#''(F(F(HI&&//T/:
446
& ,,. 9 ))(4FG $ 6 6 8G9 gw'C'CD "7#3#3#:#:#< =G") &
& E 9 9 '
s* D* +D ?D* D'#D* * D65D6T)cleanupc | t d t j d |r | j | j | y y )Nz loop is None)r- r set_event_loop
addCleanupr )rl rQ r s r r zTestCase.set_event_loop/ s: < 0 0 d# OODOOT 2 r Nc > t | }| j | |S rK )r r )rl rR rQ s r
new_test_loopzTestCase.new_test_loop7 s } D! r c 6 t j | _ y rK )r threading_setup_thread_cleanuprk s r setUpzTestCase.setUp< s / ? ? A r c t j d | j t j | j t
j | j t j y rK ) r r assertIsNonesys exception
doCleanupsr threading_cleanupr r
reap_childrenrk s r tearDownzTestCase.tearDown? sP d#
#--/* **D,@,@A r rK ) rs rt ru staticmethodr r r r r rG r r r r s. & &, /3 3
B r r c # K t j } t j t j dz d t j | y # t j | w xY ww)Nr8 )r levelsetLevelloggingCRITICAL) old_levels r disable_loggerr K sM I#((*+
" "s A/*A A/A,,A/c t j t j }| |_ ||_ ||_ d|j _ |S )Ng )r MagicMockr r r r
gettimeoutr )r r r r s r mock_nonblocking_socketr Y s= 1 >>&-- (DDJDIDK#&DOO Kr )Rr rc
contextlibri r r ry r r r r r unittestr" r r http.serverr wsgiref.simple_serverr r r5 ImportErrorr r r r
r asyncio.logr testr
test.supportr r r r9 r: SIGNED_CERTFILE
SIGNING_CAPEERCERTr? rE rH rT
SHORT_TIMEOUTr` re rg rw r r r r r r r r r r contextmanagerr r r r r r BaseSelectorr
BaseEventLoopr r r{ rv r r r r IPPROTO_TCP SOCK_STREAMAF_INETr rG r r <module>r s
" @ " & )& ^ $
M
"N+
~
&
:F T0 ++&- . & 04 = #*"7"7 %
1
z
& &(8 */ F 69 " 66
". .(~
.0D
7 (- J J 'a > > $ +! A9)) (b
{(( b
J2
7#
7- -1 x 1 h
#
# #)"4"46;M;M#)>>A
Cs I I I 
Browse
Usage
Versions