,i$UUddlmZddlZddlZddlmZddlmZddlZddl m Z m Z ddl m Z ddlmZdd ldd lmZdd lmZmZd0d Zd0d Zd0dZd0dZd0dZd0dZd0dZd0dZej<j?de e!gd d1dZ"d0dZ#ddl$m%Z%ddlm&Z&Gdde&Z'Gdde&Z(Gdd e&Z)d!d"e e!d#d$e(e)gZ*gd%Z+ej<j?d&e*e+Z,e-e.ze ze!ze'ze(ze)zZ/d'e0d(<ege/fZ1d'e0d)<e,d2d*Z2e,d2d+Z3e, d2d,Z4d0d-Z5d0d.Z6d0d/Z7y)3) annotationsN)Callable) TypeAlias)Matcher RaisesGroup)_core)GLOBAL_PARKING_LOT_BREAKER)*) sleep_forever)assert_checkpointswait_all_tasks_blockedcKtjrJjjdk(sJt j t d5jdddjjsJt5jd{dddtgdfd }tj4d{}|j||j|td{ddgk(sJjjdk(sJjtd{gdk(sJdddd{y#1swYxYw7#1swYxYw777=7&#1d{7swYyxYww) Nrztrio\.Event\.__bool__ is deprecated since Trio 0\.31\.0; use trio\.Event\.is_set instead \(https://github.com/python-trio/trio/issues/3238\)matchcKjdjd{jdy7w)Nsleepingwoken)appendwait)erecordsd/var/www/system.tvplus.app.br/jogos/scrap/venv/lib/python3.12/site-packages/trio/_tests/test_sync.pychildztest_Event..child's1 j!ffh g %A?Arr)rrrrreturnNone)Eventis_set statistics tasks_waitingpytestwarnsDeprecationWarning__bool__setr rr open_nursery start_soonr)rnurseryrrs @@r test_Eventr+s Axxz> <<> ' '1 ,, , ^   EEG 88::  ffh A F !!#DDw5!5!$&&&*j1111||~++q000 $&&&CCCCDDD) D ' 'DDDDsAGF ,4G F4F5F93G,F$-G00F, F&!A F,*F(+ F,8 GF*G FGFF!G&F,(F,*G,F>2F5 3F>:Gc Ktdjdk(sJtjt5tddddtjt d5tddddtd}t ||jdk(sJ|jdk(sJ|jdk(sJtjt5|jddd|jdk(sJ|j|jdk(sJ|jdk(sJ|j}|jdk(sJ|jdk(sJ|jtjgk(sJ|j dk(sJtjt5|jddd|jdk(sJtjt5|j#d{ddd|jdk(sJt%5|j'dd{ddd|jdk(sJtjtj(5|j+d dddt-|jjtjdhk(sJ|j/tj|jjdgk(sJ|j/d|jdk(sJt%5|4d{|jdk(sJdddd{dddtj04d{}|j'd d{|j'd d{|j3|j&d t5d{|jdk(sJ|jj dk(sJ|j/d |jdk(sJtjtj(5|jddddddd{|j/d |j/d y#1swYxYw#1swYbxYw#1swYxYw#1swY%xYw7#1swYxYw7#1swYxYw#1swY|xYw77#1d{7swYxYw#1swYxYw7777Y#1swYxYw7#1d{7swYxYww) Nr?^total_tokens must be >= 0$rrsomeonez third partyzvalue 1zvalue 2zvalue 3)CapacityLimiter total_tokensr#raises TypeError ValueErrorreprborrowed_tokensavailable_tokens RuntimeErrorreleaseacquire_nowaitr! borrowersr current_taskr"acquirer acquire_on_behalf_of WouldBlockacquire_on_behalf_of_nowaitr'release_on_behalf_ofr(r)r)cstatsr*s rtest_CapacityLimiterrF7s 1  * *a // / y ! z)G HAG >>Q     !! !   "" " | $    !! !   !! !   "" " LLNE  A %% %    "" " ??u1134 44 4   ! ## # | $    !! ! | $iik   !! !  0$$Y///0   !! ! u'' (5 %%m45 q||~'' (U-?-?-A9,M MM M5--/0 <<> # # { 22 29%   !! !  * * *$$) )) * **!!#  w$$Y///$$Y///1119=$&&&  A%%%||~++q000 y)  A%%% ]]5++ ,       9%9%C  000 55 * * * * *** //&       s4U= S#U=% S1A*U=S,C U=7S+2U=:S;S8S;#U=6T  T T  U=UU="U(7U8U(U-U(>U?A9U(8U U( U=U&'U=S U=SU=S(#U=+S50U=8S;;TU=T  TU=T"U=%U(U+T> 1T42T> 9UU  U=U(U(U(U# U(&U=(U:.U1 /U:6U=cKddlm}t|}t||j|k(sJ|j dk(sJ|j |k(sJtjt5|jddd|j dk(sJ|j|j dk(sJ|j |k(sJy#1swYMxYww)Nr)infr0) mathrHr2r7r3r8r9r#r4r:r;r<)rHrDs rtest_CapacityLimiter_infrJ}sAG >>S    !! !   $$ $ | $    !! !   !! !   $$ $ sA)C+Crr0rrM)r2r#r4r5r3r6r r(ranger)r@rr'r!r=r"r8rCrDr*is r(test_CapacityLimiter_change_total_tokensrRsA y ! z)G H z)G H >>Q  !!#11wq +A   q55q 9(* * * +1<<>++,A666||~++q000 !1<<>++, <<<||~++q000 !  A%%%~~""" q! q! q!1<<>++,333||~++q000 q!1<<>++,333||~++q000'111 1 +1111s%LJ<#LK #L=K1L6K#7L:8K+2K&3F8K++ L6K)7L<KL KLK  L&K+)L+K=1K4 2K=9LcKtd}|jd{tj4d{}|j |jt d{|j jdddd{t|jdk(sJy77x7M7%#1d{7swY5xYww)Nr0)r3r) r2r?r r(r)r cancel_scopecancellen_pending_borrowers)limiterns r test_CapacityLimiter_memleak_548rZs1-G // !!#  q W__%$&&&    w)) *a // / &    sh CB6CB8C)B>,B:-B> CB< C8C:B><C>CC C Cc Ktd}|jdk(sJtj4d{}d|_t dD]0}|j |j |td{2t|jjtk(sJ|jjdk(sJd|_t|jjhdk(sJ|j |j dtd{|jjdk(sJt dD]}|j||jjdk(sJ|jdd|_tjtj5|j!ddd|j |j dtd{|jjdk(sJ|jjgk(sJd|_|jjdk(sJ|jjdgk(sJ|jd|j dd{|j |j dtd{d|_|jjdgk(sJ|jdtd{|jjgk(sJ|jjdk(sJd|_td{|jjdgk(sJ|jjdk(sJ|jdd|_|j"j%dddd{|jdk(sJ|jjgk(sJ|j&ik(sJy777,#1swYxYw7[777>77j#1d{7swYzxYww)NrLr>rr0rrMrNr0)r2r3r r(rOr)r@rr'r!r=r"rCr#r4rAr<rTrUrWrPs r&test_CapacityLimiter_zero_limit_tokensr]sA >>Q  !!#A&A&wq +A   q55q 9(* * * +1<<>++,555||~++q0001<<>++,???11115$&&&||~++q000q &A " "1 % &||~++q000 q! ]]5++ ,      11115$&&&||~++q000||~''2---||~++q000||~''A3... q!$$Q'''11115$&&&||~''A3... q!$&&&||~''2---||~++q000$&&&||~''A3...||~++q000 q!##%CA&A&F >>Q   <<> # #r )) )  2 %% %KA& + '   ' ( ' ' 'sA&A&A&A&s5R QR ?Q6:Q;B/Q6*Q+BQ6 Q1Q6 Q& B-Q69Q):-Q6'Q,(A Q61Q/2AQ6Q2 A5Q6> R  Q4 AR Q6Q6Q#  Q6)Q6,Q6/Q62Q64R 6R<Q? =RR cKtjt5tddddtjtd5tddddtd}t ||j dk(sJ|jJ|j|j dk(sJ|jjdk(sJ|j|j dk(sJt5|jd{ddd|j dk(sJtjtj5|jddd|j|j dk(sJt5|4d{|j dk(sJdddd{ddd|j dk(sJ|jgd fd }tj 4d{}|j#||t%d{d gk(sJ|j dk(sJ|j|j dk(sJtjtj5|jddddddd{d d gk(sJy#1swYxYw#1swYxYw7#1swYxYw#1swYxYw7_7A#1d{7swYRxYw#1swYWxYw77#1swYxYw7#1d{7swYxYww) Nr-z^initial value must be >= 0$rr/r0rrcKjd|jd{jdy7wNstartedfinished)rr?)srs r do_acquirez"test_Semaphore..do_acquire+s3 i iik j! rrarb)rc Semaphorerr)r#r4r5rer6r7value max_valuer;r!r"r<r r?r rAr(r)r)rcrdr*rs @rtest_Semaphorerh s y !# z)H I" ! AG 77a<< ;;  IIK 77a<< <<> ' '1 ,, , 77a<<  iik 77a<< u'' ( IIK 77a<<     77a< <    77a<< F" !!#  w:q)$&&&)$$$ww!|| ww!|| ]]5++ ,        i, ,, ,Y          &       sDM K#M KB(MK%K"K%= initial_value$rrz#^semaphore released too many times$r) r#r4r5rer6rgr7r;rfr<)bss rtest_Semaphore_boundedrk=s y !$!s#$ z)Q R"!q!" 1 "B <<1  H z)O P  88q== 88q==JJL 88q==$$"" s#D D%D*DD'*D3lockclsc|jSN)__name__)fns rrqNs 2;;)idscK|jrJtj}|usJt|jtvsJt 54d{jsJtdddd{dddjrJj jsJjjrJt 5jd{dddjsJjjrJj tjt5j dddjtjt5jdddddfd }tj4d{}jrJ|j|td{jsJtjtj 5j dddtjt5jdddj#}t%||jsJ|j&usJ|j(dk(sJ|j|td{j#}t%||j(dk(sJ|j*j-dddd{j#}|jrJ|j&J|j(dk(sJy7O7%#1d{7swY6xYw#1swY;xYw7#1swYxYw#1swYaxYw#1swY,xYw77#1swYxYw#1swYqxYw7 7#1d{7swYxYww)NcKtj4d{td{dddd{y7'77 #1d{7swYyxYwwrn)r r>r ) holder_tasklsrholderz,test_Lock_and_StrictFIFOLock..holdervsV((*  " "/ ! ! " " " ! " " " "sSA!AA!A AA  A!A A!A  A! AA AA!rr0r)lockedweakrefrefr7ror r<r;r?r#r4r:r r(r)rrAr!printownerr"rTrU)rlrrxr*r!rvrws @@rtest_Lock_and_StrictFIFOLockrNs  Axxz>  AA 3!8O8G   tAw && &    88: : G  xxz> 88::IIKxxz>  iik 88::IIKxxz> | $ IIK | $ K" !!#&&w88:~6"$&&&xxzz ]]5++ ,     ]]< (  IIK \\^  j    ;...''1,,,6"$&&&\\^  j''1,,,##%1&&4J      ## #  # #q (( (y      & '     ''&&&&sUA(Q,O3O4O7O O O!O%A(Q O.!O+"O.&A%Q O;1Q P)QPQ 1P:<P=9P:6P!P:(P(9A0P:)P5*A P:4 Q?P8AQOOO OO OO(#Q+O..O83Q;PQP QP:P% P:(P2 - P:8Q:Q Q Q Qc| Ktjt5tt ddddtjt5tt dddt }t||jrJjrJt5jd{ddd|jsJjsJtjrJjjsJtjt5jdddjtjt5jd{dddtjt5jdddtjt5jdddt!dfd }t#j$4d{}t'dD]&}|j)||t+d{(4d{jdddd{jsJt+d{dhk(sJ4d{jdddd{t+d{hdk(sJdddd{t!t#j$4d{}t'dD]&}|j)||t+d{(4d{jdj-}t/||j0dk(sJ|j2j0dk(sJdddd{j-j2j0dk(sJt+d{ddhk(sJ4d{jdddd{dddd{t#j45}4d{|j7 jd{jsJdddd{dddy#1swYxYw#1swYxYw79#1swY9xYw#1swYxYw7x#1swYxxYw#1swYSxYw#1swY.xYw7777#1d{7swYxYw777z#1d{7swYxYw77k#1d{7swY|xYw7]7.7$7#1d{7swYxYw777o#1d{7swYxYw7x#1d{7swYxYw7q7K#jsJwxYw7C#1d{7swYTxYw#1swYyxYww)Nr0cK4d{jd{dddd{j|y7>7(7#1d{7swY*xYwwrn)radd)rQrDfinished_waiterss rwaiterztest_Condition..waitersX  &&(NN  Q      sQA$A A$AA A A$A A$ A A$A!A A!A$rMr>rr0rr)rQintrr)r#r4r5 ConditionreStrictFIFOLockLockryr r?r<r:r;rnotify notify_allr'r r(rOr)rr!r|r"lock_statistics CancelScoperU)rwrr*rQr!scoperDrs @@rtest_Conditionrs6 y ! )A, y !".!" A! Axxz>xxz>  iik 88:: 88:: Axxz> 88:: | $ IIK | $ffh | $   | $ u !!# - -wq +A   vq )(* * * +   HHJ  xxzz$&&&A3&&&   LLN  $&&&9,,, - -u!!#wq +A   vq )(* * * + A A HHQKJ * ++q0 00--;;q@ @@  A A||~--;;q@@@$&&&Aq6)))   LLN  !*    " " " LLN "ffhxxz!z  " """U  ""   - +      '     & - - - - + A A A A A '     !, "xxz!z  " " " """sHX<S"!X<S/$A X</S?S<S?BX< T 1X< T!T"T&!X<T)!X<9T6 1X<;U<X<?.V -U. V :U ;V >U V U #V >U%?V U(V U.& V 1U+2V V V  X<V&X<V X<.W$5V#6 W$V&W$AV, W$*V)+:W$%W&W$9W:W$=W  W$WW$ X<)W!*X<X0 W: X0 XX2W=3X7X X0XX0 X<"S,'X</S94X<<S??T X< TX<TT&!X<)T3.X<6U; X<V  V  V U" UU"  V (V +V .V 4U75V < V X< VV V X<#W$&W$)W$,V? 2V53V? : W$W$W$ W WW W$!X<$W7*W- +W72X<:X0=XXXX0X- X#!X- (X00X95X<)open_memory_channel)AsyncContextManagerMixinc,eZdZddZddZddZddZy) ChannelLock1ctd|\|_|_t|dz D]}|jj dyNr0)rrcr~rO send_nowait)selfcapacity_s r__init__zChannelLock1.__init__sC,T28<x!|$ %A FF  t $ %rrc:|jjdyrnrcrrs rr<zChannelLock1.acquire_nowait 4 rrcVK|jjdd{y7wrn)rcsendrs rr?zChannelLock1.acquiresffkk$s )')c8|jjyrnr~receive_nowaitrs rr;zChannelLock1.release rrN)rrrrrro __module__ __qualname__rr<r?r;rrrrrs% !  rrrc,eZdZddZddZddZddZy) ChannelLock2cptdd\|_|_|jjdyN )rrcr~rrs rrzChannelLock2.__init__s+,T226 4 rrc8|jjyrnrrs rr<zChannelLock2.acquire_nowait rrrcTK|jjd{y7wrn)r~receivers rr?zChannelLock2.acquiresffnns (&(c:|jjdyrnrrs rr;zChannelLock2.releaserrrNrrrrrrrrs! !rrrc,eZdZddZddZddZddZy) ChannelLock3cHtdd\|_|_d|_y)NrF)rrcr~acquiredrs rrzChannelLock3.__init__s",T215 rrc.|jrJd|_yNT)rrs rr<zChannelLock3.acquire_nowaits==   rrcK|jr$|jjdd{yd|_tjd{y7)7wr)rrcrr checkpointrs rr?zChannelLock3.acquire"sG ==&&++d# # # DM""$ $ $ $ %s!+AA#AAAAc |jjy#tj$r|jsJd|_YywxYw)NF)r~rr rArrs rr;zChannelLock3.release)s? " FF ! ! # "== =!DM "s(AANrrrrrrrrs%"rrrctdSr)r2rrrrrqrq2s OA rrctdSr)rerrrrrqrq3s IaLrrctdSrrrrrrrqrq6s L rrctdSrrrrrrrqrq7s LOrr)zCapacityLimiter(1)z Semaphore(1)rrzChannelLock1(10)zChannelLock1(1)rr lock_factoryrLockLike LockFactoryc,Kdd}dddfd }tj4d{}|}t|D]}|j||dddd{rJ|zk(sJy7L7#1d{7swY%xYww)NrrLFrc0KtD]f}|4d{dz rJdtjd{tjd{sJddddd{hy7`7;7!7 #1d{7swYxYww)Nr0TF)rOr r) lock_likerLOOPSacquiresin_critical_sections rworkerz+test_generic_lock_exclusion..workerasu ,A  , ,A ...&*#&&(((&&(((***&+# , , , , ,)(  , , , ,sgBA9B#BA;BA= B& B1A?2B;B=B?BB B B B)rrrr)r r(rOr)) rWORKERSrr*rrrrrs @@@rtest_generic_lock_exclusionrZs EGH ,!!#22w N w 2A   vy 1 222#" " uw && & 22222sD)BA;B*A? B'A=(B=B?BB B BcKggddfd }|}tj4d{}|j|d||j|d||j|d|dddd{tD]}d|zd|dzzk(rJy7q7*#1d{7swY:xYww)NrLcKj|tD].}|4d{j|dddd{0y7(7 #1d{7swYHxYwwrn)rrO)namerrr initial_orderrs rloopyz.test_generic_lock_fifo_fairness..loopy}skT"u $A  $ $ d# $ $ $ $ $ $ $ $ $sC&A+AA+A A+ A A+A+A( AA( $A+r0rrM)rrrrrr)r r(r)rO)rrrr*rQrrrs @@@rtest_generic_lock_fifo_fairnessrwsM F E$I!!#00w5!Y/5!Y/5!Y/00 5\<a!ea1q5k*m;;;< 00000sJ.B>B%B>:B)1 B><B'=#B>!B>'B>)B;/B2 0B;7B>cVK|gdfd }tj4d{}j|j|t d{dgk(sJj dddd{y7`7/7 #1d{7swYyxYww)NcKjd4d{ dddd{jdy7'7#1d{7swY(xYwwr`)r)rrsr lock_takerzCtest_generic_lock_acquire_nowait_blocks_acquire..lock_takersT i       j!     sAAAAA AAAAA A AArar)r r(r<r)rr;)rrr*rrs @@r/test_generic_lock_acquire_nowait_blocks_acquirersI F" !!#w  ":&$&&&)$$$  'sV)B)BB)/B B!B= B)B B)BB)B&B B&"B)c0KtrJtj}tj4d{}|j |j dddd{t jt|jjd}tjtjd|d5|j d{dddtrJy77#1d{7swYxYw7.#1swY-xYww)zTest that trying to acquire a lock whose owner has exited raises an error. see https://github.com/python-trio/trio/issues/3035 Nr.^Owner of this lock exited without releasing: $r)r triorr(r)r?reescapestr_lot broken_byr#r4BrokenResourceError)lockr* owner_strs rtest_lock_acquire_unowned_lockrs*) ) 99;D  "))g4<<()) #dii11!456I    >ykK lln  *) )))))))  so5DC/DC3 D"C1#A"DD DD D1D3D9C< :DDD  DDcKtrJtj}tt tj d5tj 4d{}|j|j|j|jdddd{dddtrJy7[7#1d{7swY'xYw#1swY+xYww)zTest for error if awaiting on a lock whose owner exits without releasing. see https://github.com/python-trio/trio/issues/3035rrN) r rrrrrr(r)r?)rr*s rtest_lock_multiple_acquirers*) ) 99;D   $ $B  - $$& - -'   t|| ,   t|| , - - -*) )) - - - - - --sfACCB8C 7B< C"B:#C'C8C:C<C CC CCCcKtrJd}tj}|jt j |j gitk(sJtj4d{}|j|jtd{|jttdk(sJttt}t||j gk(sJdddd{|j j|gk(sJtrJy777-#1d{7swY=xYwwr)r rrr<r r>rr(r)r?rr;rVnextiterr) child_taskrr*s rtest_lock_handoverrs:)) )"J 99;D   II   $  $$ $   " E Eg4<<($&&& -.!333$9:; )*5$))DDD E E 99  :, .. .)) )) E& E E E Es[A1E 3D/4E 7)D5 D1!AD5: E D3*E 1D53E 5E;D> <EE r)rlztype[Lock | StrictFIFOLock]rr)rrrr)8 __future__rrrzcollections.abcrtypingrr# trio.testingrrr _core._parking_lotr _sync _timeoutsr testingr rr+rFrJrRrZr]rhrkmark parametrizerrrr_channelrrrrrlock_factorieslock_factory_namesgeneric_lock_testr2rer__annotations__rrrrrrrrrrrrs" $ -;%@!DHC&L % !1J 0J&Z--`"T>$:@VWJ) (J) J)XJ)ZQ"h+,  +  !+ !"+"8  KK++,        )""h,/ Y/ ''8<<. **"*"*rr