<|hlddlmZmZddlZddlZddlmZgZejZejZ ddl m Z ddl mZGddeZeZej%d ej&Ze j*d fe j,d fgZd ZGd deZGddeZGddeZGdde jZ Gdde j<e ZGddeZ Gdde e jBe Z"Gdde e jFe Z$Gdde jJe Z&e&e'd<Gd d!e jPe Z)Gd"d#e jTe Z+Gd$d%e jXe Z-Gd&d'e j\e Z/Gd(d)e j`e Z1Gd*d+e1Z2Gd,d-e jfe Z4y).)absolute_importprint_functionN) _corecffi)watcher)_dbgceZdZdZdZy)_ClosingWatchersc` ||=y#t$rtdtjYywxYw)Nzgevent error: Unable to remove closing watcher from keepaliveset. Has the module state been corrupted or executed more than once?)file)KeyErrorprintsysstderr)selfobjs S/var/www/html/test/engine/venv/lib/python3.12/site-packages/gevent/libuv/watcher.pyremovez_ClosingWatchers.removes4 S   RZZ  s $--N)__name__ __module__ __qualname__ __slots__rr rr r s I rr _uv_close_callback)nameREADWRITEc6tj|tSN)_base events_to_str_events)eventss r_events_to_strr$8s   vw //rc eZdZy)UVFuncallErrorN)rrrr rrr&r&;srr&ceZdZdZdZy)libuv_error_wrapperc||_yr)_libuv)ruvs r__init__zlibuv_error_wrapper.__init__Fs  rct|j|tjfd}t ||||S)Nc |rt|dtr|dd}|i|}||dkrtttj t j|jddztj t j|jdzdzt|zdzt|z|S)Nrascii z Args: z KWARGS: ) isinstancerr&strffistringlibuv uv_err_namedecode uv_strerrorrepr)argskwargsres libuv_funcs rwrapz-libuv_error_wrapper.__getattr__..wrapLs 47G4ABxd-f-C37$ 5#4#4S#9:AA'J**U%6%6s%;<CCGLMN  #'t*-0;;>B&\J Jr)getattrr* functoolswrapssetattr)rrr?r>s @r __getattr__zlibuv_error_wrapper.__getattr__IsAT[[$/  $  %  dD! rN)rrrr,rDr rrr(r(>s rr(ceZdZdZdZdZy) ffi_unwrapperc||_yr)_ffi)rffs rr,zffi_unwrapper.__init__cs  rc.t|j|Sr)r@rH)rrs rrDzffi_unwrapper.__getattr__fstyy$''rcft|tsJ|jjt|Sr)r2r(rH addressofr6)rlibrs rrLzffi_unwrapper.addressofis*#2333yy""5$//rN)rrrr,rDrLr rrrFrF_s(0rrFceZdZeeZeeZdZ dZ e dZ dZ dZdZdZej$dZej$d Zd Zd Zd Zd ZeeeZdZy)rr+z%s_tc|jjd|}tj|_|j rDt j|s.|t|<t j|t jyyy)Nz uv_handle_t*) _FFIcastr4NULLdatatyper6 uv_is_closing_closing_watchersuv_closer)cls ffi_watcherffi_handle_watchers r_watcher_ffi_closezwatcher._watcher_ffi_closeush<!XX]]>;G"%((  " "5+>+>{+K 5@ 0 1 NN;(@(@ A ,L "rc||_yr)refrr]s r_watcher_ffi_set_init_refz!watcher._watcher_ffi_set_init_refs rcf|j|jj|jg|Sr _watcher_initloopptr_watcherrr;s r_watcher_ffi_initzwatcher._watcher_ffi_inits0!t!!$))--"&--)#') )rcP|j|j|jyr)_watcher_startre_watcher_callbackrs r_watcher_ffi_startzwatcher._watcher_ffi_starts DMM4+A+ABrcT|jr|j|jyyr)re _watcher_stoprks r_watcher_ffi_stopzwatcher._watcher_ffi_stops" ==   t}} - rcBtj|jyr)r6uv_refrerks r_watcher_ffi_refzwatcher._watcher_ffi_refs T]]#rcBtj|jyr)r6uv_unrefrerks r_watcher_ffi_unrefzwatcher._watcher_ffi_unrefs t}}%rcyrr rks r_watcher_ffi_start_unrefz watcher._watcher_ffi_start_unref rcyrr rks r_watcher_ffi_stop_refzwatcher._watcher_ffi_stop_refrxrcl|jyttj|jSr)reboolr6 uv_has_refrks r_get_refzwatcher._get_refs) == E$$T]]344rcJ|r|jy|jyr)rrru)rvalues r_set_refzwatcher._set_refs   ! ! #  # # %rctd)NzNot implemented) Exception)r_revents _callback_argss rfeedz watcher.feeds)**rN)rrrrFr4rPr(r6_LIB_watcher_prefix_watcher_struct_pattern classmethodr[r_rgrlror only_if_watcherrrrurwrzr~rpropertyr]rr rrrrns  D u %DO$&B&BP) C. $$ &&  5 & 8X &C+rrcveZdZdZdZdZejejzejzZ dZ dfd Z dZ ejdZdZd ZeeeZd Zej.j1d rej4j6ZGd d eZdZdZ dZ!dZ"fdZ#dZ$dZ%dZ&xZ'S)iopoll_gevent_poll_callback2Fr cdtt| ||||||f||_||_g|_y)N)r]priorityr)superrr,_fdr"_multiplex_watchers)rrcfdr#r]r __class__s rr,z io.__init__s9 b$ r6sXVXUZ [ #% rc|jSr)rrks r_get_fdz io._get_fds xxrc6||_|j|fyr)rrg)rrs r_set_fdz io._set_fds u%rc|jSrr"rks r _get_eventszio._get_events s ||rc||jk(ry||_|jr@|jJ|j|j|j|j yyr)r"active_handlerirerj)rr#s r _set_eventszio._set_events sV T\\ !  ;;<<+ ++    t||T=S=S T rcf|j|j|j|jyr)rirer"rjrks rrlzio._watcher_ffi_starts" DMM4<<9O9OPrwin32ceZdZdZdZdZdZdZede jdZ dZ d Z d Zed Zed Zed dZy)io._multiplexwatcherNr FTc ||_||_yr)r" _watcher_refrr#rs rr,zio._multiplexwatcher.__init__@s!DL!(D rc|jSrrrks rzio._multiplexwatcher.Ks rct|d|S)Nr")rCrnvs rrzio._multiplexwatcher.LsGD)R4Prc|jd|_||_||_|j}|.|j s|j y|jyy)N pass_events)getrcallbackr;rr _io_start_calc_and_update_events)rrr;r<rs rstartzio._multiplexwatcher.startNsX%zz-8D $DMDI''G"~~%%'335 #rcld|_d|_d|_|j}||j yyr)rrr;r_io_maybe_stoprrs rstopzio._multiplexwatcher.stop[s: DM#D DI''G"&&(#rc`|j|jj|d|_yr)r_multiplex_closedrks rclosezio._multiplexwatcher.closecs*  ,!!33D9 $D rc|jduSr)rrks rrzio._multiplexwatcher.activehs==, ,rc.|jjSr)rrerks rrezio._multiplexwatcher._watcherls$$-- -rc0t|jddS)Nr)r@rrks rrzio._multiplexwatcher.ss74+<+tst'8'8'@'@'Dr)rrrrr;rr]r,rr not_while_activer#rrrrrerr rr_multiplexwatcherr9s  ( % "E " "#P QS 6 ) %  -  -  .  . HDFrrc|j|jD]}|jy|jyr)rrrr)rws rrzio._io_maybe_stopvs= $$&)) Azz%   rc^|j|j|jdy)NT)r)rr _io_callbackrks rrz io._io_starts$ $$& 4$$$ 7rcd}|jD]}|j||jz} |j|y)Nr)rrr#rrs rrzio._calc_and_update_eventssF// )G+'..( )  rc|j||}|jj||j|Sr)rrappendrrs r multiplexz io.multiplexs9((6   ''0 $$&rc.tt| |`yr)rrrr)rrs rrzio.closes b$  $rc|jj||js1|j|j|j y|j yr)rrr_no_more_watchersrrrs rrzio._multiplex_closedsK   ''0'' IIK  " " $ JJL  ( ( *rcyrr rks rrzio._no_more_watcherss rc  |dkrdtd|jtjtj |tjtj ||jD]}|js|j|usJ||jf||jzxs|dk}|sJ|js|j|jp|j|g|jy)NrzCallback error on) rrr4r5r6r7r9rrrr#rr;)rr#r send_events rrzio._io_callbacks A: $dhhE--f56E--f56 8"// >1@fqjJ**$G$$gll3$G$$V;gll; eZdZdZdZdZdZdZdZe dZ y) r_gevent_async_callback0cyrr r rrrzasync_.Ksrcx|j|jj|j|jSr)rbrcrdrerjrfs rrgzasync_._watcher_ffi_initMs0 !!$))--"&"8"8: :rcyrr rks rrlzasync_._watcher_ffi_startUrxrcyrr rks rrozasync_._watcher_ffi_stopXrxrc|jtjusJdtj|jr t dtj |jy)NzSending to a closed watcherzClosing handle)rrr6rUrer uv_async_sendrks rrz async_.send[sP~~V%5%55T7TT5   t}} -,- - DMM*rcyrr rks rpendingzasync_.pendingbrrN) rrrrrrgrlrorrrr rrrr9s76"I:  +rrasyncc&eZdZdZdZdZdZdZy)timer_gevent_timer_callback0Fcj|j|jj|j|\|_|_|jr-|jdkrddl}|jddd|_|j r/|j dkrddl}|jddd|_yyy)NgMbP?rzTlibuv only supports millisecond timer resolution; all times less will be set to 1 ms) stacklevel)rbrcrdre_after_repeatwarningswarn)rr;r$s rrgztimer._watcher_ffi_inits 499==$--8$(! T\ ;;4;;.  MM?%&  (  DK < "k! "s ABBc|js|j|g|i|yd|_ |j|g|i||`y#|`wxYw)NT)rrr()rrr;kws ragainz timer.againsU{{ DJJx -$ -" -    DJJx -$ -" -  s AA N)rrrrr(rgrlr/r rrrrhs6(F!( " rrc^eZdZdZdZdZdZdZdZdZ e dZ e d Z e d Z y ) statfs_pollgevent_fs_poll_t_gevent_fs_poll_callback3c(||j_|Sr)handlerS)r the_watcherrSs r_watcher_set_datazstat._watcher_set_datas"&  rcb|j|jj|jSrrarfs rrgzstat._watcher_ffi_inits!!!$))--??rg`--g?c t|j|j|_|j|j|j |j t|jdzyr')max _intervalMIN_STAT_INTERVALrirerj_cpathr*rks rrlzstat._watcher_ffi_startsNT^^T-C-CD DMM4+A+A KK 56 8rcB|jjjSr)rer6rSrks rrzstat._watcher_handles}}##(((rcp|jjjsy|jjSr)recurrst_nlinkrks rattrz stat.attr(}}!!** }}!!!rcp|jjjsy|jjSr)reprevrBrks rrFz stat.prevrDrN)rrrr_watcher_struct_namerr8rgr=rlrrrCrFr rrr1r1sgM-8@"8))"" ""rr1ceZdZdZdZdZy)signal_gevent_signal_callback1cr|j|jj|jd|_y)NF)rbrcrdrer]rfs rrgzsignal._watcher_ffi_inits% 499==$--8rcf|j|j|j|jyr)rirerj _signalnumrks rrlzsignal._watcher_ffi_starts% DMM4+A+A OO -rN)rrrrrgrlr rrrIrIs7 -rrIceZdZdZy)idle_gevent_idle_callback0Nrrrrr rrrOrOs 6rrOceZdZdZy)check_gevent_check_callback0NrQr rrrSrSs6rrSceZdZdZdZdZy) OneShotCheckTc^|jtjfd}|S)Nc|Srr )r;funcrs rrz"OneShotCheck.__make_cb..cbs F; r)rrArB)rrYrrs ` @r __make_cbzOneShotCheck.__make_cbs.yy      rcNtj||j|g|Sr)rSr_OneShotCheck__make_cb)rrr;s rrzOneShotCheck.starts!{{4!9ADAArN)rrrrr\rr rrrVrVsBrrVceZdZdZy)prepare_gevent_prepare_callback0NrQr rrr^r^s8rr^)5 __future__rrrAr gevent.libuvr__all__r4rMr6 gevent._ffirr rdictr rV def_externrrrrr"r$r+r&rr(rFIoMixinrr ForkMixinr ChildMixinr AsyncMixinrlocals TimerMixinr StatMixinr1 SignalMixinrI IdleMixinrO CheckMixinrSrV PrepareMixinr^r rrrqs7 " mm ( t %&?S^^)=^>   v &   w ' )0 Z &B 0F 0b+emmb+H}<}<~8$v8$t # ?? ( $    4+U  w+ZCE  gCL#"5??G#"L -U   -65??G6 7E  g7 B5 B9e  '9r