<|hQdZddlmZmZddlZddlZddlZddlm Z ddl m Z  ddl m Z dZ ddlmZddlmZddlmZddlmZddlmZddlmZeek\ZgZ eGdde!Z"e"dZ"dZ#dZ$dZ%Gdde&Z'GddeZ(e'defe)e(jTZ(Gdd eZ+Gd!d"eZ,Gd#d$eZ-Gd%d&eZ.Gd'd(eZ/Gd)d*eZ0Gd+d,eZ1Gd-d.eZ2Gd/d0eZ3Gd1d2eZ4y#e$r,e jrddlZGdd eZd Z d Z nd Z d Z YwxYw#e$rGdde ZYwxYw)3zb Useful base classes for watchers. The available watchers will depend on the specific event loop. )absolute_importprint_functionN)config) LazyOnClass)get_object_tracebackc|SNinits R/var/www/html/test/engine/venv/lib/python3.12/site-packages/gevent/_ffi/watcher.py tracemallocrs ceZdZdZdZdZy)_TBlinescT|Dcgc]}|jc}|_ycc}wr )rstripr)selfrxs r __init__z _TB.__init__s278Qahhj8 8s%c|jSr rrs r formatz _TB.format"s zz!rN)__name__ __module__ __qualname__ __slots__rrr rr rrs"I 9 "rrcBtjfd}|S)Ncb|g|i|ttj|_yr )r traceback format_stack_captured_malloc)rargskwargsr s r tracesztracemalloc..traces&s+T+D+F+(+I,B,B,D(E%r functoolswraps)r r's` r rr%s' __T " F# FMrc|jSr )r$)objs r rr,s'' 'rcyr r )_objs r rr0src|Sr r r s r rr3sKrfsencode)_dbg)GEVENT_DEBUG_LEVEL)DEBUG)GEVENT_CORE_EVENTS)_NOARGSceZdZdZy)ResourceWarningzPython 2 fallbackN)rrr__doc__r rr r8r8Gsrr8ceZdZdZy)_NoWatcherResultcy)Nz r rs r __repr__z_NoWatcherResult.__repr__LsrN)rrrr=r rr r;r;Jsrr;cg}|D]'\}}|}||zr|j|||z}|r'n|r|jt|dj|S)N|)appendhexjoin) event_field all_eventsresultflagstringc_flags r events_to_strrIQsj F$v   MM& ! fW %K   c+&' 88F rcBtjfd}|S)NcL|jr td|g|i|y)Nznot while active)active ValueError)rr%r&funcs r nwznot_while_active..nw`s( ;;/0 0 T#D#F#rr()rNrOs` r not_while_activerP_s%__T$$ IrcBtjfd}|S)Nc8|jr|StSr )_watcherr;)rrNs r if_wzonly_if_watcher..if_whs ==: rr()rNrTs` r only_if_watcherrUgs%__T   Krc:eZdZdZdZdZdZedZdZ dZ y)AbstractWatcherTypez Base metaclass for watchers. To use, you will: - subclass the watcher class defined from this type. - optionally subclass this type Nc|dk7r$|jds|j|||d|vrts tdtj ||||S)Nwatcher_watcher_skip_ffi__del__z-CFFI watchers are not allowed to have __del__)get _fill_watcherALLOW_WATCHER_DEL TypeErrortype__new__)clsnamebasescls_dicts r razAbstractWatcherType.__new__~sT 9 X\\2E%F   dE8 4  ):KL L||Cuh77rc|jdr|dd}dd}|jdxs |d|}d|vr|dz|z}||d<n$|dj|s|dz|dz}||d<|dzfd}tj|||jds'|jd xs|d |d xsd }|fzfd } tj|| |jd xs|d |d xsdfd} tj|| d} dD])} d| z} | |vs tj|| | | +y)N_cf|D]} t||cS|r t|y#t$rY,wxYwr )getattrAttributeError)attrrderrorbs r _mro_getz3AbstractWatcherType._fill_watcher.._mro_getsL "1d++  $T**&s $ 00_watcher_prefix _watcher_type _is_activec0t|jSr )rj_LIB)r active_names r _watcher_is_activez=AbstractWatcherType._fill_watcher.._watcher_is_actives499k2 2r_watcher_struct_name_watcher_struct_patternFz struct %sc@|jjdzS)Nz *)_FFItypeof)rwatcher_struct_names r _watcher_struct_pointer_typezGAbstractWatcherType._fill_watcher.._watcher_struct_pointer_types99##$7$$>? ?r_watcher_callback_name_gevent_generic_callbackcP|jj|jSr )rz addressofrt)r callback_names r _watcher_callbackz._watcher_callbacks99&&tyy-@ @rc fd}||_|S)NcT|jdzz}t|j|S)Nrg)rqrjrt)rlib_namercs r methzCAbstractWatcherType._fill_watcher.._make_meth..meths)--3d:tyy(33r)r)rc watcher_namers` r _make_methz5AbstractWatcherType._fill_watcher.._make_meths 4)DMKr)startstopr _watcher_)T)endswithr\ startswithrlazy)rbrcrdrerorp watcher_typervwatcher_struct_patternr}rr meth_namerrurr|s @@@r r]z!AbstractWatcherType._fill_watchers == 9D +#,,'89_XFWY^=_ ( **S047L(4H_ %/*55oF*S08O3LLL(4H_ %% 4  3 #56&ll+AB"&.ll3L&M'5)12KUTY)Z'5)4 ##9L?"J  @ #?@!&>?7$%=ueL76  A #45 1 PI+i7L8+  :i+NO Prc8|jj|Sr )rz new_handle)rbr,s r rzAbstractWatcherType.new_handlesxx""3''rc8|jj|Sr )rznew)rbkinds r rzAbstractWatcherType.newsxx||D!!r) rrrr9rzrtra classmethodr]rrr rr rWrWps9 D D8?P?PB("rrWceZdZdZdZdZdZeddefdZ dZ e dZ dZ dZdZd Zd Zd Zd Zd ZdZdZdZdZdZdZdZdZdZdZdZdZ dZ!dZ"e#rdZ$dZ%dZ&e'dZ(dZ)e'dZ*dZ+dZ,e'e+e,Z-dZ.dZ/e'e.e/Z0dZ1d Z2d!Z3e4d"Z5e'e3e5Z6e'd#Z7e'd$Z8y)%rYNTc\||_||_||_||_|j yr )loop_watcher__init_priority_watcher__init_args_watcher__init_ref_watcher_full_init)r_looprefpriorityr%s r rzwatcher.__init__s, ' !rc|j}|j}|j}|j|||j | |j ||j|y#d|_xYwr )rrr_watcher_create_watcher_ffi_set_priority_watcher_ffi_initrS_watcher_ffi_set_init_ref)rrrr%s r rzwatcher._watcher_full_initsy''oo S!    * *8 4   " "4 ( &&s+  !DM s A-- A7cyr r )rb ffi_watchers r _watcher_ffi_closezwatcher._watcher_ffi_close rc.|j|_yr ) _watcher_newrSrrs r rzwatcher._watcher_creates))+ rcJt|j|jSr )r`rr}rs r rzwatcher._watcher_newsDz~~d??@@rcyr r rs r rz!watcher._watcher_ffi_set_init_ref rcyr r rrs r rz!watcher._watcher_ffi_set_priorityrrctr NotImplementedErrorrr%s r rzwatcher._watcher_ffi_init !##rctr rrs r _watcher_ffi_startzwatcher._watcher_ffi_start rrcd|j|jj|jyr ) _watcher_stoprptrrSrs r _watcher_ffi_stopzwatcher._watcher_ffi_stops 499==$--8rctr rrs r _watcher_ffi_refzwatcher._watcher_ffi_refrrctr rrs r _watcher_ffi_unrefzwatcher._watcher_ffi_unrefrrc$|jyr )rrs r _watcher_ffi_start_unrefz watcher._watcher_ffi_start_unrefs !rc$|jyr )rrs r _watcher_ffi_stop_refzwatcher._watcher_ffi_stop_refs rc|jy|j|j}d|_|j||jj|j |d|_yr )rSr_watcher_set_datarzNULLrr)rrSs r closez watcher.close6sU ==  ==  x8 ) rc||_|Sr )data)r the_watcherrs r rzwatcher._watcher_set_dataAs  rc|Sr r rs r __enter__zwatcher.__enter__Hs rc$|jyr )r)rtvtbs r __exit__zwatcher.__exit__Ks  rc|jrct|}d}|$dj|j}d|z}t j d||t |jyy)N z Traceback: zFailed to close watcher )rSrrBrwarningswarnr8r)rrtb_msgs r r[zwatcher.__del__Osa}})$/>!YYryy{3F-6F fM-/ rFcd|jjt|fz}|jr|dzSd|_ ||j }|j r|dz }|j Jt|j dd}||ur|d|j jzz }n|d|j z }|j|d|jz }|j |j|d z }|d |jzz }|d |jzz }|d |jzz }|dzd |_S#d |_wxYw)Nz <%s at 0x%x>Tz pending__self__z# callback=z callback=z args=z stoppedz watcher=%sz handle=%sz ref=%sF) __class__rid_watcher__in_repr_formatpendingcallbackrjr%rS_watcher_handler)rbasicrEfselfs r r=zwatcher.__repr__^s6!8!8"T( CC >>3;  #$dlln5F||*$}}( z4@D=Ct}}G]G]^^F @@Fyy$ 44}}$):*$ mt}}5 5F ld&:&:; ;F i488, ,FC<"DNUDNs C0D66 D?cH|jr|jjSyr )rSrrs r rzwatcher._watcher_handle{s ====%% % rcy)Nrr rs r rzwatcher._formatsrctr rrs r rz watcher.ref !##rc:d|jvr |jSdS)N _callback)__dict__rrs r _get_callbackzwatcher._get_callbacks!, !=t~~G4Grcpt|s|td||d|jvr|`yy||_y)NzExpected callable, not r)callabler_rr)rcbs r _set_callbackzwatcher._set_callbacks?|2@A A :dmm+N, DNrc|jSr )_argsrs r _get_argszwatcher._get_argss zzrctt|ts | td|d|jvr|`yy||_y)Nzargs must be a tuple or Noner) isinstancetupler_rrrs r _set_argszwatcher._set_argssA$&4+;:; ; <$--'J(DJrcF| td||_|xst|_|jj j ||j|jt|j||_ |j|jy)Nz#callback must be callable, not None)r_rr6r%r _keepalivesetaddrrSr`r_handlerr)rrr%s r rz watcher.starts~  AB B  OG  ##D)--dmmT$Z=R=RSW=XY  ! %%'rc~|j'|j||jjvsJyd|_|j|j |jjj |d|_|j|j|jjd|_ yr ) rrrrrdiscardrrrSrzrr%rs r rz watcher.stops == 99$DII4K4K(K KK   ""$   ''-  t}}diinn= rcyr r rs r _get_priorityzwatcher._get_prioritysrcyr r rs r _set_priorityzwatcher._set_priorityrrcT|j|j|jryy)NTF)rSrvrs r rLzwatcher.actives# == $)@)@)Orcy)NFr rs r rzwatcher.pendingsr)9rrrrrrSrrr6rrrrrrrrrrrrrrrrq _watcher_init_watcher_startrr}rrvrrrrr^r[rr=propertyrrrrrrrrr%rrrrPrrrLrr rr rYrYsI EHG"&G"",*  ,A  $$9$$" MMNM$(   I#:&&$$H  }5H Iy )D(    }5H rrYc4eZdZdZdfd ZfdZdZxZS)IoMixinrc|dkrtd|z||jzrtd|z||_tt|||||xs||fy)Nrzfd must be non-negative: %rzillegal event mask: %rrrr%)rM EVENT_MASK_fdsuperr r)rrfdeventsrrrrs r rzIoMixin.__init__sk 6:R?@ @ T__$ $5>? ? gt%dh+0+@RL & Brcx|xst}|jdr tf|z}tt||g|y)N pass_events)r6r\r5rr r)rrr%r&rs r rz IoMixin.starts9w ::m $&)D0D gt"83d3rc d|jzS)Nz fd=%d)rrs r rzIoMixin._formats$((""r)TNN)rrrr rrr __classcell__rs@r r r sJ B4 #rr c4eZdZdZdfd ZfdZdZxZS) TimerMixintimercz|dkrtd|z||_||_tt||||||fy)Nz#repeat must be positive or zero: %rr )rM_after_repeatrrr)rrafterrepeatrrrs r rzTimerMixin.__init__sH C<BVKL L   j$(3QVX^P_(`rc|jd|jj}|r|jjt t ||g|y)Nupdate)r\r#starting_timer_may_update_loop_time update_nowrrr)rrr%kwr!rs r rzTimerMixin.startsF$))"O"OP  II " j$%h66rctr r)rrr%r$s r againzTimerMixin.againrr)rrTN)rrrrqrrr&rrs@r rrsMa7"$rrc$eZdZdZdfd ZxZS) SignalMixinsignalc|dks|tjk\rtd|z||_tt |||||fy)Nzillegal signal number: %rr ) signalmoduleNSIGrM _signalnumrr(r)rr signalnumrrrs r rzSignalMixin.__init__ sM q=I):)::89DE E $ k4)$C(R[Q^)_r)TN)rrrrqrrrs@r r(r(sM ` `rr(ceZdZdZy) IdleMixinidleNrrrrqr rr r1r1Mrr1ceZdZdZy) PrepareMixinprepareNr3r rr r6r6sMrr6ceZdZdZy) CheckMixincheckNr3r rr r9r9sMrr9ceZdZdZy) ForkMixinforkNr3r rr r<r<#r4rr<c,eZdZdZdZdZedZy) AsyncMixinasyncctr rrs r sendzAsyncMixin.send*rrc"|jS)z Calling compatibility with ``greenlet.switch(arg)`` as used by waiters that have ``rawlink``. This is an advanced method, not usually needed. )rB)r_ignoreds r send_ignoring_argzAsyncMixin.send_ignoring_arg-syy{rctr rrs r rzAsyncMixin.pending6rrN)rrrrqrBrErrr rr r?r?'s%M$$$rr?cbeZdZdZd fd ZdZedZedZdZ dZ edZ xZ S) ChildMixinTrc|js td|j||_|jrt t |||||fyy)Nz5child watchers are only available on the default loop)rr%)defaultr_install_sigchld_pid_CALL_SUPER_INITrrHr)rrpidtracerrs r rzChildMixin.__init__@sQ||ST T   *d ,Ts#u , N !rc:d|jd|jS)Nz pid=z rstatus=)rNrstatusrs r rzChildMixin._formatHs'+xx>>rc|jSr )rLrs r rNzChildMixin.pidKs yyrc|jSr )_rpidrs r rpidzChildMixin.rpidOszzrNc|jSr )_rstatusrs r rQzChildMixin.rstatusWs }}r)rT) rrrrMrrrrNrUrTrWrQrrs@r rHrH;s\O? EH rrHcpeZdZedZdfd ZedZedZedZ edZ xZ S) StatMixinct|Sr r0)paths r _encode_pathzStatMixin._encode_path]s ~rc|j||_||_|jj d|j|_||_tt|'||||j |fy)Nzchar[]r ) r\_paths_pathrzr_cpath _intervalrrYr)rrr[intervalrrrs r rzStatMixin.__init__asj''-  iimmHdkk: ! i'3.2kk.6.8 ( 9rc|jSr )r_rs r r[zStatMixin.pathvs zzrctr rrs r rlzStatMixin.attrz!!rctr rrs r prevzStatMixin.prev~rerc|jSr )rars r rbzStatMixin.intervals ~~r)rTN) rrr staticmethodr\rrr[rlrgrbrrs@r rYrY[sj9*""""rrY)5r9 __future__rrr)r,r)rgevent._configr gevent._utilrrr ImportError trace_mallocr"objectrgevent._compatr1 gevent._ffir2r3r4gevent._ffi.loopr5r6r^__all__r8 NameErrorWarningintr;rIrPrUr`rWrYdictrr rr(r1r6r9r<r?rHrYr rr rxs 7!$%0H$*/$&%/  s $A& ["$["z@f@D i&D9I9I4J K#f#0$$> `& `6$$(@))M  "& "  (  =b's# DE -EE EE