B H/\ @sdZddlmZddlmZddlmZddlZddlmZddl m Z ddl m Z e d jed <d d ed <dgZGdddeZddZeddlmZeeddS)zO Internal module, support for the linkable protocol for "event" like objects. )absolute_import)division)print_functionN)get_hub_noargs)InvalidSwitchError)TimeoutZgreenlet getcurrentcCsdS)Nr r r 8lib/python3.7/site-packages/gevent/_abstract_linkable.pysr greenlet_initAbstractLinkablec@sfeZdZdZddZddZddZdd Zd d Zd d Z ddZ e fddZ ddZ dddZdS)r )hub_links _notifier _notify_all __weakref__cCst|_d|_d|_d|_dS)NT)setrrrr)selfr r r __init__ szAbstractLinkable.__init__cCs t|jS)N)lenr)rr r r linkcountHszAbstractLinkable.linkcountcCstdS)N)NotImplementedError)rr r r readyLszAbstractLinkable.readycCs<|r8|jr8|js8|jdkr&t|_|jj|j|_dS)N)rrrrget_hubZloopZ run_callback _notify_links)rr r r _check_and_notifyPs z"AbstractLinkable._check_and_notifycCs.t|std|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 TypeErrorraddr)rcallbackr r r rawlinkXs zAbstractLinkable.rawlinkcCs*|j||js&|jdk r&|jdS)z*Remove the callback set by :meth:`rawlink`N)rdiscardrstop)rr r r r unlinkfs zAbstractLinkable.unlinkc Cs|j}t|j}zxz|D]r}|js,|s,P||jkr8qz8y ||Wn&|jj||fftYnXWdt |ddr| |XqWWd|j|kst d|_X|js||jkr| dS)NZ auto_unlink) rrrrrrZ handle_errorsysexc_infogetattrr$AssertionErrorr)rZnotifierZtodolinkr r r rrs$    $ zAbstractLinkable._notify_linksc Cstj}||z~t|j}y6|jdkr4t|_|j}||k rTtd|fdS|k r}z||k rrdSd}~XYnXWdQRXWd||XdS)Nz$Invalid switch into Event.wait(): %rTF) rswitchr!rZ_start_new_or_dummyrrrr$)rtimeoutZcatchr*Ztimerresultexr r r _wait_cores      zAbstractLinkable._wait_corecCsdS)Nr )rZwaitedZ wait_successr r r _wait_return_valuesz#AbstractLinkable._wait_return_valueNcCs*|r|ddS||}|d|S)NFT)rr/r.)rr+Zgotitr r r _waits  zAbstractLinkable._wait)N)__name__ __module__ __qualname__ __slots__rrrrr!r$rrr.r/r0r r r r r s( + cCs tdS)N)r r r r r _initsr5)import_c_accelzgevent.__abstract_linkable)__doc__Z __future__rrrr%Zgevent._hub_localrrZgevent.exceptionsrZgevent.timeoutr __import__rlocals__all__objectr r5Z gevent._utilr6globalsr r r r s       +