python (3.11.7)
eI d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl
Z
ddl Z ddl Z ddl
Z
ddlZddlZddlZddlmZ ddlmZ ddlmZmZ ddlZn
# e$ r dZY nw xY wddlmZ ddlmZ ddlmZ dd lm Z dd
lm Z dd l m Z dd l m!Z! dd
l"m#Z# dZ$d Z% e%dd Z& e%dd Z' e%dd Z( e%dd Z)dddddddd d d d
Z*d Z+d!d"d#Z,d$ Z-d% Z.e!j/ fd&Z0d' Z1 G d( d)e Z2 G d* d+e Z3 G d, d- Z4 G d. d/e4e3 Z5d0d1d2Z6 e7e d3 rf G d4 d5e
j8 e Z9 G d6 d7e9e Z: G d8 d9e: Z; G d: d;e4e; Z<d< Z=ej> d= Z?ej> d0d1d> Z@ej> d?dd0d@dA ZAdB ZBej> d?ddCdD ZCdE ZD G dF dGejE ZF G dH dIejG ZHdJ ZI G dK dLeJ ZK G dM dN ZLdO ZM G dP dQejN ZNej> dR ZOe jP e jQ e jR fdSZSdT ZTdS )UzUtilities shared by tests. N)mock)
HTTPServer)WSGIRequestHandler
WSGIServer) base_events)events)format_helpers)futures)tasks)logger)support)threading_helper皙?c t t d rBt j j t j g| R }t j | r|S t j j t j t dg| R }t j | r|S t t j | )N
TEST_HOME_DIRz..)
hasattrr
ospathjoinr isfiledirname__file__FileNotFoundError)filenamefullnames K/BuggyBox/python/3.11.7/bootstrap/lib/python3.11/test/test_asyncio/utils.py data_filer . s w(( 7< 5AAAA
7>>( # # Ow|BGOOH 5 5tGhGGGH w~~h
BGLL 2 2
3
33 certdataz 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 } | t t
d| _ t j | _ | S NF) ssl
SSLContextPROTOCOL_TLS_SERVERload_cert_chainONLYCERTONLYKEYcheck_hostname CERT_NONE verify_mode)server_contexts r simple_server_sslcontextr@ P sB ^C$;<<N""8W555$)N!!$ N r Tdisable_verifyc v t j t j }d|_ | rt j |_ |S r5 )r6 r7 PROTOCOL_TLS_CLIENTr< r= r> )rB client_contexts r simple_client_sslcontextrF X s4 ^C$;<<N$)N! 3%(]" r c 4 t d S t d S )NTrA )r6 rF r r dummy_ssl_contextrI ` s
{t't<<<<r c d } | }| | }d|_ | | | d S # | w xY w)Nc
K d S NrH rH r r oncezrun_briefly.<locals>.onceh s r F) create_task_log_destroy_pendingrun_until_completeclose)looprM gents r run_brieflyrU g su
$&&C A #A """ s A A,c t j |z } | sd|/|t j z
}|dk rt j | t j d | bd S d S )Nr gMbP?)time monotonicr
TimeoutErrorrP r sleep)rR predtimeoutdeadlines r run_untilr^ u s ~ ')Hdff 4 !1!11G!|| *,,, E 2 2333 dff 4 4 4 4 4r c b | | j | dS )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)rR s r run_oncerc s0 NN49 r c e Zd Zd Zd ZdS )SilentWSGIRequestHandlerc ( t j S rL )ioStringIOselfs r
get_stderrz#SilentWSGIRequestHandler.get_stderr s {}} r c d S rL rH )rj formatargss r log_messagez$SilentWSGIRequestHandler.log_message r N)__name__
__module__ __qualname__rk ro rH r r re re s2
r re c 2 e Zd Zej Z fdZd Z xZS )SilentWSGIServerc t \ }}| | j ||fS rL super get_request
settimeoutrequest_timeoutrj request client_addr __class__s r ry z SilentWSGIServer.get_request s? $ww 2 2 4 4 4/000 ##r c d S rL rH rj r} client_addresss r handle_errorz SilentWSGIServer.handle_error rp r ) rq rr rs r
LOOPBACK_TIMEOUTr{ ry r
__classcell__r s @r ru ru sO .O$ $ $ $ $
r ru c e Zd Zd ZdS )SSLWSGIServerMixinc * t j t j }| t t
| |d } | ||| | d S # t $ r Y d S w xY w)NT) server_side)
r6 r7 r8 r9 r: r; wrap_socketRequestHandlerClassrQ OSError)rj r} r contextssocks r finish_requestz!SSLWSGIServerMixin.finish_request s
.!899 '222##G#>> $ $UND A A A KKMMMMM DD s +B
BBN)rq rr rs r rH r r r r s# r r c e Zd ZdS )
SSLWSGIServerNrq rr rs rH r r r r s Dr r F)use_sslc # K d fd}|r|n|} || t | j _ t j fd }| V | d S # | w xY w)Nc 3 K t | d }|rC| d t |d }|V |t | z }|Ad S d S )NCONTENT_LENGTHz
wsgi.inputi )intreadminlen)environsizedatas r rR z _run_test_server.<locals>.loop sz 7+,-- <(--c$.@.@AADJJJ CII D r c Z d}dg} ||| | d dk r | S dgS )Nz200 OK)z Content-typez
text/plain PATH_INFOz/loops Test messagerH )r start_responsestatusheadersrR s r appz _run_test_server.<locals>.app sI 12vw''' ; 7 * *4== #$ $r c 0 d S )Nr )
poll_interval)
serve_forever)httpds r <lambda>z"_run_test_server.<locals>.<lambda> s u***>> r target)
re set_appserver_addressaddress threadingThreadstartshutdown server_closer ) r r
server_clsserver_ssl_clsr server_class
server_threadr rR s @@r _run_test_serverr s+ % % % % % &-<>>*L L": ; ;E MM#(EM $>>>>@ @ @M
s 2B4 4>C2AF_UNIXc e Zd Zd ZdS )UnixHTTPServerc ` t j | d| _ d| _ d S )N 127.0.0.1P ) socketserverUnixStreamServer server_bind server_name server_portri s r r zUnixHTTPServer.server_bind s/ ) 5 5d ; ; ; *D !D r N)rq rr rs r rH r r r r s# " " " " "r r c 2 e Zd Zej Zd Z fdZ xZS )UnixWSGIServerc b t | | d S rL )r r
setup_environri s r r zUnixWSGIServer.server_bind s. & &t , , , r c t \ }}| | j |dfS )N)r rw r| s r ry zUnixWSGIServer.get_request sB #(77#6#6#8#8 G[ t 3 4 4 4 -- -r ) rq rr rs r
r r{ r ry r r s @r r r sO !2 ! ! ! . . . . . . . . .r r c e Zd Zd ZdS )SilentUnixWSGIServerc d S rL rH r s r r z!SilentUnixWSGIServer.handle_error s Dr N)rq rr rs r rH r r r r s# r r c e Zd ZdS )UnixSSLWSGIServerNr rH r r r r s r r c j t j 5 } | j cd d d S # 1 swxY w Y d S rL )tempfileNamedTemporaryFilename)files r gen_unix_socket_pathr sw
(
*
* d9 s (,,c # K t } | V t j | d S # t $ r Y d S w xY w# t j | w # t $ r Y w w xY wxY wrL )r r unlinkr )r s r unix_socket_pathr s #%% JJJ
$
$
s9 > -
;;A% AA%
A" A%!A""A%c # K t 5 }t || t t E d {V d d d d S # 1 swxY w Y d S N)r r r r )r r r r )r r s r run_test_unix_serverr s
J4'g3G7HJ J J
J
J
J
J
J
J
J J J J J J J J J J J J J J J J J J Js $AA Ar hostportr c # T K t | |f|t t E d {V d S r )r ru r r s r run_test_serverr sS t g+;/<> > > > > > > > > > > >r c | d \ }}|dk r| d S | || K)NTi STOP)recvfromrQ sendto)sockr addrs r echo_datagramsr " sP $]]4((
d 7?? JJLLL E KKd # # #
$r )r r c # D K t j | |t j }|d \ }}}}}t j ||| | |f t j fd }| V d | d S # d | w xY w)N)typer c " t S rL )r )r s r r z%run_udp_echo_server.<locals>.<lambda>2 s ^D-A-A r r r )
socket getaddrinfo
SOCK_DGRAMbindr r r getsocknamer r )
r r addr_infofamilyr proto_sockaddrthreadr s
@r run_udp_echo_serverr , s "4F4EFFFI'0|$FD%H =u - -DIItTl
%A%A%A%A
B
B
BF
LLNNN GT - - / /000
GT - - / /000
s
C! !>D c i }t | D ]@}| d r| d r-t d ||< A t d| f| j z | S )N__) return_value TestProtocol)dir
startswithendswith MockCallbackr __bases__)basedctr s r make_test_protocolr ; s
CD 4 4 ??4 T]]4%8%8 d333D >4$. 8# > > @ @@r c . e Zd Zd ZddZd Zd Zd ZdS ) TestSelectorc i | _ d S rL keysri s r __init__zTestSelector.__init__G s
r Nc H t j |d|| }|| j |< |S )Nr ) selectors SelectorKeyr )rj fileobjr r keys r registerzTestSelector.registerJ s) #GQ== '
r c 6 | j | S rL )r pop)rj r s r
unregisterzTestSelector.unregisterO s y}}W%%%r c g S rL rH )rj r\ s r selectzTestSelector.selectR s r c | j S rL r ri s r get_mapzTestSelector.get_mapU s
yr rL )rq rr rs r r
r r r rH r r r r E sd
& & & 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 z t | d }d| _ nd| _ | | _ t | j d| _ d| _ g | _ t | _ i | _
i | _ | t j | _ d S )Nc 3 K d V d S rL rH rH r r rS z TestLoop.__init__.<locals>.genp s r FTr g& .>)rx r _check_on_close_gennext_time_clock_resolution_timersr _selectorreaderswritersreset_countersweakrefWeakValueDictionary _transports)rj rS r s r r zTestLoop.__init__l s
;
#(D #'D CEE TY
!% % "688r c | j S rL r ri s r rW z
TestLoop.time s
zr c . |r| xj |z
c_ dS dS )zMove test time forward.Nr' )rj advances r advance_timezTestLoop.advance_time s( " JJ' !JJJJ " "r c t | j r; | j d t d # t $ r Y d S w xY wd S )Nr z Time generator is not finished)rx rQ r r sendAssertionError
StopIteration)rj r s r rQ zTestLoop.close s{
G
G q!!! %%EFFF !
G Gs A
A! A!c D t j ||| d | j |< d S rL )r Handler rj fdcallbackrn s r _add_readerzTestLoop._add_reader $ !=4tDD Rr c V | j |xx dz
cc< || j v r
| j |= dS dS N TF)remove_reader_countr rj r2 s r _remove_readerzTestLoop._remove_reader B $$$)$$$
R 45r c || j vrt d| d | j | }|j |k rt d|j d| |j |k rt d|j d| d S )Nfd is not registeredzunexpected callback: != zunexpected callback args: )r r- _callback_argsrj r2 r3 rn handles r
assert_readerzTestLoop.assert_reader s
T\ ! ! !=r!=!=!=>> > b! x ' ' H(8HHhHHJ J
J <4 EV\EEtEEG G
G r c > || j v rt d| d d S )Nr> z is registered)r r- r: s r assert_no_readerzTestLoop.assert_no_reader s1
!9r!9!9!9:: : r c D t j ||| d | j |< d S rL )r r0 r! r1 s r _add_writerzTestLoop._add_writer r5 r c V | j |xx dz
cc< || j v r
| j |= dS dS r7 )remove_writer_countr! r: s r _remove_writerzTestLoop._remove_writer r< r c || j vrt d| d | j | }|j |k rt |j d| |j |k rt |j d| d S )Nr> r? r@ )r! r- rA rB rC s r
assert_writerzTestLoop.assert_writer s
T\ ! ! !=r!=!=!=>> > b! x ' ' F$4!H!HH!H!HII I <4 FL!@!@!@!@AA A r c r t |t sa t | }n># t t t
f$ r$ t d | d w xY w | j | }t d || # t $ r Y d S w xY w)NzInvalid file object: {!r}z.File descriptor {!r} is used by transport {!r})
isinstancer filenoAttributeError TypeError
ValueErrorrm r% RuntimeErrorKeyError)rj r2 transports r _ensure_fd_no_transportz TestLoop._ensure_fd_no_transport s "c"" >
>%%"Iz:
>
>
> "((.r
4 49=>
> $ (,I @GG # #$ $
$ DD s !9 ;A48
B( (
B65B6c J | | | j ||g|R S )zAdd a reader callback.)rX r4 r1 s r
add_readerzTestLoop.add_reader 3 $$R((( t H4t4444r c V | | | | S )zRemove a reader callback.)rX r; r: s r
remove_readerzTestLoop.remove_reader * $$R(((""2&&&r c J | | | j ||g|R S )zAdd a writer callback..)rX rI r1 s r
add_writerzTestLoop.add_writer r[ r c V | | | | S )zRemove a writer callback.)rX rL r: s r
remove_writerzTestLoop.remove_writer r^ r c ~ t j t | _ t j t | _ d S rL ) collections defaultdictr r9 rK ri s r r" zTestLoop.reset_counters s. #.#:3#?#? #.#:3#?#? r c t | j D ]1}| j | }| | 2g | _ d S rL )rx _run_oncer r r, r* )rj whenr) r s r rg zTestLoop._run_once s_
L ' 'DinnT**G g & & & & r )r c t | j | t j ||g|R d|iS )Nr )r appendrx call_at)rj rh r3 r rn r s r rk zTestLoop.call_at sA D!!! uwwtXFFFFgFFFr c d S rL rH )rj
event_lists r _process_eventszTestLoop._process_events s r c d S rL rH ri s r _write_to_selfzTestLoop._write_to_self rp r rL )rq rr rs __doc__r rW r* rQ r4 r; rE rG rI rL rN rX rZ r] r` rb r" rg rk rn rp r r s @r r r Y s $9 9 9 9 9 9. " " "
G G G G GE E E G G G; ; ;E E E B B B$ $ $"5 5 5
' ' '
5 5 5
' ' '
@ @ @ 6: G G G G G G G
r r c * t j dddgi| S )Nspec__call__rH )r Mock)kwargss r r r s 9 1 1:, 1& 1 11r c e Zd ZdZd ZdS ) 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 v t t j t | |t j S rL )boolresearchstrSrj others r __eq__zMockPattern.__eq__ s& BIc$ii55666r N)rq rr rs rq r rH r r rx rx s- 7 7 7 7 7r rx c e Zd Zd Zd ZdS )MockInstanceOfc || _ d S rL )_type)rj r s r r zMockInstanceOf.__init__ s
r c , t || j S rL )rP r r s r r zMockInstanceOf.__eq__ s %,,,r N)rq rr rs r r rH r r r r s2 - - - - -r r c V t j | }|t d| |S )Nz unable to get the source of )r _get_function_sourcerT )funcsources r get_function_sourcer s1
0
6
6F
~jTTCDDD Mr c D e Zd Zed ZdddZd dZd Zd ZdS )
TestCasec | | j W| s(| | n| j d | t
j }| | }t |t j rpt |j
D ]K}| t j | rt% d| d Jd S d S # t& $ r Y d S w xY wd S )NT)wait)r\ zthread z& still alive: subprocess still running)_default_executor is_closedrP shutdown_default_executorr rQ r
maybe_get_event_loop_policyget_child_watcherrP asyncioThreadedChildWatcherlist_threadsvaluesr
SHORT_TIMEOUTis_aliverU NotImplementedError)rR policywatcherr s r
close_loopzTestCase.close_loop su ! ->>##
;''(F(F(H(HIIII&//T/:::
466
K 2244
gw'CDD K"&w'7'>'>'@'@"A"A K K G,A BBB!??,, K". 0J 0J 0J 0J #K #K KK K KK K
'
s D+ +
D98D9T)cleanupc |t d t j d |r | | j | d S d S )Nz loop is None)r- r set_event_loop
addCleanupr )rj rR r s r r zTestCase.set_event_loop9 sT < 00 0 d### 3 OODOT 2 2 2 2 2 3 3r Nc N t | }| | |S rL )r r )rj rS rR s r
new_test_loopzTestCase.new_test_loopA s& }} D!!! r c 6 t j | _ d S rL )r threading_setup_thread_cleanupri s r setUpzTestCase.setUpF s / ? A A r c t j d | t j d | t
j | j t j
d S )N)NNN) r r assertEqualsysexc_info
doCleanupsr threading_cleanupr r
reap_childrenri s r tearDownzTestCase.tearDownI sh d###
);<<< *D,@AA r rL ) rq rr rs staticmethodr r r r r rH r r r r s K K \K2 /3 3 3 3 3 3
B B B r r c # K t j } t j t j dz dV t j | dS # t j | w xY w)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 U sa I#(*+++
""""" """"s %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 c s9 >&- ( (DDJDIDK#&DO Kr c K d fd}t j | t j d d {V d S )Nc l D ]} d S # t $ r
}|Y d }~d S d }~ww xY wrL ) __await__
BaseException)r errcoroexcs r r z await_without_task.<locals>.funcp s^ ^^%%
CCCCCCC s
3.3r )r get_running_loopr` rZ )r r r s ` @r await_without_taskr n s}
C ((...
-
r )Urq r rd
contextlibrg r r r{ r r r r r r rW unittestr# r http.serverr wsgiref.simple_serverr r r6 ImportErrorr r r r
r asyncio.logr testr
test.supportr CLOCK_RESr r: r; SIGNED_CERTFILE
SIGNING_CAPEERCERTr@ rF rI rU r r^ rc re ru 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 r rH r r <module>r s
" " " " " " @ @ @ @ @ @ @ @JJJJ
CCC " " " " " " ) ) ) ) ) )
4 4 4 9Z 0 0
)J
.
.)J77
Yz>
2
2
:F T0 ++&- . & 04 = = = #*"7 4 4 4 4
1
z
& &(8 */ F 769 >J" " " " " 6
" " ". . . . . . . .( ~
.0D
(- J J J J J 'a > > > > > $ $ $ +! A A A 9) (b
b
b
b
b
{( b
b
b
J2 2 2
7
7
7
7
7#
7
7
7- - - - - - - - 4 4 4 4 4 x 4 4 4 n
#
#
# #)"46;M#)> s A A'&A'
Browse
Usage
Versions