daf!J dZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlZddl mZddlmZddlmZmZ ddlZddlmZddlmZddlmZdd lmZdd lmZdd lmZdd lm Z dd l!m"Z"ddl!m#Z#dZ$dZ%e%ddZ&e%ddZ'e%ddZ(e%ddZ)ddddddddddd Z*d!Z+d"d#d$Z,d%Z-d&Z.e j^fd'Z0d(Z1Gd)d*eZ2Gd+d,eZ3Gd-d.Z4Gd/d0e4e3Z5d1d2d3Z6e7e d4rcGd5d6e jpeZ9Gd7d8e9eZ:Gd9d:e:Z;Gd;dZ?ej|d1d2d?Z@ej|d@dd1dAdBZAdCZBej|d@ddDdEZCdFZDGdGdHejZFGdIdJejZHdKZIGdLdMeJZKGdNdOZLdPZMGdQdRe jZNej|dSZOe je je jfdTZSdUZTy#e$rdZYwxYw)VzUtilities shared by tests.N)mock) HTTPServer)WSGIRequestHandler WSGIServer) base_events)events)format_helpers)futures)tasks)logger)support) socket_helper)threading_helper皙?cttdrOtjjtj g|}tjj |r|Stjjtjjtdg|}tjj |r|Sttjj |)N TEST_HOME_DIRz..) hasattrr ospathjoinrisfiledirname__file__FileNotFoundError)filenamefullnames 2/root/Python-3.12.4/Lib/test/test_asyncio/utils.py data_filer-sw(77<< 5 5AA 77>>( #Oww||BGGOOH5tGhGH ww~~h BGGLL2 33certdataz 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))organizationNamezPython 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 serialNumbersubjectsubjectAltNameversionctjtj}|jtt d|_tj|_|SNF) ssl SSLContextPROTOCOL_TLS_SERVERload_cert_chainONLYCERTONLYKEYcheck_hostname CERT_NONE verify_mode)server_contexts rsimple_server_sslcontextrAOs@^^C$;$;r?)rCclient_contexts rsimple_client_sslcontextrGWs3^^C$;$;.oncegs  sF) create_task_log_destroy_pendingrun_until_completeclose)looprNgents r run_brieflyrVfsN &C A#A "  s AAcd}tj|dD]>}|ry|jtj|t |dzd}@t j)NgMbP?F)errorg?)r busy_retryrQr sleepmaxr TimeoutError)rSpredtimeoutdelay_s r run_untilrbtsc E   u 5% 6   E 23EAIs# % ""$$rcZ|j|j|jy)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)rSs rrun_oncergs  NN499rceZdZdZdZy)SilentWSGIRequestHandlerc*tjSrM)ioStringIOselfs r get_stderrz#SilentWSGIRequestHandler.get_stderrs{{}rcyrMrI)rnformatargss r log_messagez$SilentWSGIRequestHandler.log_message rN)__name__ __module__ __qualname__rorsrIrrriris  rric<eZdZejZfdZdZxZS)SilentWSGIServercdt|\}}|j|j||fSrMsuper get_request settimeoutrequest_timeoutrnrequest client_addr __class__s rr}zSilentWSGIServer.get_requests4$w244//0 ##rcyrMrIrnrclient_addresss r handle_errorzSilentWSGIServer.handle_errorrtr) rurvrwr LOOPBACK_TIMEOUTrr}r __classcell__rs@rryrys..O$  rryceZdZdZy)SSLWSGIServerMixinc tjtj}|jtt |j |d} |j||||jy#t$rYywxYw)NT) server_side) r7r8r9r:r;r< wrap_socketRequestHandlerClassrROSError)rnrrcontextssocks rfinish_requestz!SSLWSGIServerMixin.finish_requestso ..!8!89'2##G#>   $ $UND A KKM   s#A66 BBN)rurvrwrrIrrrrsrrc eZdZy) SSLWSGIServerNrurvrwrIrrrrsrrF)use_sslc#Kdfd}|r|n|}||tj|j_t j fd}|j  jj|jy#jj|jwxYww)Nc3Kt|d}|r4|djt|d}||t|z}|r3yyw)NCONTENT_LENGTHz wsgi.inputi)intreadminlen)environsizedatas rrSz_run_test_server..loopsM7+,-<(--c$.@ADJ CI Ds AAAcFd}dg}||||ddk(r|SdgS)Nz200 OK)z Content-typez text/plain PATH_INFOz/loops Test messagerI)rstart_responsestatusheadersrSs rappz_run_test_server..apps:12vw' ; 7 *= #$ $rc(jdS)Nr) poll_interval) serve_forever)httpdsrz"_run_test_server..su***>rtarget) riset_appserver_addressaddress threadingThreadstartshutdown server_closer) rr server_clsserver_ssl_clsr server_class server_threadrrSs @@r_run_test_serverrs%&->*L ": ;E MM#((EM$$>@M     sA'C,B!01C!2CCAF_UNIXceZdZdZy)UnixHTTPServerc^tjj|d|_d|_y)N 127.0.0.1P) socketserverUnixStreamServer server_bind server_name server_portrms rrzUnixHTTPServer.server_binds&  ) ) 5 5d ;*D !D rN)rurvrwrrIrrrrs "rrc<eZdZejZdZfdZxZS)UnixWSGIServercNtj||jyrM)rr setup_environrms rrzUnixWSGIServer.server_binds  & &t ,    rcdt|\}}|j|j|dfS)N)rr{rs rr}zUnixWSGIServer.get_requests7#(7#6#8 G[   t33 4-- -r) rurvrwr rrrr}rrs@rrrs!22 ! . .rrceZdZdZy)SilentUnixWSGIServercyrMrIrs rrz!SilentUnixWSGIServer.handle_errors rN)rurvrwrrIrrrrs rrc eZdZy)UnixSSLWSGIServerNrrIrrrrs rrc*tjSrM)rcreate_unix_domain_namerIrrgen_unix_socket_pathrs4466rc#Kt} | tj|y#t$rYywxYw# tj|w#t$rYwwxYwxYwwrM)rrunlinkr)rs runix_socket_pathrs[#% J  $    $  sR A"8)A" 5A"5A"AAA AAAAA"c#Kt5}t||ttEd{dddy7 #1swYyxYwwN)rrrr)rrrr)rrs rrun_test_unix_serverrsR   J4'g3G7HJ J J J J J J Js$ A868 A8AArhostportrc#RKt||f|ttEd{y7wr)rryrrs rrun_test_serverrs&t g+;/<>>>s '%'c~ |jd\}}|dk(r|jy|j||=)NiSTOP)recvfromrRsendto)sockraddrs recho_datagramsr!s= ]]4( d 7? JJL  KKd # r)rrc# Ktj||tj}|d\}}}}}tj||| j||ft j fd}|j  j jd j|jy# jd j|jwxYww)N)typerctSrM)r)rsrrz%run_udp_echo_server..1s ^D-Arrr) socket getaddrinfo SOCK_DGRAMbindrrr getsocknamerr) rr addr_infofamilyrprotorasockaddrthreadrs @rrun_udp_echo_serverr+s""4F4E4EFI'0|$FD%H ==u -DIItTl   %A BF LLN   GT--/0  GT--/0 sBD C 1D 2C>>Dci}t|D]4}|jdr|jdr&td||<6t d|f|j z|S)N__) return_value TestProtocol)dir startswithendswith MockCallbackr __bases__)basedctnames rmake_test_protocolr:sc CD 4 ??4 T]]4%8  d3D 4 ?4$.. 8# > @@rc,eZdZdZddZdZdZdZy) TestSelectorci|_yrMkeysrms r__init__zTestSelector.__init__Fs  rNcTtj|d||}||j|<|S)Nr) selectors SelectorKeyr)rnfileobjrrkeys rregisterzTestSelector.registerIs+##GQ=  ' rc8|jj|SrM)rpop)rnr s r unregisterzTestSelector.unregisterNsyy}}W%%rcgSrMrI)rnr_s rselectzTestSelector.selectQs rc|jSrMrrms rget_mapzTestSelector.get_mapTs yyrrM)rurvrwrrrrrrIrrrrDs &rrceZdZdZdfd ZdZdZfdZdZdZ d Z d Z d Z d Z d ZdZdZdZdZdZdZfdZddfd ZdZdZxZS)TestLoopaLoop 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. NcBt|| d}d|_nd|_||_t |jd|_d|_g|_t|_ i|_ i|_ |jtj|_y)Nc3KdywrMrIrIrrrTzTestLoop.__init__..genos sFTrg& .>)r|r_check_on_close_gennext_time_clock_resolution_timersr _selectorreaderswritersreset_countersweakrefWeakValueDictionary _transports)rnrTrs rrzTestLoop.__init__ks  ; #(D #'D E  TYY !% %   "668rc|jSrMrrms rtimez TestLoop.times zzrc4|r|xj|z c_yy)zMove test time forward.Nr()rnadvances r advance_timezTestLoop.advance_times  JJ' !J rct||jr' |jj dt dy#t $rYywxYw)NrzTime generator is not finished)r|rRrrsendAssertionError StopIteration)rnrs rrRzTestLoop.closesR      G q!%%EFF !  sA AAcNtj|||d|j|<yrM)rHandler!rnfdcallbackrrs r _add_readerzTestLoop._add_reader!==4tD Rrcj|j|xxdz cc<||jvr|j|=yyNTF)remove_reader_countr!rnr4s r_remove_readerzTestLoop._remove_reader6   $)$   R rc||jvrtd|d|j|}|j|k7rtd|jd||j|k7rtd|jd|y)Nfd  is not registeredzunexpected callback:  != zunexpected callback args: )r!r/ _callback_argsrnr4r5rrhandles r assert_readerzTestLoop.assert_readers T\\ ! 3rd* >b!   x ' '(8(8'9hZHJ J <<4  ,V\\N$tfEG G rc>||jvrtd|dy)Nr@z is registered)r!r/r<s rassert_no_readerzTestLoop.assert_no_readers'   3rd.!9: : rcNtj|||d|j|<yrM)rr2r"r3s r _add_writerzTestLoop._add_writerr7rcj|j|xxdz cc<||jvr|j|=yyr9)remove_writer_countr"r<s r_remove_writerzTestLoop._remove_writerr>rc||jvrtd|d|j|}|j|k7rt|jd||j|k7rt|jd|y)Nr@rArB)r"r/rCrDrEs r assert_writerzTestLoop.assert_writers T\\ ! 3rd* >b!   x ' F$4$4#7tH%  $((,I@GG #$ $#Iz: > "((.r 49=> >    sAB 0B BBcL|j||j||g|S)zAdd a reader callback.)rZr6r3s r add_readerzTestLoop.add_reader* $$R(tH4t44rcF|j||j|S)zRemove a reader callback.)rZr=r<s r remove_readerzTestLoop.remove_reader! $$R(""2&&rcL|j||j||g|S)zAdd a writer callback..)rZrKr3s r add_writerzTestLoop.add_writerr]rcF|j||j|S)zRemove a writer callback.)rZrNr<s r remove_writerzTestLoop.remove_writerr`rc|tjt|_tjt|_yrM) collections defaultdictrr;rMrms rr#zTestLoop.reset_counterss(#.#:#:3#? #.#:#:3#? rct||jD].}|jj |}|j |0g|_yrM)r| _run_oncerrr.r,)rnwhenr+rs rrizTestLoop._run_oncesJ LL 'DiinnT*G   g & ' r)rcb|jj|t| ||g|d|iS)Nr)rappendr|call_at)rnrjr5rrrrs rrmzTestLoop.call_ats0 D!wtXFFgFFrcyrMrI)rn event_lists r_process_eventszTestLoop._process_eventssrcyrMrIrms r_write_to_selfzTestLoop._write_to_selfrtrrM)rurvrw__doc__rr)r,rRr6r=rGrIrKrNrPrZr\r_rbrdr#rirmrprrrrs@rrrXs}$9." GE G;EB$"5 ' 5 ' @6:G rrc 2tjdddgi|S)Nspec__call__rI)rMock)kwargss rrrs 99 1:, 1& 11rceZdZdZdZy) 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')) cpttjt||tjSrM)boolresearchstrSrnothers r__eq__zMockPattern.__eq__ s"BIIc$i566rN)rurvrwrsrrIrrrzrzs 7rrzceZdZdZdZy)MockInstanceOfc||_yrM)_type)rnrs rrzMockInstanceOf.__init__s  rc.t||jSrM)rRrrs rrzMockInstanceOf.__eq__s%,,rN)rurvrwrrrIrrrrs -rrcPtj|}|td||S)Nzunable to get the source of )r _get_function_sourcerV)funcsources rget_function_sourcers*  0 0 6F ~TCDD Mrc<eZdZedZdddZd dZdZdZy) TestCasec|jL|js |j|jn|jj d|j t j}| tj5tjdt|j}dddttjrht!|j"j%D]A}|j't j(|j+s4t-d|dyyy#1swYxYw#t.$rYywxYw)NT)waitignore)r_zthread z& still alive: subprocess still running)_default_executor is_closedrQshutdown_default_executorrrRr maybe_get_event_loop_policywarningscatch_warnings simplefilterDeprecationWarningget_child_watcherrRasyncioThreadedChildWatcherlist_threadsvaluesr SHORT_TIMEOUTis_aliverWNotImplementedError)rSpolicywatcherrs r close_loopzTestCase.close_loops>  ! ! ->>#''(F(F(HI&&//T/: 446   K,,.9))(4FG$668G9gw'C'CD"&w'7'7'>'>'@"AK G,A,A B!??,".AJ0J#KKKE 99'  s*E+E ?E EE E#"E#T)cleanupc| tdtjd|r|j|j|yy)Nz loop is None)r/rset_event_loop addCleanupr)rnrSrs rrzTestCase.set_event_loop:s: < 0 0d#  OODOOT 2 rNc>t|}|j||SrM)rr)rnrTrSs r new_test_loopzTestCase.new_test_loopBs} D! rc6tj|_yrM)rthreading_setup_thread_cleanuprms rsetUpzTestCase.setUpGs/??Arctjd|jtj|j t j|jtjyrM) rr assertIsNonesys exception doCleanupsrthreading_cleanuprr reap_childrenrms rtearDownzTestCase.tearDownJsPd# #--/* **D,@,@ArrM) rurvrw staticmethodrrrrrrIrrrrs0KK6/33 B  rrc#Ktj} tjtjdzdtj|y#tj|wxYww)zrContext manager to disable asyncio logger. For example, it can be used to ignore warnings in debug mode. r:N)r levelsetLevelloggingCRITICAL) old_levels rdisable_loggerrVsH  I#((*+  " "sA.*AA.A++A.ctjtj}||_||_||_d|j _|S)z'Create a mock of a non-blocking socket.g)r MagicMockrrrr gettimeoutr)rrrrs rmock_nonblocking_socketrds< >>&-- (DDJDIDK#&DOO KrcKdfd}tjj|tjdd{y7 w)Ncb jD]}y#t$r }|Yd}~yd}~wwxYwrM) __await__ BaseException)raerrcoroexcs rrz await_without_task..funcqs6 ^^%   C s .).r)rget_running_looprdr[)rrrs` @rawait_without_taskrosP C ((. --   sAAA A)Ursrrf contextlibrkrrr}r rrrrunittestr$rr http.serverrwsgiref.simple_serverrrr7 ImportErrorrrr r r asyncio.logr testr test.supportrr CLOCK_RESrr;r<SIGNED_CERTFILE SIGNING_CAPEERCERTrArGrJrVrrbrgriryrrrrrrrrrrcontextmanagerrrrrrr BaseSelectorr BaseEventLooprrrrzrrrr IPPROTO_TCP SOCK_STREAMAF_INETrrrIrrrs     "@ "&)  4 Z 0 J .J7 z> 2 :FT0++&-. &04= #*"7"7% 1   z  & &(8 */ F 69"66 "..(~  .0D 7(-JJ 'a>> $  +!  A9))(b {((b J2 7# 7--6 x  6 r  # ##)"4"46;M;M#)>> m CsI II