ó úR‹_c@sfddlZddlZddlmZddlmZddlmZddlmZddlm Z ddl m Z ddl m Zdd l mZeed ƒZd efd „ƒYZd efd„ƒYZdeejfd„ƒYZdeejfd„ƒYZdefd„ƒYZe dƒdeejfd„ƒYƒZedkrbejƒndS(iÿÿÿÿN(tgettrace(tsettrace(t get_original(tthread_mod_name(t NativeStrIO(tskipOnPyPyOnWindows(t_monitor(tconfigt get_identtMockHubcBsMeZdZdZd„Zd„ZeZd„Ze d„ƒZ d„Z RS(cCs%tƒ|_tƒ|_t|_dS(N(Rt thread_identRtexception_streamtFalsetdead(tself((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyt__init__s  cCs|j S(N(R (R((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyt__bool__scGs‚dS(N((Rtargs((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyt handle_error#scCs|S(N((R((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pytloop&scCsdS(smock loop.reinitN((R((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pytreinit*tN( t__name__t __module__tNonet _threadpoolt _resolverRRt __nonzero__RtpropertyRR(((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyR s   t%_AbstractTestPeriodicMonitoringThreadcBseZd„Zd„ZRS(cs±ttˆƒjƒtjˆ_tjˆ_d„t_dˆ_‡fd†}|t_t ƒˆ_ tj ˆj ƒˆ_ ˆj ˆj _ ˆj jƒˆ_tˆjƒˆ_dS(NcSs tjƒS(N(tgctcollect(t_s((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyt6RIï¾­Þcsˆj}ˆjd7_|S(Ni(ttid(t_ft_atr(R(sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pytstart_new_thread8s (tsuperRtsetUptmonitorR&t_orig_start_new_threadt thread_sleept_orig_thread_sleepR"R thubtPeriodicMonitoringThreadtpmttperiodic_monitoring_threadtmonitoring_functionstpmt_default_funcstlentlen_pmt_default_funcs(RR&((RsT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyR(2s      cCsy|jt_|jt_|jjj}|jjƒt ƒ|ksXt t ƒ|fƒ‚t dƒt t|ƒjƒdS(N(R*R)R&R,R+R/t_greenlet_tracertprevious_trace_functiontkillRtAssertionErrorRRR'RttearDown(Rtprev((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyR9Ds   $ (RRR(R9(((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyR-s tTestPeriodicMonitoringThreadcBsneZd„Zedƒd„ƒZd„Zd„Zd„Zd„Zd„Z d„Z d „Z d „Z RS( cCs3|jd|jjƒ|jtƒ|jjƒdS(NIï¾­Þ(t assertEqualR/tmonitor_thread_identRR5(R((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyttest_constructorQss%psutil doesn't install on PyPy on WincCs9|jjƒ}|j|ƒ|j||jjƒƒdS(N(R/t _get_processtassertIsNotNonetassertIs(Rtproc((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyttest_get_processUs cCsc|j|j|jjƒ|`tjƒ|j|jjƒ|j|jjƒ|jtƒƒdS(N( RAR-R/RRt assertIsNonet assertFalset should_runR(R((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyt test_hub_wref[s  cCs/|jt|jjddƒ|jt|jjd„dƒd„}|jj|dƒ|j|jdt|jjƒƒƒ|jd|jjƒdj ƒ|jj|dƒ|j|jdt|jjƒƒƒ|jd|jjƒdj ƒ|jj|dƒ|j|jt|jjƒƒƒdS(NicSsdS(N(R(((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyR!jRiÿÿÿÿcSsdS(s Does nothingN((((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pytflRi( t assertRaisest ValueErrorR/tadd_monitoring_functionRR<R4R3R1tperiod(RRH((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyttest_add_monitoring_functiongs & & cCsÖ|j|jjƒdj|jjƒƒd|j_|j|jj|jjƒƒd|jjƒd_d|j_|jjƒ|j|jjƒdj|jjƒƒ|j|jjƒdj|jjƒdS(Niiÿÿÿÿ(R<R/R1RLtcalculate_sleep_timet_calculated_sleep_timetinactive_sleep_time(R((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyttest_calculate_sleep_time}s     csC‡fd†}ˆjj|dƒˆjƒˆjˆjjƒdS(Ncsd}dˆ_tjƒdS(N(RR-RR(t_hub(R(sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyRH™s gš™™™™™¹?(R/RKRERF(RRH((RsT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyttest_call_destroyed_hub–s cCs=d„}|jj|dƒ|jƒ|j|jjƒdS(NcSs t|_dS(N(tTrueR (R-((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyRH¥sgš™™™™™¹?(R/RKRERF(RRH((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyttest_call_dead_hub¢s  cCs*d„}|jj|dƒ|jƒdS(NcSs tƒ‚dS(N(t SystemExit(RR((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyRH­sgš™™™™™¹?(R/RK(RRH((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyttest_call_SystemExit«s cs\dtfd„ƒY‰‡fd†}|jj|dƒ|jˆƒ|jƒWdQXdS(Nt MyExceptioncBseZRS((RR(((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyRX´scs ˆƒ‚dS(N((RR(RX(sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyRH·sgš™™™™™¹?(t ExceptionR/RKRI(RRH((RXsT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyttest_call_other_error³s cCs{ddl}ddlm}d|j_|jj}||jƒ|j|jƒ|jjƒ|j|d|jjƒdS(Niÿÿÿÿ(Ri( tost gevent.hubRR/tpidR=R-R<tgetpid(RR[Rtold_tid((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyttest_hub_reinit¾s    ( RRR>RRCRGRMRQRSRURWRZR`(((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyR;Ns     tTestPeriodicMonitorBlockingcBs#eZd„Zd„Zd„ZRS(cs³|jjƒ|jtƒƒg‰‡fd†}t|ƒtj|jƒ|_|jtƒ|jj ƒ|j |jj j |ƒ|jj ddƒ|jddfgˆƒdS(Ncsˆj|ƒdS(N(tappend(R(tcalled(sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyRHÓsteventR(R(R( R/R7RDRRR)R.R-R<R5RAR6(RRH((RcsT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyttest_previous_traceÎs  cCsþ|jd|jjjƒ|jjddƒ|jd|jjjƒ|j|jjjƒtƒ}tƒ}|jjd||fƒ|jd|jjjƒ|j||jjjƒ|jjddƒ|jd|jjjƒ|j|jjjƒdS(Nitunknownitswitchii(( R<R/R5tgreenlet_switch_counterRRDtactive_greenlettobjectRA(Rtoriginttarget((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyttest__greenlet_traceràs  cCsddlm}ddlm}ddlm}g}|j|jƒ|j|jj|j ƒƒt ƒ}t ƒ}|jj d||fƒ|j|jj|j ƒƒ|j|ƒ|j |jj|j ƒƒ|j |ƒ|||dƒ|2|jj ƒ|j|jj|j ƒƒ|j|ƒ|jjƒ|j |jj|j ƒƒd|j _|j |jj|j ƒƒdS(Niÿÿÿÿ(t subscribers(tIEventLoopBlocked(t verifyObjectRgi(t gevent.eventsRnRotzope.interface.verifyRpRbRER/tmonitor_blockingR-RjR5t assertTruet ignore_current_greenlet_blockingt!monitor_current_greenlet_blockingR (RRnRoRpteventsRkRl((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyttest_monitor_blockingós,        (RRReRmRx(((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyRaËs  t MockProcesscBseZd„Zd„ZRS(cCs ||_dS(N(trss(RRz((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyRscCs|S(N((R((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pytmemory_full_info s(RRRR{(((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyRys s%psutil doesn't install on PyPy on WintTestPeriodicMonitorMemorycBsMeZdZd„Zd„Zd„Zd„Zd„Zd„Zd„Z RS(icsAttˆƒjƒtjˆ_dt_‡fd†ˆj_dS(Ncs tˆjƒS(N(RyRz((R(sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyR!/R( R'R|R(t GEVENT_CONFIGtmax_memory_usaget_old_maxRR/R?(R((RsT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyR(*s  cCs#|jt_tt|ƒjƒdS(N(RR}R~R'R|R9(R((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyR91s cCsM|j|jjƒƒ|jjƒ|j|jdt|jjƒƒƒdS(Ni(RtR/tcan_monitor_memory_usagetinstall_monitor_memory_usageR<R4R3R1(R((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyttest_can_monitor_and_install5s cCsddl}d„|j_|j|jjƒƒ|jdtƒ}|jjƒWdQX|jdt |ƒƒ|j t j |dj ƒdS(NiÿÿÿÿcSsdS(N(R(((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyR!ARtrecordii(twarningsR/R?RER€tcatch_warningsRTRR<R3RAR)tMonitorWarningtcategory(RR„tws((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyttest_cannot_monitor_and_install?s cCs |jd|jjdƒƒdS(Niÿÿÿÿ(R<R/tmonitor_memory_usageR(R((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyttest_monitor_no_allowedKscCsddlm}d|_dt_|jjdƒ}|j||j ƒ|j d|j ƒ|j d|j ƒ|j|j tƒ|jjdƒ}|j|ƒd|_|jjdƒ}|j||j ƒ|j d|j ƒd|_|jjdƒ}|j||jƒ|j d|j ƒt|ƒ|jjdƒ}|j|ƒd|_|jjdƒ}|j||j ƒ|j d|j ƒdS(Niÿÿÿÿ(Rwiii(tgeventRwRzR}R~R/RŠRtassertIsInstancetMemoryUsageThresholdExceededR<t mem_usaget max_allowedt memory_infoRyRDtMemoryUsageUnderThresholdtrepr(RRwRd((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyttest_monitor_greaterNs2        cCs5d|_dt_|jjdƒ}|j|ƒdS(Nii (RzR}R~R/RŠRRD(RRd((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyttest_monitor_initial_belowys  ( RRRzR(R9R‚R‰R‹R”R•(((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyR|$s    +t__main__(RtunittesttgreenletRRt gevent.monkeyRtgevent._compatRRtgevent.testing.skippingRRŒRR)RR}RRjR RtTestCaseR;RaRyR|Rtmain(((sT/var/www/syncserver/local/lib/python2.7/site-packages/gevent/tests/test___monitor.pyts,  !|O [