<|h5ddlmZddlmZddlZddlZddlZddlmZddlmZddl m Z ddl m Z Gdde jZGd d e jZGd d eZe j"d Gdde jZGddeZGddej*ZGddeZdZdZdZGdde jZedk(re j:yy))print_function)absolute_importN SemaphoreBoundedSemaphore)timingcHeZdZdZdZdZejdZdZ y) TestSemaphorechtd}|jd}|dusJt|y)Nr)valueg{Gz?timeoutF)racquirereprselfsresults [/var/www/html/test/engine/venv/lib/python3.12/site-packages/gevent/tests/test__semaphore.py(test_acquire_returns_false_after_timeoutz6TestSemaphore.test_acquire_returns_false_after_timeouts1 A 4(,V ,ct}g|jfd|j|jfd|jtjd|j t ddgy)Nc&jdS)Naappendrrs rz2TestSemaphore.test_release_twice..FMM#.rc&jdS)Nbrrs rrz2TestSemaphore.test_release_twice..!r rgMbP?rr")rrawlinkreleasegeventsleep assertEqualsortedrs @rtest_release_twicez TestSemaphore.test_release_twices_ K ./  ./  U #s4rcpt}tj|}|j||yN)rweakrefrefr')rrrs rtest_semaphore_weakrefz$TestSemaphore.test_semaphore_weakref's( K KKN AC rcxGddt}|ddl}|j|jy)NceZdZdZdZy)9TestSemaphore.test_semaphore_in_class_with_del..Xc"t|_yr+)rrrs r__init__zBTestSemaphore.test_semaphore_in_class_with_del..X.__init__2s "rc8|jjyr+)rrr4s r__del__zATestSemaphore.test_semaphore_in_class_with_del..X.__del__5s rN)__name__ __module__ __qualname__r5r7rrXr21s  % !rr<r)objectgccollect)rr<r>s r test_semaphore_in_class_with_delz.TestSemaphore.test_semaphore_in_class_with_del,s*  ! !   rcDt}tj|gyr+)rr%wait)rrs r)test_rawlink_on_unacquired_runs_notifiersz7TestSemaphore.test_rawlink_on_unacquired_runs_notifiers>s K QCrN) r8r9r:rr)r/ greentestignores_leakcheckr@rCr;rrr r s0- 5!   !"rr ceZdZdZdZdZdZ ddZdZdZ dZ d Z e jd dd Zd ZdZy )TestSemaphoreMultiThreadctSr+rr4s r_getTargetClassz(TestSemaphoreMultiThread._getTargetClassNsrc.|jdS)N)rIr4s r_makeOnez!TestSemaphoreMultiThread._makeOneQs &t##%a((rc B ddlmddl  fd}|S)Nrget_hub_if_existscj jjdi }|"|j |j djy#jddxYw#}|"|j |j djwxYw)NT destroy_loopr;)setrrexc_infojoindestroy) hubacquiredrTrOsemsysthread_acquire_kwargsthread_acquiredthread_runnings r thread_mainz=TestSemaphoreMultiThread._makeThreadMain..thread_main^s     &CKK8"78()?HHJKKTK2##% !lln ')?HHJKKTK2##%s!A11BB =C)gevent._hub_localrOrZ) rr]r\rYrXrTr[r^rOrZs `````` @@r_makeThreadMainz(TestSemaphoreMultiThread._makeThreadMainXs 8 & &rc ddlm}|j|jdddl}|j }|j }|j }|jg} g} |j|j|||| | fi|} d| _ | j|jd|rr|jt|jD]7} tj |jt"j$s7n|j'| dg|s`|j)drOt|jD]7} tj |jt"j$s7n|jt"j$dz|r|j+|j- |j'| gd} || fS#d} wxYw) Nrmonkey threadingtargetT rra)r%rd assertFalseis_module_patchedreEventrLrThreadr`daemonstartrBr$rangeIDLE_ITERATIONSidler LARGE_TICKr'get assertTrueis_set) rr$!require_thread_acquired_to_finishr[rdrer]r\rYrTrXt_s r$_do_test_acquire_in_one_then_anotherz=TestSemaphoreMultiThread._do_test_acquire_in_one_then_anotherqs " 11+>?"*#//+mmo    $8D$8$8 OS h% $%     B  KKM4//0  "''(9(9:    Xv .044Y?4//0  "''(9(9:  V..23 , OOO224 5    Xr *HH}Hs G00G4c(|jdy)NT)r$)ryr4s r test_acquire_in_one_then_anotherz9TestSemaphoreMultiThread.test_acquire_in_one_then_anothers 11$1?rc|jddtj\}}|jdg||j t |dd}|j |y)NFT)r$rvr _notifier)ryr SMALLEST_RELIABLE_DELAYr'r$getattr assertIsNone)rrYacquired_in_threadnotifiers r&test_acquire_in_one_then_another_timedz?TestSemaphoreMultiThread.test_acquire_in_one_then_another_timedsi"&"K"K.222#L#4  %"45 3 T2 (#rc 6 ddlm}|j|jdddl}|j j  fd}g}g}tj|}|j|j|j|j||tj d _ tjj|j!t#dD]5}tj j!tj7|j%|j&d|j%g||j%d g||j)|j*|d}y) Nrrcrecj}jtjtj |Sr+)rrnr%r&r rr)ackrYthreads r greenlet_onezeTestSemaphoreMultiThread.test_acquire_in_one_wait_greenlet_wait_thread_gives_up..greenlet_ones0++-C LLN LL** +JrrrfTF)r%rdrirjrerLrspawnrlr`rkr rrrmrqr$rUror'r rtdead) rrdrerrTrXgletrxrYrs @@r6test_acquire_in_one_wait_greenlet_wait_thread_gives_upzOTestSemaphoreMultiThread.test_acquire_in_one_wait_greenlet_wait_thread_gives_upsA " 11+>?mmo  ||L)!!)=)= OO y0  h%% *>* !      q +A KKM KK)) * + T* X& %(+  4(rc<|j|j|yr+)rrW)rrYs rassertOneHasNoHubz*TestSemaphoreMultiThread.assertOneHasNoHubs #''3'rz&Flaky there; can't reproduce elsewhereNc  ddlm}ddlm j |j dddl}ddlm jjd ddg d   f d }|j|d }d|_ |j|d }d|_ |j|j|jd |jd |js|jrWt! }|jd|jd| k(rd n"|jrF|jrWj# d z d z gy)NrrcrNre)r&i'Tc rtj tD]} snj}s|sJ|rj | |<s j   ||fr,|dzdk(r$tj tj|dzdk(s tj }|#|j|jdyy#t$r.}ddl }|jt| |<d}Yd}~_d}~wwxYw# }|#|j|jdwwxYw)NrhrdTrQ)r%get_hubrorr$rr&r r~ Exception traceback print_excstrrUrV)ixirXexrrW acquire_argscount create_hubrO native_sleepresultsrunrrYs rdo_itz.do_itsG  3uEA*s{{L9H'833 "#GBK%))-/.0"a8"a"fk V%C%CDSA$V%C%CD%E0()?HHJKKTK2#   )"5"5"7!"g   ()?HHJKKTK2#s0BC4/C44 D+=$D&!D.&D++D...E)r)rgargs)rKrKF)r%rdr_rOrirjretimer&rLrrlrmrnrUis_alivelistr')rrrrdrert1t2currrOrrrrYs``` @@@@@@rtest_dueling_threadsz-TestSemaphoreMultiThread.test_dueling_threadss5 "7 11+>?.mmo s#r( 3 3D  U  6   U  6         kkmr{{}w-C GGAJ GGAJg~kkmr{{} 519eai"89rc&|jdy)N)Trr4s rtest_dueling_threads_timeoutz5TestSemaphoreMultiThread.test_dueling_threads_timeout<s !!),rc(|jdy)NT)rrr4s rtest_dueling_threads_with_hubz6TestSemaphoreMultiThread.test_dueling_threads_with_hub?s !!T!2r)TF)r;N)r8r9r:rIrLr`rpryr{rrrrDskipOnPyPyOnWindowsrrrr;rrrGrGGsl).O6:OT<|@ $.`(#Y""#KLH:MH:T-3rrGceZdZdZy)TestBoundedSemaphoreMultiThreadctSr+rr4s rrIz/TestBoundedSemaphoreMultiThread._getTargetClassIsrN)r8r9r:rIr;rrrrGs rrzNeeds C extensionceZdZdZy)TestCExtcD|jtjdy)Nzgevent._gevent_c_semaphore)r'rr9r4s rtest_c_extensionzTestCExt.test_c_extensionOs --5 7rN)r8r9r:rr;rrrrLs7rrc*eZdZdZdZdZdZdZy)SwitchWithFixedHashc4|j|_||_yr+)switchhashcode)rgreenletrs rr5zSwitchWithFixedHash.__init__[soo   rctr+AssertionErrorr4s r__hash__zSwitchWithFixedHash.__hash___rctr+r)rothers r__eq__zSwitchWithFixedHash.__eq__brrc&|j|i|Sr+)rrrkwargss r__call__zSwitchWithFixedHash.__call__est{{D+F++rc,t|jSr+)rrr4s r__repr__zSwitchWithFixedHash.__repr__hsDKK  rN)r8r9r:r5rrrrr;rrrrTs!,!rrceZdZdZdZy)FirstGrhctjj|g|i|t||j|_yr+)r%Greenletr5rrrrs rr5zFirstG.__init__ps0  777)$ > rN)r8r9r:rr5r;rrrrksH?rrceZdZdZy)LastG N)r8r9r:rr;rrrrusHrrcF|j|jdy)NT)rr)rY should_quits racquire_then_exitrzsKKMtrc|ry|jtjt||}|j yr+)rrrrelease_then_spawnrUrYrgs racquire_then_spawnrs-KKM 'k:AFFHrc|j|rytjt||}|j yr+)r$rrrrUrs rrrs-KKM 'k:AFFHrceZdZdZy)TestSemaphoreFairct}g}tjt||}tjt||}tjt ||}|j tjj5tj|||gddd|j|j||j|j||j|j||j|j|j|jtj y#1swYxYwr+)rrrrrr assertRaisesr% exceptionsLoopExitjoinallrtrrir$killrq)rrYr keep_going1 keep_going2exitings rtest_fair_or_hangsz$TestSemaphoreFair.test_fair_or_hangssk ll#5sKH ll#5sKH ++/kB   v0099 : @ NNKg> ? @  g.  ((+6 ));7    @ @s EEN)r8r9r:rr;rrrrsrr__main__) __future__rrr,r%gevent.exceptions gevent.lockrrgevent.testingtestingrDr TestCaser rGrskipOnPurePythonrr=rrrrrrrrr8mainr;rrrs&& !("!0I&&0fy3y11y3@ &> /07y!!717!&!.?V__?F     **6 zINNr