+ Pj<DRt^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RI t ^RI t ^RI t ^RI t ^RI t ^RIt^RIt^RIt^RIt^RIt!RR]4t!RR]P*4t!RR]4t!RR ]P2]R 7tR t]P8R 4tR R lt!RR4t!RR]4t !RR]4t!Rt"]"!4t"!RR4t#!RR]PH4t%!RR]%4t&!RR]%4t'Rt(R!Rlt)]P8R4t*R#)"z8Test utilities. Don't use outside of the uvloop project.Nc&a]tRt^toRtRtVtR#) MockPatterncr\\P!\V4V\P44#N)boolresearchstrS)selfothers&&i/Users/ahmed/devFolder/Ultron/claude-voice/gateway/.venv/lib/python3.14/site-packages/uvloop/_testbase.py__eq__MockPattern.__eq__s"BIIc$i566N)__name__ __module__ __qualname____firstlineno__r__static_attributes____classdictcell__ __classdict__s@r rrs77rrc>aa]tRt^toV3RltV3RltRtVtV;t#) TestCaseDictc0<\SV`4WnR#r)super__init__name)r r __class__s&&r rTestCaseDict.__init__s  rc<WP9d&\RPVPV44h\SV`W4R#)zduplicate test {}.{}N)data RuntimeErrorformatrr __setitem__)r keyvaluer s&&&r r&TestCaseDict.__setitem__#s> )) 5<< 3 ! ! C'r)r) rrrrrr&rr __classcell__r rs@@r rrs((rrcBaa]tRt^*to]R4tV3RltRtVtV;t #)BaseTestCaseMetac\V4#r)r)mclsrbasess&&&r __prepare__BaseTestCaseMeta.__prepare__,s D!!rc <VF[pVPR4'gKVF9p\WT4'gK\RPWVP44h K] \ SV`WV\V44#)test_z6duplicate test {}.{} (also defined in {} parent class)) startswithhasattrr$r%rr__new__dict)r/rr0dct test_namebaser s&&&& r r7BaseTestCaseMeta.__new__0stI''004++&((. T]])<==wt5$s)<toRtRtRtRtRtRR/Rlt R t R t R t R t R ]PRRR^R^R^ /Rlt]P^ 3RltRtRt]P*R4tRtRtVtR#) BaseTestCasec\hrNotImplementedErrorr s&r new_loopBaseTestCase.new_loop@!!rc\hrrArCs&r new_policyBaseTestCase.new_policyCrFrc\V4#r)r)r r s&&r mock_patternBaseTestCase.mock_patternFs 3rc"\V\P4'gR#VP4GRjxL R#L \\ 3dR#i;i5ir) isinstanceasyncio StreamWriter wait_closedBrokenPipeErrorConnectionError)r objs&&r rQBaseTestCase.wait_closedIsF#w3344  //# # #1   s7#AAAAAAAAAAc^\VP4PPR4#)zasyncio.)typelooprr5rCs&r is_asyncio_loopBaseTestCase.is_asyncio_loopQs!DII))44Z@@rdelayg{Gz?cdVPP\P!V44R#r)rXrun_until_completerOsleep)r r[s&$r run_loop_brieflyBaseTestCase.run_loop_brieflyTs $$W]]5%9:rcrVPPV4VPPV4R#r)#_BaseTestCase__unhandled_exceptionsappendrXdefault_exception_handler)r rXcontexts&&&r loop_exception_handler#BaseTestCase.loop_exception_handlerWs( ##**73 ++G4rcVP4Vn\P!VP 44\P !VP4RVnVPPVP4.Vn R#)TN) rDrXrOset_event_loop_policyrHset_event_loop"_check_unclosed_resources_in_debugset_exception_handlerrfrbrCs&r setUpBaseTestCase.setUp[s^MMO %%doo&78tyy)26/ ''(C(CD&(#rc RVPP4VP'd?\R4\P!VP4VP R4R#VP 'gR#\P!4\P!4\P!4\VPRR4'Ed\P!4\P!4\P!4VPVPPVPPR4VPVPP^R4VPVPP^R4VPVPP^R4VPP P#4FKwrVP%R VR 7;_uu_4VPV^R P'V44RRR4KM VPP(P#4FewrVP%R VR 7;_uu_4VPW PP*V,R P'V44RRR4Kg \,P.!R4\,P0!R4RVnR# +'giEK#;i +'giK;i)z2Unexpected calls to loop.call_exception_handler():z1unexpected calls to loop.call_exception_handler()N _debug_ccFz¬ all uv_handle_t handles were freedz¬ 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 {})rXcloserbprintpprintfailrkgccollectgetattr 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_closedrOrjri)r h_nameh_cnts& r tearDownBaseTestCase.tearDowndsX   & & & F G MM$55 6 III J 666    499k5 1 1 JJL JJL JJL    11 118 :    1118 :    77? A    55q8 :"&!A!A!G!G!I \\";.4"66$$q-44V<>66"J"&!?!?!E!E!G \\"8.4"66$$yy>>vF077?A66"H t$%%d+ 666666s#L=L L  L& cRVnR#FN)rkrCs&r skip_unclosed_handles_check(BaseTestCase.skip_unclosed_handles_checks 27/rfamilyaddrNtimeoutbacklog max_clientscVfKV\P8Xd4\P!4;_uu_4pVPpRRR4MRp\P!V\P 4pVf \ R4hV^8:d \ R4hVPV4VPV4VPV4\YYT4# +'giL;i \dp TP4T hRp ? ii;i)Ntimeout is required#only blocking sockets are supported)z 127.0.0.1) socketAF_UNIXtempfileNamedTemporaryFiler SOCK_STREAMr$ settimeoutbindlistenOSErrorrrTestThreadedServer) r server_progrrrrrtmpsockexs &&$$$$$ r tcp_serverBaseTestCase.tcp_servers <'0022c88D32(}}VV%7%78 ?45 5 a<DE E    IIdO KK "  k; ;)32   JJLH s# C'"C) C& ) D 4DD c\P!V\P4pVf \R4hV^8:d \R4hVPV4\ WW4#)Nrr)rrr$rTestThreadedClient)r client_progrrrs&&&& r tcp_clientBaseTestCase.tcp_clients\}}VV%7%78 ?45 5 a<DE E  !  . .rcFVP!VR\P/VB#r)rrrr argskwargss&*,r unix_serverBaseTestCase.unix_serverFV^^FvFFrcFVP!VR\P/VB#r)rrrrs&*,r unix_clientBaseTestCase.unix_clientrrc#v"\P!4;_uu_4p\PP VR4pVx\P !V4RRR4R# \ dLi;i \P !T4i \ dii;i;i +'giR#;i5i)rN)rTemporaryDirectoryospathjoinunlinkr)r tdfns& r unix_sock_nameBaseTestCase.unix_sock_names  ( ( * *bb&)B IIbM + *IIbM+ * *spB9!B%A8A' B9' A52B%4A55B%8B":BB" B B"B B""B%% B6 0 B9cVPP4VPV4R# TPT4i;ir)rXstoprur rs&&r _abort_socket_testBaseTestCase._abort_socket_tests,  IINN  IIbMDIIbMs /A)__unhandled_exceptionsrkrX)rrrrrDrHrKrQrYr_rfrmrrrAF_INETrrrr contextlibcontextmanagerrrrrrs@r r?r?>s"" A;;5)7r8; ..;;; ; " ;B!.. .GG  rr?) metaclassc \PP\PP\PP V4RV44p\PP V4'gQhV#)certs)rrabspathrdirnameisfile)test_file_namecert_file_namefullnames&& r _cert_fullnamersWwwrww|| '. BCH 77>>( # ## # Orc#"!RR\P4p\P!R4pV!4pVPV4RxVP V4R# TP T4i;i5i)c&a]tRt^toRtRtVtR#))silence_long_exec_warning..FiltercVPPR4;'dVPPR4'*#) Executingseconds)msgr5endswith)r records&&r filter0silence_long_exec_warning..Filter.filters: --k:77 ++I68 8rrN)rrrrrrrrs@r Filterrs 8 8rrrON)loggingr getLogger addFilter removeFilter)rloggerrs r silence_long_exec_warningrs`88   y )F XF V$ F#F#sAA8 A"A8"A55A8c:\WR,4FCp\P!4pV;_uu_4VPRV34VuuRRR4u# \ R4h \Pd RRR4Kri;i +'giK;i)iNzcould not find a free port)rangerrerrorr$) start_fromportrs& r find_free_portrs~js"23}} T  2t*% T4 3 44 <<  T TTs.B A% B %B :B B B  B c\a]tRtRtoR RltRR/Rlt]PR4tRt Vt R#) SSLTestCasei Nc\\R4'd&\P!\P4pM_\\R4'd&\P!\P4pM$\P!\P 4pV;P \P,unVPW4V#)PROTOCOL_TLS_SERVER PROTOCOL_TLS) r6ssl 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) rrrrrrrrrrrrs@r rr s0 4((rrc0a]tRtRtoRtRtRtRtVtR#) UVTestCasei-uvloopc,\P!4#r)rnew_event_looprCs&r rDUVTestCase.new_loop1s$$&&rc,\P!4#r)rEventLoopPolicyrCs&r rHUVTestCase.new_policy4s%%''rrN) rrrrimplementationrDrHrrrs@r rr-sN'((rrcNaa]tRtRtoRtV3RltV3RltRtRtRt Vt V;t #) AIOTestCasei8rOc<\SV`4\PR8dI\P !4pVP VP4\P!V4R#R#N)r ) rrmsys version_inforOSafeChildWatcher attach_looprXset_child_watcher)r watcherr s& r rmAIOTestCase.setUp<sM     g %..0G    *  % %g . &rcz<\PR8d\P!R4\SV`4R#r)rrrOrrrr r s&r rAIOTestCase.tearDownDs*   g %  % %d + rc,\P!4#r)rOr rCs&r rDAIOTestCase.new_loopIs%%''rc,\P!4#r)rODefaultEventLoopPolicyrCs&r rHAIOTestCase.new_policyLs--//rr) rrrrrrmrrDrHrrr*r+s@@r rr8s#N/ (00rrc\P!\P4pV;_uu_4VPR4RRR4R# \d RRR4R#i;i +'giR#;i)::1NTF)r&r)rAF_INET6rr) server_socks r has_IPv6r)Ps]--0K     Z (     s.A'A A' A$A'#A$$A'' A8 cNa]tRtRtoRtRtRRRRRR /R ltR tR tR t Vt R#)TestSocketWrappericcWnR#r)_TestSocketWrapper__sockr rs&&r rTestSocketWrapper.__init__es rcRp\V4V8d9VPV\V4, 4pVR8Xd\hW#, pKHV#)r)lenrecvConnectionAbortedError)r nbufr#s&& r recv_allTestSocketWrapper.recv_allhsA#hl99QS\*Ds{,, KC r server_sideFserver_hostnameNdo_handshake_on_connectTc\V\P4'gQhVPVPVVVR7pV'dVP 4VPP 4WPnR#))r8r9r:N)rNrr wrap_socketr- do_handshakerr)r ssl_contextr8r9r:ssl_socks&&$$$ r starttlsTestSocketWrapper.starttlsqse +s~~6666** KK[+$;+=   ! ! #  rc.\VPV4#r)rxr-)r rs&&r __getattr__TestSocketWrapper.__getattr__st{{D))rc`RP\V4PVP4#)z <{} {!r}>)r%rWrr-rCs&r __repr__TestSocketWrapper.__repr__s#!!$t*"5"5t{{CCr)__sock) rrrrrr6r@rCrFrrrs@r r+r+cs?"!%*.$*DDrr+c2a]tRtRtoRtRtRtRtVtR#) SocketThreadic4RVnVP4R#r)_activerrCs&r rSocketThread.stops  rc&VP4V#r)startrCs&r __enter__SocketThread.__enter__s  rc&VP4R#r)r)r excs&*r __exit__SocketThread.__exit__s  r)rLN) rrrrrrPrTrrrs@r rJrJsrrJc,a]tRtRtoRtRtRtVtR#)ric\PPVRRR4RVnW@nW nRVnW0nWnR#)Nz test-clientT) threadingThreadrdaemon_timeout_sockrL_prog_test)r testrprogrs&&&&&r rTestThreadedClient.__init__s>!!$dMB      rcVP\VP44R# \\3dh\ d'pTP PT4Rp?R#Rp?ii;ir)r]r+r\KeyboardInterrupt SystemExit BaseExceptionr^rrs& r runTestThreadedClient.runsR . JJ(4 5!:.   . JJ ) )" - - .s$(A*A*A%%A*)rLr]r\r^r[rZN)rrrrrrfrrrs@r rrs..rrcZaa]tRtRtoRtV3RltRtRtRt] R4t Rt Vt V;t #) ric8\PPVRRR4RVn^Vn^VnWPnW@nW nRVn W0n \P!4wVn VnVPPR4WnR#)Nz test-serverTF)rXrYrrZ_clients_finished_clients _max_clientsr[r\rLr]r socketpair_s1_s2 setblockingr^)r r_rr`rrs&&&&&&r rTestThreadedServer.__init__s|!!$dMB  !"'    #..0$( U# rc<VP'd<VPP4R8wdVPPR4\SV`4R# \dLi;i \ST`4i;i)sstopN)rofilenosendrrrrs&r rTestThreadedServer.stopsc xxxDHHOO-3HHMM'* GLN GLNs-A1A1A A.+A1-A..A11BcVP;_uu_4VPP^4VP4RRR4VPP 4VP P 4R# +'giLF;i TPP 4TP P 4i;i)rN)r\rp_runrnrrrorCs&r rfTestThreadedServer.runsu  &&q)  HHNN  HHNN   HHNN  HHNN s"B,BB B B6C cXVP'dVPVP8dR#\P!VPVP ...VP 4wrpVP V9dR#VPV9gKVPP4wrEV;P^, unVPVP 4V;_uu_4VPV4RRR4EK R# +'giEK;i \\3dh\d/pRTnh TPPT4i;iRp?ii;i \dEK}\ P"dTP'gR#hi;i)NF)rLrjrlselectr\rnr[acceptr_handle_clientrcrdrer^rBlockingIOErrorrr)r rwxconnrrs& r ryTestThreadedServer._runs=lll}} 1 11mmTXX&B ?GA!xx1}zzQ>!%!2!2!4JDMMQ&MOODMM2 >!T //5"T10"TT-z:(>', >! JJ99"= >'~~<<< slE/$ D".D D" D D"D""E,=E,>E'EE$$E''E,/ F)>F)F)'F)c:VP\V44R#r)r]r+r.s&&r r~!TestThreadedServer._handle_clients $T*+rc6VPP4#r)r\ getsocknamerCs&r rTestThreadedServer.addrszz%%''r) rLrjrkrlr]rnror\r^r[rZ)rrrrrrrfryr~propertyrrrr*r+s@@r rrs8$">H,(((rrcRpV!4pVPV4pRVnVPV4VP4R# TP4i;i)c"R#5irrrrr oncerun_briefly..onces sFN) create_task_log_destroy_pendingr]rr)rXrgents& r run_brieflyrsN &C A#A "  s AAcB\P!4V,pV!4'gvVeBV\P!4, pV^8:d\PP4hVP \P P R44KR#)NgMbP?)timerOfutures TimeoutErrorr]tasksr^)rXpredrdeadlines&&& r run_untilrskyy{W$Hff  ,G!|oo2244  3 3E :; rc#"\PPPp\PPP \ P ^,4Rx\PPP V4R# \PPP T4i;i5i)zjContext manager to disable asyncio logger. For example, it can be used to ignore warnings in debug mode. N)rOlogrlevelsetLevelrCRITICAL) old_levels r disable_loggerrsw  ""((I/ ##G$4$4q$89  ##I. ##I.s%CAB*+C+CC)iP))+__doc__rOasyncio.events collectionsrrvrrrtrr|rrrrrXrunittestrr rUserDictrrWr-TestCaser?rrrrrrrr)r+rYrJrrrrrrrr rs5>    7#7 (;'' (=t=(g8$$0@gT  $ $ 5((@((0,00 :$D$DN 9## ..*P(P(p <  / /r