U Ã@ÛfÄDã@s6ddlZddlZddlZddlZddlZddlZdZeedƒrLdd„ZeZn4zddl Z e j ZWn e k r~dd„Z e ZYnXddl Zddl mZddlmZzdd lmZWn e k rÐdd lmZYnXd Zd Zd Zd d„ZGdd„dƒZeeddd„dd„dƒZGdd„deƒZdd„ZGdd„dƒZdS)éNÚ setitimercCst tj|¡dS©N)ÚsignalrÚ ITIMER_REAL©Úseconds©rúK/var/www/html/chatgpt/venv/lib/python3.8/site-packages/eventlet/hubs/hub.pyÚ alarm_itimer sr cCst t |¡¡dSr)rÚalarmÚmathÚceilrrrr Ú alarm_signalsr)Útimer)Ú greenlets)Ú monotonicTÚreadÚwritecCsdS)zP Used to de-fang a callback that may be triggered by a loop in BaseHub.wait Nr)Úfilenorrr Úclosed_callback$src@s(eZdZdd„Zdd„ZeZdd„ZdS)Ú FdListenercCsF|tks|tkst‚||_||_||_||_||_d|_t   ¡|_ dS)aŠ The following are required: cb - the standard callback, which will switch into the listening greenlet to indicate that the event waited upon is ready tb - a 'throwback'. This is typically greenlet.throw, used to raise a signal into the target greenlet indicating that an event was obsoleted by its underlying filehandle being repurposed. mark_as_closed - if any listener is obsoleted, this is called (in the context of some other client greenlet) to alert underlying filehandle-wrapping objects that they've been closed. FN) ÚREADÚWRITEÚAssertionErrorÚevtyperÚcbÚtbÚmark_as_closedÚspentÚgreenletÚ getcurrent©Úselfrrrrrrrr Ú__init__-szFdListener.__init__cCs dt|ƒj|j|j|j|jfS)Nz%s(%r, %r, %r, %r))ÚtypeÚ__name__rrrr©r"rrr Ú__repr__DsÿzFdListener.__repr__cCs"t|_|jdk r| ¡d|_dS)NT)rrrrr&rrr ÚdefangIs zFdListener.defangN)r%Ú __module__Ú __qualname__r#r'Ú__str__r(rrrr r+srcCsdSrr)Úxrrr ÚPór-cs(eZdZ‡fdd„Zdd„ZeZ‡ZS)Ú DebugListenercs,t ¡|_t ¡|_tƒ |||||¡dSr)Ú tracebackÚ format_stackÚ where_calledrr Úsuperr#r!©Ú __class__rr r#Xs  zDebugListener.__init__c Cs*d|j|j|j|j|j|jd |j¡fS)Nz:DebugListener(%r, %r, %r, %r, %r, %r) %sEndDebugFdListenerÚ)rrrrrrÚjoinr2r&rrr r']s ùzDebugListener.__repr__)r%r)r*r#r'r+Ú __classcell__rrr4r r/Vs  r/cCs"ddl}tdt| |¡ƒƒ‚dS)NrzBlocking detector ALARMED at)ÚinspectÚ RuntimeErrorÚstrÚ getframeinfo)ÚsignumÚframer9rrr Ú alarm_handlerisr?c@seZdZdZeefZeZeZdBdd„Z dd„Z dd„Z d d „Z d d „Z d d„Zdd„Zdd„Zdd„Zdd„Zdd„Zdd„Zdd„ZdCdd„Zdd „Zd!d"„Zd#d$„ZdDd&d'„Zd(d)„Zd*d+„Zd,d-„Zd.d/„Zd0d1„Zd2d3„Z d4d5„Z!d6d7„Z"d8d9„Z#d:d;„Z$dd?„Z&d@dA„Z'dS)EÚBaseHubz Base hub class for easing the implementation of subclasses that are specific to a particular underlying event architecture. NcCs|titii|_titii|_g|_|dkr.t}||_t |j¡|_d|_ d|_ g|_ g|_ t |_d|_d|_d|_d|_dS)NFrTé)rrÚ listenersÚ secondariesÚclosedrÚclockrÚrunÚstoppingÚrunningÚtimersÚ next_timersrÚlclassÚtimers_canceledÚdebug_exceptionsÚdebug_blockingÚdebug_blocking_resolution)r"rErrr r#ws zBaseHub.__init__cCs*t tjt¡}|tkr||_t|jƒdSr)rÚSIGALRMr?Ú_old_signal_handlerÚ arm_alarmrO)r"Útmprrr Úblock_detect_pre‹szBaseHub.block_detect_precCs.t|dƒr |jr t tj|j¡t d¡dS)NrQr)ÚhasattrrQrrPr r&rrr Úblock_detect_post“s  ÿzBaseHub.block_detect_postcCsh| |||||¡}|j|}||kr\trBtd||||||fƒ‚|j| |g¡ |¡n|||<|S)a– Signals an intent to or write a particular file descriptor. The *evtype* argument is either the constant READ or WRITE. The *fileno* argument is the file number of the file of interest. The *cb* argument is the callback which will be called when the file is ready for reading/writing. The *tb* argument is the throwback used to signal (into the greenlet) that the file was closed. The *mark_as_closed* is used in the context of the event hub to prepare a Python object as being closed, pre-empting further close operations from accidentally shutting down the wrong OS thread. aPSecond simultaneous %s on fileno %s detected. Unless you really know what you're doing, make sure that only one greenthread can %s any particular socket. Consider using a pools.Pool. If you do know what you're doing and want to disable this error, call eventlet.debug.hub_prevent_multiple_readers(False) - MY THREAD=%s; THAT THREAD=%s)rKrBÚg_prevent_multiple_readersr:rCÚ setdefaultÚappend)r"rrrrrÚlistenerÚbucketrrr Úadd™s" ÿùÿ z BaseHub.addcCs–d}|j ¡D]<\}}||kr||D]}d}|j |¡| ¡q&||=q|j ¡D]:\}}||krV||}d}|j |¡| |¡| ¡qV|S)zÀ We've received an indication that 'fileno' has been obsoleted. Any current listeners must be defanged, and notifications to their greenlets queued up to send. FT)rCÚitemsrDrYr(rBÚremove)r"rÚfoundrr[rZrrr Ú _obsolete¾s       zBaseHub._obsoletecCsdS)zÈ We might want to do something when a fileno is closed. However, currently it suffices to obsolete listeners only when we detect an old fileno being recycled, on open. Nr©r"rrrr Ú notify_closeØszBaseHub.notify_closecCs¬|jr dS|j}|j}||j||krz|j||=||j|kr¨|j||}|rh| d¡|j||<|s¨|j||=n.|j|| |¡|j||s¨|j||=dS©Nr)rrrrBrCÚpopr^)r"rZrrÚsecrrr r^ßs zBaseHub.removecCs| |¡dS)zë If a file descriptor is returned by the OS as the result of some open call (or equivalent), that signals that it might be being recycled. Catch the case where the fd was previously in use. N)r`rarrr Úmark_as_reopenedôszBaseHub.mark_as_reopenedc Csìg}| |jt |t¡¡| |jt |t¡¡| |jt |d¡¡| |jt |d¡¡|D]6}z| |¡Wqht k rœ|  t   ¡¡YqhXqh|jt  |d¡|jt  |d¡|jt  |d¡|jt  |d¡dS)zQ Completely remove all listeners for this fileno. For internal use only.rN)rYrBrÚgetÚnooprÚextendrCrÚ ExceptionÚsquelch_generic_exceptionÚsysÚexc_inford)r"rrBrZrrr Úremove_descriptorýszBaseHub.remove_descriptorcCs,|j ¡}|jjs(| tj tj d¡¡dS)zÑ Triggered from the main run loop. If a listener's underlying FD was closed somehow, throw an exception back to the trampoline, which should be able to manage it appropriately. zOperation on closed fileN) rDrdrÚdeadrÚeventletZhubsZIOClosedÚerrnoÚENOTCONN)r"rZrrr Ú close_ones zBaseHub.close_onecCs,|jjr(t |j|jj¡}||j_||_dSr)rrorFÚparent)r"Únewrrr Úensure_greenletszBaseHub.ensure_greenletcCs”t ¡}||jk stdƒ‚t|ddƒ}|dk rTz |ƒWn| t ¡¡YnX| ¡z|jj|k rr|j|_Wnt k rˆYnX|j  ¡S)Nz'Cannot switch to MAINLOOP from MAINLOOPÚ switch_out) rr rÚgetattrrkrlrmrvrtÚ ValueErrorÚswitch)r"Úcurrwrrr rz's    zBaseHub.switchc Csxtj|Žtj d|f¡tj ¡z| |¡Wn>tk rr}z tj d|f¡tj ¡W5d}~XYnXdS)NzRemoving descriptor: %r z(Exception while removing descriptor! %r )r0Úprint_exceptionrlÚstderrrÚflushrnrj)r"rrmÚerrr Úsquelch_exception8s  zBaseHub.squelch_exceptioncCs tdƒ‚dS)NzImplement this in a subclass)ÚNotImplementedError)r"rrrr ÚwaitBsz BaseHub.waitcCsdS)NgN@rr&rrr Ú default_sleepEszBaseHub.default_sleepcCs|j}|sdS|ddSrc)rI)r"Útrrr Ú sleep_untilHszBaseHub.sleep_untilcOsæ|jrtdƒ‚zÄd|_d|_|js²|jr2| ¡q"| ¡|jrH| ¡| |  ¡¡|jrd|  ¡| ¡|  ¡}|dkr†|  ¡}n ||  ¡}|dkr¦|  |¡q|  d¡qd|_|jdd…=|jdd…=W5d|_d|_XdS)z/Run the runloop until abort is called. zAlready running!FTNr)rHr:rGrDrsÚprepare_timersrNrTÚ fire_timersrErVr…rƒr‚rLrIrJ)r"ÚaÚkwZ wakeup_whenZ sleep_timerrr rFNs6      z BaseHub.runFcCsB|jr d|_|r>|jt ¡k s&tdƒ‚| ddd„¡| ¡dS)amStop the runloop. If run is executing, it will exit after completing the next runloop iteration. Set *wait* to True to cause abort to switch to the hub immediately and wait until it's finished processing. Waiting for the hub will only work from the main greenthread; all other greenthreads will become unreachable. Tz5Can't abort with wait from inside the hub's greenlet.rcSsdSrrrrrr r-„r.zBaseHub.abort..N)rHrGrr rÚschedule_call_globalrz)r"r‚rrr Úabortus ÿz BaseHub.abortcCs|jrtj|Žtj ¡dSr©rMr0r|rlr}r~)r"rmrrr rk‰s z!BaseHub.squelch_generic_exceptioncCs|jrtj|Žtj ¡dSrrŒ)r"rrmrrr Úsquelch_timer_exceptionŽs zBaseHub.squelch_timer_exceptioncCs"| ¡|j}|j ||f¡|Sr)rErrJrY)r"rZscheduled_timerrr Ú add_timer“szBaseHub.add_timercCsr|jd7_t|jƒt|jƒ}|dkrn|d|jkrnd|_dd„|jDƒ|_dd„|jDƒ|_t |j¡dS)NrAièércSsg|]}|djs|‘qS©rA©Úcalled©Ú.0r„rrr Ú s z*BaseHub.timer_canceled..cSsg|]}|djs|‘qSrr‘r“rrr r•žs )rLÚlenrIrJÚheapqÚheapify)r"rZ len_timersrrr Útimer_canceled˜szBaseHub.timer_canceledcCsLtj}|j}|jD](}|djr0|jd8_q|||ƒq|jdd…=dS)NrA)r—ÚheappushrIrJr’rL)r"ršr„Úitemrrr r†¡s   zBaseHub.prepare_timerscOs"tj||f|ž|Ž}| |¡|S)azSchedule a callable to be called after 'seconds' seconds have elapsed. Cancel the timer if greenlet has exited. seconds: The number of seconds to wait. cb: The callable to call after the given time. *args: Arguments to pass to the callable when called. **kw: Keyword arguments to pass to the callable when called. )rZ LocalTimerrŽ©r"rrÚargsr‰r„rrr Úschedule_call_local«s zBaseHub.schedule_call_localcOs"tj||f|ž|Ž}| |¡|S)a³Schedule a callable to be called after 'seconds' seconds have elapsed. The timer will NOT be canceled if the current greenlet has exited before the timer fires. seconds: The number of seconds to wait. cb: The callable to call after the given time. *args: Arguments to pass to the callable when called. **kw: Keyword arguments to pass to the callable when called. )rÚTimerrŽrœrrr rŠ·s  zBaseHub.schedule_call_globalcCs”|j}tj}|r|d}|d}|d}||kr2q||ƒz |jrR|jd8_n|ƒWq |jk rr‚Yq | |t ¡¡Yq Xq dS)NrrA) rIr—Úheappopr’rLÚSYSTEM_EXCEPTIONSrrlrm)r"Úwhenr„r ÚnextÚexprrrr r‡Äs" zBaseHub.fire_timerscCs|jt ¡Sr)rBrÚvaluesr&rrr Ú get_readersßszBaseHub.get_readerscCs|jt ¡Sr)rBrr¥r&rrr Ú get_writersâszBaseHub.get_writerscCst|jƒt|jƒSr)r–rIrJ)Zhubrrr Úget_timers_countåszBaseHub.get_timers_countcCs|r t|_nt|_dSr)r/rKr©r"Úvaluerrr Úset_debug_listenersèszBaseHub.set_debug_listenerscCs ||_dSr)rMr©rrr Úset_timer_exceptionsîszBaseHub.set_timer_exceptions)N)N)F)(r%r)r*Ú__doc__ÚKeyboardInterruptÚ SystemExitr¡rrr#rTrVr\r`rbr^rfrnrsrvrzr€r‚rƒr…rFr‹rkrrŽr™r†ržrŠr‡r¦r§r¨r«r¬rrrr r@nsF %    '     r@)rqr—r rrlr0rRrUr Zitimerr Ú ImportErrorrZ eventlet.hubsrprZeventlet.supportrrrÚtimerWrrrrrhr/r?r@rrrr Ús>     %