o сббi$Qу@sfddlmZddlZddlmZddlZddlmZmZm Z ddlmZddl mZmZddlmZdd lTdd lmZddlmZerRddlmZdd lmZmZd:ddДZd;ddДZd:ddДZd.busy_beecУєБtГIdHИаdбdS)Nzquiet at last!й┌wait_all_tasks_blockedrrrrr┌waiting_for_bee_to_leaveєАz=test_wait_all_tasks_blocked..waiting_for_bee_to_leavecУs6Бz tГIdHWdStjyИаdбYdSw)N┌ok)r r┌ Cancelledrrrrr┌cancelled_while_waiting*sА z.cancelled_while_waitingr#йrr)r┌open_nursery┌ start_soon┌cancel_scope┌cancel)rr!┌nurseryr%rrr┌test_wait_all_tasks_blockeds А (¤ (■r,┌ mock_clock┌ MockClockc ГsаБgЙdЗfddД}tаб4IdHЪ1}|а|бtГIdHИdgks%JВ|аdбtГIdHИddgks8JВWdГIdHdS1IdHsIwYdS) NrrcУs(БИаdбtdГIdHИаdбdS)N·tt startщ·tt finishedйrrrrrr┌timeout_task9sА z?test_wait_all_tasks_blocked_with_timeouts..timeout_taskr/rr1r&)rr'r(r ┌jump)r-r3r+rrr┌)test_wait_all_tasks_blocked_with_timeouts6sА .·r5c Гs└БgЙdЗfddД}dЗfddД}dЗfddД}dЗfd d Д}tаб4IdHЪ$}|а|б|а|б|а|б|а|б|а|бWdГIdHn1IdHsQwYИgdвks^JВdS) NrrcУsDБИаdбtdГIdHtdГIdHtdГIdHИаdбdS)N·blink startg{оGсzД?· blink endr2rrrr┌blinkJsА z7test_wait_all_tasks_blocked_with_cushion..blinkcУr)N·wait_no_cushion endrrrrr┌wait_no_cushionQr"zAtest_wait_all_tasks_blocked_with_cushion..wait_no_cushioncУєБtdГIdHИаdбdS)Ng{оGсzФ?·wait_small_cushion endrrrrr┌wait_small_cushionUєАzDtest_wait_all_tasks_blocked_with_cushion..wait_small_cushioncУr;)Ng╕ЕыQ╕Ю?·wait_big_cushion endrrrrr┌wait_big_cushionYr>zBtest_wait_all_tasks_blocked_with_cushion..wait_big_cushion)r6r9r7r<r<r?r&)rr'r()r8r:r=r@r+rrr┌(test_wait_all_tasks_blocked_with_cushionGsА (√rA┌recwarn·pytest.WarningsRecorderc ├sDБtГПtабIdHWdГn1swYtаtбПtГПWdГn1s/wYWdГn1s>wYtjtjfD]4}t|ГtаtбП!tГП|ГIdHWdГn1siwYWdГn1sxwYqItГПtабIdHtабIdHWdГdS1sЫwYdSйN) ┌assert_checkpointsrr┌pytest┌raises┌AssertionError┌checkpoint_if_cancelled┌cancel_shielded_checkpoint┌printйrB┌ partial_yieldrrr┌test_assert_checkpointsqs2А А ■ А А"■rNc ├s~БtГПWdГn1swYtаtбП"tГПtабIdHWdГn1s/wYWdГn1s>wYtjtjfD]4}t|ГtаtбП!tГП|ГIdHWdГn1siwYWdГn1sxwYqItаtбП2tГПtабIdHtабIdHWdГn1sаwYWdГdSWdГdS1s╕wYdSrD) ┌assert_no_checkpointsrFrGrHrrrIrJrKrLrrr┌test_assert_no_checkpointsЛs:А А ■ А А■ " rPc ГsаБgЙdЗfddДЙdЗfd d Д}dЗfddД}tГ}tаб4IdHЪC}|а||б|а||б|d Г4IdHЪtГIdHWdГIdHn1IdHsOwYИgdвks\JВWdГIdHn1IdHslwYtГ}|dГ4IdHЪWdГIdHn1IdHsНwYtаtбП/|dГ4IdHЪWdГIdHn1IdHs▒wYWdГdSWdГdS1s╔wYdS)N┌val┌objectrrcst|ГИа|бdSrD)rKr)rQrrr┌tмsztest_Sequencer..t┌seq┌ Sequencerc Уs╘Б|dГ4IdHЪИdГWdГIdHn1IdHswY|dГ4IdHЪИdГWdГIdHn1IdHs@wY|dГ4IdHЪИdГWdГIdHdS1IdHscwYdS)Nщй┌f1rVщйrXrYщйrXr[rйrTйrSrrrX░sА ( ( . ztest_Sequencer..f1c УsРБ|dГ4IdHЪИdГWdГIdHn1IdHswY|dГ4IdHЪИdГWdГIdHdS1IdHsAwYdS)Nrй┌f2rrйr`rrr]r^rrr`╕sА ( . ztest_Sequencer..f2r0)r_rWrarZr\r)rQrRrr)rTrUrr)rUrr'r(r rFrG┌RuntimeError)rXr`rTr+r)rrSr┌test_Sequencerйs2А( (√( * " rcc Гs8БgЙtГЙd ЗЗfddД}tаб4IdHЪ5}|а|dб|а|dбИd Г4IdHЪWdГIdHn1IdHs.childrVrrzseq(1) RuntimeErrorzseq(2) RuntimeErrorrY)rdrerr)rUrr'r(rFrGrb)rir+rrhr┌test_Sequencer_cancel╧s&А * (¤* " rjc Cs╬tаtбПttГПWdГn1swYWdГn1s$wYtаtбП ttГПddWdГn1sBwYWdГn1sQwYttГПtВ1s`wYdS)N┌foorV)rFrGrHr rb┌ TypeErrorrrrr┌test__assert_raisesэs А А rmc Гs╥БtГЙИаdбИаdбИаdбdksJВИаdбdks JВИаdбИабdks-JВtаtjбП ИаdбWdГn1sCwYtаtjбПИабWdГn1s]wYtаtбП ИаdбWdГn1swwYИаd бtГПИа dбIdHd ksСJВWdГn1sЫwYИаd бИаdбtГПИа dбIdHdks║JВWdГn1s─wYtГПИа бIdHd ks╪JВWdГn1sтwYdЗfddД}dЗfddД}tа б4IdHЪ}|а|dб|а|dбWdГIdHn1IdHРswYtаtj бП3tа б4IdHЪ}|а|dб|а|dбWdГIdHn1IdHРsMwYWdГn 1Рs]wYИабtаtjбП ИаdбWdГn 1Рs}wYИаdбdkРsМJВИабdkРsХJВИа dбIdHdkРsвJВИа бIdHdkРsоJВИабtГЙdЗfddД}tа б4IdHЪ}|а|dб|а|бWdГIdHdS1IdHРsтwYdS) Nє123є456rVє1rs23456є789┌stringєabcєdefsghiєdsefghi┌data┌bytesrrcУsБtГIdHИа|бdSrD)r ┌putйrvй┌ubqrr┌putterr"z'test__UnboundeByteQueue..putter┌expectcУsDБtГПИабIdH|ksJВWdГdS1swYdSrD)rE┌get)r}rzrr┌gettersА" z'test__UnboundeByteQueue..getterєxyzsasdfє---єcУsБtГIdHИабdSrD)r ┌closer)┌ubq2rr┌closer;sАz'test__UnboundeByteQueue..closerйrvrwrr)r}rwrrr&)rrx┌ get_nowaitrFrGr┌ WouldBlockrlrEr~r'r(┌RaisesGroup┌BusyResourceErrorrГ┌ClosedResourceError)r|rr+rЕr)r{rДr┌test__UnboundeByteQueue№srА *■*■А 0■rМc Гs БtГЙdЗfddДЙИdГIdHИаdбd ksJВИабd ks#JВtГПИабIdHWdГn1s8wYtаtjбПИабWdГn1sRwYtаtjбП ИаdбWdГn1smwYИdГIdHtГПИабIdHdksИJВWdГn1sТwYd ЙdЗЗfddД}tа б4IdHЪ}|а |б|а |бWdГIdHn1IdHs─wYИdks╧JВtГПИабIdHWdГn1sфwYИабIdHdksЇJВИабIdHdks JВtаtjбПИdГIdHWdГn 1РswYИj duРs%JВИjduРs-JВИjduРs5JВgЙdЗЗfddД}dЗfddД}dЗfddД}t|||ГЙИj |uРs[JВИj|uРscJВИj|uРskJВИаdбIdHИабIdHtИГIdHИабИgdвkРsОJВdS)NrvrwrrcУs>БtГПИа|бIdHWdГdS1swYdSrD)rE┌send_allry)┌mssrr┌do_send_allGsА" z*test_MemorySendStream..do_send_allrnrVrps23rrorcУs6Бz ИdГIdHWdStjyИd7ЙYdSw)NєxxxrV)rrКr)rП┌resource_busy_countrr┌do_send_all_count_resourcebusyasА z=test_MemorySendStream..do_send_all_count_resourcebusyrРrВrБcУs БИабdks JВИаdбdS)Nrs┌ send_all_hook)┌get_data_nowaitrr)┌mss2rrrrУ~sАz,test_MemorySendStream..send_all_hookcУєБИаdбdS)N┌"wait_send_all_might_not_block_hookйrrrrrrЧГєАzAtest_MemorySendStream..wait_send_all_might_not_block_hookcєИаdбdS)N┌ close_hookrШrrrrrЫЖєz)test_MemorySendStream..close_hookrs)rУrЧrЫrЫrЖr&)┌MemorySendStreamrФrE┌wait_send_all_might_not_blockrFrGrrИ┌get_datar'r(┌acloserЛrУrЧrЫrНr rГ)rТr+rУrЧrЫr)rПrОrХrrСr┌test_MemorySendStreamDslА (■ ¤rбc ГsцБtГЙdЗfddД}Иаdб|dГIdHd ksJВ|d ГIdHdks&JВИаdб|dГIdHdks6JВtаtjбП2tаб4IdHЪ}|а|d б|а|d бWdГIdHn1IdHsbwYWdГn1sqwYИjdus}JВИаdбИа бИа б|d ГIdHdksХJВ|d ГIdHd ksаJВ|d ГIdHd ksлJВtа tjбП ИаdбWdГn1s┴wYdЗfddД}gЙdЗfddД}t||ГЙИj|usтJВИj|usщJВИаdбИа d бIdHdks·JВИа d бIdHdkРsJВИа d бIdHdkРsJВИаdбdИ_Иа d бIdHdkРs)JВИаdбtГПИабIdHWdГn 1РsDwYИdgkРsQJВtа tjбПИа d бIdHWdГdS1РslwYdS)N┌ max_bytes· int | NonerrwcУs<БtГПИа|бIdHWdГS1swYdSrD)rE┌receive_someйrв)┌mrsrr┌do_receive_someгsА$ z1test_MemoryReceiveStream..do_receive_somersrVєarsbcrtrВrБrcУrЦ)NrР)┌put_datar)┌mrs2rr┌receive_some_hook┐rЩz3test_MemoryReceiveStream..receive_some_hookcrЪ)N┌closedrШrrrrrЫ─rЬz,test_MemoryReceiveStream..close_hooksyyysyyyxxxrРszzzs lost on closerм)rвrгrrwr&)┌MemoryReceiveStreamrйrFrЙrrКr'r(rл┌put_eofrGrЛrЫrдrErа)rзr+rлrЫr)rжrкrr┌test_MemoryReceiveStreamаs\А (■А $ rпc├sьБtГ}|абtаtjбП|аdбIdHdksJВWdГn1s%wY|абtаtjбП |аdбWdГn1sDwYtГ}|аdб|абtаtjбП|аdбIdHWdГdS1sowYdS)NrrВrnrА)rнrГrFrGrrЛrдrй)rжrкrrr┌test_MemoryRecvStream_closing▌s А " r░c├sБtГ}tГ}t||Г|аdбIdHt||Г|аdбIdHdks%JВ|аdбIdHt||ddНs6JВ|аdбIdHdksBJВt||ddНsKJВt||ddНsTJВt||ddНr]JВ|аdбIdHdksiJВ|абt||Г|аdбIdHdks~JВdS) NrnrrorVrеє4s56rВ)rЭrн┌memory_stream_pumprНrдrГ)rОrжrrr┌test_memory_stream_pumpёs"А r│c ГslБtГ\}Й|jdus JВ|jdusJВ|jdusJВИjdus"JВ|аdбIdHИаdбIdHdks6JВdЗfddД}tаб4IdHЪ}|а |d бt ГIdH|аd бIdHWdГIdHn1IdHsjwYtаб4IdHЪ}|а |d бt ГIdH|абIdHWdГIdHn1IdHsЫwYtГ\}Йtаб4IdHЪ}|а |d бt ГIdH|абWdГIdHn1IdHs╬wYtГ\}Й|j}d|_|аdбIdHdddД}dЗfddД}tаб4IdHЪ}|а ||б|а |бWdГIdHn1IdHРswY||_|аdбIdHИаdбIdHdkРs4JВdS)Nrnr┌expectedrwrrcУsБИаdбIdH|ks JВdSйNrйrд)r┤й┌rrr┌receiverєАz1test_memory_stream_one_way_pair..receiverrsrВror+rc╙sБtГIdH|jабdSrD)r r)r*)r+rrr┌cancel_after_idle.r"z:test_memory_stream_one_way_pair..cancel_after_idlecУsDБtаtjбПИаdбIdHWdГdS1swYdSr╡)rFrGrr$rдrr╖rr┌check_for_cancel2sА"¤z9test_memory_stream_one_way_pair..check_for_cancelrqs456789)r┤rwrr)r+rrrr&) ┌memory_stream_one_way_pairrУrЧrЫrлrНrдrr'r(r rаrГ)┌sr╣r+┌oldr╗r╝rr╖r┌test_memory_stream_one_way_pair sLА (¤(¤ (¤ *■r└c ГsЇБtГ\ЙЙИаdбIdHИаdбIdHИаdбIdHdks"JВИаdбIdHdks.JВИабIdHИаdбIdHdksAJВdЗfddД}dЗfd d Д}tаб4IdHЪ}|а|б|а|бWdГIdHdS1IdHsswYdS)NrnrsrrВrrcУs"БtГIdHИаdбIdHdS)NrА)r rНr)┌brr┌senderKsАz'test_memory_stream_pair..sendercУsБИаdбIdHdks JВdS)NrrАr╢r)┌arrr╣Or║z)test_memory_stream_pair..receiverr&)┌memory_stream_pairrНrд┌send_eofrr'r()r┬r╣r+r)r├r┴r┌test_memory_stream_pairAsА .■r╞c├s:БdddД}t|dГIdHd ddД}t|dГIdHdS) Nr·,tuple[MemorySendStream, MemoryReceiveStream]c╙єБtГSrD)r╜rrrr┌one_way_stream_makerXєАzDtest_memory_streams_with_generic_tests..one_way_stream_maker·qtuple[StapledStream[MemorySendStream, MemoryReceiveStream], StapledStream[MemorySendStream, MemoryReceiveStream]]c╙r╚rD)r─rrrr┌half_closeable_stream_maker]єАzKtest_memory_streams_with_generic_tests..half_closeable_stream_maker)rr╟)rr╦)┌check_one_way_stream┌check_half_closeable_stream)r╔r╠rrr┌&test_memory_streams_with_generic_testsWє А r╨c├s:БdddД}t||ГIdHd ddД}t||ГIdHdS) Nr· tuple[SendStream, ReceiveStream]c╙r╚rD)┌lockstep_stream_one_way_pairrrrrr╔gr╩zFtest_lockstep_streams_with_generic_tests..one_way_stream_maker·Ytuple[StapledStream[SendStream, ReceiveStream], StapledStream[SendStream, ReceiveStream]]c╙r╚rD)┌lockstep_stream_pairrrrr┌two_way_stream_makerlr═zFtest_lockstep_streams_with_generic_tests..two_way_stream_maker)rr╥)rr╘)r╬┌check_two_way_stream)r╔r╓rrr┌(test_lockstep_streams_with_generic_testsfr╤r╪c├s2БdddД}tаб}|аdбIdH|аdб|t|ГГIdHtаб}|аd бIdH|аdб|t|ГГIdHtrYtjtjd Н}|аdбIdH|аdб|t|ГГIdHttdГrЧtjtjd Н}t а бП$}|Ыd Э}|а|бIdH|аdб|t|ГГIdHWdГdS1sРwYdSdS)N┌listenerrrrc╙sЇБ|4IdHЪft|ГIdH}|4IdHЪB|абIdH}|4IdHЪ|аdбIdH|аdбIdHdks8JВWdГIdHn1IdHsHwYWdГIdHn1IdHs]wYWdГIdHdS1IdHsswYdS)NєxrV)┌open_stream_to_socket_listener┌acceptrНrд)r┘┌ client_stream┌ server_streamrrr┌checkvsА*■*■.■z2test_open_stream_to_socket_listener..check)z 127.0.0.1rr)z0.0.0.0r)┌family)z::r┌AF_UNIXz/sock)r┘rrr)┌tsocketr┌bind┌listenrr┌AF_INET6┌hasattrrс┌tempfile┌TemporaryDirectory)r▀┌sock┌tmpdir┌pathrrr┌#test_open_stream_to_socket_listenerus0А "№√rьcCsVd ddД}tjtdd НПt|ГtГtd dНdНWdГdS1s$wYdS)Nr-rR┌autojump_clockrrc╙sБdSrDrйr-rэrrr┌busy_kitchenаsАz$test_trio_test..busy_kitchenz"^too many clocks spoil the broth!$)┌matchr)┌autojump_thresholdrю)r-rRrэrRrr)rFrG┌ ValueError┌ trio_testr.)rяrrr┌test_trio_testЯs ■" rЇr&)r-r.rr)rBrCrr)/┌ __future__rrч┌typingrrF┌rrrrт┌_core._tests.tutilr┌_highlevel_genericr r ┌_highlevel_socketr┌testing┌testing._check_streamsr ┌testing._memory_streamsr┌trior┌trio.abcrrr,r5rArNrPrcrjrmrМrбrпr░r│r└r╞r╨r╪rьrЇrrrr┌sB * & H \ = 8 *