python (3.11.7)
eI 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 dlZd dlmZ d dlmZ d dlmZmZ d dlZn
# e$ r dZY nw xY wd dl mZ d dl mZ d dl mZ d dl mZ d d l m Z d d
l m Z d d l m Z d d l!m"Z" d
Z#d Z$ e$dd Z% e$dd Z& e$dd Z' e$dd 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 e6ed2 rf G d3 d4e j7 e Z8 G d5 d6e8e Z9 G d7 d8e9 Z: G d9 d:e3e: Z;d; Z<ej= d< Z>ej= d/d0d= Z?ej= d>d d/d?d@ Z@dA ZAej= d>d dBdC ZBdD ZC G dE dFejD ZE G dG dHejF ZGdI ZH G dJ dKeI ZJ G dL dM ZKdN ZL G dO dPejM ZMej= dQ ZNejO ejP ejQ fdRZRdS ZSdS )T 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 d | | j | d S rL ) call_soonstop run_forever)rR s r run_oncerc s5 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 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 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 0 |r| xj |z
c_ d S d S rL r' )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 L | | | j ||g|R S rL )rX r4 r1 s r
add_readerzTestLoop.add_reader s6 $ $$R((( t H4t4444r c X | | | | S rL )rX r; r: s r
remove_readerzTestLoop.remove_reader - ' $$R(((""2&&&r c L | | | j ||g|R S rL )rX rI r1 s r
add_writerzTestLoop.add_writer s6 % $$R((( t H4t4444r c X | | | | S rL )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 rf 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 rg r3 r rn r s r rj 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 r rW r* rQ r4 r; rE rG rI rL rN rX rZ r\ r_ ra r" rf rj rm ro 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 Z d ZdS ) MockPatternc v t t j t | |t j S rL )boolresearchstrSrj others r __eq__zMockPattern.__eq__ s& BIc$ii55666r N)rq rr rs r rH r r rv rv s( 7 7 7 7 7r rv 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 d V t j | d S # t j | w xY w)Nr8 )r levelsetLevelloggingCRITICAL) old_levels r disable_loggerr U sf I#(*+++
""""" """"s %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 c s: 1 >&- ( (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 )Tr rc
contextlibrg r r ry 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{ rv 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