,h.busy_bees>r %A""$ $ $ % *+ %s&AAAcXKtd{jdy7w)Nzquiet at last!wait_all_tasks_blockedrrsrwaiting_for_bee_to_leavez=test_wait_all_tasks_blocked..waiting_for_bee_to_leave s%$&&& &' ' *(*cK td{y7#tj$rjdYywxYww)Nok)r r Cancelledrr!srcancelled_while_waitingz.cancelled_while_waiting,s6 (* * * MM$  s0A A$AAAAr%returnNone)r open_nursery start_soon cancel_scopecancel)rr"nurseryr'rs @rtest_wait_all_tasks_blockedr0s F, (!!#55w8$343455 F !!#&&w23##%&& dV  #55555&&&&&s'D CD 4C" D -C.$D C4D ,C8 D  C6D D C1%C( &C1-D 6D 8D >D ?D D c`Kgdfd }tj4d{}|j|td{dgk(sJ|j dtd{ddgk(sJdddd{y7l7K7"7 #1d{7swYyxYww)Nc|Kjdtdd{jdy7w)Ntt start tt finishedrrr!sr timeout_taskz?test_wait_all_tasks_blocked_with_timeouts..timeout_task;s/ j!Ah m$ s <:<r3rr5r()rr+r,r jump) mock_clockr7r/rs @r)test_wait_all_tasks_blocked_with_timeoutsr:8s F% !!#55w<($&&&*%%$&&&*m444 555& ' 5555sh!B.BB.BB*B2B3 B B. B B.BBB.B+B" B+'B.cKgdfd }dfd }dfd }dfd }tj4d{}|j||j||j||j||j|dddd{gdk(sJy7s7#1d{7swY xYww)NcKjdtdd{tdd{tdd{jdy7<7+7w)N blink startg{Gz? blink endr6r!srblinkz7test_wait_all_tasks_blocked_with_cushion..blinkLsS m$DkDkDk k" s1 A&A A&A"A& A$ A&"A&$A&cXKtd{jdy7w)Nwait_no_cushion endrr!srwait_no_cushionzAtest_wait_all_tasks_blocked_with_cushion..wait_no_cushionSs%$&&& +, 'r#cZKtdd{jdy7w)Ng{Gz?wait_small_cushion endrr!srwait_small_cushionzDtest_wait_all_tasks_blocked_with_cushion..wait_small_cushionWs'$T*** ./ + +)+cZKtdd{jdy7w)NgQ?wait_big_cushion endrr!srwait_big_cushionzBtest_wait_all_tasks_blocked_with_cushion..wait_big_cushion[s'$T*** ,- +rF)r=rAr>rDrDrHr()rr+r,)r?rBrErIr/rs @r(test_wait_all_tasks_blocked_with_cushionrJIs F#-0.!!#--w5!?+-.-.+, --   -----sE3CB*CAB. CB,C,C.C4B7 5C<CcKt5tjd{dddtjt 5t5 ddddddtj tjfD]Q}t|tjt 5t5|d{ddddddSt5tj d{tjd{dddy7#1swYxYw#1swYxYw#1swYxYw7#1swYxYw#1swYxYw7k7Q#1swYyxYwwN) assert_checkpointsrrpytestraisesAssertionErrorcheckpoint_if_cancelledcancel_shielded_checkpointprintrecwarn partial_yields rtest_assert_checkpointsrWssJ  !   ! ~ &  !    %% ((&  m ]]> * &#% &#o%% & & & &  1++---..00011' !!!  & & & & & .011s E:D+D(D+!E: ED8E AE:/ E: EE E EE:&E.>E*?E.E,E. E:(D++D50E:8E =EE  E:EE EE' #E:*E.,E..E73E:cZKt5 dddtjt5t5t j d{ddddddtj tjfD]Q}t|tjt5t5|d{ddddddStjt5t5t j d{t jd{ddddddy#1swY=xYw7#1swYxYw#1swY xYw7#1swYxYw#1swYxYw7v7\#1swY[xYw#1swYyxYwwrL) assert_no_checkpointsrNrOrPrrrQrRrSrTs rtest_assert_no_checkpointsrZsk    ~ &% " $ %""$ $ $ %% %% ((&  m ]]> * &&( &#o%% & & & & ~ &5 " $ 5//1 1 1224 4 4 555) % % %%%& & & & & 2 4 5 555s F+E !F+ E'EEEE' AF+/ F: E6E4 E6 F#F+5 FFFF4F5F9F F+ EF+EE$ E''E1,F+4E66E? ;FF F+FFF FF($F+c*Kgdfd dfd }dfd }t}tj4d{}|j|||j|||d4d{t d{dddd{gdk(sJdddd{t}|d4d{ dddd{t j t5|d4d{ dddd{dddy7777#1d{7swYxYw7#1d{7swYxYw77#1d{7swYxYw7k7\#1d{7swYlxYw#1swYyxYww) Nc>t|j|yrL)rSr)valrs rtztest_Sequencer..ts c  ccK|d4d{ddddd{|d4d{ddddd{|d4d{ddddd{y7o7Y#1d{7swYixYw7_7I#1d{7swYYxYw7O79#1d{7swYyxYww)Nf1rarcrdrcrfseqr^s rrcztest_Sequencer..f1sq6   iL  q6   iL  q6   iL                   s C BC  B C BC BC  B C BC "B2#C & B6/ C :B4;C C B B BC C B/#B& $B/+C 4C 6C<B? =CC cK|d4d{ddddd{|d4d{ddddd{y7F70#1d{7swY@xYw767 #1d{7swYyxYww)Nrf2rrrmrrhris rrmztest_Sequencer..f2sq6   iL  q6   iL             s B AB  A B AB A0B  A4 B A2B B A-!A$ "A-)B 2B 4B:A= ;BB r4)rlrbrnrergr)r]objectr)r*)rj Sequencerr)r*)rprr+r,r rNrO RuntimeError)rcrmrjr/rr^s @@rtest_Sequencerrrs F +C!!#QQw2s#2s#q6 + +(* * * + +PPP QQ +C1v     | $q6     Q + * + + + +QQQQ          s@7FD!F1E0D#1E4D)D%D) ED' E F+D>,FEF E FEF5 FE.FE2 FE0F F#E%D)'E)D; /D20D; 7E>FEE EFFE+E" E+'F.F0F2F 8E;9F FF FcdKgtdfd }tj4d{}|j|d|j|dd4d{ dddd{dddd{ddgk(sJt j t 5d4d{ dddd{dddy77u7f#1d{7swYvxYw7m#1d{7swY}xYw7P7A#1d{7swYQxYw#1swYyxYww) NcJKtj5}|dk(r|j |4d{ dddd{dddy77#1d{7swYxYw#t$rj d|dYBwxYw#1swYyxYww)Nrazseq(z) RuntimeError)r CancelScoper.rqr)iscoperrjs rchildz$test_Sequencer_cancel..childs     8EAv  8q6  8 8 8 QC~67 8  8 8s~B#B A3AA3A A3 A A3 B#A3A3A0 $A'%A0 ,A33BBBBB B#rarrzseq(1) RuntimeErrorzseq(2) RuntimeErrorrd)rvintr)r*)rprr+r,rNrOrq)rxr/rrjs @@rtest_Sequencer_cancelrzs' F +C8!!#w5!$5!$q6      +-BC CC | $q6               s,D0CD01C6%C&C6)C+ C66C7C6; D0C4&D0- D$:D ;D$>D D$ D  D$ D0C6C6C1 %C(&C1 -C64D06D<C? =DD0 D$ D$D! DD! D$$D-)D0ctjt5tt5 ddddddtjt 5tt5ddzddddddtt5t#1swYfxYw#1swYjxYw#1swY?xYw#1swYCxYw#1swYyxYw)Nfoora)rNrOrPrrq TypeErrorrhr_rtest__assert_raisesr~s ~ & L )    y ! L )  AI   %     sQBBBB5%B)+B5 CB BB&)B2 .B55B>C cj Ktjdjdjddk(sJjddk(sJjdjdk(sJtjt j 5jddddtjt j 5jdddtjt5jddddjd t5jdd{d k(sJ dddjd jd t5jdd{d k(sJ dddt5jd{d k(sJ ddddfd }dfd }t j4d{}|j|d|j|ddddd{tt j5t j4d{}|j|d|j|ddddd{dddjtjt j5jddddjddk(sJjdk(sJjdd{dk(sJjd{dk(sJjtdfd }t j4d{}|j|d|j|dddd{y#1swY5xYw#1swYxYw#1swYxYw7#1swYxYw7o#1swYixYw7N#1swYHxYw7'7#1d{7swYxYw77#1d{7swYxYw#1swYxYw#1swY}xYw7A7'77#1d{7swYyxYww)N123456ra1rs23456789stringabcdefsghidsefghicXKtd{j|y7wrL)r put)dataubqs rputterz'test__UnboundeByteQueue..putters#$&&&   'r#cKt5jd{|k(sJ dddy7#1swYyxYwwrL)rMget)expectrs rgetterz'test__UnboundeByteQueue..getters@  ! -?f, ,, - -" - -s$ A86 8 A8AAxyzsasdf---r_cVKtd{jy7wrL)r close)ubq2srcloserz'test__UnboundeByteQueue..closer=s!$&&&  's )')rbytesr)r*)rrr)r*r()rr get_nowaitrNrOr WouldBlockr}rMrr+r,rBusyResourceErrorrClosedResourceError)rrr/rrrs @@rtest__UnboundeByteQueuers  CGGFOGGFO >>!  $$ >>"  ))GGFO >> v %% u'' ( r u'' (  y ! GGFO  +WWR[ F***+GGFOGGFO  (WWQZ4'''(  +WWY(***+-!!#++w66*66*++ U,, -0%%' 0 07   vw /   vw / 0 00IIK u00 1  >>"  $$ >> s ""  ##?c !!IIK  D!!###w63'6"###s !++  ((+++++++  0 0 0 0 000  #####sB"R3&O+8+R3#O84!R3P'#R3 PP P*4R3P%3P"4 P%>R3P5$P2% P5/,R3QR3%Q R3QR3-Q:QQ: %Q$/ Q::Q!;Q:?;R3:R AR3RR30R1AR32R3R36$R R3%R&R3+O50R38P=R3P R3PPR3"P%%P/*R32P55P?: R3R3QQ QR3Q:!Q:$Q7 *Q-+Q7 2Q::R?R3R R3R3R3R3R0$R' %R0,R3c8 Ktdfd dd{jddk(sJjdk(sJt5jd{dddt j t j5jdddt j t j5jdddddd{t5jd{dk(sJ dddd d fd }t j4d{}|j||j|dddd{ dk(sJt5jd{dddjd{d k(sJjd{d k(sJt j t j5d d{dddjJjJjJgdfd }dfd }dfd }t|||j|usJj|usJj|usJj!dd{jd{t#d{j%gdk(sJy77#1swYxYw#1swYuxYw#1swYExYw7=7#1swYxYw77#1d{7swYxYw7#1swYxYw777Y#1swYYxYw777w)NcKt5j|d{dddy7 #1swYyxYwwrL)rMsend_all)rmsss r do_send_allz*test_MemorySendStream..do_send_allIs<  ! %,,t$ $ $ % % $ % %s ?313 ?3<?rrars23rrrcpK dd{y7#tj$rdz YywxYww)Nxxxra)rr)rresource_busy_countsrdo_send_all_count_resourcebusyz=test_MemorySendStream..do_send_all_count_resourcebusycs9 %f% % %&& % 1 $  %s(6 63636rr_rcZKjdk(sJjdyw)Nr send_all_hook)get_data_nowaitr)mss2rsrrz,test_MemorySendStream..send_all_hooks'##%// o&s(+c0Kjdyw)N"wait_send_all_might_not_block_hookrr!srrzAtest_MemorySendStream..wait_send_all_might_not_block_hooks :;c(jdy)N close_hookrr!srrz)test_MemorySendStream..close_hooks l#r_r)rrrrrr()MemorySendStreamrrMwait_send_all_might_not_blockrNrOrrget_datar+r,acloserrrrrr r) rr/rrrrrrrrs @@@@@rtest_MemorySendStreamrFs=  C% f    q !T ))    E ))  2//1112 u'' (  u'' (  B  f   .\\^#v---.%!!#;;w9:9:;; ! ##  jjl 6 )) 3 && u00 1"&!!!"    $$  1 1 99 >> !! F' <$ * D    ..  2 26X XX ??j (( --   , , ... D !!!JJL   [ 222  #.. ;;;;;  !""@ .!sNL9NL1L2L6+N!L%2+NL2/NL?NM%M& M0)NMN#M N M N!M15M.6M1:NM>N2N3,N N+N,N0BNN N N!N3N4NLL"N%L/*N2L<7 NMM NNM+M! M+&N.M11M;6 NNNN NNNcKtdfd }jd|dd{dk(sJ|dd{dk(sJjd|dd{dk(sJttj5tj 4d{}|j |d|j |ddddd{dddjJjdjj|dd{dk(sJ|dd{dk(sJ|dd{dk(sJtjtj5jd ddddfd }gdfd }t||j|usJj|usJjd jdd{d k(sJjdd{dk(sJjdd{dk(sJjdd_jdd{dk(sJjdt5jd{ddddgk(sJtjtj5jdd{dddy7777j79#1d{7swYJxYw#1swYOxYw777#1swYxYw7N73777#1swYxYw7n#1swYyxYww)NcKt5j|d{cdddS7 #1swYyxYwwrL)rM receive_some) max_bytesmrss rdo_receive_somez1test_MemoryReceiveStream..do_receive_somes;  ! 5)))44 5 54 5 5s ?313 ?3<?rraarsbcrr_rc0Kjdyw)Nr)put_data)mrs2srreceive_some_hookz3test_MemoryReceiveStream..receive_some_hooks frc(jdy)Nclosedrr!srrz,test_MemoryReceiveStream..close_hooks hr_syyysyyyxxxrszzzs lost on closer)rz int | Noner)rr()MemoryReceiveStreamrrrrr+r,rput_eofrNrOrrrrMr)rr/rrrrrs @@@rtest_MemoryReceiveStreamrs  C5LL # #t ++ $ $ --LL & && 00 U,, -4%%' 4 47    3    3 4 44  ((LLKKMKKM $ $ .. $ $ ++ $ $ ++ u00 1 VF  0* =D  ! !%6 66 ??j ((MM&""2& &) 33""2& && 00""2& && 00MM&!D""2& && 00MM"#  kkm hZ  u00 1$###$$c $ $ & 4 4 4 4 444 % $ $ ' & & '  $$$ss-M9L M9L %M9-L."M9L/)L*L/-%L L/LL/"AM94L<5M9 L? M9M,M9 MA'M9MM9"M#M9M5M96M7$M9M/M0M43M9'M-<M+=M- M9 M9M9L/L/L, L" L, 'L//L94 M9?M9M9M M9M9M9M9MM($M9+M--M62M9cKt}|jtjtj 5|j dd{dk(sJ ddd|jtjtj 5|jddddt}|jd|jtjtj 5|j dd{dddy7#1swYxYw#1swYxYw7'#1swYyxYww)Nrr_rr)rrrNrOrrrr)rrs rtest_MemoryRecvStream_closingrs  CIIK u00 11%%b))S0001IIK u00 1 V  DMM&JJL u00 1$###$$*11  $$$sr>ED(D& D( ;ED4-AEEEE E&D((D1-E4D=9EEE EcKt}t}t|||jdd{t|||j dd{dk(sJ|jdd{t||dsJ|j dd{dk(sJt||dsJt||dsJt||drJ|j dd{dk(sJ|j t|||j dd{dk(sJy77777L7w) Nrrrra)r4s56r_)rrmemory_stream_pumprrr)rrs rtest_memory_stream_pumprs#  C  CsC ,,v sC !!"% % // ,,v  c3! 44!!"% % -- c3! 44 c3! 44!#sa88!!"% % ..IIKsC !!"% % ,, , % % & &sj5ED6$ED8E:D:;(E#D<$A E1D>29E+E, E8E:E<E>EEcHKt\}|jJ|jJ|jJjJ|j dd{j dd{dk(sJd fd }tj4d{}|j|dtd{|j dd{dddd{tj4d{}|j|dtd{|jd{dddd{t\}tj4d{}|j|dtd{|jdddd{t\}|j}d|_|j dd{d d}d fd }tj4d{}|j|||j|dddd{||_|j d d{j dd{d k(sJy7<7&7777#1d{7swYxYw7777v#1d{7swYxYw7e7D7'#1d{7swY8xYw777#1d{7swYxYw77w)NrrcNKjdd{|k(sJy7 wNrr)expectedrs rreceiverz1test_memory_stream_one_way_pair..receivers$^^B''8333' %# %rr_rchKtd{|jjy7wrL)r r-r.)r/s rcancel_after_idlez:test_memory_stream_one_way_pair..cancel_after_idle0s)$&&&##% 's 20 2cKtjtj5j dd{dddy7 #1swYyxYwwr)rNrOrr&r)rsrcheck_for_cancelz9test_memory_stream_one_way_pair..check_for_cancel4sJ ]]5?? + %..$ $ $ % % % % %s,$AA A A  A A  AArs456789)rrr)r*)r/rr)r*r() memory_stream_one_way_pairrrrrrrrr+r,r rr)srr/oldrrrs @rtest_memory_stream_one_way_pairr s % 'DAq ?? && / / 77 << ##   && **V # #v --4!!#!!w8V,$&&&jj   !! !!#w8S)$&&&hhj & 'DAq!!#w8S)$&&&   & 'DAq //CAO **V &% !!#--w,g6+,--AO **V # #y 00 0_ # !& !!!! &&-----  #sAL"JL"6J7'L"JL"" J+J"J+J%J+ L"+J(,L"K L" K ,K-K KK  L"K )L">K#?L" K,"K&#K,7 L"K)8L";L<&L""L#L"&$L  L"LL"5L6L"L  L"L"L""J+%J+(L"+J>1J4 2J>9 L"K K  L" K K K  L"&K,)L",K?2K5 3K?: L"L"L" LL LL" L"crKt\jdd{jdd{jdd{dk(sJjdd{dk(sJjd{jdd{dk(sJdfd }dfd }t j 4d{}|j ||j |dddd{y777777o7C7#1d{7swYyxYww)Nrrrr_clKtd{jdd{y77w)Nr)r r)bsrsenderz'test_memory_stream_pair..senderMs.$&&&jj    ' s404244cNKjdd{dk(sJy7 w)Nrrr)asrrz)test_memory_stream_pair..receiverQs$^^B''6111'rr()memory_stream_pairrrsend_eofrr+r,)rrr/rrs @@rtest_memory_stream_pairrCs  DAq **V  **V # #v --# #v -- **,# #s **!2!!###w8$6"### # # ######s"D7DD7DD7DD76D7D7DD7,D--D7DD7#D" D7 D  D7D7D7D7D7D7D7 D7"D4(D+ )D40D7ctKdd}t|dd{dd}t|dd{y77w)NcKtSwrL)rrhr_rone_way_stream_makerzDtest_memory_streams_with_generic_tests..one_way_stream_makerZs)++ cKtSwrL)rrhr_rhalf_closeable_stream_makerzKtest_memory_streams_with_generic_tests..half_closeable_stream_maker_s"##r)r)z,tuple[MemorySendStream, MemoryReceiveStream])r)zqtuple[StapledStream[MemorySendStream, MemoryReceiveStream], StapledStream[MemorySendStream, MemoryReceiveStream]])check_one_way_streamcheck_half_closeable_stream)rrs r&test_memory_streams_with_generic_testsrYsB, 3T :::$ &&A4 HHH;I848688ctKdd}t||d{dd}t||d{y77w)NcKtSwrL)lockstep_stream_one_way_pairrhr_rrzFtest_lockstep_streams_with_generic_tests..one_way_stream_makeris+--rcKtSwrL)lockstep_stream_pairrhr_rtwo_way_stream_makerzFtest_lockstep_streams_with_generic_tests..two_way_stream_makerns$%%r)r)z tuple[SendStream, ReceiveStream])r)zYtuple[StapledStream[SendStream, ReceiveStream], StapledStream[SendStream, ReceiveStream]])rcheck_two_way_stream)rrs r(test_lockstep_streams_with_generic_testsrhsE. 35I JJJ& 35I JJJKKrcKd d}tj}|jdd{|jd|t |d{tj}|jdd{|jd|t |d{t rgtjtj }|jdd{|jd|t |d{ttdrtjtj}tj5}|d}|j|d{|jd|t |d{dddyy77g7=7777H7 #1swYyxYww) Nc K|4d{t|d{}|4d{|jd{}|4d{|jdd{|jdd{dk(sJdddd{dddd{dddd{y7777}7t7]7F73#1d{7swYCxYw7:#1d{7swYJxYw7A#1d{7swYyxYww)Nxra)open_stream_to_socket_listeneracceptrr)listener client_stream server_streams rcheckz2test_open_stream_to_socket_listener..checkxs G G"@"JJM$ G G&.oo&7 7 (GG'00666!.!;!;A!>>$FFGG G G G G GJ G 7G6>GGGG G G G G G G G GsD B7D C5B9 C5B;C5CB= C B? CC#C $C<C = C CCC C5!C"C5& D 1C32D 9C5;C5=C?CCCCC CC CC5C0 $C'%C0 ,C53D 5D;C> <DD )z 127.0.0.1rr)z0.0.0.0r)family)z::rAF_UNIXz/sock)rr r)r*) tsocketr bindlistenr r AF_INET6hasattrrtempfileTemporaryDirectory)rsocktmpdirpaths r#test_open_stream_to_socket_listenerr wsG >> D ))$ %%%KKO t$ %%% >> D ))N ###KKO t$ %%%~~W%5%56ii """ BN4()))w "~~W__5 ( ( * .fXU#D))D/ ! ! KKOt,- - -  . . #%&%$% #) " -  . .s-GF=)GG,GG)G0G1AG3G 4)GG A G*GG )G.G/G3 GGGG G G GGGGc dd}tjtd5t|t t ddddy#1swYyxYw)Nc KywrLrhr9autojump_clocks r busy_kitchenz$test_trio_test..busy_kitchens sz"^too many clocks spoil the broth!$)matchr)autojump_thresholdr)r9rorror)r*)rNrO ValueError trio_test MockClock)rs rtest_trio_testrse   z)N O  , {$:    s &AAr()r9rr)r*)rUzpytest.WarningsRecorderr)r*)1 __future__rrtypingrrN trio.testingrrrr r_core._tests.tutilr _highlevel_genericr r _highlevel_socketr testingtesting._check_streamsrtesting._memory_streamsrtriortrio.abcrrr0r:rJrWrZrrrzr~rrrrrrrrrr rrhr_rr$s" $...A.392@5"$T145<#L< E#PYx:$z$(-051p#, I K'.T  r_