+ -Ij?<^RIt^RIHt^RIt^RIt^RIt^RIHt^RIt^RIH t ^RI H t ^RI H t ^RIHt^RIHt^R IHt^R IHtHtHtHt^R IHtHt^RIt]e ^R IHtH t H!t!R t"]PF!]RJR4!RR]PH44t%!RR]4t&!RR]4t'!RR]4t(]PF!]RJR4!RR]44t)!RR]4t*]PF!]RJR4!RR]44t+!RR]4t,]PF!]RJR4!RR ]44t-]PF!]RJR4!R!R"]P\44t/]PF!]RJR4!R#R$]44t0R# ]dRtEL?@ rcv.p\PP\RR4;_uu_4VP RVP R7pRRR4VP XP^4VP RPV4\P!44R# +'giLb;i)max_buffer_size /large_bodystreaming_callbackNr) rpatchobjectrfetchappend assertEqualcodejoinr large_body)r&chunksresponses& rtest_streaming_pause_and_resumeMCurlHTTPClientCommonTestCase.test_concurrent_paused_streams..JsUCII (/  (/ #LL $ ] ;36::)(/ s5AN)rrange bytearrayrr0r1rio_looprun_synccloser4bytesr r7)r&_rCrDr'sf @@rtest_concurrent_paused_streams;CurlHTTPClientCommonTestCase.test_concurrent_paused_streamsBs1-(-a119;1 ""#79JDQQ %% R LLNC   U3Z)C)C)E F!2QQ LLNs(C-C,!"CC, C) $C,,C>cxaV3RlpV!4p\P!4SPV!44R#)c<a\4oSPPVV3Rl4SPPVV3Rl4SP4\P !S4#)cD<SPSPR44#)z/hellor2rAr'r&srrExCurlHTTPClientCommonTestCase.test_client_not_leaked_by_write_callbacks..use_and_close_a_client..as&,,t||H7M*NrcJ<SPSPR4RR7#)r-cR#Nr)chunks&rrEڊCurlHTTPClientCommonTestCase.test_client_not_leaked_by_write_callbacks..use_and_close_a_client....esTrr.rSrTsrrErUcs" LL/'9%r)rrIrJrKweakrefrefrTs@ruse_and_close_a_clientfCurlHTTPClientCommonTestCase.test_client_not_leaked_by_write_callbacks..use_and_close_a_client_sN"_F LL ! !"N O LL ! !  LLN;;v& &rN)gccollect assertIsNone)r&r]r\sf r)test_client_not_leaked_by_write_callbacksFCurlHTTPClientCommonTestCase.test_client_not_leaked_by_write_callbacksYs+ '%&  #% rc a.oV3Rlp\PP\RR4;_uu_4\ \ R4;_uu_4VP RVR7pRRR4RRR4VPXP^4VPRPS4\P!44R# +'giLj;i +'giLu;i)c^<SPV4\S4^8Xd \4hR#)N)r3lenZeroDivisionError)rYr8s&rr/ZCurlHTTPClientCommonTestCase.test_streaming_callback_exception..streaming_callbackts) MM% 6{a')) rr+r,zException in callbackr-r.Nr) rr0r1rrrr2r4r5r6r r7)r&r/r9r8s& @r!test_streaming_callback_exception>CurlHTTPClientCommonTestCase.test_streaming_callback_exceptionos! * ZZ  35F M M7$;<<::!6H&=N , &)?+E+E+GH =<N Ms#CC $C C C C) r)__name__ __module__ __qualname____firstlineno__pycurlversiondecompresses_brotlir(r:rNr rbrj__static_attributes____classdictcell__ __classdict__s@rr!r!*sT !,KKV^^1K IG.!!*IIrr!c,a]tRt^toRtRtRtVtR#)DigestAuthHandlercWnW nR#rX)usernamepassword)r&rzr{s&&&r initializeDigestAuthHandler.initializes   rc nRpRpRpVPPPRR4pVEeVPR^4wrVVR8XgQh/pVPR4FJpVP 4PR^4wrV ^,R 8XdV R,R 8XdV ^Rp WV &KL VR ,V8XgQhVR ,V8XgQhVR ,V8XgQhVR ,VP 8XgQhVR,VPP 8XgQh\\VP RV RVP 244P4p \\VPP RVPP 244P4p \\V RV RV 244P4p WR,8XdVPR4R#VPR4R#VPR4VPRRV RV RV R 24R#)testasdf1234 AuthorizationN Digest,="realmopaquenoncerzuri:r9okfailizWWW-AuthenticatezDigest realm="z ", nonce="z ", opaque=")requestheadersgetsplitstriprzpathrrr{ hexdigestmethodwrite set_status set_header)r&rrr auth_header auth_modeparams param_dictpairkvh1h2digests& rrDigestAuthHandler.getsll**..E  " + 1 1#q 9 I( ((J S)zz|))#q1Q43;1R5C<!BA !1 * g&%/ //h'61 11g&%/ //j)T]]: ::e$ (9(99 99TT]]O1UG1T]]ODEFPPRBTT\\0014<<3D3D2EFGHRRTBAeWAbT234>>@FJ// 4  6" OOC OO" z% F81M r)r{rzN)rlrmrnror|rrsrtrus@rrxrxs!!!rrxc&a]tRt^toRtRtVtR#)CustomReasonHandlerc*VP^R4R#) Custom reasonNrr&s&rrCustomReasonHandler.get _-rrNrlrmrnrorrsrtrus@rrr..rrc&a]tRt^toRtRtVtR#)CustomFailReasonHandlerc*VPRR4R#)irNrrs&rrCustomFailReasonHandler.getrrrNrrus@rrrrrrcPaa]tRt^toV3RltRtRtRtRtRt Rt Vt V;t #)CurlHTTPClientTestCasecB<\SV`4\4VnR#rX)supersetUpr http_client)r& __class__s&rrCurlHTTPClientTestCase.setUps  (?rc d\R\RRRR/3R\RRRR/3R\3R\3.4#) /digestrzfoor{bar/digest_non_asciibarユ£/custom_reason/custom_fail_reason)rrxrrrs&rget_appCurlHTTPClientTestCase.get_appsS- E:u/UV'% J? "#67&(?@   rchVPRRRRR7pVPVPR4R#)rrrrr auth_username auth_passwordokNr2r4bodyr&r9s& rtest_digest_auth'CurlHTTPClientTestCase.test_digest_auths4:: e  .rc`VPR4pVPVPR4R#)rrN)r2r4reasonrs& rtest_custom_reason)CurlHTTPClientTestCase.test_custom_reasons%::./ /:rcrVPR4pVP\VP4R4R#)rzHTTP 400: Custom reasonN)r2r4strerrorrs& rtest_fail_custom_reason.CurlHTTPClientTestCase.test_fail_custom_reasons+::34 X^^,.GHrchVPRRRRR7pVPVPR4R#)rrrrrrNrrs& rtest_digest_auth_non_ascii1CurlHTTPClientTestCase.test_digest_auth_non_asciis7:: $   .r)r) rlrmrnrorrrrrrrsrt __classcell__rrvs@@rrrs)+  / ;I//rrc&a]tRt^toRtRtVtR#)ProxyAuthEchoHandlercVPPPRR4e2VPRVPPR, 24R#VPR4R#)zProxy-AuthorizationNz proxy auth: z no proxy auth)rrrrrs&rrProxyAuthEchoHandler.getsP <<   # #$94 @ L JJdll&:&:;P&Q%RS T JJ 'rrNrrus@rrrs((rrc2a]tRt^toRtRtRtRtVtR#)$CurlHTTPClientReuseProxyAuthTestCasec&\R\3.4#)z .*/proxy_auth)rrrs&rr,CurlHTTPClientReuseProxyAuthTestCase.get_apps_.BCDEErc2\R\RR7^R7#)TFrrrr>rrs&rr(4CurlHTTPClientReuseProxyAuthTestCase.get_http_clients$#    rcVPRRVP4RRR7pVPVPR4VPRRVP4R7pVPVPR4R#) z /proxy_authz 127.0.0.1rr) proxy_host proxy_portproxy_usernameproxy_passwordsproxy auth: Basic Zm9vOmJhcg==)rrs no proxy authN)r2 get_http_portr4rrs& rtest_reuse_proxy_credentialsACurlHTTPClientReuseProxyAuthTestCase.test_reuse_proxy_credentialss:: "))+    (IJ:: "))+  (89rrN) rlrmrnrorr(rrsrtrus@rrrsF  ::rrc&a]tRtRtoRtRtVtR#)ClientCertEchoHandlericVPP4pVe6\V\4'gQhVP RVR, 24R#VP R4R#)Nz client cert: subjectzno client cert)rget_ssl_certificater%rr)r&certs& rrClientCertEchoHandler.getsR||//1  dD)) )) JJtI&78 9 JJ' (rrNrrus@rrrs))rrcJaa]tRtRtoRtRtRtV3RltRtRt Vt V;t #) CurlHTTPClientReuseCertsTestCaseic&\R\3.4#)z.*/client_cert)rrrs&rr(CurlHTTPClientReuseCertsTestCase.get_apps-/DEFGGrc4\R\RRR7^R7#)TF)r validate_certrrrs&rr(0CurlHTTPClientReuseCertsTestCase.get_http_clients%" #   rcz\VP4RR7p\PVn\ VR7#)T) server_side) ssl_options)rget_ssl_optionsssl CERT_OPTIONAL verify_moder)r&ssl_ctxs& rget_httpserver_options7CurlHTTPClientReuseCertsTestCase.get_httpserver_options's0()=)=)?TR!//((rc<\SV`4p\PP \PP \ 4R4VR&V#)test.crtca_certs)rrosrr6dirname__file__)r&optsrs& rr0CurlHTTPClientReuseCertsTestCase.get_ssl_options,s;w&(77<<(A:NZ rc VPVPR4\PP \PP \ 4R4\PP \PP \ 4R4R7pVPVPR4VPVPR44pVPVPR4R#)z /client_certr ztest.key) client_cert client_keys4client cert: ((('commonName', 'foo.example.com'),),)sno client certN) r2rAr rr6rrr4rrs& rtest_reuse_certs1CurlHTTPClientReuseCertsTestCase.test_reuse_certs1s:: LL ( RWW__X%> Kww||BGGOOH$=zJ   MMR ::dll>:; (9:rr) rlrmrnrorr(rrrrsrtrrs@@rrrs$H )  ; ;rrc2a]tRtRtoRtRtRtRtVtR#)!CurlHTTPClientMaxBodySizeTestCasei@c8\\P^R7#)rf) max_body_sizer>)rr MAX_BODY_SIZErs&rr(1CurlHTTPClientMaxBodySizeTestCase.get_http_clientDs?+H+HVWXXrcVP\4;_uu_4pVPRRR7RRR4VPR\ XP 44R# +'giL7;i)z/bombT) raise_errorNr) assertRaisesrr2assertInr exception)r&cms& rtest_refusal_message6CurlHTTPClientMaxBodySizeTestCase.test_refusal_messageIsL  y ) )R JJwDJ 1* os2<<'89* )s A!! A1 cVPR4pVP4VPVPR\P ,4R#)z/body_bearing_redirectaN)r2rethrowr4rr rrs& rtest_redirect_body_not_counted@CurlHTTPClientMaxBodySizeTestCase.test_redirect_body_not_countedQs> ::67 /L/L(LMrrN) rlrmrnror(r#r(rsrtrus@rrr@sY :NNrrcNaa]tRtRtoRtV3RltRtRtRtRt Rt Vt V;t #) CurlStreamingBufferTesti\z>Unit tests for the buffer that feeds a ``streaming_callback``.cj<a\SV`4.VnVo!V3RlR4pV!4VnR#)cL<a]tRtRtoZPtRtV3RltRtVtR#)1CurlStreamingBufferTest.setUp..FakeClientiec><SPPV4R#rX)timeouts_requestedr3)r&msecsrs&&r _set_timeout>CurlStreamingBufferTest.setUp..FakeClient._set_timeoutis''..u5rrNi) rlrmrnrorIrr2rsrt)rvrs@r FakeClientr.esllG'M 6 6rr4N)rrr0r')r&r4rrs& @rrCurlStreamingBufferTest.setUp`s.  -/ 6 6!l rc0\VPVV4#rX)rr')r&curlcallbacks&&&r make_buffer#CurlStreamingBufferTest.make_bufferns# KK    rc`a.o!V3RlR4p.pVPV!4VP4p\PP \ R^4;_uu_4VP VPR4^4VP VPR4\P4RRR4VP4VP VR.4VP S\P.4VP VP^.4R# +'giLs;i)c.<a]tRtRtoV3RltRtVtR#)OCurlStreamingBufferTest.test_unpause_asks_for_a_socket_action..FakeCurli{c*<SPV4R#rX)r3)r&flagspauseds&&rpauseUCurlStreamingBufferTest.test_unpause_asks_for_a_socket_action..FakeCurl.pause|s e$rrNrlrmrnrorArsrt)rvr@s@rFakeCurlr={s % %rrDr+helloworldN) r9r3rr0r1rr4rrpWRITEFUNC_PAUSEflush PAUSE_CONTr0)r&rDr8rCr@s& @r%test_unpause_asks_for_a_socket_action=CurlStreamingBufferTest.test_unpause_asks_for_a_socket_actionus % %!xz6==9 ZZ  35F J J   SYYx0! 4   SYYx0&2H2H IK  (, &"3"3!45 001#6 K Js !AD D- c!RR4p.pVPV!4VP4p^VPnVP VP R4^4VP VP4VP VP R4^4VPVP4VP4VP VR.4R#)c&a]tRtRtoRtRtVtR#)=CurlStreamingBufferTest.test_body_too_large..FakeCurlic\R4h)zshould not pause)AssertionErrorr&r?s&&rrACCurlStreamingBufferTest.test_body_too_large..FakeCurl.pauses$%788rrNrCrus@rrDrNs 9 9rrDs12345s67890N) r9r3r'rr4r assertFalsebody_too_larger$rHr&rDr8rCs& rtest_body_too_large+CurlStreamingBufferTest.test_body_too_larges 9 9!xz6==9$% ! 8,a0 ++, 8,a0 **+  (,rc|!RR4p.pVPV!4VP4p\PP \ R^4;_uu_4VP VPR4^4VP VPR4\P4RRR4VPVP4VP4VP VR.4VPVP4VP VP.4R# +'giL;i)c&a]tRtRtoRtRtVtR#)GCurlStreamingBufferTest.test_unpause_error_is_ignored..FakeCurlicL\P!\PR4h)z write error)rpr E_WRITE_ERRORrQs&&rrAMCurlStreamingBufferTest.test_unpause_error_is_ignored..FakeCurl.pausesll6#7#7GGrrNrCrus@rrDrZs H HrrDr+rErFN)r9r3rr0r1rr4rrprGr$r@rHrSr0rUs& rtest_unpause_error_is_ignored5CurlStreamingBufferTest.test_unpause_error_is_ignoreds  H H!xz6==9 ZZ  35F J J   SYYx0! 4   SYYx0&2H2H IK  #  (, $ 00"5K Js AD++ D; )r'r0) rlrmrnro__doc__rr9rJrVr^rsrtrrs@@rr+r+\s&H # 7(-&66rr+)1r_hashlibrr runittestrr[tornadortornado.escaper tornado.logrtornado.netutilr tornado.testr tornado.test.utilr tornado.testingr r r r tornado.webrrrp ImportErrortornado.curl_httpclientrrrrskipIfHTTPClientCommonTestCaser!rxrrrrrrrHTTPClientMaxBodySizeTestCaserr+rrrrps  2(, 4   4!<=TI?#K#KTI>TIn&&R... .n.  4!<=(/.(/>(/V(>( 4!<=!:+<!:>!:H)N) 4!<=$;'9$;>$;N 4!<=N(U(UN>N6 4!<=S6mS6>S6I  FsF FF