o tPfX@s&dZddlmZddlmZddlmZddlZddlmZddlmZddlm Z dd l m Z dd l mZdd l mZdd lmZdd lmZddlmZedjed<dded<dgZee jZee jZGdddeZddZ GdddeZ!ddZ"e"ddl#m$Z$e$e%ddS)zO Internal module, support for the linkable protocol for "event" like objects. )absolute_import)division)print_functionN) get_objects)greenlet)error)thread_mod_name)get_hub_noargs)get_hub_if_exists)InvalidSwitchError)InvalidThreadUseError)Timeoutr getcurrentcCdSNrrrZ/var/www/html/humari/django-venv/lib/python3.10/site-packages/gevent/_abstract_linkable.pysr greenlet_initAbstractLinkablec@seZdZdZddZdS) _FakeNotifierpendingcCs d|_dS)NFrselfrrr__init__* z_FakeNotifier.__init__N)__name__ __module__ __qualname__ __slots__rrrrrr%s rcs ddlmfddtDS)NrHubcs(i|]}t|r|jdur|j|qSr) isinstanceloopparent).0xr!rr /s z&get_roots_and_hubs..) gevent.hubr"rrrr!rget_roots_and_hubs-s  r*c@seZdZdZd1ddZddZddZd d Zd d Zd dZ ddZ ddZ ddZ ddZ ddZddZddZddZdd Zd!d"Zd#d$Zd%d&Zd'd(Zefd)d*Zd+d,Zd1d-d.Zd/d0ZdS)2r)hub_links _notifier _notify_all __weakref__NcCsg|_d|_d|_||_dS)NT)r,r-r.r+rr+rrrrXs zAbstractLinkable.__init__cCs t|jSr)lenr,rrrr linkcounts zAbstractLinkable.linkcountcCstr)NotImplementedErrorrrrrreadyszAbstractLinkable.readycCs.t|s td|f|j||dS)a Register a callback to call when this object is ready. *callback* will be called in the :class:`Hub `, so it must not use blocking gevent API. *callback* will be passed one argument: this instance. zExpected callable: %rN)callable TypeErrorr,append_check_and_notifyrcallbackrrrrawlinks  zAbstractLinkable.rawlinkcCsVz|j|Wn tyYnw|js%|jdur'|jjr)|jdSdSdSdS)z*Remove the callback set by :meth:`rawlink`N)r,remove ValueErrorr-rstopr9rrrunlinks  zAbstractLinkable.unlinkcCtSr)_allocate_thread_lockrrrr_allocate_lockzAbstractLinkable._allocate_lockcCr@r)rrrrr _getcurrentrCzAbstractLinkable._getcurrentcCr@r)_get_thread_identrrrrrErCz"AbstractLinkable._get_thread_identcCs |j}|dur n|jr|j|urd|_d}nnnq|jdur/|r$tnt}|jdur/||_|jdurD|jjtkrDt|jtt|jSr)r+deadget_hubr thread_identrEr r)rcreatemy_hub current_hubrrr _capture_hubs.   zAbstractLinkable._capture_hubcCs|r?|jrA|jsCd}z|d}Wn tyYnw|dur,|j|jg|_dSd|_z |gWd|_dSd|_wdSdSdS)NF)r4r,r-rLr r$ run_callback _notify_linksr0rrrr8s   z"AbstractLinkable._check_and_notifyc Cs|sgS|j }|d}t}|jdur|jnt}g}|r|r'|s' |S|d}t|}||vr||z'|zz||Wnt yS| |YnwW| n| wWn|durv|j ||fgt Rnddl} | Y||ur |S|s|S)Nr)r.setr+r r4popidadd_drop_lock_for_switch_outgreenlet_errorr7_acquire_lock_for_switch_in handle_errorsysexc_info traceback print_exc) rlinksonly_while_ready final_linkdoner+ unswitchedlinkid_linkr[rrr_notify_link_listsF     !z"AbstractLinkable._notify_link_listc Cs|j}|dur |dSz)||j}|r&||}|||j|W|j|us3J|j|fd|_n|j|usCJ|j|fd|_w||rT||dSdSr)r-r8rdr,extend _handle_unswitched_notifications)rarrived_while_waitingnotifierraun2rrrrOs&     zAbstractLinkable._notify_linksc Csd}d}|j }|r|r|s|||dS|d}d}t|dddkrjtt|ddtrj|j}|j}|durJt |drC|j}n|j}|dus:|durZ|durUt }| |}|durj|j durj|j |||duss|j dur{|||d}|s dSdS)NFrrswitch__self__r$T)r.r4+_AbstractLinkable__print_unswitched_warningrRgetattrr#rrkr%hasattrr*getr$run_callback_threadsafe) rraroot_greenlets printed_tbr^rbr+gletr%rrrrf^s<       z1AbstractLinkable._handle_unswitched_notificationscCsFtd|d|dtjd|s!d}tddtjdddl}|dSdS) Nz+gevent: error: Unable to switch to greenletfromz,; crossing thread boundaries is not allowed.)fileTzNgevent: error: This is a result of using gevent objects from multiple threads,z!and is a bug in the calling code.r)printrYstderrr[ print_stack)rrbrrr[rrr__print_unswitched_warnings z+AbstractLinkable.__print_unswitched_warningcCs^|durdS|||jdur+|jjr-z |jjd|WdSty*YdSwdSdSNr)r?r-argsr<r=)robjrrr_quiet_unlink_alls  z"AbstractLinkable._quiet_unlink_allc CsXtj}|r ||n |jjd|z||jd}W||dS||wrz) rrjr;r-r{r7_switch_to_hubr+r})rr;resume_this_greenletrrr__wait_to_be_notifieds  z&AbstractLinkable.__wait_to_be_notifiedcCsH|z |}W|n|w||ur"td|jj|fdS)Nz!Invalid switch into %s.wait(): %r)rUrjrWr __class__r)rthe_hubresultrrrr~s zAbstractLinkable._switch_to_hubcCrrrrrrrrWz,AbstractLinkable._acquire_lock_for_switch_incCrrrrrrrrUrz*AbstractLinkable._drop_lock_for_switch_outc Cszt|.}z|dWWddS|y2}z||ur!WYd}~WddSd}~ww1s6wYdS)a The core of the wait implementation, handling switching and linking. This method is NOT safe to call from multiple threads. ``self.hub`` must be initialized before entering this method. The hub that is set is considered the owner and cannot be changed while this method is running. It must only be called from the thread where ``self.hub`` is the current hub. If *catch* is set to ``()``, a timeout that elapses will be allowed to be raised. :return: A true value if the wait succeeded without timing out. That is, a true return value means we were notified and control resumed in this greenlet. TNF)r _start_new_or_dummy&_AbstractLinkable__wait_to_be_notified)rtimeoutcatchtimerexrrr _wait_cores  zAbstractLinkable._wait_corecCrrr)rwaited wait_successrrr_wait_return_valuesz#AbstractLinkable._wait_return_valuecCsH|d|r|dd}|jr|d|S||}|d|S)NTF)rLr4rr-rr)rrrgotitrrr_waits     zAbstractLinkable._waitcCsd|_d|_dS)a This method was added in Python 3.9 and is called by logging.py ``_after_at_fork_child_reinit_locks`` on Lock objects. It is also called from threading.py, ``_after_fork`` in ``_reset_internal_locks``, and that can hit ``Event`` objects. Subclasses should reset themselves to an initial state. This includes unlocking/releasing, if possible. This method detaches from the previous hub and drops any existing notifier. N)r+r-rrrr_at_fork_reinit s z AbstractLinkable._at_fork_reinitr)rrrr rr2r4r;r?rBrDrErLr8rdrOrfrlr}rr~rWrUr rrrrrrrrr:s2 ) %3?:  !  cCs tdSr)rrrrr_initrr)import_c_accelzgevent.__abstract_linkable)&__doc__ __future__rrrrYgcrrrrVgevent._compatrgevent._hub_localr rGr gevent.exceptionsr r gevent.timeoutr __import__rlocals__all__ get_identrE allocate_lockrAobjectrr*rr gevent._utilrglobalsrrrrs<               d