python (3.12.0)
ϑeF d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl
Z
ddl Z ddl Z ddl
Z
ddlZddlZddl
mZ ddlmZ ddlmZmZ ddlZddlmZ ddlmZ ddlmZ dd lmZ dd
lm Z dd l m Z dd l m Z dd
l!m"Z" ddl!m#Z# d Z$ e$d Z% e$d Z& e$d Z' e$d Z(ddddddddd d d
Z)d Z*d d!d"Z+d# Z,d$ Z-e j\ fd%Z/d& Z0 G d' d(e Z1 G d) d*e Z2 G d+ d, Z3 G d- d.e3e2 Z4d/d0d1Z5 e6e d2 rc G d3 d4e
jn e Z8 G d5 d6e8e Z9 G d7 d8e9 Z: G d9 d:e3e: Z;d; Z<ejz d< Z>ejz d/d0d= Z?ejz d>dd/d?d@ Z@dA ZAejz d>ddBdC ZBdD ZC G dE dFej ZE G dG dHej ZGdI ZH G dJ dKeI ZJ G dL dM ZKdN ZL G dO dPe
j ZMejz dQ ZNe j e j e j fdRZRy# e$ r dZY w xY w)SzUtilities shared by tests. 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 Z | j | j | j y)zLegacy API to run once through the event loop.
This is the recommended pattern for test code. It will poll the
selector once and run all callbacks scheduled in response to I/O
events.
N) 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 ZdZd fd Zd Zd Z fdZd Zd Z d Z
d
Z d Z d Z
d
Zd Zd Zd Zd Zd Zd Z fdZdd fd
Zd Zd Z xZS )TestLoopa Loop for unittests.
It manages self time directly.
If something scheduled to be executed later then
on next loop iteration after all ready handlers done
generator passed to __init__ is calling.
Generator should be like this:
def gen():
...
when = yield ...
... = yield time_advance
Value returned by yield is absolute time of next scheduled handler.
Value passed to yield is time advance to move loop's time forward.
Nc 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 4 |r| xj |z
c_ yy)zMove test time forward.Nr& )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 L | j | | j ||g| S )zAdd a reader callback.)rX r4 r1 s r
add_readerzTestLoop.add_reader * $$R( t H4t44r c F | j | | j | S )zRemove a reader callback.)rX r; r: s r
remove_readerzTestLoop.remove_reader ! $$R(""2&&r c L | j | | j ||g| S )zAdd a writer callback..)rX rI r1 s r
add_writerzTestLoop.add_writer r[ r c F | j | | j | S )zRemove a writer callback.)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 rg zTestLoop._run_once sJ
LL 'DiinnT*G g & ' r )r c b | j j | t | ||g|d|iS )Nr )r appendrz call_at)rl rh r3 r rp r s r rk 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 __doc__r r' r* rP r4 r; rE rG rI rL rN rX rZ r] r` rb r! rg rk rn rp 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 ZdZd Zy) MockPatternzA regex based str with a fuzzy __eq__.
Use this helper with 'mock.assert_called_with', or anywhere
where a regex comparison between strings is needed.
For instance:
mock_call.assert_called_with(MockPattern('spam.*ham'))
c p t t j t | |t j S rK )boolresearchstrSrl others r __eq__zMockPattern.__eq__ s" BIIc$i566r N)rs rt ru rq r rG r r rx rx s 7r rx 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)zrContext manager to disable asyncio logger.
For example, it can be used to ignore warnings in debug mode.
r8 N)r levelsetLevelloggingCRITICAL) old_levels r disable_loggerr K sH I#((*+
" "s A.*A A.A++A.c t j t j }| |_ ||_ ||_ d|j _ |S )z'Create a mock of a non-blocking socket.g )r MagicMockr r r r
gettimeoutr )r r r r s r mock_nonblocking_socketr Y s< >>&-- (DDJDIDK#&DOO Kr )Srq r rd
contextlibri r r r{ 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} rx 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