MhS<ddlmZddlmZddlmZddlmZddlmZm Z m Z m Z m Z ddl mZmZddlmZddlmZmZdd lmZdd lmZmZdd lmZdd lmZdd lmZm Z m!Z!m"Z"m#Z#m$Z$ddl%m&Z&m'Z'm(Z(m)Z)ddl*m+Z+m,Z,ddl-Z-ddl.Z.ddl/Z/ddl0Z0ddl1Z1ddl2Z2ddl3Z3ddl4Z4ddl5Z5ddl6Z6ddl7m8Z8ddl7Z7dZ9Gdde+Z:e)Gdde!Z;e)Gdde!ZGdde e;Z?Gdd e=Z@Gd!d"e=ZAGd#d$e=ZBGd%d&e!ZCGd'd(e!ZDGd)d*e!ZEe&Gd+d,er><s>$$$222$s$$$$.3$$$&*$>Dj$ $$$$ &11X1X&X*X X ! !X ! ! !r/r>c*eZdZdZdZedZedZedZedZ edZ edZ ed Z ed Z ed Zed Zed ZedZedZedZedZedZedZedZedZedZedZedZedZedZdS)TestReadWriteMixinc tr@rA)r8rLs r0make_iostream_pairz%TestReadWriteMixin.make_iostream_pairs!!r/c 4Gdd}|||S)zLike make_iostream_pair, but called by ``async with``. In py37 this becomes simpler with contextlib.asynccontextmanager. c eZdZdZdZdZdS)=TestReadWriteMixin.iostream_pair..IOStreamPairContextc"||_||_dSr@)testrL)r8rrLs r0__init__zFTestReadWriteMixin.iostream_pair..IOStreamPairContext.__init__s  $ r/cXK|jjdi|jd{V|_|jS)Nr.)rrrLpairr7s r0 __aenter__zHTestReadWriteMixin.iostream_pair..IOStreamPairContext.__aenter__s>">$)">"M"M"M"MMMMMMM y r/cFK|jD]}|dSr@)rrS)r8typvaluetbss r0 __aexit__zGTestReadWriteMixin.iostream_pair..IOStreamPairContext.__aexit__s0AGGIIIIr/N)r:r;r<rrrr.r/r0IOStreamPairContextrsA % % % ! ! !     r/rr.)r8rLrs r0 iostream_pairz TestReadWriteMixin.iostream_pairs?        #"4000r/c#K|V\}}|dV||dS)Nr/)rr6rS)r8rswss r0test_write_zero_bytesz(TestReadWriteMixin.test_write_zero_bytessW..0000Bhhsmm    r/c#K|V\}} |dg}||dV|||dV||ddg||dS#||wxYw)N12r12)rr6rtrkrSrl)r8rrchunkss r0"test_future_delayed_close_callbackz5TestReadWriteMixin.test_future_delayed_close_callbacks..0000B  HHUOOOF MMq!1!111 3 3 3 HHJJJ MMq!1!111 3 3 3   VdD\ 2 2 2 HHJJJ HHJJJJJ HHJJJ HHJJJJs BC*Dc#K|dV\}} |d|dV}|d||t jdV|dV}|d|||dS#||wxYw)N)read_chunk_sizesAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAsAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAg{Gz?)rr6rkrlrSrsleepr8rrrfs r0test_close_buffered_dataz+TestReadWriteMixin.test_close_buffered_datas..s.CCCCB  HHZ s++++D   Z . . . HHJJJ)D// ! ! !s++++D   Z . . . HHJJJ HHJJJJJ HHJJJ HHJJJJs BC""*D c#K|V\}} |d|dV}|||d|V}||d||dS#||wxYw)Ns1234rrs234)rr6rkrSrlrbrs r0!test_read_until_close_after_closez4TestReadWriteMixin.test_read_until_close_after_closes..0000B  HHW   q))))D HHJJJ   T4 ( ( (,,....D   T6 * * * HHJJJ HHJJJJJ HHJJJ HHJJJJs BC *C3c#dK|V\}} t|tr+tjdkrt jdd}t|D]}|d|d| dV}| t||dzdz| | dS#| | wxYw)NPyPyz$pypy gc causes problems with opensslsAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAr|) r isinstancerrWpython_implementationunittestSkipTestranger6rrllenrS)r8rrNUM_KBirfs r0test_large_read_untilz(TestReadWriteMixin.test_large_read_until*s  ..0000B  2{++ P244>>'(NOOOF6]] & &%%%% HHW   w////D   SYY (9 : : : HHJJJ HHJJJJJ HHJJJ HHJJJJs B>D*D/cK|4d{V\}}tj|d}tjdd{V|dd{V|d||d{Vdddd{VdS#1d{VswxYwYdS)Ndone皙?xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx)rasyncio ensure_futurerrr6rSr8rrrfs r0.test_read_until_with_close_after_second_packetzATestReadWriteMixin.test_read_until_with_close_after_second_packetCsm%%''       8B&r}}W'='=>>B-$$ $ $ $ $ $ $ $((;'' ' ' ' ' ' ' ' HHW    HHJJJHHHHHHH                              sBC C C cK|4d{V\}}tj|d}|dd{V|d||t5|d{Vdddn #1swxYwYdddd{VdS#1d{VswxYwYdS)Nrrsfoo)rrrrr6rSrr rs r0'test_read_until_unsatisfied_after_closez:TestReadWriteMixin.test_read_until_unsatisfied_after_close[s %%''       8B&r}}W'='=>>B((;'' ' ' ' ' ' ' ' HHV    HHJJJ""#455                                                s6B C& B;/ C;B? ?CB? C C#&C#c#>Kd}|V\}}t}||j |||dV}|||||d|V||dS#||wxYw)NsOK r|) rrset_close_callbacksetr6rrlrSwait)r8OKrreventress r0%test_close_callback_with_pending_readz8TestReadWriteMixin.test_close_callback_with_pending_readis ..0000B ei(((  HHRLLL g....C   S" % % % HHJJJ MM' " " "**,,    HHJJJ HHJJJJJ HHJJJ HHJJJJs BC22*Dc#K|V\}}dgtfd}|| |d|dV}||d|d|V| d||dS#||wxYw)NFc:dd<dS)NTr)notify)closedcondsr0close_callbackzETestReadWriteMixin.test_future_close_callback..close_callbacksF1I KKMMMMMr/arr) rrrr6rkrlrprSrrc)r8rrrrrrs @@r0test_future_close_callbackz-TestReadWriteMixin.test_future_close_callbacks9..0000B{{       n---  HHTNNN a((((C   S$ ' ' '   VAY ' ' ' HHJJJ))++    OOF1I & & & HHJJJ HHJJJJJ HHJJJ HHJJJJs B"D*Ec#K|V\}} |d}|td|V}||d||dS#||wxYw)Nhelloshell)rrkr6 memoryviewrlrSr8rrfutrfs r0test_write_memoryviewz(TestReadWriteMixin.test_write_memoryviews..0000B --""C HHZ)) * * *99D   T7 + + + HHJJJ HHJJJJJ HHJJJ HHJJJJs AB*Cc#^K|V\}} |dd}|d|V}||d|dd}|d|V}||d|ddV}||d ||dS#||wxYw) N2Tpartialrrjsworldworrr/)rrkr6rlrSrs r0test_read_bytes_partialz*TestReadWriteMixin.test_read_bytes_partials'..0000B --D-11C HHX   99D   T8 , , ,--4-00C HHX   99D   T6 * * *q$7777D   T3 ' ' ' HHJJJ HHJJJJJ HHJJJ HHJJJJs B;D*D,c#FK|V\}}t}||j |dd}|d|V}||d|dd}|d|V}||dttdtj 5|dd}|d | Vdddn #1swxYwY| | dS#| | wxYw Ndefr max_bytesabcdefUnsatisfiable readlevel123456) rrrrrr6rlrrloggingINFOrrSr8rrrrrfs r0test_read_until_max_bytesz,TestReadWriteMixin.test_read_until_max_bytess..0000B fj))) --"-55C HHY   99D   T9 - - ---!-44C HHY   99D   T9 - - -7$8 MMM $ $mmFam88###kkmm### $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ HHJJJ HHJJJJJ HHJJJ HHJJJJ2B-E62AE5 E6EE6E E66*F c#K|V\}}t}||j |dt t dtj5| t5| ddVdddn #1swxYwYdddn #1swxYwY| V| | dS#| | wxYwNrrrrrr)rrrrr6rrrrrr rrrSr8rrrs r0 test_read_until_max_bytes_inlinez3TestReadWriteMixin.test_read_until_max_bytes_inlines..0000B fj)))  HHY   7$8 MMM = =&&'899==--!-<<<<<=============== = = = = = = = = = = = = = = =++--    HHJJJ HHJJJJJ HHJJJ HHJJJJsT6D;CB<0 C<C CC C DCDCD*Ec#.K|V\}}t}||j |dt t dtj5| dd| Vdddn #1swxYwY| | dS#| | wxYwNrrrrrr) rrrrr6rrrrrrrSrs r0'test_read_until_max_bytes_ignores_extraz:TestReadWriteMixin.test_read_until_max_bytes_ignores_extras2..0000B fj)))  HHY   7$8 MMM $ $ f 222kkmm### $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ HHJJJ HHJJJJJ HHJJJ HHJJJJ06C*;.B5) C*5B99C*<B9=C***Dc#FK|V\}}t}||j |dd}|d|V}||d|dd}|d|V}||dttdtj 5|dd|d | Vdddn #1swxYwY| | dS#| | wxYwr) rrrrread_until_regexr6rlrrrrrrSrs r0test_read_until_regex_max_bytesz2TestReadWriteMixin.test_read_until_regex_max_bytess..0000B fj))) %%f%;;C HHY   99D   T9 - - -%%f%::C HHY   99D   T9 - - -7$8 MMM $ $##Fa#888###kkmm### $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ HHJJJ HHJJJJJ HHJJJ HHJJJJrc#.K|V\}}t}||j |dt t dtj5| dd| Vdddn #1swxYwY| | dS#| | wxYwr rrrrr6rrrrr rrSrs r0&test_read_until_regex_max_bytes_inlinez9TestReadWriteMixin.test_read_until_regex_max_bytes_inlines5..0000B fj)))  HHY   7$8 MMM $ $##Fa#888kkmm### $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ HHJJJ HHJJJJJ HHJJJ HHJJJJr c#.K|V\}}t}||j |dt t dtj5| dd| Vdddn #1swxYwY| | dS#| | wxYwr rrs r0-test_read_until_regex_max_bytes_ignores_extraz@TestReadWriteMixin.test_read_until_regex_max_bytes_ignores_extra-s5..0000B fj)))  HHY   7$8 MMM $ $##Fa#888kkmm### $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ HHJJJ HHJJJJJ HHJJJ HHJJJJr c#K|dV\}} |ddztdD]/}|dV}||d0 ||dS#||wxYw)N(max_buffer_sizesaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaadr)rr6rrkrlrSr8rrrrfs r0"test_small_reads_from_large_bufferz5TestReadWriteMixin.test_small_reads_from_large_buffer>s ..y.IIIIB  HH[3& ' ' '3ZZ 4 4]]40000  {3333 4 HHJJJ HHJJJJJ HHJJJ HHJJJJs AB!!*C c#K|dV\}} |ddztdD]1}|ddV}||d2 ||dS#||wxYw)Nrrsaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa r rr)rr6rrrlrSrs r0(test_small_read_untils_from_large_bufferz;TestReadWriteMixin.test_small_read_untils_from_large_bufferMs ..y.IIIIB  HH)S0 1 1 13ZZ < <]]5D]AAAA  ':;;;; < HHJJJ HHJJJJJ HHJJJ HHJJJJs AB##*C c#Kd}|d|zV\}} |d|z||VtjdVt dD]}||V ||dS#||wxYw)Nrrrs aaaaaaaaaarri)rr6rkrrrrS)r8MBrrrs r0test_flow_controlz$TestReadWriteMixin.test_flow_control\s ..q2v.FFFFB  HHY^ $ $ $--## # # #)C.. 1XX ( (mmB'''''' ( HHJJJ HHJJJJJ HHJJJ HHJJJJs A.B==*C'c#KV\}}fd} td}||}|dt jdV||d|V}| |d t|d||}t jdV||d|V}| |d t|dtd }|d ||V} |d  t|d | d V} |d | | dS#| | wxYw)Nc>jddS)Nc*tjdS)N皙?)rrr.r/r0zGTestReadWriteMixin.test_read_into..sleep_some..ss#)D//r/)io_looprun_syncr7sr0 sleep_somez5TestReadWriteMixin.test_read_into..sleep_somers# L ! !"9"9 : : : : :r/ rr$sworld!!s helloworlds 1234567890s !!12345678rs abcdefghis90abscdefghi) r bytearray read_intor6rrrcreadingrprlbytesrkrS)r8rrr(bufrrfs` r0test_read_intoz!TestReadWriteMixin.test_read_intons..0000B ; ; ; ; ;! B--C,,s##C HHX   )D// ! ! ! OOBJJLL ) ) ) HHZ 99D   RZZ\\ * * *   T2 & & &   U3ZZ 7 7 7,,s##C)D// ! ! ! OOBJJLL ) ) ) HH] # # #99D   RZZ\\ * * *   T2 & & &   U3ZZ 7 7 7A,,C HH\ " " "c****D   T1 % % %   U3ZZ 1 1 1q))))D   T: . . . HHJJJ HHJJJJJ HHJJJ HHJJJJs IJ((*Kc#K|V\}} td}||d}|d|V}||||d|t|d|d||dV}||d|t|d||dV}||d |t|d ||dS#||wxYw) Nr)Trrrs hellosworld!1234567890s world!1234rs 5678901234) rr+r,r6rpr-rlr.rS)r8rrr/rrfs r0test_read_into_partialz)TestReadWriteMixin.test_read_into_partials..0000B B--C,,sD,11C HHX   99D   RZZ\\ * * *   T1 % % %   U3ZZ); < < < HH( ) ) )c48888D   T2 & & &   U3ZZ 7 7 7c48888D   T1 % % %   U3ZZ 7 7 7 HHJJJ HHJJJJJ HHJJJ HHJJJJs EF*G c#~K|V\}} t}||}||d||dS#||wxYwNr)rr+r,rlresultrS)r8rrr/rs r0test_read_into_zero_bytesz,TestReadWriteMixin.test_read_into_zero_bytess..0000B ++C,,s##C   SZZ\\1 - - - HHJJJ HHJJJJJ HHJJJ HHJJJJs A B*B<c#ZKtjdd|V\tjtjt jfd}t jfd} ||gVksJ dS#wxYw)N*i@Bc3 K}|dkrodtd|}tj|}||V||z}|dko|dksJdS)Nrr)randintminr)urandomupdater6) remainingsizerfnbytes produce_hashrrs r0producez9TestReadWriteMixin.test_many_mixed_reads..producesIa--yyCi$8$899z$''##D)))hhtnn$$$T! a-- >>>>>>r/c3K}|dkrdkrVdtd|}|V}|||z}nldtd|}t |}|V}||ksJ|||z}|dk|dksJdS)Nrg?rr:)randomr;r<rkr>r+r,) r?r@rfr/n consume_hashrArCrs r0consumez9TestReadWriteMixin.test_many_mixed_reads..consumesIa--88::##99QD)(<(<==D!#t!4!444D ''---%II99QD)(<(<==D#D//C ll3////A9999 '',,,%Ia-->>>>>>r/) rFRandomrhashlibsha1r coroutine hexdigestrS) r8rDrIrHrArBrCrrs @@@@@@r0test_many_mixed_readsz(TestReadWriteMixin.test_many_mixed_readssK M"  ..0000B|~~ |~~  " " " " " " "  "  " " " " " " "  "& 799ggii( ( ( ())++|/E/E/G/GGGGGG HHJJJ HHJJJJJ HHJJJ HHJJJJs AD*D*N)r:r;r<rrrrrrrrrrrrrrrrr rrrrrr r0r2r6rOr.r/r0rrs """111*X  X X2X$X0X.  X X.X0  X X0X6X$X X6X"X   X   X X"''X'RX8X//X///r/rceZdZdZdZejdZedZ edZ edZ e edZ edZed Zd S) TestIOStreamMixinc tr@rAr8 connectionrLs r0_make_server_iostreamz'TestIOStreamMixin._make_server_iostreamrDr/c tr@rArSs r0rCz'TestIOStreamMixin._make_client_iostreamrDr/c+Kt\}}tfd}tj||jt jfi}|d|f}|gV\}}j| | tj ||f)NcJj|fidSr@) set_resultrU)rTaddressrLr8server_stream_futs r0accept_callbackz=TestIOStreamMixin.make_iostream_pair..accept_callbacks=  ( (**:@@@@     r/r^) rrradd_accept_handlerrCsocketrar&remove_handlerfilenorSrReturn) r8rLlistenerportr\ client_streamrv server_streamr[s `` @r0rz$TestIOStreamMixin.make_iostream_pairs)++$"HH        "8_===226=??MMfMM #++[$,?@@ .?-M'M'M$ } ##HOO$5$5666j-7888r/c#$Kt\}}||ttj}||jt tdd5|t5| d|fVdddn #1swxYwYdddn #1swxYwY| t|j t|j dS)Nz.*F)requiredr^)r addCleanuprr^rstoprrrr rarcrerrorConnectionRefusedError)r8 cleanup_funcrcres r0test_connection_refusedz)TestIOStreamMixin.test_connection_refused sm +__ d  %%%&-//**!!$),,, wu 5 5 5 : :""#455 : :nnk4%899999 : : : : : : : : : : : : : : : : : : : : : : : : : : : : : :  6<1GHH&,WWWWWs6:CB;/ C;B? ?CB? CCCc#>Ktjtjtjd}t|}||jt jdtjtj d5| t5| dVdddn #1swxYwY|t|jtjddddS#1swxYwYdS)Nrzsocket.socket.connectboom side_effect) localhostP)r^AF_INET SOCK_STREAMrrrir"patchgaierrorerrnoEIOrr rarcrrj)r8rres r0 test_gaierrorzTestIOStreamMixin.test_gaierrors M&.&*.fake_read_from_fdls>--//000 --f55555r/z error on read) rrrrrkr6rrrrrS)r8rrrr~s @r0test_async_read_error_loggingz/TestIOStreamMixin.test_async_read_error_logging_sL $668888!!&*---    a LL    6 6 6 6 6#4F 7O44 $ $kkmm### $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ LLNNN LLNNNNN LLNNN LLNNNNs1A C)B4( C)4B88C);B8<C))*Dc#Kd\d}z|z|V\tjfdtjfd} fdt|D|gzVdS#wxYw)z? Test that write() Futures are never orphaned. )ir:r)rc3hKdz}tD]}|VdS)Nx)rr6)rfrmrGr~s r0rDz4TestIOStreamMixin.test_future_write..producesJ!8D1XX ) )ll4(((((( ) )r/c3~Kd}|kr1V}|t|z }|k/dSdSr4)rkr)nreadrrr total_bytess r0rIz4TestIOStreamMixin.test_future_write..consumesYE+%%"--a0000S!+%%%%%%r/c$g|] } Sr.r.).0rrDs r0 z7TestIOStreamMixin.test_future_write..s8887799888r/N)rrrMrrS) r8 nproducersrIrrrGrDr~rs @@@@@@r0test_future_writez#TestIOStreamMixin.test_future_writexs$1 !ej( #66{6SSSS  ) ) ) ) ) )  )  " " " " " "  "  8888eJ&7&7888GGII;F F F F LLNNN LLNNNNN LLNNN LLNNNNs &)B99*C#N)r:r;r<rUrCrrMrrrmrzrrrrrr.r/r0rQrQs$$$$$$ ]99]9"XXXX GGXG   X  X]@X0Xr/rQceZdZdZdZdS)TestIOStreamWebHTTPcBttjSr@)rr^r7s r0rCz)TestIOStreamWebHTTP._make_client_iostreams (((r/c*|Sr@rGr7s r0get_appzTestIOStreamWebHTTP.get_app!!###r/Nr:r;r<rCrr.r/r0rrs2)))$$$$$r/rceZdZdZdZdS)TestIOStreamWebHTTPScvttjttjS)N cert_reqs ssl_options)rr^r(ssl CERT_NONEr7s r0rCz*TestIOStreamWebHTTPS._make_client_iostreams(6=??s}8U8U8UVVVVr/c*|Sr@rr7s r0rzTestIOStreamWebHTTPS.get_apprr/Nrr.r/r0rrs5WWW$$$$$r/rceZdZdZdZdS) TestIOStreamc t|fi|Sr@rrSs r0rUz"TestIOStream._make_server_iostream --f---r/c t|fi|Sr@rrSs r0rCz"TestIOStream._make_client_iostreamrr/Nr:r;r<rUrCr.r/r0rrs2........r/rceZdZdZdZdS)TestIOStreamSSLc ttd}||dd}t|fi|S)NT) server_sideFrdo_handshake_on_connect)rr1 wrap_socketr)r8rTrLssl_ctxs r0rUz%TestIOStreamSSL._make_server_iostreamsV()<)>)>DQQQ(( $))  :00000r/c Pt|fdttji|S)Nrr)rr(rrrSs r0rCz%TestIOStreamSSL._make_client_iostreams9   $(3=$A$A$A EK   r/Nrr.r/r0rrs2111     r/rceZdZdZdZdS)TestIOStreamSSLContextc tjtjj}|t jt jtdt jt jtdt||dd}t|fi|SNr$r%TFr) rcreate_default_contextPurpose CLIENT_AUTHload_cert_chainr)r*r+r,r-rrr8rTrLcontexts r0rUz,TestIOStreamSSLContext._make_server_iostreams,S[-DEE GLL22J ? ? GLL22J ? ?   % T5   :00000r/c tjtjj}d|_tj|_t|fd|i|S)NFr)rrr SERVER_AUTHcheck_hostnamer verify_moderrs r0rCz,TestIOStreamSSLContext._make_client_iostreamsD,S[-DEE!&!m:EE7EfEEEr/Nrr.r/r0rrs7 1 1 1FFFFFr/rceZdZfdZfdZdZejdZejdZ d dZ ddZ e d Z e d Ze d Ze d ZxZS)TestIOStreamStartTLSc tt\|_|_d|_t |_tj |j|j ttj |_ |j|j d|jf|j||j|j|j|dS#t&$r}t)|d}~wwxYw)Nr^)supersetUprrbrcrerserver_acceptedrr]acceptrr^rdr& add_futurerarir Exceptionprint)r8ers r0rzTestIOStreamStartTLS.setUps  GGMMOOO'7'9'9 $DM49!%D #)88D  &t}dk B B B!) ""D  L # #"**K+CDDdi    IIKKK L # #D$8$) D D D IIKKKKK    !HHH  sD%D** E 4EE c\|j|j|j|j|j|j|jtdSr@) rerSrdr&r_rbr`rtearDownr8rs r0rzTestIOStreamStartTLS.tearDowns   )   $ $ & & &   )   $ $ & & & ##DM$8$8$:$:;;;  r/c|j|dt||_|jddS)Nzshould only get one connection)refailrrrY)r8rTrZs r0rzTestIOStreamStartTLS.acceptsK   ) II6 7 7 7%j11 ''-----r/c#K|jJ|j||jJ|jdV}|||dSNr|)rdr6rerrlr8line recv_lines r0client_send_linez%TestIOStreamStartTLS.client_send_lines!---   &&&!---,77@@@@  y)))))r/c#K|jJ|j||jJ|jdV}|||dSr)rer6rdrrlrs r0server_send_linez%TestIOStreamStartTLS.server_send_linerr/Nc^|jJ|j}d|_|d||S)NF)rd start_tls)r8rserver_hostnamerds r0client_start_tlsz%TestIOStreamStartTLS.client_start_tls s9!---* !&&uk?KKKr/c\|jJ|j}d|_|d|S)NT)rer)r8rres r0server_start_tlsz%TestIOStreamStartTLS.server_start_tlss7!---* !&&t[999r/c#K|dV|dV|dV|dV|dV|dV|ttj}|t}|V|_|V|_ | t|jt| t|j t|dV|dVdS) Ns220 mail.example.com ready sEHLO mail.example.com s250-mail.example.com welcome s250 STARTTLS s STARTTLS s220 Go ahead rs250 mail.example.com welcome ) rrrr(rrrr1rdrercrr)r8 client_future server_futures r0test_start_tls_smtpz(TestIOStreamStartTLS.test_start_tls_smtpsy ##$EFFFFF##$@AAAAA##$GHHHHH##$788888##O44444##$788888--dS].K.K.KLL --.A.C.CDD #000#000  4#5{CCDDD  4#5{CCDDD##$@AAAAA##$GHHHHHHHr/c#K|t}ttd5|d}|t j5|Vdddn #1swxYwY|t jtj f5|Vdddn #1swxYwYddddS#1swxYwYdS)N SSL Errorrrr) rr1rrrrrSSLErrorr^rjr8rrs r0test_handshake_failz(TestIOStreamStartTLS.test_handshake_fail+s--.A.C.CDD w , , $ $ 11+1NNM""3<00 $ $#### $ $ $ $ $ $ $ $ $ $ $ $ $ $ $""CL&,#?@@ $ $#### $ $ $ $ $ $ $ $ $ $ $ $ $ $ $  $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $sY6C/B4 CB CB .C6C; CC CC CC#&C#c#K|t}ttd5|t jd}|t j5|Vdddn #1swxYwY|t5|Vdddn #1swxYwYddddS#1swxYwYdS)Nrr^r) rr1rrrrrrrrrs r0test_check_hostnamez(TestIOStreamStartTLS.test_check_hostname6s--.A.C.CDD w , , $ $ 11*,,k2M""3<00 $ $#### $ $ $ $ $ $ $ $ $ $ $ $ $ $ $""9-- $ $#### $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $sZAC B C B C B C 7C< C C C C C  C$'C$c#fKttdd}|jJ|j|V|jJ|j|jV}|t|t|dS)NrsL) rr.castrer6rdrkrArl)r8r/recvs r0test_typed_memoryviewz*TestIOStreamStartTLS.test_typed_memoryviewEsr##((--!--- &&s+++++!---'223:>>>> teCjj11111r/)NNr@)r:r;r<rrrrrMrrrrrrrrr __classcell__rs@r0rrs5(...  ]**]* ]**]*LLLL :::: IIXI($$X$ $ $X $22X22222r/rcpeZdZejdZedZedZedZ dS)WaitForHandshakeTestc#(Kdx}} t\}}|t}||tjtjj}d|_tj|_ t5|xj ttddzc_ ttj|}dddn #1swxYwY|d|fV||j||||dSdS#||||wwxYw)NrF OP_NO_TLSv1_3rr^)rr1 add_socketrrrrrrrroptionsgetattrrr^raassertIsNotNonecipherrirS)r8 server_clsr~rsockrcrs r0connect_to_serverz&WaitForHandshakeTest.connect_to_serverRs )++JD$Z,?,A,ABBBF   d # # #01HIIG%*G ""%-G $%% K K73#C#CC$V]__'JJJ K K K K K K K K K K K K K K K..+t!455 5 5 5  !5!5!7!7 8 8 8! ! "!! ! "s2BE"AC" E""C&&E")C&*AE""/Fc#K|tGfddt}||VVdS)Nc>eZdZfdZejfdZdS)GWaitForHandshakeTest.test_wait_for_handshake_future..TestServerc|jj|j|dSr@) assertIsNoner^rr&spawn_callbackhandle_connection)r8rerZrs r0 handle_streamzUWaitForHandshakeTest.test_wait_for_handshake_future..TestServer.handle_streamusF!!&-"6"6"8"8999 ++D,BFKKKKKr/c3bK|VddSr@wait_for_handshakerY)r8rehandshake_futures r0r zYWaitForHandshakeTest.test_wait_for_handshake_future..TestServer.handle_connectionys9//11111 ++D11111r/N)r:r;r<r rrMr rrsr0 TestServerrtsZ L L L L L] 2 2 2 2] 2 2 2r/rrrrr8rrrs @@r0test_wait_for_handshake_futurez3WaitForHandshakeTest.test_wait_for_handshake_futureos~!88 2 2 2 2 2 2 2 2 2 2 2$$Z00000r/c#K|tGfddt}||VVdS)Nc6eZdZejfdZdS)VWaitForHandshakeTest.test_wait_for_handshake_already_waiting_error..TestServerc3K|}t|j|VddSr@)rr RuntimeErrorrY)r8rerZrrrs r0r zdWaitForHandshakeTest.test_wait_for_handshake_already_waiting_error..TestServer.handle_streamsT//11!!,0IJJJ  ++D11111r/Nr:r;r<rrMr rsr0rrs? ] 2 2 2 2 2] 2 2 2r/rrrs @@r0-test_wait_for_handshake_already_waiting_errorzBWaitForHandshakeTest.test_wait_for_handshake_already_waiting_errors~!88 2 2 2 2 2 2 2 2 2 2 2$$Z00000r/c#KtGfddt}||VVdS)Nc4eZdZejfdZdS)RWaitForHandshakeTest.test_wait_for_handshake_already_connected..TestServerc3K|V|VddSr@r)r8rerZrs r0r z`WaitForHandshakeTest.test_wait_for_handshake_already_connected..TestServer.handle_streamsQ//11111//11111 ++D11111r/Nr)rsr0rrs: ] 2 2 2 2] 2 2 2r/rr)r8rrs @r0)test_wait_for_handshake_already_connectedz>WaitForHandshakeTest.test_wait_for_handshake_already_connectedss!88 2 2 2 2 2 2 2 2 2 2$$Z00000r/N) r:r;r<rrMrrrrr!r.r/r0rrQs]]8X"X   X   r/rcjeZdZfdZfdZedZedZedZxZ S)TestIOStreamCheckHostnamectt\|_|_d}t j|j|tjtj j |_ |j tjtjt"ddS)Nctjtjj}|t jt jtdt jt jtd| |dd}t|dSr) rrrrrr)r*r+r,r-rr)rTrZrs r0r\z8TestIOStreamCheckHostname.setUp..accept_callbacks01HIIG  # # RW__X66 CC RW__X66 CC   !,, (--J  # # # # #r/r$)rrrrbrcrr]rrrrclient_ssl_ctxload_verify_locationsr)r*r+r,r-)r8r\rs r0rzTestIOStreamCheckHostname.setUps  #3#5#5  ty $ $ $ "4=/BBB"89PQQ 11 GLL22J ? ?     r/c|j|j|jt dSr@)r&r_rbr`rSrrrs r0rz"TestIOStreamCheckHostname.tearDownsW ##DM$8$8$:$:;;;  r/cKttj|j}|d|jfdd{V|dS)Nrr^zfoo.example.comr)rr^r&rarcrSrs r0 test_matchz$TestIOStreamCheckHostname.test_matchszV]__$:MNNNnn $) $-           r/cKttj|j}ttdt jtjdk5| tj 5ttdt j5| d|j fd d{Vdddn #1swxYwYdddn #1swxYwYtjdkrtjd d{VddddS#1swxYwYdS) Nrz.*alert bad certificateWindows)rrgz0.*(certificate verify failed: Hostname mismatch)rr^bar.example.comrr)rr^r&rrrWARNINGrWrXrrSSLCertVerificationErrorrarcrrrs r0 test_no_matchz'TestIOStreamCheckHostname.test_no_matchsV]__$:MNNN   %/_&&)3     ) ) ""3#?@@  F!/ !..$di0(9)                  I--mC((((((((() ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) )sZ! D4"C+#%C C+C C+C C+ D4+C/ /D42C/ 34D44D8;D8cKd|j_ttj|j}|d|jfdd{VdS)NFrr^r-r)r&rrr^rarcrs r0test_check_disabledz-TestIOStreamCheckHostname.test_check_disableds~.3*V]__$:MNNNnn $) $-           r/) r:r;r<rrrr*r0r2rrs@r0r#r#s      4 X))X)0  X     r/r#cZeZdZejdZedZedZdS)TestPipeIOStreamc btj\}}t|fi|t|fi|fSr@)r)piper )r8rLrCws r0rz#TestPipeIOStream.make_iostream_pairs<wyy1A((((,q*C*CF*C*CCCr/c#K|V\}}|d|d|dV}||d|dV}||d||V}||d|dS)Nshelslo world shello rjrsld)rr6rrlrkrSrbrs r0test_pipe_iostreamz#TestPipeIOStream.test_pipe_iostreams..0000B  ]]4(((( y)))]]1%%%% v&&&  ((**** u%%%  r/c# K|V\}}d}|d|z||V}||d|z||dS)Nrr)rr6rkrlrS)r8rr NUM_BYTESrfs r0test_pipe_iostream_big_writez-TestPipeIOStream.test_pipe_iostream_big_writes..0000B   !"""]]9---- ti/000    r/N) r:r;r<rrMrrr:r=r.r/r0r4r4sh]DD]D X&  X   r/r4c>eZdZdZdZdZd dZdZdZdZ d Z d S) TestStreamBufferz9 Unit tests for the private _StreamBuffer class. c8tjd|_dS)Nr8)rFrJr7s r0rzTestStreamBuffer.setUp$smB'' r/ct|ttfrt|St|tr|St |r@)rr.r+rtobytes TypeError)r8bs r0to_byteszTestStreamBuffer.to_bytes'sP a%+ , , 88O : & & 99;; A,, r/r)cBt}|jsJ||_|Sr@)r _large_buf_threshold)r8large_buf_thresholdr/s r0make_streambufferz"TestStreamBuffer.make_streambuffer/s'oo''''#6  r/cd}|dt|zkr|||}|||t|||||||f|dzdzdz}|dt|zkdSdS)Nrrrj)rrEpeekrcassertLessEqualrd)r8r/expectedr@gots r0 check_peekzTestStreamBuffer.check_peek5sQX&&&--//C OOC  S4 0 0 0 OOH//44xo F F F1HqLQ&D QX&&&&&&&r/c|t|dd}|D]k}||z }||||t|t||||l|r|jdt|dz}||d}|||t|t||||||t|ddS)Nrr/r)rlrrtrOrF randrangeadvance)r8r/objs input_typerMorGs r0check_append_all_then_skip_allz/TestStreamBuffer.check_append_all_then_skip_all>s8 S1%%% + +A MH JJzz!}} % % %   SXXs8}} 5 5 5 OOC * * * * + %%aX):;;A|H KKNNN   SXXs8}} 5 5 5 OOC * * *  + S1%%%%%r/cgd}|}|||t|}|||t|}|||t|d}t dD]}|d|t|j dt dD]}|d|t|j d| d|t|j d| d|t|j d|t|ddS) N)rs345s67s89abcdesfghsijklmnr)rirrrr rIrVr.r+rrrtrlr_buffersrRr8rSr/rs r0 test_smallzTestStreamBuffer.test_smallRsIII$$&& ++Cu===$$&& ++CyAAA$$&& ++CzBBB$$R((q  A JJt     S\**A...q  A JJt     S\**A... B S\**A... A S\**A... S1%%%%%r/c$gd}|}|||t|}|||t|}|||t|d}t dD]}|d|t|j d|d|t|j d|d|t|j d| d|t|j d | d |t|j d |t|d dS) N)s 1212121212s345345s(6767676767676767676767676767676767676767s$89a89a89a89a89a89a89a89a89a89a89a89arXsfghfghfghfghfghfghfghs ijklmnijklmnr)rjs xxxxxxxxxxxyrz!rrrrZr\s r0 test_largezTestStreamBuffer.test_largels   $$&& ++Cu===$$&& ++CyAAA$$&& ++CzBBB$$R((q " "A JJy ! ! ! ! S\**A... 4 S\**A... 4 S\**A... B S\**A... A S\**A... S1%%%%%r/N)r)) r:r;r<__doc__rrErIrOrVr]rbr.r/r0r?r?s((( '''&&&(&&&4!&!&!&!&!&r/r?)Itornado.concurrentrtornadorrtornado.iolooprtornado.iostreamrrr r r tornado.httpclientr r tornado.httputilr tornado.locksrr tornado.logrtornado.netutilrrtornado.platform.asynciortornado.tcpserverrtornado.testingrrrrrrtornado.test.utilrrrr tornado.webr r!rrxrKrr)rWrFr^rrrr"r1r3r>rrQrrrrrrrr#r4TestCaser?r.r/r0rss3%%%%%%!!!!!!=<<<<<<<((((((********CCCCCCCC??????'''''' 43333333   > G!G!G!G!G!=G!G!G!ThhhhhhhhVaaaaa*aaaH$$$$$+-A$$$$$$$$-/C$$$.....$...      '    &FFFFF.FFF&x2x2x2x2x2=x2x2x2vMMMMM=MMM`O O O O O O O O d((((()=(((Vn&n&n&n&n&x(n&n&n&n&n&r/