ޠj<<SrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK r SSK r SSK r SSK r SSK r SSKrSSKrSSKrSSKrSSKr"SS\5r"SS\R*5r"SS\5r"S S \R2\S 9rS r\R8S 5rS!Sjr"SS5r"SS\5r "SS\5r!Sr"\""5r""SS5r#"SS\RH5r%"SS\%5r&"SS\%5r'Sr(S"Sjr)\R8S 5r*g)#z8Test utilities. Don't use outside of the uvloop project.Nc\rSrSrSrSrg) MockPatterncr[[R"[U5U[R55$N)boolresearchstrS)selfothers J/var/www/html/gaurav/venv/lib/python3.13/site-packages/uvloop/_testbase.py__eq__MockPattern.__eq__s"BIIc$i566N)__name__ __module__ __qualname____firstlineno__r__static_attributes__rrrrrs7rrc4^\rSrSrU4SjrU4SjrSrU=r$) TestCaseDictc.>[TU]5 Xlgr)super__init__name)r r __class__s rrTestCaseDict.__init__s  rc>XR;a%[SRURU55e[TU]X5 g)Nzduplicate test {}.{})data RuntimeErrorformatrr __setitem__)r keyvaluer s rr&TestCaseDict.__setitem__#s> )) 5<< 3 ! ! C'r)r)rrrrrr&r __classcell__r s@rrrs((rrc8^\rSrSr\S5rU4SjrSrU=r$)BaseTestCaseMeta*c[U5$r)r)mclsrbasess r __prepare__BaseTestCaseMeta.__prepare__,s D!!rc >UHYnURS5(dMUH8n[XT5(dM[SRXUR55e M[ [ TU]XU[U55$)Ntest_z6duplicate test {}.{} (also defined in {} parent class)) startswithhasattrr$r%rr__new__dict)r0rr1dct test_namebaser s rr8BaseTestCaseMeta.__new__0stI''004++&((. T]])<==wt5$s)<c[erNotImplementedErrorr s rnew_loopBaseTestCase.new_loop@!!rc[errCrEs r new_policyBaseTestCase.new_policyCrHrc[U5$r)r)r r s r mock_patternBaseTestCase.mock_patternFs 3rc# [U[R5(dgUR5IShvN gN![[ 4a gf=f7fr) isinstanceasyncio StreamWriter wait_closedBrokenPipeErrorConnectionError)r objs rrSBaseTestCase.wait_closedIsF#w3344  //# # #1   s1!A?=?A?AAAAc^[UR5RRS5$)Nzasyncio.)typelooprr6rEs ris_asyncio_loopBaseTestCase.is_asyncio_loopQs!DII))44Z@@rg{Gz?)delaycbURR[R"U55 gr)rZrun_until_completerQsleep)r r]s rrun_loop_brieflyBaseTestCase.run_loop_brieflyTs $$W]]5%9:rcpURRU5 URRU5 gr)#_BaseTestCase__unhandled_exceptionsappendrZdefault_exception_handler)r rZcontexts rloop_exception_handler#BaseTestCase.loop_exception_handlerWs( ##**73 ++G4rcUR5Ul[R"UR 55 [R "UR5 SUlURRUR5 /Ul g)NT) rFrZrQset_event_loop_policyrJset_event_loop"_check_unclosed_resources_in_debugset_exception_handlerrhrdrEs rsetUpBaseTestCase.setUp[s^MMO %%doo&78tyy)26/ ''(C(CD&(#rc  URR5 UR(a=[S5 [R"UR5 UR S5 gUR (dg[R"5 [R"5 [R"5 [URSS5(Ga[R"5 [R"5 [R"5 URURRURRS5 URURRSS5 URURRSS5 URURRSS 5 URR R#5H@upUR%S US 9 URUSS R'U55 SSS5 MB URR(R#5HVupUR%S US 9 URX RR*USR'U55 SSS5 MX [,R."S5 [,R0"S5 SUlg!,(df  GM=f!,(df  M=f)Nz2Unexpected calls to loop.call_exception_handler():z1unexpected calls to loop.call_exception_handler() _debug_ccFz¬ all uv_handle_t handles were freedrz¬ all callbacks (call_soon) are GCedz-not all timer callbacks (call_later) are GCedz¬ all stream write contexts are GCedzAlive handle after test) handle_namezalive {} after testzTotal/closed handlesztotal != closed for {})rZcloserdprintpprintfailrmgccollectgetattr assertEqual_debug_uv_handles_total_debug_uv_handles_freed_debug_cb_handles_count_debug_cb_timer_handles_count_debug_stream_write_ctx_cnt_debug_handles_currentitemssubTestr%_debug_handles_total_debug_handles_closedrQrlrk)r h_nameh_cnts rtearDownBaseTestCase.tearDownds>   & & F G MM$55 6 III J 66    499k5 1 1 JJL JJL JJL    11 118 :    1118 :    77? A    55q8 :"&!A!A!G!G!I \\";.4"6$$q-44V<>66"J"&!?!?!E!E!G \\"8.4"6$$yy>>vF077?A66"H t$%%d+ 6666s?#K '9K3 K0 3 L cSUlgNF)rmrEs rskip_unclosed_handles_check(BaseTestCase.skip_unclosed_handles_checks 27/rN )familyaddrtimeoutbacklog max_clientscUcAU[R:Xa+[R"5nURnSSS5 OSn[R"U[R 5nUc [ S5eUS::a [ S5eURU5 URU5 URU5 [XXU5$!,(df  N=f![an UR5 U eSn A ff=f)N)z 127.0.0.1rtimeout is requiredr#only blocking sockets are supported) socketAF_UNIXtempfileNamedTemporaryFiler SOCK_STREAMr$ settimeoutbindlistenOSErrorrtTestThreadedServer) r server_progrrrrrtmpsockexs r tcp_serverBaseTestCase.tcp_servers <'002c88D32(}}VV%7%78 ?45 5 a<DE E    IIdO KK "  k; ;)32   JJLH s# C "C C C<%C77C<c[R"U[R5nUc [S5eUS::a [S5eURU5 [ XX5$)Nrrr)rrr$rTestThreadedClient)r client_progrrrs r tcp_clientBaseTestCase.tcp_clients\}}VV%7%78 ?45 5 a<DE E  !  . .rcFUR"US[R0UD6$Nr)rrrr argskwargss r unix_serverBaseTestCase.unix_serverFV^^FvFFrcFUR"US[R0UD6$r)rrrrs r unix_clientBaseTestCase.unix_clientrrc#Z# [R"5n[RR US5nUv [R "U5 SSS5 g![ a Nf=f![R "U5 f![ a ff=f=f!,(df  g=f7f)Nr)rTemporaryDirectoryospathjoinunlinkr)r tdfns runix_sock_nameBaseTestCase.unix_sock_names  ( ( *bb&)B IIbM + *IIbM+ *snB+!BA.A B+ A+(B*A++B.B0BB B BB BB B($B+cURR5 URU5 g!URU5 f=fr)rZstoprwr rs r_abort_socket_testBaseTestCase._abort_socket_tests,  IINN  IIbMDIIbMs .A)__unhandled_exceptionsrmrZ)rrrrrFrJrMrSr[rarhrorrrAF_INETrrrr contextlibcontextmanagerrrrrrrr@r@>s"" A)-;5)7r8!..! ;B!.. .GG  rr@) metaclassc[RR[RR[RR U5SU55n[RR U5(deU$)Ncerts)rrabspathrdirnameisfile)test_file_namecert_file_namefullnames r_cert_fullnamersWwwrww|| '. BCH 77>>( # ## # Orc## "SS[R5n[R"S5nU"5nURU5 Sv UR U5 g!UR U5 f=f7f)Nc\rSrSrSrSrg))silence_long_exec_warning..FiltercURRS5=(a URRS5(+$)N Executingseconds)msgr6endswith)r records rfilter0silence_long_exec_warning..Filter.filters5 --k:7 ++I68 8rrN)rrrrrrrrrFilterrs 8rrrQ)loggingr getLogger addFilter removeFilter)rloggerrs rsilence_long_exec_warningrs`88   y )F XF V$ F#F#sAA7 A!A7!A44A7c[XS-5H:n[R"5nU URSU45 UsSSS5 s $ [ S5e![Ra SSS5 Mhf=f!,(df  M{=f)Nizcould not find a free port)rangerrerrorr$) start_fromportrs rfind_free_portrszjs"23}}   2t*% T4 3 44 <<  T Ts-A;AA;A8,A;7A88A;; B cP\rSrSrS SjrSS.Sjr\RS5rSr g) SSLTestCasei Nc[[S5(a%[R"[R5nO^[[S5(a%[R"[R5nO$[R"[R 5nU=R [R-slURX5 U$)NPROTOCOL_TLS_SERVER PROTOCOL_TLS) r7ssl SSLContextrrPROTOCOL_SSLv23options OP_NO_SSLv2load_cert_chain)r certfilekeyfile sslcontexts r_create_server_ssl_context&SSLTestCase._create_server_ssl_contexts 3- . .(?(?@J S. ) )(8(89J(;(;?  (     'F   's>A-AA-A**A-rr) rrrrrrrrr rrrrrr s, <@((rrc$\rSrSrSrSrSrSrg) UVTestCasei-uvloopc,[R"5$r)r new_event_looprEs rrFUVTestCase.new_loop1s$$&&rc,[R"5$r)r EventLoopPolicyrEs rrJUVTestCase.new_policy4s%%''rrN)rrrrimplementationrFrJrrrrr r -sN'(rr cD^\rSrSrSrU4SjrU4SjrSrSrSr U=r $) AIOTestCasei8rQc>[TU]5 [RS:aG[R "5nUR UR5 [R"U5 ggN) ) rrosys version_inforQSafeChildWatcher attach_looprZset_child_watcher)r watcherr s rroAIOTestCase.setUp<sM     g %..0G    *  % %g . &rcv>[RS:a[R"S5 [TU]5 gr)rrrQrrrr r s rrAIOTestCase.tearDownDs*   g %  % %d + rc,[R"5$r)rQrrEs rrFAIOTestCase.new_loopIs%%''rc,[R"5$r)rQDefaultEventLoopPolicyrEs rrJAIOTestCase.new_policyLs--//rr) rrrrrrorrFrJrr*r+s@rrr8s!N/ (00rrc[R"[R5nU URS5 SSS5 g![a SSS5 gf=f!,(df  g=f)N)z::1rTF)rAF_INET6rr) server_socks rhas_IPv6r-PsY--0K     Z (     s-AAA AAAA A*c>\rSrSrSrSrSSSS.SjrS rS rS r g) TestSocketWrappericcXlgr)_TestSocketWrapper__sockr rs rrTestSocketWrapper.__init__es rcSn[U5U:a>URU[U5- 5nUS:Xa[eX#- n[U5U:aM>U$)Nr)lenrecvConnectionAbortedError)r nbufr#s rrecv_allTestSocketWrapper.recv_allhsP#hl99QS\*Ds{,, KC #hl  rFNT server_sideserver_hostnamedo_handshake_on_connectc[U[R5(deURURUUUS9nU(aUR 5 URR 5 XPlg)Nr<)rPrr wrap_socketr1 do_handshakert)r ssl_contextr=r>r?ssl_socks rstarttlsTestSocketWrapper.starttlsqse +s~~6666** KK[+$;+=   ! ! #  rc.[URU5$r)rzr1)r rs r __getattr__TestSocketWrapper.__getattr__st{{D))rc`SR[U5RUR5$)Nz <{} {!r}>)r%rYrr1rEs r__repr__TestSocketWrapper.__repr__s#!!$t*"5"5t{{CCr)__sock) rrrrrr:rErHrKrrrrr/r/cs'#!%)-$*Drr/c&\rSrSrSrSrSrSrg) SocketThreadic2SUlUR5 gr)_activerrEs rrSocketThread.stops  rc&UR5 U$r)startrEs r __enter__SocketThread.__enter__s  rc$UR5 gr)r)r excs r__exit__SocketThread.__exit__s  r)rQN)rrrrrrUrYrrrrrOrOsrrOc \rSrSrSrSrSrg)ric[RRUSSS5 SUlX@lX lSUlX0lXlg)Nz test-clientT) threadingThreadrdaemon_timeout_sockrQ_prog_test)r testrprogrs rrTestThreadedClient.__init__s>!!$dMB      rcUR[UR55 g![[4a e[ a%nUR RU5 SnAgSnAff=fr)rbr/raKeyboardInterrupt SystemExit BaseExceptionrcrrs rrunTestThreadedClient.runsR . JJ(4 5!:.   . JJ ) )" - - .s$'A&A!!A&)rQrbrarcr`r_N)rrrrrrkrrrrrrs .rrcP^\rSrSrSrU4SjrSrSrSr\ S5r Sr U=r $) ric6[RRUSSS5 SUlSUlSUlXPlX@lX lSUl X0l [R"5uUl UlURRS5 Xlg)Nz test-serverTrF)r]r^rr__clients_finished_clients _max_clientsr`rarQrbr socketpair_s1_s2 setblockingrc)r rdrrerrs rrTestThreadedServer.__init__s|!!$dMB  !"'    #..0$( U# rc>UR(a:URR5S:waURRS5 [TU]5 g![a Nf=f![TU]5 f=f)Nsstop)rtfilenosendrrrr#s rrTestThreadedServer.stopsa xxDHHOO-3HHMM'* GLN GLNs(/A-A A*'A-)A**A--A=cUR URRS5 UR5 SSS5 URR 5 UR R 5 g!,(df  NC=f!URR 5 UR R 5 f=f)Nr)raru_runrsrtrtrEs rrkTestThreadedServer.runss  &&q)  HHNN  HHNN   HHNN  HHNN s! B,A7B7 BB6B>c<UR(aURUR:ag[R"URUR ///UR 5upnUR U;agURU;ajURR5upEU=RS- slURUR 5 U URU5 SSS5 UR(aMgg!,(df  N#=f![[4a e[a.nSUle!URRU5 f=fSnAff=f![a GMr[ R"a UR(dgef=f)NrF)rQrorqselectrarsr`acceptr_handle_clientrhrirjrcrBlockingIOErrorrr)r rwxconnrrs rr}TestThreadedServer._runs9ll}} 1 11mmTXX&B ?GA!xx1}zzQ>!%!2!2!4JDMMQ&MOODMM2 >! //5"1lll0"T-z:(>', >! JJ99"= >'~~<< s` E%DD ,D DDDE"4E<D==EEE"% F3$FFc8UR[U55 gr)rbr/r2s rr!TestThreadedServer._handle_clients $T*+rc6URR5$r)ra getsocknamerEs rrTestThreadedServer.addrszz%%''r) rQrorprqrbrsrtrarcr`r_) rrrrrrrkr}rpropertyrrr*r+s@rrrs1$">H,((rrcSnU"5nURU5nSUlURU5 UR5 g!UR5 f=f)Nc # g7frrrrroncerun_briefly..onces sF) create_task_log_destroy_pendingr_rt)rZrgents r run_brieflyrsN &C A#A "  s AAcD[R"5U-nU"5(d|Ub<U[R"5- nUS::a[RR5eUR [R R S55 U"5(dM{gg)NrgMbP?)timerQfutures TimeoutErrorr_tasksr`)rZpredrdeadlines r run_untilrsoyy{W$Hff  ,G!|oo2244  3 3E :; ffrc## [RRRn[RRR [ R S-5 Sv [RRR U5 g![RRR U5 f=f7f)zjContext manager to disable asyncio logger. For example, it can be used to ignore warnings in debug mode. rN)rQlogrlevelsetLevelrCRITICAL) old_levels rdisable_loggerrsw  ""((I/ ##G$4$4q$89  ##I. ##I.s%B>>B&*B>+B;;B>)iP))+__doc__rQasyncio.events collectionsrrxrrrvr rrrrrr]runittestr r rUserDictrrYr-TestCaser@rrrrrr rr-r/r^rOrrrrrrrrrs5>    7#7 (;'' (=t=(g8$$0@gT  $ $ 5((@((0,00 :$D$DN 9## ..*P(P(p <  / /r