<|hP1ddlZddlZddlmZddlmZddlmZddlmZddlm Z ddl m Z ddl m Z dd lmZdd lmZeed ZGd d eZGddeZGddeej.ZGddeej.ZGddeZe dGddeej.Zedk(rej:yy)N)gettrace)settrace) get_original)thread_mod_name) NativeStrIO)verify)skipWithoutPSUtil)_monitor)config get_identc@eZdZdZdZdZdZeZdZe dZ dZ y)MockHubNcNt|_t|_d|_y)NF)r thread_identrexception_streamdeadselfs Z/var/www/html/test/engine/venv/lib/python3.12/site-packages/gevent/tests/test___monitor.py__init__zMockHub.__init__s%K +  c|j SNrrs r__bool__zMockHub.__bool__s99}rcr)rargss r handle_errorzMockHub.handle_error$s rc|Srrrs rloopz MockHub.loop's rcy)zmock loop.reinitNrrs rreinitzMockHub.reinit+r) __name__ __module__ __qualname__ _threadpool _resolverrr __nonzero__rpropertyr!r#rrrrrs;KI Krrc(eZdZfdZfdZxZS)%_AbstractTestPeriodicMonitoringThreadctt tj_tj _dt_d_fd}|t_t_ tjj_ jj_ jjdd_t!j_y)Nc*tjSr)gccollect)_ss rz=_AbstractTestPeriodicMonitoringThread.setUp..7s "**,r>[=cJj}xjdz c_|SN)tid)_f_arrs rstart_new_threadzE_AbstractTestPeriodicMonitoringThread.setUp..start_new_thread9sA HHMHHr)superr-setUpmonitorr<_orig_start_new_thread thread_sleep_orig_thread_sleepr8rhubPeriodicMonitoringThreadpmtperiodic_monitoring_threadmonitoring_functionspmt_default_funcslenlen_pmt_default_funcs)rr< __class__s` rr>z+_AbstractTestPeriodicMonitoringThread.setUp3s 3T@B&-&>&>#")"6"66  $4 933DHH=.2hh+!%!>!>!@!C%()?)?%@"rcB|jt_|jt_|j j j}|j jt|usJt|ftdtt|7yr)r@r?r<rBrArE_greenlet_tracerprevious_trace_functionkillrrr=r-tearDown)rprevrKs rrPz._AbstractTestPeriodicMonitoringThread.tearDownEsr#'#>#> #66xx((@@  zT!5HJ#55! 3TCEr)r%r&r'r>rP __classcell__)rKs@rr-r-.s A$FFrr-c^eZdZdZeddZdZdZdZdZ dZ d Z d Z d Z y ) TestPeriodicMonitoringThreadc|jd|jj|jt|jjy)Nr4) assertEqualrEmonitor_thread_identrrMrs rtest_constructorz-TestPeriodicMonitoringThread.test_constructorRs8 TXX%B%BC TXX%>%>?rzVerifies the processc|jj}|j||j||jjyr)rE _get_processassertIsNotNoneassertIs)rprocs rtest_get_processz-TestPeriodicMonitoringThread.test_get_processVs=xx$$& T" dDHH1134rcV|j|j|jj|`tj|j |jj|j |jj|j tyr) r\rCrEr0r1 assertIsNone assertFalse should_runrrs r test_hub_wrefz*TestPeriodicMonitoringThread.test_hub_wref]sj dhh - H  $((,,' ,,- (*%rc|jt|jjdd|jt|jjddd}|jj|d|j |j dzt |jj|j d|jjdj|jj|d|j |j dzt |jj|j d|jjdj|jj|d|j |j t |jjy)Nr7cyrrrrrr3zKTestPeriodicMonitoringThread.test_add_monitoring_function..lr$rcy)z Does nothingNrrrrfzDTestPeriodicMonitoringThread.test_add_monitoring_function..fnr$r) assertRaises ValueErrorrEadd_monitoring_functionrVrJrIrGperiodrrhs rtest_add_monitoring_functionz9TestPeriodicMonitoringThread.test_add_monitoring_functionisX *dhh&F&FaP *dhh&F&F VXY  ((A. 33a7TXX=Z=Z=\9]^ DHH99;A>EEF ((A. 33a7TXX=Z=Z=\9]^ DHH99;A>EEF ((D1 33S9V9V9X5YZrc|j|jjdj|jj d|j_|j|jj |jj d|jjd_d|j_|jj|j|jjdj|jj |j|jjdj|jj y)Nrrf)rVrErGrmcalculate_sleep_time_calculated_sleep_timeinactive_sleep_timers rtest_calculate_sleep_timez6TestPeriodicMonitoringThread.test_calculate_sleep_times  HH ) ) +A . 5 5 HH ) ) + - +,'  HH ( ( HH ) ) + 57%%'*1*+' %%'  HH ) ) +A . 5 5 HH ) ) + -  HH ) ) +A . 5 5 HH + + -rcfd}jj|djjjjy)Nc@d}d_tjyr)rCr0r1)_hubrs rrhz?TestPeriodicMonitoringThread.test_call_destroyed_hub..fsDDH JJLr皙?rErlrarbrns` rtest_call_destroyed_hubz4TestPeriodicMonitoringThread.test_call_destroyed_hubs?  ((C0   ,,-rcd}|jj|d|j|j|jjy)Ncd|_y)NTr)rCs rrhz:TestPeriodicMonitoringThread.test_call_dead_hub..fs CHrrxryrns rtest_call_dead_hubz/TestPeriodicMonitoringThread.test_call_dead_hubs<  ((C0   ,,-rcbd}|jj|d|jy)Nctr) SystemExit)rws rrhz.fs , rrx)rErlrns rtest_call_SystemExitz1TestPeriodicMonitoringThread.test_call_SystemExits&  ((C0  rcGddtfd}|jj|d|j5|jdddy#1swYyxYw)Nc eZdZy)GTestPeriodicMonitoringThread.test_call_other_error..MyExceptionN)r%r&r'rrr MyExceptionrs rrcrr)rwrs rrhz=TestPeriodicMonitoringThread.test_call_other_error..fs - rrx) ExceptionrErlrj)rrhrs @rtest_call_other_errorz2TestPeriodicMonitoringThread.test_call_other_errorsV )   ((C0   { +  HHJ   s AA&cDddl}ddlm}d|j_|jj }||j |j|j|jj|j|dz|jj y)Nr)r#rfr7) os gevent.hubr#rEpidrWrCrVgetpid)rrr#old_tids rtest_hub_reinitz,TestPeriodicMonitoringThread.test_hub_reinitsj% ((//txx dhhll3 1dhh&C&CDrN)r%r&r'rXr r^rcrortrzr}rrrrrrrTrTOsL@-.5/5 &[,-2 ..  ErrTceZdZdZdZdZy)TestPeriodicMonitorBlockingc|jj|jtgfd}t |t j |j|_|jt|jj|j|jjj||jjdd|jdgy)Nc(j|yr)append)rcalleds rrhz:TestPeriodicMonitorBlocking.test_previous_trace..fs MM$ reventr)rr) rErOr`rrr?rDrCrVrMr\rN)rrhrs @rtest_previous_tracez/TestPeriodicMonitorBlocking.test_previous_traces   (*%   33DHH= TXX%>%>? dhh//GGK !!'95 ./8rct|jd|jjj|jjdd|jd|jjj|j |jjj t }t }|jjd||f|jd|jjj|j||jjj |jjdd|jd|jjj|j |jjj y)Nrunknownr7switchrir)rVrErMgreenlet_switch_counterr`active_greenletobjectr\)rorigintargets rtest__greenlet_tracerz1TestPeriodicMonitorBlocking.test__greenlet_tracers- DHH55MMN !!)T2 DHH55MMN $((33CCD !!(VV,<= DHH55MMN fdhh77GGH !!)R0 DHH55MMN $((33CCDrcVddlm}ddlm}g}|j|j|j |j j |jt}t}|j jd||f|j |j j |j|j ||j|j j |j|j|tj||d|dd=|j j|j |j j |j|j ||j j|j|j j |jd|j_|j|j j |jy)Nr) subscribers)IEventLoopBlockedrrf) gevent.eventsrrrrarEmonitor_blockingrCrrM assertTruer verifyObject ignore_current_greenlet_blocking!monitor_current_greenlet_blockingr)rrreventsrrs rtest_monitor_blockingz1TestPeriodicMonitorBlocking.test_monitor_blockings .36==) 22488<= !!(VV,<= 22488<=   11$((;< -vay9 1I 113 22488<=   224 11$((;<!# 11$((;.0s DHH(=r)r-r> GEVENT_CONFIGmax_memory_usage_old_maxrErZrs`rr>zTestPeriodicMonitorMemory.setUp+s2-33D9%66 )- & =rcX|jt_tj |yr)rrrr-rPrs rrPz"TestPeriodicMonitorMemory.tearDown2s)- &-66t.Ar$rT)recordr7) warningsrErZrarcatch_warningsrrVrIr\r?MonitorWarningcategory)rrwss rtest_cannot_monitor_and_installz9TestPeriodicMonitorMemory.test_cannot_monitor_and_install?s , ::<= $ $D $ 1 4R HH 1 1 3 4 CG$ g,,benn=  4 4s B>>CcZ|jd|jjdy)Nrf)rVrEmonitor_memory_usagers rtest_monitor_no_allowedz1TestPeriodicMonitorMemory.test_monitor_no_allowedKs! TXX::4@Arc4ddlm}d|_dt_|j j d}|j||j|jd|j|jd|j|j|jt|j j d}|j|d|_|j j d}|j||j|jd|jd|_|j j d}|j||j|jd|jt!||j j d}|j|d|_|j j d}|j||j|jd|jy)Nr)rrir7r)geventrrrrrErassertIsInstanceMemoryUsageThresholdExceededrV mem_usage max_allowed memory_inforr`MemoryUsageUnderThresholdrepr)rrrs rtest_monitor_greaterz.TestPeriodicMonitorMemory.test_monitor_greaterNs!)* &--d3 eV%H%HI EOO, E--. e//=--d3 % --d3 eV%H%HI EOO,--d3 eV%E%EF EOO, U --d3 % --d3 eV%H%HI EOO,rcd|_dt_|jj d}|j |y)Nr7 )rrrrErr`)rrs rtest_monitor_initial_belowz4TestPeriodicMonitorMemory.test_monitor_initial_belowys5)+ &--d3 % rN) r%r&r'rr>rPrrrrrrrrrr%s/ C>=_ >B(-V!rr__main__)r0unittestgreenletrr gevent.monkeyrgevent._compatrrgevent.testingrgevent.testing.skippingr rr r?r rr rrr-TestCaserTrrrr%mainrrrrs &*&!5&* + 6 f0FFFBzE#H#+#4#4zE|L="G"*"3"3L=^&*+Y! E ( 1 1Y!,Y!v zHMMOr